Merge pull request #615 from hicaro/master

Created clientError event (fixes #609)

lib/client.js

@@ -130,7 +130,7 @@ Client.prototype._setup = function() {
     });
 
     function handleError(err) {
-      that.logger.warn(err);
+      that.server.emit("clientError", err, that);
       that.onNonDisconnectClose(err.message);
     }
 

lib/server.js

@@ -86,6 +86,8 @@ var nop = function() {};
  *    the client is passed as a parameter.
  *  - `clientDisconnected`, when a client is disconnected;
  *    the client is passed as a parameter.
+ *  - `clientError`, when the server identifies a client connection error;
+ *    the error and the client are passed as parameters.
  *  - `published`, when a new message is published;
  *    the packet and the client are passed as parameters.
  *  - `subscribed`, when a client is subscribed to a topic;

test/server.js

@@ -279,6 +279,19 @@ describe("mosca.Server", function() {
     });
   });
 
+  it("should emit \"clientError\" when client error occurs due to unexpected disconnection", function(done) {
+    var instance = this.instance;
+    // listen to a client error event
+    instance.once("clientError", function(error, client) {
+      expect(error).to.be.an('error');
+      done();
+    });
+    // cause a connection error between client and server
+    buildAndConnect(function () {}, instance, function(client) {
+      instance.clients[client.opts.clientId]['connection'].emit("error", new Error());
+    });
+  });
+
   describe("timers", function() {
     var clock;