chore: improve strip logging (#6866)

Author: n1ru4l

packages/services/commerce/src/stripe-billing/index.ts

@@ -63,34 +63,83 @@ export const stripeBillingRouter = router({
       }),
     )
     .query(async ({ ctx, input }) => {
+      ctx.req.log.debug(
+        'Find active subscription for organization. (organizationId=%s)',
+        input.organizationId,
+      );
+
       const storage = ctx.stripeBilling.storage;
       const organizationBillingRecord = await storage.getOrganizationBilling({
         organizationId: input.organizationId,
       });
 
       if (!organizationBillingRecord) {
+        ctx.req.log.debug(
+          'No billing record found for organization. (organizationId=%s)',
+          input.organizationId,
+        );
         throw new Error(`Organization does not have a subscription record!`);
       }
 
+      ctx.req.log.debug(
+        'Load customer from stripe based on external billing reference. (organizationId=%s, externalBillingReference=%s)',
+        input.organizationId,
+        organizationBillingRecord.externalBillingReference,
+      );
+
       const customer = await ctx.stripeBilling.stripe.customers.retrieve(
         organizationBillingRecord.externalBillingReference,
       );
 
+      ctx.req.log.debug(
+        'Stripe customer found (organizationId=%s, stripeCustomerId=%s, isDeleted=%s)',
+        input.organizationId,
+        customer.id,
+        customer.deleted ?? false,
+      );
+
       if (customer.deleted === true) {
         await storage.deleteOrganizationBilling({
           organizationId: input.organizationId,
         });
 
+        ctx.req.log.debug(
+          'Stripe customer is deleted (organizationId=%s, stripeCustomerId=%s, isDeleted=%s)',
+          input.organizationId,
+          customer.id,
+          customer.deleted ?? false,
+        );
+
         return null;
       }
 
-      const subscriptions = await ctx.stripeBilling.stripe.subscriptions
-        .list({
-          customer: organizationBillingRecord.externalBillingReference,
-        })
-        .then(v => v.data.filter(r => r.metadata?.hive_subscription));
+      ctx.req.log.debug(
+        'Load subscriptions for customer (organizationId=%s, stripeCustomerId=%s)',
+        input.organizationId,
+        customer.id,
+      );
+
+      const allSubscriptions = await ctx.stripeBilling.stripe.subscriptions.list({
+        customer: customer.id,
+      });
+
+      ctx.req.log.debug(
+        'Found total of %s subscription(s) (organizationId=%s, stripeCustomerId=%s)',
+        String(allSubscriptions.data.length),
+        input.organizationId,
+        customer.id,
+      );
+
+      const actualSubscription =
+        allSubscriptions.data.find(r => r.metadata?.hive_subscription) ?? null;
 
-      const actualSubscription = subscriptions[0] || null;
+      if (!actualSubscription) {
+        ctx.req.log.debug(
+          'Could not find the subscription with the hive metadata. (organizationId=%s, stripeCustomerId=%s)',
+          input.organizationId,
+          customer.id,
+        );
+      }
 
       const paymentMethod = await ctx.stripeBilling.stripe.customers.listPaymentMethods(
         customer.id,
@@ -100,6 +149,14 @@ export const stripeBillingRouter = router({
         },
       );
 
+      if (!paymentMethod) {
+        ctx.req.log.debug(
+          'Could not find the card payment method for he strip customer. (organizationId=%s, stripeCustomerId=%s)',
+          input.organizationId,
+          customer.id,
+        );
+      }
+
       return {
         paymentMethod: paymentMethod.data[0] || null,
         subscription: actualSubscription,