Recipe: keep an external CRM in sync

async function* all(resource) {
  let offset = 0;
  while (true) {
    const res = await fetch(`https://api.outreign.io/rest-api/${resource}?limit=100&offset=${offset}`, {
      headers: { 'X-API-Key': process.env.OUTREIGN_API_KEY },
    });
    const page = await res.json();
    if (!res.ok || page.error) throw new Error(page.error);
    yield* page.data;
    offset += page.data.length;
    if (page.data.length === 0 || offset >= page.count) return;
  }
}

for await (const lead of all('leads')) await upsertIntoCrm(lead);
for await (const deal of all('deals')) await upsertDealIntoCrm(deal);

app.post('/outreign-webhook', express.raw({ type: 'application/json' }), async (req, res) => {
  // verifyOutReignWebhook is defined in "Security and retries"
  const ok = verifyOutReignWebhook(req.body, req.get('X-Webhook-Signature'), process.env.OUTREIGN_WEBHOOK_SECRET);
  if (!ok) return res.sendStatus(401);
  const event = JSON.parse(req.body);
  // Implement durable acceptance and duplicate protection in your receiver.
  // Return 2xx only after acceptance succeeds; otherwise let OutReign retry.
  await enqueueDurablyOnce(event, req.body);
  res.sendStatus(200);
});