import { SchedulingType } from "@prisma/client"; import { stringify } from "querystring"; import { useEffect, useState } from "react"; import type { CurrentSeats } from "@calcom/core/getUserAvailability"; import dayjs, { Dayjs } from "@calcom/dayjs"; import getSlots from "@lib/slots"; import type { TimeRange, WorkingHours } from "@lib/types/schedule"; type AvailabilityUserResponse = { busy: TimeRange[]; timeZone: string; workingHours: WorkingHours[]; currentSeats?: CurrentSeats; }; type Slot = { time: Dayjs; users?: string[]; bookingUid?: string; attendees?: number; }; type UseSlotsProps = { slotInterval: number | null; eventLength: number; eventTypeId: number; minimumBookingNotice?: number; date: Dayjs; users: { username: string | null }[]; schedulingType: SchedulingType | null; beforeBufferTime?: number; afterBufferTime?: number; }; type getFilteredTimesProps = { times: dayjs.Dayjs[]; busy: TimeRange[]; eventLength: number; beforeBufferTime: number; afterBufferTime: number; currentSeats?: CurrentSeats; }; export const getFilteredTimes = (props: getFilteredTimesProps) => { const { times, busy, eventLength, beforeBufferTime, afterBufferTime, currentSeats } = props; const finalizationTime = times[times.length - 1]?.add(eventLength, "minutes"); // Check for conflicts for (let i = times.length - 1; i >= 0; i -= 1) { // const totalSlotLength = eventLength + beforeBufferTime + afterBufferTime; // Check if the slot surpasses the user's availability end time const slotEndTimeWithAfterBuffer = times[i].add(eventLength + afterBufferTime, "minutes"); if (slotEndTimeWithAfterBuffer.isAfter(finalizationTime, "minute")) { times.splice(i, 1); } else { const slotStartTime = times[i]; const slotEndTime = times[i].add(eventLength, "minutes"); const slotStartTimeWithBeforeBuffer = times[i].subtract(beforeBufferTime, "minutes"); // If the event has seats then see if there is already a booking (want to show full bookings as well) if (currentSeats?.some((booking) => booking.startTime === slotStartTime.toDate())) { break; } busy.every((busyTime): boolean => { const startTime = dayjs(busyTime.start); const endTime = dayjs(busyTime.end); // Check if start times are the same if (slotStartTime.isBetween(startTime, endTime, null, "[)")) { times.splice(i, 1); } // Check if slot end time is between start and end time else if (slotEndTime.isBetween(startTime, endTime)) { times.splice(i, 1); } // Check if startTime is between slot else if (startTime.isBetween(slotStartTime, slotEndTime)) { times.splice(i, 1); } // Check if timeslot has before buffer time space free else if ( slotStartTimeWithBeforeBuffer.isBetween( startTime.subtract(beforeBufferTime, "minutes"), endTime.add(afterBufferTime, "minutes") ) ) { times.splice(i, 1); } // Check if timeslot has after buffer time space free else if ( slotEndTimeWithAfterBuffer.isBetween( startTime.subtract(beforeBufferTime, "minutes"), endTime.add(afterBufferTime, "minutes") ) ) { times.splice(i, 1); } else { return true; } return false; }); } } return times; }; export const useSlots = (props: UseSlotsProps) => { const { slotInterval, eventLength, minimumBookingNotice = 0, beforeBufferTime = 0, afterBufferTime = 0, date, users, eventTypeId, } = props; const [slots, setSlots] = useState([]); const [loading, setLoading] = useState(false); const [error, setError] = useState(null); useEffect(() => { setSlots([]); setLoading(true); setError(null); const dateFrom = date.startOf("day").format(); const dateTo = date.endOf("day").format(); const query = stringify({ dateFrom, dateTo, eventTypeId }); const handleAvailableSlots = async (res: Response) => { const responseBody: AvailabilityUserResponse = await res.json(); const { workingHours, busy, currentSeats } = responseBody; const times = getSlots({ frequency: slotInterval || eventLength, inviteeDate: date, workingHours, minimumBookingNotice, eventLength, }); const filterTimeProps = { times, busy, eventLength, beforeBufferTime, afterBufferTime, currentSeats, }; const filteredTimes = getFilteredTimes(filterTimeProps); // temporary const user = res.url.substring(res.url.lastIndexOf("/") + 1, res.url.indexOf("?")); return filteredTimes.map((time) => ({ time, users: [user], // Conditionally add the attendees and booking id to slots object if there is already a booking during that time ...(currentSeats?.some((booking) => booking.startTime === time.toDate()) && { attendees: currentSeats[currentSeats.findIndex((booking) => booking.startTime === time.toDate())]._count .attendees, bookingUid: currentSeats[currentSeats.findIndex((booking) => booking.startTime === time.toDate())].uid, }), })); }; Promise.all( users.map((user) => fetch(`/api/availability/${user.username}?${query}`).then(handleAvailableSlots)) ) .then((results) => { let loadedSlots: Slot[] = results[0] || []; if (results.length === 1) { loadedSlots = loadedSlots?.sort((a, b) => (a.time.isAfter(b.time) ? 1 : -1)); setSlots(loadedSlots); setLoading(false); return; } let poolingMethod; switch (props.schedulingType) { // intersect by time, does not take into account eventLength (yet) case SchedulingType.COLLECTIVE: poolingMethod = (slots: Slot[], compareWith: Slot[]) => slots.filter((slot) => compareWith.some((compare) => compare.time.isSame(slot.time))); break; case SchedulingType.ROUND_ROBIN: // TODO: Create a Reservation (lock this slot for X minutes) // this will make the following code redundant poolingMethod = (slots: Slot[], compareWith: Slot[]) => { compareWith.forEach((compare) => { const match = slots.findIndex((slot) => slot.time.isSame(compare.time)); if (match !== -1) { slots[match].users?.push(compare.users![0]); } else { slots.push(compare); } }); return slots; }; break; } if (!poolingMethod) { throw Error(`No poolingMethod found for schedulingType: "${props.schedulingType}""`); } for (let i = 1; i < results.length; i++) { loadedSlots = poolingMethod(loadedSlots, results[i]); } loadedSlots = loadedSlots.sort((a, b) => (a.time.isAfter(b.time) ? 1 : -1)); setSlots(loadedSlots); setLoading(false); }) .catch((e) => { console.error(e); setError(e); }); }, [ afterBufferTime, beforeBufferTime, eventLength, minimumBookingNotice, slotInterval, eventTypeId, props.schedulingType, users, date, ]); return { slots, loading, error, }; }; export default useSlots;