cinovo-loganalyzer-aws - npm Package Compare versions

Comparing version 0.0.5 to 0.0.6

index.js

@@ -22,28 +22,36 @@ var util = require("util"),
 			self.emit("error", err);
-		} else if (data.Messages) {
-			var messages2Delete = [];
-			data.Messages.forEach(function(message) {
-				try {
-					var log = JSON.parse(message.Body);
-					self.emit("log", log);
-					messages2Delete.push({Id: message.MessageId, ReceiptHandle: message.ReceiptHandle});
-				} catch (err) {
-					self.emit("error", err);
-				}
-			});
-			self.sqs.deleteMessageBatch({QueueUrl: self.queueUrl, Entries: messages2Delete}, function(err) {
-				if (self.stopping === true) {
-					return; // prevent consuming if stop() was called
-				}
-				if (err) {
-					self.emit("error", err);
-				} else {
-					var consumeTime = (new Date).getTime() - begin.getTime();
-					self.emit("consumed", consumeTime);
-					self.timer = setTimeout(function() {
-						self.consume();
-					}, 1);
-				}
-			});
-		}
+		} else {
+            if (data.Messages) { // we have data to get
+                var messages2Delete = [];
+                data.Messages.forEach(function(message) {
+                    try {
+                        var log = JSON.parse(message.Body);
+                        self.emit("log", log);
+                        messages2Delete.push({Id: message.MessageId, ReceiptHandle: message.ReceiptHandle});
+                    } catch (err) {
+                        self.emit("error", err);
+                    }
+                });
+                self.sqs.deleteMessageBatch({QueueUrl: self.queueUrl, Entries: messages2Delete}, function(err) {
+                    if (self.stopping === true) {
+                        return; // prevent consuming if stop() was called
+                    }
+                    if (err) {
+                        self.emit("error", err);
+                    } else {
+                        var consumeTime = (new Date).getTime() - begin.getTime();
+                        self.emit("consumed", consumeTime, data.Messages.length);
+                        self.timer = setTimeout(function() {
+                            self.consume();
+                        }, 1);
+                    }
+                });
+            } else { // we have no data to get
+                var consumeTime = (new Date).getTime() - begin.getTime();
+                self.emit("consumed", consumeTime, 0);
+                self.timer = setTimeout(function() {
+                    self.consume();
+                }, 1);
+            }
+        }
 	});
@@ -50,0 +58,0 @@ };

package.json

 {
 	"name": "cinovo-loganalyzer-aws",
-	"version": "0.0.5",
+	"version": "0.0.6",
 	"description": "AWS SQS sourcepoint and SNS sire for cinovo-loganalyzer.",
@@ -29,9 +29,9 @@ "keywords": [
 		"assert-plus": "0.1.4",
-		"aws-sdk": "1.5.0"
+		"aws-sdk": "1.8.0"
 	},
 	"devDependencies": {
-		"mocha": "1.12.0",
-		"jslint": "0.1.9",
-		"madge": "0.1.4",
-		"npmedge": "0.1.3"
+		"mocha": "1.13.0",
+		"jslint": "0.1.10",
+		"madge": "0.1.7",
+		"npmedge": "0.1.4"
 	},
@@ -38,0 +38,0 @@ "main": "index",

No alert changes

Improved metrics

Total package byte prevSize

10908

increased by7.63%

Lines of code

230

increased by3.6%

Dependency changes

• + Addedaws-sdk@1.8.0(transitive)

• - Removedaws-sdk@1.5.0(transitive)

• Updatedaws-sdk@1.8.0