Pagination

import json, os, urllib.parse, urllib.request

BASE = "https://api.routeur.app"
HEADERS = {"X-API-Key": os.environ["ROUTEUR_API_KEY"]}

def get(path, **params):
    url = BASE + path + "?" + urllib.parse.urlencode(params)
    with urllib.request.urlopen(urllib.request.Request(url, headers=HEADERS), timeout=20) as r:
        return json.load(r)

def all_trades(venue, market_id, limit=1000):
    params = {"limit": limit}
    while True:
        page = get(f"/v1/markets/{venue}/{market_id}/trades", **params)
        yield from page["data"]
        if "next_cursor" not in page:
            return
        params["cursor"] = page["next_cursor"]

n = 0
for trade in all_trades("kalshi", "KXNFLTOTAL-26SEP17DETBUF-55"):
    n += 1
print(n, "trades")

const headers = { "X-API-Key": process.env.ROUTEUR_API_KEY };

async function* allMarkets(q) {
  const params = new URLSearchParams({ q, limit: "100" });
  while (true) {
    const res = await fetch(`https://api.routeur.app/v1/markets?${params}`, { headers });
    const page = await res.json();
    yield* page.data;
    if (!page.next_cursor) return;
    params.set("cursor", page.next_cursor);
  }
}

let n = 0;
for await (const market of allMarkets("bitcoin")) n++;
console.log(n, "markets");