@push-rpc/core - npm Package Compare versions

Comparing version 1.8.3 to 1.9.0

dist/local.d.ts

@@ -20,3 +20,3 @@ import { DataConsumer, DataSupplier, Topic, TopicImpl } from "./rpc";
     private dataSupplierCache;
-    getData(filter: F, callContext: unknown, connectionContext: unknown): Promise<D>;
+    getData(filter: F, callContext: unknown, connectionContext?: unknown): Promise<D>;
     private throttled;
@@ -23,0 +23,0 @@ subscribeSession(session: RpcSession, filter: F, messageId: any, ctx: any): Promise<D>;

dist/local.js

@@ -42,3 +42,3 @@ "use strict";
     }
-    async getData(filter, callContext, connectionContext) {
+    async getData(filter, callContext, connectionContext = {}) {
         return await this.dataSupplierCache.invoke({ filter, connectionContext }, () => this.supplier(filter, callContext));
@@ -45,0 +45,0 @@ }

dist/remote.d.ts

@@ -16,3 +16,4 @@ import { CallOptions, DataConsumer, LocalTopic, RemoteTopic, TopicImpl } from "./rpc";
     trigger(p?: F, data?: D): void;
+    getData(p: F, callContext: unknown, connectionContext: unknown): Promise<D>;
 }
 export declare function createRemote(session: RpcSession, name?: string): (params: any, callOpts?: any) => Promise<any>;

dist/remote.js

@@ -94,2 +94,5 @@ "use strict";
     trigger(p, data) { }
+    async getData(p, callContext, connectionContext) {
+        return undefined;
+    }
 }
@@ -96,0 +99,0 @@ exports.RemoteTopicImpl = RemoteTopicImpl;

dist/rpc.d.ts

@@ -31,2 +31,3 @@ /**
     trigger(p?: Partial<P>, data?: TD): void;
+    getData(filter: P, callContext: unknown, connectionContext?: unknown): Promise<D>;
 }
@@ -33,0 +34,0 @@ export interface RpcConnectionContext<Remote = any> {

package.json

 {
   "name": "@push-rpc/core",
-  "version": "1.8.3",
+  "version": "1.9.0",
   "main": "dist/index.js",
@@ -21,3 +21,3 @@ "types": "dist/index.d.ts",
   },
-  "gitHead": "4b2411a10a39ebe9a83b4939adfbde1a5618c1c3"
+  "gitHead": "1908188b2eb961b14809a82050eb645698fdf34f"
 }

src/local.ts

@@ -56,3 +56,3 @@ import {DataConsumer, DataSupplier, MessageType, Topic, TopicImpl} from "./rpc"
 
-  async getData(filter: F, callContext: unknown, connectionContext: unknown): Promise<D> {
+  async getData(filter: F, callContext: unknown, connectionContext: unknown = {}): Promise<D> {
     return await this.dataSupplierCache.invoke({filter, connectionContext}, () =>
@@ -59,0 +59,0 @@ this.supplier(filter, callContext)

src/remote.ts

@@ -127,2 +127,5 @@ import {CallOptions, DataConsumer, LocalTopic, MessageType, RemoteTopic, TopicImpl} from "./rpc"
   trigger(p?: F, data?: D): void {}
+  async getData(p: F, callContext: unknown, connectionContext: unknown): Promise<D> {
+    return undefined
+  }
 }
@@ -129,0 +132,0 @@

src/rpc.ts

@@ -62,2 +62,3 @@ /**
   trigger(p?: Partial<P>, data?: TD): void
+  getData(filter: P, callContext: unknown, connectionContext?: unknown): Promise<D>
 }
@@ -64,0 +65,0 @@

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

155529

increased by0.3%

Lines of code

4501

increased by0.2%

No dependency changes