Method trackCursor

apps/kimi-web/src/api/daemon/ws.ts:453–463

* Advance the tracked cursor from a durable event envelope (seq + epoch). * Volatile frames are skipped (their seq is the same watermark, and a * volatile frame can never carry a NEWER seq than the last durable one).

(frame: Record<string, unknown>)

   * volatile frame can never carry a NEWER seq than the last durable one).
   */
  private trackCursor(frame: Record<string, unknown>): void {
    if (frame['volatile'] === true) return;
    const sid = frame['session_id'];
    const seq = frame['seq'];
    if (typeof sid !== 'string' || typeof seq !== 'number') return;
    const existing = this.subscriptions.get(sid);
    if (!existing) return; // not a session we manage
    if (seq <= existing.seq && existing.epoch !== undefined) return;
    const epoch = typeof frame['epoch'] === 'string' ? (frame['epoch'] as string) : existing.epoch;
    this.subscriptions.set(sid, { seq: Math.max(seq, existing.seq), epoch });
  }

  private send(msg: unknown): void {
    if (!this.ws || this.ws.readyState !== WebSocket.OPEN) return;