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.

actions.js 5.7KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214
  1. // @flow
  2. import { appNavigate } from '../app';
  3. import { checkIfCanJoin, conferenceLeft } from '../base/conference';
  4. import { openDialog } from '../base/dialog';
  5. import {
  6. CANCEL_LOGIN,
  7. STOP_WAIT_FOR_OWNER,
  8. UPGRADE_ROLE_FINISHED,
  9. UPGRADE_ROLE_STARTED,
  10. WAIT_FOR_OWNER
  11. } from './actionTypes';
  12. import { LoginDialog, WaitForOwnerDialog } from './components';
  13. const logger = require('jitsi-meet-logger').getLogger(__filename);
  14. /**
  15. * Initiates authenticating and upgrading the role of the local participant to
  16. * moderator which will allow to create and join a new conference on an XMPP
  17. * password + guest access configuration. Refer to {@link LoginDialog} for more
  18. * info.
  19. *
  20. * @param {string} id - The XMPP user's ID (e.g. user@domain.com).
  21. * @param {string} password - The XMPP user's password.
  22. * @param {JitsiConference} conference - The conference for which the local
  23. * participant's role will be upgraded.
  24. * @returns {Function}
  25. */
  26. export function authenticateAndUpgradeRole(
  27. id: string,
  28. password: string,
  29. conference: Object) {
  30. return (dispatch: Dispatch, getState: Function) => {
  31. const { password: roomPassword }
  32. = getState()['features/base/conference'];
  33. const process
  34. = conference.authenticateAndUpgradeRole({
  35. id,
  36. password,
  37. roomPassword,
  38. onLoginSuccessful() {
  39. // When the login succeeds, the process has completed half
  40. // of its job (i.e. 0.5).
  41. return dispatch(_upgradeRoleFinished(process, 0.5));
  42. }
  43. });
  44. dispatch(_upgradeRoleStarted(process));
  45. process.then(
  46. /* onFulfilled */ () => dispatch(_upgradeRoleFinished(process, 1)),
  47. /* onRejected */ error => {
  48. // The lack of an error signals a cancellation.
  49. if (error.authenticationError || error.connectionError) {
  50. logger.error('authenticateAndUpgradeRole failed', error);
  51. }
  52. dispatch(_upgradeRoleFinished(process, error));
  53. });
  54. return process;
  55. };
  56. }
  57. /**
  58. * Cancels {@ink LoginDialog}.
  59. *
  60. * @returns {{
  61. * type: CANCEL_LOGIN
  62. * }}
  63. */
  64. export function cancelLogin() {
  65. return {
  66. type: CANCEL_LOGIN
  67. };
  68. }
  69. /**
  70. * Cancels {@link WaitForOwnerDialog}. Will navigate back to the welcome page.
  71. *
  72. * @returns {Function}
  73. */
  74. export function cancelWaitForOwner() {
  75. return (dispatch: Dispatch<*>, getState: Function) => {
  76. dispatch(stopWaitForOwner());
  77. const { authRequired } = getState()['features/base/conference'];
  78. if (authRequired) {
  79. dispatch(conferenceLeft(authRequired));
  80. }
  81. dispatch(appNavigate(undefined));
  82. };
  83. }
  84. /**
  85. * Opens {@link LoginDialog} which will ask to enter username and password
  86. * for the current conference.
  87. *
  88. * @protected
  89. * @returns {Action}
  90. */
  91. export function _openLoginDialog() {
  92. return openDialog(LoginDialog);
  93. }
  94. /**
  95. * Opens {@link WaitForOnwerDialog}.
  96. *
  97. * @protected
  98. * @returns {Action}
  99. */
  100. export function _openWaitForOwnerDialog() {
  101. return openDialog(WaitForOwnerDialog);
  102. }
  103. /**
  104. * Stops waiting for the conference owner.
  105. *
  106. * @returns {{
  107. * type: STOP_WAIT_FOR_OWNER
  108. * }}
  109. */
  110. export function stopWaitForOwner() {
  111. return {
  112. type: STOP_WAIT_FOR_OWNER
  113. };
  114. }
  115. /**
  116. * Signals that the process of authenticating and upgrading the local
  117. * participant's role has finished either with success or with a specific error.
  118. *
  119. * @param {Object} thenableWithCancel - The process of authenticating and
  120. * upgrading the local participant's role.
  121. * @param {Object} progressOrError - If the value is a {@code number}, then the
  122. * process of authenticating and upgrading the local participant's role has
  123. * succeeded in one of its two/multiple steps; otherwise, it has failed with the
  124. * specified error. Refer to {@link JitsiConference#authenticateAndUpgradeRole}
  125. * in lib-jitsi-meet for the error details.
  126. * @private
  127. * @returns {{
  128. * type: UPGRADE_ROLE_FINISHED,
  129. * error: ?Object,
  130. * progress: number
  131. * }}
  132. */
  133. function _upgradeRoleFinished(
  134. thenableWithCancel,
  135. progressOrError: number | Object) {
  136. let error;
  137. let progress;
  138. if (typeof progressOrError === 'number') {
  139. progress = progressOrError;
  140. } else {
  141. // Make the specified error object resemble an Error instance (to the
  142. // extent that jitsi-meet needs it).
  143. const {
  144. authenticationError,
  145. connectionError,
  146. ...other
  147. } = progressOrError;
  148. error = {
  149. name: authenticationError || connectionError,
  150. ...other
  151. };
  152. progress = authenticationError ? 0.5 : 0;
  153. }
  154. return {
  155. type: UPGRADE_ROLE_FINISHED,
  156. error,
  157. progress,
  158. thenableWithCancel
  159. };
  160. }
  161. /**
  162. * Signals that a process of authenticating and upgrading the local
  163. * participant's role has started.
  164. *
  165. * @param {Object} thenableWithCancel - The process of authenticating and
  166. * upgrading the local participant's role.
  167. * @private
  168. * @returns {{
  169. * type: UPGRADE_ROLE_STARTED,
  170. * thenableWithCancel: Object
  171. * }}
  172. */
  173. function _upgradeRoleStarted(thenableWithCancel) {
  174. return {
  175. type: UPGRADE_ROLE_STARTED,
  176. thenableWithCancel
  177. };
  178. }
  179. /**
  180. * Called when Jicofo rejects to create the room for anonymous user. Will
  181. * start the process of "waiting for the owner" by periodically trying to join
  182. * the room every five seconds.
  183. *
  184. * @returns {Function}
  185. */
  186. export function waitForOwner() {
  187. return (dispatch: Dispatch) =>
  188. dispatch({
  189. type: WAIT_FOR_OWNER,
  190. handler: () => dispatch(checkIfCanJoin()),
  191. timeoutMs: 5000
  192. });
  193. }