Update publish-alpha (#3157)

Co-authored-by: Kaustubh Kumar <[email protected]> Co-authored-by: Eswar Prasad Clinton. A <[email protected]> Co-authored-by: Ravi theja <[email protected]> Co-authored-by: Amar Bathwal <[email protected]>
100mslive · Aug 6, 2024 · d13d261 · d13d261
1 parent 7d0349d
commit d13d261
Show file tree

Hide file tree

Showing 2 changed files with 37 additions and 5 deletions.
diff --git a/packages/hms-video-store/src/analytics/AnalyticsTransport.ts b/packages/hms-video-store/src/analytics/AnalyticsTransport.ts
@@ -9,7 +9,30 @@ export abstract class AnalyticsTransport {
   abstract failedEvents: Queue<AnalyticsEvent>;
   private readonly TAG = '[AnalyticsTransport]';
 
+  private eventCount = 0;
+  private lastResetTime: number = Date.now();
+  private readonly MAX_EVENTS_PER_MINUTE: number = 200;
+  private readonly RESET_INTERVAL_MS: number = 60000;
+
+  private checkRateLimit() {
+    const now = Date.now();
+    if (now - this.lastResetTime >= this.RESET_INTERVAL_MS) {
+      this.eventCount = 0;
+      this.lastResetTime = now;
+    }
+    if (this.eventCount >= this.MAX_EVENTS_PER_MINUTE) {
+      throw new Error('Too many events being sent, please check the implementation.');
+    }
+    this.eventCount++;
+  }
+
   sendEvent(event: AnalyticsEvent) {
+    try {
+      this.checkRateLimit();
+    } catch (e) {
+      HMSLogger.w(this.TAG, 'Rate limit exceeded', e);
+      throw e;
+    }
     try {
       this.sendSingleEvent(event);
       this.flushFailedEvents();

diff --git a/packages/hms-video-store/src/media/tracks/HMSLocalVideoTrack.ts b/packages/hms-video-store/src/media/tracks/HMSLocalVideoTrack.ts
@@ -521,19 +521,28 @@ export class HMSLocalVideoTrack extends HMSVideoTrack {
   private handleVisibilityChange = async () => {
     if (document.visibilityState === 'hidden') {
       this.enabledStateBeforeBackground = this.enabled;
-      this.nativeTrack.enabled = false;
-      HMSLogger.d(this.TAG, 'visibility hidden muting track');
-      this.replaceSenderTrack(this.nativeTrack);
+      if (this.enabled) {
+        const track = await this.replaceTrackWithBlank();
+        await this.replaceSender(track, this.enabled);
+        this.nativeTrack?.stop();
+        this.nativeTrack = track;
+      } else {
+        await this.replaceSender(this.nativeTrack, false);
+      }
       // started interruption event
       this.eventBus.analytics.publish(
         this.sendInterruptionEvent({
           started: true,
         }),
       );
     } else {
-      this.nativeTrack.enabled = this.enabledStateBeforeBackground;
       HMSLogger.d(this.TAG, 'visibility visibile, restoring track state', this.enabledStateBeforeBackground);
-      this.replaceSender(this.nativeTrack, this.enabledStateBeforeBackground);
+      if (this.enabledStateBeforeBackground) {
+        await this.setEnabled(true);
+      } else {
+        this.nativeTrack.enabled = this.enabledStateBeforeBackground;
+        await this.replaceSender(this.nativeTrack, this.enabledStateBeforeBackground);
+      }
       // started interruption event
       this.eventBus.analytics.publish(
         this.sendInterruptionEvent({