From 107671840a32733ffaeeb4cfc2ab56480e64f20f Mon Sep 17 00:00:00 2001
From: isra el <vernu1997@gmail.com>
Date: Thu, 20 Feb 2025 08:46:46 +0300
Subject: [PATCH] chore(api): improve logging for polar webhook notifications

---
 api/src/billing/billing.service.ts                      | 8 ++++++--
 api/src/billing/schemas/polar-webhook-payload.schema.ts | 6 ++++++
 2 files changed, 12 insertions(+), 2 deletions(-)

diff --git a/api/src/billing/billing.service.ts b/api/src/billing/billing.service.ts
index 267b16c..145f378 100644
--- a/api/src/billing/billing.service.ts
+++ b/api/src/billing/billing.service.ts
@@ -430,8 +430,10 @@ export class BillingService {
   async storePolarWebhookPayload(payload: any) {
     const userId = payload.data?.metadata?.userId || payload.data?.userId
     const eventType = payload.type
-    const name = payload.data?.customer?.name
-    const email = payload.data?.customer?.email
+    const name = payload.data?.customer?.name || payload.data?.customerName
+    const email = payload.data?.customer?.email || payload.data?.customerEmail
+    const productId = payload.data?.product?.id || payload.data?.productId
+    const productName = payload.data?.product?.name || payload.data?.productName
 
     await this.polarWebhookPayloadModel.create({
       userId,
@@ -439,6 +441,8 @@ export class BillingService {
       name,
       email,
       payload,
+      productId,
+      productName,
     })
   }
 }
diff --git a/api/src/billing/schemas/polar-webhook-payload.schema.ts b/api/src/billing/schemas/polar-webhook-payload.schema.ts
index 16ff35b..6d43d46 100644
--- a/api/src/billing/schemas/polar-webhook-payload.schema.ts
+++ b/api/src/billing/schemas/polar-webhook-payload.schema.ts
@@ -19,6 +19,12 @@ export class PolarWebhookPayload {
 
   @Prop({ type: Object })
   payload: Record<string, any>
+
+  @Prop()
+  productId: string
+
+  @Prop()
+  productName: string
 }
 
 export const PolarWebhookPayloadSchema = SchemaFactory.createForClass(PolarWebhookPayload)