Method createSession

src/node/services/workspaceService.ts:2692–2722

(workspaceId: string)

  }

  private createSession(workspaceId: string): AgentSession {
    return new AgentSession({
      workspaceId,
      config: this.config,
      historyService: this.historyService,
      aiService: this.aiService,
      telemetryService: this.telemetryService,
      initStateManager: this.initStateManager,
      workspaceGoalService: this.workspaceGoalService,
      backgroundProcessManager: this.backgroundProcessManager,
      onCompactionComplete: (metadata) => {
        this.schedulePostCompactionMetadataRefresh(workspaceId);
        // Compaction marks a long session with accumulated learnings: harvest
        // the compacted epoch first, then let Dream sweep/merge the candidates.
        this.memoryConsolidationService?.triggerHarvestThenSweepInBackground(metadata);
      },
      onIdleCompactionOutcome: (success) => {
        // Reports the *persisted* idle-compaction outcome (success only after the summary
        // is written; failure on post-stream persistence errors). Reporting on actual
        // persistence — not the provider stream-end — keeps the idle loop's failure streak
        // accurate. A persistence failure is not a model error, so modelNotFound is false.
        this.reportIdleCompactionOutcome(
          workspaceId,
          success ? { success: true } : { success: false, modelNotFound: false }
        );
      },
      onPostCompactionStateChange: () => {
        this.schedulePostCompactionMetadataRefresh(workspaceId);
      },
    });
  }

  private attachSessionSubscriptions(workspaceId: string, session: AgentSession): void {
    const chatUnsubscribe = session.onChatEvent((event) => {