Add connect webhook

Author: steven-tey

…pp/api/stripe/webhook/account-updated.ts …tripe/connect/webhook/account-updated.tsapps/web/app/api/stripe/webhook/account-updated.ts renamed to apps/web/app/api/stripe/connect/webhook/account-updated.ts apps/web/app/api/stripe/webhook/account-updated.ts renamed to apps/web/app/api/stripe/connect/webhook/account-updated.ts

@@ -1 +1,56 @@
-export * from "../../integration/webhook/route";
+import { stripe } from "@/lib/stripe";
+import { log } from "@dub/utils";
+import { NextResponse } from "next/server";
+import Stripe from "stripe";
+import { accountUpdated } from "./account-updated";
+
+const relevantEvents = new Set([
+  "account.updated",
+  "charge.succeeded",
+  "payment_method.attached",
+  "checkout.session.completed",
+  "customer.subscription.updated",
+  "customer.subscription.deleted",
+  "invoice.payment_failed",
+]);
+
+// POST /api/stripe/webhook – listen to Stripe webhooks
+export const POST = async (req: Request) => {
+  const buf = await req.text();
+  const sig = req.headers.get("Stripe-Signature") as string;
+  const webhookSecret = process.env.STRIPE_CONNECT_WEBHOOK_SECRET;
+  let event: Stripe.Event;
+  try {
+    if (!sig || !webhookSecret) return;
+    event = stripe.webhooks.constructEvent(buf, sig, webhookSecret);
+  } catch (err: any) {
+    console.log(`❌ Error message: ${err.message}`);
+    return new Response(`Webhook Error: ${err.message}`, {
+      status: 400,
+    });
+  }
+
+  // Ignore unsupported events
+  if (!relevantEvents.has(event.type)) {
+    return new Response("Unsupported event, skipping...", {
+      status: 200,
+    });
+  }
+  try {
+    switch (event.type) {
+      case "account.updated":
+        await accountUpdated(event);
+        break;
+    }
+  } catch (error) {
+    await log({
+      message: `Stripe webhook failed. Error: ${error.message}`,
+      type: "errors",
+    });
+    return new Response('Webhook error: "Webhook handler failed. View logs."', {
+      status: 400,
+    });
+  }
+
+  return NextResponse.json({ received: true });
+};

apps/web/app/api/stripe/connect/webhook/route.ts

@@ -2,7 +2,6 @@ import { stripe } from "@/lib/stripe";
 import { log } from "@dub/utils";
 import { NextResponse } from "next/server";
 import Stripe from "stripe";
-import { accountUpdated } from "./account-updated";
 import { chargeSucceeded } from "./charge-succeeded";
 import { checkoutSessionCompleted } from "./checkout-session-completed";
 import { customerSubscriptionDeleted } from "./customer-subscription-deleted";
@@ -11,7 +10,6 @@ import { invoicePaymentFailed } from "./invoice-payment-failed";
 import { paymentMethodAttached } from "./payment-method-attached";
 
 const relevantEvents = new Set([
-  "account.updated",
   "charge.succeeded",
   "payment_method.attached",
   "checkout.session.completed",
@@ -44,9 +42,6 @@ export const POST = async (req: Request) => {
   }
   try {
     switch (event.type) {
-      case "account.updated":
-        await accountUpdated(event);
-        break;
       case "charge.succeeded":
         await chargeSucceeded(event);
         break;