📈 (billing) Track when workspace subscription is cancelled

apps/builder/src/features/billing/api/createCheckoutSession.ts

@@ -134,7 +134,6 @@ export const createCheckoutSessionUrl =
   (stripe: Stripe) =>
   async ({
     customerId,
-    userId,
     workspaceId,
     currency,
     plan,
@@ -158,7 +157,6 @@ export const createCheckoutSessionUrl =
         plan,
         additionalChats,
         additionalStorage,
-        userId,
       },
       currency,
       billing_address_collection: 'required',

apps/builder/src/features/billing/api/createCustomCheckoutSession.ts

@@ -84,7 +84,6 @@ export const createCustomCheckoutSession = authenticatedProcedure
         mode: 'subscription',
         metadata: {
           claimableCustomPlanId: workspace.claimableCustomPlan.id,
-          userId: user.id,
         },
         currency: workspace.claimableCustomPlan.currency,
         billing_address_collection: 'required',

apps/builder/src/pages/api/stripe/webhook.ts

@@ -4,7 +4,7 @@ import Stripe from 'stripe'
 import Cors from 'micro-cors'
 import { buffer } from 'micro'
 import prisma from '@/lib/prisma'
-import { Plan } from '@typebot.io/prisma'
+import { Plan, WorkspaceRole } from '@typebot.io/prisma'
 import { RequestHandler } from 'next/dist/server/next'
 import { sendTelemetryEvents } from '@typebot.io/lib/telemetry/sendTelemetryEvent'
 import { PublicTypebot, Typebot } from '@typebot.io/schemas'
@@ -52,18 +52,13 @@ const webhookHandler = async (req: NextApiRequest, res: NextApiResponse) => {
               }
             | { claimableCustomPlanId: string; userId: string }
           if ('plan' in metadata) {
-            const {
-              workspaceId,
-              plan,
-              additionalChats,
-              additionalStorage,
-              userId,
-            } = metadata
+            const { workspaceId, plan, additionalChats, additionalStorage } =
+              metadata
             if (!workspaceId || !plan || !additionalChats || !additionalStorage)
               return res
                 .status(500)
                 .send({ message: `Couldn't retrieve valid metadata` })
-            await prisma.workspace.update({
+            const workspace = await prisma.workspace.update({
               where: { id: workspaceId },
               data: {
                 plan,
@@ -72,20 +67,31 @@ const webhookHandler = async (req: NextApiRequest, res: NextApiResponse) => {
                 additionalStorageIndex: parseInt(additionalStorage),
                 isQuarantined: false,
               },
-            })
-
-            await sendTelemetryEvents([
-              {
-                name: 'Subscription updated',
-                workspaceId,
-                userId,
-                data: {
-                  plan,
-                  additionalChatsIndex: parseInt(additionalChats),
-                  additionalStorageIndex: parseInt(additionalStorage),
+              include: {
+                members: {
+                  select: { user: { select: { id: true } } },
+                  where: {
+                    role: WorkspaceRole.ADMIN,
+                  },
                 },
               },
-            ])
+            })
+
+            for (const user of workspace.members.map((member) => member.user)) {
+              if (!user?.id) continue
+              await sendTelemetryEvents([
+                {
+                  name: 'Subscription updated',
+                  workspaceId,
+                  userId: user.id,
+                  data: {
+                    plan,
+                    additionalChatsIndex: parseInt(additionalChats),
+                    additionalStorageIndex: parseInt(additionalStorage),
+                  },
+                },
+              ])
+            }
           } else {
             const { claimableCustomPlanId, userId } = metadata
             if (!claimableCustomPlanId)
@@ -139,7 +145,32 @@ const webhookHandler = async (req: NextApiRequest, res: NextApiResponse) => {
               customStorageLimit: null,
               customSeatsLimit: null,
             },
+            include: {
+              members: {
+                select: { user: { select: { id: true } } },
+                where: {
+                  role: WorkspaceRole.ADMIN,
+                },
+              },
+            },
           })
+
+          for (const user of workspace.members.map((member) => member.user)) {
+            if (!user?.id) continue
+            await sendTelemetryEvents([
+              {
+                name: 'Subscription updated',
+                workspaceId: workspace.id,
+                userId: user.id,
+                data: {
+                  plan: Plan.FREE,
+                  additionalChatsIndex: 0,
+                  additionalStorageIndex: 0,
+                },
+              },
+            ])
+          }
+
           const typebots = (await prisma.typebot.findMany({
             where: {
               workspaceId: workspace.id,

packages/scripts/checkSubscriptionsStatus.ts

@@ -18,7 +18,7 @@ const checkSubscriptionsStatus = async () => {
     apiVersion: '2022-11-15',
   })
 
-  let activeSubscriptions = 0
+  let totalActiveSubscriptions = 0
   for (const workspace of workspacesWithPaidPlan) {
     if (!workspace.stripeId) {
       console.log('No stripe ID', workspace.id)
@@ -35,12 +35,12 @@ const checkSubscriptionsStatus = async () => {
       continue
     }
     if (subscription.status === 'active') {
-      activeSubscriptions++
+      totalActiveSubscriptions++
       continue
     }
     console.log(`${workspace.id} - ${workspace.name} - ${subscription.status}`)
   }
-  console.log('Active subscriptions', activeSubscriptions)
+  console.log('Active subscriptions', totalActiveSubscriptions)
 }
 
 checkSubscriptionsStatus()