litening especifics event from stripe

Luciano-Ferreira · Jul 8, 2021 · 6b3437c · 6b3437c
1 parent 9200401
commit 6b3437c
Show file tree

Hide file tree

Showing 2 changed files with 39 additions and 9 deletions.
diff --git a/src/pages/api/_lib/manageSubscription.ts b/src/pages/api/_lib/manageSubscription.ts
@@ -4,7 +4,8 @@ import { stripe } from '../../../services/stripe';
 
 export async function saveSubscription(
   subscriptionId: string, 
-  customerId: string
+  customerId: string,
+  createAction = false,
   ) {
     const userRef = await fauna.query(
       q.Select(
@@ -28,10 +29,27 @@ export async function saveSubscription(
 
     }
 
-    await fauna.query(
-      q.Create(
-        q.Collection('subscriptions'),
-        { data: subscriptionData }
+    if (createAction) {
+      await fauna.query(
+        q.Create(
+          q.Collection('subscriptions'),
+          { data: subscriptionData }
+        )
+      )
+    } else {
+      await fauna.query(
+        q.Replace(
+          q.Select(
+            "ref",
+            q.Get(
+              q.Match(
+                q.Index('subscription_by_id'),
+                subscriptionId,
+              )
+            )
+          ),
+          { data: subscriptionData }
+        )
       )
-    )
+    }
 }
diff --git a/src/pages/api/webhooks.ts b/src/pages/api/webhooks.ts
@@ -23,7 +23,9 @@ export const config = {
 }
 
 const  relevantEvents = new Set([
-    'checkout.session.completed'
+    'checkout.session.completed',
+    'customer.subscriptions.updated',
+    'customer.subscriptions.deleted'
 ])
 
 export default async function (req: NextApiRequest, res: NextApiResponse) {
@@ -44,12 +46,22 @@ export default async function (req: NextApiRequest, res: NextApiResponse) {
         if (relevantEvents.has(type)) {
             try {
                 switch (type) {
+                    case 'customer.subscription.updated':
+                    case 'customer.subscription.deleted':
+                        const subscription = event.data.object as Stripe.Subscription;
+                        await saveSubscription(
+                            subscription.id,
+                            subscription.customer.toString(),
+                            false
+                        )
+                        console.log(subscription.customer.toString())
+                        break;
                     case 'checkout.session.completed':
-
                         const checkoutSession = event.data.object as Stripe.Checkout.Session
                         await saveSubscription(
                             checkoutSession.subscription.toString(),
-                            checkoutSession.customer.toString()
+                            checkoutSession.customer.toString(),
+                            true
                         )
 
                         break;