Live messages

curl -N "https://api.autumn.ai/task/8fab6f34/stream" \
  -H "X-API-Key: $AUTUMN_API_KEY" \

import os, json, requests

with requests.get(
    "https://api.autumn.ai/task/8fab6f34/stream",
    headers={"X-API-Key": os.environ["AUTUMN_API_KEY"]},
    stream=True,
) as r:
    r.raise_for_status()
    event = None
    for line in r.iter_lines(decode_unicode=True):
        if not line:
            continue
        if line.startswith("event:"):
            event = line[6:].strip()
        elif line.startswith("data:"):
            data = json.loads(line[5:].strip())
            print(f"[{event}] {data['summary']}")
            if data.get("done"):
                break

const res = await fetch("https://api.autumn.ai/task/8fab6f34/stream", {
  headers: { "X-API-Key": process.env.AUTUMN_API_KEY },
});

const reader = res.body.pipeThrough(new TextDecoderStream()).getReader();
let buffer = "";
let event = "";
while (true) {
  const { value, done } = await reader.read();
  if (done) break;
  buffer += value;
  const chunks = buffer.split("\n\n");
  buffer = chunks.pop() ?? "";
  let statusDone = false;
  for (const chunk of chunks) {
    event = chunk.match(/^event:\s*(.*)$/m)?.[1] ?? "";
    const data = chunk.match(/^data:\s*(.*)$/m)?.[1];
    if (data) {
      const status = JSON.parse(data);
      console.log(`[${event}]`, status.summary);
      if (status.done) {
        statusDone = true;
        break;
      }
    }
  }
  if (statusDone) break;
}