import { NextResponse } from "next/server";
import Stripe from "stripe";

const stripe = new Stripe(process.env.STRIPE_SECRET_KEY!);
const PING_URL = "https://api.stackster.app/p/YOUR_CHECK_UUID";

export async function POST(req: Request) {
  const body = await req.text();
  const sig = req.headers.get("stripe-signature")!;

  try {
    const event = stripe.webhooks.constructEvent(
      body,
      sig,
      process.env.STRIPE_WEBHOOK_SECRET!
    );

    // 1. Process payment / subscription logic here
    await handleStripeEvent(event);

    // 2. Success: Ping STACKSTER to reset dead-man's timer
    fetch(PING_URL, { method: "POST", body: JSON.stringify({ run_id: event.id }) });

    return NextResponse.json({ received: true });
  } catch (err: any) {
    // 3. Immediate Alert: Signal failure node directly to STACKSTER
    fetch(`${PING_URL}/fail`, {
      method: "POST",
      headers: { "Content-Type": "application/json" },
      body: JSON.stringify({ error: err.message, stack: err.stack }),
    });

    return NextResponse.json({ error: err.message }, { status: 400 });
  }
}