Function runProcess

services/cloud-agent-next/wrapper/src/utils.ts:104–293

(
  command: string,
  args: string[],
  opts?: ProcessOptions
)

    result.stdoutTruncated === true || result.stderrTruncated === true
      ? TRUNCATION_MARKER
      : undefined,
  ]
    .filter(value => value !== undefined)
    .join(', ');
}

function terminationMessage(reason: TerminationReason): string {
  switch (reason) {
    case 'timeout':
      return EXEC_TIMEOUT_MESSAGE;
    case 'inactivity_timeout':
      return EXEC_INACTIVITY_TIMEOUT_MESSAGE;
    case 'hard_timeout':
      return EXEC_HARD_TIMEOUT_MESSAGE;
    case 'abort':
      return EXEC_ABORTED_MESSAGE;
  }
}

export function runProcess(
  command: string,
  args: string[],
  opts?: ProcessOptions
): Promise<ExecResult> {
  const startedAt = Date.now();
  if (opts?.signal?.aborted) {
    return Promise.resolve({
      stdout: '',
      stderr: EXEC_ABORTED_MESSAGE,
      exitCode: EXEC_TIMEOUT_EXIT_CODE,
      elapsedMs: 0,
      terminationReason: 'abort',
      ...(opts.rawOutput ? { stdoutBytes: Buffer.alloc(0), stderrBytes: Buffer.alloc(0) } : {}),
    });
  }

  return new Promise((resolve, reject) => {
    const options = {
      cwd: opts?.cwd,
      ...(opts?.inheritEnv === false
        ? { env: opts.env ?? {} }
        : opts?.env
          ? { env: { ...process.env, ...opts.env } }
          : {}),
    };
    const owned = currentOwnedProcessScope();
    const proc =
      owned?.spawn(command, args, options) ??
      spawn(command, args, {
        ...options,
        detached: true,
        stdio: [opts?.stdinFd ?? 'ignore', 'pipe', 'pipe'],
      });
    const stdoutStream = proc.stdout;
    const stderrStream = proc.stderr;
    if (stdoutStream === null || stderrStream === null) {
      proc.kill();
      reject(new Error('Child process did not create output streams'));