78 lines
2.8 KiB
JavaScript
Executable File
78 lines
2.8 KiB
JavaScript
Executable File
import Auth from '/imports/ui/services/auth';
|
|
import Users from '/imports/api/users';
|
|
import { makeCall } from '/imports/ui/services/api';
|
|
import Meetings from '/imports/api/meetings';
|
|
import Breakouts from '/imports/api/breakouts';
|
|
import { getVideoUrl } from '/imports/ui/components/external-video-player/service';
|
|
import BreakoutsHistory from '/imports/api/breakouts-history';
|
|
|
|
const USER_CONFIG = Meteor.settings.public.user;
|
|
const ROLE_MODERATOR = USER_CONFIG.role_moderator;
|
|
const DIAL_IN_USER = 'dial-in-user';
|
|
|
|
const getBreakouts = () => Breakouts.find({ parentMeetingId: Auth.meetingID })
|
|
.fetch()
|
|
.sort((a, b) => a.sequence - b.sequence);
|
|
|
|
const getLastBreakouts = () => {
|
|
const lastBreakouts = BreakoutsHistory.findOne({ meetingId: Auth.meetingID });
|
|
if (lastBreakouts) {
|
|
return lastBreakouts.rooms
|
|
.sort((a, b) => a.sequence - b.sequence);
|
|
}
|
|
|
|
return [];
|
|
};
|
|
|
|
const currentBreakoutUsers = (user) => !Breakouts.findOne({
|
|
'joinedUsers.userId': new RegExp(`^${user.userId}`),
|
|
});
|
|
|
|
const filterBreakoutUsers = (filter) => (users) => users.filter(filter);
|
|
|
|
const getUsersNotJoined = filterBreakoutUsers(currentBreakoutUsers);
|
|
|
|
const takePresenterRole = () => makeCall('assignPresenter', Auth.userID);
|
|
|
|
const amIModerator = () => {
|
|
const currentUser = Users.findOne({ userId: Auth.userID },
|
|
{ fields: { role: 1 } });
|
|
|
|
if (!currentUser) {
|
|
return false;
|
|
}
|
|
|
|
return currentUser.role === ROLE_MODERATOR;
|
|
};
|
|
|
|
const isMe = (intId) => intId === Auth.userID;
|
|
|
|
export default {
|
|
amIModerator,
|
|
isMe,
|
|
currentUser: () => Users.findOne({ meetingId: Auth.meetingID, userId: Auth.userID },
|
|
{ fields: { userId: 1, emoji: 1 } }),
|
|
meetingName: () => Meetings.findOne({ meetingId: Auth.meetingID },
|
|
{ fields: { 'meetingProp.name': 1 } }).meetingProp.name,
|
|
users: () => Users.find({
|
|
meetingId: Auth.meetingID,
|
|
clientType: { $ne: DIAL_IN_USER },
|
|
}).fetch(),
|
|
groups: () => Meetings.findOne({ meetingId: Auth.meetingID },
|
|
{ fields: { groups: 1 } }).groups,
|
|
isBreakoutRecordable: () => Meetings.findOne({ meetingId: Auth.meetingID },
|
|
{ fields: { 'breakoutProps.record': 1 } }).breakoutProps.record,
|
|
toggleRecording: () => makeCall('toggleRecording'),
|
|
createBreakoutRoom: (rooms, durationInMinutes, record = false) => makeCall('createBreakoutRoom', rooms, durationInMinutes, record),
|
|
sendInvitation: (breakoutId, userId) => makeCall('requestJoinURL', { breakoutId, userId }),
|
|
breakoutJoinedUsers: () => Breakouts.find({
|
|
joinedUsers: { $exists: true },
|
|
}, { fields: { joinedUsers: 1, breakoutId: 1, sequence: 1 }, sort: { sequence: 1 } }).fetch(),
|
|
moveUser: (fromBreakoutId, toBreakoutId, userId) => makeCall('moveUser', fromBreakoutId, toBreakoutId, userId),
|
|
getBreakouts,
|
|
getLastBreakouts,
|
|
getUsersNotJoined,
|
|
takePresenterRole,
|
|
isSharingVideo: () => getVideoUrl(),
|
|
};
|