Browse Source

chore(api): improve logging for polar webhook notifications

pull/52/head
isra el 1 year ago
parent
commit
107671840a
  1. 8
      api/src/billing/billing.service.ts
  2. 6
      api/src/billing/schemas/polar-webhook-payload.schema.ts

8
api/src/billing/billing.service.ts

@ -430,8 +430,10 @@ export class BillingService {
async storePolarWebhookPayload(payload: any) { async storePolarWebhookPayload(payload: any) {
const userId = payload.data?.metadata?.userId || payload.data?.userId const userId = payload.data?.metadata?.userId || payload.data?.userId
const eventType = payload.type 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({ await this.polarWebhookPayloadModel.create({
userId, userId,
@ -439,6 +441,8 @@ export class BillingService {
name, name,
email, email,
payload, payload,
productId,
productName,
}) })
} }
} }

6
api/src/billing/schemas/polar-webhook-payload.schema.ts

@ -19,6 +19,12 @@ export class PolarWebhookPayload {
@Prop({ type: Object }) @Prop({ type: Object })
payload: Record<string, any> payload: Record<string, any>
@Prop()
productId: string
@Prop()
productName: string
} }
export const PolarWebhookPayloadSchema = SchemaFactory.createForClass(PolarWebhookPayload) export const PolarWebhookPayloadSchema = SchemaFactory.createForClass(PolarWebhookPayload)
Loading…
Cancel
Save