cal.pub0.org/packages/app-store/zapier/api/subscriptions/addSubscription.ts

import type { NextApiRequest, NextApiResponse } from "next";
import { v4 } from "uuid";

import { scheduleTrigger } from "@calcom/app-store/zapier/lib/nodeScheduler";
import findValidApiKey from "@calcom/features/ee/api-keys/lib/findValidApiKey";
import { defaultHandler, defaultResponder } from "@calcom/lib/server";
import prisma from "@calcom/prisma";
import { BookingStatus, WebhookTriggerEvents } from "@calcom/prisma/enums";

async function handler(req: NextApiRequest, res: NextApiResponse) {
  const apiKey = req.query.apiKey as string;

  if (!apiKey) {
    return res.status(401).json({ message: "No API key provided" });
  }

  const validKey = await findValidApiKey(apiKey, "zapier");

  if (!validKey) {
    return res.status(401).json({ message: "API key not valid" });
  }

  const { subscriberUrl, triggerEvent } = req.body;

  try {
    const createSubscription = await prisma.webhook.create({
      data: {
        id: v4(),
        userId: validKey.userId,
        eventTriggers: [triggerEvent],
        subscriberUrl,
        active: true,
        appId: "zapier",
      },
    });

    if (triggerEvent === WebhookTriggerEvents.MEETING_ENDED) {
      //schedule job for already existing bookings
      const bookings = await prisma.booking.findMany({
        where: {
          userId: validKey.userId,
          startTime: {
            gte: new Date(),
          },
          status: BookingStatus.ACCEPTED,
        },
      });

      for (const booking of bookings) {
        scheduleTrigger(booking, createSubscription.subscriberUrl, {
          id: createSubscription.id,
          appId: createSubscription.appId,
        });
      }
    }
    res.status(200).json(createSubscription);
  } catch (error) {
    return res.status(500).json({ message: "Could not create subscription." });
  }
}

export default defaultHandler({
  POST: Promise.resolve({ default: defaultResponder(handler) }),
});