61 lines
2.5 KiB
TypeScript
61 lines
2.5 KiB
TypeScript
import { SchedulingType } from "@calcom/prisma/enums";
|
|
import type { WorkingHours } from "@calcom/types/schedule";
|
|
|
|
/**
|
|
* This function gets team members working hours and busy slots,
|
|
* offsets them to UTC and intersects them for collective events.
|
|
**/
|
|
export const getAggregateWorkingHours = (
|
|
usersWorkingHoursAndBusySlots: (Omit<
|
|
Awaited<ReturnType<Awaited<typeof import("./getUserAvailability")>["getUserAvailability"]>>,
|
|
"currentSeats" | "dateRanges"
|
|
> & { user?: { isFixed?: boolean } })[],
|
|
// eslint-disable-next-line @typescript-eslint/no-unused-vars
|
|
schedulingType: SchedulingType | null
|
|
): WorkingHours[] => {
|
|
// during personal events, just flatMap.
|
|
if (!schedulingType) {
|
|
return usersWorkingHoursAndBusySlots.flatMap((s) => s.workingHours);
|
|
}
|
|
const looseHostWorkingHours = usersWorkingHoursAndBusySlots
|
|
.filter(({ user }) => schedulingType !== SchedulingType.COLLECTIVE && user?.isFixed !== true)
|
|
.flatMap((s) => s.workingHours);
|
|
|
|
const fixedHostSchedules = usersWorkingHoursAndBusySlots.filter(
|
|
({ user }) => schedulingType === SchedulingType.COLLECTIVE || user?.isFixed
|
|
);
|
|
// return early when there are no fixed hosts.
|
|
if (!fixedHostSchedules.length) {
|
|
return looseHostWorkingHours;
|
|
}
|
|
return fixedHostSchedules.reduce((currentWorkingHours: WorkingHours[], s) => {
|
|
const updatedWorkingHours: typeof currentWorkingHours = [];
|
|
|
|
s.workingHours.forEach((workingHour) => {
|
|
const sameDayWorkingHours = currentWorkingHours.filter((compare) =>
|
|
compare.days.find((day) => workingHour.days.includes(day))
|
|
);
|
|
if (!sameDayWorkingHours.length) {
|
|
updatedWorkingHours.push(workingHour); // the first day is always added.
|
|
return;
|
|
}
|
|
// days are overlapping when different users are involved, instead of adding we now need to subtract
|
|
updatedWorkingHours.push(
|
|
...sameDayWorkingHours.map((compare) => {
|
|
const intersect = workingHour.days.filter((day) => compare.days.includes(day));
|
|
const retVal: WorkingHours & { userId?: number | null } = {
|
|
days: intersect,
|
|
startTime: Math.max(workingHour.startTime, compare.startTime),
|
|
endTime: Math.min(workingHour.endTime, compare.endTime),
|
|
};
|
|
if (schedulingType !== SchedulingType.COLLECTIVE) {
|
|
retVal.userId = compare.userId;
|
|
}
|
|
return retVal;
|
|
})
|
|
);
|
|
});
|
|
return updatedWorkingHours;
|
|
}, looseHostWorkingHours);
|
|
};
|