import React, { Component } from 'react';
import { withTracker } from 'meteor/react-meteor-data';
import PropTypes from 'prop-types';
import Auth from '/imports/ui/services/auth';
import AppContainer from '/imports/ui/components/app/container';
import ErrorScreen from '/imports/ui/components/error-screen/component';
import MeetingEnded from '/imports/ui/components/meeting-ended/component';
import LoadingScreen from '/imports/ui/components/loading-screen/component';
import Settings from '/imports/ui/services/settings';
import logger from '/imports/startup/client/logger';
import Users from '/imports/api/users';
import { Session } from 'meteor/session';
import { FormattedMessage } from 'react-intl';
import Meetings, { RecordMeetings } from '../../api/meetings';
import AppService from '/imports/ui/components/app/service';
import Breakouts from '/imports/api/breakouts';
import AudioService from '/imports/ui/components/audio/service';
import { notify } from '/imports/ui/services/notification';
import deviceInfo from '/imports/utils/deviceInfo';
import getFromUserSettings from '/imports/ui/services/users-settings';
const CHAT_CONFIG = Meteor.settings.public.chat;
const CHAT_ENABLED = CHAT_CONFIG.enabled;
const PUBLIC_CHAT_ID = CHAT_CONFIG.public_id;
const BREAKOUT_END_NOTIFY_DELAY = 50;
const HTML = document.getElementsByTagName('html')[0];
let breakoutNotified = false;
const propTypes = {
subscriptionsReady: PropTypes.bool,
approved: PropTypes.bool,
meetingHasEnded: PropTypes.bool.isRequired,
meetingExist: PropTypes.bool,
};
const defaultProps = {
approved: false,
meetingExist: false,
subscriptionsReady: false,
};
const fullscreenChangedEvents = [
'fullscreenchange',
'webkitfullscreenchange',
'mozfullscreenchange',
'MSFullscreenChange',
];
class Base extends Component {
static handleFullscreenChange() {
if (document.fullscreenElement
|| document.webkitFullscreenElement
|| document.mozFullScreenElement
|| document.msFullscreenElement) {
Session.set('isFullscreen', true);
} else {
Session.set('isFullscreen', false);
}
}
constructor(props) {
super(props);
this.state = {
loading: false,
meetingExisted: false,
};
this.updateLoadingState = this.updateLoadingState.bind(this);
}
componentDidMount() {
const { animations } = this.props;
if (animations) HTML.classList.add('animationsEnabled');
if (!animations) HTML.classList.add('animationsDisabled');
if (getFromUserSettings('bbb_show_participants_on_login', true) && !deviceInfo.type().isPhone) {
Session.set('openPanel', 'userlist');
if (CHAT_ENABLED) {
Session.set('openPanel', 'chat');
Session.set('idChatOpen', PUBLIC_CHAT_ID);
}
} else {
Session.set('openPanel', '');
}
fullscreenChangedEvents.forEach((event) => {
document.addEventListener(event, Base.handleFullscreenChange);
});
Session.set('isFullscreen', false);
}
componentDidUpdate(prevProps, prevState) {
const {
approved,
meetingExist,
animations,
ejected,
isMeteorConnected,
subscriptionsReady,
} = this.props;
const {
loading,
meetingExisted,
} = this.state;
if (!prevProps.subscriptionsReady && subscriptionsReady) {
logger.info({ logCode: 'startup_client_subscriptions_ready' }, 'Subscriptions are ready');
}
if (prevProps.meetingExist && !meetingExist && !meetingExisted) {
this.setMeetingExisted(true);
}
// In case the meteor restart avoid error log
if (isMeteorConnected && (prevState.meetingExisted !== meetingExisted) && meetingExisted) {
this.setMeetingExisted(false);
}
// In case the meeting delayed to load
if (!subscriptionsReady || !meetingExist) return;
if (approved && loading && subscriptionsReady) this.updateLoadingState(false);
if (prevProps.ejected || ejected) {
Session.set('codeError', '403');
Session.set('isMeetingEnded', true);
}
// In case the meteor restart avoid error log
if (isMeteorConnected && (prevState.meetingExisted !== meetingExisted)) {
this.setMeetingExisted(false);
}
const enabled = HTML.classList.contains('animationsEnabled');
const disabled = HTML.classList.contains('animationsDisabled');
if (animations && animations !== prevProps.animations) {
if (disabled) HTML.classList.remove('animationsDisabled');
HTML.classList.add('animationsEnabled');
} else if (!animations && animations !== prevProps.animations) {
if (enabled) HTML.classList.remove('animationsEnabled');
HTML.classList.add('animationsDisabled');
}
}
componentWillUnmount() {
fullscreenChangedEvents.forEach((event) => {
document.removeEventListener(event, Base.handleFullscreenChange);
});
}
setMeetingExisted(meetingExisted) {
this.setState({ meetingExisted });
}
updateLoadingState(loading = false) {
this.setState({
loading,
});
}
renderByState() {
const { updateLoadingState } = this;
const stateControls = { updateLoadingState };
const { loading } = this.state;
const {
codeError,
ejected,
meetingExist,
meetingHasEnded,
meetingIsBreakout,
subscriptionsReady,
User,
} = this.props;
if ((loading || !subscriptionsReady) && !meetingHasEnded && meetingExist) {
return ({loading});
}
if (ejected) {
return ();
}
if ((meetingHasEnded || User.loggedOut) && meetingIsBreakout) {
window.close();
return null;
}
if (((meetingHasEnded && !meetingIsBreakout)) || (codeError && (User && User.loggedOut))) {
return ();
}
if (codeError && !meetingHasEnded) {
// 680 is set for the codeError when the user requests a logout
if (codeError !== '680') {
logger.error({ logCode: 'startup_client_usercouldnotlogin_error' }, `User could not log in HTML5, hit ${codeError}`);
return ();
}
return ();
}
return ();
}
render() {
const { meetingExist } = this.props;
const { meetingExisted } = this.state;
return (
(!meetingExisted && !meetingExist && Auth.loggedIn)
?
: this.renderByState()
);
}
}
Base.propTypes = propTypes;
Base.defaultProps = defaultProps;
const BaseContainer = withTracker(() => {
const {
animations,
userJoinAudioAlerts,
userJoinPushAlerts,
} = Settings.application;
const {
credentials,
loggedIn,
userID: localUserId,
} = Auth;
const { meetingId } = credentials;
let breakoutRoomSubscriptionHandler;
let meetingModeratorSubscriptionHandler;
const fields = {
approved: 1,
authed: 1,
ejected: 1,
color: 1,
effectiveConnectionType: 1,
extId: 1,
guest: 1,
intId: 1,
locked: 1,
loggedOut: 1,
meetingId: 1,
userId: 1,
};
const User = Users.findOne({ intId: credentials.requesterUserId }, { fields });
const meeting = Meetings.findOne({ meetingId }, {
fields: {
meetingEnded: 1,
meetingProp: 1,
},
});
if (meeting && meeting.meetingEnded) {
Session.set('codeError', '410');
}
const approved = User && User.approved && User.guest;
const ejected = User && User.ejected;
let userSubscriptionHandler;
Breakouts.find({}, { fields: { _id: 1 } }).observeChanges({
added() {
breakoutNotified = false;
},
removed() {
// Need to check the number of breakouts left because if a user's role changes to viewer
// then all but one room is removed. The data here isn't reactive so no need to filter
// the fields
const numBreakouts = Breakouts.find().count();
if (!AudioService.isUsingAudio() && !breakoutNotified && numBreakouts === 0) {
if (meeting && !meeting.meetingEnded && !meeting.meetingProp.isBreakout) {
// There's a race condition when reloading a tab where the collection gets cleared
// out and then refilled. The removal of the old data triggers the notification so
// instead wait a bit and check to see that records weren't added right after.
setTimeout(() => {
if (breakoutNotified) {
notify(
,
'info',
'rooms',
);
}
}, BREAKOUT_END_NOTIFY_DELAY);
}
breakoutNotified = true;
}
},
});
RecordMeetings.find({ meetingId }, { fields: { recording: 1 } }).observe({
changed: (newDocument, oldDocument) => {
if (newDocument) {
if (!oldDocument.recording && newDocument.recording) {
notify(
,
'success',
'record',
);
}
if (oldDocument.recording && !newDocument.recording) {
notify(
,
'error',
'record',
);
}
}
},
});
if (userJoinAudioAlerts || userJoinPushAlerts) {
Users.find({}, { fields: { validated: 1, name: 1, userId: 1 } }).observe({
changed: (newDocument) => {
if (newDocument.validated && newDocument.name && newDocument.userId !== localUserId) {
if (userJoinAudioAlerts) {
const audio = new Audio(`${Meteor.settings.public.app.cdn + Meteor.settings.public.app.basename}/resources/sounds/userJoin.mp3`);
audio.play();
}
if (userJoinPushAlerts) {
notify(
,
'info',
'user',
);
}
}
},
});
}
if (getFromUserSettings('bbb_show_participants_on_login', true) && !deviceInfo.type().isPhone) {
Session.set('openPanel', 'userlist');
if (CHAT_ENABLED && getFromUserSettings('bbb_show_public_chat_on_login', !Meteor.settings.public.chat.startClosed)) {
Session.set('openPanel', 'chat');
Session.set('idChatOpen', PUBLIC_CHAT_ID);
}
} else {
Session.set('openPanel', '');
}
const codeError = Session.get('codeError');
return {
approved,
ejected,
userSubscriptionHandler,
breakoutRoomSubscriptionHandler,
meetingModeratorSubscriptionHandler,
animations,
User,
isMeteorConnected: Meteor.status().connected,
meetingExist: !!meeting,
meetingHasEnded: !!meeting && meeting.meetingEnded,
meetingIsBreakout: AppService.meetingIsBreakout(),
subscriptionsReady: Session.get('subscriptionsReady'),
loggedIn,
codeError,
};
})(Base);
export default BaseContainer;