0.3.2

package.json

@@ -1,6 +1,6 @@
 {
   "name": "esqueue",
-  "version": "0.3.1",
+  "version": "0.3.2",
   "description": "Job queue, powered by Elasticsearch",
   "main": "lib/index.js",
   "scripts": {

src/worker.js

@@ -180,7 +180,7 @@ export default class Job extends events.EventEmitter {
   }
 
   _claimPendingJobs(jobs) {
-    if (jobs.length === 0) return;
+    if (!jobs || jobs.length === 0) return;
 
     this._stopJobPolling();
     let claimed = false;
@@ -268,7 +268,7 @@ export default class Job extends events.EventEmitter {
     })
     .catch((err) => {
       // ignore missing indices errors
-      if (err.status === 404) return;
+      if (err.status === 404) return [];
 
       this.debug('job querying failed', err);
       this.emit('error', err);

test/src/worker.js

@@ -165,6 +165,24 @@ describe('Worker class', function () {
         .then(() => { done(); })
         .catch(() => done(new Error('should not reject')));
       });
+
+      it('should return an empty array on missing index', function (done) {
+        searchStub = sinon.stub(mockQueue.client, 'search', () => Promise.reject({
+          status: 404
+        }));
+        worker = new Worker(mockQueue, 'test', noop);
+        worker._getPendingJobs()
+        .then((res) => {
+          try {
+            expect(res).to.be.an(Array);
+            expect(res).to.have.length(0);
+            done();
+          } catch (e) {
+            done(e);
+          }
+        })
+        .catch(() => done(new Error('should not reject')));
+      });
     });
 
     describe('query parameters', function () {