feat: listen to stripe account updated webhook

packages/server/src/api/controllers/StripeIntegration/StripeWebhooksController.ts

@@ -2,7 +2,7 @@ import { NextFunction, Request, Response, Router } from 'express';
 import { Inject, Service } from 'typedi';
 import bodyParser from 'body-parser';
 import { EventPublisher } from '@/lib/EventPublisher/EventPublisher';
-import { StripeCheckoutSessionCompletedEventPayload } from '@/interfaces/StripePayment';
+import { StripeWebhookEventPayload } from '@/interfaces/StripePayment';
 import { StripePaymentService } from '@/services/StripePayment/StripePaymentService';
 import events from '@/subscribers/events';
 import config from '@/config';
@@ -59,12 +59,16 @@ export class StripeWebhooksController {
             events.stripeWebhooks.onCheckoutSessionCompleted,
             {
               event,
-            } as StripeCheckoutSessionCompletedEventPayload
+            } as StripeWebhookEventPayload
           );
           break;
-        case 'payment_intent.payment_failed':
-          // Handle failed payment intent
-          console.log('PaymentIntent failed.');
+        case 'account.updated':
+          this.eventPublisher.emitAsync(
+            events.stripeWebhooks.onAccountUpdated,
+            {
+              event,
+            } as StripeWebhookEventPayload
+          );
           break;
         // Add more cases as needed
         default:

packages/server/src/interfaces/StripePayment.ts

@@ -14,3 +14,8 @@ export interface StripeInvoiceCheckoutSessionPOJO {
   publishableKey: string;
   redirectTo: string;
 }
+
+
+export interface StripeWebhookEventPayload {
+  event: any;
+}

packages/server/src/services/Sales/Invoices/GetInvoicePaymentLinkMetadata.ts

@@ -10,7 +10,7 @@ import { initalizeTenantServices } from '@/api/middleware/TenantDependencyInject
 @Service()
 export class GetInvoicePaymentLinkMetadata {
   @Inject()
-  tenancy: HasTenancyService;
+  private tenancy: HasTenancyService;
 
   @Inject()
   private transformer: TransformerInjectable;
@@ -23,12 +23,9 @@ export class GetInvoicePaymentLinkMetadata {
   async getInvoicePaymentLinkMeta(linkId: string) {
     const paymentLink = await PaymentLink.query()
       .findOne('linkId', linkId)
+      .where('resourceType', 'SaleInvoice')
       .throwIfNotFound();
-
-    // 
-    if (paymentLink.resourceType !== 'SaleInvoice') {
-      throw new ServiceError('');
-    }
+ 
     // Validate the expiry at date.
     if (paymentLink.expiryAt) {
       const currentDate = moment();

packages/server/src/services/Sales/Invoices/GetInvoicePaymentLinkTransformer.ts

@@ -82,7 +82,7 @@ class GetInvoicePaymentLinkEntryMetaTransformer extends ItemEntryTransformer {
     ];
   };
 
-  itemName(entry) {
+  public itemName(entry) {
     return entry.item.name;
   }
 

packages/server/src/services/StripePayment/events/StripeWebhooksSubscriber.ts

@@ -1,10 +1,18 @@
 import { Inject, Service } from 'typedi';
 import events from '@/subscribers/events';
 import { CreatePaymentReceiveStripePayment } from '../CreatePaymentReceivedStripePayment';
-import { StripeCheckoutSessionCompletedEventPayload } from '@/interfaces/StripePayment';
+import {
+  StripeCheckoutSessionCompletedEventPayload,
+  StripeWebhookEventPayload,
+} from '@/interfaces/StripePayment';
+import HasTenancyService from '@/services/Tenancy/TenancyService';
+import { Tenant } from '@/system/models';
 
 @Service()
 export class StripeWebhooksSubscriber {
+  @Inject()
+  private tenancy: HasTenancyService;
+
   @Inject()
   private createPaymentReceiveStripePayment: CreatePaymentReceiveStripePayment;
 
@@ -16,6 +24,10 @@ export class StripeWebhooksSubscriber {
       events.stripeWebhooks.onCheckoutSessionCompleted,
       this.handleCheckoutSessionCompleted.bind(this)
     );
+    bus.subscribe(
+      events.stripeWebhooks.onAccountUpdated,
+      this.handleAccountUpdated.bind(this)
+    );
   }
 
   /**
@@ -35,10 +47,38 @@ export class StripeWebhooksSubscriber {
     // Convert from Stripe amount (cents) to normal amount (dollars)
     const amountInDollars = amount / 100;
 
+    // Creates a new payment received transaction.
     await this.createPaymentReceiveStripePayment.createPaymentReceived(
       tenantId,
       saleInvoiceId,
       amountInDollars
     );
   }
+
+  /**
+   * Handles the account updated.
+   * @param {StripeWebhookEventPayload}
+   */
+  async handleAccountUpdated({ event }: StripeWebhookEventPayload) {
+    const { metadata } = event.data.object;
+    const account = event.data.object;
+    const tenantId = parseInt(metadata.tenantId, 10);
+
+    if (!metadata?.paymentIntegrationId || !metadata.tenantId) return;
+
+    // Find the tenant or throw not found error.
+    await Tenant.query().findById(tenantId).throwIfNotFound();
+
+    // Check if the account capabilities are active
+    if (account.capabilities.card_payments === 'active') {
+      const { PaymentIntegration } = this.tenancy.models(tenantId);
+
+      // Marks the payment method integration as active.
+      await PaymentIntegration.query()
+        .findById(metadata?.paymentIntegrationId)
+        .patch({
+          active: true,
+        });
+    }
+  }
 }

packages/server/src/subscribers/events.ts

@@ -728,6 +728,7 @@ export default {
 
   // Stripe Payment Webhooks
   stripeWebhooks: {
-    onCheckoutSessionCompleted: 'onStripeCheckoutSessionCompleted'
+    onCheckoutSessionCompleted: 'onStripeCheckoutSessionCompleted',
+    onAccountUpdated: 'onStripeAccountUpdated'
   }
 };