steveo - npm Package Compare versions

Comparing version 1.2.0 to 1.2.1

lib/base/base_runner.js

@@ -13,2 +13,6 @@ 'use strict';
 
+var _lodash3 = require('lodash.shuffle');
+
+var _lodash4 = _interopRequireDefault(_lodash3);
+
 function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
@@ -28,2 +32,5 @@
       var filtered = (0, _lodash2.default)(subscriptions, topics);
+      if (this.config.shuffleQueue) {
+        return (0, _lodash4.default)(filtered);
+      }
       return filtered;
@@ -30,0 +37,0 @@ }

lib/runner/sqs.js

@@ -30,13 +30,2 @@ 'use strict';
 /* istanbul ignore next */
-var getUrl = function getUrl(instance, topic) {
-  var params = {
-    QueueName: topic
-  };
-
-  return instance.getQueueUrlAsync(params).then(function (data) {
-    return data && data.QueueUrl;
-  });
-};
-
-/* istanbul ignore next */
 var deleteMessage = function () {
@@ -286,3 +275,3 @@ var _ref = _asyncToGenerator(regeneratorRuntime.mark(function _callee(_ref2) {
                 if (_iteratorNormalCompletion2 = (_step2 = _iterator2.next()).done) {
-                  _context4.next = 17;
+                  _context4.next = 18;
                   break;
@@ -294,2 +283,8 @@ }
                 queueURL = this.sqsUrls[_topic];
+
+                if (!queueURL) {
+                  _context4.next = 15;
+                  break;
+                }
+
                 params = {
@@ -301,6 +296,6 @@ MaxNumberOfMessages: this.config.maxNumberOfMessages,
                 };
-                _context4.next = 14;
+                _context4.next = 15;
                 return this.dequeue(_topic, params);
 
-              case 14:
+              case 15:
                 _iteratorNormalCompletion2 = true;
@@ -310,8 +305,8 @@ _context4.next = 8;
 
-              case 17:
-                _context4.next = 23;
+              case 18:
+                _context4.next = 24;
                 break;
 
-              case 19:
-                _context4.prev = 19;
+              case 20:
+                _context4.prev = 20;
                 _context4.t0 = _context4['catch'](6);
@@ -321,5 +316,5 @@ _didIteratorError2 = true;
 
-              case 23:
-                _context4.prev = 23;
+              case 24:
                 _context4.prev = 24;
+                _context4.prev = 25;
 
@@ -330,7 +325,7 @@ if (!_iteratorNormalCompletion2 && _iterator2.return) {
 
-              case 26:
-                _context4.prev = 26;
+              case 27:
+                _context4.prev = 27;
 
                 if (!_didIteratorError2) {
-                  _context4.next = 29;
+                  _context4.next = 30;
                   break;
@@ -341,13 +336,12 @@ }
 
-              case 29:
-                return _context4.finish(26);
-
               case 30:
-                return _context4.finish(23);
+                return _context4.finish(27);
 
               case 31:
+                return _context4.finish(24);
 
+              case 32:
                 setTimeout(this.process.bind(this), this.config.consumerPollInterval);
 
-              case 32:
+              case 33:
               case 'end':
@@ -357,3 +351,3 @@ return _context4.stop();
           }
-        }, _callee4, this, [[6, 19, 23, 31], [24,, 26, 30]]);
+        }, _callee4, this, [[6, 20, 24, 32], [25,, 27, 31]]);
       }));
@@ -389,3 +383,3 @@
                 return Promise.all(subscriptions.map(function (topic) {
-                  return getUrl(_this2.sqs, topic).then(function (url) {
+                  return _this2.getUrl(topic).then(function (url) {
                     return [topic, url];
@@ -406,3 +400,5 @@ });
                   // eslint-disable-line
-                  this.sqsUrls[_topic2] = url;
+                  if (url) {
+                    this.sqsUrls[_topic2] = url;
+                  }
                 }
@@ -457,2 +453,14 @@ _context5.next = 16;
   }, {
+    key: 'getUrl',
+    value: function getUrl(topic) {
+      var _this3 = this;
+
+      return this.sqs.getQueueUrlAsync({ QueueName: topic }).then(function (data) {
+        return data && data.QueueUrl;
+      }).catch(function (e) {
+        _this3.logger.error(e);
+        return null;
+      });
+    }
+  }, {
     key: 'createQueue',
@@ -459,0 +467,0 @@ value: function () {

package.json

 {
   "name": "steveo",
-  "version": "1.2.0",
+  "version": "1.2.1",
   "description": "A Task Manager Library",
@@ -40,2 +40,3 @@ "main": "lib/index.js",
     "lodash.difference": "^4.5.0",
+    "lodash.shuffle": "^4.2.0",
     "moment": "^2.18.1",
@@ -42,0 +43,0 @@ "no-kafka": "^3.1.10",

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

100178

increased by0.46%

Lines of code

1903

increased by0.69%

Worsened metrics

Dependency count

12

increased by9.09%

Dependency changes

• + Addedlodash.shuffle@^4.2.0

• + Addedlodash.shuffle@4.2.0(transitive)