feat: on stats parsed callback (#28)

* feat: on stats parsed callback

* chore(release): 1.13.0-tt-212-on-parsed-stats.1 [skip ci]

* fix: change handleNewPeerConnection args

* chore(release): 1.13.0-tt-212-on-parsed-stats.2 [skip ci]

---------

Co-authored-by: vlprojects-bot <info@vlprojects.pro>

Author: panov-va

package.json

@@ -1,6 +1,6 @@
 {
   "name": "webrtc-issue-detector",
-  "version": "1.12.0",
+  "version": "1.13.0-tt-212-on-parsed-stats.2",
   "description": "WebRTC diagnostic tool that detects issues with network or user devices",
   "repository": "git@github.com:VLprojects/webrtc-issue-detector.git",
   "author": "Roman Kuzakov <roman.kuzakov@gmail.com>",

src/WebRTCIssueDetector.ts

@@ -95,12 +95,19 @@ class WebRTCIssueDetector {
       this.calculateNetworkScores(report.stats);
     });
 
-    this.statsReporter.on(PeriodicWebRTCStatsReporter.STATS_REPORTS_PARSED, (data: { timeTaken: number }) => {
+    this.statsReporter.on(PeriodicWebRTCStatsReporter.STATS_REPORTS_PARSED, (data: {
+      timeTaken: number,
+      reportItems: StatsReportItem[],
+    }) => {
       const payload = {
         timeTaken: data.timeTaken,
         ts: Date.now(),
       };
 
+      if (params.onStats) {
+        params.onStats(data.reportItems);
+      }
+
       this.eventEmitter.emit(EventType.StatsParsingFinished, payload);
     });
   }
@@ -133,7 +140,7 @@ class WebRTCIssueDetector {
     this.statsReporter.stopReporting();
   }
 
-  public handleNewPeerConnection(pc: RTCPeerConnection): void {
+  public handleNewPeerConnection(pc: RTCPeerConnection, id?: string): void {
     if (!this.#running && this.autoAddPeerConnections) {
       this.logger.debug('Skip handling new peer connection. Detector is not running', pc);
       return;
@@ -147,7 +154,7 @@ class WebRTCIssueDetector {
 
     this.logger.debug('Handling new peer connection', pc);
 
-    this.compositeStatsParser.addPeerConnection({ pc });
+    this.compositeStatsParser.addPeerConnection({ pc, id });
   }
 
   private emitIssues(issues: IssuePayload[]): void {

src/parser/PeriodicWebRTCStatsReporter.ts

@@ -64,7 +64,7 @@ class PeriodicWebRTCStatsReporter extends EventEmitter {
     const reportItems = await this.compositeStatsParser.parse();
     const timeTaken = Date.now() - startTime;
 
-    this.emit(PeriodicWebRTCStatsReporter.STATS_REPORTS_PARSED, { timeTaken });
+    this.emit(PeriodicWebRTCStatsReporter.STATS_REPORTS_PARSED, { timeTaken, reportItems });
 
     reportItems.forEach((item: StatsReportItem) => {
       this.emit(PeriodicWebRTCStatsReporter.STATS_REPORT_READY_EVENT, item);

src/types.ts

@@ -4,7 +4,7 @@ import { WebRTCIssueEmitter } from './WebRTCIssueEmitter';
 
 export interface WIDWindow {
   wid: {
-    handleNewPeerConnection(pc: RTCPeerConnection): void;
+    handleNewPeerConnection(pc: RTCPeerConnection, id?: string): void;
   },
 }
 
@@ -55,6 +55,7 @@ export type WebRTCIssueDetectorConstructorParams = {
   logger?: Logger,
   onIssues?: (payload: IssueDetectorResult) => void,
   onNetworkScoresUpdated?: (payload: NetworkScores) => void,
+  onStats?: (payload: StatsReportItem[]) => void,
   ignoreSSRCList?: number[],
   getStatsInterval?: number,
   autoAddPeerConnections?: boolean,
@@ -177,6 +178,7 @@ export type ParsedInboundAudioStreamStats = {
   },
   trackId: string,
   transportId: string,
+  trackIdentifier: string,
 };
 
 export type ParsedOutboundAudioStreamStats = {
@@ -268,6 +270,7 @@ export type ParsedInboundVideoStreamStats = {
   }
   trackId: string,
   transportId: string,
+  trackIdentifier: string,
 };
 
 export type ParsedOutboundVideoStreamStats = {

test/parser/PeriodicWebRTCStatsReporter.spec.ts

@@ -102,7 +102,7 @@ describe('wid/lib/PeriodicWebRTCStatsReporter', () => {
     reporter.startReporting();
     await clock.tickAsync(getStatsInterval);
 
-    expect(emitSpy).to.be.calledWith(PeriodicWebRTCStatsReporter.STATS_REPORTS_PARSED, { timeTaken: 0 });
+    expect(emitSpy).to.be.calledWith(PeriodicWebRTCStatsReporter.STATS_REPORTS_PARSED, { timeTaken: 0, reportItems: undefined });
   });
 
   it('should emit stats report ready event for each stats report item', async () => {