Sync External Donations into Virtuous

async function runSubmitter(customerId) {
  const token = await loadCustomerApiToken(customerId);
  const pending = await db.virtuous_donation_queue.find({
    where: { customer_id: customerId, status: 'pending' },
    orderBy: 'created_at',
    limit: 100,
  });

  for (const donation of pending) {
    try {
      const response = await fetch(
        'https://api.virtuoussoftware.com/api/v2/Gift/Transaction',
        {
          method: 'POST',
          headers: {
            Authorization: `Bearer ${token}`,
            'Content-Type': 'application/json',
          },
          body: JSON.stringify(donation.payload),
        }
      );

      if (response.ok) {
        // Accepted into the holding state — still async, but no error.
        await db.virtuous_donation_queue.update(
          { platform_donation_id: donation.platform_donation_id },
          {
            status: 'submitted',
            submitted_at: new Date(),
            last_error: null,
          }
        );
      } else if (response.status === 429) {
        // Rate limited. Stop draining; the next run will retry.
        const retryAfter = parseInt(response.headers.get('Retry-After') || '60', 10);
        console.warn(`Rate limited for customer ${customerId}; pausing ${retryAfter}s`);
        return;
      } else if (response.status >= 500) {
        // Server error — leave as pending; retry on next run.
        const body = await response.text();
        await recordRetryableError(donation, response.status, body);
      } else {
        // 4xx error — request is malformed. Mark failed to require human review.
        const body = await response.text();
        await db.virtuous_donation_queue.update(
          { platform_donation_id: donation.platform_donation_id },
          {
            status: 'failed',
            last_error: `${response.status}: ${body}`,
          }
        );
      }
    } catch (err) {
      await recordRetryableError(donation, 0, err.message);
    }
  }
}

async function recordRetryableError(donation, status, message) {
  await db.virtuous_donation_queue.update(
    { platform_donation_id: donation.platform_donation_id },
    {
      retry_count: donation.retry_count + 1,
      last_error: `${status}: ${message}`,
      // Leave status as 'pending' so the next run picks it up
    }
  );
}

async function handleGiftCreated(event) {
  const gift = event.data;

  // Only act on gifts that came from our integration
  if (gift.transactionSource !== 'YourPlatform') {
    return;
  }

  const donation = await db.virtuous_donation_queue.findOne({
    platform_donation_id: gift.transactionId,
  });

  if (!donation) {
    // Webhook for a donation we don't have a record of.
    // Log for investigation but don't fail — could be a legitimate orphan.
    console.warn('giftCreate event for unknown donation', {
      transactionId: gift.transactionId,
      virtuousGiftId: gift.id,
    });
    return;
  }

  if (donation.status === 'confirmed') {
    // Duplicate webhook delivery — already processed.
    return;
  }

  await db.virtuous_donation_queue.update(
    { platform_donation_id: donation.platform_donation_id },
    {
      status: 'confirmed',
      confirmed_at: new Date(),
      virtuous_gift_id: gift.id,
    }
  );
}

async function runReconciliation(customerId) {
  const token = await loadCustomerApiToken(customerId);

  // Find submitted-but-not-confirmed donations older than a reasonable window
  const stale = await db.virtuous_donation_queue.find({
    where: {
      customer_id: customerId,
      status: 'submitted',
      submitted_at: { lt: '24 hours ago' },
    },
    limit: 100,
  });

  for (const donation of stale) {
    const response = await fetch(
      `https://api.virtuoussoftware.com/api/Gift/YourPlatform/${donation.platform_donation_id}`,
      { headers: { Authorization: `Bearer ${token}` } }
    );

    if (response.ok) {
      // Gift exists — webhook was lost but the Transaction succeeded.
      const gift = await response.json();
      await db.virtuous_donation_queue.update(
        { platform_donation_id: donation.platform_donation_id },
        {
          status: 'confirmed',
          confirmed_at: new Date(),
          virtuous_gift_id: gift.id,
        }
      );
    } else if (response.status === 404) {
      // Transaction was accepted but never produced a real Gift.
      // Likely landed in needs-update for manual resolution.
      await db.virtuous_donation_queue.update(
        { platform_donation_id: donation.platform_donation_id },
        {
          status: 'needs_review',
          last_error: 'Transaction never resolved — likely in needs-update bucket',
        }
      );
    }
  }
}