Stream Logs

curl -sN \
  -H "Authorization: Bearer $REACTOR_API_KEY" \
  "https://api.reactor.inc/logs?session_id=$SESSION_ID"

curl -sN \
  -H "Authorization: Bearer $REACTOR_API_KEY" \
  "https://api.reactor.inc/logs?machine_id=$MACHINE_ID"

// Run this in your backend. EventSource is unsupported because it cannot set
// custom headers, and the raw API key must never reach a browser.
// Use fetch + a ReadableStream reader and parse SSE frames yourself.
const url = new URL("https://api.reactor.inc/logs");
url.searchParams.set("session_id", sessionId);

const resp = await fetch(url, {
  headers: {
    Authorization: `Bearer ${apiKey}`,
    Accept: "text/event-stream",
  },
});
if (!resp.ok || !resp.body) {
  throw new Error(`stream rejected: ${resp.status}`);
}

const reader = resp.body.pipeThrough(new TextDecoderStream()).getReader();
let buffer = "";

for (;;) {
  const { value, done } = await reader.read();
  if (done) break;
  buffer += value;

  // SSE frames are separated by a blank line ("\n\n").
  let sep;
  while ((sep = buffer.indexOf("\n\n")) !== -1) {
    const frame = buffer.slice(0, sep);
    buffer = buffer.slice(sep + 2);

    let event = "";
    const dataLines = [];
    for (const raw of frame.split("\n")) {
      const line = raw.replace(/\r$/, "");
      if (line.startsWith(":")) continue; // SSE comment / keepalive
      const idx = line.indexOf(":");
      const field = idx === -1 ? line : line.slice(0, idx);
      const value = idx === -1 ? "" : line.slice(idx + 1).replace(/^ /, "");
      if (field === "event") event = value;
      else if (field === "data") dataLines.push(value);
    }
    if (!event) continue;
    const payload = JSON.parse(dataLines.join("\n"));

    if (event === "log") console.log(payload.timestamp, payload.line);
    else if (event === "end") return;
  }
}

import httpx, json

async def stream_logs(session_id: str, api_key: str) -> None:
    headers = {"Authorization": f"Bearer {api_key}"}
    params = {"session_id": session_id}
    async with httpx.AsyncClient(timeout=None) as client:
        async with client.stream(
            "GET", "https://api.reactor.inc/logs",
            params=params, headers=headers,
        ) as resp:
            resp.raise_for_status()
            event, data_lines = "", []
            async for raw in resp.aiter_lines():
                line = raw.rstrip("\r")
                if line == "":
                    if event:
                        payload = json.loads("\n".join(data_lines))
                        yield event, payload
                    event, data_lines = "", []
                    continue
                field, _, value = line.partition(":")
                value = value.removeprefix(" ")
                if field == "event":
                    event = value
                elif field == "data":
                    data_lines.append(value)