Add the fields that triggered update notifications

features/kuzzle.feature

@@ -326,6 +326,7 @@ Feature: Kuzzle functional tests
     When I write the document "documentAda"
     Then I update the document with value "Hopper" in field "lastName"
     Then I should receive a document notification with field action equal to "update"
+    And The notification should have "_updatedFields" array with 1 element
     And The notification should have a "_source" member
     And The notification should have volatile
 

features/step_definitions/notifications.js

@@ -37,6 +37,17 @@ Then(/^I should receive a ?(.*?) notification with field ?(.*?) equal to "([^"]*
   });
 });
 
+
+Then(/^The notification should have "([^"]*)" array with ([\d]*) element/, function (member, n_elements, callback) {
+  if (this.api.responses.result[member].length === parseInt(n_elements)) {
+    callback();
+  } else {
+    console.log('Wrong notification received: ');
+    console.dir(this.api.responses, { colors: true, depth: null });
+    callback('The document was supposed to contain the member "' + member + '" with ' + n_elements + ' elements : Has '+ this.api.responses.result[member].length +'.');
+  }
+});
+
 Then(/^The notification should ?(not)* have a "([^"]*)" member/, function (not, member, callback) {
   if ((this.api.responses.result[member] || not) && !(this.api.responses.result[member] && not)) {
     callback();

lib/api/core/notifier.js

@@ -340,11 +340,16 @@ class NotifierController {
           result._source,
           result._id);
 
+
+        const updatedFields = Object.keys(request.input.body)
+          .filter(_updatedFields => _updatedFields !== '_kuzzle_info');
+
         return this.notifyDocument(
           matchedRooms, request, 'in', 'done', 'update', {
             _meta: updatedDocument._meta || {},
             _id: updatedDocument._id,
-            _source: updatedDocument._source
+            _source: updatedDocument._source,
+            _updatedFields: updatedFields
           });
       })
       .then(() => this.cache.get(cachePrefix + updatedDocument._id))

test/api/core/notifier/notifyDocumentUpdate.test.js

@@ -65,7 +65,8 @@ describe('Test: notifier.notifyDocumentUpdate', () => {
           {
             _id,
             _meta: {canIhas: 'cheezburgers?'},
-            _source: {foo: 'bar'}
+            _source: {foo: 'bar'},
+            _updatedFields: ['foo']
           });
 
         should(notifier.notifyDocument.getCall(1)).calledWith(