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

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

export default async function handler(
  req: NextApiRequest,
  res: NextApiResponse
) {
  try {
    const requestBody = WebhookEventBodySchema.parse(req.body);

    switch (requestBody.type) {
      case WebhookEvents.USER_CREATED:
        await onUserCreatedHandler(requestBody.data.id, res);
        return;

      case WebhookEvents.USER_DELETED:
        await onUserDeletedHandler(requestBody.data.id, res);
        return;

      default:
        res.status(400).json({ error: "INVALID WEBHOOK EVENT TYPE" });
        return;
    }
  } catch {
    res.status(400).json({ error: "INVALID WEBHOOK EVENT BODY" });
    return;
  }
}