fix(tenant-management): add post webhook handler (#22)

add post webhook handler

gh-21

## Description

Please include a summary of the change and which issue is fixed. Please
also include relevant motivation and context. List any dependencies that
are required for this change.

Fixes # (issue)

## Type of change

Please delete options that are not relevant.

- [ ] Bug fix (non-breaking change which fixes an issue)
- [ ] New feature (non-breaking change which adds functionality)
- [ ] Breaking change (fix or feature that would cause existing
functionality to not work as expected)
- [ ] Intermediate change (work in progress)

## How Has This Been Tested?

Please describe the tests that you ran to verify your changes. Provide
instructions so we can reproduce. Please also list any relevant details
for your test configuration

- [ ] Test A
- [ ] Test B

## Checklist:

- [ ] Performed a self-review of my own code
- [ ] npm test passes on your machine
- [ ] New tests added or existing tests modified to cover all changes
- [ ] Code conforms with the style guide
- [ ] API Documentation in code was updated
- [ ] Any dependent changes have been merged and published in downstream
modules

services/tenant-management-service/src/__tests__/acceptance/webhook.controller.acceptance.ts

@@ -4,7 +4,7 @@ import {ILogger, LOGGER, STATUS_CODE} from '@sourceloop/core';
 import {createHmac, randomBytes} from 'crypto';
 import {TenantMgmtServiceApplication} from '../../application';
 import {TenantStatus} from '../../enums';
-import {WEBHOOK_CONFIG} from '../../keys';
+import {PostWebhookHandlerServiceKey, WEBHOOK_CONFIG} from '../../keys';
 import {
   ContactRepository,
   ResourceRepository,
@@ -24,6 +24,7 @@ describe('WebhookController', () => {
   let tenantRepo: TenantRepository;
   let contactRepo: ContactRepository;
   let webhookPayload: WebhookPayload;
+  let postWebhookHandlerServiceStub: sinon.SinonStub;
   const nonExistantTenant = 'non-existant-tenant';
   const notifStub = sinon.stub();
 
@@ -49,6 +50,11 @@ describe('WebhookController', () => {
       createNotification: notifStub,
       getTemplateByName: (name: string) => testTemplates[name],
     });
+
+    postWebhookHandlerServiceStub = sinon.stub();
+    app.bind(PostWebhookHandlerServiceKey).to({
+      postWebhookHandler: postWebhookHandlerServiceStub,
+    });
   });
 
   after(async () => {
@@ -70,6 +76,19 @@ describe('WebhookController', () => {
   });
 
   describe('Common', () => {
+    it('should call postWebhookHandler on successful webhook processing', async () => {
+      const headers = await buildHeaders(webhookPayload);
+      await client
+        .post('/webhook')
+        .set(webhookConfig.signatureHeaderName, headers.signature)
+        .set(webhookConfig.timestampHeaderName, headers.timestamp)
+        .send(webhookPayload)
+        .expect(STATUS_CODE.NO_CONTENT);
+
+      // Verify that postWebhookHandler is called
+      sinon.assert.calledOnce(postWebhookHandlerServiceStub);
+      sinon.assert.calledWith(postWebhookHandlerServiceStub, webhookPayload);
+    });
     it('should return 204 status for a webhook call with valid token', async () => {
       const headers = await buildHeaders(webhookPayload);
       await client

services/tenant-management-service/src/keys.ts

@@ -1,7 +1,9 @@
 import {VerifyFunction} from 'loopback4-authentication';
 import {
+  IPostWebhookHandlerService,
   ITenantManagementServiceConfig,
   LeadUser,
+  ResourceProvisionedWebhookPayload,
   WebhookConfig,
   WebhookNotificationServiceType,
 } from './types';
@@ -74,3 +76,7 @@ export const WebhookNotificationService =
 export const EventConnectorBinding = BindingKey.create<
   IEventConnector<unknown>
 >('arc-saas.services.tenant-management.event-connector');
+
+export const PostWebhookHandlerServiceKey = BindingKey.create<
+  IPostWebhookHandlerService<ResourceProvisionedWebhookPayload>
+>('services.PostWebhookHandlerService');

services/tenant-management-service/src/services/webhook/provisioning-webhook.handler.ts

@@ -15,6 +15,8 @@ import {
 } from '../../types';
 import {CryptoHelperService} from '../crypto-helper.service';
 import {NotificationService} from '../notifications';
+import {IPostWebhookHandlerService} from '../../types/i-post-webhook-handler-service.interface';
+import {PostWebhookHandlerServiceKey} from '../../keys';
 
 /**
  * Handler for provisioning webhooks.
@@ -41,6 +43,8 @@ export class ProvisioningWebhookHandler implements IWebhookHandler {
     public tenantRepository: TenantRepository,
     @inject('services.NotificationService')
     private notificationService: NotificationService,
+    @inject(PostWebhookHandlerServiceKey)
+    private postWebhookHandlerService: IPostWebhookHandlerService<ResourceProvisionedWebhookPayload>,
     @service(CryptoHelperService)
     private cryptoHelperService: CryptoHelperService,
     @inject(LOGGER.LOGGER_INJECT)
@@ -97,6 +101,7 @@ export class ProvisioningWebhookHandler implements IWebhookHandler {
           {transaction},
         );
       }
+      await this.postWebhookHandlerService.postWebhookHandler(payload);
 
       await transaction.commit();
     } catch (e) {

services/tenant-management-service/src/types/i-post-webhook-handler-service.interface.ts

@@ -0,0 +1,7 @@
+import {ResourceProvisionedWebhookPayload} from './webhook-payload.type';
+
+export interface IPostWebhookHandlerService<
+  T extends ResourceProvisionedWebhookPayload,
+> {
+  postWebhookHandler(dto: T): Promise<void>;
+}

services/tenant-management-service/src/types/index.ts

@@ -38,3 +38,4 @@ export * from './resource.type';
 export * from './i-provisioning-service.interface';
 export * from './i-subscription.interface';
 export * from './i-event-connector.interface';
+export * from './i-post-webhook-handler-service.interface';