@observertc/observer-js - npm Package Compare versions

Comparing version 0.9.6-beta to 0.9.7-beta

lib/common/ReportsCollector.d.ts

@@ -21,3 +21,7 @@ import { CallEventReport, CallMetaReport, ClientDataChannelReport, ClientExtensionReport, IceCandidatePairReport, InboundAudioTrackReport, InboundVideoTrackReport, ObserverEventReport, OutboundAudioTrackReport, OutboundVideoTrackReport, PeerConnectionTransportReport, SfuEventReport, SfuExtensionReport, SfuInboundRtpPadReport, SfuMetaReport, SfuOutboundRtpPadReport, SfuSctpStreamReport, SFUTransportReport } from '@observertc/report-schemas-js';
     addSfuMetaReport(report: SfuMetaReport): void;
+    getCallEventReports(): CallEventReport[];
+    getClientExtensionReports(): ClientExtensionReport[];
+    getSfuEventReports(): SfuEventReport[];
+    getSfuExtensionReports(): SfuExtensionReport[];
 }
 //# sourceMappingURL=ReportsCollector.d.ts.map

lib/common/types.d.ts

@@ -1,2 +0,2 @@
-import { CallEventReport, CallMetaReport, ClientExtensionReport, InboundAudioTrackReport, InboundVideoTrackReport, OutboundAudioTrackReport, OutboundVideoTrackReport, PeerConnectionTransportReport } from '@observertc/report-schemas-js';
+import { CallEventReport, CallMetaReport, ClientExtensionReport, InboundAudioTrackReport, InboundVideoTrackReport, OutboundAudioTrackReport, OutboundVideoTrackReport, PeerConnectionTransportReport, SfuEventReport, SfuExtensionReport } from '@observertc/report-schemas-js';
 import { ObservedCalls } from '../samples/ObservedCalls';
@@ -63,4 +63,8 @@ import { ReportsCollector } from './ReportsCollector';
     readonly reports: ReportsCollector;
+    readonly clientExtensionStats: ClientExtensionReport[];
+    readonly callEvents: CallEventReport[];
+    readonly sfuEvents: SfuEventReport[];
+    readonly sfuExtensionStats: SfuExtensionReport[];
 }
 export type EvaluatorMiddleware = Middleware<EvaluatorContext>;
 //# sourceMappingURL=types.d.ts.map

lib/Evaluator.js

@@ -100,2 +100,6 @@ "use strict";
             closedSfuSctpChannels: [],
+            clientExtensionStats: [],
+            callEvents: [],
+            sfuEvents: [],
+            sfuExtensionStats: [],
         };
@@ -102,0 +106,0 @@ const callOperations = (0, CallOperationsContext_1.createCallOperationContext)(this._clientOperations, evaluatorContext);

lib/middlewares/CommitTransactionMiddleware.d.ts

@@ -0,5 +1,6 @@
+import { ReportsCollector } from '../common/ReportsCollector';
 import { StorageProvider } from '../storages/StorageProvider';
 import { Middleware } from './Middleware';
 import { TransactionContext } from './TransactionContext';
-export declare function createCommitTransactionMiddleware(storageProvider: StorageProvider): Middleware<TransactionContext>;
+export declare function createCommitTransactionMiddleware(storageProvider: StorageProvider, reports: ReportsCollector): Middleware<TransactionContext>;
 //# sourceMappingURL=CommitTransactionMiddleware.d.ts.map

lib/middlewares/CommitTransactionMiddleware.js

@@ -6,3 +6,3 @@ "use strict";
 const logger = (0, logger_1.createLogger)('CallUpdateMiddleware');
-function createCommitTransactionMiddleware(storageProvider) {
+function createCommitTransactionMiddleware(storageProvider, reports) {
     const process = async (transaction) => {
@@ -174,2 +174,6 @@ const { clientStorage, peerConnectionStorage, inboundTrackStorage, outboundTrackStorage, sfuStorage, sfuTransportStorage, sfuInboundRtpPadStorage, sfuOutboundRtpPadStorage, sfuSctpChannelStorage, } = storageProvider;
         }));
+        evaluatorContext.callEvents = [...reports.getCallEventReports()];
+        evaluatorContext.clientExtensionStats = [...reports.getClientExtensionReports()];
+        evaluatorContext.sfuEvents = [...reports.getSfuEventReports()];
+        evaluatorContext.sfuExtensionStats = [...reports.getSfuExtensionReports()];
     };
@@ -176,0 +180,0 @@ const result = async (context, next) => {

lib/middlewares/TransactoinProcessor.js

@@ -13,4 +13,4 @@ "use strict";
     // must be the last one!
-    (0, CommitTransactionMiddleware_1.createCommitTransactionMiddleware)(storageProvider));
+    (0, CommitTransactionMiddleware_1.createCommitTransactionMiddleware)(storageProvider, reportsCollector));
 }
 exports.createTransactionProcessor = createTransactionProcessor;

lib/sinks/ObserverSink.d.ts

@@ -108,2 +108,6 @@ import { CallEventReport, CallMetaReport, ClientDataChannelReport, ClientExtensionReport, IceCandidatePairReport, InboundAudioTrackReport, InboundVideoTrackReport, ObserverEventReport, OutboundAudioTrackReport, OutboundVideoTrackReport, PeerConnectionTransportReport, SfuEventReport, SfuExtensionReport, SfuInboundRtpPadReport, SfuMetaReport, SfuOutboundRtpPadReport, SfuSctpStreamReport, SFUTransportReport } from '@observertc/report-schemas-js';
     addSfuMetaReport(report: SfuMetaReport): void;
+    getCallEventReports(): CallEventReport[];
+    getClientExtensionReports(): ClientExtensionReport[];
+    getSfuEventReports(): SfuEventReport[];
+    getSfuExtensionReports(): SfuExtensionReport[];
     emit(): number;
@@ -110,0 +114,0 @@ private _emit;

lib/sinks/ObserverSink.js

@@ -95,2 +95,14 @@ "use strict";
     }
+    getCallEventReports() {
+        return this._callEventReports;
+    }
+    getClientExtensionReports() {
+        return this._clientExtensionReports;
+    }
+    getSfuEventReports() {
+        return this._sfuEventReports;
+    }
+    getSfuExtensionReports() {
+        return this._sfuExtensionReports;
+    }
     emit() {
@@ -97,0 +109,0 @@ let result = 0;

package.json

 {
   "name": "@observertc/observer-js",
-  "version": "0.9.6-beta",
+  "version": "0.9.7-beta",
   "description": "Server Side NodeJS Library for processing ObserveRTC Samples",
@@ -5,0 +5,0 @@ "main": "lib/index.js",

src/common/ReportsCollector.ts

@@ -41,2 +41,7 @@ import {
 	addSfuMetaReport(report: SfuMetaReport): void;
+
+	getCallEventReports(): CallEventReport[];
+	getClientExtensionReports(): ClientExtensionReport[];
+	getSfuEventReports(): SfuEventReport[];
+	getSfuExtensionReports(): SfuExtensionReport[];
 }

src/common/types.ts

@@ -10,2 +10,4 @@ import {
 	PeerConnectionTransportReport,
+	SfuEventReport,
+	SfuExtensionReport,
 } from '@observertc/report-schemas-js';
@@ -95,2 +97,7 @@ import { ObservedCalls } from '../samples/ObservedCalls';
 	readonly reports: ReportsCollector;
+
+	readonly clientExtensionStats: ClientExtensionReport[],
+	readonly callEvents: CallEventReport[],
+	readonly sfuEvents: SfuEventReport[],
+	readonly sfuExtensionStats: SfuExtensionReport[],
 }
@@ -97,0 +104,0 @@

src/Evaluator.ts

@@ -137,2 +137,7 @@ import { createLogger } from './common/logger';
 			closedSfuSctpChannels: [],
+			
+			clientExtensionStats: [],
+			callEvents: [],
+			sfuEvents: [],
+			sfuExtensionStats: [],
 		};
@@ -139,0 +144,0 @@

src/middlewares/CommitTransactionMiddleware.ts

 import { createLogger } from '../common/logger';
+import { ReportsCollector } from '../common/ReportsCollector';
 import { ObserverStorage } from '../storages/ObserverStorage';
@@ -9,3 +10,6 @@ import { StorageProvider } from '../storages/StorageProvider';
 
-export function createCommitTransactionMiddleware(storageProvider: StorageProvider): Middleware<TransactionContext> {
+export function createCommitTransactionMiddleware(
+	storageProvider: StorageProvider,
+	reports: ReportsCollector,
+): Middleware<TransactionContext> {
 	const process = async (transaction: TransactionContext) => {
@@ -311,2 +315,7 @@ const {
 		);
+
+		evaluatorContext.callEvents = [...reports.getCallEventReports()];
+		evaluatorContext.clientExtensionStats = [...reports.getClientExtensionReports()];
+		evaluatorContext.sfuEvents = [...reports.getSfuEventReports()];
+		evaluatorContext.sfuExtensionStats = [...reports.getSfuExtensionReports()];
 	};
@@ -313,0 +322,0 @@

src/middlewares/TransactoinProcessor.ts

@@ -20,4 +20,4 @@ import { ReportsCollector } from '../common/ReportsCollector';
 		// must be the last one!
-		createCommitTransactionMiddleware(storageProvider)
+		createCommitTransactionMiddleware(storageProvider, reportsCollector)
 	);
 }

src/middlewares/VisitObservedCallsMiddleware.ts

@@ -10,2 +10,3 @@ import { Middleware } from './Middleware';
 import { visitOutboundVideoTrack } from './visitors/visitOutboundVideoTarck';
+import { CallEventReport, ClientExtensionReport } from '@observertc/report-schemas-js';
 
@@ -43,3 +44,3 @@ export const logger = createLogger('VisitObservedCallsMiddleware');
 		const visitedOutboundVideoTrackIds = new Set<string>();
-
+		
 		for (const observedCall of observedCalls.observedCalls()) {
@@ -58,5 +59,10 @@ const { callId, serviceId, roomId } = observedCall;
 				}
+				
+				visitClient(
+					observedClient, 
+					storedClient, 
+					reports, 
+					fetchSamples
+				);
 
-				visitClient(observedClient, storedClient, reports, fetchSamples);
-
 				for (const observedPeerConnection of observedClient.observedPeerConnections()) {
@@ -63,0 +69,0 @@ const { peerConnectionId } = observedPeerConnection;

src/sinks/ObserverSink.ts

@@ -201,2 +201,18 @@ import {
 
+	public getCallEventReports(): CallEventReport[] {
+		return this._callEventReports;
+	}
+
+	public getClientExtensionReports(): ClientExtensionReport[] {
+		return this._clientExtensionReports;
+	}
+
+	public getSfuEventReports(): SfuEventReport[] {
+		return this._sfuEventReports;
+	}
+
+	public getSfuExtensionReports(): SfuExtensionReport[] {
+		return this._sfuExtensionReports;
+	}
+
 	public emit(): number {
@@ -203,0 +219,0 @@ let result = 0;

Fixed alerts

Mixed license

License

(Experimental) Package contains multiple licenses.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

952269

increased by1.46%

Number of low license alerts

0

decreased by-100%

Lines of code

19209

increased by0.39%

No dependency changes