Pagination

async function* fetchAll(path, filters = {}) {
  let cursor = null;
  do {
    const url = new URL(`https://sandbox.api.safeonuba.com${path}`);
    for (const [k, v] of Object.entries(filters)) url.searchParams.set(k, v);
    url.searchParams.set('limit', '100');
    if (cursor) url.searchParams.set('cursor', cursor);

    const res = await fetch(url, { headers: { Authorization: `Bearer ${await safeOnubaToken()}` } });
    if (!res.ok) throw new Error(`${res.status}: ${await res.text()}`);
    const page = await res.json();
    yield* page.data;
    cursor = page.next_cursor;
  } while (cursor);
}

for await (const alert of fetchAll('/v1/alerts', { status: 'unacknowledged' })) {
  console.log(alert.id, alert.title);
}

def fetch_all(path: str, **filters):
    cursor = None
    while True:
        params = {**filters, "limit": 100}
        if cursor:
            params["cursor"] = cursor
        res = requests.get(
            f"https://sandbox.api.safeonuba.com{path}",
            headers={"Authorization": f"Bearer {safeonuba_token()}"},
            params=params,
            timeout=30,
        )
        res.raise_for_status()
        page = res.json()
        yield from page["data"]
        cursor = page["next_cursor"]
        if not cursor:
            return

for alert in fetch_all("/v1/alerts", status="unacknowledged"):
    print(alert["id"], alert["title"])

async IAsyncEnumerable<JsonElement> FetchAll(string path, string filters = "")
{
    string? cursor = null;
    do
    {
        var url = $"https://sandbox.api.safeonuba.com{path}?limit=100{filters}"
                  + (cursor is null ? "" : $"&cursor={Uri.EscapeDataString(cursor)}");
        var res = await http.GetAsync(url);
        res.EnsureSuccessStatusCode();
        var page = await res.Content.ReadFromJsonAsync<JsonElement>();
        foreach (var element in page.GetProperty("data").EnumerateArray()) yield return element;
        var next = page.GetProperty("next_cursor");
        cursor = next.ValueKind == JsonValueKind.Null ? null : next.GetString();
    } while (cursor is not null);
}

await foreach (var alert in FetchAll("/v1/alerts", "&status=unacknowledged"))
    Console.WriteLine(alert.GetProperty("title").GetString());