Method getOrCreateAggregator

src/browser/stores/WorkspaceStore.ts:3980–4002

* Get or create aggregator for a workspace. * * REQUIRES: createdAt must be provided for new aggregators. * Backend guarantees every workspace has createdAt via config.ts. * * If aggregator already exists, createdAt is optional (it was already set during creation).

(
    workspaceId: string,
    createdAt: string,
    unarchivedAt?: string
  )

   * If aggregator already exists, createdAt is optional (it was already set during creation).
   */
  private getOrCreateAggregator(
    workspaceId: string,
    createdAt: string,
    unarchivedAt?: string
  ): StreamingMessageAggregator {
    if (!this.aggregators.has(workspaceId)) {
      // Create new aggregator with required createdAt and workspaceId for localStorage persistence
      const aggregator = new StreamingMessageAggregator(createdAt, workspaceId, unarchivedAt);
      // Wire up navigation callback for notification clicks
      if (this.navigateToWorkspaceCallback) {
        aggregator.onNavigateToWorkspace = this.navigateToWorkspaceCallback;
      }
      // Wire up response-complete forwarding for the "notify on response" feature.
      aggregator.onResponseComplete = this.forwardResponseComplete;
      this.aggregators.set(workspaceId, aggregator);
      this.workspaceCreatedAt.set(workspaceId, createdAt);
    } else if (unarchivedAt) {
      // Update unarchivedAt on existing aggregator (e.g., after restore from archive)
      this.aggregators.get(workspaceId)!.setUnarchivedAt(unarchivedAt);
    }

    return this.aggregators.get(workspaceId)!;
  }

  private shouldBumpStateForBufferedStreamFallback(data: WorkspaceChatMessage): boolean {
    if (!("type" in data)) {