From 0f3b21f1e874c61238560765cb9bde37c99d0ae4 Mon Sep 17 00:00:00 2001
From: Joe Fleming <joe.fleming@gmail.com>
Date: Tue, 26 Apr 2016 17:40:14 -0700
Subject: [PATCH] add worker query for outstanding jobs

---
 src/worker.js | 29 ++++++++++++++++++++++++++++-
 1 file changed, 28 insertions(+), 1 deletion(-)

diff --git a/src/worker.js b/src/worker.js
index 3cedfb5..0484929 100644
--- a/src/worker.js
+++ b/src/worker.js
@@ -27,7 +27,34 @@ export default class Job extends events.EventEmitter {
   }
 
   _processJobs() {
-    const query = {};
+    const query = {
+      query: {
+        bool: {
+          must: [{ term: { _type: 'example' } }],
+          should: [
+            { bool: {
+              must: [{ term: { status: 'pending'} }]
+            }},
+            { bool: {
+              must: [
+                { term: { status: 'processing'}}
+              ],
+              filter: {
+                range: {
+                  process_expiration: {
+                    lte: '2016-04-26T23:40:47.820Z'
+                  }
+                }
+              }
+            }}
+          ]
+        }
+      },
+      sort: [
+        { priority: { order: 'asc' }},
+        { created_at: { order: 'asc' }}
+      ]
+    };
 
     return this.client.search({
       body: {