Stream monitor events live over server-sent events

curl -N "https://xquik.com/api/v1/events/stream" \
  -H "x-api-key: xq_YOUR_KEY_HERE" \
  -H "Last-Event-ID: 42"

let lastEventId;

async function readStream() {
  const response = await fetch("https://xquik.com/api/v1/events/stream", {
    headers: {
      "x-api-key": "xq_YOUR_KEY_HERE",
      ...(lastEventId === undefined ? {} : { "Last-Event-ID": lastEventId }),
    },
  });
  if (!response.ok) throw new Error(`Stream refused: ${response.status}`);
  const decoder = new TextDecoder();
  let buffer = "";
  for await (const chunk of response.body) {
    buffer += decoder.decode(chunk, { stream: true });
    const frames = buffer.split("\n\n");
    buffer = frames.pop() ?? "";
    for (const frame of frames) {
      const fields = Object.fromEntries(
        frame
          .split("\n")
          .filter((line) => line !== "" && !line.startsWith(":"))
          .map((line) => [line.slice(0, line.indexOf(":")), line.slice(line.indexOf(":") + 2)]),
      );
      if (fields.data === undefined) continue;
      lastEventId = fields.id;
      const event = JSON.parse(fields.data);
      process.stdout.write(`${JSON.stringify({ id: event.id, type: event.type })}\n`);
    }
  }
}

// The stream ends after 30 minutes. Reconnect with the last ID.
for (;;) {
  await readStream().catch((error) => console.error(error.message));
  await new Promise((resolve) => setTimeout(resolve, 3000));
}

import json
import time

import requests

last_event_id = None


def read_stream():
    global last_event_id
    headers = {"x-api-key": "xq_YOUR_KEY_HERE"}
    if last_event_id is not None:
        headers["Last-Event-ID"] = last_event_id
    with requests.get(
        "https://xquik.com/api/v1/events/stream",
        headers=headers,
        stream=True,
        timeout=(10, 60),
    ) as response:
        response.raise_for_status()
        fields = {}
        for line in response.iter_lines(decode_unicode=True):
            if line == "":
                if "data" in fields:
                    last_event_id = fields.get("id")
                    event = json.loads(fields["data"])
                    print(json.dumps({"id": event["id"], "type": event["type"]}))
                fields = {}
            elif not line.startswith(":"):
                name, _, value = line.partition(": ")
                fields[name] = value


# The stream ends after 30 minutes. Reconnect with the last ID.
while True:
    try:
        read_stream()
    except requests.RequestException as error:
        print(error)
    time.sleep(3)