@rokketlabs/simple-bull - npm Package Compare versions

Comparing version 1.0.0 to 1.1.0

dist/index.js

@@ -1,32 +0,74 @@
-'use strict';
+"use strict";
 
+require("core-js/modules/es.symbol");
+
+require("core-js/modules/es.symbol.description");
+
+require("core-js/modules/es.symbol.iterator");
+
+require("core-js/modules/es.array.filter");
+
+require("core-js/modules/es.array.for-each");
+
+require("core-js/modules/es.array.iterator");
+
+require("core-js/modules/es.function.name");
+
+require("core-js/modules/es.object.define-properties");
+
+require("core-js/modules/es.object.define-property");
+
+require("core-js/modules/es.object.get-own-property-descriptor");
+
+require("core-js/modules/es.object.get-own-property-descriptors");
+
+require("core-js/modules/es.object.keys");
+
+require("core-js/modules/es.object.to-string");
+
+require("core-js/modules/es.promise");
+
+require("core-js/modules/es.string.iterator");
+
+require("core-js/modules/web.dom-collections.for-each");
+
+require("core-js/modules/web.dom-collections.iterator");
+
 Object.defineProperty(exports, "__esModule", {
   value: true
 });
-exports.startQueue = undefined;
+exports.startQueue = void 0;
 
-var _bull = require('bull');
+require("regenerator-runtime/runtime");
 
-var _bull2 = _interopRequireDefault(_bull);
+require("core-js/stable");
 
-var _redisConf = require('./redisConf');
+var _bull = _interopRequireDefault(require("bull"));
 
-var _redisConf2 = _interopRequireDefault(_redisConf);
+var _redisConf = _interopRequireDefault(require("./redisConf"));
 
-var _signale = require('signale');
+var _signale = _interopRequireDefault(require("signale"));
 
-var _signale2 = _interopRequireDefault(_signale);
+var _logger = require("./logger");
 
-var _logger = require('./logger');
+function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { "default": obj }; }
 
-function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
+function ownKeys(object, enumerableOnly) { var keys = Object.keys(object); if (Object.getOwnPropertySymbols) { var symbols = Object.getOwnPropertySymbols(object); if (enumerableOnly) symbols = symbols.filter(function (sym) { return Object.getOwnPropertyDescriptor(object, sym).enumerable; }); keys.push.apply(keys, symbols); } return keys; }
 
-function _asyncToGenerator(fn) { return function () { var gen = fn.apply(this, arguments); return new Promise(function (resolve, reject) { function step(key, arg) { try { var info = gen[key](arg); var value = info.value; } catch (error) { reject(error); return; } if (info.done) { resolve(value); } else { return Promise.resolve(value).then(function (value) { step("next", value); }, function (err) { step("throw", err); }); } } return step("next"); }); }; }
+function _objectSpread(target) { for (var i = 1; i < arguments.length; i++) { var source = arguments[i] != null ? arguments[i] : {}; if (i % 2) { ownKeys(source, true).forEach(function (key) { _defineProperty(target, key, source[key]); }); } else if (Object.getOwnPropertyDescriptors) { Object.defineProperties(target, Object.getOwnPropertyDescriptors(source)); } else { ownKeys(source).forEach(function (key) { Object.defineProperty(target, key, Object.getOwnPropertyDescriptor(source, key)); }); } } return target; }
 
+function _defineProperty(obj, key, value) { if (key in obj) { Object.defineProperty(obj, key, { value: value, enumerable: true, configurable: true, writable: true }); } else { obj[key] = value; } return obj; }
+
+function asyncGeneratorStep(gen, resolve, reject, _next, _throw, key, arg) { try { var info = gen[key](arg); var value = info.value; } catch (error) { reject(error); return; } if (info.done) { resolve(value); } else { Promise.resolve(value).then(_next, _throw); } }
+
+function _asyncToGenerator(fn) { return function () { var self = this, args = arguments; return new Promise(function (resolve, reject) { var gen = fn.apply(self, args); function _next(value) { asyncGeneratorStep(gen, resolve, reject, _next, _throw, "next", value); } function _throw(err) { asyncGeneratorStep(gen, resolve, reject, _next, _throw, "throw", err); } _next(undefined); }); }; }
+
 // Initialize a queue with workers
-var startQueue = function () {
-  var _ref2 = _asyncToGenerator( /*#__PURE__*/regeneratorRuntime.mark(function _callee(_ref) {
-    var queueName = _ref.queueName,
-        workers = _ref.workers;
-    var queue;
+var startQueue =
+/*#__PURE__*/
+function () {
+  var _ref2 = _asyncToGenerator(
+  /*#__PURE__*/
+  regeneratorRuntime.mark(function _callee(_ref) {
+    var queueName, workers, queue;
     return regeneratorRuntime.wrap(function _callee$(_context) {
@@ -36,15 +78,24 @@ while (1) {
           case 0:
-            _signale2.default.pending('Creating queue and connecting with redis');
-            queue = new _bull2.default(queueName, { redis: _redisConf2.default });
+            queueName = _ref.queueName, workers = _ref.workers;
 
-            _signale2.default.success('Queue correctly created');
-            _context.next = 5;
-            return addJobsToQueue({ queue: queue, workers: workers });
+            _signale["default"].pending('Creating queue and connecting with redis');
 
-          case 5:
-          case 'end':
+            queue = new _bull["default"](queueName, {
+              redis: _redisConf["default"]
+            });
+
+            _signale["default"].success('Queue correctly created');
+
+            _context.next = 6;
+            return addJobsToQueue({
+              queue: queue,
+              workers: workers
+            });
+
+          case 6:
+          case "end":
             return _context.stop();
         }
       }
-    }, _callee, undefined);
+    }, _callee);
   }));
@@ -57,9 +108,21 @@
 
-var addJobsToQueue = function () {
-  var _ref4 = _asyncToGenerator( /*#__PURE__*/regeneratorRuntime.mark(function _callee2(_ref3) {
-    var queue = _ref3.queue,
-        workers = _ref3.workers;
+exports.startQueue = startQueue;
 
-    var _loop, _iteratorNormalCompletion, _didIteratorError, _iteratorError, _iterator, _step, _ref5, name, processor, every, limit, onFailure, onSuccess;
+var getFrecuency = function getFrecuency(frequency) {
+  if (typeof frequency === 'number') return {
+    every: frequency
+  };
+  return {
+    cron: frequency
+  };
+};
 
+var addJobsToQueue =
+/*#__PURE__*/
+function () {
+  var _ref4 = _asyncToGenerator(
+  /*#__PURE__*/
+  regeneratorRuntime.mark(function _callee2(_ref3) {
+    var queue, workers, _iteratorNormalCompletion, _didIteratorError, _iteratorError, _loop, _iterator, _step;
+
     return regeneratorRuntime.wrap(function _callee2$(_context3) {
@@ -69,3 +132,12 @@ while (1) {
           case 0:
-            _loop = /*#__PURE__*/regeneratorRuntime.mark(function _loop(name, processor, every, limit, onFailure, onSuccess) {
+            queue = _ref3.queue, workers = _ref3.workers;
+            _iteratorNormalCompletion = true;
+            _didIteratorError = false;
+            _iteratorError = undefined;
+            _context3.prev = 4;
+            _loop =
+            /*#__PURE__*/
+            regeneratorRuntime.mark(function _loop() {
+              var _step$value, name, processor, frequency, limit, delay, onFailure, onSuccess;
+
               return regeneratorRuntime.wrap(function _loop$(_context2) {
@@ -75,7 +147,14 @@ while (1) {
                     case 0:
-                      _context2.next = 2;
-                      return queue.add(name, { foo: 'bar' }, { repeat: { every: every, limit: limit } });
+                      _step$value = _step.value, name = _step$value.name, processor = _step$value.processor, frequency = _step$value.frequency, limit = _step$value.limit, delay = _step$value.delay, onFailure = _step$value.onFailure, onSuccess = _step$value.onSuccess;
+                      _context2.next = 3;
+                      return queue.add(name, {
+                        foo: 'bar'
+                      }, {
+                        repeat: _objectSpread({}, getFrecuency(frequency), {
+                          limit: limit,
+                          delay: delay
+                        })
+                      });
 
-                    case 2:
-
+                    case 3:
                       queue.process(name, function (job, done) {
@@ -85,3 +164,3 @@ try {
                           processor();
-                          if (onSuccess) onFailure(job, _logger.successMessage);
+                          if (onSuccess) onSuccess(job, _logger.successMessage);
                           (0, _logger.successMessage)(job, 'job executed correctly');
@@ -92,61 +171,51 @@ } catch (error) {
                         }
+
                         done();
                       });
 
-                    case 3:
-                    case 'end':
+                    case 4:
+                    case "end":
                       return _context2.stop();
                   }
                 }
-              }, _loop, undefined);
+              }, _loop);
             });
-            _iteratorNormalCompletion = true;
-            _didIteratorError = false;
-            _iteratorError = undefined;
-            _context3.prev = 4;
             _iterator = workers[Symbol.iterator]();
 
-          case 6:
+          case 7:
             if (_iteratorNormalCompletion = (_step = _iterator.next()).done) {
-              _context3.next = 18;
+              _context3.next = 12;
               break;
             }
 
-            _ref5 = _step.value;
-            name = _ref5.name;
-            processor = _ref5.processor;
-            every = _ref5.every;
-            limit = _ref5.limit;
-            onFailure = _ref5.onFailure;
-            onSuccess = _ref5.onSuccess;
-            return _context3.delegateYield(_loop(name, processor, every, limit, onFailure, onSuccess), 't0', 15);
+            return _context3.delegateYield(_loop(), "t0", 9);
 
-          case 15:
+          case 9:
             _iteratorNormalCompletion = true;
-            _context3.next = 6;
+            _context3.next = 7;
             break;
 
-          case 18:
-            _context3.next = 24;
+          case 12:
+            _context3.next = 18;
             break;
 
-          case 20:
-            _context3.prev = 20;
-            _context3.t1 = _context3['catch'](4);
+          case 14:
+            _context3.prev = 14;
+            _context3.t1 = _context3["catch"](4);
             _didIteratorError = true;
             _iteratorError = _context3.t1;
 
-          case 24:
-            _context3.prev = 24;
-            _context3.prev = 25;
+          case 18:
+            _context3.prev = 18;
+            _context3.prev = 19;
 
-            if (!_iteratorNormalCompletion && _iterator.return) {
-              _iterator.return();
+            if (!_iteratorNormalCompletion && _iterator["return"] != null) {
+              _iterator["return"]();
             }
 
-          case 27:
-            _context3.prev = 27;
+          case 21:
+            _context3.prev = 21;
 
             if (!_didIteratorError) {
-              _context3.next = 30;
+              _context3.next = 24;
               break;
@@ -157,14 +226,14 @@ }
 
-          case 30:
-            return _context3.finish(27);
+          case 24:
+            return _context3.finish(21);
 
-          case 31:
-            return _context3.finish(24);
+          case 25:
+            return _context3.finish(18);
 
-          case 32:
-          case 'end':
+          case 26:
+          case "end":
             return _context3.stop();
         }
       }
-    }, _callee2, undefined, [[4, 20, 24, 32], [25,, 27, 31]]);
+    }, _callee2, null, [[4, 14, 18, 26], [19,, 21, 25]]);
   }));
@@ -175,4 +244,2 @@
   };
-}();
-
-exports.startQueue = startQueue;
+}();

dist/logger.js

@@ -1,14 +0,20 @@
-'use strict';
+"use strict";
 
+require("core-js/modules/es.array.concat");
+
+require("core-js/modules/es.date.to-string");
+
+require("core-js/modules/es.function.name");
+
+require("core-js/modules/es.object.define-property");
+
 Object.defineProperty(exports, "__esModule", {
   value: true
 });
-exports.errorMessage = exports.pendingMessage = exports.successMessage = undefined;
+exports.errorMessage = exports.pendingMessage = exports.successMessage = void 0;
 
-var _signale = require('signale');
+var _signale = _interopRequireDefault(require("signale"));
 
-var _signale2 = _interopRequireDefault(_signale);
+function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { "default": obj }; }
 
-function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
-
 var now = new Date();
@@ -18,5 +24,6 @@
   var month = now.getUTCMonth() + 1; // months from 1-12
+
   var day = now.getUTCDate();
   var year = now.getUTCFullYear();
-  return year + '-' + month + '-' + day;
+  return "".concat(year, "-").concat(month, "-").concat(day);
 };
@@ -28,15 +35,19 @@
   var seconds = now.getSeconds();
-  return hours + ':' + minutes + ':' + seconds;
+  return "".concat(hours, ":").concat(minutes, ":").concat(seconds);
 };
 
 var successMessage = function successMessage(job, message) {
-  var msg = _signale2.default.scope(getUTCDate(), getUTCTime(), job.name);
+  var msg = _signale["default"].scope(getUTCDate(), getUTCTime(), job.name);
+
   msg.success({
     message: message,
-    suffix: '[' + job.name + ']'
+    suffix: "[".concat(job.name, "]")
   });
 };
 
+exports.successMessage = successMessage;
+
 var pendingMessage = function pendingMessage(job, message) {
-  var msg = _signale2.default.scope(getUTCDate(), getUTCTime(), job.name);
+  var msg = _signale["default"].scope(getUTCDate(), getUTCTime(), job.name);
+
   msg.pending({
@@ -46,9 +57,11 @@ message: message
 };
+
+exports.pendingMessage = pendingMessage;
+
 var errorMessage = function errorMessage(job, message) {
-  var msg = _signale2.default.scope(getUTCDate(), getUTCTime(), job.name);
+  var msg = _signale["default"].scope(getUTCDate(), getUTCTime(), job.name);
+
   msg.fatal(new Error(message));
 };
 
-exports.successMessage = successMessage;
-exports.pendingMessage = pendingMessage;
 exports.errorMessage = errorMessage;

dist/redisConf.js

@@ -1,10 +0,17 @@
-'use strict';
+"use strict";
 
+require("core-js/modules/es.object.define-property");
+
 Object.defineProperty(exports, "__esModule", {
   value: true
 });
+exports["default"] = void 0;
 var port = process.env.REDIS_PORT || 6970;
 var host = process.env.REDIS_HOST || 'localhost';
 var password = process.env.REDIS_PASSWORD || '';
-
-exports.default = { port: port, host: host, password: password };
+var _default = {
+  port: port,
+  host: host,
+  password: password
+};
+exports["default"] = _default;

dist/registerQueues.js

@@ -1,8 +0,23 @@
-'use strict';
+"use strict";
 
+require("core-js/modules/es.function.name");
+
+require("core-js/modules/es.object.define-property");
+
+require("core-js/modules/es.object.to-string");
+
+require("core-js/modules/es.promise");
+
 Object.defineProperty(exports, "__esModule", {
   value: true
 });
+exports["default"] = _default;
 
-exports.default = function (worker) {
+var _redisConf = _interopRequireDefault(require("./redisConf"));
+
+var _bull = _interopRequireDefault(require("bull"));
+
+function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { "default": obj }; }
+
+function _default(worker) {
   // Limit the amount of concurrent workers
@@ -12,25 +27,25 @@ // Limit the duration of each worker
     max: 1000,
-    duration: 5000
+    duration: 5000 // Set timer of each worker
 
-    // Set timer of each worker
-  };var repeat = {
+  };
+  var repeat = {
     every: 10000,
     limit: 1000
   };
-
   var delay = 5000;
-
-  var queue = new _bull2.default(worker.name, { redis: _redisConf2.default });
-
-  queue.add({ foo: 'bar' }, { repeat: repeat });
-
+  var queue = new _bull["default"](worker.name, {
+    redis: _redisConf["default"]
+  });
+  queue.add({
+    foo: 'bar'
+  }, {
+    repeat: repeat
+  });
   queue.process(function (job) {
-    console.log('Working on Job ' + worker.name);
+    console.log("Working on Job ".concat(worker.name));
     return Promise.resolve();
   });
-
   queue.on('completed', function (job, result) {
-    console.log('Job completed with result ' + result);
+    console.log("Job completed with result ".concat(result));
   });
-
   queue.on('failed', function (job, err) {
@@ -40,12 +55,2 @@ // A job failed with reason `err`!
   });
-};
-
-var _redisConf = require('./redisConf');
-
-var _redisConf2 = _interopRequireDefault(_redisConf);
-
-var _bull = require('bull');
-
-var _bull2 = _interopRequireDefault(_bull);
-
-function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
+}

package.json

 {
   "name": "@rokketlabs/simple-bull",
-  "version": "1.0.0",
+  "version": "1.1.0",
   "description": "Functional programming wrapper for bull.js library",
@@ -29,7 +29,2 @@ "main": "./dist",
     "ava": "1.4.1",
-    "babel-cli": "6.26.0",
-    "babel-polyfill": "6.26.0",
-    "babel-preset-env": "1.7.0",
-    "babel-preset-es2017": "6.24.1",
-    "babel-register": "6.26.0",
     "eslint": "5.16.0",
@@ -41,2 +36,7 @@ "eslint-config-standard": "12.0.0",
     "eslint-plugin-standard": "4.0.0",
+    "@babel/cli": "7.5.5",
+    "@babel/core": "7.5.5",
+    "@babel/node": "7.5.5",
+    "@babel/preset-env": "7.5.5",
+    "@babel/register": "7.5.5",
     "nodemon": "1.19.1"
@@ -46,3 +46,4 @@ },
     "bull": "3.10.0",
-    "signale": "^1.4.0"
+    "core-js": "3.2.1",
+    "signale": "1.4.0"
   },
@@ -49,0 +50,0 @@ "peerDependencies": {

src/index.js

@@ -0,1 +1,4 @@
+import 'core-js/stable'
+import 'regenerator-runtime/runtime'
+
 import Bull from 'bull'
@@ -14,2 +17,7 @@ import redis from './redisConf'
 
+const getFrecuency = frequency => {
+  if (typeof frequency === 'number') return { every: frequency }
+  return { cron: frequency }
+}
+
 const addJobsToQueue = async ({ queue, workers }) => {
@@ -19,8 +27,13 @@ for (const {
     processor,
-    every,
+    frequency,
     limit,
+    delay,
     onFailure,
     onSuccess
   } of workers) {
-    await queue.add(name, { foo: 'bar' }, { repeat: { every, limit } })
+    await queue.add(
+      name,
+      { foo: 'bar' },
+      { repeat: { ...getFrecuency(frequency), limit, delay } }
+    )
 
@@ -31,3 +44,3 @@ queue.process(name, (job, done) => {
         processor()
-        if (onSuccess) onFailure(job, successMessage)
+        if (onSuccess) onSuccess(job, successMessage)
         successMessage(job, 'job executed correctly')
@@ -34,0 +47,0 @@ } catch (error) {

New alerts

Environment variable access

Supply chain risk

Package accesses environment variables, which may be a sign of credential stuffing or data theft.

Found 3 instances in 1 package

Improved metrics

Total package byte prevSize

18141

increased by17.84%

Lines of code

367

increased by14.33%

Worsened metrics

Dependency count

4

increased by33.33%

Number of package files

13

decreased by-7.14%

Number of low supply chain risk alerts

4

increased by300%

Dependency changes

• + Addedcore-js@3.2.1

• + Addedcore-js@3.2.1(transitive)

• Updatedsignale@1.4.0