haraka.js

Rama master · réplica de lectura del repositorio original.

#!/usr/bin/env node

'use strict'
const path = require('node: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 {
    process.env.NODE_PATH = process.env.NODE_PATH ? `${process.env.NODE_PATH}:${makePathJoin()}` : makePathJoin()
    require('node: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) => {
    logger.crit('Caught exception:', 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('SIGUSR2', () => {
    if (!server.cluster) {
        logger.notice('SIGUSR2 received, ignored: graceful restart requires smtp.ini nodes')
        return
    }
    // workers ignore it, a SIGUSR2 sent to the whole process group would otherwise kill them
    if (!server.cluster.isMaster) return
    logger.notice('SIGUSR2 received, restarting workers gracefully')
    server.gracefulRestart()
})

process.on('exit', () => {
    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()