import db from "@/db/db";
import { NextRequest, NextResponse } from "next/server";
import Stripe from "stripe";
import { Resend } from "resend";
import PurchaseReceiptEmail from "@/lib/emails/PurchaseReceipt";
import { WebhookProduct } from "@/types";

console.log("Hello, world!");

const stripe = new Stripe(process.env.STRIPE_SECRET_KEY as string);
const resend = new Resend(process.env.RESEND_API_KEY as string);

export type ExtendedWebhookProduct = WebhookProduct & {
  quantity: number;
};

export async function POST(request: NextRequest) {
  console.log("Received stripe webhook");
  let event;
  try {
    event = stripe.webhooks.constructEvent(
      await request.text(),
      request.headers.get("stripe-signature") as string,
      process.env.STRIPE_WEBHOOK_SECRET as string
    );
  } catch (error) {
    console.error("Error verifying webhook signature", error);
    return new NextResponse("Webhook error", { status: 400 });
  }

  if (event.type === "charge.succeeded") {
    console.log("Charge succeeded");
    const charge = event.data.object as Stripe.Charge;
    const email = charge.billing_details.email;
    const priceInCents = charge.amount;
    const name = charge.billing_details.name;
    const shippingDetails = charge.shipping;

    // Parse metadata
    const productIds: string[] = JSON.parse(charge.metadata.productIds || "[]");
    const quantities: number[] = JSON.parse(charge.metadata.quantities || "[]");
    const deliveryMethod = charge.metadata.deliveryMethod;

    if (!email || !name || !shippingDetails) {
      return new NextResponse("Bad requestz", { status: 400 });
    }

  try {
    event = stripe.webhooks.constructEvent(
      await request.text(),
      request.headers.get("stripe-signature") as string,
      process.env.STRIPE_WEBHOOK_SECRET as string
    );
  } catch (error) {
    console.error("Error verifying webhook signature", error);
    return new NextResponse("Webhook error", { status: 400 });
  }