@observertc/observer-js - npm Package Compare versions

Comparing version 0.9.9-beta to 0.9.10-beta

lib/sources/Sources.js

@@ -44,3 +44,3 @@ "use strict";
                 if (closed) {
-                    throw new Error('Closed ClientSource cannot accept samples');
+                    throw new Error('Cannot accept ClientSample, because the ClientSource is closed');
                 }
@@ -67,2 +67,3 @@ const observedCallBuilder = this._observedCallsBuilder.getOrCreateObservedCallBuilder(config.callId, () => {
                 closed = true;
+                this._clientSources.delete(config.clientId);
                 this._emit('removed-client-source', source);
@@ -93,3 +94,3 @@ },
                 if (closed) {
-                    throw new Error('Closed ClientSource cannot accept samples');
+                    throw new Error('Cannot accept SfuSample, because the SfuSource is closed');
                 }
@@ -111,2 +112,3 @@ const observedSfuBuilder = this._observedSfusBuilder.getOrCreateObservedSfuBuilder(config.sfuId, () => {
                 closed = true;
+                this._sfuSources.delete(config.sfuId);
                 this._emit('removed-sfu-source', source);
@@ -135,2 +137,3 @@ },
         const observedSfus = this._observedSfusBuilder.build();
+        this._observedSfusBuilder = new ObservedSfus_1.ObservedSfusBuilder();
         this._emit('observed-samples', {
@@ -137,0 +140,0 @@ observedCalls,

package.json

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

src/sources/Sources.ts

@@ -69,3 +69,3 @@ import { ClientSample, SfuSample } from '@observertc/sample-schemas-js';
 				if (closed) {
-					throw new Error('Closed ClientSource cannot accept samples');
+					throw new Error('Cannot accept ClientSample, because the ClientSource is closed');
 				}
@@ -93,2 +93,3 @@ const observedCallBuilder = this._observedCallsBuilder.getOrCreateObservedCallBuilder(config.callId, () => {
 				closed = true;
+				this._clientSources.delete(config.clientId);
 				this._emit('removed-client-source', source);
@@ -120,3 +121,3 @@ },
 				if (closed) {
-					throw new Error('Closed ClientSource cannot accept samples');
+					throw new Error('Cannot accept SfuSample, because the SfuSource is closed');
 				}
@@ -139,2 +140,3 @@ const observedSfuBuilder = this._observedSfusBuilder.getOrCreateObservedSfuBuilder(config.sfuId, () => {
 				closed = true;
+				this._sfuSources.delete(config.sfuId);
 				this._emit('removed-sfu-source', source);
@@ -165,2 +167,3 @@ },
 		const observedSfus = this._observedSfusBuilder.build();
+		this._observedSfusBuilder = new ObservedSfusBuilder();
 		this._emit('observed-samples', {
@@ -167,0 +170,0 @@ observedCalls,

No alert changes

Improved metrics

Total package byte prevSize

967232

increased by0.04%

Lines of code

19506

increased by0.03%

No dependency changes