Function aggregateStreamToJSON

jetbrains.ts:181–225

(
  stream: ReadableStream<Uint8Array>,
  model: string,
)

}

async function aggregateStreamToJSON(
  stream: ReadableStream<Uint8Array>,
  model: string,
) {
  const decoder = new TextDecoder();
  const reader = stream.getReader();
  let buf = "";
  let content = "";

  for (;;) {
    const { value, done } = await reader.read();
    if (done) break;
    buf += decoder.decode(value, { stream: true });

    let idx: number;
    while ((idx = buf.indexOf("\n")) >= 0) {
      const line = buf.slice(0, idx).trim();
      buf = buf.slice(idx + 1);

      if (!line.startsWith("data: ")) continue;
      if (line === "data: [DONE]") continue;

      try {
        const j = JSON.parse(line.slice(6));
        const delta = j?.choices?.[0]?.delta;
        if (delta?.content) content += delta.content as string;
      } catch {
        /* ignore */
      }
    }
  }

  return {
    id: `chatcmpl-${crypto.randomUUID()}`,
    object: "chat.completion",
    created: Math.floor(Date.now() / 1000),
    model,
    choices: [{
      index: 0,
      message: { role: "assistant", content },
      finish_reason: "stop",
    }],
    usage: { prompt_tokens: 0, completion_tokens: 0, total_tokens: 0 },
  };
}

// ───────────────────────────────────────── handlers ──
async function handleModels(req: ServerRequest) {