fix(payment-stripe): allow multiple webhooks

Author: MatthewPattell

microservices/payment-stripe/README.md

@@ -28,7 +28,7 @@ This microservice provides payments mechanism for stipe.
 - `MS_API_KEY` - Stripe api key to connect ms with stripe sdk. Default: `example`
 - `MS_CONFIG` - JSON onject which contains apiVersion property required by Stripe. Default: `'{"apiVersion": "2022-11-15"}'`
 - `MS_PAYMENT_METHODS` - Payment methods allowed using in Stripe. Default: `'["bancontact", "card"]'`
-- `MS_WEBHOOK_KEY` - Stripe webhook key to connect ms and work with stripe webhook service. Example: `whsec_c6332a6b339173127d2e6c813112e2f2323b4b2b10eea5ac17c5649a60cf335e`
+- `MS_WEBHOOK_KEYS` - Stripe webhook keys to connect ms and work with stripe webhook service. Example: `{"myId":"whsec_c6332a6b339173127d2e6c813112e2f2323b4b2b10eea5ac17c5649a60cf335e"}`
 - `MS_PAYOUT_COEFF` - Number for calculating amount of money for transferring to the product owners. Default: `0.3`
 - `MS_FEES` - Fees that takes while creating payment intent. Default: `'{ "stableUnit": 30, "paymentPercent": 2.9 }'`
 - [See full list `COMMON ENVIRONMENTS`](https://github.com/Lomray-Software/microservice-helpers#common-environments)

microservices/payment-stripe/src/config/remote.ts

@@ -6,7 +6,7 @@ const defaultConfig: IRemoteConfig = {
   paymentMethods: CONST.MS_PAYMENT_METHODS,
   apiKey: CONST.MS_API_KEY,
   config: CONST.MS_CONFIG,
-  webhookKey: CONST.MS_WEBHOOK_KEY,
+  webhookKeys: CONST.MS_WEBHOOK_KEYS,
   payoutCoeff: CONST.MS_PAYOUT_COEFF,
   fees: JSON.parse(CONST.MS_FEES),
 };

microservices/payment-stripe/src/constants/index.ts

@@ -9,7 +9,7 @@ const constants = {
   MS_API_KEY: process.env.MS_API_KEY ?? '',
   MS_CONFIG: JSON.parse(process.env.MS_CONFIG ?? '{"apiVersion": "2022-11-15"}'),
   MS_PAYMENT_METHODS: JSON.parse(process.env.MS_PAYMENT_METHODS ?? '["bancontact", "card"]'),
-  MS_WEBHOOK_KEY: process.env.MS_WEBHOOK_KEY ?? '',
+  MS_WEBHOOK_KEYS: JSON.parse(process.env.MS_WEBHOOK_KEYS ?? '{}'),
   MS_PAYOUT_COEFF: Number(process.env.MS_PAYOUT_COEFF) ?? 0.3,
   MS_FEES: process.env.MS_FEES ?? '{ "stableUnit": 30, "paymentPercent": 2.9 }',
 };

microservices/payment-stripe/src/interfaces/remote-config.ts

@@ -5,7 +5,9 @@ import IFees from '@interfaces/fees';
  * Microservice remote config
  */
 export interface IRemoteConfig {
-  webhookKey?: string;
+  webhookKeys?: {
+    [id: string]: string; // id (unique key) - secret (webhook Signing secret)
+  };
   payoutCoeff?: number;
   fees?: IFees;
   paymentMethods?: string[];

microservices/payment-stripe/src/methods/stripe/webhook.ts

@@ -11,6 +11,11 @@ class WebhookInput {
 
   @IsString()
   rawBody: string;
+
+  @IsObject()
+  query: {
+    id: string; // webhook id
+  };
 }
 
 class WebhookOutput {
@@ -24,17 +29,18 @@ const webhook = Endpoint.custom(
   () => ({
     input: WebhookInput,
     output: WebhookOutput,
-    description: 'Get stripe webhooks handler',
+    description: 'Handling and processing stripe webhooks.',
   }),
-  async ({ rawBody, payload }) => {
-    const { webhookKey } = await remoteConfig();
+  async ({ rawBody, query, payload }) => {
+    const { webhookKeys } = await remoteConfig();
+    const webhookKey = webhookKeys?.[query?.id];
 
     if (!webhookKey) {
-      throw new Error('Webhook key is not provided');
+      throw new Error(`Webhook key is not provided for id: ${query.id}`);
     }
 
     if (!payload?.headers?.['stripe-signature']) {
-      throw new Error('Stripe signature is mot provided');
+      throw new Error('Stripe signature is mot provided.');
     }
 
     const service = await Factory.create(getManager());