Incrementeel ophalen

curl -H "Authorization: Bearer apib_live_JOUW_SLEUTEL" \
  "https://app.apiboard.nl/api/v1/wefact/facturen?modified_since=2026-10-07T03%3A00%3A00.000000Z"

# Gepagineerd: herhaal met &cursor=<next_cursor> tot next_cursor null is.

import json
import os
import requests

TOKEN = "apib_live_JOUW_SLEUTEL"
URL = "https://app.apiboard.nl/api/v1/wefact/facturen"
STAAT_BESTAND = "wefact_facturen_staat.json"  # bewaart rijen + watermark tussen runs

staat = {"watermark": None, "rijen": {}}
if os.path.exists(STAAT_BESTAND):
    with open(STAAT_BESTAND) as f:
        staat = json.load(f)

params = {}
if staat["watermark"]:
    params["modified_since"] = staat["watermark"]  # eerste run: zonder, dus de hele tabel

while True:
    resp = requests.get(URL, params=params, headers={"Authorization": f"Bearer {TOKEN}"})
    resp.raise_for_status()
    body = resp.json()
    for rij in body["data"]:
        staat["rijen"][rij["id"]] = rij  # dedupliceren op id, laatste versie wint
    if body["next_cursor"] is None:
        staat["watermark"] = body["sync_watermark"]  # pas bewaren na de laatste pagina
        break
    params["cursor"] = body["next_cursor"]

# Rijen die bij de bron verwijderd zijn, uit de lokale set halen.
staat["rijen"] = {i: r for i, r in staat["rijen"].items() if not r.get("bron_verwijderd_op")}

with open(STAAT_BESTAND, "w") as f:
    json.dump(staat, f)

print(f"{len(staat['rijen'])} rijen.")

let
    Basis = "https://app.apiboard.nl",
    Pad = "/api/v1/wefact/facturen",
    Token = "apib_live_JOUW_SLEUTEL",
    Filters = [modified_since = "2026-10-07T03:00:00.000000Z"],

    HaalPaginaOp = (cursor as nullable text) =>
        Json.Document(Web.Contents(Basis, [
            RelativePath = Pad,
            Query = if cursor = null then Filters else Record.AddField(Filters, "cursor", cursor),
            Headers = [Authorization = "Bearer " & Token]
        ])),

    // Volg next_cursor tot die null is; de pagina met next_cursor = null telt ook mee.
    Paginas = List.Generate(
        () => HaalPaginaOp(null),
        each _ <> null,
        each if [next_cursor] = null then null else HaalPaginaOp([next_cursor]),
        each [data]
    ),

    AlleRijen = List.Combine(Paginas),
    Tabel = if List.IsEmpty(AlleRijen)
        then #table({"id", "synced_at"}, {})
        else Table.FromRecords(AlleRijen, null, MissingField.UseNull),
    // Dedupliceer op id: eerst de nieuwste versie bovenaan, dan houdt Distinct die.
    // Verwijder daarna rijen die bij de bron verwijderd zijn.
    NieuwsteEerst = Table.Buffer(Table.Sort(Tabel, {{"synced_at", Order.Descending}})),
    ZonderDubbel = Table.Distinct(NieuwsteEerst, {"id"}),
    ZonderVerwijderd = Table.SelectRows(ZonderDubbel, each Record.FieldOrDefault(_, "bron_verwijderd_op", null) = null)
in
    ZonderVerwijderd