import { Credential } from "@prisma/client"; import short from "short-uuid"; import { v5 as uuidv5 } from "uuid"; import appStore from "@calcom/app-store"; import { sendBrokenIntegrationEmail } from "@calcom/emails"; import { getUid } from "@calcom/lib/CalEventParser"; import logger from "@calcom/lib/logger"; import type { CalendarEvent, EventBusyDate } from "@calcom/types/Calendar"; import type { EventResult, PartialReference } from "@calcom/types/EventManager"; import type { VideoApiAdapter, VideoApiAdapterFactory, VideoCallData } from "@calcom/types/VideoApiAdapter"; const log = logger.getChildLogger({ prefix: ["[lib] videoClient"] }); const translator = short(); // factory const getVideoAdapters = (withCredentials: Credential[]): VideoApiAdapter[] => withCredentials.reduce((acc, cred) => { const appName = cred.type.split("_").join(""); // Transform `zoom_video` to `zoomvideo`; const app = appStore[appName as keyof typeof appStore]; if (app && "lib" in app && "VideoApiAdapter" in app.lib) { const makeVideoApiAdapter = app.lib.VideoApiAdapter as VideoApiAdapterFactory; const videoAdapter = makeVideoApiAdapter(cred); acc.push(videoAdapter); return acc; } return acc; }, []); const getBusyVideoTimes = (withCredentials: Credential[]) => Promise.all(getVideoAdapters(withCredentials).map((c) => c?.getAvailability())).then((results) => results.reduce((acc, availability) => acc.concat(availability), [] as (EventBusyDate | undefined)[]) ); const createMeeting = async (credential: Credential, calEvent: CalendarEvent) => { 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." ); } const videoAdapters = getVideoAdapters([credential]); const [firstVideoAdapter] = videoAdapters; const createdMeeting = await firstVideoAdapter?.createMeeting(calEvent).catch(async (e) => { await sendBrokenIntegrationEmail(calEvent, "video"); console.error("createMeeting failed", e, calEvent); }); if (!createdMeeting) { return { type: credential.type, success: false, uid, originalEvent: calEvent, }; } return { type: credential.type, success: true, 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(async (e) => { await sendBrokenIntegrationEmail(calEvent, "video"); 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) { const videoAdapter = getVideoAdapters([credential])[0]; // There are certain video apps with no video adapter defined. e.g. riverby,whereby if (videoAdapter) { return videoAdapter.deleteMeeting(uid); } } return Promise.resolve({}); }; export { getBusyVideoTimes, createMeeting, updateMeeting, deleteMeeting };