Inna
389dac68c4
- 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>
32 lines
1.2 KiB
TypeScript
32 lines
1.2 KiB
TypeScript
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 }
|
|
}
|