Merge pull request #117 from kuzzleio/develop-event-queryerror

add queryError event

Author: stafyniaksacha

src/kuzzle.js

@@ -57,7 +57,8 @@ module.exports = Kuzzle = function (host, options, cb) {
         jwtTokenExpired: {lastEmitted: null, listeners: []},
         loginAttempt: {lastEmitted: null, listeners: []},
         offlineQueuePush: {listeners: []},
-        offlineQueuePop: {listeners: []}
+        offlineQueuePop: {listeners: []},
+        queryError: {listeners: []}
       }
     },
     eventTimeout: {
@@ -704,13 +705,14 @@ function emitRequest (request, cb) {
         self.emitEvent('jwtTokenExpired', request, cb);
       }
 
+      if (response.error) {
+        error = new Error(response.error.message);
+        Object.assign(error, response.error);
+        error.status = response.status;
+        self.emitEvent('queryError', error, request, cb);
+      }
+
       if (cb) {
-        if (response.error) {
-          error = new Error(response.error.message);
-          Object.assign(error, response.error);
-          error.status = response.status;
-        }
-        
         cb(error, response);
       }
     });

test/kuzzle/query.test.js

@@ -53,6 +53,30 @@ describe('Query management', function () {
       });
     });
 
+    it('should fire a queryError if an error occurred', function (done) {
+      var listenerQueryError = false;
+
+      kuzzle.network.send  = () => process.nextTick(() => kuzzle.network.emit('bar', {
+        error: {
+          message: 'foo-bar'
+        }
+      }));
+
+      kuzzle.addListener('queryError', function() {
+        listenerQueryError = true;
+      });
+
+      this.timeout(150);
+
+      emitRequest.call(kuzzle, {requestId: 'bar'}, function(error) {
+        process.nextTick(() => {
+          should(listenerQueryError).be.exactly(true);
+          should(error.message).be.exactly('foo-bar');
+          done();
+        });
+      });
+    });
+
     it('should launch the callback once a response has been received', function (done) {
       var
         response = {result: 'foo', error: {foo: 'bar', message: 'foobar'}, status: 42},