Class BackgroundProcessManager

src/node/services/backgroundProcessManager.ts:182–1366

}

export class BackgroundProcessManager extends EventEmitter<BackgroundProcessManagerEvents> {
  // NOTE: This map is in-memory only. Background processes use nohup/setsid so they
  // could survive app restarts, but we kill all tracked processes on shutdown via
  // dispose(). Rehydrating from meta.json on startup is out of scope for now.
  // All per-process state (read position, output lock) is stored in BackgroundProcess
  // so cleanup is automatic when the process is removed from this map.
  private processes = new Map<string, BackgroundProcess>();

  // Base directory for process output files
  private readonly bgOutputDir: string;
  // Tracks foreground processes (started via runtime.exec) that can be backgrounded
  // Key is toolCallId to support multiple parallel foreground processes per workspace
  private foregroundProcesses = new Map<string, ForegroundProcess>();
  // Tracks workspaces with queued messages (for bash_output to return early)
  private queuedMessageWorkspaces = new Set<string>();

  constructor(bgOutputDir: string) {
    super();
    // Background bash status can have many concurrent subscribers (e.g. multiple workspaces).
    // Raise the default listener cap to avoid noisy MaxListenersExceededWarning.
    this.setMaxListeners(50);
    this.bgOutputDir = bgOutputDir;
  }

  /**
   * Mark whether a workspace has a queued user message.
   * Used by bash_output to return early when user has sent a new message.
   */
  setMessageQueued(workspaceId: string, queued: boolean): void {
    if (queued) {
      this.queuedMessageWorkspaces.add(workspaceId);
    } else {
      this.queuedMessageWorkspaces.delete(workspaceId);
    }
  }

  /**
   * Check if a workspace has a queued user message.
   */
  hasQueuedMessage(workspaceId: string): boolean {
    return this.queuedMessageWorkspaces.has(workspaceId);
  }

  /** Emit a change event for a workspace */
  private emitChange(workspaceId: string): void {
    this.emit("change", workspaceId);
  }

  private createMonitorState(
    config: BackgroundProcessMonitorConfig,
    options: { pollIntervalMs: number }
  ): BackgroundProcessMonitorState {
    assert(config.filter.length > 0, "BackgroundProcessMonitorConfig requires a filter");
    assert(config.cooldownMs >= 0, "BackgroundProcessMonitorConfig cooldown must be non-negative");
    assert(options.pollIntervalMs > 0, "monitor poll interval must be positive");
    return {
      ...config,
      matchesCount: 0,