웹훅

await pay.webhooks.create({
  url: "https://example.com/api/webhooks/pay",
  events: [
    "subscription.created",
    "subscription.renewed",
    "subscription.cancelled",
    "payment.completed",
  ],
});

// .npmrc — 익명 read, 토큰 불필요
// @modfolio:registry=https://pkg.modfolio.io/api/packages/modfolio/npm/
// bun add @modfolio/contracts@latest

import {
  verifyModfolioEvent,
  dispatchModfolioEvent,
} from "@modfolio/contracts/webhook";

export async function POST({ request, env }) {
  // raw 문자열이어야 한다 — request.json() 으로 파싱한 뒤
  // 재직렬화하면 바이트가 달라져 서명이 깨진다.
  const body = await request.text();

  const result = await verifyModfolioEvent(
    body,
    request.headers,
    env.PAY_WEBHOOK_SECRET,
  );

  if (!result.success) {
    // reason: missing_headers | timestamp_out_of_tolerance
    //       | invalid_signature | invalid_payload
    // detail 은 어느 필드가 문제인지 한 줄로 알려준다.
    return new Response(result.reason, { status: 400 });
  }

  await dispatchModfolioEvent(result.event, {
    "payment.completed": (e) => grantAccess(e),
    "subscription.cancelled": (e) => revokeAccess(e),
  });

  // 모르는 타입도 2xx — 아니면 무한 재시도를 부른다.
  return new Response(null, { status: 204 });
}

async function handleWebhook(req: Request) {
  const eventId = req.headers.get("webhook-id");

  // 이미 처리한 이벤트인지 확인
  const exists = await db.processedEvents.findUnique({
    where: { eventId },
  });
  if (exists) {
    return new Response("OK", { status: 200 });
  }

  // 이벤트 처리 + ID 기록을 트랜잭션으로
  await db.$transaction(async (tx) => {
    await processEvent(tx, req);
    await tx.processedEvents.create({
      data: { eventId, processedAt: new Date() },
    });
  });

  return new Response("OK", { status: 200 });
}