atomic-gravity - npm Package Compare versions

Comparing version 2.0.15 to 2.0.16

gravity-acknowledge.js

@@ -8,3 +8,3 @@ module.exports = function(RED) {
 		node.on('input', function(msg, send, done) {
-			node.log('Acknowledging message');
+			//node.log('Acknowledging message');
 			msg.ack();
@@ -11,0 +11,0 @@

gravity-publish.js

@@ -87,4 +87,10 @@ module.exports = function(RED) {
 
+			// set msgID
+                        let opts = {}
+                        if (msg.natsMsgId) {
+                                opts.msgID = msg.natsMsgId;
+                        }
+
 			try {
-				await node.gravityClient.publish(msg.eventName, JSON.stringify(msg.payload));
+				await node.gravityClient.publish(msg.eventName, JSON.stringify(msg.payload), opts);
 				done();
@@ -91,0 +97,0 @@ } catch(e) {

gravity-subscriber.js

@@ -117,2 +117,3 @@ module.exports = function(RED) {
 					},
+					natsMsgId: m.seq.toString(),
 					ack: ack.bind(m),
@@ -119,0 +120,0 @@ });

package.json

 {
   "name": "atomic-gravity",
-  "version": "2.0.15",
+  "version": "2.0.16",
   "description": "Gravity module for Brobridge Atomic",
@@ -24,5 +24,5 @@ "scripts": {
   "dependencies": {
-    "gravity-sdk": "^1.0.16",
+    "gravity-sdk": "^1.0.17",
     "uuid": "^8.3.2"
   }
 }

No alert changes

Improved metrics

Total package byte prevSize

69031

increased by0.33%

Lines of code

304

increased by2.01%

Dependency changes

• Updatedgravity-sdk@^1.0.17