Function runCommand

src/node/runtime/DockerRuntime.ts:79–131

(
  command: string,
  args: string[],
  options: { timeoutMs?: number; shell?: boolean; abortSignal?: AbortSignal } = {}
)

  | { action: "create" }; // Doesn't exist, proceed to create

function runCommand(
  command: string,
  args: string[],
  options: { timeoutMs?: number; shell?: boolean; abortSignal?: AbortSignal } = {}
): Promise<DockerCommandResult> {
  return new Promise((resolve) => {
    let stdout = "";
    let stderr = "";
    let settled = false;

    if (options.abortSignal?.aborted) {
      resolve({ exitCode: -1, stdout, stderr: "Command aborted" });
      return;
    }

    const child = spawn(command, args, { shell: options.shell === true });

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

    const timer = setTimeout(() => {
      child.kill();
      finish({ exitCode: -1, stdout, stderr: "Command timed out" });
    }, options.timeoutMs ?? 30000);

    const onAbort = () => {
      child.kill();
      finish({ exitCode: -1, stdout, stderr: "Command aborted" });
    };
    options.abortSignal?.addEventListener("abort", onAbort, { once: true });

    child.stdout?.on("data", (data: Buffer) => {
      stdout += data.toString();
    });

    child.stderr?.on("data", (data: Buffer) => {
      stderr += data.toString();
    });

    child.on("close", (code) => {
      finish({ exitCode: code ?? -1, stdout, stderr });
    });

    child.on("error", (err) => {
      finish({ exitCode: -1, stdout, stderr: err.message });
    });
  });
}

/**
 * Run a Docker CLI command and return result.