2017-10-09 15:03:02 +00:00
|
|
|
// @flow
|
|
|
|
|
2018-07-20 18:19:26 +00:00
|
|
|
import { CONFERENCE_JOINED } from '../base/conference';
|
2016-10-05 14:36:59 +00:00
|
|
|
import {
|
|
|
|
DOMINANT_SPEAKER_CHANGED,
|
|
|
|
PARTICIPANT_JOINED,
|
|
|
|
PARTICIPANT_LEFT,
|
2018-05-11 17:34:39 +00:00
|
|
|
PIN_PARTICIPANT,
|
|
|
|
getLocalParticipant
|
2016-10-05 14:36:59 +00:00
|
|
|
} from '../base/participants';
|
|
|
|
import { MiddlewareRegistry } from '../base/redux';
|
2020-09-09 21:14:53 +00:00
|
|
|
import { isTestModeEnabled } from '../base/testing';
|
2016-10-05 14:36:59 +00:00
|
|
|
import {
|
|
|
|
getTrackByJitsiTrack,
|
|
|
|
TRACK_ADDED,
|
|
|
|
TRACK_REMOVED,
|
|
|
|
TRACK_UPDATED
|
|
|
|
} from '../base/tracks';
|
|
|
|
|
2021-06-04 21:09:45 +00:00
|
|
|
import { selectParticipant, selectParticipantInLargeVideo } from './actions.any';
|
2020-09-09 21:14:53 +00:00
|
|
|
import logger from './logger';
|
2016-10-05 14:36:59 +00:00
|
|
|
|
2020-06-04 14:09:13 +00:00
|
|
|
import './subscriber';
|
|
|
|
|
2016-10-05 14:36:59 +00:00
|
|
|
/**
|
|
|
|
* Middleware that catches actions related to participants and tracks and
|
|
|
|
* dispatches an action to select a participant depicted by LargeVideo.
|
|
|
|
*
|
|
|
|
* @param {Store} store - Redux store.
|
|
|
|
* @returns {Function}
|
|
|
|
*/
|
|
|
|
MiddlewareRegistry.register(store => next => action => {
|
|
|
|
const result = next(action);
|
|
|
|
|
|
|
|
switch (action.type) {
|
2018-05-11 17:34:39 +00:00
|
|
|
case DOMINANT_SPEAKER_CHANGED: {
|
2020-09-09 21:14:53 +00:00
|
|
|
const state = store.getState();
|
|
|
|
const localParticipant = getLocalParticipant(state);
|
|
|
|
|
|
|
|
if (isTestModeEnabled(state)) {
|
|
|
|
logger.info(`Dominant speaker changed event for: ${action.participant.id}`);
|
|
|
|
}
|
2018-05-11 17:34:39 +00:00
|
|
|
|
|
|
|
if (localParticipant && localParticipant.id !== action.participant.id) {
|
|
|
|
store.dispatch(selectParticipantInLargeVideo());
|
|
|
|
}
|
|
|
|
|
|
|
|
break;
|
|
|
|
}
|
2016-10-05 14:36:59 +00:00
|
|
|
case PARTICIPANT_JOINED:
|
|
|
|
case PARTICIPANT_LEFT:
|
|
|
|
case PIN_PARTICIPANT:
|
|
|
|
case TRACK_ADDED:
|
|
|
|
case TRACK_REMOVED:
|
|
|
|
store.dispatch(selectParticipantInLargeVideo());
|
|
|
|
break;
|
|
|
|
|
2019-09-18 21:09:52 +00:00
|
|
|
case CONFERENCE_JOINED:
|
|
|
|
// Ensure a participant is selected on conference join. This addresses
|
|
|
|
// the case where video tracks were received before CONFERENCE_JOINED
|
|
|
|
// fired; without the conference selection may not happen.
|
|
|
|
store.dispatch(selectParticipant());
|
|
|
|
break;
|
|
|
|
|
2017-10-09 15:03:02 +00:00
|
|
|
case TRACK_UPDATED:
|
2016-10-05 14:36:59 +00:00
|
|
|
// In order to minimize re-calculations, we need to select participant
|
|
|
|
// only if the videoType of the current participant rendered in
|
|
|
|
// LargeVideo has changed.
|
|
|
|
if ('videoType' in action.track) {
|
|
|
|
const state = store.getState();
|
|
|
|
const track
|
|
|
|
= getTrackByJitsiTrack(
|
|
|
|
state['features/base/tracks'],
|
|
|
|
action.track.jitsiTrack);
|
2017-01-17 14:44:50 +00:00
|
|
|
const participantId = state['features/large-video'].participantId;
|
2016-10-05 14:36:59 +00:00
|
|
|
|
2016-10-25 16:43:15 +00:00
|
|
|
(track.participantId === participantId)
|
|
|
|
&& store.dispatch(selectParticipant());
|
2016-10-05 14:36:59 +00:00
|
|
|
}
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
|
|
|
|
return result;
|
|
|
|
});
|