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

Comparing version 0.11.1-8ae550a.0 to 0.11.1-904ee48.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,11 @@ connection: WebSocketConnectorConfig;
     getSummaryStats(params: DashboardQueryOperations['getSummaryStats']): 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 +47,0 @@ createClientSnapshotsFrame(options: {

lib/ObserverDashboardClient.js

@@ -68,2 +68,9 @@ "use strict";
     }
+    /**
+     * @deprecated Use createReportsFrame instead loading reports from bucket
+     * @param resourceId
+     * @param conditions
+     * @param updateOnCreate
+     * @returns
+     */
     async createDatabaseFrame(resourceId, conditions, updateOnCreate = true) {
@@ -87,2 +94,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 +117,0 @@ if (this._dataStreams.has(callId)) {

lib/protocols/DashboardMessageProtocol.d.ts

@@ -9,2 +9,3 @@ import { CallSnapshot } from "./CallSnapshotSchema";
         clientSnapshotResourceId: string;
+        reportsResourceId: string;
     };
@@ -144,2 +145,12 @@ }>;
 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 = {
@@ -153,5 +164,11 @@ findCalls: {
         transportId?: string;
+        producerId?: string;
+        consumerId?: string;
     };
     ongoingCals: undefined;
     ongoingCalls: undefined;
+    getTurnStats: {
+        startDate: number;
+        endDate?: number;
+    };
     getSummaryStats: {
@@ -158,0 +175,0 @@ startDate: number;

lib/protocols/DashboardMessageProtocol.js

@@ -10,2 +10,3 @@ "use strict";
         clientSnapshotResourceId: 'client-snapshot',
+        reportsResourceId: 'reports',
     }
@@ -12,0 +13,0 @@ });

package.json

 {
   "name": "@huddle01/observer-client-sdk",
-  "version": "0.11.1-8ae550a.0",
+  "version": "0.11.1-904ee48.0",
   "description": "ObserverDashboardClient SDK",
@@ -5,0 +5,0 @@ "main": "lib/index.js",

No alert changes

Improved metrics

Total package byte prevSize

183195

increased by4.36%

Number of package files

45

increased by7.14%

Lines of code

3784

increased by4.1%

No dependency changes