apeman-d/lib/apeman_d.js

"use strict";

const argx = require('argx'),
    apemanfile = require('apemanfile'),
    fs = require('fs'),
    os = require('os'),
    path = require('path'),
    stringcase = require('stringcase'),
    startDaemon = require('./daemoning/start_daemon'),
    stopDaemon = require('./daemoning/stop_daemon'),
    showDaemon = require('./daemoning/show_daemon'),
    deleteDaemon = require('./daemoning/delete_daemon'),
    kill = require('./processing/kill'),
    async = require('async');

/** @lends apemanD */
function apemanD(action, script, options, callback) {
    let args = argx(arguments);
    action = args.shift('string');
    script = args.shift('string');
    callback = args.pop('function') || argx.noop;
    options = args.pop('object') || {};

    async.waterfall([
        (callback) => {
            apemanfile.load(options.configuration, callback);
        },
        (apemanfile, callback) => {
            let here = process.cwd(),
                cwd = apemanfile.$cwd || process.cwd();

            async.series([
                (callback) => {
                    fs.exists(cwd, (exists) => {
                        if (exists) {
                            process.chdir(cwd);
                            callback(null);
                        } else {
                            callback(new Error(`[apeman-d] cwd not exists: ${cwd}`));
                        }
                    });
                },
                (callback) => {
                    switch (String(action).trim()) {
                        case 'start':
                            startDaemon(apemanfile, script, options, callback);
                            break;
                        case 'stop':
                            stopDaemon(apemanfile, script, options, callback);
                            break;
                        case 'show':
                            showDaemon(apemanfile, script, options, callback);
                            break;
                        case 'delete':
                            deleteDaemon(apemanfile, script, options, callback);
                            break;
                    }
                },
                (callback) => {
                    process.chdir(here);
                    callback(null);
                }
            ], (err, results) => {
                callback(err, results[1]);
            });
        }

    ], callback);
}
apemanD.start = apemanD.bind(apemanD, 'start');
apemanD.stop = apemanD.bind(apemanD, 'stop');
apemanD.show = apemanD.bind(apemanD, 'show');
apemanD.delete = apemanD.bind(apemanD, 'delete');

apemanD.kill = kill;

module.exports = apemanD;