queues - npm Package Compare versions

Comparing version 0.0.6 to 0.1.0

index.js

 module.exports = {
-  iron: require('./lib/iron')
+  iron: require('./lib/iron'),
+  sqs: require('./lib/sqs')
 };

lib/iron.js

@@ -0,1 +1,2 @@
+
 /**
@@ -7,3 +8,3 @@ * Module dependencies
 var ironMQ = require('iron_mq');
-var debug = require('debug')('queues');
+var debug = require('debug')('queues:iron');
 
@@ -22,9 +23,12 @@ /**
 
-function Provider(config) {
+function Provider(id, secret) {
   if (!(this instanceof Provider)) {
-    return new Provider(config);
+    return new Provider(id, secret);
   }
 
+  this.client = new ironMQ.Client({
+    project_id: id, 
+    token: secret
+  });
 
-  this.client = new ironMQ.Client(config);
   this.queues = {};
@@ -47,4 +51,2 @@ }
  * @class Queue
- *
- * @param {Object} config - ironmq config object
  */
@@ -118,4 +120,5 @@
 
-Queue.prototype.remove = function(msgId, callback) {
+Queue.prototype.remove = function(msg, callback) {
   var self = this;
+  var msgId = msg.id;
 
@@ -126,4 +129,4 @@ self.q.del(msgId, function(err, body) {
     else
-      debug('message deleted "%s"', msgId)
+      debug('message deleted "%s"', msgId);
   });
 };

package.json

 {
   "name": "queues",
-  "version": "0.0.6",
+  "version": "0.1.0",
   "description": "Collection of queue wrappers with a common interface.",
@@ -25,4 +25,5 @@ "main": "index.js",
     "debug": "^1.0.0",
-    "event-emitter": "^0.3.1"
+    "event-emitter": "^0.3.1",
+    "aws-sqs": "0.0.6"
   }
 }

No alert changes

Improved metrics

Total package byte prevSize

7747

increased by68.3%

Number of package files

8

increased by14.29%

Lines of code

259

increased by146.67%

Worsened metrics

Dependency count

4

increased by33.33%

Dependency changes

• + Addedaws-sqs@0.0.6

• + Addedaws-lib@0.0.6(transitive)

• + Addedaws-sqs@0.0.6(transitive)

• + Addedsax@0.1.5(transitive)

• + Addedxml2js@0.1.14(transitive)