Razorpay

RAZORPAY_KEY_ID=rzp_live_xxxxxxxxxxxxxxxxxxxx
RAZORPAY_KEY_SECRET=xxxxxxxxxxxxxxxxxxxxxxxx
RAZORPAY_WEBHOOK_SECRET=xxxxxxxxxxxxxxxxxxxxxxxx   # For webhook signature verification

RAZORPAY_KEY_ID=rzp_test_xxxxxxxxxxxxxxxxxxxx
RAZORPAY_KEY_SECRET=xxxxxxxxxxxxxxxxxxxxxxxx

import Razorpay from 'razorpay';
 
const razorpay = new Razorpay({
  key_id:     config.RAZORPAY_KEY_ID,
  key_secret: config.RAZORPAY_KEY_SECRET,
});
 
// Create a plan (one-time setup — plans don't change often)
async function createPlan(options: {
  name:       string;   // e.g. "Leadmetrics Pro Monthly"
  amount:     number;   // In paise (INR × 100): 4999 rupees = 499900 paise
  currency:   string;   // 'INR'
  interval:   number;   // 1
  period:     string;   // 'monthly' | 'yearly'
}): Promise<string> {
  const plan = await razorpay.plans.create({
    period:   options.period,
    interval: options.interval,
    item: {
      name:     options.name,
      amount:   options.amount,
      currency: options.currency,
    },
  });
  return plan.id;
}
 
// Subscribe a tenant to a plan
async function createSubscription(
  planId:     string,
  totalCount: number,   // Number of billing cycles (e.g. 12 for annual)
): Promise<{ subscriptionId: string; shortUrl: string }> {
  const subscription = await razorpay.subscriptions.create({
    plan_id:     planId,
    total_count: totalCount,
    quantity:    1,
    notify_info: {
      notify_phone: tenantPhone,
      notify_email: tenantEmail,
    },
  });
  return {
    subscriptionId: subscription.id,
    shortUrl:       subscription.short_url,  // Payment page URL
  };
}

async function createTopupOrder(options: {
  credits: number;   // Number of credits being purchased
  amount:  number;   // Amount in paise
  tenantId: string;
}): Promise<{ orderId: string; amount: number; currency: string }> {
  const order = await razorpay.orders.create({
    amount:   options.amount,
    currency: 'INR',
    receipt:  `topup-${options.tenantId}-${Date.now()}`,
    notes: {
      tenantId: options.tenantId,
      credits:  String(options.credits),
      type:     'credit_topup',
    },
  });
 
  // Also insert a pending row in credit_topup_orders
  await db.insert(creditTopupOrders).values({
    tenantId:         options.tenantId,
    orderId:          order.id,
    credits:          options.credits,
    amountPaise:      options.amount,
    status:           'pending',
  });
 
  return {
    orderId:  order.id,
    amount:   order.amount,
    currency: order.currency,
  };
}

// POST /api/webhooks/razorpay
async function handleRazorpayWebhook(req: Request): Promise<void> {
  const signature = req.headers['x-razorpay-signature'] as string;
  const isValid   = Razorpay.validateWebhookSignature(
    JSON.stringify(req.body),
    signature,
    config.RAZORPAY_WEBHOOK_SECRET,
  );
  if (!isValid) throw new UnauthorizedError('Invalid webhook signature');
 
  const event = req.body as RazorpayWebhookEvent;
 
  switch (event.event) {
    case 'payment.captured':
      await handlePaymentCaptured(event.payload.payment.entity);
      break;
    case 'subscription.charged':
      await handleSubscriptionCharged(event.payload.subscription.entity);
      break;
    case 'subscription.cancelled':
      await handleSubscriptionCancelled(event.payload.subscription.entity);
      break;
    case 'payment.failed':
      await handlePaymentFailed(event.payload.payment.entity);
      break;
  }
}

async function handlePaymentCaptured(payment: RazorpayPayment): Promise<void> {
  const { tenantId, credits } = payment.notes;
 
  // Update order status
  await db.update(creditTopupOrders)
    .set({ status: 'paid', razorpayPaymentId: payment.id, paidAt: new Date() })
    .where(eq(creditTopupOrders.orderId, payment.order_id));
 
  // Add credits to balance
  await topupCredits(tenantId, Number(credits), payment.id);
 
  // Generate invoice via Billing Agent
  await billingQueue.add('generate-invoice', { tenantId, paymentId: payment.id });
 
  // Notify tenant
  await notifyTenant(tenantId, 'credit_topup_confirmed', { credits });
}