fix: add subscriber video stats to analyics

100mslive · Feb 22, 2024 · 6d34209 · 6d34209
1 parent 19450a7
commit 6d34209
Show file tree

Hide file tree

Showing 3 changed files with 21 additions and 1 deletion.
diff --git a/packages/hms-video-store/src/analytics/stats/BaseStatsAnalytics.ts b/packages/hms-video-store/src/analytics/stats/BaseStatsAnalytics.ts
@@ -158,6 +158,11 @@ export abstract class RunningTrackAnalytics {
     return latestValue - firstValue;
   }
 
+  protected calculateDifferenceAverage(key: keyof TempPublishStats, round = true) {
+    const avg = this.calculateDifferenceForSample(key) / this.tempStats.length;
+    return round ? Math.round(avg) : avg;
+  }
+
   protected calculateInstancesOfHigh(key: keyof TempPublishStats, threshold: number) {
     const checkStat = this.getLatestStat()[key];
     if (typeof checkStat !== 'number') {

diff --git a/packages/hms-video-store/src/analytics/stats/SubscribeStatsAnalytics.ts b/packages/hms-video-store/src/analytics/stats/SubscribeStatsAnalytics.ts
@@ -96,7 +96,15 @@ class RunningRemoteTrackAnalytics extends RunningTrackAnalytics {
     };
 
     if (latestStat.kind === 'video') {
-      return removeUndefinedFromObject<RemoteAudioSample | RemoteVideoSample>(baseSample);
+      return removeUndefinedFromObject<RemoteAudioSample | RemoteVideoSample>(
+        Object.assign(baseSample, {
+          avg_frames_received_per_sec: this.calculateDifferenceAverage('framesReceived'),
+          avg_frames_dropped_per_sec: this.calculateDifferenceAverage('framesDropped'),
+          avg_frames_decoded_per_sec: this.calculateDifferenceAverage('framesDecoded'),
+          frame_width: this.calculateAverage('frameWidth'),
+          frame_height: this.calculateAverage('frameHeight'),
+        }),
+      );
     } else {
       const audio_concealed_samples =
         (latestStat.concealedSamples || 0) -

diff --git a/packages/hms-video-store/src/analytics/stats/interfaces.ts b/packages/hms-video-store/src/analytics/stats/interfaces.ts
@@ -87,4 +87,11 @@ export interface RemoteVideoSample extends RemoteBaseSample {
   avg_frames_decoded_per_sec?: number;
   total_pli_count?: number;
   total_nack_count?: number;
+  frame_width?: number;
+  frame_height?: number;
+  pause_count?: number;
+  pause_duration_seconds?: number;
+  freeze_count?: number;
+  freeze_duration_seconds?: number;
+  avg_jitter_buffer_delay?: number;
 }