127 lines
2.7 KiB
JavaScript
Executable File
127 lines
2.7 KiB
JavaScript
Executable File
import { Meteor } from 'meteor/meteor';
|
|
import Auth from '/imports/ui/services/auth';
|
|
import Users from '/imports/api/users';
|
|
import Chat from '/imports/api/chat';
|
|
import Meetings from '/imports/api/meetings';
|
|
import Cursor from '/imports/api/cursor';
|
|
import Captions from '/imports/api/captions';
|
|
import Polls from '/imports/api/polls';
|
|
import Storage from '/imports/ui/services/storage/session';
|
|
|
|
function setCredentials(nextState, replace) {
|
|
if (nextState && nextState.params.authToken) {
|
|
const { meetingID, userID, authToken } = nextState.params;
|
|
Auth.setCredentials(meetingID, userID, authToken);
|
|
replace({
|
|
pathname: '/',
|
|
});
|
|
}
|
|
};
|
|
|
|
let dataSubscriptions = null;
|
|
function subscribeForData() {
|
|
if (dataSubscriptions) {
|
|
return dataSubscriptions;
|
|
}
|
|
|
|
const subNames = [
|
|
'users', 'chat', 'cursor', 'deskshare', 'meetings',
|
|
'polls', 'presentations', 'shapes', 'slides', 'captions', 'breakouts',
|
|
];
|
|
|
|
let subs = [];
|
|
subNames.forEach(name => subs.push(subscribeFor(name)));
|
|
|
|
dataSubscriptions = subs;
|
|
return subs;
|
|
};
|
|
|
|
function subscribeFor(collectionName) {
|
|
const credentials = Auth.getCredentials();
|
|
return new Promise((resolve, reject) => {
|
|
Meteor.subscribe(collectionName, credentials, {
|
|
onReady: (...args) => resolve(...args),
|
|
onStop: (...args) => reject(...args),
|
|
});
|
|
});
|
|
};
|
|
|
|
function subscribeToCollections(cb) {
|
|
subscribeFor('users')
|
|
.then(() => {
|
|
observeUserKick();
|
|
return Promise.all(subscribeForData())
|
|
.then(() => {
|
|
if (cb) {
|
|
return cb();
|
|
}
|
|
});
|
|
})
|
|
.catch(redirectToLogoutUrl);
|
|
};
|
|
|
|
function redirectToLogoutUrl(reason) {
|
|
console.error(reason);
|
|
console.log('Redirecting user to the logoutURL...');
|
|
document.location.href = Auth.logoutURL;
|
|
}
|
|
|
|
let wasKicked = false;
|
|
const wasKickedDep = new Tracker.Dependency;
|
|
|
|
function observeUserKick() {
|
|
Users.find().observe({
|
|
removed(old) {
|
|
if (old.userId === Auth.userID) {
|
|
Auth.clearCredentials(() => {
|
|
wasKicked = true;
|
|
wasKickedDep.changed();
|
|
});
|
|
}
|
|
},
|
|
});
|
|
}
|
|
|
|
function wasUserKicked() {
|
|
wasKickedDep.depend();
|
|
return wasKicked;
|
|
}
|
|
|
|
let modal = null;
|
|
const modalDep = new Tracker.Dependency;
|
|
|
|
const getModal = () => {
|
|
modalDep.depend();
|
|
return modal;
|
|
};
|
|
|
|
const showModal = (val) => {
|
|
if (val !== modal) {
|
|
modal = val;
|
|
modalDep.changed();
|
|
}
|
|
};
|
|
|
|
const clearModal = () => {
|
|
showModal(null);
|
|
};
|
|
|
|
function getCaptionsStatus() {
|
|
var CCEnabled = Storage.getItem('closedCaptions');
|
|
return !!CCEnabled;
|
|
};
|
|
|
|
export {
|
|
subscribeForData,
|
|
setCredentials,
|
|
subscribeFor,
|
|
subscribeToCollections,
|
|
wasUserKicked,
|
|
redirectToLogoutUrl,
|
|
getBreakouts,
|
|
getModal,
|
|
showModal,
|
|
clearModal,
|
|
getCaptionsStatus,
|
|
};
|