/*
* @file non-worker-app
* @desc This app listens on a different port from the pe-worker
* app. Processes logging messages received on the redis
* subsriber channel
*/
'use strict';
const express = require('express');
const http = require('http');
const config = require(__dirname + '/config');
const logger = require(__dirname + '/loggers/logger');
const peController = require(__dirname + '/controllers/pe-controller');
let app = express();
app.set('port', config.networking.pnr_enforcement_non_worker_port);
app.set('host', config.networking.pnr_enforcement_non_worker_host);
app.get('/api/v1/status', peController.redisChannelStatusHandler);
const startServer = function () {
Iif (!process.env.WORKER_NAME) {
process.env.WORKER_NAME = 'non_pe_worker';
}
const server = http.createServer(app);
server.on('error', function(e) {
logger.error('pnr-enforcement non worker server listening error - "' +
e + '"');
});
server.listen(app.get('port'), app.get('host'), function() {
logger.info(process.env.WORKER_NAME + ' listening on ' +
app.get('host') + ':' + app.get('port'));
peController.initRedisChannelSubscriber();
peController.redisSubcriberChannelHandler();
});
};
module.exports = startServer;
|