chore: add linting, fix lint issues

package.json

@@ -8,6 +8,7 @@
     "package": "git checkout -B package-lib && npm run build && git add -f lib && git commit -m 'package lib' && echo Use npm to tag and publish",
     "prepublish": "in-publish && npm run test || not-in-publish",
     "test": "retire -n -p package.json && npm run build && npm run unit",
+    "lint": "eslint \"*.js\" \"src/**/*.js\"",
     "unit": "nyc --require babel-core/register mocha test/src/**"
   },
   "author": "Joe Fleming (https://github.com/w33ble)",

src/helpers/create_client.js

@@ -10,7 +10,7 @@ export default function createClient(options) {
   }
 
   return client;
-};
+}
 
 export function isClient(client) {
   // if there's a transport property, assume it's a client instance

src/helpers/errors.js

@@ -4,7 +4,7 @@ export function WorkerTimeoutError(message, props = {}) {
   this.timeout = props.timeout;
   this.jobId = props.jobId;
 
-  if ("captureStackTrace" in Error) Error.captureStackTrace(this, WorkerTimeoutError);
+  if ('captureStackTrace' in Error) Error.captureStackTrace(this, WorkerTimeoutError);
   else this.stack = (new Error()).stack;
 }
 WorkerTimeoutError.prototype = Object.create(Error.prototype);
@@ -14,7 +14,7 @@ export function UnspecifiedWorkerError(message, props = {}) {
   this.message = message;
   this.jobId = props.jobId;
 
-  if ("captureStackTrace" in Error) Error.captureStackTrace(this, UnspecifiedWorkerError);
+  if ('captureStackTrace' in Error) Error.captureStackTrace(this, UnspecifiedWorkerError);
   else this.stack = (new Error()).stack;
 }
 UnspecifiedWorkerError.prototype = Object.create(Error.prototype);

src/worker.js

@@ -332,12 +332,12 @@ export default class Worker extends events.EventEmitter {
             bool: {
               filter: { term: { jobtype: this.jobtype } },
               should: [
-                { term: { status: 'pending'} },
+                { term: { status: 'pending' } },
                 { bool:
-                  { filter: [
+                { filter: [
                     { term: { status: 'processing' } },
                     { range: { process_expiration: { lte: nowTime } } }
-                  ] }
+                ] }
                 }
               ]
             }
@@ -345,8 +345,8 @@ export default class Worker extends events.EventEmitter {
         }
       },
       sort: [
-        { priority: { order: 'asc' }},
-        { created_at: { order: 'asc' }}
+        { priority: { order: 'asc' } },
+        { created_at: { order: 'asc' } }
       ],
       size: this.checkSize
     };