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

Comparing version 0.11.1-e596399.0 to 0.11.1-e88d773.0

lib/index.d.ts

@@ -5,7 +5,6 @@ export { ObserverDashboardClient, ObserverDashboardClientConfig, ObserverDashboardClientEventMap, } from './ObserverDashboardClient';
 export { DatabaseFrameSchema, DatabaseFrameConditions, } from './datastreams/DatabaseFrame';
-export { DataFrame, DataFrameConfig, DataFrameEvents, } from './datastreams/DataFrame';
+export { ObserverDashboardDataStream, DataFrameConfig, ObserverDashboardDataStreamEventsMap, } from './ObservedDashboardDataStream';
 export { ObserverDashboardAdminClient } from './ObserverDashboardAdminClient';
-export * as DashboardProtocol from './protocols/DashboardMessageProtocol';
+export { DashboardQueryRequest, DashboardNotification, DashboardMessage, } from './protocols/DashboardMessageProtocol';
 export * as CallSnapshotSchema from './protocols/CallSnapshotSchema';
-export { DataStream } from './datastreams/DataStream';
 //# sourceMappingURL=index.d.ts.map

lib/index.js

@@ -26,3 +26,3 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.CallSnapshotSchema = exports.DashboardProtocol = exports.ObserverDashboardAdminClient = exports.DataFrame = exports.WebSocketConnector = exports.ObserverDashboardClient = void 0;
+exports.CallSnapshotSchema = exports.DashboardQueryRequest = exports.ObserverDashboardAdminClient = exports.ObserverDashboardDataStream = exports.WebSocketConnector = exports.ObserverDashboardClient = void 0;
 var ObserverDashboardClient_1 = require("./ObserverDashboardClient");
@@ -32,7 +32,8 @@ Object.defineProperty(exports, "ObserverDashboardClient", { enumerable: true, get: function () { return ObserverDashboardClient_1.ObserverDashboardClient; } });
 Object.defineProperty(exports, "WebSocketConnector", { enumerable: true, get: function () { return WebSocketConnector_1.WebSocketConnector; } });
-var DataFrame_1 = require("./datastreams/DataFrame");
-Object.defineProperty(exports, "DataFrame", { enumerable: true, get: function () { return DataFrame_1.DataFrame; } });
+var ObservedDashboardDataStream_1 = require("./ObservedDashboardDataStream");
+Object.defineProperty(exports, "ObserverDashboardDataStream", { enumerable: true, get: function () { return ObservedDashboardDataStream_1.ObserverDashboardDataStream; } });
 var ObserverDashboardAdminClient_1 = require("./ObserverDashboardAdminClient");
 Object.defineProperty(exports, "ObserverDashboardAdminClient", { enumerable: true, get: function () { return ObserverDashboardAdminClient_1.ObserverDashboardAdminClient; } });
-exports.DashboardProtocol = __importStar(require("./protocols/DashboardMessageProtocol"));
+var DashboardMessageProtocol_1 = require("./protocols/DashboardMessageProtocol");
+Object.defineProperty(exports, "DashboardQueryRequest", { enumerable: true, get: function () { return DashboardMessageProtocol_1.DashboardQueryRequest; } });
 exports.CallSnapshotSchema = __importStar(require("./protocols/CallSnapshotSchema"));

lib/ObserverDashboardClient.d.ts

@@ -1,3 +0,2 @@
-import { DataFrame } from './datastreams/DataFrame';
-import { DataStream, ObserverDataStream } from './datastreams/DataStream';
+import { ObserverDashboardDataStream } from './ObservedDashboardDataStream';
 import { DatabaseFrameSchema, DatabaseFrameConditions } from './datastreams/DatabaseFrame';
@@ -15,3 +14,3 @@ import { DashboardDataStreamOperations, DashboardMessage, DashboardQueryOperations, FindCallsResponsePayload, GetSummaryResponsePayload, OngoingCallsResponsePayload } from './protocols/DashboardMessageProtocol';
 type CreateDataStreamOptions = DashboardDataStreamOperations['create'] & {
-    create: (dataStreamId: string) => DataStream<any>;
+    create: (dataStreamId: string) => ObserverDashboardDataStream<any>;
 };
@@ -36,9 +35,9 @@ export declare interface ObserverDashboardClient {
     getSummaryStats(params: DashboardQueryOperations['getSummaryStats']): Promise<GetSummaryResponsePayload>;
-    createDatabaseFrame<K extends keyof DatabaseFrameSchema>(resourceId: K, conditions: DatabaseFrameConditions<DatabaseFrameSchema[K]>, updateOnCreate?: boolean): Promise<DataFrame<DatabaseFrameSchema[K]>>;
-    createCallSnapshotsFrame(callId: string): Promise<DataFrame<CallSnapshot>>;
+    createDatabaseFrame<K extends keyof DatabaseFrameSchema>(resourceId: K, conditions: DatabaseFrameConditions<DatabaseFrameSchema[K]>, updateOnCreate?: boolean): Promise<ObserverDashboardDataStream<DatabaseFrameSchema[K]>>;
+    createCallSnapshotsFrame(callId: string): Promise<ObserverDashboardDataStream<CallSnapshot>>;
     createClientSnapshotsFrame(options: {
         callId: string;
         clientId: string;
-    }): Promise<DataFrame<ClientSnapshot>>;
-    protected _createDataStream(options: CreateDataStreamOptions, updateOnCreate: boolean): Promise<ObserverDataStream>;
+    }): Promise<ObserverDashboardDataStream<ClientSnapshot>>;
+    protected _createDataStream<T>(options: CreateDataStreamOptions, updateOnCreate: boolean): Promise<ObserverDashboardDataStream<T>>;
     protected _receive(message: DashboardMessage): void;
@@ -45,0 +44,0 @@ }

lib/ObserverDashboardClient.js

@@ -7,3 +7,3 @@ "use strict";
 exports.ObserverDashboardClient = void 0;
-const DataFrame_1 = require("./datastreams/DataFrame");
+const ObservedDashboardDataStream_1 = require("./ObservedDashboardDataStream");
 const DashboardMessageProtocol_1 = require("./protocols/DashboardMessageProtocol");
@@ -76,3 +76,3 @@ const WebSocketConnector_1 = require("./WebSocketConnector");
         }
-        const create = () => new DataFrame_1.DataFrame({
+        const create = () => new ObservedDashboardDataStream_1.ObserverDashboardDataStream({
             dataFrameId,
@@ -94,3 +94,3 @@ }, this.connection);
         }
-        const create = () => new DataFrame_1.DataFrame({
+        const create = () => new ObservedDashboardDataStream_1.ObserverDashboardDataStream({
             dataFrameId: callId,
@@ -115,3 +115,3 @@ }, this.connection);
         }
-        const create = () => new DataFrame_1.DataFrame({
+        const create = () => new ObservedDashboardDataStream_1.ObserverDashboardDataStream({
             dataFrameId: clientId,
@@ -149,3 +149,3 @@ }, this.connection);
         if (updateOnCreate)
-            await dataStream.update();
+            await dataStream.open();
         return dataStream;
@@ -152,0 +152,0 @@ }

package.json

 {
   "name": "@huddle01/observer-client-sdk",
-  "version": "0.11.1-e596399.0",
+  "version": "0.11.1-e88d773.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

Worsened metrics

Total package byte prevSize

173476

decreased by-0.85%

Number of package files

42

decreased by-6.67%

Lines of code

3596

decreased by-0.44%

No dependency changes