feat(JitsiConnection) force reload page on shard changes.

JitsiConference.js

@@ -2906,18 +2906,6 @@ JitsiConference.prototype.isConnectionInterrupted = function() {
         ? this.isP2PConnectionInterrupted : this.isJvbConnectionInterrupted;
 };
 
-/**
- * Handles {@link XMPPEvents.CONNECTION_RESTARTED} event. This happens when the bridge goes down
- * and Jicofo moves conferences away to a different bridge.
- * @param {JingleSessionPC} session
- * @private
- */
-JitsiConference.prototype._onConferenceRestarted = function(session) {
-    if (!session.isP2P && this.options.config.enableForcedReload) {
-        this.eventEmitter.emit(JitsiConferenceEvents.CONFERENCE_FAILED, JitsiConferenceErrors.CONFERENCE_RESTARTED);
-    }
-};
-
 /**
  * Handles {@link XMPPEvents.CONNECTION_INTERRUPTED}
  * @param {JingleSessionPC} session

JitsiConferenceEventManager.js

@@ -193,11 +193,6 @@ JitsiConferenceEventManager.prototype.setupChatRoomListeners = function() {
         XMPPEvents.BRIDGE_DOWN,
         () => Statistics.sendAnalytics(createBridgeDownEvent()));
 
-    chatRoom.addListener(XMPPEvents.CONNECTION_RESTARTED,
-        jingleSession => {
-            conference._onConferenceRestarted(jingleSession);
-        });
-
     this.chatRoomForwarder.forward(XMPPEvents.RESERVATION_ERROR,
         JitsiConferenceEvents.CONFERENCE_FAILED,
         JitsiConferenceErrors.RESERVATION_ERROR);

JitsiConnectionErrors.spec.ts

@@ -10,6 +10,7 @@ describe( "/JitsiConnectionErrors members", () => {
         OTHER_ERROR,
         PASSWORD_REQUIRED,
         SERVER_ERROR,
+        SHARD_CHANGED_ERROR,
         JitsiConnectionErrors,
         ...others
     } = exported;
@@ -30,6 +31,7 @@ describe( "/JitsiConnectionErrors members", () => {
         expect( JitsiConnectionErrors.OTHER_ERROR ).toBe( 'connection.otherError' );
         expect( JitsiConnectionErrors.PASSWORD_REQUIRED ).toBe( 'connection.passwordRequired' );
         expect( JitsiConnectionErrors.SERVER_ERROR ).toBe( 'connection.serverError' );
+        expect( JitsiConnectionErrors.SHARD_CHANGED_ERROR ).toBe( 'connection.shardChangedError' );
     } );
 
     it( "unknown members", () => {

JitsiConnectionErrors.ts

@@ -41,7 +41,12 @@ export enum JitsiConnectionErrors {
      * Indicates that the connection was dropped, because of too many 5xx HTTP
      * errors on BOSH requests.
      */
-    SERVER_ERROR = 'connection.serverError'
+    SERVER_ERROR = 'connection.serverError',
+
+    /**
+     * Indicates that the connection was dropped, because of conference being moved to a new shard.
+     */
+    SHARD_CHANGED_ERROR = 'connection.shardChangedError'
 }
 
 // exported for backward compatibility
@@ -51,3 +56,4 @@ export const NOT_LIVE_ERROR = JitsiConnectionErrors.NOT_LIVE_ERROR;
 export const OTHER_ERROR = JitsiConnectionErrors.OTHER_ERROR;
 export const PASSWORD_REQUIRED = JitsiConnectionErrors.PASSWORD_REQUIRED;
 export const SERVER_ERROR = JitsiConnectionErrors.SERVER_ERROR;
+export const SHARD_CHANGED_ERROR = JitsiConnectionErrors.SHARD_CHANGED_ERROR;

modules/xmpp/xmpp.js

@@ -196,12 +196,19 @@ export default class XMPP extends Listenable {
             };
             /* eslint-enable camelcase */
 
-            this.eventEmitter.emit(
-                JitsiConnectionEvents.CONNECTION_FAILED,
-                JitsiConnectionErrors.OTHER_ERROR,
-                undefined,
-                undefined,
-                details);
+            if (this.options.testing?.enableGracefulReconnect) {
+                this.eventEmitter.emit(
+                    JitsiConnectionEvents.CONNECTION_FAILED,
+                    JitsiConnectionErrors.SHARD_CHANGED_ERROR
+                );
+            } else {
+                this.eventEmitter.emit(
+                    JitsiConnectionEvents.CONNECTION_FAILED,
+                    JitsiConnectionErrors.OTHER_ERROR,
+                    undefined,
+                    undefined,
+                    details);
+            }
         });
 
         this._initStrophePlugins();

service/xmpp/XMPPEvents.spec.ts

@@ -27,7 +27,6 @@ describe( "/service/xmpp/XMPPEvents members", () => {
         expect( XMPPEvents.CONNECTION_INTERRUPTED ).toBe( 'xmpp.connection.interrupted' );
         expect( XMPPEvents.CONNECTION_RESTORED ).toBe( 'xmpp.connection.restored' );
         expect( XMPPEvents.CONNECTION_ICE_FAILED ).toBe( 'xmpp.connection.ice.failed' );
-        expect( XMPPEvents.CONNECTION_RESTARTED ).toBe( 'xmpp.connection.restart' );
         expect( XMPPEvents.CONNECTION_STATUS_CHANGED ).toBe( 'xmpp.connection.status.changed' );
         expect( XMPPEvents.DISPLAY_NAME_CHANGED ).toBe( 'xmpp.display_name_changed' );
         expect( XMPPEvents.EMUC_ROOM_ADDED ).toBe( 'xmpp.emuc_room_added' );

service/xmpp/XMPPEvents.ts

@@ -100,10 +100,6 @@ export enum XMPPEvents {
     // interrupted. This should go to the RTC module.
     CONNECTION_INTERRUPTED = 'xmpp.connection.interrupted',
 
-    // Designates an event indicating that the call has been migrated to a different
-    // bridge and that the client needs to be restarted for a successful transition.
-    CONNECTION_RESTARTED = 'xmpp.connection.restart',
-
     // Designates an event indicating that the media (ICE) connection was
     // restored. This should go to the RTC module.
     CONNECTION_RESTORED = 'xmpp.connection.restored',

types/hand-crafted/service/xmpp/XMPPEvents.d.ts

@@ -14,7 +14,6 @@
   CONNECTION_INTERRUPTED = 'xmpp.connection.interrupted',
   CONNECTION_RESTORED = 'xmpp.connection.restored',
   CONNECTION_ICE_FAILED = 'xmpp.connection.ice.failed',
-  CONNECTION_RESTARTED = 'xmpp.connection.restart',
   CONNECTION_STATUS_CHANGED = 'xmpp.connection.status.changed',
   DISPLAY_NAME_CHANGED = 'xmpp.display_name_changed',
   EMUC_ROOM_ADDED = 'xmpp.emuc_room_added',