Method connectEvents

apps/kimi-web/src/api/daemon/client.ts:1244–1377

(handlers: KimiEventHandlers)

  // -------------------------------------------------------------------------

  connectEvents(handlers: KimiEventHandlers): KimiEventConnection {
    const wsUrl = buildWsUrl(this.config.serverHttpUrl, this.config.clientId);

    // Per-session projector for raw agent-core events.
    // Keyed by session_id; reset when a session is re-subscribed or resynced.
    const projector = createAgentProjector();

    const socket = new DaemonEventSocket(wsUrl, this.config.clientId, {
      // -----------------------------------------------------------------------
      // Projected "event.*" frames — existing path (kept working for stub / spec)
      // -----------------------------------------------------------------------
      onWireEvent: (wireEvent: WireEvent) => {
        const sessionId = wireEventSessionId(wireEvent);
        const seq = wireEventSeq(wireEvent);
        const appEvent = toAppEvent(wireEvent);

        // Route history_compacted to onResync so the client reloads messages —
        // EXCEPT for compaction itself: the transcript keeps the scrollback and
        // the reducer appends a divider marker instead (reloading would replace
        // the visible conversation with the compacted model context).
        if (appEvent.type === 'historyCompacted' && !isCompactionReason(appEvent.reason)) {
          handlers.onResync(appEvent.sessionId, appEvent.beforeSeq);
          // Still dispatch the event to onEvent so the reducer can update lastSeqBySession
        }

        // Deliver the AppEvent together with wire-level seq/session so the
        // reducer can advance lastSeqBySession[sessionId] = seq.
        handlers.onEvent(appEvent, { sessionId, seq });
      },

      // -----------------------------------------------------------------------
      // Raw agent-core frames — client-side projection path (real daemon)
      // -----------------------------------------------------------------------
      onRawAgentEvent: (frame) => {
        const { type, seq, session_id: sessionId, payload, offset } = frame;
        const appEvents = projector.project(type, payload, sessionId, { offset });
        for (const appEvent of appEvents) {
          // historyCompacted from the projector is either a compaction signal
          // (reason auto_compact — no reload, the divider marker handles it) or
          // a delta-gap recovery (reason delta_gap — a real resync, routed to
          // onResync with the real frame.seq, mirroring the protocol path).
          if (appEvent.type === 'historyCompacted' && !isCompactionReason(appEvent.reason)) {
            handlers.onResync(sessionId, seq);
          }
          handlers.onEvent(appEvent, { sessionId, seq });
        }
      },

      onResync: (sessionId: string, currentSeq: number, epoch?: string) => {
        // Reset per-session projector state on resync
        projector.reset(sessionId);
        handlers.onResync(sessionId, currentSeq, epoch);
      },

      onConnectionState: (connected: boolean) => {
        handlers.onConnectionChange(connected);
      },