Cursors and paging

# First page
curl -sS "https://api.smry.ai/v1/library/items?limit=50&status=inbox" \
  -H "Authorization: Bearer $SMRY_API_KEY"

# Next page — same filters, plus the cursor you were handed
curl -sS "https://api.smry.ai/v1/library/items?limit=50&status=inbox&cursor=Nv8kQ4tLm1sPd60Zr7hXc2" \
  -H "Authorization: Bearer $SMRY_API_KEY"

import os
import httpx

KEY = os.environ["SMRY_API_KEY"]
BASE = "https://api.smry.ai"

def all_inbox_items():
    # Filters are fixed for the whole loop. Changing one invalidates the cursor.
    params = {"limit": 100, "status": "inbox"}
    cursor = None
    with httpx.Client(headers={"Authorization": f"Bearer {KEY}"}, timeout=60) as client:
        while True:
            page = {**params, **({"cursor": cursor} if cursor else {})}
            response = client.get(BASE + "/v1/library/items", params=page)
            response.raise_for_status()
            body = response.json()

            yield from body["items"]

            cursor = body["nextCursor"]   # camelCase, string or null
            if not cursor:
                return

for item in all_inbox_items():
    print(item["id"], item["title"])

const KEY = process.env.SMRY_API_KEY!;
const BASE = "https://api.smry.ai";

interface LibraryPage {
  items: Array<{ id: string; title: string }>;
  nextCursor: string | null;
}

export async function* allInboxItems() {
  // Filters are fixed for the whole loop. Changing one invalidates the cursor.
  const filters = { limit: "100", status: "inbox" };
  let cursor: string | null = null;

  for (;;) {
    const query = new URLSearchParams(filters);
    if (cursor) query.set("cursor", cursor);

    const response = await fetch(`${BASE}/v1/library/items?${query}`, {
      headers: { Authorization: `Bearer ${KEY}` },
    });
    if (!response.ok) throw new Error(`page failed: ${response.status}`);

    const page = (await response.json()) as LibraryPage;
    yield* page.items;

    cursor = page.nextCursor; // camelCase, string or null
    if (!cursor) return;
  }
}

# 1. Bootstrap. Returns next_cursor and NO events.
curl -sS -X POST "https://api.smry.ai/v1/feeds/changes" \
  -H "Authorization: Bearer $SMRY_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{"cursor": "latest", "limit": 50}'

# 2. Poll with the cursor you stored. This one returns events.
curl -sS -X POST "https://api.smry.ai/v1/feeds/changes" \
  -H "Authorization: Bearer $SMRY_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{"cursor": "Zr7hXc2Nv9kQ4t...", "limit": 50}'

import os, time
import httpx

KEY = os.environ["SMRY_API_KEY"]
BASE = "https://api.smry.ai"

def poll_feeds(where=None, state_file="cursor.txt"):
    headers = {"Authorization": f"Bearer {KEY}"}
    # The predicate is fingerprinted into the cursor. Keep it identical, or restart.
    body = {"limit": 100, **({"where": where} if where else {})}

    try:
        cursor = open(state_file).read().strip()
    except FileNotFoundError:
        cursor = "latest"   # First run only. Returns no events.

    with httpx.Client(headers=headers, timeout=60) as client:
        while True:
            response = client.post(BASE + "/v1/feeds/changes", json={**body, "cursor": cursor})
            response.raise_for_status()
            page = response.json()

            for event in page["events"]:
                handle(event)

            cursor = page["next_cursor"]         # snake_case
            open(state_file, "w").write(cursor)  # Persist BEFORE sleeping.

            if not page["has_more"]:
                time.sleep(300)                  # Drained. Wait, then poll again.

const KEY = process.env.SMRY_API_KEY!;
const BASE = "https://api.smry.ai";

interface ChangesPage {
  events: Array<Record<string, unknown>>;
  has_more: boolean;
  next_cursor: string;
}

export async function pollFeeds(
  load: () => Promise<string | null>,
  save: (cursor: string) => Promise<void>,
  where?: Record<string, unknown>,
) {
  // The predicate is fingerprinted into the cursor. Keep it identical, or restart.
  const base = { limit: 100, ...(where ? { where } : {}) };
  let cursor = (await load()) ?? "latest"; // First run only. Returns no events.

  for (;;) {
    const response = await fetch(`${BASE}/v1/feeds/changes`, {
      method: "POST",
      headers: {
        Authorization: `Bearer ${KEY}`,
        "Content-Type": "application/json",
      },
      body: JSON.stringify({ ...base, cursor }),
    });
    if (!response.ok) throw new Error(`poll failed: ${response.status}`);

    const page = (await response.json()) as ChangesPage;
    for (const event of page.events) await handle(event);

    cursor = page.next_cursor; // snake_case
    await save(cursor); // Persist BEFORE sleeping.

    if (!page.has_more) await new Promise((r) => setTimeout(r, 300_000));
  }
}