Stream reconnectable durable-run events

curl --fail-with-body --no-buffer -X GET 'https://api.praxa.io/v1/runs/018f0000-0000-7000-8000-000000000001/events' \
  -H "Authorization: Bearer $PRAXA_API_KEY" \
  -H "Last-Event-ID: 0" \
  -H "Accept: text/event-stream"

const response = await fetch("https://api.praxa.io/v1/runs/018f0000-0000-7000-8000-000000000001/events", {
  "method": "GET",
  "headers": {
    "Authorization": `Bearer ${process.env.PRAXA_API_KEY}`,
    "Last-Event-ID": "0",
    "Accept": "text/event-stream"
  }
});
if (!response.ok) throw new Error(`${response.status}: ${await response.text()}`);
if (!response.body) throw new Error("SSE response had no body");
const decoder = new TextDecoder();
let buffer = "";
for await (const chunk of response.body) {
  buffer = (buffer + decoder.decode(chunk, { stream: true })).replaceAll("\r\n", "\n");
  for (;;) {
    const boundary = buffer.indexOf("\n\n");
    if (boundary < 0) break;
    const frame = buffer.slice(0, boundary);
    buffer = buffer.slice(boundary + 2);
    if (frame && !frame.startsWith(":")) console.log(frame);
  }
}

import json
import os
from urllib import error, request

req = request.Request(
    "https://api.praxa.io/v1/runs/018f0000-0000-7000-8000-000000000001/events",
    method="GET",
    headers={
      "Authorization": f"Bearer {os.environ['PRAXA_API_KEY']}",
      "Last-Event-ID": "0",
      "Accept": "text/event-stream"
    },
)
try:
    with request.urlopen(req, timeout=30) as response:
        frame_lines = []
        for raw_line in response:
            line = raw_line.decode("utf-8").rstrip("\r\n")
            if line:
                if not line.startswith(":"):
                    frame_lines.append(line)
            elif frame_lines:
                print("\n".join(frame_lines), flush=True)
                frame_lines.clear()
        if frame_lines:
            print("\n".join(frame_lines), flush=True)
except error.HTTPError as exc:
    raise RuntimeError(f"{exc.code}: {exc.read().decode()}") from exc