// Stripe webhook endpoint (Next.js API route example)
import { NextRequest, NextResponse } from 'next/server';
import Stripe from 'stripe';

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

export async function POST(request: NextRequest) {
  const body = await request.text();
  const signature = request.headers.get('stripe-signature')!;

  let event: Stripe.Event;

  try {
    event = stripe.webhooks.constructEvent(body, signature, webhookSecret);
  } catch (err) {
    console.error('Webhook signature verification failed:', err);
    return NextResponse.json({ error: 'Webhook error' }, { status: 400 });
  }

  // Handle successful payment
  if (event.type === 'checkout.session.completed') {
    const session = event.data.object as Stripe.Checkout.Session;
    
    // Send revenue data to theBizness.ai
    await fetch('https://thebizness.ai/api/revenue', {
      method: 'POST',
      headers: {
        'Content-Type': 'application/json',
        'Authorization': `Bearer ${process.env.THEBIZNESS_API_KEY}`
      },
      body: JSON.stringify({
        website_id: process.env.THEBIZNESS_WEBSITE_ID,
        customer_id: session.customer,
        session_id: session.id,
        amount: session.amount_total, // in cents
        currency: session.currency,
        timestamp: new Date().toISOString(),
        metadata: session.metadata
      })
    });
  }

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