rqueue - npm Package Compare versions

Comparing version 0.2.0 to 0.4.0

index.js

@@ -152,3 +152,3 @@ /**
           ._returnJob(jobs[i])
-          .addMessage('Retry set on "' + queue.name + ':' + queue.id + '".')
+          .message('Retry set on "' + queue.name + ':' + queue.id + '".')
           .forward('queued', null, true)
@@ -275,3 +275,3 @@ } catch (error) {}
   var queue       = this
-  var job         = queue.createJob(payload)
+  var job         = queue.job(payload)
 
@@ -288,3 +288,3 @@ job.forward('queued', callback)
  */
-Queue.prototype.createJob = function createJob (payload) {
+Queue.prototype.job = function job (payload) {
   var queue       = this
@@ -317,3 +317,3 @@ var now         = Date.now()
  */
-Queue.prototype.getJob = function getJob (uuid, callback) {
+Queue.prototype.findJob = function findJob (uuid, callback) {
   if (!callback) callback = asyncLog
@@ -551,3 +551,3 @@ var queue = this
  */
-Job.prototype.addMessage = function addMessage (message) {
+Job.prototype.message = function message (message) {
   var job = this
@@ -566,3 +566,3 @@
  */
-Job.prototype.addError = function addError (error) {
+Job.prototype.error = function error (error) {
   var job = this
@@ -629,3 +629,3 @@
   if (job.is_new) {
-    job.addMessage('Created on "' + job.queue + ':' + job.parent.id + '".')
+    job.message('Created on "' + job.queue + ':' + job.parent.id + '".')
     client.publish(job._prefix + ':new', job.id)
@@ -725,5 +725,5 @@ }
   if (error) {
-    job.addError(error)
+    job.error(error)
   }
-  job.addMessage('Retry set on "' + job.queue + ':' + job.parent.id + '".')
+  job.message('Retry set on "' + job.queue + ':' + job.parent.id + '".')
 
@@ -756,6 +756,6 @@ job.forward('queued', callback)
   if (error) {
-    job.addError(error)
+    job.error(error)
     dest    = 'failed'
   } else {
-    job.addMessage('Done on "' + job.queue + ':' + job.parent.id + '".')
+    job.message('Done on "' + job.queue + ':' + job.parent.id + '".')
     dest    = 'completed'
@@ -762,0 +762,0 @@ }

package.json

 { "name"          : "rqueue"
 , "description"   : "A node.js implementation of RQueue, includes Worker and Queue."
-, "version"       : "0.2.0"
+, "version"       : "0.4.0"
 , "author"        : "Tim Smart <[e-mail]>"
@@ -5,0 +5,0 @@ , "main"          : "./"

README.md

@@ -10,3 +10,3 @@ node-rqueue
 
-```js
+```javascript
 var rq      = require('rqueue')
@@ -80,3 +80,3 @@ var assert  = require('assert').ok
 // Create a job and mess with individual options.
-var job = q.createJob({ my : 'data' })
+var job = q.job({ my : 'data' })
 assert(null === job.status)
@@ -94,4 +94,4 @@ assert(0 === job.retries)
 // Add some messages
-job.addMessage('Custom info message')
-job.addError(new Error('fail'))
+job.message('Custom info message')
+job.error(new Error('fail'))
 
@@ -103,3 +103,3 @@ // Save the job and push it to the 'queued' status
   // Get a job from an id
-  q.getJob(job.id, function (error, job) {})
+  q.findJob(job.id, function (error, job) {})
 })
@@ -106,0 +106,0 @@ assert('queued' === job.status)

test/migrate.test.js

-var rq      = require('../')
-
-var q       = rq.createQueue(
-  { name    : 'test'
-  , prefix  : 'local:'
-  //, timeout : 5000
-  }
-)
-
-q.migrate('TESTID', function () {
-  q.end()
-})

test/queue.test.js

-var q      = require('../').createQueue({ name: 'queue.test' }),
-    assert = require('assert');
-
-module.exports = {
-  'test queue exports': function () {
-    assert.ok(q.client);
-    assert.equal('queue.test', q.name);
-
-    // Queue methods
-    assert.equal(typeof q.push, 'function');
-  },
-  'test job creation': function (done) {
-    q.push({
-      name: 'Tim',
-      server: 'node'
-    }, function (error, id) {
-      assert.ok(!error);
-      assert.equal(id, 1);
-
-      q.client.lpop('queue:queue.test', function (error, data) {
-        assert.ok(!error);
-
-        data = JSON.parse(data.toString());
-
-        assert.equal(data.id, 1);
-        assert.equal(data.errors.length, 0);
-        assert.equal(data.error_count, 0);
-        assert.equal(data.payload.name, 'Tim');
-        assert.equal(data.payload.server, 'node');
-
-        done();
-      });
-    });
-  },
-  after: function () {
-    q.client.del('queue:queue.test');
-    q.client.del('id:queue.test');
-    q.client.quit();
-  }
-};

test/simple.test.js

-var rq      = require('../')
-
-var q       = rq.createQueue(
-  { name    : 'test'
-  , prefix  : 'local:'
-  , timeout : 5000
-  }
-)
-
-q.id = 'TESTID'
-
-q.once('data', function (job) {
-  job.done()
-
-  q.once('data', test2)
-  q.write('test2')
-})
-
-function test2 (job) {
-  job.emit('custom', 123)
-  job.retry()
-  q.once('data', test3)
-}
-
-function test3 (job) {
-  job.done()
-  q.write('test3')
-  q.getJob(job.id, function (error, job) {
-    console.log(job.payload)
-  })
-}
-
-q.write('test')
-
-q.subscribe('running')
-q.on('running', function (job_id) {
-  console.log('Got running', job_id)
-})
-q.subscribe('custom')
-q.on('custom', function (job_id, data) {
-  console.log('Got custom', job_id, data.toString())
-})
-
-q.listen()
-
-setTimeout(
-  function () {
-    q.end()
-  }
-, 10000
-)

test/worker.test.js

-var client = require('../'),
-    assert = require('assert');
-
-var q = client.createQueue({ name: 'worker.test' }),
-    w = client.createWorker({ name: 'worker.test' }),
-    job;
-
-w.continual = true;
-
-job = new client.Job(w, {
-  payload:     'testing',
-  id:          2,
-  error_count: 0,
-  errors:      []
-}, 'worker.test');
-
-q.push({
-  testing: 'worker',
-  time: 'lunch'
-});
-
-module.exports = {
-  "test Worker events": function (done) {
-    w.once('message', function (job) {
-      assert.ok(job);
-      assert.equal(typeof job.reportError, 'function');
-      assert.equal(typeof job.retry, 'function');
-
-      assert.equal(job.id, 1);
-      assert.equal(job.error_count, 0);
-      assert.equal(job.errors.length, 0);
-      assert.equal(job.payload.testing, 'worker');
-      assert.equal(job.payload.time, 'lunch');
-
-      done();
-    });
-
-    w.start();
-  },
-  "test Worker#stop": function () {
-    w.stop();
-    assert.ok(w.client.quitting);
-  },
-  "test Job#reportError": function () {
-    job.reportError(new Error('Bacon was not tasty enough.'));
-
-    assert.equal(job.errors.length, 1);
-    assert.equal(job.error_count, 1);
-  },
-  "test Job#retry": function (done) {
-    w.on('message', function (job) {
-      w.next();
-
-      assert.ok(job);
-
-      assert.equal(job.id, 2);
-      assert.equal(job.error_count, 1);
-      assert.equal(job.errors.length, 1);
-      assert.equal(job.errors[0], 'Bacon was not tasty enough.');
-      assert.equal(job.payload, 'testing');
-
-      done();
-    });
-
-    w.continual = false;
-    w.start();
-
-    job.retry(function (error, id) {
-      assert.ok(!error);
-      assert.equal(id, job.id);
-    });
-  },
-  after: function () {
-    q.client.del('queue:worker.test');
-    q.client.del('id:worker.test');
-
-    setTimeout(process.exit, 100);
-  }
-};

New alerts

New author

Supply chain risk

A new npm collaborator published a version of the package for the first time. New collaborators are usually benign additions to a project, but do indicate a change to the security surface area of a package.

Found 1 instance in 1 package

Fixed alerts

Non-existent author

Supply chain risk

The package was published by an npm account that no longer exists.

Found 1 instance in 1 package

Major refactor

Supply chain risk

Package has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.

Found 1 instance in 1 package

Improved metrics

Number of high supply chain risk alerts

0

-100%

Worsened metrics

Total package byte prevSize

19567

-16.17%

Number of package files

5

-44.44%

Lines of code

623

-19.3%

No dependency changes