How Raise Data Flows to CRM+

function buildCrmLink(donor) {
  // crmKeyUrls is keyed by integration type string
  const entries = Object.values(donor.crmKeyUrls || {});
  if (entries.length === 0) return null;
  return entries[0].url;
}

curl -X PUT https://prod-api.raisedonors.com/api/Campaign/5678/toggle-sync \
  -H "Authorization: Bearer YOUR_API_TOKEN"

async function findCrmContactForRaiseDonor(raiseDonorId) {
  // 1. Read the Raise Donor
  const raiseDonor = await fetch(
    `https://prod-api.raisedonors.com/api/Donor/${raiseDonorId}`,
    { headers: { Authorization: `Bearer ${process.env.RAISE_API_TOKEN}` } }
  ).then((r) => r.json());

  if (!raiseDonor.crmKey) {
    // Not synced yet
    return null;
  }

  // 2. Use the crmKey to fetch the CRM+ Contact
  const crmContact = await fetch(
    `https://api.virtuoussoftware.com/api/Contact/${raiseDonor.crmKey}`,
    { headers: { Authorization: `Bearer ${process.env.CRM_API_TOKEN}` } }
  ).then((r) => r.json());

  return crmContact;
}

// Two webhook handlers — one per product
async function handleRaiseGiftCreate(payload) {
  await ingestGift({
    source: 'raise',
    raiseGiftId: payload.giftId,
    crmKey: payload.crmKey,
  });
}

async function handleCrmGiftCreate(payload) {
  await ingestGift({
    source: 'crm',
    crmGiftId: payload.giftId,
    raiseGiftId: payload.sourceRaiseGiftId, // if exposed by the CRM+ payload
  });
}

async function ingestGift({ source, raiseGiftId, crmGiftId, crmKey }) {
  // Deduplicate by raiseGiftId — the Raise event arrives first
  const existing = await db.findByRaiseGiftId(raiseGiftId);
  if (existing) {
    await db.update(existing.id, { crmGiftId, lastSeenSource: source });
    return;
  }
  await db.create({ raiseGiftId, crmGiftId, crmKey, source });
}

async function reconcileGiftsForDay(date) {
  // 1. Pull all Raise gifts for the day
  const raiseGifts = await queryRaiseGifts({ dateAfter: date.startOfDay() });

  // 2. Pull all CRM+ gifts that originated from Raise for the day
  const crmGifts = await queryCrmGifts({
    dateAfter: date.startOfDay(),
    transactionSource: 'raise',
  });

  // 3. Build a map by crmKey (which Raise has) ↔ source ID (which CRM+ has)
  const raiseByKey = new Map(raiseGifts.filter((g) => g.crmKey).map((g) => [g.crmKey, g]));
  const crmByKey = new Map(crmGifts.map((g) => [g.sourceRaiseGiftId, g]));

  // 4. Identify the discrepancies
  const inRaiseNotCrm = raiseGifts.filter((g) => !crmByKey.has(g.id));
  const inCrmNotRaise = crmGifts.filter((g) => !raiseByKey.has(g.sourceRaiseGiftId));

  // 5. Alert on persistent discrepancies (after allowing for sync lag)
  return { inRaiseNotCrm, inCrmNotRaise };
}