import dayjs from "@calcom/dayjs"; import prisma from "@calcom/prisma"; import { BookingStatus } from "@calcom/prisma/enums"; import type { IntervalLimit } from "@calcom/types/Calendar"; import { getErrorFromUnknown } from "../errors"; import { HttpError } from "../http-error"; import { ascendingLimitKeys, intervalLimitKeyToUnit } from "../intervalLimit"; import { parseBookingLimit } from "../isBookingLimits"; export async function checkBookingLimits( bookingLimits: IntervalLimit, eventStartDate: Date, eventId: number ) { const parsedBookingLimits = parseBookingLimit(bookingLimits); if (!parsedBookingLimits) return false; // not iterating entries to preserve types const limitCalculations = ascendingLimitKeys.map((key) => checkBookingLimit({ key, limitingNumber: parsedBookingLimits[key], eventStartDate, eventId }) ); try { return !!(await Promise.all(limitCalculations)); } catch (error) { throw new HttpError({ message: getErrorFromUnknown(error).message, statusCode: 401 }); } } export async function checkBookingLimit({ eventStartDate, eventId, key, limitingNumber, }: { eventStartDate: Date; eventId: number; key: keyof IntervalLimit; limitingNumber: number | undefined; }) { { if (!limitingNumber) return; const unit = intervalLimitKeyToUnit(key); const startDate = dayjs(eventStartDate).startOf(unit).toDate(); const endDate = dayjs(eventStartDate).endOf(unit).toDate(); const bookingsInPeriod = await prisma.booking.count({ where: { status: BookingStatus.ACCEPTED, eventTypeId: eventId, // FIXME: bookings that overlap on one side will never be counted startTime: { gte: startDate, }, endTime: { lte: endDate, }, }, }); if (bookingsInPeriod < limitingNumber) return; throw new HttpError({ message: `booking_limit_reached`, statusCode: 403, }); } }