Stripe: webhook que entrega el servicio aunque el usuario no vuelva

- app/api/stripe/webhook: verifica firma (constructEventAsync) y en
  checkout.session.completed registra la IP de Stripe (como Django) y ENTREGA
  el servicio. Idempotente frente a la página de éxito.
- lib/stripe.ts: claimPaidCheckout ahora es ATÓMICO (UPDATE ... WHERE fulfilled=0
  + affectedRows) para evitar doble entrega entre webhook y página de éxito;
  nuevo recordStripeIp.
- lib/fulfill.ts: fulfillCheckoutSession compartido (reclama + resuelve servicio
  desde metadata.service + ejecuta). checkout guarda `service` en metadata.
- service-success: usa la entrega compartida y distingue entregado/ya-procesado/error.
- i18n: Paid.alreadyProcessed.

Requiere configurar STRIPE_WEBHOOK_SECRET en .env.local (endpoint apuntando a
/api/stripe/webhook, evento checkout.session.completed).

Verificado: build OK, webhook 400 sin firma / firma inválida.

Co-Authored-By: Claude Opus 4.8 (1M context) <noreply@anthropic.com>

web-next/lib/fulfill.ts

@@ -0,0 +1,31 @@
+import { claimPaidCheckout } from './stripe'
+import { getPaidService } from './paid-services'
+
+export interface FulfillResult {
+  ok: boolean
+  service: string | null
+  character: string | null
+}
+
+/**
+ * Entrega un checkout pagado: reclama (atómico, una sola vez), resuelve el servicio
+ * desde metadata.service y ejecuta su acción. Reutilizable por la página de éxito y
+ * por el webhook, de modo que el pago se cumple aunque el usuario no vuelva.
+ *
+ * `fallbackService` permite a la página de éxito pasar el servicio de la URL para
+ * sesiones antiguas cuyo metadata no lo incluía.
+ */
+export async function fulfillCheckoutSession(
+  sessionId: string,
+  fallbackService?: string,
+): Promise<FulfillResult> {
+  const claim = await claimPaidCheckout(sessionId)
+  if (!claim) return { ok: false, service: fallbackService ?? null, character: null }
+
+  const service = claim.metadata.service || fallbackService || ''
+  const cfg = service ? getPaidService(service) : null
+  if (!cfg) return { ok: false, service: service || null, character: claim.characterName }
+
+  const ok = await cfg.fulfill(claim.characterName, claim.metadata)
+  return { ok, service, character: claim.characterName }
+}

web-next/lib/stripe.ts

@@ -1,5 +1,5 @@
 import Stripe from 'stripe'
-import type { RowDataPacket } from 'mysql2'
+import type { RowDataPacket, ResultSetHeader } from 'mysql2'
 import { db, DB } from './db'
 
 const stripe = new Stripe(process.env.STRIPE_SECRET_KEY as string)
@@ -82,11 +82,26 @@ export async function claimPaidCheckout(
     return null
   }
   const [rows] = await db(DB.default).query<RowDataPacket[]>(
-    'SELECT id, character_name, fulfilled FROM home_stripelog WHERE session_id = ?',
+    'SELECT id, character_name FROM home_stripelog WHERE session_id = ?',
     [sessionId],
   )
   const log = rows[0]
-  if (!log || log.fulfilled) return null
-  await db(DB.default).query('UPDATE home_stripelog SET fulfilled = 1 WHERE id = ?', [log.id])
+  if (!log) return null
+  // Reclamo ATÓMICO: solo gana quien pasa fulfilled 0->1. Evita doble entrega si
+  // el webhook y la página de éxito corren a la vez.
+  const [res] = await db(DB.default).query<ResultSetHeader>(
+    'UPDATE home_stripelog SET fulfilled = 1 WHERE id = ? AND fulfilled = 0',
+    [log.id],
+  )
+  if (res.affectedRows === 0) return null
   return { characterName: log.character_name, metadata }
 }
+
+/** Registra la IP de Stripe y actualiza el timestamp del log (como el webhook de Django). */
+export async function recordStripeIp(sessionId: string, ip: string): Promise<void> {
+  if (!sessionId) return
+  await db(DB.default).query('UPDATE home_stripelog SET stripe_ip = ?, timestamp = NOW() WHERE session_id = ?', [
+    ip.slice(0, 45),
+    sessionId,
+  ])
+}