[NEW] Video Conference Model / Collection

apps/meteor/app/api/server/v1/videoConference.ts

@@ -29,23 +29,21 @@ API.v1.addRoute(
 
 API.v1.addRoute(
 	'video-conference.start',
-	{ authRequired: true },
+	{ authRequired: true, validateParams: isVideoConfStartProps },
 	{
 		async post() {
-			if (!isVideoConfStartProps(this.bodyParams)) {
-				return API.v1.failure('invalid-params', isVideoConfStartProps.errors?.map((e) => e.message).join('\n '));
-			}
+			const { roomId } = this.bodyParams;
 
 			// #ToDo: Validate if there is an active provider
 
 			const { userId } = this;
 
-			if (!userId || !(await canAccessRoomIdAsync(this.bodyParams.roomId, userId))) {
+			if (!userId || !(await canAccessRoomIdAsync(roomId, userId))) {
 				return API.v1.failure('invalid-params');
 			}
 
 			return API.v1.success({
-				data: await startVideoConference(userId, this.bodyParams.roomId),
+				data: await startVideoConference(userId, roomId),
 			});
 		},
 	},

apps/meteor/app/models/server/raw/VideoConference.ts

@@ -0,0 +1,9 @@
+import { IVideoConference } from '@rocket.chat/core-typings';
+
+import { BaseRaw, IndexSpecification } from './BaseRaw';
+
+export class VideoConferenceRaw extends BaseRaw<IVideoConference> {
+	protected modelIndexes(): IndexSpecification[] {
+		return [{ key: { rid: 1, status: 1, createdAt: 1 }, unique: false }];
+	}
+}

apps/meteor/app/models/server/raw/index.ts

@@ -68,6 +68,7 @@ import SubscriptionsModel from '../models/Subscriptions';
 import UsersModel from '../models/Users';
 import { PbxEventsRaw } from './PbxEvents';
 import { isRunningMs } from '../../../../server/lib/isRunningMs';
+import { VideoConferenceRaw } from './VideoConference';
 
 const trashCollection = trash.rawCollection();
 
@@ -144,6 +145,7 @@ export const WebdavAccounts = new WebdavAccountsRaw(db.collection(`${prefix}webd
 export const VoipRoom = new VoipRoomsRaw(db.collection(`${prefix}room`), trashCollection);
 export const PbxEvent = new PbxEventsRaw(db.collection('pbx_events'), trashCollection);
 export const LivechatAgentActivity = new LivechatAgentActivityRaw(db.collection(`${prefix}livechat_agent_activity`), trashCollection);
+export const VideoConference = new VideoConferenceRaw(db.collection(`${prefix}video_conference`), trashCollection);
 
 const map = {
 	[Messages.col.collectionName]: MessagesModel,

packages/core-typings/src/IVideoConference.ts

@@ -1,5 +1,6 @@
 import type { IRocketChatRecord } from './IRocketChatRecord';
 import type { IUser } from './IUser';
+import type { IMessage } from './IMessage';
 
 export type DirectCallInstructions = {
 	type: 'direct';
@@ -13,14 +14,36 @@ export type ConferenceInstructions = {
 };
 
 export type VideoConferenceType = DirectCallInstructions['type'] | ConferenceInstructions['type'];
+export interface IVideoConferenceUser extends Required<Pick<IUser, '_id' | 'username' | 'name'>> {
+	ts: Date;
+}
+
+export enum VideoConferenceStatus {
+	CALLING = 0,
+	STARTED = 1,
+	ENDED = 2,
+}
 
 export interface IVideoConference extends IRocketChatRecord {
 	type: VideoConferenceType;
-	users: Pick<IUser, '_id' | 'username' | 'name'>[];
+	users: IVideoConferenceUser[];
 	rid: string;
+	anonymousUsers: number;
+	title: string;
+	messages: {
+		calling?: IMessage['_id'];
+		missed?: IMessage['_id'];
+		started?: IMessage['_id'];
+		ended?: IMessage['_id'];
+	};
+	status: VideoConferenceStatus;
+	url?: string;
+
+	createdBy: Required<Pick<IUser, '_id' | 'username' | 'name'>>;
+	createdAt: Date;
 
-	_createdBy: Pick<IUser, '_id' | 'username' | 'name'>;
-	_createdAt: Date;
+	endedBy?: Required<Pick<IUser, '_id' | 'username' | 'name'>>;
+	endedAt?: Date;
 }
 
 export type VideoConferenceInstructions = DirectCallInstructions | ConferenceInstructions;