From d3a1177d1535d5e258fab267f73c574ee676730a Mon Sep 17 00:00:00 2001 From: gabriellsh Date: Tue, 16 Jan 2024 12:48:51 -0300 Subject: [PATCH] VideoConfManager --- apps/meteor/client/lib/VideoConfManager.ts | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/apps/meteor/client/lib/VideoConfManager.ts b/apps/meteor/client/lib/VideoConfManager.ts index 42aa92a7be0e4..7ae1c04db6df5 100644 --- a/apps/meteor/client/lib/VideoConfManager.ts +++ b/apps/meteor/client/lib/VideoConfManager.ts @@ -3,7 +3,6 @@ import { Emitter } from '@rocket.chat/emitter'; import { Meteor } from 'meteor/meteor'; import { Tracker } from 'meteor/tracker'; -import { Notifications } from '../../app/notifications/client'; import { sdk } from '../../app/utils/client/lib/SDKClient'; import { getConfig } from './utils/getConfig'; @@ -507,14 +506,14 @@ export const VideoConfManager = new (class VideoConfManager extends Emitter { - return Notifications.notifyUser(uid, 'video-conference', { action, params }); + return sdk.publish('notify-user', [`${uid}/video-conference`, { action, params }]); } private async connectUser(userId: string): Promise { debug && console.log(`[VideoConf] connecting user ${userId}`); this.userId = userId; - const { stop, ready } = Notifications.onUser('video-conference', (data) => this.onVideoConfNotification(data)); + const { stop, ready } = sdk.stream('notify-user', [`${userId}/video-conference`], (data) => this.onVideoConfNotification(data)); await ready();