159 lines
4.7 KiB
JavaScript
159 lines
4.7 KiB
JavaScript
import {
|
|
LIB_DISPOSED,
|
|
LIB_INITIALIZED
|
|
} from '../lib-jitsi-meet';
|
|
import {
|
|
AUDIO_MUTED_CHANGED,
|
|
audioMutedChanged,
|
|
CAMERA_FACING_MODE_CHANGED,
|
|
MEDIA_TYPE,
|
|
VIDEO_MUTED_CHANGED,
|
|
videoMutedChanged
|
|
} from '../media';
|
|
import { MiddlewareRegistry } from '../redux';
|
|
|
|
import {
|
|
createLocalTracks,
|
|
destroyLocalTracks
|
|
} from './actions';
|
|
import { TRACK_UPDATED } from './actionTypes';
|
|
import {
|
|
getLocalTrack,
|
|
setTrackMuted
|
|
} from './functions';
|
|
|
|
/**
|
|
* Middleware that captures LIB_INITIALIZED and LIB_DISPOSED actions
|
|
* and respectively creates/destroys local media tracks. Also listens to media-
|
|
* related actions and performs corresponding operations with tracks.
|
|
*
|
|
* @param {Store} store - Redux store.
|
|
* @returns {Function}
|
|
*/
|
|
MiddlewareRegistry.register(store => next => action => {
|
|
switch (action.type) {
|
|
case AUDIO_MUTED_CHANGED:
|
|
_mutedChanged(store, action, MEDIA_TYPE.AUDIO);
|
|
break;
|
|
|
|
case CAMERA_FACING_MODE_CHANGED:
|
|
store.dispatch(
|
|
createLocalTracks({
|
|
devices: [ MEDIA_TYPE.VIDEO ],
|
|
facingMode: action.cameraFacingMode
|
|
})
|
|
);
|
|
break;
|
|
|
|
case LIB_INITIALIZED:
|
|
store.dispatch(createLocalTracks());
|
|
break;
|
|
|
|
case LIB_DISPOSED:
|
|
store.dispatch(destroyLocalTracks());
|
|
break;
|
|
|
|
case TRACK_UPDATED:
|
|
return _trackUpdated(store, next, action);
|
|
|
|
case VIDEO_MUTED_CHANGED:
|
|
_mutedChanged(store, action, MEDIA_TYPE.VIDEO);
|
|
break;
|
|
}
|
|
|
|
return next(action);
|
|
});
|
|
|
|
/**
|
|
* Gets the local track associated with a specific <tt>MEDIA_TYPE</tt> in a
|
|
* specific Redux store.
|
|
*
|
|
* @param {Store} store - The Redux store from which the local track associated
|
|
* with the specified <tt>mediaType</tt> is to be retrieved.
|
|
* @param {MEDIA_TYPE} mediaType - The <tt>MEDIA_TYPE</tt> of the local track to
|
|
* be retrieved from the specified <tt>store</tt>.
|
|
* @private
|
|
* @returns {Track} The local <tt>Track</tt> associated with the specified
|
|
* <tt>mediaType</tt> in the specified <tt>store</tt>.
|
|
*/
|
|
function _getLocalTrack(store, mediaType) {
|
|
return getLocalTrack(store.getState()['features/base/tracks'], mediaType);
|
|
}
|
|
|
|
/**
|
|
* Mutes or unmutes a local track with a specific media type.
|
|
*
|
|
* @param {Store} store - The Redux store in which the specified action is
|
|
* dispatched.
|
|
* @param {Action} action - The Redux action dispatched in the specified store.
|
|
* @param {MEDIA_TYPE} mediaType - The {@link MEDIA_TYPE} of the local track
|
|
* which is being muted or unmuted.
|
|
* @private
|
|
* @returns {void}
|
|
*/
|
|
function _mutedChanged(store, action, mediaType) {
|
|
const localTrack = _getLocalTrack(store, mediaType);
|
|
|
|
localTrack && setTrackMuted(localTrack.jitsiTrack, action.muted);
|
|
}
|
|
|
|
/**
|
|
* Intercepts the action <tt>TRACK_UPDATED</tt> in order to synchronize the
|
|
* muted states of the local tracks of features/base/tracks with the muted
|
|
* states of features/base/media.
|
|
*
|
|
* @param {Store} store - The Redux store in which the specified <tt>action</tt>
|
|
* is being dispatched.
|
|
* @param {Dispatch} next - The Redux dispatch function to dispatch the
|
|
* specified <tt>action</tt> to the specified <tt>store</tt>.
|
|
* @param {Action} action - The Redux action <tt>TRACK_UPDATED</tt> which is
|
|
* being dispatched in the specified <tt>store</tt>.
|
|
* @private
|
|
* @returns {void}
|
|
*/
|
|
function _trackUpdated(store, next, action) {
|
|
// Determine the muted state of the local track before the update.
|
|
const track = action.track;
|
|
let mediaType;
|
|
let oldMuted;
|
|
|
|
if ('muted' in track) {
|
|
// XXX The return value of JitsiTrack.getType() is of type MEDIA_TYPE
|
|
// that happens to be compatible with the type MEDIA_TYPE defined by
|
|
// jitsi-meet-react.
|
|
mediaType = track.jitsiTrack.getType();
|
|
|
|
const localTrack = _getLocalTrack(store, mediaType);
|
|
|
|
if (localTrack) {
|
|
oldMuted = localTrack.muted;
|
|
}
|
|
}
|
|
|
|
const result = next(action);
|
|
|
|
if (typeof oldMuted !== 'undefined') {
|
|
// Determine the muted state of the local track after the update. If the
|
|
// muted states before and after the update differ, then the respective
|
|
// media state should by synchronized.
|
|
const localTrack = _getLocalTrack(store, mediaType);
|
|
|
|
if (localTrack) {
|
|
const newMuted = localTrack.muted;
|
|
|
|
if (oldMuted !== newMuted) {
|
|
switch (mediaType) {
|
|
case MEDIA_TYPE.AUDIO:
|
|
store.dispatch(audioMutedChanged(newMuted));
|
|
break;
|
|
case MEDIA_TYPE.VIDEO:
|
|
store.dispatch(videoMutedChanged(newMuted));
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
return result;
|
|
}
|