chore: Implement base signaling system for media calls

apps/meteor/ee/server/configuration/voip.ts

@@ -1,10 +1,10 @@
+import { MediaCall } from '@rocket.chat/core-services';
 import { License } from '@rocket.chat/license';
-import { Meteor } from 'meteor/meteor';
 
 import { addSettings } from '../settings/voip';
 
-Meteor.startup(async () => {
-	License.onValidateLicense(async () => {
-		await addSettings();
-	});
+License.onValidateLicense(async () => {
+	await addSettings();
+
+	await MediaCall.hangupExpiredCalls();
 });

apps/meteor/ee/server/services/Dockerfile

@@ -17,6 +17,7 @@ COPY ./packages/core-typings packages/core-typings
 COPY ./packages/eslint-config packages/eslint-config
 COPY ./packages/tsconfig packages/tsconfig
 COPY ./packages/rest-typings packages/rest-typings
+COPY ./packages/media-signaling packages/media-signaling
 COPY ./packages/model-typings packages/model-typings
 COPY ./packages/models packages/models
 
@@ -42,6 +43,9 @@ COPY --from=build /app/packages/core-typings/dist /app/packages/core-typings/dis
 COPY --from=build /app/packages/rest-typings/package.json /app/packages/rest-typings/package.json
 COPY --from=build /app/packages/rest-typings/dist /app/packages/rest-typings/dist
 
+COPY --from=build /app/packages/media-signaling/package.json /app/packages/media-signaling/package.json
+COPY --from=build /app/packages/media-signaling/dist /app/packages/media-signaling/dist
+
 COPY --from=build /app/packages/model-typings/package.json /app/packages/model-typings/package.json
 COPY --from=build /app/packages/model-typings/dist /app/packages/model-typings/dist
 

apps/meteor/package.json

@@ -271,6 +271,8 @@
 		"@rocket.chat/log-format": "workspace:^",
 		"@rocket.chat/logger": "workspace:^",
 		"@rocket.chat/logo": "^0.32.2",
+		"@rocket.chat/media-calls": "workspace:^",
+		"@rocket.chat/media-signaling": "workspace:^",
 		"@rocket.chat/memo": "~0.31.25",
 		"@rocket.chat/message-parser": "workspace:^",
 		"@rocket.chat/message-types": "workspace:~",

apps/meteor/server/models.ts

@@ -43,6 +43,9 @@ import {
 	LoginServiceConfigurationRaw,
 	MatrixBridgedRoomRaw,
 	MatrixBridgedUserRaw,
+	MediaCallsRaw,
+	MediaCallChannelsRaw,
+	MediaCallNegotiationsRaw,
 	MessageReadsRaw,
 	MessagesRaw,
 	MigrationsRaw,
@@ -134,6 +137,9 @@ registerModel('ILivechatVisitorsModel', new LivechatVisitorsRaw(db));
 registerModel('ILoginServiceConfigurationModel', new LoginServiceConfigurationRaw(db));
 registerModel('IMatrixBridgedRoomModel', new MatrixBridgedRoomRaw(db));
 registerModel('IMatrixBridgedUserModel', new MatrixBridgedUserRaw(db));
+registerModel('IMediaCallsModel', new MediaCallsRaw(db));
+registerModel('IMediaCallChannelsModel', new MediaCallChannelsRaw(db));
+registerModel('IMediaCallNegotiationsModel', new MediaCallNegotiationsRaw(db));
 registerModel('IMessageReadsModel', new MessageReadsRaw(db));
 registerModel('IMessagesModel', new MessagesRaw(db, trashCollection));
 registerModel('IMigrationsModel', new MigrationsRaw(db));

apps/meteor/server/modules/listeners/listeners.module.ts

@@ -5,6 +5,7 @@ import { EnterpriseSettings } from '@rocket.chat/core-services';
 import { isSettingColor, isSettingEnterprise, UserStatus } from '@rocket.chat/core-typings';
 import type { IUser, IRoom, IRole, VideoConference, ISetting, IOmnichannelRoom, IMessage, IOTRMessage } from '@rocket.chat/core-typings';
 import { Logger } from '@rocket.chat/logger';
+import type { ServerMediaSignal } from '@rocket.chat/media-signaling';
 import { parse } from '@rocket.chat/message-parser';
 
 import { settings } from '../../../app/settings/server/cached';
@@ -144,6 +145,10 @@ export class ListenersModule {
 			},
 		);
 
+		service.onEvent('user.media-signal', ({ userId, signal }: { userId: string; signal: ServerMediaSignal }) => {
+			notifications.notifyUserInThisInstance(userId, 'media-signal', signal);
+		});
+
 		service.onEvent('room.video-conference', ({ rid, callId }) => {
 			/* deprecated */
 			(notifications.notifyRoom as any)(rid, callId);

apps/meteor/server/modules/notifications/notifications.module.ts

@@ -1,4 +1,4 @@
-import { Authorization, VideoConf } from '@rocket.chat/core-services';
+import { Authorization, MediaCall, VideoConf } from '@rocket.chat/core-services';
 import type { ISubscription, IOmnichannelRoom, IUser } from '@rocket.chat/core-typings';
 import type { StreamerCallbackArgs, StreamKeys, StreamNames } from '@rocket.chat/ddp-client';
 import { Rooms, Subscriptions, Users, Settings } from '@rocket.chat/models';
@@ -308,6 +308,17 @@ export class NotificationsModule {
 				});
 			}
 
+			if (e === 'media-calls') {
+				if (!this.userId || !data || typeof data !== 'string') {
+					return false;
+				}
+
+				void MediaCall.processSerializedSignal(this.userId, data).catch(() => null);
+
+				// media call signals don't ever need to be broadcasted
+				return false;
+			}
+
 			return Boolean(this.userId);
 		});
 		this.streamUser.allowRead(async function (eventName) {

apps/meteor/server/services/media-call/service.ts

@@ -0,0 +1,100 @@
+import { api, ServiceClassInternal, type IMediaCallService } from '@rocket.chat/core-services';
+import type { IUser } from '@rocket.chat/core-typings';
+import { Logger } from '@rocket.chat/logger';
+import { callServer, type IMediaCallServerSettings } from '@rocket.chat/media-calls';
+import { isClientMediaSignal, type ClientMediaSignal, type ServerMediaSignal } from '@rocket.chat/media-signaling';
+import { MediaCalls } from '@rocket.chat/models';
+
+import { settings } from '../../../app/settings/server';
+
+const logger = new Logger('media-call service');
+
+export class MediaCallService extends ServiceClassInternal implements IMediaCallService {
+	protected name = 'media-call';
+
+	constructor() {
+		super();
+		callServer.emitter.on('signalRequest', ({ toUid, signal }) => this.sendSignal(toUid, signal));
+
+		this.onEvent('watch.settings', async ({ setting }): Promise<void> => {
+			if (setting._id.startsWith('VoIP_TeamCollab_')) {
+				setImmediate(() => this.configureMediaCallServer());
+			}
+		});
+
+		this.configureMediaCallServer();
+	}
+
+	public async processSignal(uid: IUser['_id'], signal: ClientMediaSignal): Promise<void> {
+		try {
+			logger.debug({ msg: 'new client signal', type: signal.type, uid });
+			callServer.receiveSignal(uid, signal);
+		} catch (error) {
+			logger.error({ msg: 'failed to process client signal', error, signal, uid });
+		}
+	}
+
+	public async processSerializedSignal(uid: IUser['_id'], signal: string): Promise<void> {
+		try {
+			logger.debug({ msg: 'new client signal', uid });
+
+			const deserialized = await this.deserializeClientSignal(signal);
+
+			callServer.receiveSignal(uid, deserialized);
+		} catch (error) {
+			logger.error({ msg: 'failed to process client signal', error, uid });
+		}
+	}
+
+	public async hangupExpiredCalls(): Promise<void> {
+		await callServer.hangupExpiredCalls().catch((error) => {
+			logger.error({ msg: 'Media Call Server failed to hangup expired calls', error });
+		});
+
+		try {
+			if (await MediaCalls.hasUnfinishedCalls()) {
+				callServer.scheduleExpirationCheck();
+			}
+		} catch (error) {
+			logger.error({ msg: 'Media Call Server failed to check if there are expired calls', error });
+		}
+	}
+
+	private async sendSignal(toUid: IUser['_id'], signal: ServerMediaSignal): Promise<void> {
+		void api.broadcast('user.media-signal', { userId: toUid, signal });
+	}
+
+	private configureMediaCallServer(): void {
+		callServer.configure(this.getMediaServerSettings());
+	}
+
+	private getMediaServerSettings(): IMediaCallServerSettings {
+		const enabled = settings.get<boolean>('VoIP_TeamCollab_Enabled') ?? false;
+		const sipEnabled = false;
+		const forceSip = false;
+
+		return {
+			enabled,
+			internalCalls: {
+				requireExtensions: forceSip,
+				routeExternally: forceSip ? 'always' : 'never',
+			},
+			sip: {
+				enabled: sipEnabled,
+			},
+		};
+	}
+
+	private async deserializeClientSignal(serialized: string): Promise<ClientMediaSignal> {
+		try {
+			const signal = JSON.parse(serialized);
+			if (!isClientMediaSignal(signal)) {
+				throw new Error('signal-format-invalid');
+			}
+			return signal;
+		} catch (error) {
+			logger.error({ msg: 'Failed to parse client signal' }, error);
+			throw error;
+		}
+	}
+}

apps/meteor/server/services/startup.ts

@@ -13,6 +13,7 @@ import { DeviceManagementService } from './device-management/service';
 import { MediaService } from './image/service';
 import { ImportService } from './import/service';
 import { LDAPService } from './ldap/service';
+import { MediaCallService } from './media-call/service';
 import { MessageService } from './messages/service';
 import { MeteorService } from './meteor/service';
 import { NPSService } from './nps/service';
@@ -61,6 +62,7 @@ export const registerServices = async (): Promise<void> => {
 	api.registerService(new ImportService());
 	api.registerService(new OmnichannelAnalyticsService());
 	api.registerService(new UserService());
+	api.registerService(new MediaCallService());
 
 	// if the process is running in micro services mode we don't need to register services that will run separately
 	if (!isRunningMs()) {

ee/apps/account-service/Dockerfile

@@ -20,6 +20,9 @@ COPY ./packages/core-typings/dist packages/core-typings/dist
 COPY ./packages/rest-typings/package.json packages/rest-typings/package.json
 COPY ./packages/rest-typings/dist packages/rest-typings/dist
 
+COPY ./packages/media-signaling/package.json packages/media-signaling/package.json
+COPY ./packages/media-signaling/dist packages/media-signaling/dist
+
 COPY ./packages/message-parser/package.json packages/message-parser/package.json
 COPY ./packages/message-parser/dist packages/message-parser/dist
 COPY ./packages/message-parser/messageParser.js packages/message-parser/messageParser.js

ee/apps/authorization-service/Dockerfile

@@ -20,6 +20,9 @@ COPY ./packages/core-typings/dist packages/core-typings/dist
 COPY ./packages/rest-typings/package.json packages/rest-typings/package.json
 COPY ./packages/rest-typings/dist packages/rest-typings/dist
 
+COPY ./packages/media-signaling/package.json packages/media-signaling/package.json
+COPY ./packages/media-signaling/dist packages/media-signaling/dist
+
 COPY ./packages/message-parser/package.json packages/message-parser/package.json
 COPY ./packages/message-parser/dist packages/message-parser/dist
 COPY ./packages/message-parser/messageParser.js packages/message-parser/messageParser.js

ee/apps/ddp-streamer/Dockerfile

@@ -20,6 +20,9 @@ COPY ./packages/core-typings/dist packages/core-typings/dist
 COPY ./packages/rest-typings/package.json packages/rest-typings/package.json
 COPY ./packages/rest-typings/dist packages/rest-typings/dist
 
+COPY ./packages/media-signaling/package.json packages/media-signaling/package.json
+COPY ./packages/media-signaling/dist packages/media-signaling/dist
+
 COPY ./packages/message-parser/package.json packages/message-parser/package.json
 COPY ./packages/message-parser/dist packages/message-parser/dist
 COPY ./packages/message-parser/messageParser.js packages/message-parser/messageParser.js

ee/apps/omnichannel-transcript/Dockerfile

@@ -20,6 +20,9 @@ COPY ./packages/core-typings/dist packages/core-typings/dist
 COPY ./packages/rest-typings/package.json packages/rest-typings/package.json
 COPY ./packages/rest-typings/dist packages/rest-typings/dist
 
+COPY ./packages/media-signaling/package.json packages/media-signaling/package.json
+COPY ./packages/media-signaling/dist packages/media-signaling/dist
+
 COPY ./packages/message-parser/package.json packages/message-parser/package.json
 COPY ./packages/message-parser/dist packages/message-parser/dist
 COPY ./packages/message-parser/messageParser.js packages/message-parser/messageParser.js

ee/apps/presence-service/Dockerfile

@@ -23,6 +23,9 @@ COPY ./packages/core-typings/dist packages/core-typings/dist
 COPY ./packages/rest-typings/package.json packages/rest-typings/package.json
 COPY ./packages/rest-typings/dist packages/rest-typings/dist
 
+COPY ./packages/media-signaling/package.json packages/media-signaling/package.json
+COPY ./packages/media-signaling/dist packages/media-signaling/dist
+
 COPY ./packages/message-parser/package.json packages/message-parser/package.json
 COPY ./packages/message-parser/dist packages/message-parser/dist
 COPY ./packages/message-parser/messageParser.js packages/message-parser/messageParser.js

ee/apps/queue-worker/Dockerfile

@@ -20,6 +20,9 @@ COPY ./packages/core-typings/dist packages/core-typings/dist
 COPY ./packages/rest-typings/package.json packages/rest-typings/package.json
 COPY ./packages/rest-typings/dist packages/rest-typings/dist
 
+COPY ./packages/media-signaling/package.json packages/media-signaling/package.json
+COPY ./packages/media-signaling/dist packages/media-signaling/dist
+
 COPY ./packages/message-parser/package.json packages/message-parser/package.json
 COPY ./packages/message-parser/dist packages/message-parser/dist
 COPY ./packages/message-parser/messageParser.js packages/message-parser/messageParser.js

ee/apps/stream-hub-service/Dockerfile

@@ -20,6 +20,9 @@ COPY ./packages/core-typings/dist packages/core-typings/dist
 COPY ./packages/rest-typings/package.json packages/rest-typings/package.json
 COPY ./packages/rest-typings/dist packages/rest-typings/dist
 
+COPY ./packages/media-signaling/package.json packages/media-signaling/package.json
+COPY ./packages/media-signaling/dist packages/media-signaling/dist
+
 COPY ./packages/message-parser/package.json packages/message-parser/package.json
 COPY ./packages/message-parser/dist packages/message-parser/dist
 COPY ./packages/message-parser/messageParser.js packages/message-parser/messageParser.js

ee/packages/media-calls/.eslintrc.json

@@ -0,0 +1,4 @@
+{
+	"extends": ["@rocket.chat/eslint-config"],
+	"ignorePatterns": ["**/dist"]
+}

ee/packages/media-calls/package.json

@@ -0,0 +1,33 @@
+{
+	"name": "@rocket.chat/media-calls",
+	"version": "0.0.1",
+	"private": true,
+	"devDependencies": {
+		"@rocket.chat/jest-presets": "workspace:~",
+		"@rocket.chat/tsconfig": "workspace:*",
+		"@types/jest": "~30.0.0",
+		"eslint": "~8.45.0",
+		"jest": "~30.0.5",
+		"typescript": "~5.9.2"
+	},
+	"scripts": {
+		"lint": "eslint --ext .js,.jsx,.ts,.tsx .",
+		"lint:fix": "eslint --ext .js,.jsx,.ts,.tsx . --fix",
+		"test": "jest",
+		"build": "rm -rf dist && tsc -p tsconfig.json",
+		"dev": "tsc -p tsconfig.json --watch --preserveWatchOutput",
+		"build-preview": "mkdir -p ../../.preview && cp -r ./dist ../../.preview/media-calls"
+	},
+	"main": "./dist/index.js",
+	"typings": "./dist/index.d.ts",
+	"files": [
+		"/dist"
+	],
+	"dependencies": {
+		"@rocket.chat/core-typings": "workspace:^",
+		"@rocket.chat/emitter": "~0.31.25",
+		"@rocket.chat/logger": "workspace:^",
+		"@rocket.chat/media-signaling": "workspace:^",
+		"@rocket.chat/models": "workspace:^"
+	}
+}