Fix lint errors (#656)

OptimalBits · Aug 13, 2017 · 1b6b08d · 1b6b08d
1 parent 51b1347
commit 1b6b08d
Show file tree

Hide file tree

Showing 6 changed files with 45 additions and 43 deletions.
diff --git a/lib/commands/index.js b/lib/commands/index.js
@@ -37,8 +37,7 @@ module.exports = (function (){
 function loadScripts(dir) {
   return fs.readdirAsync(dir).filter(function (file){
     return path.extname(file) === '.lua';
-  })
-  .map(function (file) {
+  }).map(function (file) {
     var longName = path.basename(file, '.lua');
     var name = longName.split('-')[0];
     var numberOfKeys = parseInt(longName.split('-')[1]);
@@ -50,4 +49,4 @@ function loadScripts(dir) {
       };
     });
   });
-}
+}
diff --git a/lib/job.js b/lib/job.js
@@ -239,11 +239,12 @@ Job.prototype.promote = function(){
     keys.length,
     keys[0],
     keys[1],
-    jobId).then(function(result){
-      if(result === -1){
-        throw new Error('Job ' + jobId + ' is not in a delayed state');
-      }
-    });
+    jobId
+  ).then(function(result){
+    if(result === -1){
+      throw new Error('Job ' + jobId + ' is not in a delayed state');
+    }
+  });
 };
 
 /**

diff --git a/lib/queue.js b/lib/queue.js
@@ -209,8 +209,8 @@ var Queue = function Queue(name, url, opts){
 
 function redisClientGetter(queue, options, initCallback) {
   var createClient = _.isFunction(options.createClient)
-      ? options.createClient
-      : function(type, config) { return new redis(config); };
+    ? options.createClient
+    : function(type, config) { return new redis(config); };
 
   var connections = {};
 

diff --git a/lib/repeatable.js b/lib/repeatable.js
@@ -61,21 +61,22 @@ module.exports = function(Queue){
     end = end || -1;
     return (asc ?
       this.client.zrange(key, start, end, 'WITHSCORES') :
-      this.client.zrevrange(key, start, end, 'WITHSCORES')).then(function(result){
-        var jobs = [];
-        for(var i=0; i<result.length; i+=2){
-          var data = result[i].split(':');
-          jobs.push({
-            name: data[0],
-            id: data[1] || null,
-            endDate: parseInt(data[2]) || null,
-            tz: data[3] || null,
-            cron: data[4],
-            next: parseInt(result[i+1])
-          });
-        }
-        return jobs;
-      });
+      this.client.zrevrange(key, start, end, 'WITHSCORES')
+    ).then(function(result){
+      var jobs = [];
+      for(var i=0; i<result.length; i+=2){
+        var data = result[i].split(':');
+        jobs.push({
+          name: data[0],
+          id: data[1] || null,
+          endDate: parseInt(data[2]) || null,
+          tz: data[3] || null,
+          cron: data[4],
+          next: parseInt(result[i+1])
+        });
+      }
+      return jobs;
+    });
   };
 
   Queue.prototype.getRepeatableCount = function(){

diff --git a/test/cluster_worker.js b/test/cluster_worker.js
@@ -22,7 +22,7 @@ queue.process(1, function(job, jobDone) {
 
 process.on('disconnect', function () {
   queue.close().then(function () {
-//    process.exit(0);
+  //  process.exit(0);
   }).catch(function (err) {
     console.error(err);
   //  process.exit(-1);

diff --git a/test/test_queue.js b/test/test_queue.js
@@ -1528,24 +1528,25 @@ describe('Queue', function () {
         queue.add({ order: 2 }, { delay: 300 }),
         queue.add({ order: 4 }, { delay: 500 }),
         queue.add({ order: 1 }, { delay: 200 }),
-        queue.add({ order: 3 }, { delay: 400 })).then(function () {
-          //
-          // Start processing so that jobs get into the delay set.
-          //
-          queue.process(fn);
-        }).delay(20).then(function () {
-          /*
-          //We simulate a restart
-          console.log('RESTART');
-          return queue.close().then(function () {
-            console.log('CLOSED');
-            return Promise.delay(100).then(function () {
-              queue = new Queue(QUEUE_NAME);
-              queue.process(fn);
-            });
+        queue.add({ order: 3 }, { delay: 400 })
+      ).then(function () {
+        //
+        // Start processing so that jobs get into the delay set.
+        //
+        queue.process(fn);
+      }).delay(20).then(function () {
+        /*
+        //We simulate a restart
+        console.log('RESTART');
+        return queue.close().then(function () {
+          console.log('CLOSED');
+          return Promise.delay(100).then(function () {
+            queue = new Queue(QUEUE_NAME);
+            queue.process(fn);
           });
-          */
         });
+        */
+      });
     });
 
     it('should process delayed jobs with exact same timestamps in correct order (FIFO)', function (done) {
@@ -2458,4 +2459,4 @@ describe('Queue', function () {
       });
     });
   });
-});
+});