Webhooks

import express from "express";
import { EasyWebhooks } from "@easylabs/node";
import { EasyApiError } from "@easylabs/common";

const app = express();

app.post(
  "/webhooks/easy",
  express.raw({ type: "application/json" }),
  (req, res) => {
    try {
      const event = EasyWebhooks.constructEvent(
        req.body.toString("utf8"),
        req.header("x-easy-webhook-signature") ?? "",
        process.env.EASY_WEBHOOK_SECRET!,
      );

      // event.type is one of EASY_EVENT_TYPES, e.g. "payment.created"
      console.log(event.id, event.type);

      res.status(204).end();
    } catch (err) {
      if (err instanceof EasyApiError) return res.status(400).end();
      throw err;
    }
  },
);

import Fastify from "fastify";
import { EasyWebhooks } from "@easylabs/node";
import { EasyApiError } from "@easylabs/common";

const app = Fastify();

// Capture the raw body for the webhook route
app.addContentTypeParser(
  "application/json",
  { parseAs: "string" },
  (_req, body, done) => done(null, body),
);

app.post("/webhooks/easy", async (req, reply) => {
  try {
    const event = EasyWebhooks.constructEvent(
      req.body as string,
      (req.headers["x-easy-webhook-signature"] as string) ?? "",
      process.env.EASY_WEBHOOK_SECRET!,
    );
    // ...handle event...
    return reply.code(204).send();
  } catch (err) {
    // Signature failures throw EasyApiError(status: 400) — surface that
    // to the dispatcher instead of letting Fastify return a 500.
    if (err instanceof EasyApiError) return reply.code(400).send();
    throw err;
  }
});

// app/api/webhooks/easy/route.ts
import { EasyWebhooks } from "@easylabs/node";
import { EasyApiError } from "@easylabs/common";

export async function POST(req: Request) {
  const rawBody = await req.text();
  try {
    const event = EasyWebhooks.constructEvent(
      rawBody,
      req.headers.get("x-easy-webhook-signature") ?? "",
      process.env.EASY_WEBHOOK_SECRET!,
    );
    // ...handle event...
    return new Response(null, { status: 204 });
  } catch (err) {
    if (err instanceof EasyApiError) return new Response(null, { status: 400 });
    throw err;
  }
}