Class WorkspaceService

src/node/services/workspaceService.ts:1542–9509

// eslint-disable-next-line @typescript-eslint/no-unsafe-declaration-merging
export class WorkspaceService extends EventEmitter {
  private readonly sessions = new Map<string, AgentSession>();
  // Startup recovery may need a short-lived session even before the workspace is opened.
  // Promote only sessions that keep retry/stream activity alive after the initial check.
  private readonly transientStartupRecoverySessions = new Map<string, AgentSession>();
  private readonly sessionSubscriptions = new Map<
    string,
    { chat: () => void; metadata: () => void }
  >();

  private readonly bashMonitorWakeStore: BashMonitorWakeStore;
  private readonly pendingBashMonitorWakeDrainsByOwner = new Map<string, Promise<void>>();
  private readonly pendingBashMonitorWakeIdleWaitsByOwner = new Map<string, Promise<void>>();
  private readonly cancelingBashMonitorWakeKeys = new Set<string>();
  private readonly pendingBashMonitorWakeDrains = new Set<Promise<void>>();
  private readonly bashMonitorMatchListener = (
    _workspaceId: string,
    payload: MonitorMatchPayload
  ) => {
    void this.handleBashMonitorMatch(payload);
  };

  // Lazily bootstrapped workflow activity cache so sidebar refreshes don't rescan run history.
  private readonly activeWorkflowRunIdBootstrapsByWorkspace = new Map<
    string,
    Promise<Set<string>>
  >();
  private readonly activeWorkflowRunIdsByWorkspace = new Map<string, Set<string>>();

  // Debounce post-compaction metadata refreshes (file_edit_* can fire rapidly)
  private readonly postCompactionRefreshTimers = new Map<string, ReturnType<typeof setTimeout>>();
  // Tracks workspaces currently being renamed to prevent streaming during rename
  private readonly renamingWorkspaces = new Set<string>();

  // Cache for @file mention autocomplete (git ls-files output).
  private readonly fileCompletionsCache = new Map<string, FileCompletionsCacheEntry>();
  // Tracks workspaces currently being removed to prevent new sessions/streams during deletion.
  private readonly removingWorkspaces = new Set<string>();

  // Tracks workspaces currently being archived to prevent runtime-affecting operations (e.g. SSH)
  // from waking a dedicated workspace during archive().
  private readonly archivingWorkspaces = new Set<string>();

  // Tracks stream generations that are compaction turns so background stop snapshots
  // can carry authoritative notification policy instead of forcing the frontend to
  // infer compaction from best-effort chat replay state.
  private readonly compactionStreamGenerations = new Map<string, number>();

  // Tracks workspaces undergoing idle (background) compaction so the activity snapshot
  // can tag the stream, letting the frontend suppress notifications for maintenance work.
  private readonly idleCompactingWorkspaces = new Set<string>();

  // Reports the terminal outcome of an idle compaction (success or failure, including
  // mid-stream failures like model_not_found) back to IdleCompactionService so it can
  // stop re-attempting a persistently failing workspace. Wired in ServiceContainer.
  private idleCompactionOutcomeListener:
    | ((workspaceId: string, outcome: IdleCompactionOutcome) => void)
    | undefined;