async function resumeStream(workflowRunId, apiKey) {
const response = await fetch(
`https://www.verahealth.ai/api/chat/v2/stream/${workflowRunId}`,
{headers: {"x-api-key": apiKey}},
);
if (!response.ok) throw new Error(`Resume failed: ${response.status}`);
const reader = response.body.getReader();
const decoder = new TextDecoder();
let buffer = "";
while (true) {
const {done, value} = await reader.read();
if (done) break;
buffer += decoder.decode(value, {stream: true});
const frames = buffer.split("\n\n");
buffer = frames.pop() ?? "";
for (const frame of frames) {
const line = frame.trim();
if (!line.startsWith("data: ")) continue;
const event = JSON.parse(line.slice(6));
console.log(event);
}
}
}
