Function execCommand

src/lib/docker.ts:124–173

(
  sessionId: string,
  command: string[],
  workingDir?: string
)

 * Execute a command in the container
 */
export async function execCommand(
  sessionId: string,
  command: string[],
  workingDir?: string
): Promise<{ stdout: string; stderr: string; exitCode: number }> {
  const container = containerCache.get(sessionId);
  if (!container) {
    throw new Error(`No container found for session: ${sessionId}`);
  }

  try {
    logger.info('Executing command in container', { sessionId, command, workingDir });

    const exec = await container.exec({
      Cmd: command,
      AttachStdout: true,
      AttachStderr: true,
      WorkingDir: workingDir || '/workspace',
    });

    const stream = await exec.start({ hijack: true, stdin: false });

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

    await new Promise<void>((resolve, reject) => {
      container.modem.demuxStream(stream,
        {
          write: (chunk: Buffer) => { stdout += chunk.toString(); },
        } as NodeJS.WritableStream,
        {
          write: (chunk: Buffer) => { stderr += chunk.toString(); },
        } as NodeJS.WritableStream
      );

      stream.on('end', () => resolve());
      stream.on('error', (err) => reject(err));
    });

    const inspection = await exec.inspect();
    const exitCode = inspection.ExitCode || 0;

    logger.info('Command executed', { sessionId, exitCode, stdoutLength: stdout.length, stderrLength: stderr.length });

    return { stdout, stderr, exitCode };
  } catch (error) {
    logger.error('Failed to execute command', { sessionId, command, error });
    throw new Error(`Failed to execute command: ${error}`);
  }
}

/**
 * Read a file from the container