Function runCliCapture

src/__tests__/cli-capture.ts:48–122

(
  argv: string[],
  responderOrOptions: CliCaptureResponder | CliCaptureOptions = {},
  extraOptions: CliCaptureOptions = {},
)

) => Promise<DaemonResponse>;

export async function runCliCapture(
  argv: string[],
  responderOrOptions: CliCaptureResponder | CliCaptureOptions = {},
  extraOptions: CliCaptureOptions = {},
): Promise<CapturedCliRun> {
  const options =
    typeof responderOrOptions === 'function'
      ? { ...extraOptions, sendToDaemon: responderOrOptions }
      : { ...extraOptions, ...(responderOrOptions ?? {}) };
  let stdout = '';
  let stderr = '';
  let code: number | null = null;
  const calls: CapturedDaemonRequest[] = [];
  const stateDir = options.stateDirPrefix
    ? fs.mkdtempSync(path.join(os.tmpdir(), options.stateDirPrefix))
    : undefined;

  const originalExit = process.exit;
  const originalStdoutWrite = process.stdout.write.bind(process.stdout);
  const originalStderrWrite = process.stderr.write.bind(process.stderr);
  const originalCwd = process.cwd();
  const restoreEnv = installIsolatedCliTestEnv({
    ...(options.env ?? {}),
    ...(stateDir ? { AGENT_DEVICE_STATE_DIR: stateDir } : {}),
  });

  if (options.cwd) {
    process.chdir(options.cwd);
  }

  (process as any).exit = ((nextCode?: number) => {
    throw new ExitSignal(nextCode ?? 0);
  }) as typeof process.exit;
  (process.stdout as any).write = ((chunk: unknown, ...args: unknown[]) => {
    if (options.passthroughBufferWrites && Buffer.isBuffer(chunk)) {
      return originalStdoutWrite(chunk, ...(args as [any]));
    }
    stdout += String(chunk);
    return true;
  }) as typeof process.stdout.write;
  (process.stderr as any).write = ((chunk: unknown, ...args: unknown[]) => {
    if (options.passthroughBufferWrites && Buffer.isBuffer(chunk)) {
      return originalStderrWrite(chunk, ...(args as [any]));
    }
    stderr += String(chunk);
    return true;
  }) as typeof process.stderr.write;

  const sendToDaemon = async (
    req: CapturedDaemonRequest,
    daemonOptions?: DaemonTransportOptions,
  ): Promise<DaemonResponse> => {
    calls.push(req);
    if (options.sendToDaemon) {
      return await options.sendToDaemon(req, daemonOptions);
    }
    return options.defaultResponse ?? { ok: true, data: {} };
  };