Pagination

# The first page, then the next one with the cursor from the first.
curl "https://api.citino.ai/v1/projects/$PROJECT_ID/prompts" -H "Authorization: Bearer $CITINO_API_KEY"
curl "https://api.citino.ai/v1/projects/$PROJECT_ID/prompts?cursor=$NEXT_CURSOR" -H "Authorization: Bearer $CITINO_API_KEY"

import os
import requests

BASE = "https://api.citino.ai/v1"
key = os.environ["CITINO_API_KEY"]
project_id = os.environ["PROJECT_ID"]
session = requests.Session()
session.headers["Authorization"] = f"Bearer {key}"


def every_row(path, **params):
    """Yield every row of a list route, page by page."""
    cursor = None
    while True:
        query = dict(params, **({"cursor": cursor} if cursor else {}))
        response = session.get(f"{BASE}{path}", params=query)
        response.raise_for_status()
        page = response.json()
        yield from page["items"]
        if not page["has_more"]:
            return
        cursor = page["next_cursor"]


for prompt in every_row(f"/projects/{project_id}/prompts"):
    print(prompt["id"], prompt["text"])

const BASE = "https://api.citino.ai/v1";
const headers = { Authorization: `Bearer ${process.env.CITINO_API_KEY}` };

// Every row of a list route, page by page.
async function* everyRow(path, params = {}) {
  let cursor = null;
  for (;;) {
    const query = new URLSearchParams({ ...params, ...(cursor ? { cursor } : {}) });
    const response = await fetch(`${BASE}${path}?${query}`, { headers });
    if (!response.ok) throw new Error(`Citino answered ${response.status}`);
    const page = await response.json();
    yield* page.items;
    if (!page.has_more) return;
    cursor = page.next_cursor;
  }
}

for await (const prompt of everyRow(`/projects/${process.env.PROJECT_ID}/prompts`)) {
  console.log(prompt.id, prompt.text);
}