64 lines
2.0 KiB
JavaScript
64 lines
2.0 KiB
JavaScript
import { check } from 'meteor/check';
|
|
import VoiceUsers from '/imports/api/voice-users/';
|
|
import Meetings from '/imports/api/meetings';
|
|
import addVoiceUser from '../modifiers/addVoiceUser';
|
|
import removeVoiceUser from '../modifiers/removeVoiceUser';
|
|
import updateVoiceUser from '../modifiers/updateVoiceUser';
|
|
|
|
export default async function handleGetVoiceUsers({ body }, meetingId) {
|
|
const { users } = body;
|
|
|
|
check(meetingId, String);
|
|
check(users, Array);
|
|
|
|
const meeting = await Meetings.findOneAsync({ meetingId }, { fields: { 'voiceProp.voiceConf': 1 } });
|
|
const usersIds = users.map((m) => m.intId);
|
|
|
|
const voiceUsersFetch = await VoiceUsers.find({
|
|
meetingId,
|
|
intId: { $in: usersIds },
|
|
}, { fields: { intId: 1 } }).fetchAsync();
|
|
|
|
const voiceUsersIdsToUpdate = voiceUsersFetch.map((m) => m.intId);
|
|
|
|
await Promise.all(users.map(async (user) => {
|
|
if (voiceUsersIdsToUpdate.indexOf(user.intId) >= 0) {
|
|
// user already exist, then update
|
|
await updateVoiceUser(meetingId, {
|
|
intId: user.intId,
|
|
voiceUserId: user.voiceUserId,
|
|
talking: user.talking,
|
|
muted: user.muted,
|
|
voiceConf: meeting.voiceProp.voiceConf,
|
|
joined: true,
|
|
});
|
|
} else {
|
|
// user doesn't exist yet, then add it
|
|
await addVoiceUser(meetingId, {
|
|
voiceUserId: user.voiceUserId,
|
|
intId: user.intId,
|
|
callerName: user.callerName,
|
|
callerNum: user.callerNum,
|
|
muted: user.muted,
|
|
talking: user.talking,
|
|
callingWith: user.callingWith,
|
|
listenOnly: user.listenOnly,
|
|
voiceConf: meeting.voiceProp.voiceConf,
|
|
joined: true,
|
|
});
|
|
}
|
|
}));
|
|
// removing extra users already existing in Mongo
|
|
const voiceUsersToRemove = await VoiceUsers.find({
|
|
meetingId,
|
|
intId: { $nin: usersIds },
|
|
}).fetchAsync();
|
|
await Promise.all(voiceUsersToRemove.map(async (user) => {
|
|
await removeVoiceUser(meetingId, {
|
|
voiceConf: meeting.voiceProp.voiceConf,
|
|
voiceUserId: user.voiceUserId,
|
|
intId: user.intId,
|
|
});
|
|
}));
|
|
}
|