Allow async checkout purchases in UserProduct

Author: kof

packages/prisma-client/prisma/migrations/20260502000000_user_product_async_checkout/migration.sql

@@ -0,0 +1,71 @@
+-- Treat async-paid Checkout Sessions as purchase-granting events.
+-- Stripe can emit checkout.session.completed before async payment confirmation;
+-- checkout.session.async_payment_succeeded is the paid signal for that flow.
+CREATE OR REPLACE VIEW "UserProduct" AS (
+  SELECT
+    "userId",
+    "subscriptionId",
+    "productId",
+    "customerId",
+    "customerEmail"
+  FROM
+    "TransactionLog" AS tl
+  WHERE
+    "status" = 'complete'
+    AND "eventData"#>>'{data,object,payment_status}' = 'paid'
+    AND "eventType" IN (
+      'checkout.session.completed',
+      'checkout.session.async_payment_succeeded'
+    )
+    -- If both events were logged for one async Checkout Session, prefer the
+    -- paid async signal so the same subscription is not granted twice.
+    AND NOT (
+      tl."eventType" = 'checkout.session.completed'
+      AND tl."subscriptionId" IS NOT NULL
+      AND EXISTS (
+        SELECT
+          1
+        FROM
+          "TransactionLog" AS async_success
+        WHERE
+          async_success."subscriptionId" = tl."subscriptionId"
+          AND async_success."eventType" =
+            'checkout.session.async_payment_succeeded'
+          AND async_success."status" = 'complete'
+          AND async_success."eventData"#>>'{data,object,payment_status}' =
+            'paid')
+      )
+    AND NOT EXISTS (
+      SELECT
+        1
+      FROM
+        "TransactionLog" AS tlexsists
+      WHERE
+        tlexsists."subscriptionId" = tl."subscriptionId"
+        AND tlexsists."eventType" = 'customer.subscription.deleted'
+        AND tlexsists."status" = 'canceled'
+        AND tlexsists."eventCreated" > tl."eventCreated")
+      AND NOT EXISTS (
+        SELECT
+          1
+        FROM
+          "TransactionLog" AS tlexsists
+        WHERE
+          tlexsists."paymentIntent" = tl."paymentIntent"
+          AND tlexsists."eventType" = 'charge.refunded'
+          AND tlexsists."status" = 'succeeded'
+          AND tlexsists."eventCreated" > tl."eventCreated")
+      ORDER BY
+        "userId",
+        "eventCreated" DESC)
+    UNION ALL (
+      SELECT
+        "userId",
+        "subscriptionId",
+        "productId",
+        "customerId",
+        "customerEmail"
+      FROM
+        "TransactionLog"
+      WHERE
+        "eventType" = 'appsumo.activate');