cal.pub0.org/packages/app-store/zapier/lib/nodeScheduler.ts

import schedule from "node-schedule";

import prisma from "@calcom/prisma";

export async function scheduleTrigger(
  booking: { id: number; endTime: Date; scheduledJobs: string[] },
  subscriberUrl: string,
  subscriber: { id: string; appId: string | null }
) {
  //schedule job to call subscriber url at the end of meeting
  const job = schedule.scheduleJob(
    `${subscriber.appId}_${subscriber.id}`,
    booking.endTime,
    async function () {
      const body = JSON.stringify(booking);
      await fetch(subscriberUrl, {
        method: "POST",
        body,
      });

      //remove scheduled job from bookings once triggered
      const updatedScheduledJobs = booking.scheduledJobs.filter((scheduledJob) => {
        return scheduledJob !== `${subscriber.appId}_${subscriber.id}`;
      });

      await prisma.booking.update({
        where: {
          id: booking.id,
        },
        data: {
          scheduledJobs: updatedScheduledJobs,
        },
      });
    }
  );

  //add scheduled job name to booking
  await prisma.booking.update({
    where: {
      id: booking.id,
    },
    data: {
      scheduledJobs: {
        push: job.name,
      },
    },
  });
}

export async function cancelScheduledJobs(
  booking: { uid: string; scheduledJobs?: string[] },
  appId?: string | null
) {
  let scheduledJobs = booking.scheduledJobs || [];

  if (booking.scheduledJobs) {
    booking.scheduledJobs.forEach(async (scheduledJob) => {
      if (appId) {
        if (scheduledJob.startsWith(appId)) {
          if (schedule.scheduledJobs[scheduledJob]) {
            schedule.scheduledJobs[scheduledJob].cancel();
          }
          scheduledJobs = scheduledJobs?.filter((job) => scheduledJob !== job) || [];
        }
      } else {
        //if no specific appId given, delete all scheduled jobs of booking
        if (schedule.scheduledJobs[scheduledJob]) {
          schedule.scheduledJobs[scheduledJob].cancel();
        }
        scheduledJobs = [];
      }

      await prisma.booking.update({
        where: {
          uid: booking.uid,
        },
        data: {
          scheduledJobs: scheduledJobs,
        },
      });
    });
  }
}