✨ Handle Stripe webhook event

src/modules/stripe/stripe-webhook.controller.ts

@@ -1,5 +1,4 @@
 import { Body, Controller, Headers, Post } from '@nestjs/common';
-import Stripe from 'stripe';
 import { Public } from '../auth/public.decorator';
 import { StripeService } from './stripe.service';
 
@@ -11,8 +10,8 @@ export class StripeWebhookController {
   @Post()
   async handleWebhook(
     @Headers('stripe-signature') signature: string,
-    @Body() event: Stripe.Event,
-  ): Promise<void> {
-    return this.stripeService.handleWebhook(signature, event);
+    @Body() raw: Buffer,
+  ): Promise<{ received: true }> {
+    return this.stripeService.handleWebhook(signature, raw);
   }
 }

src/modules/stripe/stripe.service.ts

@@ -1,6 +1,7 @@
 import {
   BadRequestException,
   Injectable,
+  Logger,
   NotFoundException,
 } from '@nestjs/common';
 import { ConfigService } from '@nestjs/config';
@@ -10,6 +11,7 @@ import { PrismaService } from '../prisma/prisma.service';
 @Injectable()
 export class StripeService {
   stripe: Stripe;
+  logger = new Logger('stripe');
 
   constructor(
     private configService: ConfigService,
@@ -209,12 +211,20 @@ export class StripeService {
     });
   }
 
-  async handleWebhook(signature: string, payload: any) {
-    this.stripe.webhooks.constructEvent(
+  async handleWebhook(
+    signature: string,
+    payload: Buffer,
+  ): Promise<{ received: true }> {
+    const event = this.stripe.webhooks.constructEvent(
       payload,
       signature,
       this.configService.get<string>('payments.stripeEndpointSecret') ?? '',
     );
+    switch (event.type) {
+      default:
+        this.logger.warn(`Unhandled event type ${event.type}`);
+    }
+    return { received: true };
   }
 
   private list<T>(result: Stripe.Response<Stripe.ApiList<T>>) {