Merge pull request #139 from kuzzleio/feature-532-refresh-wait-for

Add refresh as option

Author: scottinet

package.json

@@ -18,7 +18,8 @@
     "bulk"
   ],
   "scripts": {
-    "test": "npm run --silent lint && istanbul cover _mocha  -- --recursive",
+    "test": "npm run --silent lint && npm run unit-testing",
+    "unit-testing": "istanbul cover _mocha  -- --recursive",
     "lint": "eslint --max-warnings=0 ./lib ./test",
     "build": "node build.js"
   },

src/kuzzle.js

@@ -1253,15 +1253,19 @@ Kuzzle.prototype.query = function (queryArgs, query, options, cb) {
   }
 
   if (options) {
+    if (options.queuable === false && self.state === 'offline') {
+      return self;
+    }
+
+    if (options.refresh) {
+      object.refresh = options.refresh;
+    }
+
     if (options.metadata) {
       Object.keys(options.metadata).forEach(function (meta) {
         object.metadata[meta] = options.metadata[meta];
       });
     }
-
-    if (options.queuable === false && self.state === 'offline') {
-      return self;
-    }
   }
 
   if (!query || typeof query !== 'object' || Array.isArray(query)) {

test/.eslintrc.json

@@ -3,6 +3,7 @@
     "func-names": 0,
     "no-invalid-this": 0,
     "no-new": 0,
-    "new-cap": 0
+    "new-cap": 0,
+    "no-console": 0
   }
 }

test/kuzzle/query.test.js

@@ -164,6 +164,14 @@ describe('Query management', function () {
       should(requestObject.metadata).match(metadata);
     });
 
+    it('should handle option refresh properly', function () {
+      var
+        refresh = 'foo';
+
+      kuzzle.query(queryArgs, { body: { some: 'query'}}, {refresh: refresh});
+      should(requestObject.refresh).match(refresh);
+    });
+
     it('should exit early if the query is not queuable and the SDK is offline', function () {
       kuzzle.state = 'offline';
       kuzzle.query(queryArgs, { body: { some: 'query'}}, {queuable: false});