jiti-meet/react/features/connection-indicator/statsEmitter.ts

167 lines
5.3 KiB
TypeScript
Raw Normal View History

2017-07-13 18:44:12 +00:00
import _ from 'lodash';
import { IJitsiConference } from '../base/conference/reducer';
import {
JitsiConnectionQualityEvents
} from '../base/lib-jitsi-meet';
/**
* Contains all the callbacks to be notified when stats are updated.
*
* {
* userId: Function[]
2021-11-04 21:10:43 +00:00
* }.
*/
const subscribers: any = {};
interface IStats {
codec?: Object;
framerate?: Object;
resolution?: Object;
}
/**
* A singleton that acts as a pub/sub service for connection stat updates.
*/
const statsEmitter = {
/**
* Have {@code statsEmitter} subscribe to stat updates from a given
* conference.
*
* @param {JitsiConference} conference - The conference for which
* {@code statsEmitter} should subscribe for stat updates.
* @returns {void}
*/
startListeningForStats(conference: IJitsiConference) {
conference.on(JitsiConnectionQualityEvents.LOCAL_STATS_UPDATED,
(stats: IStats) => this._onStatsUpdated(conference.myUserId(), stats));
conference.on(JitsiConnectionQualityEvents.REMOTE_STATS_UPDATED,
(id: string, stats: IStats) => this._emitStatsUpdate(id, stats));
},
/**
* Add a subscriber to be notified when stats are updated for a specified
* user id.
*
* @param {string} id - The user id whose stats updates are of interest.
* @param {Function} callback - The function to invoke when stats for the
* user have been updated.
* @returns {void}
*/
subscribeToClientStats(id: string | undefined, callback: Function) {
if (!id) {
return;
}
if (!subscribers[id]) {
subscribers[id] = [];
}
subscribers[id].push(callback);
},
/**
* Remove a subscriber that is listening for stats updates for a specified
* user id.
*
* @param {string} id - The user id whose stats updates are no longer of
* interest.
* @param {Function} callback - The function that is currently subscribed to
* stat updates for the specified user id.
* @returns {void}
*/
unsubscribeToClientStats(id: string, callback: Function) {
if (!subscribers[id]) {
return;
}
const filteredSubscribers = subscribers[id].filter(
(subscriber: Function) => subscriber !== callback);
if (filteredSubscribers.length) {
subscribers[id] = filteredSubscribers;
} else {
delete subscribers[id];
}
},
/**
* Emit a stat update to all those listening for a specific user's
* connection stats.
*
* @param {string} id - The user id the stats are associated with.
* @param {Object} stats - New connection stats for the user.
* @returns {void}
*/
_emitStatsUpdate(id: string, stats: IStats = {}) {
const callbacks = subscribers[id] || [];
callbacks.forEach((callback: Function) => {
callback(stats);
});
},
/**
* Emit a stat update to all those listening for local stat updates. Will
* also update listeners of remote user stats of changes related to their
* stats.
*
* @param {string} localUserId - The user id for the local user.
* @param {Object} stats - Connection stats for the local user as provided
* by the library.
* @returns {void}
*/
_onStatsUpdated(localUserId: string, stats: IStats) {
const allUserFramerates = stats.framerate || {};
const allUserResolutions = stats.resolution || {};
const allUserCodecs = stats.codec || {};
// FIXME resolution and framerate are maps keyed off of user ids with
// stat values. Receivers of stats expect resolution and framerate to
// be primitives, not maps, so here we override the 'lib-jitsi-meet'
// stats objects.
const modifiedLocalStats = Object.assign({}, stats, {
framerate: allUserFramerates[localUserId as keyof typeof allUserFramerates],
resolution: allUserResolutions[localUserId as keyof typeof allUserResolutions],
codec: allUserCodecs[localUserId as keyof typeof allUserCodecs]
});
this._emitStatsUpdate(localUserId, modifiedLocalStats);
2017-07-13 18:44:12 +00:00
// Get all the unique user ids from the framerate and resolution stats
// and update remote user stats as needed.
const framerateUserIds = Object.keys(allUserFramerates);
const resolutionUserIds = Object.keys(allUserResolutions);
const codecUserIds = Object.keys(allUserCodecs);
2017-07-13 18:44:12 +00:00
_.union(framerateUserIds, resolutionUserIds, codecUserIds)
.filter(id => id !== localUserId)
.forEach(id => {
const remoteUserStats: IStats = {};
2017-07-13 18:44:12 +00:00
const framerate = allUserFramerates[id as keyof typeof allUserFramerates];
if (framerate) {
2017-07-13 18:44:12 +00:00
remoteUserStats.framerate = framerate;
}
const resolution = allUserResolutions[id as keyof typeof allUserResolutions];
if (resolution) {
2017-07-13 18:44:12 +00:00
remoteUserStats.resolution = resolution;
}
const codec = allUserCodecs[id as keyof typeof allUserCodecs];
if (codec) {
remoteUserStats.codec = codec;
}
2017-07-13 18:44:12 +00:00
this._emitStatsUpdate(id, remoteUserStats);
});
}
};
export default statsEmitter;