fix: Workflow action 'email to host' only sends to one host of team e…

packages/features/bookings/lib/handleConfirmation.ts

@@ -14,6 +14,7 @@ import { getTeamIdFromEventType } from "@calcom/lib/getTeamIdFromEventType";
 import logger from "@calcom/lib/logger";
 import { safeStringify } from "@calcom/lib/safeStringify";
 import type { PrismaClient } from "@calcom/prisma";
+import type { SchedulingType } from "@calcom/prisma/enums";
 import { BookingStatus, WebhookTriggerEvents } from "@calcom/prisma/enums";
 import { EventTypeMetaDataSchema } from "@calcom/prisma/zod-utils";
 import type { AdditionalInformation, CalendarEvent } from "@calcom/types/Calendar";
@@ -129,6 +130,7 @@ export async function handleConfirmation(args: {
     eventType: {
       bookingFields: Prisma.JsonValue | null;
       slug: string;
+      schedulingType: SchedulingType | null;
       owner: {
         hideBranding?: boolean | null;
       } | null;
@@ -174,6 +176,7 @@ export async function handleConfirmation(args: {
             select: {
               slug: true,
               bookingFields: true,
+              schedulingType: true,
               owner: {
                 select: {
                   hideBranding: true,
@@ -228,6 +231,7 @@ export async function handleConfirmation(args: {
           select: {
             slug: true,
             bookingFields: true,
+            schedulingType: true,
             owner: {
               select: {
                 hideBranding: true,
@@ -266,7 +270,10 @@ export async function handleConfirmation(args: {
       const evtOfBooking = {
         ...evt,
         metadata: { videoCallUrl: meetingUrl },
-        eventType: { slug: eventTypeSlug },
+        eventType: {
+          slug: eventTypeSlug,
+          schedulingType: updatedBookings[index].eventType?.schedulingType,
+        },
       };
       evtOfBooking.startTime = updatedBookings[index].startTime.toISOString();
       evtOfBooking.endTime = updatedBookings[index].endTime.toISOString();

packages/features/bookings/lib/handleNewBooking.ts

@@ -2368,7 +2368,11 @@ async function handler(
     loggerWithEventDetails.error("Error while creating booking references", JSON.stringify({ error }));
   }
 
-  const evtWithMetadata = { ...evt, metadata, eventType: { slug: eventType.slug } };
+  const evtWithMetadata = {
+    ...evt,
+    metadata,
+    eventType: { slug: eventType.slug, schedulingType: eventType.schedulingType },
+  };
 
   await scheduleMandatoryReminder(
     evtWithMetadata,

packages/features/bookings/lib/handleNewBooking/test/workflow-notifications.test.ts

@@ -391,8 +391,7 @@ describe("handleNewBooking", () => {
         });
 
         expectWorkflowToBeTriggered({
-          // emailsToReceive: [organizer.email].concat(otherTeamMembers.map(member => member.email)),
-          emailsToReceive: [organizer.email],
+          emailsToReceive: [organizer.email].concat(otherTeamMembers.map((member) => member.email)),
           emails,
         });
       },

packages/features/bookings/lib/handleSeats/handleSeats.ts

@@ -103,7 +103,16 @@ const handleSeats = async (newSeatedBookingObject: NewSeatedBookingObject) => {
       await scheduleWorkflowReminders({
         workflows: eventType.workflows,
         smsReminderNumber: smsReminderNumber || null,
-        calendarEvent: { ...evt, ...{ metadata, eventType: { slug: eventType.slug } } },
+        calendarEvent: {
+          ...evt,
+          ...{
+            metadata,
+            eventType: {
+              slug: eventType.slug,
+              schedulingType: eventType.schedulingType,
+            },
+          },
+        },
         isNotConfirmed: evt.requiresConfirmation || false,
         isRescheduleEvent: !!rescheduleUid,
         isFirstRecurringEvent: true,

packages/features/ee/workflows/api/scheduleEmailReminders.ts

@@ -9,7 +9,7 @@ import logger from "@calcom/lib/logger";
 import { defaultHandler } from "@calcom/lib/server";
 import { getTimeFormatStringFromUserTimeFormat } from "@calcom/lib/timeFormat";
 import prisma from "@calcom/prisma";
-import { WorkflowActions, WorkflowMethods, WorkflowTemplates } from "@calcom/prisma/enums";
+import { SchedulingType, WorkflowActions, WorkflowMethods, WorkflowTemplates } from "@calcom/prisma/enums";
 import { bookingMetadataSchema } from "@calcom/prisma/zod-utils";
 
 import type { PartialWorkflowReminder } from "../lib/getWorkflowReminders";
@@ -119,6 +119,19 @@ async function handler(req: NextApiRequest, res: NextApiResponse) {
         switch (reminder.workflowStep.action) {
           case WorkflowActions.EMAIL_HOST:
             sendTo = reminder.booking?.userPrimaryEmail ?? reminder.booking.user?.email;
+            const hosts = reminder.booking.attendees
+              .filter((attendee) =>
+                reminder.booking?.eventType?.hosts?.some((host) => host.user.email === attendee.email)
+              )
+              .map((host) => host.email);
+            const schedulingType = reminder.booking.eventType?.schedulingType;
+
+            if (
+              hosts &&
+              (schedulingType === SchedulingType.COLLECTIVE || schedulingType === SchedulingType.ROUND_ROBIN)
+            ) {
+              sendTo = sendTo ? [sendTo, ...hosts] : hosts;
+            }
             break;
           case WorkflowActions.EMAIL_ATTENDEE:
             sendTo = reminder.booking.attendees[0].email;

packages/features/ee/workflows/lib/getWorkflowReminders.ts

@@ -27,7 +27,14 @@ type PartialBooking =
       | "attendees"
       | "userPrimaryEmail"
       | "smsReminderNumber"
-    > & { eventType: (Partial<EventType> & { team: { parentId?: number } }) | null } & {
+    > & {
+      eventType:
+        | (Partial<EventType> & {
+            team: { parentId?: number };
+            hosts: { user: { email: string } }[] | undefined;
+          })
+        | null;
+    } & {
       user: Partial<User> | null;
     })
   | null;
@@ -159,6 +166,15 @@ export const select: Prisma.WorkflowReminderSelect = {
           bookingFields: true,
           title: true,
           slug: true,
+          hosts: {
+            select: {
+              user: {
+                select: {
+                  email: true,
+                },
+              },
+            },
+          },
           recurringEvent: true,
           team: {
             select: {

packages/features/ee/workflows/lib/reminders/reminderScheduler.ts

@@ -7,6 +7,7 @@ import {
 } from "@calcom/features/ee/workflows/lib/actionHelperFunctions";
 import { checkSMSRateLimit } from "@calcom/lib/checkRateLimitAndThrowError";
 import { SENDER_NAME } from "@calcom/lib/constants";
+import { SchedulingType } from "@calcom/prisma/enums";
 import { WorkflowActions, WorkflowMethods, WorkflowTriggerEvents } from "@calcom/prisma/enums";
 import type { CalendarEvent } from "@calcom/types/Calendar";
 
@@ -17,7 +18,11 @@ import { deleteScheduledWhatsappReminder, scheduleWhatsappReminder } from "./wha
 
 type ExtendedCalendarEvent = CalendarEvent & {
   metadata?: { videoCallUrl: string | undefined };
-  eventType: { slug?: string };
+  eventType: {
+    slug?: string;
+    schedulingType?: SchedulingType | null;
+    hosts?: { user: { email: string } }[];
+  };
 };
 
 type ProcessWorkflowStepParams = {
@@ -90,6 +95,13 @@ const processWorkflowStep = async (
         break;
       case WorkflowActions.EMAIL_HOST:
         sendTo = [evt.organizer?.email || ""];
+
+        const schedulingType = evt.eventType.schedulingType;
+        const isTeamEvent =
+          schedulingType === SchedulingType.ROUND_ROBIN || schedulingType === SchedulingType.COLLECTIVE;
+        if (isTeamEvent && evt.team?.members) {
+          sendTo = sendTo.concat(evt.team.members.map((member) => member.email));
+        }
         break;
       case WorkflowActions.EMAIL_ATTENDEE:
         const attendees = !!emailAttendeeSendToOverride

packages/trpc/server/routers/viewer/workflows/activateEventType.handler.ts

@@ -13,7 +13,7 @@ import {
 import { getTimeFormatStringFromUserTimeFormat } from "@calcom/lib/timeFormat";
 import { prisma } from "@calcom/prisma";
 import { BookingStatus } from "@calcom/prisma/client";
-import { MembershipRole, WorkflowActions, WorkflowMethods } from "@calcom/prisma/enums";
+import { MembershipRole, SchedulingType, WorkflowActions, WorkflowMethods } from "@calcom/prisma/enums";
 import type { TrpcSessionUser } from "@calcom/trpc/server/trpc";
 
 import { TRPCError } from "@trpc/server";
@@ -149,7 +149,21 @@ export const activateEventTypeHandler = async ({ ctx, input }: ActivateEventType
       },
       include: {
         attendees: true,
-        eventType: true,
+        eventType: {
+          select: {
+            schedulingType: true,
+            slug: true,
+            hosts: {
+              select: {
+                user: {
+                  select: {
+                    email: true,
+                  },
+                },
+              },
+            },
+          },
+        },
         user: true,
       },
     });
@@ -181,6 +195,8 @@ export const activateEventTypeHandler = async ({ ctx, input }: ActivateEventType
         language: { locale: booking?.user?.locale || defaultLocale },
         eventType: {
           slug: booking.eventType?.slug,
+          schedulingType: booking.eventType?.schedulingType,
+          hosts: booking.eventType?.hosts,
         },
       };
       for (const step of eventTypeWorkflow.steps) {
@@ -194,6 +210,19 @@ export const activateEventTypeHandler = async ({ ctx, input }: ActivateEventType
           switch (step.action) {
             case WorkflowActions.EMAIL_HOST:
               sendTo = [bookingInfo.organizer?.email];
+              const schedulingType = bookingInfo.eventType?.schedulingType;
+              const hosts = bookingInfo.attendees
+                .filter((attendee) =>
+                  bookingInfo.eventType.hosts?.some((host) => host.user.email === attendee.email)
+                )
+                .map((host) => host.email);
+              if (
+                (schedulingType === SchedulingType.ROUND_ROBIN ||
+                  schedulingType === SchedulingType.COLLECTIVE) &&
+                hosts
+              ) {
+                sendTo = sendTo.concat(hosts);
+              }
               break;
             case WorkflowActions.EMAIL_ATTENDEE:
               sendTo = bookingInfo.attendees.map((attendee) => attendee.email);