@observertc/observer-js - npm Package Compare versions

Comparing version 0.9.14-beta to 0.9.15-beta

lib/middlewares/visitors/visitClient.js

@@ -166,4 +166,22 @@ "use strict";
         }
+        if (clientSample.iceLocalCandidates && 0 < clientSample.iceLocalCandidates.length) {
+            for (const iceLocalCandidate of clientSample.iceLocalCandidates) {
+                const callMetaReport = (0, callMetaReports_1.createCallMetaReport)(serviceId, mediaUnitId, roomId, callId, clientId, {
+                    type: callMetaReports_1.CallMetaType.ICE_LOCAL_CANDIDATE,
+                    payload: iceLocalCandidate,
+                }, userId);
+                reports.addCallMetaReport(callMetaReport);
+            }
+        }
+        if (clientSample.iceRemoteCandidates && 0 < clientSample.iceRemoteCandidates.length) {
+            for (const iceRemoteCandidate of clientSample.iceRemoteCandidates) {
+                const callMetaReport = (0, callMetaReports_1.createCallMetaReport)(serviceId, mediaUnitId, roomId, callId, clientId, {
+                    type: callMetaReports_1.CallMetaType.ICE_REMOTE_CANDIDATE,
+                    payload: iceRemoteCandidate,
+                }, userId);
+                reports.addCallMetaReport(callMetaReport);
+            }
+        }
     }
 }
 exports.visitClient = visitClient;

lib/processes/joinClientProcess.js

@@ -90,6 +90,6 @@ "use strict";
         for (const [clientId, client] of newClients) {
-            const { serviceId, mediaUnitId, roomId, callId, clientId, 
+            const { serviceId, mediaUnitId, roomId, callId, clientId: savedClientId, 
             // timeZoneId,
             marker, joined, } = client;
-            if (!serviceId || !mediaUnitId || !roomId || !callId || !clientId) {
+            if (!serviceId || !mediaUnitId || !roomId || !callId || !savedClientId) {
                 continue;
@@ -96,0 +96,0 @@ }

package.json

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

src/middlewares/visitors/visitClient.ts

@@ -204,3 +204,23 @@ import { ObservedClient } from '../../samples/ObservedClient';
 		}
+
+		if (clientSample.iceLocalCandidates && 0 < clientSample.iceLocalCandidates.length) {
+			for (const iceLocalCandidate of clientSample.iceLocalCandidates) {
+				const callMetaReport = createCallMetaReport(serviceId, mediaUnitId, roomId, callId, clientId, {
+					type: CallMetaType.ICE_LOCAL_CANDIDATE,
+					payload: iceLocalCandidate,
+				}, userId);
+				reports.addCallMetaReport(callMetaReport);
+			}
+		}
+
+		if (clientSample.iceRemoteCandidates && 0 < clientSample.iceRemoteCandidates.length) {
+			for (const iceRemoteCandidate of clientSample.iceRemoteCandidates) {
+				const callMetaReport = createCallMetaReport(serviceId, mediaUnitId, roomId, callId, clientId, {
+					type: CallMetaType.ICE_REMOTE_CANDIDATE,
+					payload: iceRemoteCandidate,
+				}, userId);
+				reports.addCallMetaReport(callMetaReport);
+			}
+		}
 	}
 }

src/processes/joinClientProcess.ts

@@ -97,3 +97,3 @@ import { EvaluatorContext } from '../common/types';
 				callId,
-				clientId,
+				clientId: savedClientId,
 				// timeZoneId,
@@ -104,3 +104,3 @@ marker,
 
-			if (!serviceId || !mediaUnitId || !roomId || !callId || !clientId) {
+			if (!serviceId || !mediaUnitId || !roomId || !callId || !savedClientId) {
 				continue;
@@ -107,0 +107,0 @@ }

No alert changes

Improved metrics

Total package byte prevSize

1012844

increased by0.19%

Lines of code

20458

increased by0.18%

No dependency changes