@highoutput/amqp - npm Package Compare versions

Comparing version 0.7.2 to 0.7.3

build/lib/client.js

@@ -61,6 +61,5 @@ "use strict";
         const now = Date.now();
-        const stringifyArgs = JSON.stringify(this.options.serialize ? util_1.serialize(args) : args);
         const body = {
             correlationId,
-            arguments: stringifyArgs,
+            arguments: JSON.stringify(this.options.serialize ? util_1.serialize(args) : args),
             timestamp: now,
@@ -67,0 +66,0 @@ };

build/lib/publisher.js

@@ -44,5 +44,4 @@ "use strict";
         }
-        const stringifyArgs = JSON.stringify(this.options.serialize ? util_1.serialize(args) : args);
         const body = {
-            arguments: stringifyArgs,
+            arguments: JSON.stringify(this.options.serialize ? util_1.serialize(args) : args),
             timestamp: Date.now(),
@@ -49,0 +48,0 @@ };

build/lib/subscriber.js

@@ -45,6 +45,6 @@ "use strict";
         }
-        const parseArgs = typeof message.body.arguments === 'string'
+        const parsed = typeof message.body.arguments === 'string'
             ? JSON.parse(message.body.arguments)
             : message.body.arguments;
-        const body = Object.assign(Object.assign({}, message.body), { arguments: this.options.deserialize ? util_1.deserialize(parseArgs) : parseArgs });
+        const body = Object.assign(Object.assign({}, message.body), { arguments: this.options.deserialize ? util_1.deserialize(parsed) : parsed });
         logger_1.default.tag(['subscriber', 'request']).info(body);
@@ -51,0 +51,0 @@ try {

build/lib/worker.js

@@ -64,6 +64,6 @@ "use strict";
         }
-        const parseArgs = typeof message.body.arguments === 'string'
+        const parsed = typeof message.body.arguments === 'string'
             ? JSON.parse(message.body.arguments)
             : message.body.arguments;
-        const request = Object.assign(Object.assign({}, message.body), { arguments: this.options.deserialize ? util_1.deserialize(parseArgs) : parseArgs });
+        const request = Object.assign(Object.assign({}, message.body), { arguments: this.options.deserialize ? util_1.deserialize(parsed) : parsed });
         logger_1.default.tag(['worker', 'request']).verbose(request);
@@ -123,4 +123,4 @@ let result = null;
                 const now = Date.now();
-                if (message.absolute_expiry_time &&
-                    now > message.absolute_expiry_time) {
+                if (message.absolute_expiry_time
+                    && now > message.absolute_expiry_time) {
                     logger_1.default
@@ -127,0 +127,0 @@ .tag(['worker', 'message'])

package.json

 {
   "name": "@highoutput/amqp",
-  "version": "0.7.2",
+  "version": "0.7.3",
   "description": "A simplified abstraction of the AMQP 1.0 protocol",
@@ -57,3 +57,3 @@ "keywords": [
   },
-  "gitHead": "cb875e16db1a008b09f1030ab4f4e16a303f1158"
+  "gitHead": "cf1a83ff7348e87acd7bc2b98a7e163ba01d2be0"
 }

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

Worsened metrics

Total package byte prevSize

70727

decreased by-0.24%

Lines of code

906

decreased by-0.22%

No dependency changes