/* eslint-disable lines-around-comment */ import _ from 'lodash'; import { AnyAction } from 'redux'; import { IStore } from '../../app/types'; import { PREJOIN_INITIALIZED } from '../../prejoin/actionTypes'; import { setPrejoinPageVisibility } from '../../prejoin/actions'; import { APP_WILL_MOUNT } from '../app/actionTypes'; import { setAudioOnly } from '../audio-only/actions'; import { SET_LOCATION_URL } from '../connection/actionTypes'; // minimize imports to avoid circular imports import { getJwtName } from '../jwt/functions'; import { participantUpdated } from '../participants/actions'; import { getLocalParticipant } from '../participants/functions'; import MiddlewareRegistry from '../redux/MiddlewareRegistry'; import { parseURLParams } from '../util/parseURLParams'; import { SETTINGS_UPDATED } from './actionTypes'; import { updateSettings } from './actions'; // @ts-ignore import { handleCallIntegrationChange, handleCrashReportingChange } from './functions'; import { ISettingsState } from './reducer'; /** * The middleware of the feature base/settings. Distributes changes to the state * of base/settings to the states of other features computed from the state of * base/settings. * * @param {Store} store - The redux store. * @returns {Function} */ MiddlewareRegistry.register(store => next => action => { const result = next(action); switch (action.type) { case APP_WILL_MOUNT: _initializeCallIntegration(store); _initializeShowPrejoin(store); break; case PREJOIN_INITIALIZED: { _maybeUpdateDisplayName(store); break; } case SETTINGS_UPDATED: _maybeHandleCallIntegrationChange(action); _maybeSetAudioOnly(store, action); _updateLocalParticipant(store, action); _maybeCrashReportingChange(action); break; case SET_LOCATION_URL: _updateLocalParticipantFromUrl(store); break; } return result; }); /** * Overwrites the showPrejoin flag based on cached used selection for showing prejoin screen. * * @param {Store} store - The redux store. * @private * @returns {void} */ function _initializeShowPrejoin({ dispatch, getState }: IStore) { const { userSelectedSkipPrejoin } = getState()['features/base/settings']; if (userSelectedSkipPrejoin) { dispatch(setPrejoinPageVisibility(false)); } } /** * Initializes the audio device handler based on the `disableCallIntegration` setting. * * @param {Store} store - The redux store. * @private * @returns {void} */ function _initializeCallIntegration({ getState }: IStore) { const { disableCallIntegration } = getState()['features/base/settings']; if (typeof disableCallIntegration === 'boolean') { handleCallIntegrationChange(disableCallIntegration); } } /** * Maps the settings field names to participant names where they don't match. * Currently there is only one such field, but may be extended in the future. * * @private * @param {string} settingsField - The name of the settings field to map. * @returns {string} */ function _mapSettingsFieldToParticipant(settingsField: string) { switch (settingsField) { case 'displayName': return 'name'; } return settingsField; } /** * Handles a change in the `disableCallIntegration` setting. * * @param {Object} action - The redux action. * @private * @returns {void} */ function _maybeHandleCallIntegrationChange({ settings: { disableCallIntegration } }: { settings: Partial; }) { if (typeof disableCallIntegration === 'boolean') { handleCallIntegrationChange(disableCallIntegration); } } /** * Handles a change in the `disableCrashReporting` setting. * * @param {Object} action - The redux action. * @private * @returns {void} */ function _maybeCrashReportingChange({ settings: { disableCrashReporting } }: { settings: Partial; }) { if (typeof disableCrashReporting === 'boolean') { handleCrashReportingChange(disableCrashReporting); } } /** * Updates {@code startAudioOnly} flag if it's updated in the settings. * * @param {Store} store - The redux store. * @param {Object} action - The redux action. * @private * @returns {void} */ function _maybeSetAudioOnly( { dispatch }: IStore, { settings: { startAudioOnly } }: { settings: Partial; }) { if (typeof startAudioOnly === 'boolean') { dispatch(setAudioOnly(startAudioOnly)); } } /** * Updates the display name to the one in JWT if there is one. * * @param {Store} store - The redux store. * @private * @returns {void} */ function _maybeUpdateDisplayName({ dispatch, getState }: IStore) { const state = getState(); const hasJwt = Boolean(state['features/base/jwt'].jwt); if (hasJwt) { const displayName = getJwtName(state); if (displayName) { dispatch(updateSettings({ displayName })); } } } /** * Updates the local participant according to settings changes. * * @param {Store} store - The redux store. * @param {Object} action - The dispatched action. * @private * @returns {void} */ function _updateLocalParticipant({ dispatch, getState }: IStore, action: AnyAction) { const { settings } = action; const localParticipant = getLocalParticipant(getState()); const newLocalParticipant = { ...localParticipant }; for (const key in settings) { if (settings.hasOwnProperty(key)) { newLocalParticipant[_mapSettingsFieldToParticipant(key) as keyof typeof newLocalParticipant] = settings[key]; } } dispatch(participantUpdated({ ...newLocalParticipant, id: newLocalParticipant.id ?? '' })); } /** * Returns the userInfo set in the URL. * * @param {Store} store - The redux store. * @private * @returns {void} */ function _updateLocalParticipantFromUrl({ dispatch, getState }: IStore) { const urlParams = parseURLParams(getState()['features/base/connection'].locationURL ?? ''); const urlEmail = urlParams['userInfo.email']; const urlDisplayName = urlParams['userInfo.displayName']; if (!urlEmail && !urlDisplayName) { return; } const localParticipant = getLocalParticipant(getState()); if (localParticipant) { const displayName = _.escape(urlDisplayName); const email = _.escape(urlEmail); dispatch(participantUpdated({ ...localParticipant, email, name: displayName })); dispatch(updateSettings({ displayName, email })); } }