import React, { PureComponent } from 'react'; import { FormattedTime, defineMessages, injectIntl } from 'react-intl'; import PropTypes from 'prop-types'; import UserAvatar from '/imports/ui/components/user-avatar/component'; import Icon from '/imports/ui/components/connection-status/icon/component'; import Service from '../service'; import Styled from './styles'; import ConnectionStatusHelper from '../status-helper/container'; const NETWORK_MONITORING_INTERVAL_MS = 2000; const MIN_TIMEOUT = 3000; const intlMessages = defineMessages({ ariaTitle: { id: 'app.connection-status.ariaTitle', description: 'Connection status aria title', }, title: { id: 'app.connection-status.title', description: 'Connection status title', }, description: { id: 'app.connection-status.description', description: 'Connection status description', }, empty: { id: 'app.connection-status.empty', description: 'Connection status empty', }, more: { id: 'app.connection-status.more', description: 'More about conectivity issues', }, audioLabel: { id: 'app.settings.audioTab.label', description: 'Audio label', }, videoLabel: { id: 'app.settings.videoTab.label', description: 'Video label', }, copy: { id: 'app.connection-status.copy', description: 'Copy network data', }, copied: { id: 'app.connection-status.copied', description: 'Copied network data', }, offline: { id: 'app.connection-status.offline', description: 'Offline user', }, dataSaving: { id: 'app.settings.dataSavingTab.description', description: 'Description of data saving', }, webcam: { id: 'app.settings.dataSavingTab.webcam', description: 'Webcam data saving switch', }, screenshare: { id: 'app.settings.dataSavingTab.screenShare', description: 'Screenshare data saving switch', }, on: { id: 'app.switch.onLabel', description: 'label for toggle switch on state', }, off: { id: 'app.switch.offLabel', description: 'label for toggle switch off state', }, no: { id: 'app.connection-status.no', description: 'No to is using turn', }, yes: { id: 'app.connection-status.yes', description: 'Yes to is using turn', }, usingTurn: { id: 'app.connection-status.usingTurn', description: 'User is using turn server', }, jitter: { id: 'app.connection-status.jitter', description: 'Jitter buffer in ms', }, lostPackets: { id: 'app.connection-status.lostPackets', description: 'Number of lost packets', }, audioUploadRate: { id: 'app.connection-status.audioUploadRate', description: 'Label for audio current upload rate', }, audioDownloadRate: { id: 'app.connection-status.audioDownloadRate', description: 'Label for audio current download rate', }, videoUploadRate: { id: 'app.connection-status.videoUploadRate', description: 'Label for video current upload rate', }, videoDownloadRate: { id: 'app.connection-status.videoDownloadRate', description: 'Label for video current download rate', }, connectionStats: { id: 'app.connection-status.connectionStats', description: 'Label for Connection Stats tab', }, myLogs: { id: 'app.connection-status.myLogs', description: 'Label for My Logs tab', }, sessionLogs: { id: 'app.connection-status.sessionLogs', description: 'Label for Session Logs tab', }, next: { id: 'app.connection-status.next', description: 'Label for the next page of the connection stats tab', }, prev: { id: 'app.connection-status.prev', description: 'Label for the previous page of the connection stats tab', }, clientNotResponding: { id: 'app.connection-status.clientNotRespondingWarning', description: 'Text for Client not responding warning', }, }); const propTypes = { closeModal: PropTypes.func.isRequired, intl: PropTypes.shape({ formatMessage: PropTypes.func.isRequired, }).isRequired, }; const isConnectionStatusEmpty = (connectionStatus) => { // Check if it's defined if (!connectionStatus) return true; // Check if it's an array if (!Array.isArray(connectionStatus)) return true; // Check if is empty if (connectionStatus.length === 0) return true; return false; }; class ConnectionStatusComponent extends PureComponent { constructor(props) { super(props); const { intl } = this.props; this.help = Service.getHelp(); this.state = { selectedTab: 0, hasNetworkData: false, copyButtonText: intl.formatMessage(intlMessages.copy), networkData: { user: { }, audio: { audioCurrentUploadRate: 0, audioCurrentDownloadRate: 0, jitter: 0, packetsLost: 0, transportStats: {}, }, video: { videoCurrentUploadRate: 0, videoCurrentDownloadRate: 0, }, }, }; this.setButtonMessage = this.setButtonMessage.bind(this); this.rateInterval = null; this.audioUploadLabel = intl.formatMessage(intlMessages.audioUploadRate); this.audioDownloadLabel = intl.formatMessage(intlMessages.audioDownloadRate); this.videoUploadLabel = intl.formatMessage(intlMessages.videoUploadRate); this.videoDownloadLabel = intl.formatMessage(intlMessages.videoDownloadRate); this.handleSelectTab = this.handleSelectTab.bind(this); } async componentDidMount() { this.startMonitoringNetwork(); } componentWillUnmount() { Meteor.clearInterval(this.rateInterval); } handleSelectTab(tab) { this.setState({ selectedTab: tab, }); } setButtonMessage(msg) { this.setState({ copyButtonText: msg, }); } /** * Start monitoring the network data. * @return {Promise} A Promise that resolves when process started. */ async startMonitoringNetwork() { let previousData = await Service.getNetworkData(); this.rateInterval = Meteor.setInterval(async () => { const data = await Service.getNetworkData(); const { outbound: audioCurrentUploadRate, inbound: audioCurrentDownloadRate, } = Service.calculateBitsPerSecond(data.audio, previousData.audio); const inboundRtp = Service.getDataType(data.audio, 'inbound-rtp')[0]; const jitter = inboundRtp ? inboundRtp.jitterBufferAverage : 0; const packetsLost = inboundRtp ? inboundRtp.packetsLost : 0; const audio = { audioCurrentUploadRate, audioCurrentDownloadRate, jitter, packetsLost, transportStats: data.audio.transportStats, }; const { outbound: videoCurrentUploadRate, inbound: videoCurrentDownloadRate, } = Service.calculateBitsPerSecondFromMultipleData(data.video, previousData.video); const video = { videoCurrentUploadRate, videoCurrentDownloadRate, }; const { user } = data; const networkData = { user, audio, video, }; previousData = data; this.setState({ networkData, hasNetworkData: true, }); }, NETWORK_MONITORING_INTERVAL_MS); } /** * Copy network data to clipboard * @return {Promise} A Promise that is resolved after data is copied. * * */ async copyNetworkData() { const { intl } = this.props; const { networkData, hasNetworkData, } = this.state; if (!hasNetworkData) return; this.setButtonMessage(intl.formatMessage(intlMessages.copied)); const data = JSON.stringify(networkData, null, 2); await navigator.clipboard.writeText(data); this.copyNetworkDataTimeout = setTimeout(() => { this.setButtonMessage(intl.formatMessage(intlMessages.copy)); }, MIN_TIMEOUT); } renderEmpty() { const { intl } = this.props; return ( {intl.formatMessage(intlMessages.empty)} ); } renderConnections() { const { connectionStatus, intl, } = this.props; const { selectedTab } = this.state; if (isConnectionStatusEmpty(connectionStatus)) return this.renderEmpty(); let connections = connectionStatus; if (selectedTab === 1) { connections = connections.filter(conn => conn.you); if (isConnectionStatusEmpty(connections)) return this.renderEmpty(); } return connections.map((conn, index) => { const dateTime = new Date(conn.timestamp); return ( {conn.name.toLowerCase().slice(0, 2)} {conn.name} {conn.offline ? ` (${intl.formatMessage(intlMessages.offline)})` : null} { conn.notResponding && !conn.offline ? ( {intl.formatMessage(intlMessages.clientNotResponding)} ) : null } { conn.timestamp ? : null } ); }); } /** * Render network data , containing information abount current upload and * download rates * @return {Object} The component to be renderized. */ renderNetworkData() { const { enableNetworkStats } = Meteor.settings.public.app; if (!enableNetworkStats) { return null; } const { audioUploadLabel, audioDownloadLabel, videoUploadLabel, videoDownloadLabel, } = this; const { intl, closeModal } = this.props; const { networkData } = this.state; const { audioCurrentUploadRate, audioCurrentDownloadRate, jitter, packetsLost, transportStats, } = networkData.audio; const { videoCurrentUploadRate, videoCurrentDownloadRate, } = networkData.video; let isUsingTurn = '--'; if (transportStats) { switch (transportStats.isUsingTurn) { case true: isUsingTurn = intl.formatMessage(intlMessages.yes); break; case false: isUsingTurn = intl.formatMessage(intlMessages.no); break; default: break; } } return ( closeModal()} /> {`${audioUploadLabel}`} {`${audioCurrentUploadRate}k ↑`} {`${videoUploadLabel}`} {`${videoCurrentUploadRate}k ↑`} {`${intl.formatMessage(intlMessages.jitter)}`} {`${jitter} ms`} {`${intl.formatMessage(intlMessages.usingTurn)}`} {`${isUsingTurn}`} {`${audioDownloadLabel}`} {`${audioCurrentDownloadRate}k ↓`} {`${videoDownloadLabel}`} {`${videoCurrentDownloadRate}k ↓`} {`${intl.formatMessage(intlMessages.lostPackets)}`} {`${packetsLost}`} Content Hidden 0 ); } /** * Renders the clipboard's copy button, for network stats. * @return {Object} - The component to be renderized */ renderCopyDataButton() { const { enableCopyNetworkStatsButton } = Meteor.settings.public.app; if (!enableCopyNetworkStatsButton) { return null; } const { hasNetworkData, copyButtonText } = this.state; return ( {copyButtonText} ); } render() { const { closeModal, intl, } = this.props; const { selectedTab } = this.state; return ( closeModal()} hideBorder contentLabel={intl.formatMessage(intlMessages.ariaTitle)} data-test="connectionStatusModal" > {intl.formatMessage(intlMessages.title)} {intl.formatMessage(intlMessages.title)} {intl.formatMessage(intlMessages.myLogs)} {Service.isModerator() && ( {intl.formatMessage(intlMessages.sessionLogs)} ) } {this.renderNetworkData()} {this.renderCopyDataButton()} {this.renderConnections()} {Service.isModerator() && ( {this.renderConnections()} ) } ); } } ConnectionStatusComponent.propTypes = propTypes; export default injectIntl(ConnectionStatusComponent);