Function processFrame

deployments/desktop/static/desktop.js:4542–4574

(frame)

    let doneReceived = false;

    const processFrame = (frame) => {
      if (!frame.trim()) return;
      const parsed = parseSseFrame(frame);
      if (!parsed) return;
      if (parsed.event === "error") throw new Error(parsed.data.error || ui().chat.streamFailed);
      if (parsed.event === "status" && !text) {
        answerTarget.innerHTML = `<p>${escapeHtml(parsed.data.text || ui().chat.generating)}</p>`;
      }
      if (parsed.event === "meta") {
        result = { ...result, ...parsed.data };
        citations = normalizeCitations(parsed.data);
        const metaTarget = message.querySelector(".answer-meta");
        if (metaTarget) metaTarget.outerHTML = renderAnswerMeta(parsed.data, citations);
        renderChatSources(citations);
      }
      if (parsed.event === "chunk") {
        text += parsed.data.text || "";
        answerTarget.classList.remove("loading");
        answerTarget.innerHTML = renderAnswerWithCitations(text, citations);
        $("chatThread").scrollTop = $("chatThread").scrollHeight;
      }
      if (parsed.event === "done") {
        doneReceived = true;
        result = { ...result, ...parsed.data };
        text = parsed.data.text || text;
        citations = normalizeCitations(parsed.data);
        const metaTarget = message.querySelector(".answer-meta");
        if (metaTarget) metaTarget.outerHTML = renderAnswerMeta(parsed.data, citations);
        answerTarget.classList.remove("loading");
        answerTarget.innerHTML = renderAnswerWithCitations(text, citations);
        renderChatSources(citations);
      }
    };

    while (true) {
      const { value, done } = await reader.read();