pull-ws - npm Package Compare versions

Comparing version 3.3.0 to 3.3.1

package.json

 {
   "name": "pull-ws",
-  "version": "3.3.0",
+  "version": "3.3.1",
   "description": "Simple pull-streams for websocket client connections",
@@ -5,0 +5,0 @@ "main": "index.js",

server.js

@@ -8,60 +8,61 @@ var ws = require('./')
 var EventEmitter = require('events').EventEmitter
-if(!WebSocket.Server)
-  return module.exports = null
+module.exports = !WebSocket.Server ? null : function (opts, onConnection) {
+    var emitter = new EventEmitter()
+    var server
+    if (typeof opts === 'function'){
+      onConnection = opts
+      opts = null
+    }
+    opts = opts || {}
 
-module.exports = function (opts, onConnection) {
-  var emitter = new EventEmitter()
-  var server
-  if (typeof opts === 'function'){
-    onConnection = opts
-    opts = null
-  }
-  opts = opts || {}
+    if(onConnection)
+      emitter.on('connection', onConnection)
 
-  if(onConnection)
-    emitter.on('connection', onConnection)
+    function proxy (server, event) {
+      return server.on(event, function () {
+        var args = [].slice.call(arguments)
+        args.unshift(event)
+        emitter.emit.apply(emitter, args)
+      })
+    }
 
-  function proxy (server, event) {
-    return server.on(event, function () {
-      var args = [].slice.call(arguments)
-      args.unshift(event)
-      emitter.emit.apply(emitter, args)
+    var server = opts.server ||
+      (opts.key && opts.cert ? https.createServer(opts) : http.createServer())
+
+    var wsServer = new WebSocket.Server({
+      server: server,
+      perMessageDeflate: false,
+      verifyClient: opts.verifyClient
     })
-  }
 
-  var server = opts.server ||
-    (opts.key && opts.cert ? https.createServer(opts) : http.createServer())
+    proxy(server, 'listening')
+    proxy(server, 'request')
+    proxy(server, 'close')
 
-  var wsServer = new WebSocket.Server({
-    server: server,
-    perMessageDeflate: false,
-    verifyClient: opts.verifyClient
-  })
+    wsServer.on('connection', function (socket) {
+      var stream = ws(socket)
+      stream.remoteAddress = socket.upgradeReq.socket.remoteAddress
+      emitter.emit('connection', stream)
+    })
 
-  proxy(server, 'listening')
-  proxy(server, 'request')
-  proxy(server, 'close')
+    emitter.listen = function (addr, onListening) {
+      if(onListening)
+        emitter.once('listening', onListening)
+      server.listen(addr.port || addr)
+      return emitter
+    }
 
-  wsServer.on('connection', function (socket) {
-    var stream = ws(socket)
-    stream.remoteAddress = socket.upgradeReq.socket.remoteAddress
-    emitter.emit('connection', stream)
-  })
+    emitter.close = function (onClose) {
+      server.close(onClose)
+      wsServer.close()
+      return emitter
+    }
 
-  emitter.listen = function (addr, onListening) {
-    if(onListening)
-      emitter.once('listening', onListening)
-    server.listen(addr.port || addr)
+    emitter.address = server.address.bind(server)
     return emitter
   }
 
-  emitter.close = function (onClose) {
-    server.close(onClose)
-    wsServer.close()
-    return emitter
-  }
 
-  emitter.address = server.address.bind(server)
-  return emitter
-}
 
+
+

No alert changes

Improved metrics

Total package byte prevSize

27167

increased by0.2%

Worsened metrics

Number of package files

29

decreased by-3.33%

Lines of code

701

decreased by-0.28%

No dependency changes