feat(medusa-payment-stripe): Add delay to Stripe webhook

packages/medusa-payment-stripe/src/api/admin/orders/stripe-payments/[order_id]/route.ts

@@ -0,0 +1,7 @@
+import { MedusaRequest, MedusaResponse } from "@medusajs/medusa"
+import { getStripePayments } from "../../../../../controllers/get-payments"
+
+export const GET = async (req: MedusaRequest, res: MedusaResponse) => {
+  const payments = await getStripePayments(req)
+  res.json({ payments })
+}

packages/medusa-payment-stripe/src/api/middlewares.ts

@@ -0,0 +1,11 @@
+import type { MiddlewaresConfig } from "@medusajs/medusa"
+import { raw } from "body-parser"
+
+export const config: MiddlewaresConfig = {
+  routes: [
+    {
+      matcher: "/stripe/hooks",
+      middlewares: [raw({ type: "application/json" })],
+    },
+  ],
+}

packages/medusa-payment-stripe/src/api/stripe/hooks/route.ts

@@ -0,0 +1,29 @@
+import { MedusaRequest, MedusaResponse } from "@medusajs/medusa"
+import { constructWebhook } from "../../utils/utils"
+
+const WEBHOOK_DELAY = process.env.STRIPE_WEBHOOK_DELAY ?? 2000
+
+export const POST = async (req: MedusaRequest, res: MedusaResponse) => {
+  let event
+
+  try {
+    event = constructWebhook({
+      signature: req.headers["stripe-signature"],
+      body: req.body,
+      container: req.scope,
+    })
+
+    const eventBus = req.scope.resolve("eventBusService")
+
+    // we delay the processing of the event to avoid a conflict caused by a race condition
+    await eventBus.emit("medusa.stripe_payment_intent", event, {
+      delay: WEBHOOK_DELAY,
+      attempts: 2,
+    })
+  } catch (err) {
+    res.status(400).send(`Webhook Error: ${err.message}`)
+    return
+  }
+
+  res.sendStatus(200)
+}

packages/medusa-payment-stripe/src/api/utils/utils.ts

@@ -51,13 +51,9 @@ export async function handlePaymentHook({
   container,
   paymentIntent,
 }: {
-  event: { type: string; id: string }
+  event: Stripe.Event
   container: AwilixContainer
-  paymentIntent: {
-    id: string
-    metadata: { cart_id?: string; resource_id?: string }
-    last_payment_error?: { message: string }
-  }
+  paymentIntent: Stripe.PaymentIntent
 }): Promise<{ statusCode: number }> {
   const logger = container.resolve("logger")
 

packages/medusa-payment-stripe/src/subscribers/stripe.ts

@@ -0,0 +1,24 @@
+import { type SubscriberArgs, type SubscriberConfig } from "@medusajs/medusa"
+import Stripe from "stripe"
+import { handlePaymentHook } from "../api/utils/utils"
+
+export default async function stripeHandler({
+  data,
+  container,
+}: SubscriberArgs<Stripe.Event>) {
+  const event = data
+  const paymentIntent = event.data.object as Stripe.PaymentIntent
+
+  await handlePaymentHook({
+    event,
+    container,
+    paymentIntent,
+  })
+}
+
+export const config: SubscriberConfig = {
+  event: "medusa.stripe_payment_intent",
+  context: {
+    subscriberId: "medusa.stripe_payment_intent",
+  },
+}

packages/medusa/src/api/routes/store/auth/create-session.ts

@@ -1,10 +1,9 @@
 import { IsEmail, IsNotEmpty } from "class-validator"
-import jwt from "jsonwebtoken"
 import { EntityManager } from "typeorm"
+import { defaultRelations } from "."
 import AuthService from "../../../../services/auth"
 import CustomerService from "../../../../services/customer"
 import { validator } from "../../../../utils/validator"
-import { defaultRelations } from "."
 
 /**
  * @oas [post] /store/auth