Function createContainer

src/lib/docker.ts:50–112

(
  sessionId: string,
  options?: { portMappings?: Record<number, number> }
)

 * Create a new container for a chat session
 */
export async function createContainer(
  sessionId: string,
  options?: { portMappings?: Record<number, number> }
): Promise<Docker.Container> {
  try {
    logger.info('Creating Docker container', { sessionId, portMappings: options?.portMappings });

    await ensureImageExists();

    // Build port bindings if provided
    const portBindings: Record<string, Array<{ HostPort: string }>> = {};
    const exposedPorts: Record<string, object> = {};

    if (options?.portMappings) {
      for (const [containerPort, hostPort] of Object.entries(options.portMappings)) {
        const portKey = `${containerPort}/tcp`;
        portBindings[portKey] = [{ HostPort: String(hostPort) }];
        exposedPorts[portKey] = {};
      }
    }

    const container = await docker.createContainer({
      Image: 'pilot-agent:latest',
      name: `pilot-session-${sessionId}`,
      Env: [
        `GITHUB_TOKEN=${process.env.GITHUB_TOKEN || ''}`,
      ],
      WorkingDir: '/workspace',
      ExposedPorts: Object.keys(exposedPorts).length > 0 ? exposedPorts : undefined,
      HostConfig: {
        AutoRemove: false,
        Memory: 2 * 1024 * 1024 * 1024, // 2GB memory limit
        MemorySwap: 2 * 1024 * 1024 * 1024,
        CpuPeriod: 100000,
        CpuQuota: 200000, // 2 CPU cores max
        NetworkMode: 'bridge',
        PortBindings: Object.keys(portBindings).length > 0 ? portBindings : undefined,
      },
      AttachStdout: true,
      AttachStderr: true,
      Tty: false,
    });

    await container.start();

    // Verify container is actually running
    const inspection = await container.inspect();
    if (inspection.State.Status !== 'running') {
      throw new Error(
        `Container failed to start properly. Status: ${inspection.State.Status}, ` +
        `Error: ${inspection.State.Error || 'unknown'}. This may indicate Docker is out of disk space.`
      );
    }

    containerCache.set(sessionId, container);

    logger.info('Container created and started', { sessionId, containerId: container.id });
    return container;