@push-rpc/tcp - npm Package Compare versions

Comparing version 1.0.3 to 1.0.4

dist/client.js

@@ -25,2 +25,5 @@ "use strict";
         },
+        onPing: function (h) {
+            // not implemented
+        },
         terminate: function () { return socket.destroy(); },
@@ -27,0 +30,0 @@ send: function (data) { return socket.write(data); },

example/handshake/client.ts

@@ -14,3 +14,3 @@ import {createRpcClient, setLogger} from "@push-rpc/core"
     socket.on("connect", () => {
-      socket.write("my-id")
+      socket.write('my-id\n[2,"1","getHello",null]')
     })
@@ -23,3 +23,3 @@
 
-  console.log("From server: " + (await remote.getHello()))
+  // console.log("From server: " + (await remote.getHello()))
 })()

example/handshake/server.ts

@@ -8,2 +8,3 @@ import {createRpcServer, RpcConnectionContext, RpcContext, setLogger, Socket} from "@push-rpc/core"
   async getHello(_, ctx: RpcContext) {
+    console.log("Receive req")
     return "Hello, " + ctx.remoteId
@@ -14,3 +15,3 @@ },
 createRpcServer(services, createSocketServer(5555), {
-  createConnectionContext(socket: Socket, transportDetails: any): Promise<RpcConnectionContext> {
+  createConnectionContext(socket: Socket, impl): Promise<RpcConnectionContext> {
     return new Promise((resolve, reject) => {
@@ -32,5 +33,13 @@ let handshaked = false
 
+        const [remoteId, message] = data.split("\n")
+
         resolve({
-          remoteId: data,
+          remoteId,
         })
+
+        if (message) {
+          setTimeout(() => {
+            impl.emit("data", message)
+          }, 0)
+        }
       })
@@ -37,0 +46,0 @@ })

package.json

 {
   "name": "@push-rpc/tcp",
-  "version": "1.0.3",
+  "version": "1.0.4",
   "main": "dist/index.js",
@@ -18,3 +18,3 @@ "types": "dist/index.d.ts",
   "dependencies": {
-    "@push-rpc/core": "^1.0.15"
+    "@push-rpc/core": "^1.0.32"
   },
@@ -21,0 +21,0 @@ "repository": "https://github.com/vasyas/push-rpc.git",

src/client.ts

@@ -30,2 +30,6 @@ import {Socket} from "@push-rpc/core"
 
+    onPing(h: () => void) {
+      // not implemented
+    },
+
     terminate: () => socket.destroy(),
@@ -32,0 +36,0 @@ send: data => socket.write(data),

No alert changes

Improved metrics

Total package byte prevSize

6818

increased by5.28%

Lines of code

199

increased by6.99%

Dependency changes

• Updated@push-rpc/core@^1.0.32