You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

middleware.js 3.0KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104
  1. // @flow
  2. import { updateConfig } from '../base/config';
  3. import { SET_AUDIO_MUTED, SET_VIDEO_MUTED } from '../base/media';
  4. import { MiddlewareRegistry } from '../base/redux';
  5. import { updateSettings } from '../base/settings';
  6. import {
  7. getLocalVideoTrack,
  8. replaceLocalTrack,
  9. TRACK_ADDED,
  10. TRACK_NO_DATA_FROM_SOURCE
  11. } from '../base/tracks';
  12. import { PREJOIN_START_CONFERENCE } from './actionTypes';
  13. import {
  14. setDeviceStatusOk,
  15. setDeviceStatusWarning,
  16. setPrejoinPageVisibility
  17. } from './actions';
  18. import { isPrejoinPageVisible } from './functions';
  19. declare var APP: Object;
  20. /**
  21. * The redux middleware for {@link PrejoinPage}.
  22. *
  23. * @param {Store} store - The redux store.
  24. * @returns {Function}
  25. */
  26. MiddlewareRegistry.register(store => next => async action => {
  27. switch (action.type) {
  28. case PREJOIN_START_CONFERENCE: {
  29. const { getState, dispatch } = store;
  30. const state = getState();
  31. const { userSelectedSkipPrejoin } = state['features/prejoin'];
  32. const localVideoTrack = getLocalVideoTrack(state['features/base/tracks']);
  33. const { options } = action;
  34. options && store.dispatch(updateConfig(options));
  35. userSelectedSkipPrejoin && dispatch(updateSettings({
  36. userSelectedSkipPrejoin
  37. }));
  38. if (localVideoTrack?.muted) {
  39. await dispatch(replaceLocalTrack(localVideoTrack.jitsiTrack, null));
  40. }
  41. const jitsiTracks = getState()['features/base/tracks']
  42. .map(t => t.jitsiTrack)
  43. .filter(t => Boolean(t)); // Filter out GUM in progress tracks...
  44. dispatch(setPrejoinPageVisibility(false));
  45. APP.conference.prejoinStart(jitsiTracks);
  46. break;
  47. }
  48. case SET_AUDIO_MUTED: {
  49. if (isPrejoinPageVisible(store.getState())) {
  50. store.dispatch(updateSettings({
  51. startWithAudioMuted: Boolean(action.muted)
  52. }));
  53. }
  54. break;
  55. }
  56. case SET_VIDEO_MUTED: {
  57. if (isPrejoinPageVisible(store.getState())) {
  58. store.dispatch(updateSettings({
  59. startWithVideoMuted: Boolean(action.muted)
  60. }));
  61. }
  62. break;
  63. }
  64. case TRACK_ADDED:
  65. case TRACK_NO_DATA_FROM_SOURCE: {
  66. const state = store.getState();
  67. if (isPrejoinPageVisible(state)) {
  68. const { track: { jitsiTrack: track } } = action;
  69. const { deviceStatusType, deviceStatusText } = state['features/prejoin'];
  70. if (!track.isAudioTrack()) {
  71. break;
  72. }
  73. if (track.isReceivingData()) {
  74. if (deviceStatusType === 'warning'
  75. && deviceStatusText === 'prejoin.audioDeviceProblem') {
  76. store.dispatch(setDeviceStatusOk('prejoin.lookGood'));
  77. }
  78. } else if (deviceStatusType === 'ok') {
  79. store.dispatch(setDeviceStatusWarning('prejoin.audioDeviceProblem'));
  80. }
  81. }
  82. break;
  83. }
  84. }
  85. return next(action);
  86. });