Function streamWikiAsk

deployments/desktop/static/desktop.js:4526–4596

(payload, answerTarget, message)

  }

  async function streamWikiAsk(payload, answerTarget, message) {
    const response = await fetch("/api/wiki/ask/stream", {
      method: "POST",
      headers: { "Content-Type": "application/json" },
      body: JSON.stringify(payload)
    });
    if (!response.ok || !response.body) throw new Error(ui().chat.streamUnavailable);

    const decoder = new TextDecoder();
    const reader = response.body.getReader();
    let buffer = "";
    let text = "";
    let result = {};
    let citations = [];
    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();
      if (done) {
        buffer += decoder.decode();
        break;
      }
      buffer += decoder.decode(value, { stream: true });
      const frames = buffer.split(/\n\n/);