@push-rpc/tcp - npm Package Compare versions

Comparing version 1.7.1 to 1.8.0

dist/client.js

 "use strict";
+var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
+    if (k2 === undefined) k2 = k;
+    var desc = Object.getOwnPropertyDescriptor(m, k);
+    if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) {
+      desc = { enumerable: true, get: function() { return m[k]; } };
+    }
+    Object.defineProperty(o, k2, desc);
+}) : (function(o, m, k, k2) {
+    if (k2 === undefined) k2 = k;
+    o[k2] = m[k];
+}));
+var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) {
+    Object.defineProperty(o, "default", { enumerable: true, value: v });
+}) : function(o, v) {
+    o["default"] = v;
+});
+var __importStar = (this && this.__importStar) || function (mod) {
+    if (mod && mod.__esModule) return mod;
+    var result = {};
+    if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
+    __setModuleDefault(result, mod);
+    return result;
+};
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.wrapSocket = exports.createSocket = void 0;
-var net = require("net");
+const net = __importStar(require("net"));
 function createSocket(host, port) {
-    var socket = new net.Socket();
+    const socket = new net.Socket();
     socket.connect(port, host);
@@ -13,21 +36,19 @@ return wrapSocket(socket);
     return {
-        onMessage: function (h) {
-            socket.on("data", function (data) { return h(data.toString("utf8")); });
+        onMessage: h => {
+            socket.on("data", data => h(data.toString("utf8")));
         },
-        onOpen: function (h) { return socket.on("connect", h); },
-        onDisconnected: function (h) {
-            return socket.on("close", function (error) {
-                h(error ? 1 : 0, error ? "error" : null);
-            });
-        },
-        onError: function (h) { return socket.on("error", h); },
-        onPong: function (h) {
+        onOpen: h => socket.on("connect", h),
+        onDisconnected: h => socket.on("close", error => {
+            h(error ? 1 : 0, error ? "error" : null);
+        }),
+        onError: h => socket.on("error", h),
+        onPong: h => {
             // not implemented
         },
-        onPing: function (h) {
+        onPing(h) {
             // not implemented
         },
-        disconnect: function () { return socket.destroy(); },
-        send: function (data) { return socket.write(data); },
-        ping: function (data) {
+        disconnect: () => socket.destroy(),
+        send: data => socket.write(data),
+        ping: data => {
             // not implemented
@@ -34,0 +55,0 @@ },

dist/index.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.createSocketServer = exports.wrapSocket = exports.createSocket = void 0;
 var client_1 = require("./client");
@@ -4,0 +5,0 @@ Object.defineProperty(exports, "createSocket", { enumerable: true, get: function () { return client_1.createSocket; } });

dist/server.js

 "use strict";
+var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
+    if (k2 === undefined) k2 = k;
+    var desc = Object.getOwnPropertyDescriptor(m, k);
+    if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) {
+      desc = { enumerable: true, get: function() { return m[k]; } };
+    }
+    Object.defineProperty(o, k2, desc);
+}) : (function(o, m, k, k2) {
+    if (k2 === undefined) k2 = k;
+    o[k2] = m[k];
+}));
+var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) {
+    Object.defineProperty(o, "default", { enumerable: true, value: v });
+}) : function(o, v) {
+    o["default"] = v;
+});
+var __importStar = (this && this.__importStar) || function (mod) {
+    if (mod && mod.__esModule) return mod;
+    var result = {};
+    if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
+    __setModuleDefault(result, mod);
+    return result;
+};
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.createSocketServer = void 0;
-var net = require("net");
-var client_1 = require("./client");
+const net = __importStar(require("net"));
+const client_1 = require("./client");
 function createSocketServer(port) {
-    var s = new net.Server();
+    const s = new net.Server();
     s.listen(port);
     return {
-        onError: function (e) { return s.on("error", e); },
-        onConnection: function (h) {
-            s.on("connection", function (socket) {
-                h(client_1.wrapSocket(socket), socket);
+        onError: e => s.on("error", e),
+        onConnection: h => {
+            s.on("connection", socket => {
+                h((0, client_1.wrapSocket)(socket), socket);
             });
         },
-        close: function (h) { return s.close(h); },
+        close: h => s.close(h),
     };
 }
 exports.createSocketServer = createSocketServer;

package.json

 {
   "name": "@push-rpc/tcp",
-  "version": "1.7.1",
+  "version": "1.8.0",
   "main": "dist/index.js",
@@ -15,3 +15,3 @@ "types": "dist/index.d.ts",
   "dependencies": {
-    "@push-rpc/core": "^1.7.1"
+    "@push-rpc/core": "^1.8.0"
   },
@@ -23,3 +23,3 @@ "repository": "https://github.com/vasyas/push-rpc.git",
   },
-  "gitHead": "a5bdea5151a3b21cc20762664290359caf6cb59f"
+  "gitHead": "8a5ba0d8a336a598746903ab25c1601e5033a765"
 }

tsconfig.json

 {
+  "extends": "../../tsconfig.json",
+  "include": ["src/**/*.ts"],
   "compilerOptions": {
-    "target": "es5",
-    "outDir": "dist",
-    "lib": [
-      "es6"
-    ],
-    "declaration": true
-  },
-  "include": ["src/**/*.ts", "demo/**/*.ts"]
+    "outDir": "dist"
+  }
 }

No alert changes

Improved metrics

Total package byte prevSize

10078

increased by22.86%

Lines of code

242

increased by20.4%

Dependency changes

• Updated@push-rpc/core@^1.8.0