bsock - npm Package Compare versions

Comparing version 0.1.9 to 0.1.10

lib/backend-browser.js

 'use strict';
 
-module.exports = {
-  Client: global.WebSocket || global.MozWebSocket,
-  EventSource: global.EventSource
-};
+exports.Client = global.WebSocket || global.MozWebSocket;
+exports.EventSource = global.EventSource;

lib/backend.js

 'use strict';
 
-module.exports = require('../vendor/faye-websocket');
+/** @type {any} */
+const WebSocket = require('../vendor/faye-websocket');
+
+exports.WebSocket = WebSocket;
+exports.Client = WebSocket.Client;
+exports.EventSource = WebSocket.EventSource;

lib/bsock.js

 'use strict';
 
-const WebSocket = require('./backend');
-const Server = require('./server');
-const Socket = require('./socket');
+const {WebSocket, Client} = require('./backend');
+const {Server} = require('./server');
+const {Socket} = require('./socket');
 
 exports.WebSocket = WebSocket;
+exports.Client = Client;
 exports.Server = Server;
@@ -9,0 +10,0 @@ exports.server = () => new Server();

lib/frame.js

@@ -127,2 +127,2 @@ 'use strict';
 
-module.exports = Frame;
+exports.Frame = Frame;

lib/packet.js

@@ -134,2 +134,7 @@ 'use strict';
 
+/**
+ * @param {Object} obj
+ * @returns {[string, Buffer[]]}
+ */
+
 function deconstruct(obj) {
@@ -203,7 +208,13 @@ const buffers = [];
 
-function readChar(str, i) {
+/**
+ * @param {String} str
+ * @param {Number} i
+ * @returns {[Number, Number]}
+ */
+
+function readChar(str,  i) {
   const ch = str.charCodeAt(i) - 0x30;
 
   if (ch < 0 || ch > 9)
-    return -1;
+    return [0, -1];
 
@@ -255,2 +266,2 @@ return [i + 1, ch];
 
-module.exports = Packet;
+exports.Packet = Packet;

lib/parser.js

@@ -11,3 +11,3 @@ /*!
 const EventEmitter = require('events');
-const Frame = require('./frame');
+const {Frame} = require('./frame');
 
@@ -68,2 +68,2 @@ const MAX_MESSAGE = 100000000;
 
-module.exports = Parser;
+exports.Parser = Parser;

lib/server-browser.js

@@ -14,3 +14,3 @@ 'use strict';
 
-  attach() {
+  attach(server) {
     return this;
@@ -51,2 +51,2 @@ }
 
-module.exports = Server;
+exports.Server = Server;

lib/server.js

@@ -5,5 +5,5 @@ 'use strict';
 const EventEmitter = require('events');
-const Packet = require('./packet');
-const WebSocket = require('./backend');
-const Socket = require('./socket');
+const {Packet} = require('./packet');
+const {WebSocket} = require('./backend');
+const {Socket} = require('./socket');
 
@@ -181,2 +181,2 @@ class Server extends EventEmitter {
 
-module.exports = Server;
+exports.Server = Server;

lib/socket.js

@@ -8,6 +8,6 @@ 'use strict';
 const WebSocket = require('./backend').Client;
-const Packet = require('./packet');
-const Frame = require('./frame');
+const {Packet} = require('./packet');
+const {Frame} = require('./frame');
 const util = require('./util');
-const Parser = require('./parser');
+const {Parser} = require('./parser');
 const codes = require('./codes');
@@ -278,5 +278,3 @@ const blacklist = require('./blacklist');
 
-    const err = new Error(msg);
-    err.reason = event.reason || '';
-    err.code = event.code || 0;
+    const err = new SocketError(msg, reason, code);
 
@@ -497,3 +495,3 @@ this.emit('error', err);
 
-  async handlePing() {
+  async handlePing(frame) {
     if (!this.inbound)
@@ -505,3 +503,3 @@ throw new Error('Outbound socket sent a ping frame.');
 
-  async handlePong() {
+  async handlePong(frame) {
     if (this.inbound)
@@ -602,2 +600,6 @@ throw new Error('Inbound socket sent a pong frame.');
 
+  /**
+   * @param {Packet} packet
+   */
+
   async handlePacket(packet) {
@@ -690,3 +692,4 @@ if (this.destroyed)
 
-      this.events.emit(...args);
+      const rest = args.slice(1);
+      this.events.emit(event, ...rest);
     } catch (e) {
@@ -743,3 +746,3 @@ this.emit('error', e);
     if (id === -1) {
-      const e = new Error(msg);
+      const e = new SocketError(msg);
       e.name = name;
@@ -759,3 +762,3 @@ e.type = type;
 
-    const e = new Error(msg);
+    const e = new SocketError(msg);
     e.name = name;
@@ -995,4 +998,7 @@ e.type = type;
 
+    // @ts-ignore
     if (typeof Blob !== 'undefined' && Blob) {
+      // @ts-ignore
       if (data instanceof Blob) {
+        // @ts-ignore
         const reader = new FileReader();
@@ -1012,2 +1018,14 @@ reader.onloadend = () => {
 
+class SocketError extends Error {
+  constructor(message, reason, code) {
+    super(message);
+    this.type = 'SocketError';
+    this.reason = reason || '';
+    this.code = code || 0;
+
+    if (Error.captureStackTrace)
+      Error.captureStackTrace(this, SocketError);
+  }
+}
+
 /*
@@ -1017,2 +1035,2 @@ * Expose
 
-module.exports = Socket;
+exports.Socket = Socket;

lib/uws.js

@@ -0,1 +1,2 @@
+// @ts-nocheck
 'use strict';
@@ -2,0 +3,0 @@

package.json

 {
   "name": "bsock",
-  "version": "0.1.9",
+  "version": "0.1.10",
   "description": "Websocket bike-shed",
@@ -20,10 +20,12 @@ "keywords": [
   "scripts": {
-    "lint": "eslint lib/ test/socket-test.js || exit 0",
+    "lint": "eslint lib/ test/socket-test.js",
+    "lint-types": "tsc -p .",
     "test": "bmocha --reporter spec test/*-test.js"
   },
   "dependencies": {
-    "bsert": "~0.0.10"
+    "bsert": "~0.0.12"
   },
   "devDependencies": {
-    "bmocha": "^2.1.0"
+    "bmocha": "^2.1.8",
+    "bts-type-deps": "^0.0.3"
   },
@@ -30,0 +32,0 @@ "engines": {

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

New author

Supply chain risk

A new npm collaborator published a version of the package for the first time. New collaborators are usually benign additions to a project, but do indicate a change to the security surface area of a package.

Found 1 instance in 1 package

Mixed license

License

(Experimental) Package contains multiple licenses.

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

151259

increased by4.04%

Number of package files

18

increased by5.88%

Lines of code

4577

increased by4.09%

Worsened metrics

Dev dependency count

2

increased by100%

Number of low license alerts

1

increased byInfinity%

Number of medium supply chain risk alerts

3

increased by50%

Dependency changes

• Updatedbsert@~0.0.12