@push-rpc/websocket - npm Package Compare versions

Comparing version 1.7.1 to 1.8.0

dist/index.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.createNodeWebsocket = exports.createWebsocketServer = void 0;
 var server_1 = require("./server");
 Object.defineProperty(exports, "createWebsocketServer", { enumerable: true, get: function () { return server_1.createWebsocketServer; } });
 Object.defineProperty(exports, "createNodeWebsocket", { enumerable: true, get: function () { return server_1.createNodeWebsocket; } });

dist/server.d.ts

@@ -1,2 +0,2 @@
-import * as WebSocket from "ws";
+import WebSocket from "ws";
 import { Socket, SocketServer } from "@push-rpc/core";
@@ -3,0 +3,0 @@ /**

dist/server.js

 "use strict";
+var __importDefault = (this && this.__importDefault) || function (mod) {
+    return (mod && mod.__esModule) ? mod : { "default": mod };
+};
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.wrapWebsocket = exports.createNodeWebsocket = exports.createWebsocketServer = void 0;
-var WebSocket = require("ws");
+const ws_1 = __importDefault(require("ws"));
 /**
@@ -10,14 +13,13 @@ * Create Push-RPC SocketServer using WebSocket transport.
  */
-function createWebsocketServer(options) {
-    if (options === void 0) { options = { noServer: true }; }
-    var wss = new WebSocket.Server(options);
+function createWebsocketServer(options = { noServer: true }) {
+    const wss = new ws_1.default.Server(options);
     return {
-        onError: function (h) {
+        onError: h => {
             wss.on("error", h);
         },
-        onConnection: function (h) {
-            wss.on("connection", function (ws, req) { return h(wrapWebsocket(ws), req, ws.protocol); });
+        onConnection: h => {
+            wss.on("connection", (ws, req) => h(wrapWebsocket(ws), req, ws.protocol));
         },
-        close: function (h) { return wss.close(h); },
-        wss: wss,
+        close: h => wss.close(h),
+        wss,
     };
@@ -32,9 +34,9 @@ }
 function createNodeWebsocket(url, protocol) {
-    return wrapWebsocket(new WebSocket(url, protocol));
+    return wrapWebsocket(new ws_1.default(url, protocol));
 }
 exports.createNodeWebsocket = createNodeWebsocket;
 function wrapWebsocket(ws) {
-    var errorHandler = function () { };
-    var messageReplay = [];
-    ws.on("message", function (e) {
+    let errorHandler = () => { };
+    let messageReplay = [];
+    ws.on("message", e => {
         if (messageReplay) {
@@ -45,26 +47,23 @@ messageReplay.push(e.toString("utf-8"));
     return {
-        onMessage: function (h) {
-            for (var _i = 0, messageReplay_1 = messageReplay; _i < messageReplay_1.length; _i++) {
-                var message = messageReplay_1[_i];
+        onMessage: h => {
+            for (const message of messageReplay) {
                 h(message);
             }
             messageReplay = null;
-            ws.on("message", function (e) {
+            ws.on("message", e => {
                 h(e.toString("utf-8"));
             });
         },
-        onOpen: function (h) { return ws.on("open", h); },
-        onDisconnected: function (h) {
-            return ws.on("close", function (code, reason) {
-                h(code, reason);
-            });
-        },
-        onError: function (h) {
+        onOpen: h => ws.on("open", h),
+        onDisconnected: h => ws.on("close", (code, reason) => {
+            h(code, reason);
+        }),
+        onError: h => {
             errorHandler = h;
             ws.on("error", h);
         },
-        onPong: function (h) { return ws.on("pong", h); },
-        onPing: function (h) { return ws.on("ping", h); },
-        disconnect: function () { return ws.terminate(); },
-        send: function (data) {
+        onPong: h => ws.on("pong", h),
+        onPing: h => ws.on("ping", h),
+        disconnect: () => ws.terminate(),
+        send: data => {
             try {
@@ -77,3 +76,3 @@ ws.send(data);
         },
-        ping: function (data) {
+        ping: data => {
             try {
@@ -80,0 +79,0 @@ ws.ping(data);

package.json

 {
   "name": "@push-rpc/websocket",
-  "version": "1.7.1",
+  "version": "1.8.0",
   "main": "dist/index.js",
@@ -12,3 +12,3 @@ "types": "dist/index.d.ts",
   "dependencies": {
-    "@push-rpc/core": "^1.7.1",
+    "@push-rpc/core": "^1.8.0",
     "ws": "^7.2.0"
@@ -21,3 +21,3 @@ },
   },
-  "gitHead": "a5bdea5151a3b21cc20762664290359caf6cb59f"
+  "gitHead": "8a5ba0d8a336a598746903ab25c1601e5033a765"
 }

src/server.ts

@@ -1,2 +0,2 @@
-import * as WebSocket from "ws"
+import WebSocket from "ws"
 import {Socket, SocketServer} from "@push-rpc/core"
@@ -3,0 +3,0 @@

tsconfig.json

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

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

8638

decreased by-2.47%

Lines of code

229

decreased by-2.14%

Dependency changes

• Updated@push-rpc/core@^1.8.0