Task sync

curl -X PATCH https://api.quiva.ai/workspaces/task/OPS-7 \
  -H "Authorization: Bearer $TOKEN" \
  -H "If-Match: 4" \
  -H "Content-Type: application/json" \
  -d '{"status": "in_progress"}'

curl -X PUT "https://api.quiva.ai/workspaces/space/OPS/tasks/external/ticket-9041" \
  -H "Authorization: Bearer $TOKEN" \
  -H "Content-Type: application/json" \
  -d '{
    "title": "Printer on floor 2 is jammed",
    "status": "todo",
    "priority": "high"
  }'

curl "https://api.quiva.ai/workspaces/space/OPS/tasks?sort_by=activity_at&sort_order=desc&limit=50" \
  -H "Authorization: Bearer $TOKEN"

curl "https://api.quiva.ai/workspaces/space/OPS/changes?cursor=1842&limit=100" \
  -H "Authorization: Bearer $TOKEN"

{
  "events": [
    {
      "event_id": "A1B2C3-1843",
      "event_type": "task-status-changed",
      "occurred_at": "2026-10-06T09:15:00Z",
      "space_id": "OPS",
      "origin": { "kind": "user", "id": "u_82f1" },
      "task": { "id": "OPS-7", "version": 4, "external_id": "ticket-9041", "status": "done" },
      "changed_fields": ["status"],
      "status_from": "in_progress"
    }
  ],
  "next_cursor": "1843",
  "has_more": false,
  "retention_days": 30
}

const BASE = "https://api.quiva.ai";
const ME = process.env.QUIVA_CLIENT_ID;

async function api(path, init = {}) {
  const res = await fetch(BASE + path, {
    ...init,
    headers: {
      Authorization: `Bearer ${await getToken()}`, // see Task sync authentication
      "Content-Type": "application/json",
      ...init.headers,
    },
  });
  if (res.status === 401) throw new Error("re-mint the token once and retry");
  return res;
}

// Quiva to your system
async function pull(space, cursor) {
  for (;;) {
    const res = await api(`/workspaces/space/${space}/changes?limit=200` + (cursor ? `&cursor=${cursor}` : ""));
    if (res.status === 410) {
      const gone = await res.json();
      await fullResync(space);   // events in the gap are lost: list the Space
      cursor = gone.next_cursor;
      continue;
    }
    const page = await res.json();
    for (const ev of page.events) {
      if (ev.origin?.kind === "integration" && ev.origin.id === ME) continue; // our own write
      await applyToMySystem(ev); // apply only if ev.task.version is newer than what you hold
    }
    cursor = page.next_cursor;
    saveCursor(space, cursor);
    if (!page.has_more) return cursor;
  }
}

// Your system to Quiva
async function push(space, item) {
  const id = encodeURIComponent(item.id);
  const res = await api(`/workspaces/space/${space}/tasks/external/${id}`, {
    method: "PUT",
    headers: item.quivaVersion ? { "If-Match": String(item.quivaVersion) } : {},
    body: JSON.stringify({ title: item.title, status: item.statusId }),
  });
  if (res.status === 409) {
    const body = await res.json();
    if (body.code === "version_conflict") return resolve(item, body.task);
    if (body.code === "external_id_pending") return retryLater(item);
  }
  if (res.status === 410) return markDeletedInMySystem(item); // deleted in Quiva: never recreated
  return res.json(); // keep task.version for the next If-Match
}