Stream a Run's Output

GET https://api.vyomflow.co.in/api/public/v1/runs/{runId}/stream

const res = await fetch(
  `https://api.vyomflow.co.in/api/public/v1/runs/${runId}/stream`,
  { headers: { Authorization: `Bearer ${process.env.VYOMFLOW_API_KEY}` } },
);

const reader = res.body.getReader();
const decoder = new TextDecoder();
let buffer = "";

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

  // SSE frames are separated by a blank line.
  const frames = buffer.split("\n\n");
  buffer = frames.pop(); // keep the last (possibly incomplete) frame

  for (const frame of frames) {
    if (!frame || frame.startsWith(":")) continue; // comment (heartbeat/connected)
    const lines = frame.split("\n");
    const event = lines.find((l) => l.startsWith("event: "))?.slice(7);
    const data = lines.find((l) => l.startsWith("data: "))?.slice(6);
    const id = lines.find((l) => l.startsWith("id: "))?.slice(4);
    if (event && data) console.log(event, JSON.parse(data), "id:", id);
  }
}

curl -N --http1.1 \
  -H "Authorization: Bearer $VYOMFLOW_API_KEY" \
  https://api.vyomflow.co.in/api/public/v1/runs/$RUN_ID/stream

id: <streamIndex>
event: <eventName>
data: <JSON payload>

{
  "runId": "run_01JXYZABCDEF1234567890",
  "status": "running",
  "lastStreamIndex": 12,
  "cancelRequestedAt": null
}

{ "index": 4, "channel": "text", "delta": "Hello" }

{
  "index": 6,
  "toolInvocationId": "tinv_01JXYZ1111111111111111",
  "toolCallId": "call_abc123",
  "name": "magica_crop_image",
  "turnIndex": 0,
  "callIndex": 0,
  "status": "running",
  "creditUsed": 0.5,
  "resultUrls": ["https://..."],
  "errorMessage": null
}

{
  "index": 8,
  "waitpoint": {
    "id": "wp_01JXYZ2222222222222222",
    "status": "PENDING",
    "kind": "CREDIT_APPROVAL"
  }
}

{
  "runId": "run_01JXYZABCDEF1234567890",
  "status": "completed",
  "assistantMessageId": "msg_01JXYZ0987654321FEDCBA",
  "totalCreditsUsed": 1.5,
  "errorCode": null,
  "errorMessage": null
}

{ "reason": "duration_limit", "nextFromIndex": 137 }