ꦫꦣꦺꦤ꧀ꦄꦤ꧀ꦠꦱꦺꦤ

PATH: usr / local / lib / node_modules / ghost-cli / lib / utils

'use strict';
const execa = require('execa');
const {Observable} = require('rxjs');
const {ProcessError} = require('../errors');

/**
 * Runs a yarn command. Can return an Observer which allows
 * listr to output the current status of yarn
 */
module.exports = function yarn(yarnArgs, options) {
    options = options || {};

const observe = options.observe || false;
    delete options.observe;

const verbose = options.verbose || false;
    delete options.verbose;

yarnArgs = yarnArgs || [];

if (verbose) {
        yarnArgs.push('--verbose');
    }

const execaOpts = {...options, preferLocal: true, localDir: __dirname};
    const cp = execa('yarn', yarnArgs, execaOpts);

if (!observe) {
        // execa augments the error object with
        // some other properties, so we just pass
        // the entire error object in as options to
        // the ProcessError
        return cp.catch(error => Promise.reject(new ProcessError(error)));
    }

return new Observable((observer) => {
        const onData = data => observer.next(data.replace(/\n$/, ''));

cp.stdout.setEncoding('utf8');
        cp.stdout.on('data', onData);

if (verbose) {
            cp.stderr.setEncoding('utf8');
            cp.stderr.on('data', onData);
        }

cp.then(() => {
            observer.complete();
        }).catch((error) => {
            // execa augments the error object with
            // some other properties, so we just pass
            // the entire error object in as options to
            // the ProcessError
            observer.error(new ProcessError(error));
        });
    });
};

[-] needed-migrations.js [edit]
[-] port-polling.js [edit]
[+] ..
[-] local-process.js [edit]
[-] get-proxy-agent.js [edit]
[-] url.js [edit]
[-] check-valid-install.js [edit]
[-] use-ghost-user.js [edit]
[-] config.js [edit]
[-] yarn.js [edit]
[-] dir-is-empty.js [edit]
[-] pre-checks.js [edit]
[-] find-extensions.js [edit]
[-] check-root-user.js [edit]
[-] version.js [edit]