Pagination

async function* listAll(path: string, params: Record<string, string> = {}) {
  let cursor: string | null = null;
  do {
    const query = new URLSearchParams({ ...params, limit: "100", ...(cursor ? { cursor } : {}) });
    const page = await fetch(`https://app.reflections.ai/v1${path}?${query}`, {
      headers: {
        Authorization: `Bearer ${process.env.REFLECTIONS_KEY}`,
        "Reflections-Version": "2026-10-15",
      },
    }).then((r) => r.json());
    yield* page.data;
    cursor = page.has_more ? page.next_cursor : null;
  } while (cursor);
}

for await (const license of listAll("/licenses", { status: "active" })) {
  console.log(license.id, license.handle);
}

import os, requests

def list_all(path, **params):
    headers = {
        "Authorization": f"Bearer {os.environ['REFLECTIONS_KEY']}",
        "Reflections-Version": "2026-10-15",
    }
    params = {**params, "limit": 100}
    while True:
        page = requests.get(f"https://app.reflections.ai/v1{path}", headers=headers, params=params).json()
        yield from page["data"]
        if not page["has_more"]:
            break
        params["cursor"] = page["next_cursor"]

for license in list_all("/licenses", status="active"):
    print(license["id"], license["handle"])

let after: string = await loadLastRevocationId(); // for example "rvk_s9t0wxyhk5zba2q8v1m3n7p4r6"

async function pollRevocations() {
  let hasMore = true;
  while (hasMore) {
    const query = new URLSearchParams({ limit: "100", after });
    const res = await fetch(`https://app.reflections.ai/v1/revocations?${query}`, {
      headers: {
        Authorization: `Bearer ${process.env.REFLECTIONS_KEY}`,
        "Reflections-Version": "2026-10-15",
      },
    });
    if (!res.ok) throw new Error(`List revocations failed: ${res.status}`); // retry on the next poll
    const page = await res.json();
    for (const revocation of page.data) {
      await applyRevocation(revocation);
      after = revocation.id;
      await saveLastRevocationId(after);
    }
    hasMore = page.has_more;
  }
}

setInterval(pollRevocations, 30_000);

import os, time, requests

after = load_last_revocation_id()  # for example "rvk_s9t0wxyhk5zba2q8v1m3n7p4r6"

def poll_revocations():
    global after
    while True:
        res = requests.get(
            "https://app.reflections.ai/v1/revocations",
            headers={
                "Authorization": f"Bearer {os.environ['REFLECTIONS_KEY']}",
                "Reflections-Version": "2026-10-15",
            },
            params={"limit": 100, "after": after},
        )
        res.raise_for_status()  # retry on the next poll
        page = res.json()
        for revocation in page["data"]:
            apply_revocation(revocation)
            after = revocation["id"]
            save_last_revocation_id(after)
        if not page["has_more"]:
            break

while True:
    poll_revocations()
    time.sleep(30)