Payment Failed Recovery

// app/api/webhooks/stripe/route.ts
import Stripe from 'stripe';
import { retake } from '@/lib/retake';

const stripe = new Stripe(process.env.STRIPE_SECRET_KEY!);

export async function POST(req: Request) {
  const body = await req.text();
  const sig = req.headers.get('stripe-signature')!;
  
  const event = stripe.webhooks.constructEvent(
    body,
    sig,
    process.env.STRIPE_WEBHOOK_SECRET!
  );

  switch (event.type) {
    case 'invoice.payment_failed':
      const invoice = event.data.object;
      const user = await getUserByStripeId(invoice.customer as string);
      
      if (user) {
        await retake.track({
          event: "INTENT",
          type: "payment_failed",
          userId: user.id,
          email: user.email,
          value: invoice.amount_due / 100,
          metadata: {
            attemptCount: invoice.attempt_count,
            nextAttempt: invoice.next_payment_attempt
          }
        });
      }
      break;

    case 'invoice.payment_succeeded':
      // Payment succeeded after retry - cancel recovery
      const paidInvoice = event.data.object;
      const paidUser = await getUserByStripeId(paidInvoice.customer as string);
      
      if (paidUser) {
        await retake.track({
          event: "CONVERSION",
          userId: paidUser.id,
          value: paidInvoice.amount_paid / 100,
          transactionId: paidInvoice.id
        });
      }
      break;
  }

  return Response.json({ received: true });
}

// Paddle webhook handler
async function handlePaddleWebhook(event: PaddleEvent) {
  switch (event.event_type) {
    case 'transaction.payment_failed':
      const user = await getUserByPaddleId(event.data.customer_id);
      
      await retake.track({
        event: "INTENT",
        type: "payment_failed",
        userId: user.id,
        email: user.email,
        value: parseFloat(event.data.details.totals.total),
        metadata: {
          errorCode: event.data.payments[0]?.error_code,
          subscriptionId: event.data.subscription_id
        }
      });
      break;
      
    case 'transaction.completed':
      // Recovery successful
      await retake.track({
        event: "CONVERSION",
        userId: user.id,
        value: parseFloat(event.data.details.totals.total)
      });
      break;
  }
}