From d569296654495621b0475a4636fa9ac937cccd56 Mon Sep 17 00:00:00 2001
From: Syed Ali Shahbaz <52925846+alishaz-polymath@users.noreply.github.com>
Date: Thu, 9 Jun 2022 17:09:20 +0530
Subject: [PATCH] Add webhook trigger --init

---
 pages/api/bookings/index.ts | 26 +++++++++++++++++++++++++-
 1 file changed, 25 insertions(+), 1 deletion(-)

diff --git a/pages/api/bookings/index.ts b/pages/api/bookings/index.ts
index 40f24283ee..1951e4475d 100644
--- a/pages/api/bookings/index.ts
+++ b/pages/api/bookings/index.ts
@@ -81,7 +81,31 @@ async function createOrlistAllBookings(
     const data = await prisma.booking.create({ data: { ...safe.data } });
     const booking = schemaBookingReadPublic.parse(data);
 
-    if (booking) res.status(201).json({ booking, message: "Booking created successfully" });
+    if (booking) {
+      res.status(201).json({ booking, message: "Booking created successfully" });
+      
+      // Send Webhook call if hooked to BOOKING_CREATED & BOOKING_RESCHEDULED
+//       const eventTrigger: WebhookTriggerEvents = rescheduleUid ? "BOOKING_RESCHEDULED" : "BOOKING_CREATED";
+//       const subscriberOptions = {
+//         userId: user.id,
+//         eventTypeId,
+//         triggerEvent: eventTrigger,
+//       };
+      
+//       const subscribers = await getSubscribers(subscriberOptions);
+//       const bookingId = booking?.id;
+//       const promises = subscribers.map((sub) =>
+//         sendPayload(eventTrigger, new Date().toISOString(), sub, {
+//           ...evt,
+//           bookingId,
+//           rescheduleUid,
+//           metadata: reqBody.metadata,
+//         }).catch((e) => {
+//           console.error(`Error executing webhook for event: ${eventTrigger}, URL: ${sub.subscriberUrl}`, e);
+//         })
+//       );
+//       await Promise.all(promises);
+    } 
     else
       (error: Error) => {
         console.log(error);