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 + + @Prop() + productId: string + + @Prop() + productName: string } export const PolarWebhookPayloadSchema = SchemaFactory.createForClass(PolarWebhookPayload)