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

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

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

export default async function handler(req: NextRequest) {
  try {
    const eventBody = (await req.json()) as WebhookEventBody;
    console.log(eventBody);
    const { data, type } = WebhookEventBodySchema.parse(eventBody);
    let success = false;

    switch (type) {
      case WebhookEvents.USER_CREATED:
        success = await onUserCreatedHandler(
          data.id,
          `${data.first_name} ${data.last_name}`,
          data.email_addresses?.map((email) => email.email_address) || []
        );
        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(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 (error) {
    console.log(error);
    return NextResponse.json(
      { result: "INVALID WEBHOOK EVENT BODY" },
      { status: 400, statusText: "INVALID WEBHOOK EVENT BODY" }
    );
  }
}