Method handleStreamCompletion

src/node/services/workspaceService.ts:2526–2552

(workspaceId: string)

  }

  private async handleStreamCompletion(workspaceId: string): Promise<void> {
    const generation = this.streamingGenerations.get(workspaceId) ?? 0;
    const isIdleCompaction = this.idleCompactingWorkspaces.has(workspaceId);

    // Note: idle-compaction success/failure is reported from onIdleCompactionOutcome
    // (after the summary is actually persisted), not here — a clean provider stream-end
    // does not guarantee the post-stream history compaction succeeded.

    // Idle compaction is maintenance work, so preserve the pre-existing recency.
    // That keeps the workspace from jumping to the top of the sidebar and also
    // prevents the background activity path from treating compaction as a fresh response.

    if (!isIdleCompaction) {
      // Always use Date.now() for stream-completion recency.
      // extractTimestamp() returns the message-creation timestamp from stream
      // metadata, which is effectively the same as the sendMessage recency and
      // can lose the race against the frontend's lastRead (set via Date.now()
      // after the IPC round-trip). Using a fresh timestamp here ensures the
      // completion recency is strictly after any earlier lastRead write.
      await this.updateRecencyTimestamp(workspaceId, Date.now());
    }

    await this.stopStreamingStatus(workspaceId, generation);
    // Goal mutations are drained by AgentSession after stream accounting. Doing
    // it here races with per-session stream-end listeners because EventEmitter
    // does not await async handlers.
  }

  private createInitLogger(workspaceId: string) {
    const hasInitState = () => this.initStateManager.getInitState(workspaceId) !== undefined;