@huddle01/observer-client-sdk - npm Package Compare versions

Comparing version 0.11.1-1ccf3ca.0 to 0.11.1-32878d0.0

lib/ObservedDashboardDataStream.d.ts

@@ -7,3 +7,3 @@ import { DashboardDataStreamNotification } from './protocols/DashboardMessageProtocol';
     newrow: [row: T];
-    error: [error: string];
+    streamerror: [error: string];
 };
@@ -10,0 +10,0 @@ export type ObserverDashboardDataStreamConfig = {

lib/ObservedDashboardDataStream.js

@@ -86,4 +86,4 @@ "use strict";
             }
-            case 'error': {
-                this.emit('error', event.payload);
+            case 'streamerror': {
+                this.emit('streamerror', event.payload);
                 break;
@@ -90,0 +90,0 @@ }

lib/protocols/DashboardMessageProtocol.d.ts

@@ -52,8 +52,2 @@ import { CallSnapshot } from "./CallSnapshotSchema";
     }[];
-    dataStreams: {
-        streamType: string;
-        streamId: string;
-        instanceType: 'dataCollector' | 'dataSource';
-        collectedBytes: number;
-    }[];
     jobRouter: {
@@ -66,2 +60,36 @@ createdAt: number;
     };
+    streamRouter: {
+        emitter: {
+            numberOfSubscriptions: number;
+            numberOfSentEventInvocations: number;
+            numberOfReceivedEventInvocations: number;
+        };
+        sinks: {
+            sinkId: string;
+            streamId: string;
+            state: string;
+            streamProviderPeerId?: string;
+        }[];
+        streamProviders: {
+            streamType: string;
+            bytesHighWaterMark: number;
+            bytesLowWaterMark: number;
+            totalBytes: number;
+            collectors: {
+                createdAt: number;
+                streamId: string;
+                numberOfFilesUploaded: number;
+                numberOfSinks: number;
+                collectedBytes: number;
+            }[];
+            sources: {
+                createdAt: number;
+                streamId: string;
+                numberOfFilesDownloaded: number;
+                numberOfSinks: number;
+                activeClosingTimer: boolean;
+                collectedBytes: number;
+            }[];
+        }[];
+    };
     stats: {
@@ -166,3 +194,3 @@ consumedSamples: number;
     data: unknown;
-    error: string;
+    streamerror: string;
     close: undefined;
@@ -169,0 +197,0 @@ };

lib/WebSocketConnector.js

@@ -161,3 +161,3 @@ "use strict";
         }
-        console.warn('sending request', pendingRequest.request);
+        // console.warn('sending request', pendingRequest.request);
         this._pendingRequests.set(pendingRequest.request.requestId, pendingRequest);
@@ -164,0 +164,0 @@ this._socket?.send(this._codec.encode(pendingRequest.request));

package.json

 {
   "name": "@huddle01/observer-client-sdk",
-  "version": "0.11.1-1ccf3ca.0",
+  "version": "0.11.1-32878d0.0",
   "description": "ObserverDashboardClient SDK",
@@ -5,0 +5,0 @@ "main": "lib/index.js",

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

175542

increased by0.89%

Lines of code

3635

increased by0.78%

No dependency changes