Function runCommandWithPty

apps/node/src/modules/utils/run-command.ts:82–159

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

const appDir = getAppDataDir();

export async function runCommandWithPty(
    command: string,
    dispatcher: TaskEventDispatcher = () => { },
    options: Options = {},
    cb?: (process: nodePty.IPty) => void
) {
    const { systemProxy, systemProxyString } = await getSystemProxy();
    logger.info("run command with PTY");
    const fullCommand = `${command} && echo END_OF_COMMAND\n`;

    return new Promise((resolve, reject) => {
        try {
            const pty = nodePty.spawn(shell, [], {
                name: 'xterm-color',
                // conpty will cause Error: ptyProcess.kill() will throw a error that can't be catched
                useConpty: false,
                cols: 80,
                rows: 30,
                env: {
                    ...process.env,
                    ...systemProxy,
                    Path: process.env.PATH,
                    DISABLE_UPDATE_PROMPT: "true",
                    encoding: 'utf-8',
                },
                cwd: (options.cwd || appDir) as string
            });
    
            cb && cb(pty);
            
            let buffer = "";
            const disposable = pty.onData(function (data: string) {
                // raw output data
                dispatcher && dispatcher({
                    message: data,
                    data: {
                        raw: true
                    }
                });

                if (data.trim() === fullCommand.trim()) {
                    return;
                }

                // wrapped output data
                buffer += data;
                if (data.indexOf('\n') > 0) {
                    logger.info("[Log:" + buffer + "]");
                    dispatcher && dispatcher({
                        message: buffer.replace("&& echo END_OF_COMMAND", "").replace("END_OF_COMMAND", ""),
                        data: {
                            raw: false
                        }
                    });
                    buffer = ""
                }
                if (data.trim() === 'END_OF_COMMAND') {
                    logger.info('The command has finished executing.');