Function startRun

examples/plan-explore-ui/static/main.js:48–116

()

  }

  function startRun() {
    const prompt = promptEl.value.trim();
    if (!prompt) return;

    clearPhases();
    setStatus("运行中...");
    runBtn.disabled = true;

    if (currentController) {
      currentController.abort();
    }
    currentController = new AbortController();

    fetch("/api/chat/stream", {
      method: "POST",
      headers: { "Content-Type": "application/json" },
      body: JSON.stringify({ input: prompt }),
      signal: currentController.signal,
    })
      .then((response) => {
        if (!response.ok) {
          appendPhaseLine(`请求失败: ${response.status}`, "error");
          setStatus("请求失败");
          runBtn.disabled = false;
          return;
        }

        const reader = response.body.getReader();
        const decoder = new TextDecoder("utf-8");
        let buffer = "";
        const uiState = { currentPhase: null, textStarted: false };

        function pump() {
          reader
            .read()
            .then(({ done, value }) => {
              if (done) {
                setStatus("完成");
                runBtn.disabled = false;
                return;
              }
              buffer += decoder.decode(value, { stream: true });
              let idx;
              while ((idx = buffer.indexOf("\n\n")) >= 0) {
                const raw = buffer.slice(0, idx);
                buffer = buffer.slice(idx + 2);
                handleSSEChunk(raw, uiState);
              }
              pump();
            })
            .catch((err) => {
              if (err.name !== "AbortError") {
                appendPhaseLine(`流式读取出错: ${err}`, "error");
                setStatus("出错");
                runBtn.disabled = false;
              }
            });
        }