pollo/src/pages/api/webhooks/index.ts

import { type NextRequest, NextResponse } from "next/server";
import {
  onUserCreatedHandler,
  onUserDeletedHandler,
} from "~/server/webhookHelpers";
import { WebhookEventBodySchema, WebhookEvents } from "~/utils/types";

export const config = {
  runtime: "edge",
  regions: ["pdx1"],
};

export default async function handler(req: NextRequest) {
  try {
    const requestBody = WebhookEventBodySchema.parse(await req.json());
    let success = false;

    switch (requestBody.type) {
      case WebhookEvents.USER_CREATED:
        success = await onUserCreatedHandler(requestBody.data.id);
        if (success) {
          return NextResponse.json(
            { result: "USER CREATED" },
            { status: 200, statusText: "USER CREATED" }
          );
        } else {
          return NextResponse.json(
            { result: "USER WITH THIS ID NOT FOUND" },
            { status: 404, statusText: "USER WITH THIS ID NOT FOUND" }
          );
        }

      case WebhookEvents.USER_DELETED:
        success = await onUserDeletedHandler(requestBody.data.id);

        return NextResponse.json(
          { result: "USER DELETED" },
          { status: 200, statusText: "USER DELETED" }
        );

      default:
        return NextResponse.json(
          { result: "INVALID WEBHOOK EVENT TYPE" },
          { status: 400, statusText: "INVALID WEBHOOK EVENT TYPE" }
        );
    }
  } catch {
    return NextResponse.json(
      { result: "INVALID WEBHOOK EVENT BODY" },
      { status: 400, statusText: "INVALID WEBHOOK EVENT BODY" }
    );
  }
}