app.js

'use strict';

var createError = require('http-errors');
var express = require('express');
const handlebars = require('handlebars')
const exphbs = require('express-handlebars');
const {allowInsecurePrototypeAccess} = require('@handlebars/allow-prototype-access')
 

var path = require('path');
var cookieParser = require('cookie-parser');
var logger = require('morgan');
const winston = require('./winston/config')


var RED = require('node-red');
var http = require('http');

const probe = require('kube-probe')




var indexRouter = require('./routes/index');
//var discoveryRouter = require('./routes/discovery');

var app = express();
var server = http.createServer(app);

// Create the settings object - see default settings.js file for other options
var settings = {
  httpAdminRoot: "/editor",
  httpNodeRoot: "/",
  userDir: "./workspace",
  flowFilePretty: true,
  flowFile: "flows.json",
  nodesDir: "./custom-nodes",
  credentialSecret: '(get this from keystore)',
  disableEditor: false,
  httpNodeCors: true,
  ui: { path: 'dashboard' },

  httpNodeMiddleware: function (req, res, next) {
    // Perform any processing on the request.
    // Be sure to call next() if the request should be passed
    // to the relevant HTTP In node.

    //TODO copy Istio/Jaeger HTTP headers to responce for tracing
    next();
  },

  // enables global context
  functionGlobalContext: {
    os: require('os'),
  },

  // Editor Theme and project configuration
  editorTheme: {
    projects: {
      enabled: true
    }
  },
  // adminAuth: {
  //   users: [
  //     {
  //       username: "admin",
  //       // use 'node-red-admin hash-pw' to create pw hash, marty
  //       password: "$2a$08$MLbFBa8uhtcH3gGC4k0xruUfRtXh5YSBc/VOkxia7UG8Z/RN/kL5O",
  //       permissions: "*"
  //     },
  //   ],
  //   default: [
  //     {
  //       permissions: "read"
  //     }
  //   ]
  // },

};

RED.init(server, settings);


// Serve the editor UI
app.use(settings.httpAdminRoot, RED.httpAdmin);

// Serve the http nodes UI from /api
app.use(settings.httpNodeRoot, RED.httpNode);


// view engine setup
app.set('views', path.join(__dirname, 'views'));

app.engine('handlebars', exphbs({ 
  handlebars: allowInsecurePrototypeAccess(handlebars),
  extname: '.handlebars' 
  }));
app.set('view engine', 'handlebars');


app.use(logger('dev'));
app.use(express.json());
app.use(express.urlencoded({ extended: false }));
app.use(cookieParser());
app.use(express.static(path.join(__dirname, 'public')));

app.use('/', indexRouter);
//app.use('/discovery', discoveryRouter);

// add kube probes (healthcheck and readiness check) to express app
// /api/health/liveness
// /api/health/readiness
probe(app, {
  readinessURL: '/api/health/readiness',
  readinessCallback: function (request, response) {
    winston.info("readiness probe triggered")
    return response.end('ready')
  },
  livenessURL: '/api/health/liveness',
  livenessCallback: function (request, response) {
    winston.info("liveness probe triggered")
    return response.end('alive')
  },
});
winston.info('Added kubernetes probes');



// catch 404 and forward to error handler
app.use(function (req, res, next) {
  next(createError(404));
});

// error handler
app.use(function (err, req, res, next) {
  // set locals, only providing error in development
  res.locals.message = err.message;
  res.locals.error = req.app.get('env') === 'development' ? err : {};

  // render the error page
  res.status(err.status || 500);
  res.render('error');
});

module.exports = { expressApp: app, RED: RED, server: server }