curl -N https://api.u1.archetypeai.app/v0.5/lens/sessions/consumer/lsn-250313c2177253cbaa7a73542edd90 \
  -H "Authorization: Bearer $ATAI_API_KEY" \
  -H "Accept: text/event-stream"

import json
import requests
import os

api_key = os.environ.get("ATAI_API_KEY")
session_id = "lsn-250313c2177253cbaa7a73542edd90"

with requests.get(
    f"https://api.u1.archetypeai.app/v0.5/lens/sessions/consumer/{session_id}",
    headers={
        "Authorization": f"Bearer {api_key}",
        "Accept": "text/event-stream",
    },
    stream=True,
    timeout=(10, None),
) as resp:
    resp.raise_for_status()
    for line in resp.iter_lines(decode_unicode=True):
        if not line or not line.startswith("data:"):
            continue
        payload = json.loads(line[len("data:"):].strip())
        if payload.get("type") == "sse.stream.heartbeat":
            continue
        if payload.get("type") == "sse.stream.end":
            break
        print(payload)

from archetypeai import ArchetypeAI

client = ArchetypeAI()
reader = client.lens.create_sse_consumer(session_id="lsn-250313c2177253cbaa7a73542edd90")
for event in reader.read(block=True):
    print(event)

// EventSource cannot set Authorization headers; use fetch with a streaming
// reader instead.
const sessionId = "lsn-250313c2177253cbaa7a73542edd90";

const response = await fetch(
  `https://api.u1.archetypeai.app/v0.5/lens/sessions/consumer/${sessionId}`,
  {
    headers: {
      Authorization: `Bearer ${process.env.ATAI_API_KEY}`,
      Accept: "text/event-stream",
    },
  }
);

const reader = response.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 });

  let idx;
  while ((idx = buffer.indexOf("\n\n")) !== -1) {
    const frame = buffer.slice(0, idx);
    buffer = buffer.slice(idx + 2);

    const dataLine = frame.split("\n").find((l) => l.startsWith("data:"));
    if (!dataLine) continue;
    const payload = JSON.parse(dataLine.slice("data:".length).trim());
    if (payload.type === "sse.stream.heartbeat") continue;
    if (payload.type === "sse.stream.end") return;
    console.log(payload);
  }
}

event: message
data: {"type": "sse.stream.start", "event_data": {"session_id": "lsn-...", "reader_id": "87e6d51c992557bc"}}

event: message
data: {"type": "sse.stream.heartbeat", "event_data": {"session_id": "lsn-...", "session_status": "SESSION_STATUS_RUNNING", "num_messages": 0, "num_bytes": 0, "message_timeout": 5.0}}

event: message
data: {"type": "inference.result", "timestamp": 1741843200.123, "data": {"result": "A construction worker wearing a hard hat and safety vest"}}

event: message
data: {"type": "sse.stream.end"}

{
  "errors": [
    {
      "code": "unauthorized_request",
      "message": "Unauthorized or invalid access.",
      "suggestion": "Provide valid authentication credentials and ensure they have the required permissions.",
      "error_uid": "err-xxxxxxxx"
    }
  ]
}

{
  "errors": [
    {
      "code": "session_not_found",
      "message": "No session with the given session_id was found for the organization.",
      "suggestion": "Verify the session_id and that the session has not been destroyed.",
      "error_uid": "err-xxxxxxxx"
    }
  ]
}