Pagination

import os, requests

API = "https://api.onlyx.ai/v1"
HEADERS = {"Authorization": f"Bearer {os.environ['ONLYX_API_KEY']}"}


def paginate(path, **params):
    """Yield every item of a list endpoint."""
    params.setdefault("limit", 100)
    while True:
        r = requests.get(f"{API}{path}", headers=HEADERS, params=params, timeout=30)
        r.raise_for_status()
        page = r.json()
        yield from page["data"]
        if not page["hasMore"]:
            return
        params["cursor"] = page["nextCursor"]


for fan in paginate("/fans", creatorId="cre_5f2d9a1c7b3e4f60a2d1", sort="spend", order="desc"):
    print(fan["displayName"], fan["totalSpentCents"])

const API = "https://api.onlyx.ai/v1";
const headers = { Authorization: `Bearer ${process.env.ONLYX_API_KEY}` };

async function* paginate(path, params = {}) {
  const query = { limit: "100", ...params };
  for (;;) {
    const res = await fetch(`${API}${path}?${new URLSearchParams(query)}`, { headers });
    if (!res.ok) throw new Error(`${res.status} ${await res.text()}`);
    const page = await res.json();
    yield* page.data;
    if (!page.hasMore) return;
    query.cursor = page.nextCursor;
  }
}

for await (const fan of paginate("/fans", { creatorId: "cre_5f2d9a1c7b3e4f60a2d1", sort: "spend", order: "desc" })) {
  console.log(fan.displayName, fan.totalSpentCents);
}

# first page
curl "https://api.onlyx.ai/v1/fans?limit=100" -H "Authorization: Bearer $ONLYX_API_KEY"
# next page: pass nextCursor from the previous response
curl "https://api.onlyx.ai/v1/fans?limit=100&cursor=eyJvIjoxMDB9" -H "Authorization: Bearer $ONLYX_API_KEY"