Skip to content
Snippets Groups Projects
Unverified Commit e2d11f1b authored by Anton Georgiev's avatar Anton Georgiev Committed by GitHub
Browse files

Merge pull request #6405 from antobinary/fix-end-meeting

Improve format of callbacks on collection document removal (to address exception)
parents d12c01fb afa1a64e
No related branches found
No related tags found
No related merge requests found
Showing
with 71 additions and 36 deletions
......@@ -7,8 +7,12 @@ export default function clearBreakouts(breakoutId) {
breakoutId,
};
return Breakouts.remove(selector);
return Breakouts.remove(selector, () => {
Logger.info(`Cleared Breakouts (${breakoutId})`);
});
}
return Breakouts.remove({}, Logger.info('Cleared Breakouts (all)'));
return Breakouts.remove({}, () => {
Logger.info('Cleared Breakouts (all)');
});
}
......@@ -3,8 +3,12 @@ import Logger from '/imports/startup/server/logger';
export default function clearCaptions(meetingId) {
if (meetingId) {
return Captions.remove({ meetingId }, Logger.info(`Cleared Captions (${meetingId})`));
return Captions.remove({ meetingId }, () => {
Logger.info(`Cleared Captions (${meetingId})`);
});
}
return Captions.remove({}, Logger.info('Cleared Captions (all)'));
return Captions.remove({}, () => {
Logger.info('Cleared Captions (all)');
});
}
......@@ -9,7 +9,9 @@ export default function clearGroupChatMsg(meetingId, chatId) {
const CHAT_CLEAR_MESSAGE = CHAT_CONFIG.system_messages_keys.chat_clear;
if (chatId) {
GroupChatMsg.remove({ meetingId, chatId }, Logger.info(`Cleared GroupChatMsg (${meetingId}, ${chatId})`));
GroupChatMsg.remove({ meetingId, chatId }, () => {
Logger.info(`Cleared GroupChatMsg (${meetingId}, ${chatId})`);
});
const clearMsg = {
color: '0',
......@@ -26,8 +28,12 @@ export default function clearGroupChatMsg(meetingId, chatId) {
}
if (meetingId) {
return GroupChatMsg.remove({ meetingId }, Logger.info(`Cleared GroupChatMsg (${meetingId})`));
return GroupChatMsg.remove({ meetingId }, () => {
Logger.info(`Cleared GroupChatMsg (${meetingId})`);
});
}
return GroupChatMsg.remove({}, Logger.info('Cleared GroupChatMsg (all)'));
return GroupChatMsg.remove({}, () => {
Logger.info('Cleared GroupChatMsg (all)');
});
}
......@@ -4,5 +4,7 @@ import clearGroupChatMsg from '/imports/api/group-chat-msg/server/modifiers/clea
export default function clearGroupChat(meetingId) {
clearGroupChatMsg(meetingId);
return GroupChat.remove({ meetingId }, Logger.info(`Cleared GroupChat (${meetingId})`));
return GroupChat.remove({ meetingId }, () => {
Logger.info(`Cleared GroupChat (${meetingId})`);
});
}
......@@ -3,8 +3,12 @@ import Logger from '/imports/startup/server/logger';
export default function clearPolls(meetingId) {
if (meetingId) {
return Polls.remove({ meetingId }, Logger.info(`Cleared Polls (${meetingId})`));
return Polls.remove({ meetingId }, () => {
Logger.info(`Cleared Polls (${meetingId})`);
});
}
return Polls.remove({}, Logger.info('Cleared Polls (all)'));
return Polls.remove({}, () => {
Logger.info('Cleared Polls (all)');
});
}
......@@ -3,19 +3,19 @@ import Logger from '/imports/startup/server/logger';
export default function clearPresentationUploadToken(meetingId, podId) {
if (meetingId && podId) {
return PresentationUploadToken.remove(
{ meetingId, podId },
Logger.info(`Cleared Presentations Upload Token (${meetingId}, ${podId})`),
);
return PresentationUploadToken.remove({ meetingId, podId }, () => {
Logger.info(`Cleared Presentations Upload Token (${meetingId}, ${podId})`);
});
}
if (meetingId) {
return PresentationUploadToken.remove(
{ meetingId },
Logger.info(`Cleared Presentations Upload Token (${meetingId})`),
);
return PresentationUploadToken.remove({ meetingId }, () => {
Logger.info(`Cleared Presentations Upload Token (${meetingId})`);
});
}
// clearing presentations for the whole server
return PresentationUploadToken.remove({}, Logger.info('Cleared Presentations Upload Token (all)'));
return PresentationUploadToken.remove({}, () => {
Logger.info('Cleared Presentations Upload Token (all)');
});
}
......@@ -4,19 +4,20 @@ import Logger from '/imports/startup/server/logger';
export default function clearPresentations(meetingId, podId) {
// clearing presentations for 1 pod
if (meetingId && podId) {
return Presentations.remove(
{ meetingId, podId },
Logger.info(`Cleared Presentations (${meetingId}, ${podId})`),
);
return Presentations.remove({ meetingId, podId }, () => {
Logger.info(`Cleared Presentations (${meetingId}, ${podId})`);
});
}
// clearing presentations for the whole meeting
} else if (meetingId) {
return Presentations.remove(
{ meetingId },
Logger.info(`Cleared Presentations (${meetingId})`),
);
if (meetingId) {
return Presentations.remove({ meetingId }, () => {
Logger.info(`Cleared Presentations (${meetingId})`);
});
}
// clearing presentations for the whole server
return Presentations.remove({}, Logger.info('Cleared Presentations (all)'));
return Presentations.remove({}, () => {
Logger.info('Cleared Presentations (all)');
});
}
......@@ -3,8 +3,12 @@ import Logger from '/imports/startup/server/logger';
export default function clearSlides(meetingId) {
if (meetingId) {
return Slides.remove({ meetingId }, Logger.info(`Cleared Slides (${meetingId})`));
return Slides.remove({ meetingId }, () => {
Logger.info(`Cleared Slides (${meetingId})`);
});
}
return Slides.remove({}, Logger.info('Cleared Slides (all)'));
return Slides.remove({}, () => {
Logger.info('Cleared Slides (all)');
});
}
......@@ -2,5 +2,7 @@ import UserSettings from '/imports/api/users-settings';
import Logger from '/imports/startup/server/logger';
export default function clearUsersSettings(meetingId) {
return UserSettings.remove({ meetingId }, Logger.info(`Cleared User Settings (${meetingId})`));
return UserSettings.remove({ meetingId }, () => {
Logger.info(`Cleared User Settings (${meetingId})`);
});
}
......@@ -3,10 +3,14 @@ import Users from '/imports/api/users/index';
const clearUsers = (meetingId) => {
if (meetingId) {
return Users.remove({ meetingId }, Logger.info(`Cleared Users (${meetingId})`));
return Users.remove({ meetingId }, () => {
Logger.info(`Cleared Users (${meetingId})`);
});
}
return Users.remove({}, Logger.info('Cleared Users (all)'));
return Users.remove({}, () => {
Logger.info('Cleared Users (all)');
});
};
export default clearUsers;
......@@ -3,8 +3,12 @@ import VoiceUsers from '/imports/api/voice-users';
export default function clearVoiceUser(meetingId) {
if (meetingId) {
return VoiceUsers.remove({ meetingId }, Logger.info(`Cleared Users (${meetingId})`));
return VoiceUsers.remove({ meetingId }, () => {
Logger.info(`Cleared Users (${meetingId})`);
});
}
return VoiceUsers.remove({}, Logger.info('Cleared Users (all)'));
return VoiceUsers.remove({}, () => {
Logger.info('Cleared Users (all)');
});
}
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