@davinci/messaging-amqp - npm Package Compare versions

Comparing version 2.0.0-next.15 to 2.0.0-next.16

.nyc_output/processinfo/index.json

@@ -1,1 +0,1 @@
-{"processes":{"749b667d-841b-4f96-bdb6-56be0d5c4d19":{"parent":"7ff37906-ff82-4a1e-b67b-3c2f29480c21","children":[]},"7ff37906-ff82-4a1e-b67b-3c2f29480c21":{"parent":"fae41735-c627-4f15-a7da-7e337d5307e7","children":["749b667d-841b-4f96-bdb6-56be0d5c4d19"]},"84e3a467-d9aa-46b1-9492-9ada11ad4124":{"parent":null,"children":[]},"fae41735-c627-4f15-a7da-7e337d5307e7":{"parent":null,"children":["7ff37906-ff82-4a1e-b67b-3c2f29480c21"]}},"files":{"/home/circleci/project/packages/messaging-amqp/src/index.ts":["749b667d-841b-4f96-bdb6-56be0d5c4d19","84e3a467-d9aa-46b1-9492-9ada11ad4124"],"/home/circleci/project/packages/messaging-amqp/src/AmqpModule.ts":["749b667d-841b-4f96-bdb6-56be0d5c4d19","84e3a467-d9aa-46b1-9492-9ada11ad4124"],"/home/circleci/project/packages/messaging-amqp/src/ChannelManager.ts":["749b667d-841b-4f96-bdb6-56be0d5c4d19","84e3a467-d9aa-46b1-9492-9ada11ad4124"],"/home/circleci/project/packages/messaging-amqp/src/types.ts":["749b667d-841b-4f96-bdb6-56be0d5c4d19","84e3a467-d9aa-46b1-9492-9ada11ad4124"]},"externalIds":{}}
+{"processes":{"75733e9e-fcda-4b71-acd6-5ee3751f58de":{"parent":"a82b353e-7c2b-483d-abed-14cc67c9666e","children":["d64921db-e9c6-4d5a-8919-4cae0b66e848"]},"a82b353e-7c2b-483d-abed-14cc67c9666e":{"parent":null,"children":["75733e9e-fcda-4b71-acd6-5ee3751f58de"]},"accdf72c-4db9-4bec-8be4-9c2686474c64":{"parent":null,"children":[]},"d64921db-e9c6-4d5a-8919-4cae0b66e848":{"parent":"75733e9e-fcda-4b71-acd6-5ee3751f58de","children":[]}},"files":{"/home/circleci/project/packages/messaging-amqp/src/AmqpModule.ts":["accdf72c-4db9-4bec-8be4-9c2686474c64","d64921db-e9c6-4d5a-8919-4cae0b66e848"],"/home/circleci/project/packages/messaging-amqp/src/ChannelManager.ts":["accdf72c-4db9-4bec-8be4-9c2686474c64","d64921db-e9c6-4d5a-8919-4cae0b66e848"],"/home/circleci/project/packages/messaging-amqp/src/index.ts":["accdf72c-4db9-4bec-8be4-9c2686474c64","d64921db-e9c6-4d5a-8919-4cae0b66e848"],"/home/circleci/project/packages/messaging-amqp/src/types.ts":["accdf72c-4db9-4bec-8be4-9c2686474c64","d64921db-e9c6-4d5a-8919-4cae0b66e848"]},"externalIds":{}}

build-cjs/AmqpModule.js

@@ -19,3 +19,3 @@ "use strict";
     constructor(options) {
-        var _a, _b;
+        var _a, _b, _c;
         super();
@@ -27,3 +27,5 @@ this.subscriptionsMap = new Map();
         this.logger = (0, pino_1.pino)({ name: (_a = this.options.logger) === null || _a === void 0 ? void 0 : _a.name });
-        this.logger.level = (_b = this.options.logger) === null || _b === void 0 ? void 0 : _b.level;
+        if ((_b = this.options.logger) === null || _b === void 0 ? void 0 : _b.level) {
+            this.logger.level = (_c = this.options.logger) === null || _c === void 0 ? void 0 : _c.level;
+        }
     }
@@ -34,8 +36,12 @@ getModuleId() {
     onRegister(app) {
-        var _a, _b, _c;
+        var _a, _b, _c, _d, _e, _f;
         this.app = app;
+        const level = (_b = (_a = this.options.logger) === null || _a === void 0 ? void 0 : _a.level) !== null && _b !== void 0 ? _b : (_c = app.getOptions().logger) === null || _c === void 0 ? void 0 : _c.level;
+        if (level) {
+            this.logger.level = level;
+        }
         const connectionOptions = typeof this.options.connection === 'object' ? this.options.connection : { url: this.options.connection };
         this.connection = amqp_connection_manager_1.default.connect(connectionOptions, this.options.connectionManagerOptions);
         this.channelManager =
-            (_c = (_b = (_a = this.options).channelManagerFactory) === null || _b === void 0 ? void 0 : _b.call(_a, this.connection, { logger: this.options.logger })) !== null && _c !== void 0 ? _c : new ChannelManager_1.ChannelManager(this.connection, { logger: this.options.logger });
+            (_f = (_e = (_d = this.options).channelManagerFactory) === null || _e === void 0 ? void 0 : _e.call(_d, this.connection, { logger: this.options.logger })) !== null && _f !== void 0 ? _f : new ChannelManager_1.ChannelManager(this.connection, { logger: this.options.logger });
     }
@@ -42,0 +48,0 @@ async onInit() {

build-esm/AmqpModule.js

@@ -15,3 +15,3 @@ /*
     constructor(options) {
-        var _a, _b;
+        var _a, _b, _c;
         super();
@@ -23,3 +23,5 @@ this.subscriptionsMap = new Map();
         this.logger = pino({ name: (_a = this.options.logger) === null || _a === void 0 ? void 0 : _a.name });
-        this.logger.level = (_b = this.options.logger) === null || _b === void 0 ? void 0 : _b.level;
+        if ((_b = this.options.logger) === null || _b === void 0 ? void 0 : _b.level) {
+            this.logger.level = (_c = this.options.logger) === null || _c === void 0 ? void 0 : _c.level;
+        }
     }
@@ -30,8 +32,12 @@ getModuleId() {
     onRegister(app) {
-        var _a, _b, _c;
+        var _a, _b, _c, _d, _e, _f;
         this.app = app;
+        const level = (_b = (_a = this.options.logger) === null || _a === void 0 ? void 0 : _a.level) !== null && _b !== void 0 ? _b : (_c = app.getOptions().logger) === null || _c === void 0 ? void 0 : _c.level;
+        if (level) {
+            this.logger.level = level;
+        }
         const connectionOptions = typeof this.options.connection === 'object' ? this.options.connection : { url: this.options.connection };
         this.connection = amqpConnectionManager.connect(connectionOptions, this.options.connectionManagerOptions);
         this.channelManager =
-            (_c = (_b = (_a = this.options).channelManagerFactory) === null || _b === void 0 ? void 0 : _b.call(_a, this.connection, { logger: this.options.logger })) !== null && _c !== void 0 ? _c : new ChannelManager(this.connection, { logger: this.options.logger });
+            (_f = (_e = (_d = this.options).channelManagerFactory) === null || _e === void 0 ? void 0 : _e.call(_d, this.connection, { logger: this.options.logger })) !== null && _f !== void 0 ? _f : new ChannelManager(this.connection, { logger: this.options.logger });
     }
@@ -38,0 +44,0 @@ async onInit() {

CHANGELOG.md

@@ -6,2 +6,10 @@ # Change Log
 
+# [2.0.0-next.16](https://github.com/HPInc/davinci/compare/@davinci/messaging-amqp@2.0.0-next.15...@davinci/messaging-amqp@2.0.0-next.16) (2022-11-18)
+
+**Note:** Version bump only for package @davinci/messaging-amqp
+
+
+
+
+
 # [2.0.0-next.15](https://github.com/HPInc/davinci/compare/@davinci/messaging-amqp@2.0.0-next.14...@davinci/messaging-amqp@2.0.0-next.15) (2022-11-17)
@@ -8,0 +16,0 @@

package.json

 {
 	"name": "@davinci/messaging-amqp",
-	"version": "2.0.0-next.15",
+	"version": "2.0.0-next.16",
 	"description": "AMQP module",
@@ -40,3 +40,3 @@ "author": "HP",
 	},
-	"gitHead": "7ec642982bd2a951806b09656416d010adacaca4"
+	"gitHead": "b58c92ee275c82ac4462271fdd89212bfdfadb08"
 }

src/AmqpModule.ts

@@ -64,3 +64,5 @@ /*
 		this.logger = pino({ name: this.options.logger?.name });
-		this.logger.level = this.options.logger?.level;
+		if (this.options.logger?.level) {
+			this.logger.level = this.options.logger?.level;
+		}
 	}
@@ -74,2 +76,8 @@
 		this.app = app;
+
+		const level = this.options.logger?.level ?? app.getOptions().logger?.level;
+		if (level) {
+			this.logger.level = level;
+		}
+
 		const connectionOptions =
@@ -76,0 +84,0 @@ typeof this.options.connection === 'object' ? this.options.connection : { url: this.options.connection };

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

388634

increased by2.66%

Lines of code

2430

increased by0.75%

No dependency changes