forked.js

let file = process.argv[2];
process.title = process.argv[3];
process.argv.splice(1, 1);
process.argv.splice(2, 1);


function send(message, retries = 0) {
    try {
        process.send(message)
    } catch (err) {
        if (retries < 3) {
            return setImmediate(() => send(message, ++retries));
        }
        throw err;
    }
}

try {
    let forkedModule = require(file);
    process.on('message', async message => {
        try {
            if (message.prop) {
                if (!forkedModule[message.prop]) {
                    return send({error: 'TypeError: ' + message.prop + ' is not a function', stack: ''})
                }
                let response = await forkedModule[message.prop](...message.args);
                send({response});
            } else {
                let response = await forkedModule(...message.args);
                send({response});
            }
        } catch(err) {
            send({error: err.message, stack: err.stack});
        }
    });
} catch (err) {
    send({error: err.message, stack: err.stack, failed: true});
}

// Watch parent exit when it dies
process.on('disconnect', () => process.exit());