Update publish-alpha

packages/hms-video-store/src/device-manager/DeviceManager.ts

@@ -500,20 +500,25 @@ export class DeviceManager implements HMSDeviceManager {
     if (localAudioTrack.settings.deviceId === externalDeviceID && this.earpieceSelected) {
       return;
     }
-    if (!this.earpieceSelected) {
-      if (bluetoothDevice?.deviceId === externalDeviceID) {
+
+    try {
+      if (!this.earpieceSelected) {
+        if (bluetoothDevice?.deviceId === externalDeviceID) {
+          this.earpieceSelected = true;
+          return;
+        }
+        await localAudioTrack.setSettings({ deviceId: earpiece?.deviceId }, true);
         this.earpieceSelected = true;
-        return;
       }
-      await localAudioTrack.setSettings({ deviceId: earpiece?.deviceId }, true);
-      this.earpieceSelected = true;
-    }
-    await localAudioTrack.setSettings(
-      {
-        deviceId: externalDeviceID,
-      },
-      true,
-    );
+      await localAudioTrack.setSettings(
+        {
+          deviceId: externalDeviceID,
+        },
+        true,
+      );
+    } catch (error) {
+      this.eventBus.error.publish(error as HMSException);
+    }
   };
 
   // eslint-disable-next-line complexity

packages/hms-video-store/src/events/EventBus.ts

@@ -81,4 +81,6 @@ export class EventBus {
   readonly autoplayError = new HMSInternalEvent<HMSException>(HMSEvents.AUTOPLAY_ERROR, this.eventEmitter);
 
   readonly leave = new HMSInternalEvent<HMSException | undefined>(HMSEvents.LEAVE, this.eventEmitter);
+
+  readonly error = new HMSInternalEvent<HMSException>(HMSEvents.ERROR, this.eventEmitter);
 }

packages/hms-video-store/src/media/tracks/HMSLocalAudioTrack.ts

@@ -115,7 +115,11 @@ export class HMSLocalAudioTrack extends HMSAudioTrack {
       );
     } else {
       HMSLogger.d(this.TAG, 'On visibile replacing track as it is not publishing');
-      await this.replaceTrackWith(this.settings);
+      try {
+        await this.replaceTrackWith(this.settings);
+      } catch (error) {
+        this.eventBus.error.publish(error as HMSException);
+      }
       this.eventBus.analytics.publish(
         this.sendInterruptionEvent({
           started: false,
@@ -334,9 +338,13 @@ export class HMSLocalAudioTrack extends HMSAudioTrack {
         reason,
       }),
     );
-    await this.setEnabled(this.enabled);
-    // whatsapp call doesn't seem to send video unmute natively, so use audio unmute to play video
-    this.eventBus.localAudioUnmutedNatively.publish();
+    try {
+      await this.setEnabled(this.enabled);
+      // whatsapp call doesn't seem to send video unmute natively, so use audio unmute to play video
+      this.eventBus.localAudioUnmutedNatively.publish();
+    } catch (error) {
+      this.eventBus.error.publish(error as HMSException);
+    }
   };
 
   private replaceSenderTrack = async () => {
@@ -348,9 +356,7 @@ export class HMSLocalAudioTrack extends HMSAudioTrack {
   };
 
   private shouldReacquireTrack = () => {
-    return (
-      isEmptyTrack(this.nativeTrack) || this.isTrackNotPublishing() || this.audioLevelMonitor?.isSilentThisInstant()
-    );
+    return isEmptyTrack(this.nativeTrack) || this.isTrackNotPublishing();
   };
 
   private buildNewSettings(settings: Partial<HMSAudioTrackSettings>) {

packages/hms-video-store/src/media/tracks/HMSLocalVideoTrack.ts

@@ -5,6 +5,7 @@ import AnalyticsEventFactory from '../../analytics/AnalyticsEventFactory';
 import { DeviceStorageManager } from '../../device-manager/DeviceStorage';
 import { ErrorFactory } from '../../error/ErrorFactory';
 import { HMSAction } from '../../error/HMSAction';
+import { HMSException } from '../../error/HMSException';
 import { EventBus } from '../../events/EventBus';
 import {
   HMSFacingMode,
@@ -587,7 +588,11 @@ export class HMSLocalVideoTrack extends HMSVideoTrack {
     } else {
       HMSLogger.d(this.TAG, 'visibility visible, restoring track state', this.enabledStateBeforeBackground);
       if (this.enabledStateBeforeBackground) {
-        await this.setEnabled(true);
+        try {
+          await this.setEnabled(true);
+        } catch (error) {
+          this.eventBus.error.publish(error as HMSException);
+        }
       }
       // ended interruption event
       this.eventBus.analytics.publish(

packages/hms-video-store/src/sdk/index.ts

@@ -260,6 +260,7 @@ export class HMSSdk implements HMSInterface {
     this.eventBus.localVideoUnmutedNatively.subscribe(this.unpauseRemoteVideoTracks);
     this.eventBus.localAudioUnmutedNatively.subscribe(this.unpauseRemoteVideoTracks);
     this.eventBus.audioPluginFailed.subscribe(this.handleAudioPluginError);
+    this.eventBus.error.subscribe(this.handleError);
   }
 
   private validateJoined(name: string) {
@@ -600,6 +601,17 @@ export class HMSSdk implements HMSInterface {
     this.errorListener?.onError(error);
   };
 
+  /**
+   * This is to handle errors thrown from internal handling of audio video track changes
+   * For example, handling visibility change and making a new gum can throw an error which is currently
+   * unhandled. This will notify the app of the error.
+   * @param {HMSException} error
+   */
+  private handleError = (error: HMSException) => {
+    HMSLogger.e(this.TAG, error);
+    this.errorListener?.onError(error);
+  };
+
   // eslint-disable-next-line complexity
   async join(config: HMSConfig, listener: HMSUpdateListener) {
     validateMediaDevicesExistence();
@@ -696,6 +708,7 @@ export class HMSSdk implements HMSInterface {
     this.eventBus.analytics.unsubscribe(this.sendAnalyticsEvent);
     this.eventBus.localVideoUnmutedNatively.unsubscribe(this.unpauseRemoteVideoTracks);
     this.eventBus.localAudioUnmutedNatively.unsubscribe(this.unpauseRemoteVideoTracks);
+    this.eventBus.error.unsubscribe(this.handleError);
     this.analyticsTimer.cleanup();
     DeviceStorageManager.cleanup();
     this.playlistManager.cleanup();

packages/hms-video-store/src/utils/constants.ts

@@ -56,6 +56,7 @@ export const HMSEvents = {
   AUDIO_TRACK_REMOVED: 'audio-track-removed',
   AUTOPLAY_ERROR: 'autoplay-error',
   LEAVE: 'leave',
+  ERROR: 'error',
 };
 
 export const PROTOCOL_VERSION = '2.5';

yarn.lock

@@ -16864,7 +16864,16 @@ string-natural-compare@^3.0.1:
   resolved "https://registry.yarnpkg.com/string-natural-compare/-/string-natural-compare-3.0.1.tgz#7a42d58474454963759e8e8b7ae63d71c1e7fdf4"
   integrity sha512-n3sPwynL1nwKi3WJ6AIsClwBMa0zTi54fn2oLU6ndfTSIO05xaznjSf15PcBZU6FNWbmN5Q6cxT4V5hGvB4taw==
 
-"string-width-cjs@npm:string-width@^4.2.0", "string-width@^1.0.2 || 2 || 3 || 4", string-width@^4.1.0, string-width@^4.2.0, string-width@^4.2.3:
+"string-width-cjs@npm:string-width@^4.2.0":
+  version "4.2.3"
+  resolved "https://registry.yarnpkg.com/string-width/-/string-width-4.2.3.tgz#269c7117d27b05ad2e536830a8ec895ef9c6d010"
+  integrity sha512-wKyQRQpjJ0sIp62ErSZdGsjMJWsap5oRNihHhu6G7JVO/9jIB6UyevL+tXuOqrng8j/cxKTWyWUwvSTriiZz/g==
+  dependencies:
+    emoji-regex "^8.0.0"
+    is-fullwidth-code-point "^3.0.0"
+    strip-ansi "^6.0.1"
+
+"string-width@^1.0.2 || 2 || 3 || 4", string-width@^4.1.0, string-width@^4.2.0, string-width@^4.2.3:
   version "4.2.3"
   resolved "https://registry.yarnpkg.com/string-width/-/string-width-4.2.3.tgz#269c7117d27b05ad2e536830a8ec895ef9c6d010"
   integrity sha512-wKyQRQpjJ0sIp62ErSZdGsjMJWsap5oRNihHhu6G7JVO/9jIB6UyevL+tXuOqrng8j/cxKTWyWUwvSTriiZz/g==
@@ -16969,7 +16978,14 @@ string_decoder@~1.1.1:
   dependencies:
     safe-buffer "~5.1.0"
 
-"strip-ansi-cjs@npm:strip-ansi@^6.0.1", strip-ansi@^6.0.0, strip-ansi@^6.0.1:
+"strip-ansi-cjs@npm:strip-ansi@^6.0.1":
+  version "6.0.1"
+  resolved "https://registry.yarnpkg.com/strip-ansi/-/strip-ansi-6.0.1.tgz#9e26c63d30f53443e9489495b2105d37b67a85d9"
+  integrity sha512-Y38VPSHcqkFrCpFnQ9vuSXmquuv5oXOKpGeT6aGrr3o3Gc9AlVa6JBfUSOCnbxGGZF+/0ooI7KrPuUSztUdU5A==
+  dependencies:
+    ansi-regex "^5.0.1"
+
+strip-ansi@^6.0.0, strip-ansi@^6.0.1:
   version "6.0.1"
   resolved "https://registry.yarnpkg.com/strip-ansi/-/strip-ansi-6.0.1.tgz#9e26c63d30f53443e9489495b2105d37b67a85d9"
   integrity sha512-Y38VPSHcqkFrCpFnQ9vuSXmquuv5oXOKpGeT6aGrr3o3Gc9AlVa6JBfUSOCnbxGGZF+/0ooI7KrPuUSztUdU5A==
@@ -18325,7 +18341,7 @@ worker-timers@^7.0.40:
     worker-timers-broker "^6.0.95"
     worker-timers-worker "^7.0.59"
 
-"wrap-ansi-cjs@npm:wrap-ansi@^7.0.0", wrap-ansi@^7.0.0:
+"wrap-ansi-cjs@npm:wrap-ansi@^7.0.0":
   version "7.0.0"
   resolved "https://registry.yarnpkg.com/wrap-ansi/-/wrap-ansi-7.0.0.tgz#67e145cff510a6a6984bdf1152911d69d2eb9e43"
   integrity sha512-YVGIj2kamLSTxw6NsZjoBxfSwsn0ycdesmc4p+Q21c5zPuZ1pl+NfxVdxPtdHvmNVOQ6XSYG4AUtyt/Fi7D16Q==
@@ -18343,6 +18359,15 @@ wrap-ansi@^6.0.1, wrap-ansi@^6.2.0:
     string-width "^4.1.0"
     strip-ansi "^6.0.0"
 
+wrap-ansi@^7.0.0:
+  version "7.0.0"
+  resolved "https://registry.yarnpkg.com/wrap-ansi/-/wrap-ansi-7.0.0.tgz#67e145cff510a6a6984bdf1152911d69d2eb9e43"
+  integrity sha512-YVGIj2kamLSTxw6NsZjoBxfSwsn0ycdesmc4p+Q21c5zPuZ1pl+NfxVdxPtdHvmNVOQ6XSYG4AUtyt/Fi7D16Q==
+  dependencies:
+    ansi-styles "^4.0.0"
+    string-width "^4.1.0"
+    strip-ansi "^6.0.0"
+
 wrap-ansi@^8.1.0:
   version "8.1.0"
   resolved "https://registry.yarnpkg.com/wrap-ansi/-/wrap-ansi-8.1.0.tgz#56dc22368ee570face1b49819975d9b9a5ead214"