add extension report and clientEventReport methods

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@observertc/observer-js",
-  "version": "0.40.20",
+  "version": "0.40.22",
   "description": "Server Side NodeJS Library for processing ObserveRTC Samples",
   "main": "lib/index.js",
   "types": "lib/index.d.ts",

src/ObservedCall.ts

@@ -3,6 +3,8 @@ import { ObservedClient, ObservedClientModel } from './ObservedClient';
 import { ObservedOutboundTrack } from './ObservedOutboundTrack';
 import { Observer } from './Observer';
 import { createClientJoinedEventReport } from './common/callEventReports';
+import { PartialBy } from './common/utils';
+import { CallEventReport } from '@observertc/report-schemas-js';
 
 export type ObservedCallModel = {
 	serviceId: string;
@@ -88,6 +90,16 @@ export class ObservedCall<AppData extends Record<string, unknown> = Record<strin
 		this.emit('close');
 	}
 
+	public addEventReport(params: PartialBy<Omit<CallEventReport, 'serviceId' | 'roomId' | 'callId' >, 'timestamp'>) {
+		this.reports.addCallEventReport({
+			...params,
+			serviceId: this.serviceId,
+			roomId: this.roomId,
+			callId: this.callId,
+			timestamp: params.timestamp ?? Date.now(),
+		});
+	}
+
 	public createClient<ClientAppData extends Record<string, unknown> = Record<string, unknown>>(config: ObservedClientModel & { appData: ClientAppData, generateClientJoinedReport?: boolean, joined?: number }) {
 		if (this._closed) throw new Error(`Call ${this.callId} is closed`);
 

src/ObservedClient.ts

@@ -5,11 +5,12 @@ import { ObservedPeerConnection } from './ObservedPeerConnection';
 import { createLogger } from './common/logger';
 import { CallMetaType, createCallMetaReport } from './common/callMetaReports';
 // eslint-disable-next-line camelcase
-import { isValidUuid } from './common/utils';
+import { PartialBy, isValidUuid } from './common/utils';
 import { createClientLeftEventReport } from './common/callEventReports';
 import { CallEventType } from './common/CallEventType';
 import { ObservedSfu } from './ObservedSfu';
 import { ClientIssue } from './monitors/CallSummary';
+import { CallEventReport } from '@observertc/report-schemas-js';
 
 const logger = createLogger('ObservedClient');
 
@@ -214,6 +215,35 @@ export class ObservedClient<AppData extends Record<string, unknown> = Record<str
 		this.emit('close');
 	}
 
+	public addEventReport(params: PartialBy<Omit<CallEventReport, 'serviceId' | 'roomId' | 'callId' | 'clientId' | 'userId' | 'marker'>, 'timestamp'>) {
+		this.reports.addCallEventReport({
+			...params,
+			serviceId: this.serviceId,
+			mediaUnitId: this.mediaUnitId,
+			roomId: this.roomId,
+			callId: this.callId,
+			clientId: this.clientId,
+			userId: this.userId,
+			timestamp: params.timestamp ?? Date.now(),
+			marker: this.marker,
+		});
+	}
+
+	public addExtensionStatsReport(extensionType: string, payload: Record<string, unknown>) {
+		this.reports.addClientExtensionReport({
+			serviceId: this.serviceId,
+			mediaUnitId: this.mediaUnitId,
+			roomId: this.roomId,
+			callId: this.callId,
+			clientId: this.clientId,
+			userId: this.userId,
+			timestamp: Date.now(),
+			extensionType,
+			payload: JSON.stringify(payload),
+			marker: this.marker,
+		});
+	}
+
 	public addIssue(issue: ClientIssue) {
 		try {
 			this.reports.addCallEventReport({

src/ObservedPeerConnection.ts

@@ -3,9 +3,10 @@ import { PeerConnectionTransport } from '@observertc/sample-schemas-js';
 import { ObservedClient } from './ObservedClient';
 import { ObservedInboundTrack, ObservedInboundTrackModel } from './ObservedInboundTrack';
 import { ObservedOutboundTrack, ObservedOutboundTrackModel } from './ObservedOutboundTrack';
-import { PeerConnectionTransportReport } from '@observertc/report-schemas-js';
+import { CallEventReport, PeerConnectionTransportReport } from '@observertc/report-schemas-js';
 import { ObservedICE } from './ObservedICE';
 import { ObservedDataChannel } from './ObservedDataChannel';
+import { PartialBy } from './common/utils';
 
 export type ObservedPeerConnectionEvents = {
 	update: [{
@@ -187,6 +188,21 @@ export class ObservedPeerConnection extends EventEmitter {
 		this.ICE.marker = value;
 	}
 
+	public addEventReport(params: PartialBy<Omit<CallEventReport, 'serviceId' | 'roomId' | 'callId' | 'clientId' | 'userId' | 'peerConnectionId' | 'marker'>, 'timestamp'>) {
+		this.reports.addCallEventReport({
+			...params,
+			serviceId: this.serviceId,
+			mediaUnitId: this.mediaUnitId,
+			roomId: this.roomId,
+			callId: this.callId,
+			clientId: this.clientId,
+			userId: this.client.userId,
+			peerConnectionId: this.peerConnectionId,
+			marker: this.client.marker,
+			timestamp: params.timestamp ?? Date.now(),
+		});
+	}
+
 	public get closed() {
 		return this._closed;
 	}

src/ObservedSfu.ts

@@ -3,6 +3,7 @@ import { Observer } from './Observer';
 import { SfuSample } from '@observertc/sample-schemas-js';
 import { ObservedSfuTransport, ObservedSfuTransportModel } from './ObservedSfuTransport';
 import { SfuEventReport, SfuExtensionReport } from '@observertc/report-schemas-js';
+import { PartialBy } from './common/utils';
 
 export type ObservedSfuModel= {
 	serviceId: string;
@@ -97,6 +98,16 @@ export class ObservedSfu<AppData extends Record<string, unknown> = Record<string
 		this.emit('close');
 	}
 
+	public addEventReport(params: PartialBy<Omit<SfuEventReport, 'serviceId' | 'sfuId' | 'marker'>, 'timestamp'>) {
+		this.reports.addCallEventReport({
+			...params,
+			serviceId: this.serviceId,
+			mediaUnitId: this.mediaUnitId,
+			marker: this.marker,
+			timestamp: params.timestamp ?? Date.now(),
+		});
+	}
+
 	public update(sample: SfuSample) {
 		if (this._closed) throw new Error(`Sfu ${this.sfuId} is closed`);
 		if (sample.sfuId !== this.sfuId) throw new Error(`Sfu ${this.sfuId} is not the same as sample.sfuId`);

src/monitors/CallSummaryMonitor.ts

@@ -30,6 +30,7 @@ export class CallSummaryMonitor extends EventEmitter {
 		public readonly config: CallSummaryMonitorConfig = {},
 	) {
 		super();
+		this.setMaxListeners(Infinity);
 	}
 
 	public addCall(call: ObservedCall) {

src/monitors/TurnUsageMonitor.ts

@@ -53,6 +53,7 @@ export class TurnUsageMonitor extends EventEmitter {
 	private _closed = false;
 	public constructor() {
 		super();
+		this.setMaxListeners(Infinity);
 	}
 
 	public getStats(): TurnStats[] {