Stripe Affiliate Tracking: Complete Integration Guide | AffiliateBase

// Example: Next.js API route for Stripe webhooks
import { headers } from 'next/headers';
import Stripe from 'stripe';
import { AffiliateBase } from '@affiliatebase/sdk';

const stripe = new Stripe(process.env.STRIPE_SECRET_KEY!);
const affiliateBase = new AffiliateBase({
  apiKey: process.env.AFFILIATEBASE_API_KEY!,
});

export async function POST(request: Request) {
  const body = await request.text();
  const signature = headers().get('stripe-signature')!;
  
  let event: Stripe.Event;
  
  try {
    event = stripe.webhooks.constructEvent(
      body,
      signature,
      process.env.STRIPE_WEBHOOK_SECRET!
    );
  } catch (err) {
    return new Response(`Webhook Error: ${err.message}`, { status: 400 });
  }
  
  // Handle different event types
  switch (event.type) {
    case 'checkout.session.completed':
      const session = event.data.object as Stripe.Checkout.Session;
      await affiliateBase.trackConversion({
        affiliateId: session.metadata?.affiliateId,
        type: 'subscription',
        amount: session.amount_total! / 100,
        currency: session.currency!,
        customerId: session.customer as string,
        subscriptionId: session.subscription as string,
      });
      break;
      
    case 'customer.subscription.created':
    case 'invoice.payment_succeeded':
      const subscription = event.data.object as Stripe.Subscription;
      await affiliateBase.trackConversion({
        affiliateId: subscription.metadata?.affiliateId,
        type: 'subscription_renewal',
        amount: subscription.items.data[0].price.unit_amount! / 100,
        currency: subscription.currency,
        customerId: subscription.customer as string,
        subscriptionId: subscription.id,
      });
      break;
      
    case 'payment_intent.succeeded':
      const paymentIntent = event.data.object as Stripe.PaymentIntent;
      await affiliateBase.trackConversion({
        affiliateId: paymentIntent.metadata?.affiliateId,
        type: 'one_time_payment',
        amount: paymentIntent.amount / 100,
        currency: paymentIntent.currency,
        customerId: paymentIntent.customer as string,
      });
      break;
  }
  
  return new Response(JSON.stringify({ received: true }), { status: 200 });
}