Class WorkspaceConsumerManager

src/browser/stores/WorkspaceConsumerManager.ts:68–369

 *   (components subscribe to workspace changes, delegates to manager for state)
 */
export class WorkspaceConsumerManager {
  // Track scheduled calculations (in debounce window, not yet executing)
  private scheduledCalcs = new Set<string>();

  // Track executing calculations (Web Worker running)
  private pendingCalcs = new Set<string>();

  // Track workspaces that need recalculation after current one completes
  private needsRecalc = new Map<string, StreamingMessageAggregator>();

  // Cache calculated consumer data (persists across bumps)
  private cache = new Map<string, WorkspaceConsumersState>();

  // Debounce timers for consumer calculations (prevents rapid-fire during tool sequences)
  private debounceTimers = new Map<string, NodeJS.Timeout>();

  // Callback to bump the store when calculation completes
  private readonly onCalculationComplete: (workspaceId: string) => void;
  // Stable provider-config fingerprint to stamp persisted token stats cache entries.
  // Returns null before the first config fetch completes (blocks calculation).
  private readonly getProvidersConfigVersion: () => number | null;

  // Track pending store notifications to avoid duplicate bumps within the same tick
  private pendingNotifications = new Set<string>();

  constructor(
    onCalculationComplete: (workspaceId: string) => void,
    getProvidersConfigVersion: () => number | null
  ) {
    this.onCalculationComplete = onCalculationComplete;
    this.getProvidersConfigVersion = getProvidersConfigVersion;
  }

  /**
   * Get cached state without side effects.
   * Returns null if no cache exists.
   */
  getCachedState(workspaceId: string): WorkspaceConsumersState | null {
    return this.cache.get(workspaceId) ?? null;
  }

  /**
   * Check if calculation is pending or scheduled for workspace.
   */
  isPending(workspaceId: string): boolean {
    return this.scheduledCalcs.has(workspaceId) || this.pendingCalcs.has(workspaceId);
  }

  /**
   * Get current state synchronously without triggering calculations.
   * Returns cached result if available, otherwise returns default state.
   *
   * Note: This is called from WorkspaceStore.getWorkspaceConsumers(),
   * which handles the lazy trigger logic separately.
   */
  getStateSync(workspaceId: string): WorkspaceConsumersState {
    const cached = this.cache.get(workspaceId);
    if (cached) {