From 27c0e45940f2ac07594cd0853c6557c6cbe1199c Mon Sep 17 00:00:00 2001 From: Nick O'Leary Date: Thu, 30 Jul 2020 17:52:28 +0100 Subject: [PATCH] Remove unused router component --- .../runtime/lib/flows/router/index.js | 50 ------------------- .../runtime/lib/flows/router/localRouter.js | 17 ------- 2 files changed, 67 deletions(-) delete mode 100644 packages/node_modules/@node-red/runtime/lib/flows/router/index.js delete mode 100644 packages/node_modules/@node-red/runtime/lib/flows/router/localRouter.js diff --git a/packages/node_modules/@node-red/runtime/lib/flows/router/index.js b/packages/node_modules/@node-red/runtime/lib/flows/router/index.js deleted file mode 100644 index 116019635..000000000 --- a/packages/node_modules/@node-red/runtime/lib/flows/router/index.js +++ /dev/null @@ -1,50 +0,0 @@ - -var settings; - -const LocalRouter = require("./localRouter"); -var defaultRouter; - - -class Router { - constructor(stack) { - this.stack = stack || []; - } - send(source,destinationId,msg) { - var pos = 0; - var next = () => { - var router = this.stack[pos++]; - if (router) { - router.send(source,destinationId,msg,next); - } - } - next(); - } -} - -function init(runtime) { - settings = runtime.settings; - - defaultRouter = new Router([ - new LocalRouter(), - new PostMessageLogger() - ]) - -} - -function send(source,destinationId,msg) { - defaultRouter.send(source,destinationId,msg); -} - -module.exports = { - init:init, - send: send -} - - - -class PostMessageLogger { - constructor() {} - send(source,destinationId,msg,next) { - console.log(source.id.padEnd(16),"->",destinationId.padEnd(16),JSON.stringify(msg)); - } -} diff --git a/packages/node_modules/@node-red/runtime/lib/flows/router/localRouter.js b/packages/node_modules/@node-red/runtime/lib/flows/router/localRouter.js deleted file mode 100644 index 96dcc3489..000000000 --- a/packages/node_modules/@node-red/runtime/lib/flows/router/localRouter.js +++ /dev/null @@ -1,17 +0,0 @@ - -class LocalRouter { - constructor() {} - send(source,destinationId,msg,next) { - var node = source._flow.getNode(destinationId); - if (node) { - setImmediate(function() { - node.receive(msg); - next(); - }); - } else if (next) { - next() - } - } -} - -module.exports = LocalRouter \ No newline at end of file