Stronicowanie i synchronizacja

const base = "https://attendbeacon.com/api/v1/events/b3ac0000-0000-4000-8000-000000000001/attendees";
const headers = { Authorization: `Bearer ${process.env.ATTENDBEACON_KEY}` };

let since = await loadMark();              // null on the first run
let newest = since;
let cursor = null;

do {
  const url = new URL(base);
  url.searchParams.set("limit", "500");
  if (since) url.searchParams.set("updatedSince", since);
  if (cursor) url.searchParams.set("cursor", cursor);

  const page = await fetch(url, { headers }).then((r) => r.json());
  for (const attendee of page.data) {
    await upsert(attendee);                // by attendee.attendeeId
    if (!newest || attendee.updatedUtc > newest) newest = attendee.updatedUtc;
  }
  cursor = page.nextCursor;
} while (cursor);

await saveMark(newest);

var since = await LoadMarkAsync();         // null on the first run
var newest = since;
string? cursor = null;

do
{
    var query = $"events/b3ac0000-0000-4000-8000-000000000001/attendees?limit=500"
        + (since is null ? "" : $"&updatedSince={Uri.EscapeDataString(since)}")
        + (cursor is null ? "" : $"&cursor={cursor}");
    var page = await client.GetFromJsonAsync<JsonElement>(query);

    foreach (var attendee in page.GetProperty("data").EnumerateArray())
    {
        await UpsertAsync(attendee);       // by attendeeId
        var updated = attendee.GetProperty("updatedUtc").GetString()!;
        if (newest is null || string.CompareOrdinal(updated, newest) > 0) newest = updated;
    }

    cursor = page.GetProperty("nextCursor").GetString();
}
while (cursor is not null);

await SaveMarkAsync(newest);

base = "https://attendbeacon.com/api/v1/events/b3ac0000-0000-4000-8000-000000000001/attendees"
headers = {"Authorization": f"Bearer {os.environ['ATTENDBEACON_KEY']}"}

since = load_mark()                        # None on the first run
newest = since
cursor = None

while True:
    params = {"limit": 500}
    if since: params["updatedSince"] = since
    if cursor: params["cursor"] = cursor
    page = requests.get(base, params=params, headers=headers).json()

    for attendee in page["data"]:
        upsert(attendee)                   # by attendee["attendeeId"]
        if newest is None or attendee["updatedUtc"] > newest:
            newest = attendee["updatedUtc"]

    cursor = page["nextCursor"]
    if cursor is None:
        break

save_mark(newest)

$base = "https://attendbeacon.com/api/v1/events/b3ac0000-0000-4000-8000-000000000001/attendees"
$since = Get-Content mark.txt -ErrorAction SilentlyContinue   # nothing on the first run
$newest = $since
$cursor = $null

do {
    $query = "?limit=500"
    if ($since)  { $query += "&updatedSince=" + [uri]::EscapeDataString($since) }
    if ($cursor) { $query += "&cursor=$cursor" }
    $page = Invoke-RestMethod -Uri ($base + $query) -Headers $headers

    foreach ($attendee in $page.data) {
        Save-Attendee $attendee                                 # by attendeeId
        if (-not $newest -or $attendee.updatedUtc -gt $newest) { $newest = $attendee.updatedUtc }
    }
    $cursor = $page.nextCursor
} while ($cursor)

Set-Content mark.txt $newest