Handling Stripe Webhooks in Elysia

import { type } from "arktype";

// Note: you dont specify your body in the schema!
const WebhookSchema = {
  headers: type({ "stripe-signature": "string" }),
};

export function stripeRoute({ sql, logger, stripeConfig }: StripeRouteParams) {
  const { stripe, webhookSecret } = stripeConfig;

  const webhookService = new Elysia().post(
    "/webhooks",
    async ({ request, headers, set }) => {
      // you have to do this!
      const body = await request.text();

      logger.debug("Received webhook request");

      const signature = headers["stripe-signature"];

      if (!signature) {
        logger.warn("Webhook received without Stripe signature");
        set.status = 400;
        return { error: "No signature provided" };
      }

      let event: Stripe.Event;
      try {
        event = await stripe.webhooks.constructEventAsync(body, signature, webhookSecret);
      } catch (err) {
        logger.error({ error: err }, "Webhook signature verification failed");
        set.status = 400;
        return {
          error: `Webhook Error: ${err instanceof Error ? err.message : "Unknown error"}`,
        };
      }

      logger.info({ eventType: event.type, eventId: event.id }, "Processing Stripe webhook event");

      try {
        /* handle your events here */
        set.status = 200;
        return { received: true };
      } catch (error) {
        logger.error(
          { error, eventType: event.type, eventId: event.id },
          "Error processing webhook",
        );
        set.status = 500;
        return { error: "Webhook processing failed" };
      }
    },
    WebhookSchema,
  );
}