Replay and reconcile events

const API = "https://app.sajn.se/api/v1";
const OVERLAP_MS = 5 * 60 * 1000;

// Returns the new watermark. Store it and pass it as `since` on the next run.
async function reconcile(since, handleEvent) {
  const startedAt = new Date();
  const createdAfter = new Date(since.getTime() - OVERLAP_MS).toISOString();
  let cursor = null;

  do {
    const params = new URLSearchParams({ createdAfter, limit: "100" });
    if (cursor) params.set("cursor", cursor);

    const response = await fetch(`${API}/events?${params}`, {
      headers: {
        Authorization: `Bearer ${process.env.SAJN_API_KEY}`,
        "Sajn-Version": "2026-10",
      },
    });
    if (!response.ok) throw new Error(`sajn returned ${response.status}`);

    const page = await response.json();
    for (const event of page.data) {
      // The same handler as your webhook endpoint. It skips IDs it has seen.
      await handleEvent(event);
    }
    cursor = page.nextCursor;
  } while (cursor);

  return startedAt;
}

import os
from datetime import datetime, timedelta, timezone

import requests

API = "https://app.sajn.se/api/v1"
OVERLAP = timedelta(minutes=5)


def reconcile(since: datetime, handle_event) -> datetime:
    """Returns the new watermark. Store it and pass it as `since` next time."""
    started_at = datetime.now(timezone.utc)
    created_after = (since - OVERLAP).astimezone(timezone.utc)
    params = {
        "createdAfter": created_after.strftime("%Y-%m-%dT%H:%M:%SZ"),
        "limit": 100,
    }
    headers = {
        "Authorization": f"Bearer {os.environ['SAJN_API_KEY']}",
        "Sajn-Version": "2026-10",
    }

    while True:
        response = requests.get(f"{API}/events", params=params, headers=headers)
        response.raise_for_status()
        page = response.json()
        for event in page["data"]:
            # The same handler as your webhook endpoint. It skips IDs it has seen.
            handle_event(event)
        if not page["nextCursor"]:
            return started_at
        params["cursor"] = page["nextCursor"]