import { Credential } from "@prisma/client"; import short from "short-uuid"; import { v5 as uuidv5 } from "uuid"; import { getUid } from "@lib/CalEventParser"; import { EventResult } from "@lib/events/EventManager"; import { PartialReference } from "@lib/events/EventManager"; import logger from "@lib/logger"; import { CalendarEvent } from "./calendarClient"; import DailyVideoApiAdapter from "./integrations/Daily/DailyVideoApiAdapter"; import ZoomVideoApiAdapter from "./integrations/Zoom/ZoomVideoApiAdapter"; import { Ensure } from "./types/utils"; const log = logger.getChildLogger({ prefix: ["[lib] videoClient"] }); const translator = short(); export interface VideoCallData { type: string; id: string; password: string; url: string; } type EventBusyDate = Record<"start" | "end", Date>; export interface VideoApiAdapter { createMeeting(event: CalendarEvent): Promise; updateMeeting(bookingRef: PartialReference, event: CalendarEvent): Promise; deleteMeeting(uid: string): Promise; getAvailability(dateFrom?: string, dateTo?: string): Promise; } // factory const getVideoAdapters = (withCredentials: Credential[]): VideoApiAdapter[] => withCredentials.reduce((acc, cred) => { switch (cred.type) { case "zoom_video": acc.push(ZoomVideoApiAdapter(cred)); break; case "daily_video": acc.push(DailyVideoApiAdapter(cred)); break; default: break; } return acc; }, []); const getBusyVideoTimes = (withCredentials: Credential[]) => Promise.all(getVideoAdapters(withCredentials).map((c) => c.getAvailability())).then((results) => results.reduce((acc, availability) => acc.concat(availability), []) ); const createMeeting = async ( credential: Credential, calEvent: Ensure ): Promise => { const uid: string = getUid(calEvent); if (!credential) { throw new Error( "Credentials must be set! Video platforms are optional, so this method shouldn't even be called when no video credentials are set." ); } let success = true; const videoAdapters = getVideoAdapters([credential]); const [firstVideoAdapter] = videoAdapters; const createdMeeting = await firstVideoAdapter.createMeeting(calEvent).catch((e) => { log.error("createMeeting failed", e, calEvent); success = false; }); if (!createdMeeting) { return { type: credential.type, success, uid, originalEvent: calEvent, }; } return { type: credential.type, success, uid, createdEvent: createdMeeting, originalEvent: calEvent, }; }; const updateMeeting = async ( credential: Credential, calEvent: CalendarEvent, bookingRef: PartialReference | null ): Promise => { const uid = translator.fromUUID(uuidv5(JSON.stringify(calEvent), uuidv5.URL)); let success = true; const [firstVideoAdapter] = getVideoAdapters([credential]); const updatedMeeting = credential && bookingRef ? await firstVideoAdapter.updateMeeting(bookingRef, calEvent).catch((e) => { log.error("updateMeeting failed", e, calEvent); success = false; return undefined; }) : undefined; if (!updatedMeeting) { return { type: credential.type, success, uid, originalEvent: calEvent, }; } return { type: credential.type, success, uid, updatedEvent: updatedMeeting, originalEvent: calEvent, }; }; const deleteMeeting = (credential: Credential, uid: string): Promise => { if (credential) { return getVideoAdapters([credential])[0].deleteMeeting(uid); } return Promise.resolve({}); }; export { getBusyVideoTimes, createMeeting, updateMeeting, deleteMeeting };