Function runDockerWithStandardIO

packages/component-sdk/src/runner.ts:265–397

* Run Docker container with standard I/O. * Stdout/stderr are collected - stdout is returned for backwards compatibility. * Primary output method is the mounted output file.

(
  dockerArgs: string[],
  params: I,
  context: ExecutionContext,
  timeoutSeconds: number,
  stdinJson?: boolean,
  detached?: boolean,
)

 * Primary output method is the mounted output file.
 */
async function runDockerWithStandardIO<I, O>(
  dockerArgs: string[],
  params: I,
  context: ExecutionContext,
  timeoutSeconds: number,
  stdinJson?: boolean,
  detached?: boolean,
): Promise<string> {
  const dockerPath = await resolveDockerPath(context);
  return new Promise<string>((resolve, reject) => {
    const stdoutEmitter = createTerminalChunkEmitter(context, 'stdout');
    const stderrEmitter = createTerminalChunkEmitter(context, 'stderr');

    const timeout = setTimeout(() => {
      proc.kill();
      reject(new TimeoutError(`Docker container timed out after ${timeoutSeconds}s`, timeoutSeconds * 1000, {
        details: { dockerArgs: formatArgs(dockerArgs) },
      }));
    }, timeoutSeconds * 1000);

    const proc = spawn(dockerPath, dockerArgs, {
      stdio: ['pipe', 'pipe', 'pipe'],
      env: process.env,
    });



    let stdout = '';
    let stderr = '';

    proc.stdout.on('data', (data) => {
      stdoutEmitter(data);
      const chunk = data.toString();
      stdout += chunk; // Capture for fallback

      // Send to log collector (which has chunking support)
      const logEntry = {
        runId: context.runId,
        nodeRef: context.componentRef,
        stream: 'stdout' as const,
        level: 'info' as const,
        message: chunk,
        timestamp: new Date().toISOString(),
      };
      context.logCollector?.(logEntry);

      // NOTE: We intentionally do NOT emit stdout as trace progress events.
      // Output data is written to /shipsec-output/result.json by the container.
      // Stdout should only contain logs and progress messages from the component.
    });

    proc.stderr.on('data', (data) => {
      stderrEmitter(data);
      const chunk = data.toString();
      stderr += chunk;
      const logEntry = {
        runId: context.runId,
        nodeRef: context.componentRef,