Function redeemReferralCodeForInvoice

server/src/db/referral-codes-db.ts:302–341

(
  code: string,
  companyName: string,
  contactEmail: string
)

 * Tracks company name and contact email for later reconciliation.
 */
export async function redeemReferralCodeForInvoice(
  code: string,
  companyName: string,
  contactEmail: string
): Promise<Referral | null> {
  const referralCode = await getReferralCode(code);

  if (!referralCode || referralCode.status !== 'active') return null;
  if (referralCode.expires_at && referralCode.expires_at < new Date()) return null;
  if (referralCode.max_uses !== null && referralCode.used_count >= referralCode.max_uses) return null;

  const result = await query<Referral>(
    `WITH updated_code AS (
       UPDATE referral_codes
       SET used_count = used_count + 1, updated_at = NOW()
       WHERE id = $1
         AND status = 'active'
         AND (max_uses IS NULL OR used_count < max_uses)
       RETURNING id, referrer_org_id, referrer_user_id, target_company_name
     )
     INSERT INTO referrals
       (referral_code_id, referral_code, referrer_org_id, referrer_user_id,
        target_company_name, referred_company_name, referred_contact_email, status)
     SELECT
       uc.id, $2, uc.referrer_org_id, uc.referrer_user_id,
       uc.target_company_name, $3, $4, 'pending'
     FROM updated_code uc
     RETURNING *`,
    [referralCode.id, code.toUpperCase(), companyName, contactEmail]
  );

  const referral = result.rows[0] || null;
  if (referral) {
    logger.info(
      { referralId: referral.id, code, company: companyName },
      'Referral code redeemed for invoice'
    );
  }
  return referral;
}

/**
 * Mark an accepted referral as converted after successful payment.