Function worker

packages/utils/src/lib/execute-process.ts:162–215

()

  const bin = [command, ...(args ?? [])].join(' ');

  const worker = () =>
    new Promise<ProcessResult>((resolve, reject) => {
      const spawnedProcess = spawn(command, args ?? [], {
        // shell:true tells Windows to use shell command for spawning a child process
        // https://stackoverflow.com/questions/60386867/node-spawn-child-process-not-working-in-windows
        shell: true,
        windowsHide: true,
        ...options,
      }) as ChildProcessByStdio<Writable, Readable, Readable>;

      // eslint-disable-next-line functional/no-let
      let stdout = '';
      // eslint-disable-next-line functional/no-let
      let stderr = '';
      // eslint-disable-next-line functional/no-let
      let output = ''; // interleaved stdout and stderr

      spawnedProcess.stdout.on('data', (data: unknown) => {
        const message = String(data);
        stdout += message;
        output += message;
        onStdout?.(message, spawnedProcess);
      });

      spawnedProcess.stderr.on('data', (data: unknown) => {
        const message = String(data);
        stderr += message;
        output += message;
        onStderr?.(message, spawnedProcess);
      });

      spawnedProcess.on('error', error => {
        reject(error);
      });

      spawnedProcess.on('close', (code, signal) => {
        const result: ProcessResult = { bin, code, signal, stdout, stderr };
        if (code === 0 || ignoreExitCode) {
          if (!silent) {
            logger.debug(output);
          }
          onComplete?.();
          resolve(result);
        } else {
          if (!silent) {
            // ensure stdout and stderr are logged to help debug failure
            logger.debug(output, { force: true });
          }
          const error = new ProcessError(result);
          onError?.(error);
          reject(error);
        }
      });
    });

  return silent ? worker() : logger.command(bin, worker);
}