Function runCommand

apps/node/src/modules/utils/run-command.ts:5–71

(
    command: string, 
    dispatcher: TaskEventDispatcher = () => { }, 
    options: Options = {}, 
    cb?: (process: ExecaChildProcess) => void
)

import { getSystemPath, getSystemProxy } from "./env";

export async function runCommand(
    command: string, 
    dispatcher: TaskEventDispatcher = () => { }, 
    options: Options = {}, 
    cb?: (process: ExecaChildProcess) => void
): Promise<{
    stderr: string,
    exitCode: number,
    stdout: string,
}> {
    const { systemProxy, systemProxyString } = await getSystemProxy();
    if (systemProxy) {
        logger.info("run command with proxy:" + command + " " + systemProxyString);
    } else {
        logger.info("run command without proxy")
    }
    const SHELL_ENV_PATH = getSystemPath({
        CONDA_SCRIPTS_PATH: conda.info?.CONDA_SCRIPTS_PATH || "",
        CONDA_ENV_PATH: conda.env?.CONDA_ENV_PATH || ""
    });
    const subProcess = execaCommand(command, {
        env: {
            ...process.env,
            PATH: SHELL_ENV_PATH,
            ...systemProxy,
        },
        // shell: isMac ? "/bin/zsh" : true,
        ...options
    });

    cb && cb(subProcess);

    subProcess.stdout?.on('data', (chunk) => {
        logger.info("out", chunk.toString());
        dispatcher && dispatcher({
            message: chunk.toString()
        })
    });

    subProcess.stderr?.on('data', (chunk) => {
        logger.error(`run command "${command}" error: ${chunk.toString()}`);
        dispatcher && dispatcher({
            message: chunk.toString()
        })
    });

    const { exitCode, stderr, stdout } = await subProcess;

    dispatcher && dispatcher({
        data: {
            exitCode,
            stderr,
            stdout,
        },
        message: stderr + stdout
    });

    if (exitCode !== 0) {