Pagination

curl "https://api.zquence.ai/v1/accounts?limit=50&starting_after=tx_01HX3ZF..." \
  -H "x-api-key: $ZQUENCE_PUBLIC_KEY" \
  -H "x-api-secret: $ZQUENCE_SECRET_KEY"

async function* paginate(path: string, params: Record<string, string> = {}) {
  let cursor: string | null = null;
  do {
    const q = new URLSearchParams({ ...params, limit: "50", ...(cursor ? { starting_after: cursor } : {}) });
    const res  = await fetch(`https://api.zquence.ai/v1${path}?${q}`, { headers: authHeaders });
    const page = await res.json();
    for (const row of page.data) yield row;
    cursor = page.hasMore ? page.nextCursor : null;
  } while (cursor);
}

for await (const tx of paginate("/accounts")) {
  await process(tx);
}

def paginate(path, **params):
    cursor = None
    while True:
        q = {**params, "limit": 50, **({"starting_after": cursor} if cursor else {})}
        page = requests.get(f"https://api.zquence.ai/v1{path}",
                            headers=auth_headers, params=q).json()
        for row in page["data"]:
            yield row
        if not page["hasMore"]:
            return
        cursor = page["nextCursor"]

for tx in paginate("/accounts"):
    process(tx)