Method start

packages/server/src/services/session-manager.ts:146–213

(id: string)

    private readonly eventBus: EventBus,
    teamReconciler?: TeamReconcilerService,
    runtimeRegistry?: RuntimeRegistry,
  ) {
    this.teamReconciler = teamReconciler ?? new TeamReconcilerService({
      eventBus,
      sessionMessenger: this,
      // 续催/唤醒统一由 MemberHeartbeatScheduler 轮询驱动；这里关闭内部 setTimeout 避免双驱动重复触发。
      // session 退出时的首次 reconcile（COMPLETED 判定 / 首次补催）仍即时执行，不依赖该定时器。
      scheduleReminders: false,
    });
    this.runtimeCoordinator = new RuntimeCoordinator(
      runtimeRegistry ?? new StaticRuntimeRegistry([
        new CliRuntimeDriver(),
        new AcpRuntimeDriver(),
      ]),
      {
        onTurnEvent: (event) => this.handleRuntimeTurnEvent(event),
        onRuntimeState: (state) => this.handleRuntimeState(state),
        onProcessEvent: (event) => this.handleRuntimeProcessEvent(event),
        onDriverSessionDisposed: (sessionId) => revokeAgentApiCredential(sessionId),
      },
    );

    // Patches only mark the snapshot dirty. A low-frequency checkpoint keeps the
    // hot stream away from SQLite while terminal paths still force a final flush.
    this.eventBus.on('session:patch', ({ sessionId, patch }) => {
      if (DEBUG_SNAPSHOT) {
        const ops = (patch as Array<{ op?: string; path?: string }>).slice(0, 3)
          .map((p) => `${p.op ?? '?'}:${p.path ?? '?'}`)
          .join(', ');
        console.log(
          `[SessionManager:snapshot] patch sessionId=${sessionId} ops=${(patch as unknown[]).length} [${ops}]`
        );
      }
      this.scheduleSnapshotPersist(sessionId);
      // 仅 agent 侧真实进展用作 TeamRun 成员心跳信号（节流落库）；本地 user_message（含唤醒）被过滤。
      this.maybeRecordTeamRunHeartbeat(sessionId, patch);
    });

    this.eventBus.on('session:turn-completed', ({ sessionId }) => {
      if (this.terminalSessions.has(sessionId)) return;
      // The parser has already written raw stdout, the final assistant entry,
      // usage and all other state from the turn.completed chunk at this point.
      this.terminalSessions.set(sessionId, SessionStatus.COMPLETED);
      this.startSessionFinalization(sessionId, 0, { logicalCompletion: true });
    });

    this.eventBus.on('session:turn-failed', ({ sessionId }) => {
      if (this.terminalSessions.has(sessionId)) return;
      // A turn failure is terminal even when the CLI wrapper later exits 0 or
      // without an exit code. Use a synthetic non-zero code for the shared
      // finalization path so success-only post-processing cannot run.
      this.terminalSessions.set(sessionId, SessionStatus.FAILED);
      this.startSessionFinalization(sessionId, 1, { logicalCompletion: true });
    });

    // NOTE: checkTaskAutoRevert is called directly (awaited) inside start()
    // and sendMessage() to guarantee the task status is updated before the
    // HTTP response is sent. A fire-and-forget EventBus listener here caused