Skip to content
Snippets Groups Projects
Commit 9ed813ea authored by Joao Siebel's avatar Joao Siebel
Browse files

Remove streamers on meeting end

parent 72cc05ab
No related branches found
No related tags found
No related merge requests found
import Logger from '/imports/startup/server/logger';
export function removeAnnotationsStreamer(meetingId) {
Logger.info(`Removing Annotations streamer object for meeting ${meetingId}`);
delete Meteor.StreamerCentral.instances[`annotations-${meetingId}`];
}
......
import Logger from '/imports/startup/server/logger';
import publishCursorUpdate from './methods/publishCursorUpdate';
export function removeCursorStreamer(meetingId) {
Logger.info(`Removing Cursor streamer object for meeting ${meetingId}`);
delete Meteor.StreamerCentral.instances[`cursor-${meetingId}`];
}
......
......@@ -2,6 +2,8 @@ import RedisPubSub from '/imports/startup/server/redis';
import { check } from 'meteor/check';
import destroyExternalVideo from '/imports/api/external-videos/server/methods/destroyExternalVideo';
import { removeAnnotationsStreamer } from '/imports/api/annotations/server/streamer';
import { removeCursorStreamer } from '/imports/api/cursor/server/streamer';
export default function handleMeetingDestruction({ body }) {
check(body, Object);
......@@ -9,6 +11,8 @@ export default function handleMeetingDestruction({ body }) {
check(meetingId, String);
destroyExternalVideo(meetingId);
removeAnnotationsStreamer(meetingId);
removeCursorStreamer(meetingId);
return RedisPubSub.destroyMeetingQueue(meetingId);
}
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment