Method stop

packages/server/src/services/session-manager.ts:502–561

(id: string, options: StopSessionOptions = {})

    });

    const msgStore = sessionMsgStoreManager.get(id);
    if (msgStore) {
      msgStore.pushFinished();
      try {
        await this.flushSnapshotPersist(id, SessionStatus.CANCELLED);
      } catch (error) {
        console.error(`[SessionManager] Failed to persist cancelled snapshot for ${id}:`, error);
        await prisma.session.update({
          where: { id },
          data: { status: SessionStatus.CANCELLED },
        });
      }
    } else {
      await prisma.session.update({
        where: { id },
        data: { status: SessionStatus.CANCELLED },
      });
    }

    if (!options.skipTeamRunReconcile && !this.isConversationSession(session)) {
      await this.teamReconciler.handleSessionStopped(id);
    }
    this.eventBus.emit('session:stopped', { sessionId: id });
    // Cancellation does not run normal terminal finalization, so release the
    // store after the CANCELLED snapshot has been persisted above.
    sessionMsgStoreManager.delete(id);
    this.releaseSnapshotPersistenceState(id);
    revokeAgentApiCredential(id);
    return session;
  }

  /** @deprecated Use hasActiveTurn(). */
  hasActivePipeline(sessionId: string): boolean {
    return this.runtimeCoordinator.hasActiveTurn(sessionId);
  }

  hasActiveTurn(sessionId: string): boolean {
    return this.runtimeCoordinator.hasActiveTurn(sessionId);
  }

  isAwaitingPermission(sessionId: string): boolean {
    return this.runtimeCoordinator.isAwaitingPermission(sessionId);
  }

  /**
   * 节流写入 TeamRun invocation 的心跳时间戳。非 TeamRun session 无对应 invocation，updateMany 命中 0 行无副作用。
   */
  private maybeRecordTeamRunHeartbeat(sessionId: string, patch: unknown): void {
    // 过滤掉本地 user_message patch（含心跳唤醒注入的消息），只让 agent 真实进展刷新心跳。
    if (!isAgentProgressPatch(patch)) {
      return;
    }
    const now = Date.now();
    const last = this.heartbeatThrottle.get(sessionId) ?? 0;
    if (now - last < SessionManager.HEARTBEAT_THROTTLE_MS) {
      return;
    }
    this.heartbeatThrottle.set(sessionId, now);