update-self.ts

import { BufferFile } from "vinyl";
import { Stream } from "stream";

(function() {
    const
        spawn = requireModule<Spawn>("spawn"),
        gulp = requireModule<GulpWithHelp>("gulp"),
        env = requireModule<Env>("env"),
        chalk = requireModule<AnsiColors>("ansi-colors"),
        resolveMasks = requireModule<ResolveMasks>("resolve-masks"),
        debug = requireModule<DebugFactory>("debug")(__filename),
        es = require("event-stream");

    env.associate([
                      env.DRY_RUN,
                      env.INCLUDE_PACKAGE_JSON,
                      env.EXCLUDE_PACKAGE_JSON
                  ], "update-self");

    gulp.task(
        "update-self",
        "Updates zarro throughout your current project",
        () => {
            const
                glob = resolveMasks(env.INCLUDE_PACKAGE_JSON, env.EXCLUDE_PACKAGE_JSON);
            debug({
                      glob
                  });
            return gulp.src(glob)
                .pipe(updateZarroPipe(env.resolveFlag(env.BETA)));
        }
    );

    function updateZarroPipe(beta: boolean) {
        const
            promises: Promise<any>[] = [];
        return es.through(function input(this: Stream, file: BufferFile) {
            let
                save = false,
                saveDev = false;
            const json = file.contents.toString();
            try {
                const
                    search = "zarro",
                    packageIndex = JSON.parse(json) as PackageIndex,
                    deps = packageIndex.dependencies || {},
                    devDeps = packageIndex.devDependencies || {};
                save = Object.keys(deps).includes(search);
                saveDev = Object.keys(devDeps).includes(search);
                if (!save && !saveDev) {
                    debug(`${ search } not installed in ${ file.path }`);
                    return;
                }
            } catch (e) {
                debug(`${ file.path } is not valid JSON`);
                return;
            }
            console.log(chalk.yellow(`update zarro in: ${ file.dirname }`));
            const
                proc = "npm",
                tag = beta ? "beta" : "latest",
                args = [ "install", save ? "--save" : "--save-dev", `zarro@${ tag }`, "--no-progress", "--silent" ],
                opts = {
                    cwd: file.dirname,
                    interactive: true
                }
            if (env.resolveFlag(env.DRY_RUN)) {
                console.log({
                                label: "would run spawn with",
                                proc,
                                args,
                                opts
                            });
            } else {
                promises.push(spawn.call(null, proc, args, opts))
            }
        }, async function end(this: Stream) {
            try {
                await Promise.all(promises)
                this.emit("end");
            } catch (err) {
                console.error(chalk.redBright(`
 ==================================================
| WARNING: Unable to update zarro, error(s) follow |
 ==================================================
`));
                this.emit("error", err);
            }
        });
    }
})();