Sync Recurring Donor Updates

// Sequence:
// 1. Find or create the Contact
let contactId = await findContactByReference(commitment.donor.platformId, token);
if (!contactId) {
  // Submit a Contact Transaction first, wait for it to resolve, then proceed
  await submitContactTransaction(commitment.donor, token);
  contactId = await waitForContactResolution(commitment.donor.platformId, token);
}

// 2. Then create the RecurringGift
await createRecurringGift(commitment, contactId, token);

async function recordRecurringPayment(payment, token) {
  await fetch(
    'https://api.virtuoussoftware.com/api/v2/Gift/Transaction',
    {
      method: 'POST',
      headers: { Authorization: `Bearer ${token}`, 'Content-Type': 'application/json' },
      body: JSON.stringify({
        transactionSource: 'YourPlatform',
        transactionId: payment.paymentId,                  // The specific payment, not the schedule
        recurringGiftTransactionId: payment.scheduleId,    // The schedule's transactionId
        contact: { referenceId: payment.donor.platformId },
        giftDate: payment.date,
        giftType: 'Cash',
        amount: payment.amount.toFixed(2),
        currencyCode: 'USD',
        batch: 'Recurring',
        giftDesignations: [
          {
            projectCode: payment.projectCode,
            amountDesignated: payment.amount.toFixed(2),
          },
        ],
      }),
    }
  );
}

async function updateRecurringAmount(recurringGiftId, newAmount, token) {
  // 1. Read the current schedule
  const current = await fetch(
    `https://api.virtuoussoftware.com/api/RecurringGift/${recurringGiftId}`,
    { headers: { Authorization: `Bearer ${token}` } }
  ).then((r) => r.json());

  // 2. Modify
  const updated = {
    ...current,
    amount: newAmount,
    designations: current.designations.map((d) => ({
      ...d,
      // Distribute the new amount proportionally across existing designations
      amountDesignated: (d.amountDesignated / current.amount) * newAmount,
    })),
  };

  // 3. Write
  await fetch(
    `https://api.virtuoussoftware.com/api/RecurringGift/${recurringGiftId}`,
    {
      method: 'PUT',
      headers: { Authorization: `Bearer ${token}`, 'Content-Type': 'application/json' },
      body: JSON.stringify(updated),
    }
  );
}

curl -X PUT https://api.virtuoussoftware.com/api/RecurringGift/Cancel/12345 \
  -H "Authorization: Bearer YOUR_API_TOKEN"

async function cancelRecurringGift(recurringGiftId, token) {
  await fetch(
    `https://api.virtuoussoftware.com/api/RecurringGift/Cancel/${recurringGiftId}`,
    {
      method: 'PUT',
      headers: { Authorization: `Bearer ${token}` },
    }
  );
}

async function reconcileRecurringSchedules(customerId, token) {
  // 1. Pull all RecurringGifts from Virtuous that came from your platform
  const virtuousSchedules = await queryAllPages({
    groups: [
      // Filter by transactionSource if available; otherwise filter client-side
    ],
    sortBy: 'id',
  }, '/api/RecurringGift/Query', token);

  const fromOurPlatform = virtuousSchedules.filter(
    (s) => s.transactionSource === 'YourPlatform'
  );

  // 2. Pull all active recurring schedules from your platform
  const platformSchedules = await db.recurring_schedules.find({
    customer_id: customerId,
    status: 'active',
  });

  // 3. Cross-match by transactionId and report discrepancies
  for (const platformSchedule of platformSchedules) {
    const virtuousMatch = fromOurPlatform.find(
      (v) => v.transactionId === platformSchedule.id
    );

    if (!virtuousMatch) {
      console.warn(`Platform schedule ${platformSchedule.id} missing from Virtuous`);
    } else if (Math.abs(virtuousMatch.amount - platformSchedule.amount) > 0.01) {
      console.warn(
        `Amount mismatch on schedule ${platformSchedule.id}: ` +
        `platform $${platformSchedule.amount}, Virtuous $${virtuousMatch.amount}`
      );
    }
  }
}