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.6KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209
  1. /* @flow */
  2. import { checkIfCanJoin } from '../base/conference';
  3. import { openDialog } from '../base/dialog';
  4. import {
  5. CANCEL_LOGIN,
  6. CANCEL_WAIT_FOR_OWNER,
  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({ dispatch: Dispatch, getState: 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 {{
  73. * type: CANCEL_WAIT_FOR_OWNER
  74. * }}
  75. */
  76. export function cancelWaitForOwner() {
  77. return {
  78. type: CANCEL_WAIT_FOR_OWNER
  79. };
  80. }
  81. /**
  82. * Opens {@link LoginDialog} which will ask to enter username and password
  83. * for the current conference.
  84. *
  85. * @protected
  86. * @returns {Action}
  87. */
  88. export function _openLoginDialog() {
  89. return openDialog(LoginDialog);
  90. }
  91. /**
  92. * Opens {@link WaitForOnwerDialog}.
  93. *
  94. * @protected
  95. * @returns {Action}
  96. */
  97. export function _openWaitForOwnerDialog() {
  98. return openDialog(WaitForOwnerDialog);
  99. }
  100. /**
  101. * Stops waiting for the conference owner.
  102. *
  103. * @returns {{
  104. * type: STOP_WAIT_FOR_OWNER
  105. * }}
  106. */
  107. export function stopWaitForOwner() {
  108. return {
  109. type: STOP_WAIT_FOR_OWNER
  110. };
  111. }
  112. /**
  113. * Signals that the process of authenticating and upgrading the local
  114. * participant's role has finished either with success or with a specific error.
  115. *
  116. * @param {Object} thenableWithCancel - The process of authenticating and
  117. * upgrading the local participant's role.
  118. * @param {Object} progressOrError - If the value is a {@code number}, then the
  119. * process of authenticating and upgrading the local participant's role has
  120. * succeeded in one of its two/multiple steps; otherwise, it has failed with the
  121. * specified error. Refer to {@link JitsiConference#authenticateAndUpgradeRole}
  122. * in lib-jitsi-meet for the error details.
  123. * @private
  124. * @returns {{
  125. * type: UPGRADE_ROLE_FINISHED,
  126. * error: ?Object,
  127. * progress: number
  128. * }}
  129. */
  130. function _upgradeRoleFinished(
  131. thenableWithCancel,
  132. progressOrError: number | Object) {
  133. let error;
  134. let progress;
  135. if (typeof progressOrError === 'number') {
  136. progress = progressOrError;
  137. } else {
  138. // Make the specified error object resemble an Error instance (to the
  139. // extent that jitsi-meet needs it).
  140. const {
  141. authenticationError,
  142. connectionError,
  143. ...other
  144. } = progressOrError;
  145. error = {
  146. name: authenticationError || connectionError,
  147. ...other
  148. };
  149. progress = authenticationError ? 0.5 : 0;
  150. }
  151. return {
  152. type: UPGRADE_ROLE_FINISHED,
  153. error,
  154. progress,
  155. thenableWithCancel
  156. };
  157. }
  158. /**
  159. * Signals that a process of authenticating and upgrading the local
  160. * participant's role has started.
  161. *
  162. * @param {Object} thenableWithCancel - The process of authenticating and
  163. * upgrading the local participant's role.
  164. * @private
  165. * @returns {{
  166. * type: UPGRADE_ROLE_STARTED,
  167. * thenableWithCancel: Object
  168. * }}
  169. */
  170. function _upgradeRoleStarted(thenableWithCancel) {
  171. return {
  172. type: UPGRADE_ROLE_STARTED,
  173. thenableWithCancel
  174. };
  175. }
  176. /**
  177. * Called when Jicofo rejects to create the room for anonymous user. Will
  178. * start the process of "waiting for the owner" by periodically trying to join
  179. * the room every five seconds.
  180. *
  181. * @returns {function({ dispatch: Dispatch })}
  182. */
  183. export function waitForOwner() {
  184. return (dispatch: Dispatch) =>
  185. dispatch({
  186. type: WAIT_FOR_OWNER,
  187. handler: () => dispatch(checkIfCanJoin()),
  188. timeoutMs: 5000
  189. });
  190. }