Upgrade the WebSocket libraries

.kuzzlerc.sample

@@ -380,10 +380,25 @@
       "websocket": {
         // * enabled:
         //    Set to true to enable WebSocket support
+        // * idleTimeout:
+        //    The maximum time (in milliseconds) without sending or receiving a
+        //    message from a client. Once reached, the client's socket is
+        //    forcibly closed.
+        //    Contrary to heartbeats (see below), this is a passive check,
+        //    forcing all clients to actively send either PINGs or messages to
+        //    maintain their connection active.
+        //    Set the value to 0 to disable this feature (should only be
+        //    activated if heartbeat is disabled)
         // * heartbeat:
-        //    The time, in milliseconds, between the server's PING requests.
-        //    Setting this value to 0 disables PING/PONG requests entirely.
+        //    The time, in milliseconds, between the server's PING requests to
+        //    clients, to make sure they are still active.
+        //    Setting this value to 0 disables PING requests from the server
+        //    (it will still respond with a PONG to PING requests from clients).
+        //    If heartbeat is deactivated, then setting a non-zero value to
+        //    idleTimeout is strongly recommended to detect and remove
+        //    dead sockets.
         "enabled": true,
+        "idleTimeout": 0,
         "heartbeat": 60000
       }
     }

default.config.js

@@ -203,6 +203,7 @@ module.exports = {
       },
       websocket: {
         enabled: true,
+        idleTimeout: 0,
         heartbeat: 60000
       }
     }

features/support/api/websocket.js

@@ -1,7 +1,7 @@
 const
   Bluebird = require('bluebird'),
   WsApiBase = require('./websocketBase'),
-  Ws = require('uws');
+  Ws = require('ws');
 
 class WebSocketApi extends WsApiBase {
 

lib/api/core/entrypoints/embedded/index.js

@@ -479,7 +479,7 @@ class EmbeddedEntryPoint extends EntryPoint {
         protocol.broadcast(this.constructor._removeErrorStack(data));
       }
       catch (e) {
-        this.kuzzle.emit('log:error', `[broadcast] protocol ${protoKey} failed: ${e.message}`);
+        this.kuzzle.emit('log:error', `[broadcast] protocol ${protoKey} failed: ${e.message}\n${e.stack}`);
       }
     }
   }