steveo - npm Package Compare versions

Comparing version 1.0.20 to 1.0.22

lib/config.js

@@ -11,5 +11,3 @@ 'use strict';
 
-var Config = function Config() {
-  var config = arguments.length > 0 && arguments[0] !== undefined ? arguments[0] : Configuration;
-
+var Config = function Config(config) {
   _classCallCheck(this, Config);
@@ -16,0 +14,0 @@

lib/runner.js

@@ -11,6 +11,2 @@ 'use strict';
 
-var _config = require('./config');
-
-var _config2 = _interopRequireDefault(_config);
-
 function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
@@ -47,3 +43,3 @@
               if (_iteratorNormalCompletion = (_step = _iterator.next()).done) {
-                _context.next = 26;
+                _context.next = 29;
                 break;
@@ -53,4 +49,4 @@ }
               m = _step.value;
-              // eslint-disable-line
-              params = null;
+              // eslint-disable-line no-restricted-syntax
+              params = {};
               _context.prev = 8;
@@ -61,19 +57,23 @@
               registry.events.emit('runner_receive', topic, params);
-              _context.next = 13;
+              logger.info('Commit offset', topic, params);
+              _context.next = 14;
               return consumer.commitOffset({ topic: topic, partition: partition, offset: m.offset, metadata: 'optional' });
 
-            case 13:
+            case 14:
               // eslint-disable-line
               task = registry.getTask(topic);
-              _context.next = 16;
+
+              logger.info('Start subscribe', topic, params);
+              _context.next = 18;
               return task.subscribe(params);
 
-            case 16:
+            case 18:
               // eslint-disable-line
+              logger.info('Finish subscribe', topic);
               registry.events.emit('runner_complete', topic, params);
-              _context.next = 23;
+              _context.next = 26;
               break;
 
-            case 19:
-              _context.prev = 19;
+            case 22:
+              _context.prev = 22;
               _context.t0 = _context['catch'](8);
@@ -84,3 +84,3 @@
 
-            case 23:
+            case 26:
               _iteratorNormalCompletion = true;
@@ -90,8 +90,8 @@ _context.next = 5;
 
-            case 26:
-              _context.next = 32;
+            case 29:
+              _context.next = 35;
               break;
 
-            case 28:
-              _context.prev = 28;
+            case 31:
+              _context.prev = 31;
               _context.t1 = _context['catch'](3);
@@ -101,5 +101,5 @@ _didIteratorError = true;
 
-            case 32:
-              _context.prev = 32;
-              _context.prev = 33;
+            case 35:
+              _context.prev = 35;
+              _context.prev = 36;
 
@@ -110,7 +110,7 @@ if (!_iteratorNormalCompletion && _iterator.return) {
 
-            case 35:
-              _context.prev = 35;
+            case 38:
+              _context.prev = 38;
 
               if (!_didIteratorError) {
-                _context.next = 38;
+                _context.next = 41;
                 break;
@@ -121,9 +121,9 @@ }
 
-            case 38:
+            case 41:
+              return _context.finish(38);
+
+            case 42:
               return _context.finish(35);
 
-            case 39:
-              return _context.finish(32);
-
-            case 40:
+            case 43:
             case 'end':
@@ -133,3 +133,3 @@ return _context.stop();
         }
-      }, _callee, undefined, [[3, 28, 32, 40], [8, 19], [33,, 35, 39]]);
+      }, _callee, undefined, [[3, 31, 35, 43], [8, 22], [36,, 38, 42]]);
     }));
@@ -136,0 +136,0 @@

package.json

 {
   "name": "steveo",
-  "version": "1.0.20",
+  "version": "1.0.22",
   "description": "A Task Manager Library",
@@ -19,3 +19,4 @@ "main": "lib/index.js",
     "flow": "./node_modules/.bin/flow check",
-    "steveo": "node ./lib/cli-task.js"
+    "steveo": "node ./lib/cli-task.js",
+    "flow:coverage": "./node_modules/.bin/flow-coverage-report -i 'src/**/*.js' -x 'src/test/**' -t html -t json -t text"
   },
@@ -56,7 +57,8 @@ "files": [
     "eslint": "^3.18.0",
-    "eslint-config-airbnb": "^14.1.0",
+    "eslint-config-airbnb": "^15.0.1",
     "eslint-plugin-import": "^2.2.0",
-    "eslint-plugin-jsx-a11y": "^4.0.0",
-    "eslint-plugin-react": "^6.10.3",
-    "flow-bin": "^0.43.1",
+    "eslint-plugin-jsx-a11y": "^5.0.1",
+    "eslint-plugin-react": "^7.0.0",
+    "flow-bin": "^0.46.0",
+    "flow-coverage-report": "^0.3.0",
     "mocha": "^3.2.0",
@@ -63,0 +65,0 @@ "nyc": "^10.1.2",

README.md

 # Steveo - Kafka Task Framework for Node.js
 
+[![Greenkeeper badge](https://badges.greenkeeper.io/ordermentum/steveo.svg)](https://greenkeeper.io/)
+
 [![npm version](https://badge.fury.io/js/steveo.svg)](https://badge.fury.io/js/steveo)
@@ -49,3 +51,3 @@ [![Build Status](https://travis-ci.org/ordermentum/steveo.svg?branch=master)](https://travis-ci.org/ordermentum/steveo)
 (async () => {
-  const steveo = new Steveo({
+  const steveo = Steveo({
     kafkaConnection: process.env.KAFKA_CONNECTION,
@@ -52,0 +54,0 @@ clientId: '1234-123',

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

31831

increased by0.87%

Number of lines in readme file

68

increased by3.03%

Worsened metrics

Dev dependency count

21

increased by5%

No dependency changes