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

Comparing version 0.11.1-e09dcc4.0 to 0.11.1-e47c50d.0

lib/ObservedDashboardDataStream.d.ts

@@ -7,3 +7,3 @@ import { DashboardDataStreamNotification } from './protocols/DashboardMessageProtocol';
     newrow: [row: T];
-    error: [error: string];
+    streamerror: [error: string];
 };
@@ -27,2 +27,3 @@ export type ObserverDashboardDataStreamConfig = {
     private _rows;
+    private _reject?;
     constructor(config: ObserverDashboardDataStreamConfig, _channel: WebSocketConnector, _sortFn?: ((a: T, b: T) => number) | undefined);
@@ -29,0 +30,0 @@ get id(): string;

lib/ObservedDashboardDataStream.js

@@ -17,2 +17,3 @@ "use strict";
     _rows = [];
+    _reject;
     constructor(config, _channel, _sortFn) {
@@ -50,3 +51,9 @@ super();
         this._opened = true;
+        let error;
+        const listener = (err) => (error = err);
+        this.once('streamerror', listener);
         await this._request('update', {}).then(() => void 0);
+        this.off('streamerror', listener);
+        if (error)
+            throw new Error(error);
         if (this._sortFn)
@@ -88,4 +95,4 @@ this._rows.sort(this._sortFn);
             }
-            case 'error': {
-                this.emit('error', event.payload);
+            case 'streamerror': {
+                this.emit('streamerror', event.payload);
                 break;
@@ -92,0 +99,0 @@ }

lib/ObserverDashboardClient.d.ts

@@ -7,2 +7,3 @@ import { ObserverDashboardDataStream } from './ObservedDashboardDataStream';
 import { CallSnapshot, ClientSnapshot } from './protocols/CallSnapshotSchema';
+import { ReportSchemas } from './datastreams/ReportSchemas';
 export type ObserverDashboardClientConfig = {
@@ -35,3 +36,12 @@ connection: WebSocketConnectorConfig;
     getSummaryStats(params: DashboardQueryOperations['getSummaryStats']): Promise<GetSummaryResponsePayload>;
+    getTurnStats(params: DashboardQueryOperations['getTurnStats']): Promise<GetSummaryResponsePayload>;
+    /**
+     * @deprecated Use createReportsFrame instead loading reports from bucket
+     * @param resourceId
+     * @param conditions
+     * @param updateOnCreate
+     * @returns
+     */
     createDatabaseFrame<K extends keyof DatabaseFrameSchema>(resourceId: K, conditions: DatabaseFrameConditions<DatabaseFrameSchema[K]>, updateOnCreate?: boolean): Promise<ObserverDashboardDataStream<DatabaseFrameSchema[K]>>;
+    createReportsFrame<K extends keyof ReportSchemas>(reportType: K, settings: ReportSchemas[K]['request']): Promise<ObserverDashboardDataStream<ReportSchemas[K]["response"]>>;
     createCallSnapshotsFrame(callId: string): Promise<ObserverDashboardDataStream<CallSnapshot>>;
@@ -38,0 +48,0 @@ createClientSnapshotsFrame(options: {

lib/ObserverDashboardClient.js

@@ -68,2 +68,17 @@ "use strict";
     }
+    async getTurnStats(params) {
+        return this.connection.request({
+            request: new DashboardMessageProtocol_1.DashboardQueryRequest((0, uuid_1.v4)(), {
+                method: 'getTurnStats',
+                parameters: params,
+            }),
+        });
+    }
+    /**
+     * @deprecated Use createReportsFrame instead loading reports from bucket
+     * @param resourceId
+     * @param conditions
+     * @param updateOnCreate
+     * @returns
+     */
     async createDatabaseFrame(resourceId, conditions, updateOnCreate = true) {
@@ -87,2 +102,23 @@ const dataStreamId = object_hash_1.default.sha1({ connectionId: this.connection.id, conditions, resourceId });
     }
+    async createReportsFrame(reportType, settings) {
+        const dataStreamId = object_hash_1.default.sha1({ connectionId: this.connection.id, reportType, settings });
+        if (this._dataStreams.has(dataStreamId)) {
+            const dataFramePromise = this._dataStreams.get(dataStreamId);
+            if (dataFramePromise)
+                return dataFramePromise;
+        }
+        const create = () => new ObservedDashboardDataStream_1.ObserverDashboardDataStream({
+            dataStreamId,
+        }, this.connection);
+        const result = await this._createDataStream({
+            dataStreamId,
+            resourceId: DashboardMessageProtocol_1.protocolMeta.dataStreams.reportsResourceId,
+            create,
+            parameters: {
+                reportType,
+                ...settings,
+            },
+        }, true);
+        return result;
+    }
     async createCallSnapshotsFrame(callId) {
@@ -89,0 +125,0 @@ if (this._dataStreams.has(callId)) {

lib/protocols/DashboardMessageProtocol.d.ts

@@ -9,2 +9,3 @@ import { CallSnapshot } from "./CallSnapshotSchema";
         clientSnapshotResourceId: string;
+        reportsResourceId: string;
     };
@@ -53,8 +54,2 @@ }>;
     }[];
-    dataStreams: {
-        streamType: string;
-        streamId: string;
-        instanceType: 'dataCollector' | 'dataSource';
-        collectedBytes: number;
-    }[];
     jobRouter: {
@@ -67,2 +62,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: {
@@ -118,2 +147,12 @@ consumedSamples: number;
 export type GetServerStatesResponsePayload = ObserverServerState[];
+export type GetTurnStatsResponsePayload = {
+    [K in string]: {
+        totalBytesSent: number;
+        totalBytesReceived: number;
+        totalPacketsSent: number;
+        totalPacketsReceived: number;
+        inboundBitrate: number;
+        outboundBitrate: number;
+    };
+};
 export type DashboardQueryOperations = {
@@ -127,5 +166,11 @@ findCalls: {
         transportId?: string;
+        producerId?: string;
+        consumerId?: string;
     };
     ongoingCals: undefined;
     ongoingCalls: undefined;
+    getTurnStats: {
+        startDate: number;
+        endDate?: number;
+    };
     getSummaryStats: {
@@ -169,3 +214,3 @@ startDate: number;
     data: unknown;
-    error: string;
+    streamerror: string;
     close: undefined;
@@ -172,0 +217,0 @@ };

lib/protocols/DashboardMessageProtocol.js

@@ -10,2 +10,3 @@ "use strict";
         clientSnapshotResourceId: 'client-snapshot',
+        reportsResourceId: 'reports',
     }
@@ -12,0 +13,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-e09dcc4.0",
+  "version": "0.11.1-e47c50d.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

183931

increased by5.72%

Number of package files

45

increased by7.14%

Lines of code

3801

increased by5.38%

No dependency changes