GET /v1/changes: seit einem Zeitpunkt geänderte Tabellen

import os

import requests

BASE_URL = "https://api.trassets.ai"
HEADERS = {"X-API-Key": os.environ["TRASSETS_API_KEY"]}


def fetch_table(endpoint_url: str) -> list[dict]:
    """Fetch every row of one table from its endpoint_url."""
    rows: list[dict] = []
    params: dict = {"limit": 1000}
    while True:
        resp = requests.get(f"{BASE_URL}{endpoint_url}", headers=HEADERS, params=params, timeout=60)
        resp.raise_for_status()
        body = resp.json()
        rows.extend(body["data"])
        if body["next_cursor"] is None:
            return rows
        params["cursor"] = body["next_cursor"]


def sync(since: str, etag: str | None = None):
    """Return (tables, next_since, next_etag)."""
    headers = dict(HEADERS)
    if etag:
        headers["If-None-Match"] = etag
    resp = requests.get(f"{BASE_URL}/v1/changes", headers=headers, params={"since": since}, timeout=30)
    if resp.status_code == 304:
        return {}, since, etag
    resp.raise_for_status()
    changed = resp.json()

    tables = {t["table_name"]: fetch_table(t["endpoint_url"]) for t in changed}
    # last_sync_at is UTC without a suffix; the API expects it with "Z"
    next_since = max(t["last_sync_at"] for t in changed) + "Z" if changed else since
    return tables, next_since, resp.headers.get("ETag")


if __name__ == "__main__":
    tables, next_since, next_etag = sync("2026-07-01T00:00:00Z")
    for name, rows in tables.items():
        print(f"{name}: {len(rows)} rows")
    # Replace the local tables, then persist next_since and next_etag for the next run.