src/lib/stripe.ts

import Stripe from "stripe";

const STRIPE_KEY = process.env.STRIPE_SECRET_KEY || "";
const STRIPE_WEBHOOK_SECRET = process.env.STRIPE_WEBHOOK_SECRET || "";

export const stripe = new Stripe(STRIPE_KEY, { apiVersion: "2026-02-25.clover" });

// Crear sesión de checkout para suscripción
export async function createCheckoutSession({
  userId,
  influencerId,
  influencerName,
  tier,
  price,
  stripeCustomerId,
  origin,
}: {
  userId: string;
  influencerId: string;
  influencerName: string;
  tier: string;
  price: number;
  stripeCustomerId?: string;
  origin: string;
}): Promise<string> {
  const session = await stripe.checkout.sessions.create({
    customer: stripeCustomerId,
    payment_method_types: ["card"],
    mode: "subscription",
    line_items: [
      {
        price_data: {
          currency: "usd",
          product_data: {
            name: `Suscripción a ${influencerName} - ${tier}`,
            description: `Acceso a contenido exclusivo de ${influencerName}`,
            metadata: {
              influencerId,
              userId,
              influencerName,
            },
          },
          recurring: {
            interval: "month",
            interval_count: 1,
          },
          unit_amount: Math.round(price * 100), // Convert to cents
        },
        quantity: 1,
      },
    ],
    metadata: {
      userId,
      influencerId,
      tier,
    },
    success_url: `${origin}/success?session_id={CHECKOUT_SESSION_ID}`,
    cancel_url: `${origin}/cancel`,
  });

  return session.id;
}

// Validar firma del webhook
export function validateWebhookSignature(body: string, signature: string): boolean {
  if (!STRIPE_WEBHOOK_SECRET) return false;
  try {
    const event = stripe.webhooks.constructEvent(body, signature, STRIPE_WEBHOOK_SECRET);
    return true;
  } catch {
    return false;
  }
}

// Parsear webhook event
export function parseWebhookEvent(body: string, signature: string) {
  if (!STRIPE_WEBHOOK_SECRET) throw new Error("STRIPE_WEBHOOK_SECRET no configurado");
  return stripe.webhooks.constructEvent(body, signature, STRIPE_WEBHOOK_SECRET);
}

// Crear o obtener cliente Stripe
export async function getOrCreateStripeCustomer(
  userId: string,
  email: string,
  name?: string
): Promise<string> {
  const customers = await stripe.customers.list({ email, limit: 1 });
  if (customers.data.length > 0) return customers.data[0].id;

  const customer = await stripe.customers.create({
    email,
    name: name || undefined,
    metadata: { userId },
  });
  return customer.id;
}

// Cancelar suscripción en Stripe
export async function cancelStripeSubscription(stripeSubscriptionId: string) {
  if (!stripeSubscriptionId) throw new Error("stripeSubscriptionId es requerido");
  return stripe.subscriptions.cancel(stripeSubscriptionId);
}