Class WorkspaceStore

src/browser/stores/WorkspaceStore.ts:611–4434

 * components re-render when workspace state changes.
 */
export class WorkspaceStore {
  // Per-workspace state (lazy computed on get)
  private states = new MapStore<string, WorkspaceState>();

  // Stable subset for WorkspaceShell so message deltas do not re-render shell chrome.
  private workspaceShellStatusCache = new Map<string, WorkspaceShellStatus>();

  // Derived aggregate state (computed from multiple workspaces)
  private derived = new MapStore<string, DerivedState>();

  // Usage and consumer stores (two-store approach for CostsTab optimization)
  private usageStore = new MapStore<string, WorkspaceUsageState>();
  private client: RouterClient<AppRouter> | null = null;
  private clientChangeController = new AbortController();
  private providersConfig: ProvidersConfigMap | null = null;
  /** Stable fingerprint for cache freshness checks across reconnects/app restarts.
   * `null` until the first successful config fetch — prevents hydrating stale caches
   * and blocks tokenization until we know the real configuration. */
  private providersConfigFingerprint: number | null = null;
  /** Monotonic request counter for serializing provider config refreshes (latest wins). */
  private providersConfigVersion = 0;
  /** Version of the last successfully applied provider config (prevents stale overwrites). */
  private providersConfigAppliedVersion = 0;
  /** Consecutive provider-config subscription/refresh failures (used for exponential backoff). */
  private providersConfigFailureStreak = 0;
  // Workspaces that need a clean history replay once a new iterator is established.
  // We keep the existing UI visible until the replay can actually start.
  private pendingReplayReset = new Set<string>();
  // Last usage snapshot captured right before full replay clears the aggregator.
  // Used as a temporary fallback so context/cost indicators don't flash empty
  // during reconnect until replayed usage catches up.
  private preReplayUsageSnapshot = new Map<string, WorkspaceUsageState>();
  private consumersStore = new MapStore<string, WorkspaceConsumersState>();

  // Manager for consumer calculations (debouncing, caching, lazy loading)
  // Architecture: WorkspaceStore orchestrates (decides when), manager executes (performs calculations)
  // Dual-cache: consumersStore (MapStore) handles subscriptions, manager owns data cache
  private readonly consumerManager: WorkspaceConsumerManager;

  // Supporting data structures
  private aggregators = new Map<string, StreamingMessageAggregator>();
  // Active onChat subscription cleanup handlers (must stay size <= 1).
  private ipcUnsubscribers = new Map<string, () => void>();

  // Workspace selected in the UI (set from WorkspaceContext routing state).
  private activeWorkspaceId: string | null = null;

  // Workspace currently owning the live onChat subscription.
  private activeOnChatWorkspaceId: string | null = null;

  // Lightweight activity snapshots from workspace.activity.list/subscribe.
  private workspaceActivity = new Map<string, WorkspaceActivitySnapshot>();
  // Recency timestamp observed when a workspace transitions into streaming=true.
  // Used to distinguish true stream completion (recency bumps on stream-end) from
  // abort/error transitions (streaming=false without recency advance).
  private activityStreamingStartRecency = new Map<string, number>();
  private activityAbortController: AbortController | null = null;
  // True once the initial activity.list() snapshot has been applied (or the