Function streamDockerRun

src/node/runtime/DockerRuntime.ts:184–252

* Run docker run with streaming output (for image pull progress). * Streams stdout/stderr to initLogger for visibility during image pulls.

(
  containerName: string,
  image: string,
  initLogger: InitLogger,
  options?: { abortSignal?: AbortSignal; shareCredentials?: boolean; timeoutMs?: number }
)

 * Streams stdout/stderr to initLogger for visibility during image pulls.
 */
function streamDockerRun(
  containerName: string,
  image: string,
  initLogger: InitLogger,
  options?: { abortSignal?: AbortSignal; shareCredentials?: boolean; timeoutMs?: number }
): Promise<DockerCommandResult> {
  const { abortSignal, shareCredentials, timeoutMs = 600000 } = options ?? {};

  return new Promise((resolve) => {
    let stdout = "";
    let stderr = "";
    let resolved = false;

    const finish = (result: DockerCommandResult) => {
      if (resolved) return;
      resolved = true;
      clearTimeout(timer);
      abortSignal?.removeEventListener("abort", abortHandler);
      resolve(result);
    };

    // Build docker run args
    const dockerArgs = ["run", "-d", "--name", containerName];
    if (shareCredentials) {
      dockerArgs.push(...buildCredentialArgs());
    }
    dockerArgs.push(image, "sleep", "infinity");

    // Use spawn for streaming output - array args don't need shell escaping
    const child = spawn("docker", dockerArgs);

    const timer = setTimeout(() => {
      child.kill();
      void runDockerCommand(`docker rm -f ${containerName}`, 10000);
      finish({ exitCode: -1, stdout, stderr: "Container creation timed out" });
    }, timeoutMs);

    const abortHandler = () => {
      child.kill();
      // Container might have been created before abort - clean it up
      void runDockerCommand(`docker rm -f ${containerName}`, 10000);
      finish({ exitCode: -1, stdout, stderr: "Aborted" });
    };
    abortSignal?.addEventListener("abort", abortHandler);

    child.stdout?.on("data", (data: Buffer) => {
      const text = data.toString();
      stdout += text;
      // docker run -d outputs container ID to stdout, not useful to stream
    });

    child.stderr?.on("data", (data: Buffer) => {
      const text = data.toString();
      stderr += text;
      // Stream pull progress to init logger
      for (const line of text.split("\n").filter((l) => l.trim())) {
        initLogger.logStdout(line);
      }