Stripe

import Stripe from 'stripe';
import {Biqli} from '@biqli/sdk';

const stripe = new Stripe(process.env.STRIPE_SECRET_KEY!);
const biqli = new Biqli({apiKey: process.env.BIQLI_API_KEY!});

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

  if (event.type !== 'checkout.session.completed') return;

  const session = event.data.object;

  await biqli.track.sale({
    clickId: session.metadata?.biqli_click_id,
    customerExternalId: session.metadata?.customer_external_id
      ?? String(session.customer),
    amount: session.amount_total ?? 0,
    currency: session.currency ?? 'usd',
    paymentProcessor: 'stripe',
    invoiceId: String(session.invoice ?? session.id),
  });
}