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()