test subscription saving customer id

Author: rphovley

repos/License.ts

@@ -118,9 +118,9 @@ const deleteLicense = async (userId: string): Promise<boolean> => {
 
 
 
-const getLicenseByStripePaymentId = async (stripePaymentId: string): Promise<License | null> => {
+const getLicenseByCustomerId = async (customerId: string): Promise<License | null> => {
   const result = await db(tableName)
-    .where({ stripe_payment_id: stripePaymentId })
+    .where({ stripe_customer_id: customerId })
     .first('*')
 
   return result || null
@@ -139,11 +139,11 @@ const updateLicenseByStripePaymentId = async (stripePaymentId: string, status: L
 }
 
 export const LicenseRepo = {
+  getLicenseByCustomerId,
   getActiveLicenseByUserId,
   getFreeTrialLicenseByUserId,
   getExistingSubscriptionLicenseByUserId,
   getLicenseByUserId,
-  getLicenseByStripePaymentId,
   createLicense,
   updateLicense,
   deleteLicense,

services/WebhookService.ts

@@ -13,7 +13,9 @@ const getNotificationEngine = (): NotificationEngine => {
 }
 
 const handleCheckoutSessionCompleted = async (session: Stripe.Checkout.Session): Promise<void> => {
-  const customerId = session.customer as string
+  const customer = session.customer as Stripe.Customer
+  console.log('customer', customer)
+  const customerId = customer.id
   const userId = session.client_reference_id || session.metadata?.user_id
   const productId = session.metadata?.product_id
 
@@ -114,7 +116,7 @@ const handleSubscriptionUpdated = async (subscription: Stripe.Subscription): Pro
       const notificationEngine = getNotificationEngine()
 
       // Get license info to get user_id
-      const license = await LicenseRepo.getLicenseByStripePaymentId(subscription.id)
+      const license = await LicenseRepo.getLicenseByCustomerId(subscription.customer as string)
 
       await notificationEngine.sendNotification({
         type: 'subscription_cancelled',