Run prettier once over all JavaScript files'

Author: mxstbr

examples/cluster-queue.js

@@ -1,31 +1,29 @@
 'use strict';
 
-var
-  Queue = require('..'),
+var Queue = require('..'),
   cluster = require('cluster');
 
 var numWorkers = 8;
 var queue = Queue('test concurrent queue', 6379, '127.0.0.1');
 
-if(cluster.isMaster){
+if (cluster.isMaster) {
   for (var i = 0; i < numWorkers; i++) {
     cluster.fork();
   }
 
   cluster.on('online', function(worker) {
     // Lets create a few jobs for every created worker
-    for(var i=0; i<500; i++){
-      queue.add({foo: 'bar'});
-    };
+    for (var i = 0; i < 500; i++) {
+      queue.add({ foo: 'bar' });
+    }
   });
 
   cluster.on('exit', function(worker, code, signal) {
     console.log('worker ' + worker.process.pid + ' died');
   });
-}else{
-  queue.process(function(job, jobDone){
+} else {
+  queue.process(function(job, jobDone) {
     console.log('Job done by worker', cluster.worker.id, job.jobId);
     jobDone();
   });
 }
-

examples/message.js

@@ -10,40 +10,40 @@ interface JobOptions
 */
 
 // queue: Queue, msgId: string, data: {}, opts: JobOptions
-var Message = function Message(queue, msgId, data, opts){
+var Message = function Message(queue, msgId, data, opts) {
   this.queue = queue;
   this.msgId = msgId;
   this.data = data;
   this.opts = opts;
   this._progress = 0;
 };
 
-Message.create = function(queue, msgId, data, opts){
+Message.create = function(queue, msgId, data, opts) {
   var deferred = when.defer();
   var msg = new Message(queue, msgId, data, opts);
-  queue.client.HMSET(queue.toKey(msgId), msg.toData(), function(err){
-    if(err){
+  queue.client.HMSET(queue.toKey(msgId), msg.toData(), function(err) {
+    if (err) {
       deferred.reject(err);
-    }else{
+    } else {
       deferred.resolve(job);
     }
   });
   return deferred.promise;
 };
 
-Message.fromId = function(queue, msgId){
+Message.fromId = function(queue, msgId) {
   var deferred = when.defer();
-  queue.client.HGETALL(queue.toKey(msgId), function(err, data){
-    if(data){
+  queue.client.HGETALL(queue.toKey(msgId), function(err, data) {
+    if (data) {
       deferred.resolve(Message.fromData(queue, msgId, data));
-    }else{
+    } else {
       deferred.reject(err);
     }
   });
   return deferred.promise;
 };
 
-Message.prototype.toData = function(){
+Message.prototype.toData = function() {
   return {
     name: this.name,
     data: JSON.stringify(this.data || {}),
@@ -52,71 +52,80 @@ Message.prototype.toData = function(){
   };
 };
 
-Message.prototype.progress = function(progress){
-  if(progress){
+Message.prototype.progress = function(progress) {
+  if (progress) {
     var deferred = when.defer();
     var _this = this;
-    this.queue.client.hset(this.queue.toKey(this.msgId), 'progress', progress, function(err){
-      if(err){
-        deferred.reject(err);
-      }else{
-        deferred.resolve();
-        _this.queue.emit('progress', _this, progress);
+    this.queue.client.hset(
+      this.queue.toKey(this.msgId),
+      'progress',
+      progress,
+      function(err) {
+        if (err) {
+          deferred.reject(err);
+        } else {
+          deferred.resolve();
+          _this.queue.emit('progress', _this, progress);
+        }
       }
-    });
+    );
     return deferred.promise;
-  }else{
+  } else {
     return this._progress;
   }
 };
 
-Job.prototype.completed = function(){
+Job.prototype.completed = function() {
   return this._done('completed');
 };
 
-Job.prototype.failed = function(err){
+Job.prototype.failed = function(err) {
   return this._done('failed');
 };
 
-Job.prototype.isCompleted = function(){
+Job.prototype.isCompleted = function() {
   return this._isDone('completed');
 };
 
-Job.prototype.isFailed = function(){
+Job.prototype.isFailed = function() {
   return this._isDone('failed');
 };
 
-Job.prototype._isDone = function(list){
+Job.prototype._isDone = function(list) {
   var deferred = when.defer();
-  this.queue.client.SISMEMBER(this.queue.toKey(list), this.jobId, function(err, isMember){
-    if(err){
+  this.queue.client.SISMEMBER(this.queue.toKey(list), this.jobId, function(
+    err,
+    isMember
+  ) {
+    if (err) {
       deferred.reject(err);
-    }else{
+    } else {
       deferred.resolve(isMember === 1);
     }
   });
   return deferred.promise;
 };
 
-Job.prototype._done = function(list){
+Job.prototype._done = function(list) {
   var deferred = when.defer();
   var queue = this.queue;
   var activeList = queue.toKey('active');
   var completedList = queue.toKey(list);
 
-  queue.client.multi()
+  queue.client
+    .multi()
     .lrem(activeList, 0, this.jobId)
     .sadd(completedList, this.jobId)
-    .exec(function(err){
+    .exec(function(err) {
       !err && deferred.resolve();
       err && deferred.reject(err);
     });
   return deferred.promise;
 };
 
 /**
-*/
-Job.fromData = function(queue, jobId, data){
+ */
+Job.fromData = function(queue, jobId, data) {
   var job = new Job(queue, jobId, data.name, JSON.parse(data.data), data.opts);
   job._progress = parseInt(data.progress);
   return job;

examples/state.js

@@ -6,14 +6,14 @@
 
 var machine = Machine('signup', opts); // opts -> redis connection mostly, name of the machine.
 
-machine.state('send mail', function(data, next){
+machine.state('send mail', function(data, next) {
   // In this state we send an email with a confirmation link and exit the state
   next('wait confirmation', data);
 });
 
 machine.state('wait confirmation'); // // In this state we do nothing we just wait for an external input
 
-machine.state('confirm user', function(task){
+machine.state('confirm user', function(task) {
   return data;
 });
 
@@ -22,27 +22,25 @@ machine.next('wait confirmation', data);
 /**
   queue('wait confirmation').add(data);
   */
-machine.state('transcode video', function(data){
-  // transcode...
-  this.next('append moov');
-}).catch(function(err){
-  this.next('delete tmp');
-});
-
-machine.state('append moov', input, function(data, next){
+machine
+  .state('transcode video', function(data) {
+    // transcode...
+    this.next('append moov');
+  })
+  .catch(function(err) {
+    this.next('delete tmp');
+  });
+
+machine.state('append moov', input, function(data, next) {
   // Append MOOV etc.
   this.next('delete tmp');
 });
 
-machine.next('delete temp', input, function(data, next){
+machine.next('delete temp', input, function(data, next) {
   // delete temp file
   this.next('update user account');
 });
 
-machine.state('update user account', function(data, next){
+machine.state('update user account', function(data, next) {
   // update database
 });
-
-
-
-

index.js

@@ -1,3 +1,2 @@
-
 module.exports = require('./lib/queue');
 module.exports.Job = require('./lib/job');

lib/backoffs.js

@@ -1,14 +1,14 @@
 var _ = require('lodash');
 
 var builtinStrategies = {
-  fixed: function (delay) {
-    return function () {
+  fixed: function(delay) {
+    return function() {
       return delay;
     };
   },
 
-  exponential: function (delay) {
-    return function (attemptsMade) {
+  exponential: function(delay) {
+    return function(attemptsMade) {
       return Math.round((Math.pow(2, attemptsMade) - 1) * delay);
     };
   }
@@ -20,12 +20,16 @@ function lookupStrategy(backoff, customStrategies) {
   } else if (backoff.type in builtinStrategies) {
     return builtinStrategies[backoff.type](backoff.delay);
   } else {
-    throw new Error('Unknown backoff strategy ' + backoff.type + '. If a custom backoff strategy is used, specify it when the queue is created.');
+    throw new Error(
+      'Unknown backoff strategy ' +
+        backoff.type +
+        '. If a custom backoff strategy is used, specify it when the queue is created.'
+    );
   }
 }
 
 module.exports = {
-  normalize: function (backoff) {
+  normalize: function(backoff) {
     if (_.isFinite(backoff)) {
       return {
         type: 'fixed',
@@ -36,7 +40,7 @@ module.exports = {
     }
   },
 
-  calculate: function (backoff, attemptsMade, customStrategies) {
+  calculate: function(backoff, attemptsMade, customStrategies) {
     if (backoff) {
       var strategy = lookupStrategy(backoff, customStrategies);
 

lib/commands/index.js

@@ -24,33 +24,36 @@ fs = Promise.promisifyAll(fs);
 // for some very strange reason, defining scripts with this code results in this error
 // when executing the scripts: ERR value is not an integer or out of range
 //
-module.exports = (function (){
+module.exports = (function() {
   var scripts;
 
-  return function(client){
-    return utils.isRedisReady(client).then(function(){
+  return function(client) {
+    return utils.isRedisReady(client).then(function() {
       scripts = scripts || loadScripts(__dirname);
 
-      return scripts.each(function (command){
+      return scripts.each(function(command) {
         return client.defineCommand(command.name, command.options);
       });
     });
   };
 })();
 
 function loadScripts(dir) {
-  return fs.readdirAsync(dir).filter(function (file){
-    return path.extname(file) === '.lua';
-  }).map(function (file) {
-    var longName = path.basename(file, '.lua');
-    var name = longName.split('-')[0];
-    var numberOfKeys = parseInt(longName.split('-')[1]);
-
-    return fs.readFileAsync(path.join(dir, file)).then(function(lua){
-      return {
-        name: name,
-        options: { numberOfKeys: numberOfKeys, lua: lua.toString() }
-      };
+  return fs
+    .readdirAsync(dir)
+    .filter(function(file) {
+      return path.extname(file) === '.lua';
+    })
+    .map(function(file) {
+      var longName = path.basename(file, '.lua');
+      var name = longName.split('-')[0];
+      var numberOfKeys = parseInt(longName.split('-')[1]);
+
+      return fs.readFileAsync(path.join(dir, file)).then(function(lua) {
+        return {
+          name: name,
+          options: { numberOfKeys: numberOfKeys, lua: lua.toString() }
+        };
+      });
     });
-  });
 }

lib/errors.js

@@ -1,7 +1,8 @@
 'use strict';
 
 module.exports.Messages = {
-  RETRY_JOB_NOT_EXIST: 'Couldn\'t retry job: The job doesn\'t exist',
-  RETRY_JOB_IS_LOCKED: 'Couldn\'t retry job: The job is locked',
-  RETRY_JOB_NOT_FAILED: 'Couldn\'t retry job: The job has been already retried or has not failed'
-};
+  RETRY_JOB_NOT_EXIST: "Couldn't retry job: The job doesn't exist",
+  RETRY_JOB_IS_LOCKED: "Couldn't retry job: The job is locked",
+  RETRY_JOB_NOT_FAILED:
+    "Couldn't retry job: The job has been already retried or has not failed"
+};