Function startReplyStream

apps/web/components/codex-sessions-shell.tsx:807–836

(runId: string, draftId: string, draftTimestamp: string)

  }

  function startReplyStream(runId: string, draftId: string, draftTimestamp: string) {
    closeReplyStream();
    const stream = new EventSource(`/api/codex-threads/${encodeURIComponent(threadId)}/runs/${encodeURIComponent(runId)}/events`);
    replyStreamRef.current = stream;

    const handleSnapshot = (event: MessageEvent<string>) => {
      try {
        const snapshot = JSON.parse(event.data) as ReplyRunSnapshot;
        applyRunSnapshot(snapshot, draftId, draftTimestamp);
      } catch {
        // Ignore malformed SSE chunks.
      }
    };

    stream.addEventListener('snapshot', handleSnapshot);
    stream.addEventListener('started', handleSnapshot);
    stream.addEventListener('assistant', handleSnapshot);
    stream.addEventListener('commentary', handleSnapshot);
    stream.addEventListener('done', handleSnapshot);
    stream.addEventListener('failed', handleSnapshot);
    stream.onerror = () => {
      if (stream.readyState !== EventSource.CLOSED) {
        return;
      }
      replaceStreamFailureMessage(draftId, draftTimestamp, '连接已中断，请稍后重试。');
      setReplyError('连接已中断，请稍后重试。');
      setSendingReply(false);
      closeReplyStream();
    };
  }

  useEffect(() => {
    setThreadMessages(initialThreadMessages);