@5minds/node-red-contrib-processcube-amqp - npm Package Compare versions

Comparing version 0.5.0 to 0.6.0

.node-red/data/.config.nodes.json

 {
     "node-red": {
         "name": "node-red",
-        "version": "3.1.9",
+        "version": "4.0.3",
         "local": false,
@@ -432,3 +432,3 @@ "user": false,
         "name": "@5minds/node-red-contrib-processcube-amqp",
-        "version": "0.4.0",
+        "version": "0.5.0",
         "local": true,
@@ -448,2 +448,24 @@ "user": false,
             },
+            "amqpIntermediateInput": {
+                "name": "amqpIntermediateInput",
+                "types": [
+                    "amqp-intermediate-input"
+                ],
+                "enabled": true,
+                "local": true,
+                "user": false,
+                "module": "@5minds/node-red-contrib-processcube-amqp",
+                "file": "/data/node_modules/node-red-contrib-processcube-amqp/amqp-intermediate-input.js"
+            },
+            "amqpIntermediateOutput": {
+                "name": "amqpIntermediateOutput",
+                "types": [
+                    "amqp-intermediate-output"
+                ],
+                "enabled": true,
+                "local": true,
+                "user": false,
+                "module": "@5minds/node-red-contrib-processcube-amqp",
+                "file": "/data/node_modules/node-red-contrib-processcube-amqp/amqp-intermediate-output.js"
+            },
             "amqpOutput": {
@@ -450,0 +472,0 @@ "name": "amqpOutput",

.node-red/data/.config.users.json

@@ -16,3 +16,3 @@ {
             "tours": {
-                "welcome": "3.1.9"
+                "welcome": "4.0.3"
             }
@@ -19,0 +19,0 @@ }

.node-red/data/flows.json

@@ -120,3 +120,3 @@ [
         "x": 250,
-        "y": 140,
+        "y": 120,
         "wires": [
@@ -127,3 +127,130 @@ [
         ]
+    },
+    {
+        "id": "674b6dfdd29d03ff",
+        "type": "inject",
+        "z": "ea5e703747705005",
+        "name": "",
+        "props": [
+            {
+                "p": "payload"
+            },
+            {
+                "p": "topic",
+                "vt": "str"
+            }
+        ],
+        "repeat": "",
+        "crontab": "",
+        "once": false,
+        "onceDelay": 0.1,
+        "topic": "",
+        "payload": "",
+        "payloadType": "date",
+        "x": 200,
+        "y": 480,
+        "wires": [
+            [
+                "80b6a88a75218de8"
+            ]
+        ]
+    },
+    {
+        "id": "80b6a88a75218de8",
+        "type": "amqp-intermediate-input",
+        "z": "ea5e703747705005",
+        "name": "",
+        "amqpServer": "cbcfcb0a896f9765",
+        "exchange": "Test2",
+        "exchangeType": "topic",
+        "routingKey": "test.${TEST}",
+        "routingKeyFieldType": "env",
+        "queue": "IntermediateQueue",
+        "x": 440,
+        "y": 480,
+        "wires": [
+            [
+                "3c9347a9984c8f4a"
+            ]
+        ]
+    },
+    {
+        "id": "3c9347a9984c8f4a",
+        "type": "debug",
+        "z": "ea5e703747705005",
+        "name": "debug 3",
+        "active": true,
+        "tosidebar": true,
+        "console": false,
+        "tostatus": false,
+        "complete": "false",
+        "statusVal": "",
+        "statusType": "auto",
+        "x": 730,
+        "y": 480,
+        "wires": []
+    },
+    {
+        "id": "73dfe1f014cf2a95",
+        "type": "amqp-intermediate-output",
+        "z": "ea5e703747705005",
+        "name": "",
+        "amqpServer": "cbcfcb0a896f9765",
+        "exchange": "Test2",
+        "exchangeType": "topic",
+        "routingKey": "test.${TEST}",
+        "routingKeyFieldType": "env",
+        "x": 420,
+        "y": 580,
+        "wires": [
+            [
+                "ea31e27c53c0b8cb"
+            ]
+        ]
+    },
+    {
+        "id": "a5d8ae6eb5ac20de",
+        "type": "inject",
+        "z": "ea5e703747705005",
+        "name": "",
+        "props": [
+            {
+                "p": "payload"
+            },
+            {
+                "p": "topic",
+                "vt": "str"
+            }
+        ],
+        "repeat": "",
+        "crontab": "",
+        "once": false,
+        "onceDelay": 0.1,
+        "topic": "",
+        "payload": "{\"test\":123}",
+        "payloadType": "json",
+        "x": 190,
+        "y": 580,
+        "wires": [
+            [
+                "73dfe1f014cf2a95"
+            ]
+        ]
+    },
+    {
+        "id": "ea31e27c53c0b8cb",
+        "type": "debug",
+        "z": "ea5e703747705005",
+        "name": "debug 4",
+        "active": true,
+        "tosidebar": true,
+        "console": false,
+        "tostatus": false,
+        "complete": "false",
+        "statusVal": "",
+        "statusType": "auto",
+        "x": 690,
+        "y": 580,
+        "wires": []
     }
 ]

amqp-config.js

@@ -0,1 +1,3 @@
+const AMQPConnection = require('./amqp-connection');
+
 module.exports = function(RED) {
@@ -5,4 +7,7 @@ function AMQPServerNode(n) {
         this.connectionString = n.connectionString;
+
+        this.connection = new AMQPConnection(this.connectionString);
+        this.connection.connect();
     }
     RED.nodes.registerType("amqp-config",AMQPServerNode);
 }

amqp-input.js

@@ -1,3 +0,1 @@
-const AMQPConnection = require('./amqp-connection');
-
 function showStatus(node, msgCounter) {
@@ -16,3 +14,2 @@ if (msgCounter >= 1) {
         var node = this;
-        var flowContext = node.context().flow;
 
@@ -22,8 +19,6 @@ const amqpServer = RED.nodes.getNode(config.amqpServer);
         async function initNode() {
-            var connection = flowContext.get('amqpConnection');
+            var connection = amqpServer.connection;
 
             if (!connection) {
-                connection = new AMQPConnection(amqpServer.connectionString);
-                flowContext.set('amqpConnection', connection);
-                await connection.connect();
+                return;
             }
@@ -30,0 +25,0 @@

amqp-output.js

@@ -13,7 +13,6 @@ const amqplib = require('amqplib');
         node.on('input', async (msg) => {
-            var connection = flowContext.get('amqpConnection');
+            var connection = amqpServer.connection;
 
             if (!connection) {
-                connection = new AMQPConnection(amqpServer.connectionString);
-                flowContext.set('amqpConnection', connection);
+                return;
             }
@@ -20,0 +19,0 @@

package.json

 {
     "name": "@5minds/node-red-contrib-processcube-amqp",
-    "version": "0.5.0",
+    "version": "0.6.0",
     "license": "MIT",
@@ -32,2 +32,4 @@ "description": "Node-RED nodes for AMQP",
             "amqpInput": "amqp-input.js",
+            "amqpIntermediateInput": "amqp-intermediate-input.js",
+            "amqpIntermediateOutput": "amqp-intermediate-output.js",
             "amqpOutput": "amqp-output.js",
@@ -34,0 +36,0 @@ "amqpConfig": "amqp-config.js"

No alert changes

Improved metrics

Total package byte prevSize

96878

19.55%

Number of package files

27

17.39%

Lines of code

1454

17.35%

No dependency changes