Events

curl "https://upbutler.com/api/v1/events?types=monitor.down,monitor.up&limit=2" \
  -H "Authorization: Bearer $UPBUTLER_API_KEY"

{
  "data": [
    {
      "id": "evt_0n3qb7c21k4m6p8r0t2",
      "type": "monitor.up",
      "at": "2026-10-09T08:26:02.311Z",
      "data": { "monitor": { "_id": "mon_0n3q8kz1m4hx7c2v9rt", "name": "Search API", ... }, "downtimeSeconds": 811, ... }
    },
    {
      "id": "evt_0n3q9a12c4r7m1t8wxe",
      "type": "monitor.down",
      "at": "2026-10-09T08:12:31.880Z",
      "data": { "monitor": { ... }, "check": { ... }, "incident": { ... }, "ai": { ... } }
    }
  ],
  "next": "evt_0n3q9a12c4r7m1t8wxe"
}

const API = "https://upbutler.com/api/v1";
const headers = { Authorization: `Bearer ${process.env.UPBUTLER_API_KEY}` };

// Start at "now": the newest event id (the list is newest-first without "after").
const first = await (await fetch(`${API}/events?limit=1`, { headers })).json();
let cursor: string | null = first.data[0]?.id ?? null;

while (true) {
  const url = new URL(`${API}/events`);
  if (cursor) url.searchParams.set("after", cursor); // oldest-first after the cursor
  url.searchParams.set("limit", "500");
  const page = await (await fetch(url, { headers })).json();

  for (const event of page.data) await handle(event); // in order
  cursor = page.next ?? cursor;                      // persist this somewhere durable

  if (page.data.length < 500) await Bun.sleep(15_000); // caught up: wait a bit
}

async function handle(e: { id: string; type: string; data: any }) {
  if (e.type === "monitor.down") console.log("DOWN", e.data.monitor.name, e.data.ai?.analysis ?? "");
}

cursor=""
while true; do
  resp=$(curl -fsS -G https://upbutler.com/api/v1/events \
    -H "Authorization: Bearer $UPBUTLER_API_KEY" \
    ${cursor:+--data-urlencode "after=$cursor"} --data-urlencode "limit=100")
  echo "$resp" | jq -c '.data[] | {id, type, at}'
  next=$(echo "$resp" | jq -r '.next // empty')
  # without a cursor the list is newest-first; start after the newest one
  [ -z "$cursor" ] && next=$(echo "$resp" | jq -r '.data[0].id // empty')
  cursor=${next:-$cursor}
  sleep 15
done

curl -N "https://upbutler.com/api/v1/stream?types=monitor.*,incident.created" \
  -H "Authorization: Bearer $UPBUTLER_KEY"

id: evt_0n3q9a12c4r7m1t8wxe
data: {"id":"evt_0n3q9a12c4r7m1t8wxe","type":"monitor.down","at":"2026-10-09T09:12:19.000Z","data":{…}}

: ping

// Reads the SSE stream with fetch so you can send the Authorization header.
let lastId: string | null = null;
while (true) {
  const res = await fetch("https://upbutler.com/api/v1/stream?types=monitor.*", {
    headers: { Authorization: `Bearer ${process.env.UPBUTLER_API_KEY}`, ...(lastId ? { "Last-Event-ID": lastId } : {}) },
  });
  const reader = res.body!.pipeThrough(new TextDecoderStream()).getReader();
  let buf = "";
  for (;;) {
    const { value, done } = await reader.read();
    if (done) break; // server closes after ~10 min: reconnect and resume
    buf += value;
    let i;
    while ((i = buf.indexOf("\n\n")) >= 0) {
      const frame = buf.slice(0, i); buf = buf.slice(i + 2);
      const id = frame.match(/^id: (.*)$/m)?.[1];
      const data = frame.match(/^data: (.*)$/m)?.[1];
      if (id) lastId = id;
      if (data) handle(JSON.parse(data)); // {id, type, at, data}
    }
  }
}