Guide: syncing with other software

import { stryk } from './stryk.js';

// Initial load: walk every page, then remember the newest updatedAt you saw.
export async function fullLoad(resource, upsert) {
  let cursor = null;
  let highWaterMark = null;
  do {
    const params = new URLSearchParams({ limit: '200', ...(cursor ? { cursor } : {}) });
    const { data: page } = await stryk(`/${resource}?${params}`);
    for (const item of page.data) {
      await upsert(item);
      if (!highWaterMark || item.updatedAt > highWaterMark) highWaterMark = item.updatedAt;
    }
    cursor = page.hasMore ? page.nextCursor : null;
  } while (cursor);
  return highWaterMark; // store it per resource, e.g. in your database
}

from stryk import stryk


def full_load(resource, upsert):
    cursor, high_water_mark = None, None
    while True:
        params = {"limit": 200, **({"cursor": cursor} if cursor else {})}
        page, _ = stryk(f"/{resource}", params=params)
        for item in page["data"]:
            upsert(item)
            if high_water_mark is None or item["updatedAt"] > high_water_mark:
                high_water_mark = item["updatedAt"]
        if not page["hasMore"]:
            return high_water_mark
        cursor = page["nextCursor"]

// Delta run: updated_since is inclusive (>=). Items at the mark arrive again, that is intended.
export async function syncChanges(resource, store) {
  const since = await store.highWaterMark(resource);
  let cursor = null;
  let newest = since;
  do {
    const params = new URLSearchParams({ limit: '200', updated_since: since, ...(cursor ? { cursor } : {}) });
    const { data: page } = await stryk(`/${resource}?${params}`);
    for (const item of page.data) {
      const known = await store.get(resource, item.id);
      // Deduplicate by id + updatedAt; never overwrite newer local data with an older copy.
      if (!known || item.updatedAt > known.updatedAt) await store.put(resource, item);
      if (item.updatedAt > newest) newest = item.updatedAt;
    }
    cursor = page.hasMore ? page.nextCursor : null;
  } while (cursor);
  await store.setHighWaterMark(resource, newest);
}

def sync_changes(resource, store):
    since = store.high_water_mark(resource)
    cursor, newest = None, since
    while True:
        params = {"limit": 200, "updated_since": since, **({"cursor": cursor} if cursor else {})}
        page, _ = stryk(f"/{resource}", params=params)
        for item in page["data"]:
            known = store.get(resource, item["id"])
            if known is None or item["updatedAt"] > known["updatedAt"]:
                store.put(resource, item)
            newest = max(newest, item["updatedAt"])
        if not page["hasMore"]:
            break
        cursor = page["nextCursor"]
    store.set_high_water_mark(resource, newest)

GET /api/partner/v1/guests/5e4d3c2b-1a09-4f8e-9d7c-6b5a4f3e2d1c
→ 200 OK
  ETag: "7e5d3c1b"
  { "id": "5e4d3c2b-…", "phone": "+43 660 1234567", "version": "7e5d3c1b", … }

PATCH /api/partner/v1/guests/5e4d3c2b-1a09-4f8e-9d7c-6b5a4f3e2d1c
If-Match: "7e5d3c1b"
{ "phone": "+43 660 7654321" }
→ 200 OK      ETag: "9f8e7d6c"
→ 412 precondition_failed   (changed in STRYK meanwhile: read again)
→ 428 precondition_required (If-Match missing)

// Optimistic concurrency: read, change, write with If-Match.
export async function updateGuestPhone(guestId, phone) {
  for (let attempt = 1; attempt <= 3; attempt += 1) {
    const { data: guest, etag } = await stryk(`/guests/${guestId}`);
    try {
      const { data: updated } = await stryk(`/guests/${guestId}`, {
        method: 'PATCH',
        headers: { 'If-Match': etag },
        body: { phone },
      });
      return updated;
    } catch (error) {
      // 412: someone changed the guest in STRYK since your read. Read again and re-apply.
      if (error.code !== 'precondition_failed') throw error;
    }
  }
  throw new Error('Guest keeps changing; resolve manually.');
}

def update_guest_phone(guest_id, phone):
    for _ in range(3):
        guest, headers = stryk(f"/guests/{guest_id}")
        try:
            updated, _ = stryk(f"/guests/{guest_id}", method="PATCH",
                               headers={"If-Match": headers["ETag"]}, json={"phone": phone})
            return updated
        except StrykError as error:
            if error.code != "precondition_failed":
                raise  # 412 means: read again and re-apply
    raise RuntimeError("Guest keeps changing; resolve manually.")