Function processEvent

apps/kimi-web/src/composables/useKimiWebClient.ts:759–823

(appEvent: AppEvent, meta: { sessionId: string; seq: number })

type PendingEvent = { appEvent: AppEvent; meta: { sessionId: string; seq: number } };

function processEvent(appEvent: AppEvent, meta: { sessionId: string; seq: number }): void {
  // meta carries wire-level seq/sessionId so the reducer can advance
  // lastSeqBySession[sessionId] = seq. Compaction completion appends a
  // persistent divider marker in the reducer (TUI parity: the scrollback
  // is kept, only a marker line records the compaction).
  applyEvent(appEvent, meta.sessionId, meta.seq);

  const sideTarget = sideChat.sideChatTargetBySession.value[meta.sessionId];
  if (sideTarget) {
    const { agentId } = sideTarget;
    const parentId = meta.sessionId;
    if (appEvent.type === 'agentDelta' && appEvent.agentId === agentId) {
      if (appEvent.delta.text) {
        sideChat.appendSideChatAssistantText(agentId, parentId, appEvent.delta.text);
      }
    } else if (appEvent.type === 'agentTurnEnded' && appEvent.agentId === agentId) {
      sideChat.finishSideChatAgent(agentId, parentId);
    } else if (appEvent.type === 'taskProgress' && appEvent.taskId === agentId) {
      sideChat.appendSideChatAssistantText(agentId, parentId, appEvent.outputChunk);
    } else if (appEvent.type === 'taskCompleted' && appEvent.taskId === agentId) {
      sideChat.finishSideChatAgent(agentId, parentId, appEvent.outputPreview);
    }
  }

  // The daemon's prompt.submitted event is projected as a user messageCreated
  // carrying the real prompt_id. When the HTTP submit response is lost
  // (timeout / network error) this is the fallback that lets Stop work.
  if (
    appEvent.type === 'messageCreated' &&
    appEvent.message.role === 'user' &&
    appEvent.message.promptId !== undefined
  ) {
    const sid = appEvent.message.sessionId;
    if (rawState.promptIdBySession[sid] !== appEvent.message.promptId) {
      rawState.promptIdBySession = {
        ...rawState.promptIdBySession,
        [sid]: appEvent.message.promptId,
      };
    }
  }

  if (appEvent.type === 'assistantDelta' && meta.sessionId === rawState.activeSessionId) {
    appearance.recordMoonDelta((appEvent.delta.text?.length ?? 0) + (appEvent.delta.thinking?.length ?? 0));
  }

  // Turn-end cleanup for the session the event belongs to — including
  // sessions running in the background (see onSessionIdle).
  // Turn-end: both 'idle' and 'aborted' mean the prompt is no longer in
  // flight, so both must flush in-flight/queued state. (Awaiting-* is still
  // in flight — it's waiting on the user — and must NOT flush.)
  if (
    appEvent.type === 'sessionStatusChanged' &&
    (appEvent.status === 'idle' || appEvent.status === 'aborted')
  ) {
    onSessionIdle(appEvent.sessionId, appEvent.status);
  }

  // The agent asked a question and is waiting for an answer — surface it so