apeman-infr/lib/apeman_infr.js

"use strict";

const argx = require('argx'),
    async = require('async'),
    arrayreduce = require('arrayreduce'),
    arrayfilter = require('arrayfilter'),
    apemanfile = require('apemanfile'),
    apemancwd = require('apemancwd'),
    listInfrs = require('./infring/list_infrs'),
    buildInfrs = require('./infring/build_infrs'),
    removeInfrs = require('./infring/remove_infrs');

let concatArray = arrayreduce.arrayConcat(),
    rejectEmpty = arrayfilter.emptyReject();

/** @lends apemanInfr */
function apemanInfr(names, options, callback) {
    let args = argx(arguments);
    callback = args.pop('function') || argx.noop;
    options = args.pop('object') || {};
    names = args.remain().filter(rejectEmpty).reduce(concatArray, []);

    let cwd = apemancwd.create({prefix: 'apeman-infr'});

    async.waterfall([
        (callback) => {
            apemanfile.load(options.configuration, callback);
        },
        (apemanfile, callback) => {
            cwd.chdir(apemanfile.$cwd);

            let duplicate = [
                    options.list,
                    options.delete,
                    options.rebuild
                ].filter((command) => {
                    return !!command;
                }).length > 1;
            if (duplicate) {
                callback(new Error(`Invalid option: ${JSON.stringify(options, null, 2)}`));
                return;
            }

            if (options.rebuild) {
                async.series([
                    (callback) => {
                        removeInfrs(apemanfile, names, {
                            force: options.force
                        }, callback);
                    },
                    (callback) => {
                        buildInfrs(apemanfile, names, {
                            force: options.force
                        }, callback);
                    }
                ], callback);
                return;
            }

            if (options.list) {
                listInfrs(apemanfile, names, {}, callback);
                return;
            }
            if (options.delete) {
                removeInfrs(apemanfile, names, {
                    force: options.force
                }, callback);
                return;
            }
            buildInfrs(apemanfile, names, {
                force: options.force
            }, callback);
        }
    ], (err) => {
        cwd.restoreAll();
        callback(err);
    });
}


module.exports = apemanInfr;