Add link-call node and add return mode for link-out node

packages/node_modules/@node-red/editor-client/src/js/ui/editor.js

@@ -151,7 +151,7 @@ RED.editor = (function() {
                 valid = definition[property].hasOwnProperty("required") && !definition[property].required;
             } else {
                 var configNode = RED.nodes.node(value);
-                valid = (configNode !== null && (configNode.valid == null || configNode.valid));
+                valid = (configNode && (configNode.valid == null || configNode.valid));
             }
         }
         return valid;

packages/node_modules/@node-red/editor-client/src/js/ui/editors/panes/appearance.js

@@ -93,17 +93,20 @@
 
 
                 }
+                var showLabel = node._def.hasOwnProperty("showLabel")?node._def.showLabel:true;
+
                 if (!$("#node-input-show-label").prop('checked')) {
                     // Not checked - hide label
-                    if (!/^link (in|out)$/.test(node.type)) {
+
-                        // Not a link node - default state is true
+                    if (showLabel) {
+                        // Default to show label
                         if (node.l !== false) {
                             editState.changes.l = node.l
                             editState.changed = true;
                         }
                         node.l = false;
                     } else {
-                        // A link node - default state is false
+                        // Node has showLabel:false (eg link nodes)
                         if (node.hasOwnProperty('l') && node.l) {
                             editState.changes.l = node.l
                             editState.changed = true;
@@ -112,8 +115,8 @@
                     }
                 } else {
                     // Checked - show label
-                    if (!/^link (in|out)$/.test(node.type)) {
+                    if (showLabel) {
-                        // Not a link node - default state is true
+                        // Default to show label
                         if (node.hasOwnProperty('l') && !node.l) {
                             editState.changes.l = node.l
                             editState.changed = true;
@@ -204,8 +207,8 @@
         })
 
         if (!node.hasOwnProperty("l")) {
-            // Show label if type not link
+            // Show label unless def.showLabel set to false
-            node.l = !/^link (in|out)$/.test(node._def.type);
+            node.l =  node._def.hasOwnProperty("showLabel")?node._def.showLabel:true;
         }
         $("#node-input-show-label").prop("checked",node.l).trigger("change");
 

packages/node_modules/@node-red/editor-client/src/js/ui/view-tools.js

@@ -159,15 +159,15 @@ RED.view.tools = (function() {
         nodes.forEach(function(n) {
             var modified = false;
             var oldValue = n.l === undefined?true:n.l;
-            var isLink = /^link (in|out)$/.test(n._def.type);
+            var showLabel = n._def.hasOwnProperty("showLabel")?n._def.showLabel:true;
 
             if (labelShown) {
-                if (n.l === false || (isLink && !n.hasOwnProperty('l'))) {
+                if (n.l === false || (!showLabel && !n.hasOwnProperty('l'))) {
                     n.l = true;
                     modified = true;
                 }
             } else {
-                if ((!isLink && (!n.hasOwnProperty('l') || n.l === true)) || (isLink && n.l === true) ) {
+                if ((showLabel && (!n.hasOwnProperty('l') || n.l === true)) || (!showLabel && n.l === true) ) {
                     n.l = false;
                     modified = true;
                 }

packages/node_modules/@node-red/editor-client/src/js/ui/view.js

@@ -413,7 +413,7 @@ RED.view = (function() {
                 var nn = result.node;
 
                 var showLabel = RED.utils.getMessageProperty(RED.settings.get('editor'),"view.view-node-show-label");
-                if (showLabel !== undefined && !/^link (in|out)$/.test(nn._def.type) && !nn._def.defaults.hasOwnProperty("l")) {
+                if (showLabel !== undefined &&  (nn._def.hasOwnProperty("showLabel")?nn._def.showLabel:true) && !nn._def.defaults.hasOwnProperty("l")) {
                     nn.l = showLabel;
                 }
 
@@ -1088,7 +1088,7 @@ RED.view = (function() {
                 nn.x = point[0];
                 nn.y = point[1];
                 var showLabel = RED.utils.getMessageProperty(RED.settings.get('editor'),"view.view-node-show-label");
-                if (showLabel !== undefined && !/^link (in|out)$/.test(nn._def.type) && !nn._def.defaults.hasOwnProperty("l")) {
+                if (showLabel !== undefined && (nn._def.hasOwnProperty("showLabel")?nn._def.showLabel:true) && !nn._def.defaults.hasOwnProperty("l")) {
                     nn.l = showLabel;
                 }
                 if (quickAddLink) {
@@ -1991,7 +1991,7 @@ RED.view = (function() {
                 activeLinkNodes = {};
                 for (var i=0;i<movingSet.length();i++) {
                     var msn = movingSet.get(i);
-                    if ((msn.n.type === "link out" || msn.n.type === "link in") &&
+                    if (((msn.n.type === "link out" && msn.n.mode !== 'return') || msn.n.type === "link in") &&
                         (msn.n.z === activeWorkspace)) {
                         var linkNode = msn.n;
                         activeLinkNodes[linkNode.id] = linkNode;
@@ -4140,7 +4140,7 @@ RED.view = (function() {
                         }
                         var numOutputs = d.outputs;
                         if (isLink && d.type === "link out") {
-                            if (showAllLinkPorts===PORT_TYPE_OUTPUT || activeLinkNodes[d.id]) {
+                            if (d.mode !== "return" && (showAllLinkPorts===PORT_TYPE_OUTPUT || activeLinkNodes[d.id])) {
                                 numOutputs = 1;
                             } else {
                                 numOutputs = 0;

packages/node_modules/@node-red/editor-client/src/sass/ui/common/treeList.scss

@@ -95,7 +95,8 @@
         color: $list-item-color;
     }
 
-    input.red-ui-treeList-checkbox {
+    input.red-ui-treeList-checkbox,
+    input.red-ui-treeList-radio {
         margin: 0;
     }
 }

packages/node_modules/@node-red/nodes/core/common/60-link.html

@@ -8,6 +8,22 @@
     <div class="form-row node-input-link-row"></div>
 </script>
 <script type="text/html" data-template-name="link out">
+    <div class="form-row">
+        <label for="node-input-name"><i class="fa fa-tag"></i> <span data-i18n="common.label.name"></span></label>
+        <input type="text" id="node-input-name" data-i18n="[placeholder]common.label.name">
+    </div>
+    <div class="form-row">
+        <label for="node-input-mode"><span data-i18n="link.outMode"></span></label>
+        <select id="node-input-mode" style="width: 70%">
+            <option value="link" selected data-i18n="link.sendToAll"></option>
+            <option value="return" data-i18n="link.returnToCaller"></option>
+        </select>
+    </div>
+    <div class="node-input-link-rows" style="position:relative; height: 30px; text-align: right;"><div style="display:inline-block"><input type="text" id="node-input-link-target-filter"></div></div>
+    <div class="form-row node-input-link-row node-input-link-rows"></div>
+</script>
+
+<script type="text/html" data-template-name="link call">
     <div class="form-row">
         <label for="node-input-name"><i class="fa fa-tag"></i> <span data-i18n="common.label.name"></span></label>
         <input type="text" id="node-input-name" data-i18n="[placeholder]common.label.name">
@@ -48,7 +64,6 @@
                 }
             });
         var candidateNodes = RED.nodes.filterNodes({type:targetType});
-
         var search = $("#node-input-link-target-filter").searchBox({
             style: "compact",
             delay: 300,
@@ -104,7 +119,8 @@
                     node: n,
                     label: n.name||n.id,
                     selected: isChecked,
-                    checkbox: true
+                    checkbox: node.type !== "link call",
+                    radio: node.type === "link call"
                 })
             }
         });
@@ -129,15 +145,22 @@
     function onEditSave(node) {
         var flows = treeList.treeList('data');
         node.links = [];
-        flows.forEach(function(f) {
+        if (node.type !== "link out" || $("node-input-mode").val() === 'link') {
-            f.children.forEach(function(n) {
+            flows.forEach(function(f) {
-                if (n.selected) {
+                f.children.forEach(function(n) {
-                    node.links.push(n.id);
+                    if (n.selected) {
-                }
+                        node.links.push(n.id);
+                    }
+                })
             })
-        })
+        }
         node.oldLinks.sort();
         node.links.sort();
+
+        if (node.type === "link call") {
+            return
+        }
+
         var nodeMap = {};
         var length = Math.max(node.oldLinks.length,node.links.length);
         for (var i=0;i<length;i++) {
@@ -195,6 +218,7 @@
         outputLabels: function(i) {
             return this.name||this._("link.linkIn");
         },
+        showLabel: false,
         label: function() {
             return this.name||this._("link.linkIn");
         },
@@ -211,25 +235,31 @@
         oneditresize: resizeNodeList
     });
 
-    RED.nodes.registerType('link out',{
+    RED.nodes.registerType('link call',{
         category: 'common',
         color:"#ddd",//"#87D8CF",
         defaults: {
             name: {value:""},
             links: { value: [], type:"link in[]"}
         },
-        align:"right",
+        inputs: 1,
-        inputs:1,
+        outputs: 1,
-        outputs:0,
+        icon: "link-call.svg",
-        icon: "link-out.svg",
         inputLabels: function(i) {
-            return this.name||this._("link.linkOut");
+            return this.name||this._("link.linkCall");
         },
         label: function() {
-            return this.name||this._("link.linkOut");
+            if (this.name) {
+                return this.name;
+            }
+            if (this.links.length > 0) {
+                var targetNode = RED.nodes.node(this.links[0]);
+                return targetNode && (targetNode.name || targetNode.id);
+            }
+            return this._("link.linkCall");
         },
         labelStyle: function() {
-            return this.name?"node_label_italic":"";
+            return (this.name || this.links.length > 0)?"node_label_italic":"";
         },
         oneditprepare: function() {
             onEditPrepare(this,"link in");
@@ -237,8 +267,56 @@
         oneditsave: function() {
             onEditSave(this);
         },
+        oneditresize: resizeNodeList
+    });
+
+
+    RED.nodes.registerType('link out',{
+        category: 'common',
+        color:"#ddd",//"#87D8CF",
+        defaults: {
+            name: {value:""},
+            mode: { value: "link" },// link || return
+            links: { value: [], type:"link in[]"}
+        },
+        align:"right",
+        inputs:1,
+        outputs:0,
+        icon: function() {
+            if (this.mode === "return") {
+                return "link-return.svg";
+            } else {
+                return "link-out.svg";
+            }
+        },
+        inputLabels: function(i) {
+            return this.name||(this.mode === "return" ?this._("link.linkOutReturn"):this._("link.linkOut"));
+        },
+        showLabel: false,
+        label: function() {
+            return this.name||(this.mode === "return" ?this._("link.linkOutReturn"):this._("link.linkOut"));
+        },
+        labelStyle: function() {
+            return this.name?"node_label_italic":"";
+        },
+        oneditprepare: function() {
+            onEditPrepare(this,"link in");
+            $("#node-input-mode").on("change", function() {
+                $(".node-input-link-rows").toggle(this.value === "link")
+            })
+            if (!this.mode) {
+                $("#node-input-mode").val('link').trigger("change");
+            }
+
+        },
+        oneditsave: function() {
+            onEditSave(this);
+        },
         onadd: onAdd,
         oneditresize: resizeNodeList
     });
+
+
+
 })();
 </script>

packages/node_modules/@node-red/nodes/core/common/60-link.js

@@ -17,6 +17,8 @@
 module.exports = function(RED) {
     "use strict";
 
+    const crypto = require("crypto");
+
     function LinkInNode(n) {
         RED.nodes.createNode(this,n);
         var node = this;
@@ -40,13 +42,70 @@ module.exports = function(RED) {
     function LinkOutNode(n) {
         RED.nodes.createNode(this,n);
         var node = this;
+        var mode = n.mode || "link";
+
         var event = "node:"+n.id;
         this.on("input", function(msg, send, done) {
             msg._event = event;
             RED.events.emit(event,msg)
-            send(msg);
+
-            done();
+            if (mode === "return") {
+                if (Array.isArray(msg._linkSource) && msg._linkSource.length > 0) {
+                    var messageEvent = msg._linkSource.pop();
+                    var returnNode = RED.nodes.getNode(messageEvent.node);
+                    if (returnNode && returnNode.returnLinkMessage) {
+                        returnNode.returnLinkMessage(messageEvent.id, msg);
+                    } else {
+                        node.warn("Return target not a link-call node")
+                    }
+                } else {
+                    node.warn("No call return target")
+                }
+                done();
+            } else if (mode === "link") {
+                send(msg);
+                done();
+            }
         });
     }
     RED.nodes.registerType("link out",LinkOutNode);
+
+
+    function LinkCallNode(n) {
+        RED.nodes.createNode(this,n);
+        const node = this;
+        const target = n.links[0];
+        const messageEvents = {};
+
+        this.on("input", function(msg, send, done) {
+            msg._linkSource = msg._linkSource || [];
+            const messageEvent = {
+                id: crypto.randomBytes(14).toString('hex'),
+                node: node.id,
+            }
+            messageEvents[messageEvent.id] = { send, done };
+            msg._linkSource.push(messageEvent);
+            var targetNode = RED.nodes.getNode(target);
+            if (targetNode) {
+                targetNode.receive(msg);
+            }
+        });
+
+        this.returnLinkMessage = function(eventId, msg) {
+            if (Array.isArray(msg._linkSource) && msg._linkSource.length === 0) {
+                delete msg._linkSource;
+            }
+            const messageEvent = messageEvents[eventId];
+            if (messageEvent) {
+                delete messageEvents[eventId];
+                messageEvent.send(msg);
+                messageEvent.done();
+            } else {
+                node.warn("Unrecognised message returned")
+            }
+        }
+    }
+    RED.nodes.registerType("link call",LinkCallNode);
+
+
 }

packages/node_modules/@node-red/nodes/icons/link-call.svg

@@ -0,0 +1,5 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!-- Created with Inkscape (http://www.inkscape.org/) -->
+<svg width="10.583mm" height="15.875mm" version="1.1" viewBox="0 0 10.583 15.875" xmlns="http://www.w3.org/2000/svg">
+ <path d="m8.2021 2.3812-4.8922 0.53612 1.604 0.92604-1.0395 1.8004c0.73719-0.37402 1.6437-0.38227 2.4095 0.059892 0.76511 0.44174 1.2118 1.2301 1.2577 2.055l1.0384-1.7986 1.604 0.92604zm-2.3813 4.1244c-0.77016-0.44465-1.7402-0.18474-2.1848 0.58542-0.44465 0.77016-0.185 1.7406 0.58516 2.1853 0.77016 0.44465 1.7422 0.18533 2.1869-0.58483 0.44465-0.77016 0.18295-1.7412-0.58721-2.1858zm-3.3193 1.5159-1.8211 3.1542 3.6662 2.1167 1.82-3.1524c-0.73731 0.37266-1.6431 0.37961-2.4082-0.062129-0.76585-0.44216-1.2122-1.2309-1.2569-2.0563z" fill="#fff"/>
+</svg>

packages/node_modules/@node-red/nodes/icons/link-return.svg

@@ -0,0 +1,5 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!-- Created with Inkscape (http://www.inkscape.org/) -->
+<svg width="10.583mm" height="15.875mm" version="1.1" viewBox="0 0 10.583 15.875" xmlns="http://www.w3.org/2000/svg">
+ <path d="m2.6623 13.292 4.8922-0.53612-1.604-0.92604 1.0395-1.8004c-0.73719 0.37402-1.6437 0.38227-2.4095-0.059892-0.76511-0.44174-1.2118-1.2301-1.2577-2.055l-1.0384 1.7986-1.604-0.92604zm2.3813-4.1244c0.77016 0.44465 1.7402 0.18474 2.1848-0.58542 0.44465-0.77016 0.185-1.7406-0.58516-2.1853-0.77016-0.44465-1.7422-0.18533-2.1869 0.58483-0.44465 0.77016-0.18295 1.7412 0.58721 2.1858zm3.3193-1.5159 1.8211-3.1542-3.6662-2.1167-1.82 3.1524c0.73731-0.37266 1.6431-0.37961 2.4082 0.062129 0.76585 0.44216 1.2122 1.2309 1.2569 2.0563z" fill="#fff"/>
+</svg>

packages/node_modules/@node-red/nodes/locales/en-US/messages.json

@@ -159,7 +159,13 @@
     },
     "link": {
         "linkIn": "link in",
-        "linkOut": "link out"
+        "linkOut": "link out",
+        "linkCall": "link call",
+        "linkOutReturn": "link return",
+        "outMode": "Mode",
+        "sendToAll": "Send to all connected link nodes",
+        "returnToCaller": "Return to calling link node"
+
     },
     "tls": {
         "tls": "TLS configuration",