crossbow/dist/command.run.pre-execution.js

"use strict";
var file = require("./file.utils");
var utils = require("./task.utils");
var file_utils_1 = require("./file.utils");
var reporter_resolve_1 = require("./reporter.resolve");
var Rx = require("rx");
var path_1 = require("path");
var config_1 = require("./config");
function createHashes(tasks, trigger) {
    var ifLookups = utils.concatProps(tasks, [], "ifChanged");
    if (!ifLookups.length)
        return Rx.Observable.empty();
    var existingFile = file.readOrCreateJsonFile(path_1.join(".crossbow", "history.json"), trigger.config.cwd);
    if (!existingFile.data.hashes) {
        existingFile.data.hashes = [];
    }
    return file.hashItems(ifLookups, trigger.config.cwd, existingFile.data.hashes)
        .do(function (hashResults) {
        // Write the hashes to disk
        trigger.config.signalObserver.onNext({
            type: config_1.SignalTypes.FileWrite,
            data: {
                file: existingFile,
                content: JSON.stringify({ hashes: hashResults.output }, null, 2)
            }
        });
    })
        .map(function (hashResults) {
        // Send in the marked hashes to the run context
        // so that matching tasks can be ignored
        return {
            "ifChanged": hashResults.markedHashes
        };
    })
        .take(1)
        .catch(function (e) {
        if (e.code === "ENOTDIR")
            e.type = file_utils_1.HashDirErrorTypes.HashNotADirectory;
        if (e.code === "ENOENT")
            e.type = file_utils_1.HashDirErrorTypes.HashPathNotFound;
        trigger.reporter({
            type: reporter_resolve_1.ReportTypes.HashDirError,
            data: {
                error: e,
                cwd: trigger.config.cwd
            }
        });
        return Rx.Observable.just({});
    });
}
exports.createHashes = createHashes;
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiY29tbWFuZC5ydW4ucHJlLWV4ZWN1dGlvbi5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbIi4uL3NyYy9jb21tYW5kLnJ1bi5wcmUtZXhlY3V0aW9uLnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiI7QUFFQSxJQUFZLElBQUksV0FBTSxjQUFjLENBQUMsQ0FBQTtBQUNyQyxJQUFZLEtBQUssV0FBTSxjQUFjLENBQUMsQ0FBQTtBQUN0QywyQkFBZ0MsY0FBYyxDQUFDLENBQUE7QUFDL0MsaUNBQThDLG9CQUFvQixDQUFDLENBQUE7QUFDbkUsSUFBTyxFQUFFLFdBQVcsSUFBSSxDQUFDLENBQUM7QUFDMUIscUJBQW1CLE1BQU0sQ0FBQyxDQUFBO0FBQzFCLHVCQUEwQixVQUFVLENBQUMsQ0FBQTtBQUVyQyxzQkFBNkIsS0FBYSxFQUFFLE9BQXVCO0lBRS9ELElBQU0sU0FBUyxHQUFHLEtBQUssQ0FBQyxXQUFXLENBQUMsS0FBSyxFQUFFLEVBQUUsRUFBRSxXQUFXLENBQUMsQ0FBQztJQUU1RCxFQUFFLENBQUMsQ0FBQyxDQUFDLFNBQVMsQ0FBQyxNQUFNLENBQUM7UUFBQyxNQUFNLENBQUMsRUFBRSxDQUFDLFVBQVUsQ0FBQyxLQUFLLEVBQUUsQ0FBQztJQUVwRCxJQUFNLFlBQVksR0FBRyxJQUFJLENBQUMsb0JBQW9CLENBQUMsV0FBSSxDQUFDLFdBQVcsRUFBRSxjQUFjLENBQUMsRUFBRSxPQUFPLENBQUMsTUFBTSxDQUFDLEdBQUcsQ0FBQyxDQUFDO0lBRXRHLEVBQUUsQ0FBQyxDQUFDLENBQUMsWUFBWSxDQUFDLElBQUksQ0FBQyxNQUFNLENBQUMsQ0FBQyxDQUFDO1FBQzVCLFlBQVksQ0FBQyxJQUFJLENBQUMsTUFBTSxHQUFHLEVBQUUsQ0FBQztJQUNsQyxDQUFDO0lBRUQsTUFBTSxDQUFDLElBQUksQ0FBQyxTQUFTLENBQUMsU0FBUyxFQUFFLE9BQU8sQ0FBQyxNQUFNLENBQUMsR0FBRyxFQUFFLFlBQVksQ0FBQyxJQUFJLENBQUMsTUFBTSxDQUFDO1NBQ3pFLEVBQUUsQ0FBQyxVQUFDLFdBQThCO1FBQy9CLDJCQUEyQjtRQUMzQixPQUFPLENBQUMsTUFBTSxDQUFDLGNBQWMsQ0FBQyxNQUFNLENBQUM7WUFDakMsSUFBSSxFQUFFLG9CQUFXLENBQUMsU0FBUztZQUMzQixJQUFJLEVBQUU7Z0JBQ0YsSUFBSSxFQUFFLFlBQVk7Z0JBQ2xCLE9BQU8sRUFBRSxJQUFJLENBQUMsU0FBUyxDQUFDLEVBQUMsTUFBTSxFQUFFLFdBQVcsQ0FBQyxNQUFNLEVBQUMsRUFBRSxJQUFJLEVBQUUsQ0FBQyxDQUFDO2FBQ2pFO1NBQ0osQ0FBQyxDQUFDO0lBQ1AsQ0FBQyxDQUFDO1NBQ0QsR0FBRyxDQUFDLFVBQVUsV0FBOEI7UUFDekMsK0NBQStDO1FBQy9DLHdDQUF3QztRQUN4QyxNQUFNLENBQUM7WUFDSCxXQUFXLEVBQUUsV0FBVyxDQUFDLFlBQVk7U0FDeEMsQ0FBQztJQUNOLENBQUMsQ0FBQztTQUNELElBQUksQ0FBQyxDQUFDLENBQUM7U0FDUCxLQUFLLENBQUMsVUFBVSxDQUFDO1FBRWQsRUFBRSxDQUFDLENBQUMsQ0FBQyxDQUFDLElBQUksS0FBSyxTQUFTLENBQUM7WUFBQyxDQUFDLENBQUMsSUFBSSxHQUFHLDhCQUFpQixDQUFDLGlCQUFpQixDQUFDO1FBQ3ZFLEVBQUUsQ0FBQyxDQUFDLENBQUMsQ0FBQyxJQUFJLEtBQUssUUFBUSxDQUFDO1lBQUUsQ0FBQyxDQUFDLElBQUksR0FBRyw4QkFBaUIsQ0FBQyxnQkFBZ0IsQ0FBQztRQUV0RSxPQUFPLENBQUMsUUFBUSxDQUFDO1lBQ2IsSUFBSSxFQUFFLDhCQUFXLENBQUMsWUFBWTtZQUM5QixJQUFJLEVBQUU7Z0JBQ0YsS0FBSyxFQUFFLENBQUM7Z0JBQ1IsR0FBRyxFQUFFLE9BQU8sQ0FBQyxNQUFNLENBQUMsR0FBRzthQUNKO1NBQzFCLENBQUMsQ0FBQztRQUVILE1BQU0sQ0FBQyxFQUFFLENBQUMsVUFBVSxDQUFDLElBQUksQ0FBQyxFQUFFLENBQUMsQ0FBQztJQUNsQyxDQUFDLENBQUMsQ0FBQztBQUNYLENBQUM7QUE5Q2Usb0JBQVksZUE4QzNCLENBQUEifQ==