feat: re-apply plugins on migration

100mslive · Aug 1, 2024 · 2a64652 · 2a64652
1 parent 8e0dd7d
commit 2a64652
Show file tree

Hide file tree

Showing 5 changed files with 21 additions and 5 deletions.
diff --git a/packages/hms-video-store/src/media/tracks/HMSLocalAudioTrack.ts b/packages/hms-video-store/src/media/tracks/HMSLocalAudioTrack.ts
@@ -65,14 +65,21 @@ export class HMSLocalAudioTrack extends HMSAudioTrack {
   }
 
   clone(stream?: HMSLocalStream) {
-    return new HMSLocalAudioTrack(
+    const track = new HMSLocalAudioTrack(
       stream || (this.stream as HMSLocalStream).clone(),
       this.nativeTrack.clone(),
       this.source!,
       this.eventBus,
       this.settings,
       this.room,
     );
+
+    if (this.pluginsManager.pluginsMap.size > 0) {
+      this.pluginsManager.pluginsMap.forEach(value => {
+        track.addPlugin(value);
+      });
+    }
+    return track;
   }
 
   getManuallySelectedDeviceId() {

diff --git a/packages/hms-video-store/src/media/tracks/HMSLocalVideoTrack.ts b/packages/hms-video-store/src/media/tracks/HMSLocalVideoTrack.ts
@@ -90,14 +90,23 @@ export class HMSLocalVideoTrack extends HMSVideoTrack {
   }
 
   clone(stream?: HMSLocalStream) {
-    return new HMSLocalVideoTrack(
+    const track = new HMSLocalVideoTrack(
       stream || (this.stream as HMSLocalStream).clone(),
       this.nativeTrack.clone(),
       this.source!,
       this.eventBus,
       this.settings,
       this.room,
     );
+    if (this.pluginsManager.pluginsMap.size > 0) {
+      this.pluginsManager.pluginsMap.forEach(value => {
+        track.addPlugin(value);
+      });
+    }
+    if (this.mediaStreamPluginsManager.plugins.size > 0) {
+      track.addStreamPlugins(Array.from(this.mediaStreamPluginsManager.plugins));
+    }
+    return track;
   }
 
   /** @internal */

diff --git a/packages/hms-video-store/src/plugins/audio/HMSAudioPluginsManager.ts b/packages/hms-video-store/src/plugins/audio/HMSAudioPluginsManager.ts
@@ -32,7 +32,7 @@ export class HMSAudioPluginsManager {
   private readonly TAG = '[AudioPluginsManager]';
   private readonly hmsTrack: HMSLocalAudioTrack;
   // Map maintains the insertion order
-  private readonly pluginsMap: Map<string, HMSAudioPlugin>;
+  readonly pluginsMap: Map<string, HMSAudioPlugin>;
   private audioContext?: AudioContext;
 
   private sourceNode?: MediaStreamAudioSourceNode;

diff --git a/packages/hms-video-store/src/plugins/video/HMSMediaStreamPluginsManager.ts b/packages/hms-video-store/src/plugins/video/HMSMediaStreamPluginsManager.ts
@@ -8,7 +8,7 @@ import HMSLogger from '../../utils/logger';
 export class HMSMediaStreamPluginsManager {
   private readonly TAG = '[MediaStreamPluginsManager]';
   private analytics: VideoPluginsAnalytics;
-  private plugins: Set<HMSMediaStreamPlugin>;
+  readonly plugins: Set<HMSMediaStreamPlugin>;
   private room?: Room;
 
   constructor(eventBus: EventBus, room?: Room) {

diff --git a/packages/hms-video-store/src/plugins/video/HMSVideoPluginsManager.ts b/packages/hms-video-store/src/plugins/video/HMSVideoPluginsManager.ts
@@ -47,7 +47,7 @@ export class HMSVideoPluginsManager {
   private pluginsLoopRunning = false;
   private pluginsLoopState: 'paused' | 'running' = 'paused';
   private readonly hmsTrack: HMSLocalVideoTrack;
-  private readonly pluginsMap: Map<string, HMSVideoPlugin>; // plugin names to their instance mapping
+  readonly pluginsMap: Map<string, HMSVideoPlugin>; // plugin names to their instance mapping
   private inputVideo?: HTMLVideoElement;
   private inputCanvas?: CanvasElement;
   private outputCanvas?: CanvasElement;