Add RTCEngineSupersededBy event

src/e2ee/E2eeManager.ts

@@ -34,7 +34,6 @@ import { isE2EESupported, isScriptTransformSupported } from './utils';
 
 export interface BaseE2EEManager {
   setup(room: Room): void;
-  setupEngine(engine: RTCEngine): void;
   setParticipantCryptorEnabled(enabled: boolean, participantIdentity: string): void;
   setSifTrailer(trailer: Uint8Array): void;
   on<E extends keyof E2EEManagerCallbacks>(event: E, listener: E2EEManagerCallbacks[E]): this;
@@ -174,6 +173,9 @@ export class E2EEManager
     engine.on(EngineEvent.RTPVideoMapUpdate, (rtpMap) => {
       this.postRTPMap(rtpMap);
     });
+    engine.on(EngineEvent.SupersededBy, (newEngine) => {
+      this.setupEngine(newEngine);
+    });
   }
 
   private setupEventListeners(room: Room, keyProvider: BaseKeyProvider) {

src/room/RTCEngine.ts

@@ -94,8 +94,10 @@ enum PCState {
   Closed,
 }
 
+const EngineEventEmitter = EventEmitter as new () => TypedEventEmitter<EngineEventCallbacks>;
+
 /** @internal */
-export default class RTCEngine extends (EventEmitter as new () => TypedEventEmitter<EngineEventCallbacks>) {
+export default class RTCEngine extends EngineEventEmitter {
   client: SignalClient;
 
   rtcConfig: RTCConfiguration = {};
@@ -1580,6 +1582,7 @@ export type EngineEventCallbacks = {
   offline: () => void;
   signalRequestResponse: (response: RequestResponse) => void;
   signalConnected: (joinResp: JoinResponse) => void;
+  supersededBy: (newEngine: RTCEngine) => void;
 };
 
 function supportOptionalDatachannel(protocol: number | undefined): boolean {

src/room/Room.ts

@@ -517,6 +517,7 @@ class Room extends (EventEmitter as new () => TypedEmitter<RoomEventCallbacks>)
       return;
     }
 
+    const oldEngine = this.engine;
     this.engine = new RTCEngine(this.options);
 
     this.engine
@@ -610,12 +611,7 @@ class Room extends (EventEmitter as new () => TypedEmitter<RoomEventCallbacks>)
         }
       });
 
-    if (this.localParticipant) {
-      this.localParticipant.setupEngine(this.engine);
-    }
-    if (this.e2eeManager) {
-      this.e2eeManager.setupEngine(this.engine);
-    }
+    oldEngine?.emit(EngineEvent.SupersededBy, this.engine);
   }
 
   /**

src/room/events.ts

@@ -606,6 +606,7 @@ export enum EngineEvent {
   SignalRequestResponse = 'signalRequestResponse',
   SignalConnected = 'signalConnected',
   RoomMoved = 'roomMoved',
+  SupersededBy = 'supersededBy',
 }
 
 export enum TrackEvent {

src/room/participant/LocalParticipant.ts

@@ -234,7 +234,7 @@ export default class LocalParticipant extends Participant {
   /**
    * @internal
    */
-  setupEngine(engine: RTCEngine) {
+  private setupEngine(engine: RTCEngine) {
     this.engine = engine;
     this.engine.on(EngineEvent.RemoteMute, (trackSid: string, muted: boolean) => {
       const pub = this.trackPublications.get(trackSid);
@@ -263,7 +263,8 @@ export default class LocalParticipant extends Participant {
       .on(EngineEvent.SubscribedQualityUpdate, this.handleSubscribedQualityUpdate)
       .on(EngineEvent.Closing, this.handleClosing)
       .on(EngineEvent.SignalRequestResponse, this.handleSignalRequestResponse)
-      .on(EngineEvent.DataPacketReceived, this.handleDataPacket);
+      .on(EngineEvent.DataPacketReceived, this.handleDataPacket)
+      .on(EngineEvent.SupersededBy, this.handleNewEngine);
   }
 
   private handleReconnecting = () => {
@@ -337,6 +338,10 @@ export default class LocalParticipant extends Participant {
     }
   };
 
+  private handleNewEngine = (newEngine: RTCEngine) => {
+    this.setupEngine(newEngine);
+  };
+
   /**
    * Sets and updates the metadata of the local participant.
    * Note: this requires `canUpdateOwnMetadata` permission.