Bun.js + Stripe Webhooks + Drizzle: платежі без дублювань

import Stripe from "stripe";
const stripe = new Stripe(Bun.env.STRIPE_SECRET_KEY!);

export async function verifyStripeRequest(request: Request) {
  const signature = request.headers.get("stripe-signature");
  if (!signature) throw new Response("Missing signature", { status: 400 });
  const rawBody = await request.text();
  return stripe.webhooks.constructEvent(rawBody, signature, Bun.env.STRIPE_WEBHOOK_SECRET!);
}

import { eq } from "drizzle-orm";
import { db } from "./db/client";
import { stripeEvents } from "./db/schema";

export async function processEvent(event: Stripe.Event) {
  const inserted = await db.insert(stripeEvents).values({ id: event.id, type: event.type }).onConflictDoNothing().returning();
  if (inserted.length === 0) return { duplicate: true };

  await db.transaction(async (tx) => {
    if (event.type === "checkout.session.completed") {
      const session = event.data.object as Stripe.Checkout.Session;
      // tx.update(orders).set({ status: "paid" }).where(eq(orders.id, session.client_reference_id!));
    }
    await tx.update(stripeEvents).set({ processedAt: new Date() }).where(eq(stripeEvents.id, event.id));
  });
  return { duplicate: false };
}

export async function POST(request: Request) {
  try {
    const event = await verifyStripeRequest(request);
    await processEvent(event);
    return new Response("ok", { status: 200 });
  } catch (error) {
    console.error("stripe webhook failed", error);
    return new Response("retry", { status: 500 });
  }
}