Function webhookHandler

integrations/stripe/src/index.ts:1135–1189

(event: HandlerEvent<"HTTP">, logger: Logger)

}

async function webhookHandler(event: HandlerEvent<"HTTP">, logger: Logger) {
  logger.debug("[@trigger.dev/stripe] Handling webhook payload");

  const { rawEvent: request, source } = event;

  if (!request.body) {
    logger.debug("[@trigger.dev/stripe] No body found");

    return { events: [] };
  }

  const rawBody = await request.text();

  const signature = request.headers.get("stripe-signature");

  if (signature) {
    const stripeClient = new StripeClient("", { apiVersion: "2022-11-15" });

    try {
      const event = await stripeClient.webhooks.constructEventAsync(rawBody, signature, source.secret);

      return {
        events: [
          {
            id: event.id,
            payload: event.data.object,
            source: "stripe.com",
            name: event.type,
            timestamp: new Date(event.created * 1000),
            context: {
              apiVersion: event.api_version,
              livemode: event.livemode,
              request: event.request,
              previousAttributes: event.data.previous_attributes,
            },
          },
        ],
      };
    } catch (error) {
      if (error instanceof Error) {
        logger.error("[@trigger.dev/stripe] Error while validating webhook signature", {
          error: { name: error.name, message: error.message },
        });
      } else {
        logger.error("[@trigger.dev/stripe] Unknown Error while validating webhook signature");
      }

      return { events: [] };
    }
  }

  return {
    events: [],
  };
}