100mslive · raviteja83 · Jul 31, 2024 · Jul 24, 2024 · Jul 24, 2024 · Jul 24, 2024
diff --git a/examples/prebuilt-react-integration/index.html b/examples/prebuilt-react-integration/index.html
@@ -1,4 +1,4 @@
-<!doctype html>
+<!DOCTYPE html>
 <html lang="en">
   <head>
     <meta charset="UTF-8" />

diff --git a/packages/hms-video-store/src/analytics/AnalyticsEventFactory.ts b/packages/hms-video-store/src/analytics/AnalyticsEventFactory.ts
@@ -256,6 +256,18 @@ export default class AnalyticsEventFactory {
       level: AnalyticsEventLevel.INFO,
     });
   }
+
+  static interrupion(started: boolean, type: string, deviceInfo: Partial<MediaDeviceInfo>) {
+    return new AnalyticsEvent({
+      name: `${started ? 'interruption.start' : 'interruption.stop'}`,
+      level: AnalyticsEventLevel.INFO,
+      properties: {
+        type,
+        ...deviceInfo,
+      },
+    });
+  }
+
   private static eventNameFor(name: string, ok: boolean) {
     const suffix = ok ? 'success' : 'failed';
     return `${name}.${suffix}`;

diff --git a/packages/hms-video-store/src/audio-sink-manager/AudioSinkManager.ts b/packages/hms-video-store/src/audio-sink-manager/AudioSinkManager.ts
@@ -116,13 +116,22 @@ export class AudioSinkManager {
 
   private handleAudioPaused = async (event: any) => {
     // this means the audio paused because of external factors(headset removal, incoming phone call)
-    HMSLogger.d(this.TAG, 'Audio Paused', event.target.id);
     const audioTrack = this.store.getTrackById(event.target.id);
     if (audioTrack) {
       this.autoPausedTracks.add(audioTrack as HMSRemoteAudioTrack);
+      // started interruption event
+      audioTrack.sendInterruptionEvent(true, true);
     }
   };
 
+  private handleAudioPlay = async (event: any) => {
+    // this means the audio replayed because of external factors(headset removal, incoming phone call)
+    const audioTrack = this.store.getTrackById(event.target.id);
+    if (audioTrack) {
+      // stopped interruption event
+      audioTrack.sendInterruptionEvent(false, true);
+    }
+  };
   private handleTrackUpdate = ({ track }: { track: HMSRemoteAudioTrack; enabled: boolean }) => {
     HMSLogger.d(this.TAG, 'Track updated', `${track}`);
   };
@@ -140,6 +149,7 @@ export class AudioSinkManager {
     audioEl.style.display = 'none';
     audioEl.id = track.trackId;
     audioEl.addEventListener('pause', this.handleAudioPaused);
+    audioEl.addEventListener('play', this.handleAudioPlay);
 
     audioEl.onerror = async () => {
       HMSLogger.e(this.TAG, 'error on audio element', audioEl.error);
@@ -259,6 +269,7 @@ export class AudioSinkManager {
     if (audioEl) {
       HMSLogger.d(this.TAG, 'removing audio element', `${track}`);
       audioEl.removeEventListener('pause', this.handleAudioPaused);
+      audioEl.removeEventListener('play', this.handleAudioPlay);
       audioEl.srcObject = null;
       audioEl.remove();
       track.setAudioElement(null);

diff --git a/packages/hms-video-store/src/media/tracks/HMSLocalAudioTrack.ts b/packages/hms-video-store/src/media/tracks/HMSLocalAudioTrack.ts
@@ -76,6 +76,10 @@ export class HMSLocalAudioTrack extends HMSAudioTrack {
   private handleVisibilityChange = async () => {
     if (document.visibilityState === 'visible') {
       await this.replaceTrackWith(this.settings);
+      this.sendInterruptionEvent(false);
+    } else {
+      // started interruption event
+      this.sendInterruptionEvent(true);
     }
   };
 

diff --git a/packages/hms-video-store/src/media/tracks/HMSLocalVideoTrack.ts b/packages/hms-video-store/src/media/tracks/HMSLocalVideoTrack.ts
@@ -499,9 +499,13 @@ export class HMSLocalVideoTrack extends HMSVideoTrack {
       this.enabledStateBeforeBackground = this.enabled;
       this.nativeTrack.enabled = false;
       this.replaceSenderTrack(this.nativeTrack);
+      // started interruption event
+      this.sendInterruptionEvent(true);
     } else {
       this.nativeTrack.enabled = this.enabledStateBeforeBackground;
       this.replaceSenderTrack(this.processedTrack || this.nativeTrack);
+      // stopped interruption event
+      this.sendInterruptionEvent(false);
     }
     this.eventBus.localVideoEnabled.publish({ enabled: this.nativeTrack.enabled, track: this });
   };

diff --git a/packages/hms-video-store/src/media/tracks/HMSTrack.ts b/packages/hms-video-store/src/media/tracks/HMSTrack.ts
@@ -1,4 +1,5 @@
 import { HMSTrackType } from './HMSTrackType';
+import AnalyticsEventFactory from '../../analytics/AnalyticsEventFactory';
 import { stringifyMediaStreamTrack } from '../../utils/json';
 import HMSLogger from '../../utils/logger';
 import { HMSMediaStream } from '../streams';
@@ -84,7 +85,16 @@ export abstract class HMSTrack {
   protected setFirstTrackId(trackId: string) {
     this.firstTrackId = trackId;
   }
-
+  /**
+   * @internal
+   * It will send event to analytics when interruption start/stop
+   */
+  sendInterruptionEvent(started: boolean, isRemoteAudio = false) {
+    AnalyticsEventFactory.interrupion(started, isRemoteAudio ? 'remote.audio' : this.type, {
+      deviceId: this.nativeTrack.getSettings().deviceId,
+      groupId: this.nativeTrack.getSettings().groupId,
+    });
+  }
   /**
    * @internal
    * take care of -