haraka.js

#!/usr/bin/env node

'use strict';
const path = require('path');
const makePathJoin = () => path.join(process.env.HARAKA, 'node_modules');

if (!process.env.HARAKA) {
    console.warn("WARNING: Not running installed Haraka - command line arguments ignored")
}

// this must be set before "server.js" is loaded
process.env.HARAKA = process.env.HARAKA || path.resolve('.');
try {
    require.paths.push(makePathJoin());
}
catch (e) {
    process.env.NODE_PATH = process.env.NODE_PATH ?
        (`${process.env.NODE_PATH}:${makePathJoin()}`) :
        (makePathJoin());
    require('module')._initPaths(); // Horrible hack
}

const utils = require('haraka-utils');
const logger = require('./logger');
const server = require('./server');

exports.version = utils.getVersion(__dirname)

process.on('uncaughtException', err => {
    if (err.stack) {
        err.stack.split("\n").forEach(line => logger.crit(line));
    }
    else {
        logger.crit(`Caught exception: ${JSON.stringify(err)}`);
    }
    logger.dump_and_exit(1);
});

let shutting_down = false;
const signals = ['SIGINT'];

if (process.pid === 1) signals.push('SIGTERM')

for (const sig of signals) {
    process.on(sig, () => {
        if (shutting_down) return process.exit(1);
        shutting_down = true;
        const [, filename] = process.argv;
        process.title = path.basename(filename, '.js');

        logger.notice(`${sig} received`);
        logger.dump_and_exit(() => {
            if (server.cluster?.isMaster) {
                server.performShutdown();
            }
            else if (!server.cluster) {
                server.performShutdown();
            }
        });
    });
}

process.on('SIGHUP', () => {
    logger.notice('Flushing the temp fail queue');
    server.flushQueue();
});

process.on('exit', code => {
    if (shutting_down) return;
    const [, filename] = process.argv;
    process.title = path.basename(filename, '.js');

    logger.notice('Shutting down');
    logger.dump_logs();
});

logger.log('NOTICE', `Starting up Haraka version ${exports.version}`);

server.createServer();