import { Meteor } from 'meteor/meteor';
import { withTracker } from 'meteor/react-meteor-data';
import React, { useEffect } from 'react';
import { defineMessages, injectIntl } from 'react-intl';
import _ from 'lodash';
import Auth from '/imports/ui/services/auth';
import { MeetingTimeRemaining } from '/imports/api/meetings';
import Meetings from '/imports/api/meetings';
import BreakoutRemainingTime from '/imports/ui/components/breakout-room/breakout-remaining-time/container';
import Styled from './styles';
import { layoutSelectInput, layoutDispatch } from '../layout/context';
import { ACTIONS } from '../layout/enums';
import breakoutService from '/imports/ui/components/breakout-room/service';
import NotificationsBar from './component';
// disconnected and trying to open a new connection
const STATUS_CONNECTING = 'connecting';
// permanently failed to connect; e.g., the client and server support different versions of DDP
const STATUS_FAILED = 'failed';
// failed to connect and waiting to try to reconnect
const STATUS_WAITING = 'waiting';
const METEOR_SETTINGS_APP = Meteor.settings.public.app;
const REMAINING_TIME_THRESHOLD = METEOR_SETTINGS_APP.remainingTimeThreshold;
const REMAINING_TIME_ALERT_THRESHOLD = METEOR_SETTINGS_APP.remainingTimeAlertThreshold;
const intlMessages = defineMessages({
failedMessage: {
id: 'app.failedMessage',
description: 'Notification for connecting to server problems',
},
connectingMessage: {
id: 'app.connectingMessage',
description: 'Notification message for when client is connecting to server',
},
waitingMessage: {
id: 'app.waitingMessage',
description: 'Notification message for disconnection with reconnection counter',
},
retryNow: {
id: 'app.retryNow',
description: 'Retry now text for reconnection counter',
},
breakoutTimeRemaining: {
id: 'app.breakoutTimeRemainingMessage',
description: 'Message that tells how much time is remaining for the breakout room',
},
breakoutWillClose: {
id: 'app.breakoutWillCloseMessage',
description: 'Message that tells time has ended and breakout will close',
},
calculatingBreakoutTimeRemaining: {
id: 'app.calculatingBreakoutTimeRemaining',
description: 'Message that tells that the remaining time is being calculated',
},
meetingTimeRemaining: {
id: 'app.meeting.meetingTimeRemaining',
description: 'Message that tells how much time is remaining for the meeting',
},
meetingWillClose: {
id: 'app.meeting.meetingTimeHasEnded',
description: 'Message that tells time has ended and meeting will close',
},
alertMeetingEndsUnderMinutes: {
id: 'app.meeting.alertMeetingEndsUnderMinutes',
description: 'Alert that tells that the meeting ends under x minutes',
},
alertBreakoutEndsUnderMinutes: {
id: 'app.meeting.alertBreakoutEndsUnderMinutes',
description: 'Alert that tells that the breakout ends under x minutes',
},
});
const NotificationsBarContainer = (props) => {
const { message, color } = props;
const notificationsBar = layoutSelectInput((i) => i.notificationsBar);
const layoutContextDispatch = layoutDispatch();
const { hasNotification } = notificationsBar;
useEffect(() => {
const localHasNotification = !!message;
if (localHasNotification !== hasNotification) {
layoutContextDispatch({
type: ACTIONS.SET_HAS_NOTIFICATIONS_BAR,
value: localHasNotification,
});
}
}, [message, hasNotification]);
if (_.isEmpty(message)) {
return null;
}
return (
{message}
);
};
let retrySeconds = 0;
const retrySecondsDep = new Tracker.Dependency();
let retryInterval = null;
const getRetrySeconds = () => {
retrySecondsDep.depend();
return retrySeconds;
};
const setRetrySeconds = (sec = 0) => {
if (sec !== retrySeconds) {
retrySeconds = sec;
retrySecondsDep.changed();
}
};
const startCounter = (sec, set, get, interval) => {
clearInterval(interval);
set(sec);
return setInterval(() => {
set(get() - 1);
}, 1000);
};
const reconnect = () => {
Meteor.reconnect();
};
export default injectIntl(withTracker(({ intl }) => {
const { status, connected, retryTime } = Meteor.status();
const data = {};
if (!connected) {
data.color = 'primary';
switch (status) {
case STATUS_FAILED: {
data.color = 'danger';
data.message = intl.formatMessage(intlMessages.failedMessage);
break;
}
case STATUS_CONNECTING: {
data.message = intl.formatMessage(intlMessages.connectingMessage);
break;
}
case STATUS_WAITING: {
const sec = Math.round((retryTime - (new Date()).getTime()) / 1000);
retryInterval = startCounter(sec, setRetrySeconds, getRetrySeconds, retryInterval);
data.message = (
<>
{intl.formatMessage(intlMessages.waitingMessage, { 0: getRetrySeconds() })}
{intl.formatMessage(intlMessages.retryNow)}
>
);
break;
}
default:
break;
}
return data;
}
const meetingId = Auth.meetingID;
const breakouts = breakoutService.getBreakouts();
let msg = { id: `${intlMessages.alertBreakoutEndsUnderMinutes.id}${REMAINING_TIME_ALERT_THRESHOLD === 1 ? 'Singular' : 'Plural'}` };
if (breakouts.length > 0) {
const currentBreakout = breakouts.find((b) => b.breakoutId === meetingId);
if (currentBreakout) {
data.message = (
);
}
}
const meetingTimeRemaining = MeetingTimeRemaining.findOne({ meetingId });
const Meeting = Meetings.findOne({ meetingId },
{ fields: { 'meetingProp.isBreakout': 1 } });
if (meetingTimeRemaining && Meeting) {
const { timeRemaining } = meetingTimeRemaining;
const { isBreakout } = Meeting.meetingProp;
const underThirtyMin = timeRemaining && timeRemaining <= (REMAINING_TIME_THRESHOLD * 60);
msg = { id: `${intlMessages.alertMeetingEndsUnderMinutes.id}${REMAINING_TIME_ALERT_THRESHOLD === 1 ? 'Singular' : 'Plural'}` };
if (underThirtyMin && !isBreakout) {
data.message = (
);
}
}
data.alert = true;
data.color = 'primary';
return data;
})(NotificationsBarContainer));