NodeJsProcess.js

exports.newNodeJsProcess = function () {

    let thisObject = {
        initialize: initialize
    }

    return thisObject;

    function initialize() {

        process.on('uncaughtException', function (err) {
            SA.logger.error('Task Server -> Node JS Process -> uncaughtException -> err.message = ' + err.message)
            SA.logger.error('Task Server -> Node JS Process -> uncaughtException -> err.stack = ' + err.stack)
            if (err !== undefined) { SA.logger.error(err.stack) }
            TS.projects.foundations.functionLibraries.nodeJSFunctions.exitProcess()
        })

        process.on('unhandledRejection', (reason, p) => {
            SA.logger.error('Task Server -> Node JS Process -> unhandledRejection -> reason = ' + JSON.stringify(reason))
            SA.logger.error('Task Server -> Node JS Process -> unhandledRejection -> p = ' + JSON.stringify(p))
            if (reason !== undefined) { SA.logger.error(reason.stack) }
            TS.projects.foundations.functionLibraries.nodeJSFunctions.exitProcess()
        })

        process.on('exit', function (config) {

            if (TS.projects.foundations.globals.taskConstants.TASK_NODE !== undefined) {
                /* We send an event signaling that the Task is being terminated. */
                let key = TS.projects.foundations.globals.taskConstants.TASK_NODE.name + '-' + TS.projects.foundations.globals.taskConstants.TASK_NODE.type + '-' + TS.projects.foundations.globals.taskConstants.TASK_NODE.id

                TS.projects.foundations.globals.taskConstants.EVENT_SERVER_CLIENT_MODULE_OBJECT.raiseEvent(key, 'Stopped') // Meaning Task Stopped
                TS.projects.foundations.globals.taskConstants.EVENT_SERVER_CLIENT_MODULE_OBJECT.finalize()
                TS.projects.foundations.globals.taskConstants.EVENT_SERVER_CLIENT_MODULE_OBJECT = undefined
            }

            //SA.logger.debug('Task Server -> Node JS Process -> process.on.exit -> About to exit -> config = ' + config)
        })

        /* Here we listen for the message to stop this Task / Process coming from the Task Manager, which is the parent of this node js process. */
        process.on('message', message => {
            if (message === 'Stop this Task') {

                TS.projects.foundations.globals.taskVariables.IS_TASK_STOPPING = true;

                /*
                There are some process that might no be able to end gracefully, for example the ones schedule to process information in a future day or month.
                In order to be sure that the process will be terminated, we schedule one forced exit in 2 minutes from now.
                */
                let key = TS.projects.foundations.globals.taskConstants.TASK_NODE.name + '-' + TS.projects.foundations.globals.taskConstants.TASK_NODE.type
                SA.logger.info('Task Server -> Node JS Process -> process.on -> Stopping Task ' + key + '. Nodejs process will be exited in less than 1 minute.')
                setTimeout(TS.projects.foundations.functionLibraries.nodeJSFunctions.exitProcess, 60000);
            }
        });

    }
}