Method addWorkspace

src/browser/stores/WorkspaceStore.ts:3698–3753

(metadata: FrontendWorkspaceMetadata)

  }

  addWorkspace(metadata: FrontendWorkspaceMetadata): void {
    const workspaceId = metadata.id;

    // Skip if already registered
    if (this.workspaceMetadata.has(workspaceId)) {
      return;
    }

    // Store metadata for name lookup
    this.workspaceMetadata.set(workspaceId, metadata);
    this.derived.bump("workspaces");

    // Backend guarantees createdAt via config.ts - this should never be undefined
    assert(
      metadata.createdAt,
      `Workspace ${workspaceId} missing createdAt - backend contract violated`
    );

    const aggregator = this.getOrCreateAggregator(
      workspaceId,
      metadata.createdAt,
      metadata.unarchivedAt
    );

    // Initialize recency cache and bump derived store immediately
    // This ensures UI sees correct workspace order before messages load
    const initialRecency = aggregator.getRecencyTimestamp();
    if (initialRecency !== null) {
      this.recencyCache.set(workspaceId, initialRecency);
      this.derived.bump("recency");
    }

    // Initialize transient chat state
    if (!this.chatTransientState.has(workspaceId)) {
      this.chatTransientState.set(workspaceId, createInitialChatTransientState());
    }

    if (!this.historyPagination.has(workspaceId)) {
      this.historyPagination.set(workspaceId, createInitialHistoryPaginationState());
    }

    // Clear stale streaming state
    aggregator.clearActiveStreams();

    // Fetch persisted session usage (fire-and-forget)
    this.refreshSessionUsage(workspaceId);

    // Stats snapshots are subscribed lazily via subscribeStats().
    this.subscribeToStats(workspaceId);

    this.ensureActiveOnChatSubscription();

    if (!this.client) {
      console.warn(`[WorkspaceStore] No ORPC client available for workspace ${workspaceId}`);
    }
  }

  markPendingInitialSend(workspaceId: string, pendingStreamModel: string | null): void {