crossbow/dist/command.run.execute.js

"use strict";
var command_run_1 = require("./command.run");
var reporter_resolve_1 = require("./reporter.resolve");
var task_resolve_1 = require("./task.resolve");
var Rx = require("rx");
var command_run_context_1 = require("./command.run.context");
var debug = require("debug")("cb:command.run.execute");
(function (RunCommandReportTypes) {
    RunCommandReportTypes[RunCommandReportTypes["NoTasks"] = "NoTasks"] = "NoTasks";
    RunCommandReportTypes[RunCommandReportTypes["Setup"] = "Setup"] = "Setup";
    RunCommandReportTypes[RunCommandReportTypes["Complete"] = "Complete"] = "Complete";
    RunCommandReportTypes[RunCommandReportTypes["TaskReport"] = "TaskReport"] = "TaskReport";
})(exports.RunCommandReportTypes || (exports.RunCommandReportTypes = {}));
var RunCommandReportTypes = exports.RunCommandReportTypes;
function executeRunCommand(trigger) {
    var cli = trigger.cli, input = trigger.input, config = trigger.config, reporter = trigger.reporter;
    var _a = command_run_1.getRunCommandSetup(trigger), tasks = _a.tasks, sequence = _a.sequence, runner = _a.runner;
    /**
     * Never continue if any tasks were flagged as invalid and we've not handed
     * off
     */
    if (tasks.invalid.length) {
        reporter({
            type: reporter_resolve_1.ReportTypes.TaskErrors,
            data: {
                tasks: tasks.all,
                taskCollection: cli.input.slice(1),
                input: input,
                config: config
            }
        });
        return {
            setup: {
                sequence: sequence,
                tasks: tasks,
                errors: []
            },
            update$: Rx.Observable.empty()
        };
    }
    debug("~ run mode from config in mode: '" + config.runMode + "'");
    /**
     * Report task list that's about to run
     */
    reporter({ type: reporter_resolve_1.ReportTypes.TaskList, data: { sequence: sequence, cli: cli, titlePrefix: "", config: config } });
    /**
     * Get a run context for this execution.
     * note: This could take some time as it may need
     * to hash directories etc. A run context is just a key=>value
     * map of read-only values.
     */
    return {
        setup: {
            sequence: sequence,
            tasks: tasks,
            errors: []
        },
        update$: command_run_context_1.default(tasks.all, trigger)
            .flatMap(function (runContext) {
            if (trigger.config.runMode === task_resolve_1.TaskRunModes.parallel) {
                return runner.parallel(runContext);
            }
            return runner.series(runContext);
        }).share()
    };
}
Object.defineProperty(exports, "__esModule", { value: true });
exports.default = executeRunCommand;
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiY29tbWFuZC5ydW4uZXhlY3V0ZS5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbIi4uL3NyYy9jb21tYW5kLnJ1bi5leGVjdXRlLnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiI7QUFBQSw0QkFBaUQsZUFBZSxDQUFDLENBQUE7QUFDakUsaUNBQTBCLG9CQUFvQixDQUFDLENBQUE7QUFDL0MsNkJBQWtDLGdCQUFnQixDQUFDLENBQUE7QUFJbkQsSUFBTyxFQUFFLFdBQVcsSUFBSSxDQUFDLENBQUM7QUFDMUIsb0NBQXVCLHVCQUF1QixDQUFDLENBQUE7QUFLL0MsSUFBTSxLQUFLLEdBQUcsT0FBTyxDQUFDLE9BQU8sQ0FBQyxDQUFDLHdCQUF3QixDQUFDLENBQUM7QUFFekQsV0FBWSxxQkFBcUI7SUFDN0IseURBQW9CLFNBQVMsYUFBQSxDQUFBO0lBQzdCLHVEQUFvQixPQUFPLFdBQUEsQ0FBQTtJQUMzQiwwREFBb0IsVUFBVSxjQUFBLENBQUE7SUFDOUIsNERBQW9CLFlBQVksZ0JBQUEsQ0FBQTtBQUNwQyxDQUFDLEVBTFcsNkJBQXFCLEtBQXJCLDZCQUFxQixRQUtoQztBQUxELElBQVkscUJBQXFCLEdBQXJCLDZCQUtYLENBQUE7QUErQkQsMkJBQTBDLE9BQXVCO0lBRXRELHFCQUFHLEVBQUUscUJBQUssRUFBRSx1QkFBTSxFQUFFLDJCQUFRLENBQVk7SUFDL0MsSUFBQSw4Q0FBa0UsRUFBM0QsZ0JBQUssRUFBRSxzQkFBUSxFQUFFLGtCQUFNLENBQXFDO0lBRW5FOzs7T0FHRztJQUNILEVBQUUsQ0FBQyxDQUFDLEtBQUssQ0FBQyxPQUFPLENBQUMsTUFBTSxDQUFDLENBQUMsQ0FBQztRQUV2QixRQUFRLENBQUM7WUFDTCxJQUFJLEVBQUUsOEJBQVcsQ0FBQyxVQUFVO1lBQzVCLElBQUksRUFBRTtnQkFDRixLQUFLLEVBQUUsS0FBSyxDQUFDLEdBQUc7Z0JBQ2hCLGNBQWMsRUFBRSxHQUFHLENBQUMsS0FBSyxDQUFDLEtBQUssQ0FBQyxDQUFDLENBQUM7Z0JBQ2xDLFlBQUs7Z0JBQ0wsY0FBTTthQUNXO1NBQ3hCLENBQUMsQ0FBQztRQUVILE1BQU0sQ0FBQztZQUNILEtBQUssRUFBRTtnQkFDSCxrQkFBUTtnQkFDUixZQUFLO2dCQUNMLE1BQU0sRUFBRSxFQUFFO2FBQ2I7WUFDRCxPQUFPLEVBQU8sRUFBRSxDQUFDLFVBQVUsQ0FBQyxLQUFLLEVBQUU7U0FDdEMsQ0FBQztJQUNOLENBQUM7SUFFRCxLQUFLLENBQUMsc0NBQW9DLE1BQU0sQ0FBQyxPQUFPLE1BQUcsQ0FBQyxDQUFDO0lBRTdEOztPQUVHO0lBQ0gsUUFBUSxDQUFDLEVBQUMsSUFBSSxFQUFFLDhCQUFXLENBQUMsUUFBUSxFQUFFLElBQUksRUFBRSxFQUFDLGtCQUFRLEVBQUUsUUFBRyxFQUFFLFdBQVcsRUFBRSxFQUFFLEVBQUUsY0FBTSxFQUFDLEVBQUMsQ0FBQyxDQUFDO0lBRXZGOzs7OztPQUtHO0lBQ0gsTUFBTSxDQUFDO1FBQ0gsS0FBSyxFQUFFO1lBQ0gsa0JBQVE7WUFDUixZQUFLO1lBQ0wsTUFBTSxFQUFFLEVBQUU7U0FDYjtRQUNELE9BQU8sRUFBRSw2QkFBVSxDQUFDLEtBQUssQ0FBQyxHQUFHLEVBQUUsT0FBTyxDQUFDO2FBQ2xDLE9BQU8sQ0FBQyxVQUFDLFVBQXNCO1lBQzVCLEVBQUUsQ0FBQyxDQUFDLE9BQU8sQ0FBQyxNQUFNLENBQUMsT0FBTyxLQUFLLDJCQUFZLENBQUMsUUFBUSxDQUFDLENBQUMsQ0FBQztnQkFDbkQsTUFBTSxDQUFDLE1BQU0sQ0FBQyxRQUFRLENBQUMsVUFBVSxDQUFDLENBQUM7WUFDdkMsQ0FBQztZQUNELE1BQU0sQ0FBQyxNQUFNLENBQUMsTUFBTSxDQUFDLFVBQVUsQ0FBQyxDQUFDO1FBQ3JDLENBQUMsQ0FBQyxDQUFDLEtBQUssRUFBRTtLQUNqQixDQUFDO0FBQ04sQ0FBQztBQTFERDttQ0EwREMsQ0FBQSJ9