Integration sync

1
async function ensurePivotalCustomer(crm: CrmRecord, store: Store): Promise<string> {
2
  const known = await store.get(crm.id);
3
  if (known) return known;
4
5
  const res = await fetch("https://my.pivotal.app/api/v1/customers", {
6
    method: "POST",
7
    headers: {
8
      Authorization: `Bearer ${process.env.PIVOTAL_API_KEY}`,
9
      "Content-Type": "application/json",
10
      "Idempotency-Key": `crm-sync-${crm.id}`,
11
    },
12
    body: JSON.stringify({
13
      name: crm.name,
14
      slug: slugify(crm.name),
15
      domain: crm.domain,
16
      hubspot_company_id: crm.id,
17
      status: "onboarding",
18
    }),
19
  });
20
  const body = await res.json();
21
  if (!res.ok && body.error?.code !== "slug_taken") {
22
    throw new Error(`Pivotal POST failed: ${body.error?.code}`);
23
  }
24
  await store.set(crm.id, body.id);
25
  return body.id;
26
}

1
const res = await fetch(
2
  "https://my.pivotal.app/api/v1/customers?limit=100",
3
  { headers: { Authorization: `Bearer ${process.env.PIVOTAL_API_KEY}` } },
4
);
5
const page = await res.json();
6
const byHubspotId = new Map(page.data.map((c: any) => [c.hubspot_company_id, c.id]));

1
async function syncOne(crm: CrmRecord, pivotalId: string) {
2
  const res = await fetch(`https://my.pivotal.app/api/v1/customers/${pivotalId}`, {
3
    method: "PATCH",
4
    headers: {
5
      Authorization: `Bearer ${process.env.PIVOTAL_API_KEY}`,
6
      "Content-Type": "application/json",
7
    },
8
    body: JSON.stringify({
9
      name: crm.name,
10
      domain: crm.domain,
11
      status: mapStatus(crm.lifecycle_stage),
12
    }),
13
  });
14
  if (!res.ok) {
15
    const body = await res.json();
16
    console.error(`Sync failed for ${crm.id}:`, body.error);
17
  }
18
}

1
const lastRun = (await store.get("last_run")) ?? "2026-01-01T00:00:00Z";
2
const updated = await crm.companies.search({
3
  filter: `updated_at >= ${lastRun}`,
4
  sort: "updated_at",
5
  limit: 200,
6
});
7
8
let maxUpdated = lastRun;
9
for (const record of updated) {
10
  await syncOne(record, await ensurePivotalCustomer(record, store));
11
  if (record.updated_at > maxUpdated) maxUpdated = record.updated_at;
12
}
13
await store.set("last_run", maxUpdated);

1
import pLimit from "p-limit";
2
const limit = pLimit(4); // 4 in-flight requests
3
await Promise.all(records.map((r) => limit(() => syncOne(r, idMap.get(r.id)!))));

1
const since = (await store.get("pivotal_cursor")) ?? new Date().toISOString();
2
let cursor: string | undefined;
3
const updates: any[] = [];
4
5
do {
6
  const url = new URL("https://my.pivotal.app/api/v1/customers");
7
  url.searchParams.set("limit", "100");
8
  if (cursor) url.searchParams.set("cursor", cursor);
9
10
  const res = await fetch(url, { headers: { Authorization: `Bearer ${process.env.PIVOTAL_API_KEY}` } });
11
  const page = await res.json();
12
13
  for (const c of page.data) {
14
    if (c.updated_at <= since) { cursor = undefined; break; } // walked far enough
15
    updates.push(c);
16
  }
17
  cursor = page.has_more ? page.next_cursor : undefined;
18
} while (cursor);
19
20
// Apply `updates` to your CRM in updated-at order
21
updates.sort((a, b) => a.updated_at.localeCompare(b.updated_at));
22
for (const u of updates) await pushToCrm(u);
23
24
await store.set("pivotal_cursor", updates.at(-1)?.updated_at ?? since);