Function polarWebhook

apps/api/src/controllers/webhook.controller.ts:316–452

(
  request: FastifyRequest<{
    Querystring: unknown;
  }>,
  reply: FastifyReply
)

}

export async function polarWebhook(
  request: FastifyRequest<{
    Querystring: unknown;
  }>,
  reply: FastifyReply
) {
  request.log.info({ body: request.body }, 'polar webhook received');

  const validation = await tryCatch(async () =>
    validatePolarEvent(
      request.rawBody!,
      request.headers as Record<string, string>,
      process.env.POLAR_WEBHOOK_SECRET ?? ''
    )
  );

  if (!validation.ok) {
    request.log.error(
      { err: validation.error },
      'polar webhook: failed to parse event'
    );
    throw validation.error;
  }

  const event = validation.data;

  const eventOrganizationId =
    'metadata' in event.data &&
    event.data.metadata &&
    typeof event.data.metadata === 'object' &&
    'organizationId' in event.data.metadata
      ? String(event.data.metadata.organizationId)
      : undefined;

  const eventCtx = {
    eventType: event.type,
    eventId: 'id' in event.data ? event.data.id : undefined,
    organizationId: eventOrganizationId,
  };

  request.log.info(
    eventCtx,
    `polar webhook: processing ${event.type}${eventOrganizationId ? ` for ${eventOrganizationId}` : ''}`
  );

  if (
    'data' in event &&
    'product' in event.data &&
    event.data.product?.name === 'Supporter'
  ) {
    request.log.info(eventCtx, 'polar webhook: supporter event ignored');
    return reply.status(202).send('OK');
  }

  const handler = await tryCatch(async () => {
    switch (event.type) {
      // A new paid billing cycle resets the org's usage counter. Polar sends
      // `order.updated` (not `order.created`) and the order moves through