hive-dev - npm Package Compare versions

Comparing version 1.0.12 to 1.0.13

lib/defaults/general.js

@@ -46,3 +46,3 @@ /**
         min: 1,
-        max: 2
+        max: 1
       },
@@ -52,22 +52,22 @@ {
         scale: 0,
-        min: 2,
-        max: 4
+        min: 1,
+        max: 2
       },
       {
         name: 'default',
-        scale: 1,
-        min: 3,
-        max: 6
+        scale: 0,
+        min: 1,
+        max: 3
       },
       {
         name: 'high',
-        scale: 2,
-        min: 4,
-        max: 8
+        scale: 0,
+        min: 2,
+        max: 4
       },
       {
         name: 'highest',
-        scale: 3,
-        min: 5,
-        max: 10
+        scale: 0,
+        min: 3,
+        max: 5
       }
@@ -74,0 +74,0 @@ ],

lib/plugins/throttle.js

@@ -52,8 +52,11 @@ /**
         var updateKey = function updateKey(key, per, count, callback) {
-          _this.redis.pipeline([
-            ['hmset', key, 'timestamp', new Date().getTime().toString(), 'count', count],
-            ['expire', key, per]
-          ]).exec(callback);
+          if (count == 1)
+            _this.redis.pipeline([
+              ['hmset', key, 'timestamp', new Date().getTime().toString(), 'count', count],
+              ['expire', key, per]
+            ]).exec(callback);
+          else
+            _this.redis.hmset(key, {timestamp: new Date().getTime().toString(), count: count}, callback);
+        };
 
-        };
         var limit = _this.task.options.throttle.limit;
@@ -64,3 +67,2 @@ var per = _this.task.options.throttle.per;
 
-
         if (limit > 0 && per) {
@@ -72,3 +74,3 @@
               _this.redis.del(_this.key('queue'), function (err) {
-                _this.lane.queueObject.enqueueIn(perMs + (Math.floor(Math.random() * perMs) + 1000),
+                _this.lane.queueObject.enqueueIn((perMs / 2) + (Math.floor(Math.random() * perMs) + 1000),
                   _this.task.options.priority, 'HiveRunner', _this.task, function () {
@@ -75,0 +77,0 @@ next(null, false);

lib/services/runner.js

@@ -95,3 +95,2 @@ /**
 
-
         }
@@ -98,0 +97,0 @@ }

lib/services/worker.js

@@ -91,6 +91,4 @@ /**
     _this.on('success', function (worker, priority, job, result) {
-      //console.log('Worker: finished a', priority, 'priority job.', {
-      //  worker: worker,
-      //  name: {class: job.class, priority: job.queue}
-      //});
+      if (process.env.NODE_ENV && process.env.NODE_ENV == 'development')
+        console.log(new Date() + ': Task "' + job.args[0].name + '" completed!');
     });
@@ -97,0 +95,0 @@

package.json

 {
   "name": "hive-dev",
-  "version": "1.0.12",
+  "version": "1.0.13",
   "description": "An intelligent Redis powered, job, worker and queue library with advanced options and plugin support.",
@@ -5,0 +5,0 @@ "main": "index.js",

README.md

@@ -16,2 +16,3 @@ # Hive
  - Unique locking of queue items based on all task data. [DONE]
+ - Repeatable Tasks [DONE]
  - Priority queues with scaleable task processesors per priority. [DONE]
@@ -22,2 +23,2 @@ - Clustered by design, works across multiple servers but also just as well on it's own. [DONE]
  - API [WIP]
- - Plugins [DONE - Just queue pluginss for now]
+ - Plugins [DONE - Just queue plugins for now]

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

174204

increased by1.29%

Lines of code

3228

increased by0.03%

Number of lines in readme file

23

increased by4.55%

Worsened metrics

Number of low supply chain risk alerts

16

increased by14.29%

No dependency changes