steveo - npm Package Compare versions

Comparing version 5.0.0-beta2.3 to 5.0.0-beta2.4

lib/config/sqs.js

 "use strict";
 var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
     if (k2 === undefined) k2 = k;
-    Object.defineProperty(o, k2, { enumerable: true, get: function() { return m[k]; } });
+    var desc = Object.getOwnPropertyDescriptor(m, k);
+    if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) {
+      desc = { enumerable: true, get: function() { return m[k]; } };
+    }
+    Object.defineProperty(o, k2, desc);
 }) : (function(o, m, k, k2) {
@@ -6,0 +10,0 @@ if (k2 === undefined) k2 = k;

lib/index.d.ts

@@ -38,3 +38,3 @@ /// <reference types="node" />
 }
-declare const _default: (config: Configuration, logger: Logger, hooks?: Hooks | undefined) => Steveo;
+declare const _default: (config: Configuration, logger: Logger, hooks?: Hooks) => Steveo;
 export default _default;

lib/producer/utils.js

 "use strict";
 var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
     if (k2 === undefined) k2 = k;
-    Object.defineProperty(o, k2, { enumerable: true, get: function() { return m[k]; } });
+    var desc = Object.getOwnPropertyDescriptor(m, k);
+    if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) {
+      desc = { enumerable: true, get: function() { return m[k]; } };
+    }
+    Object.defineProperty(o, k2, desc);
 }) : (function(o, m, k, k2) {
@@ -6,0 +10,0 @@ if (k2 === undefined) k2 = k;

lib/runner/kafka.js

 "use strict";
 var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
     if (k2 === undefined) k2 = k;
-    Object.defineProperty(o, k2, { enumerable: true, get: function() { return m[k]; } });
+    var desc = Object.getOwnPropertyDescriptor(m, k);
+    if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) {
+      desc = { enumerable: true, get: function() { return m[k]; } };
+    }
+    Object.defineProperty(o, k2, desc);
 }) : (function(o, m, k, k2) {
@@ -71,3 +75,3 @@ if (k2 === undefined) k2 = k;
                 if (waitToCommit) {
-                    this.logger.debug(`commit offset ${message.offset}`);
+                    this.logger.debug(`committing message ${message}`);
                     this.consumer.commitMessage(message);
@@ -123,3 +127,4 @@ }
         this.consumeCallback = async (err, messages) => {
-            this.logger.debug('Consumer callback');
+            this.logger.debug('Consumer callback', messages === null || messages === void 0 ? void 0 : messages[0]);
+            this.logger.debug('Consumer assignments', this.consumer.assignments());
             await this.healthCheck();
@@ -130,2 +135,6 @@ if (this.steveo.exiting) {
             }
+            if (this.paused) {
+                this.logger.debug('Consumer paused');
+                return;
+            }
             await this.preProcess();
@@ -157,3 +166,3 @@ if (err) {
                 else {
-                    this.logger.debug(topicPartitions);
+                    this.logger.debug('Offset commit successful', topicPartitions, ' assigments', this.consumer.assignments());
                 }
@@ -177,5 +186,7 @@ } }, ((_c = (_b = this.config.consumer) === null || _b === void 0 ? void 0 : _b.global) !== null && _c !== void 0 ? _c : {})), (_e = (_d = this.config.consumer) === null || _d === void 0 ? void 0 : _d.topic) !== null && _e !== void 0 ? _e : {});
                 if (this.paused) {
+                    this.logger.debug('Pausing consumer', this.consumer.assignments());
                     this.consumer.pause(this.consumer.assignments());
                 }
                 else {
+                    this.logger.debug('Playing consumer', this.consumer.assignments());
                     this.consumer.resume(this.consumer.assignments());
@@ -182,0 +193,0 @@ }

lib/util.d.ts

 /// <reference types="node" />
 import { ChildProcess } from 'child_process';
 import { ChildProcessConfig } from './common';
-export declare const forkChild: (topic: string, tasksPath?: string | undefined, childProcessConfig?: ChildProcessConfig | undefined) => Promise<ChildProcess>;
+export declare const forkChild: (topic: string, tasksPath?: string, childProcessConfig?: ChildProcessConfig) => Promise<ChildProcess>;

package.json

 {
   "name": "steveo",
-  "version": "5.0.0-beta2.3",
+  "version": "5.0.0-beta2.4",
   "description": "A Task Pub/Sub Background processing library",
@@ -52,3 +52,3 @@ "main": "lib/index.js",
     "aws-sdk": "^2.1043.0",
-    "node-rdkafka": "^2.11.0",
+    "node-rdkafka": "^2.13.0",
     "rsmq": "^0.12.4"
@@ -55,0 +55,0 @@ },

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

94835

increased by1.6%

Number of package files

49

increased by4.26%

Lines of code

1990

increased by1.74%

No dependency changes