From 3f08764dd4a5e49e7c48f0980c3dd3431a117690 Mon Sep 17 00:00:00 2001
From: dceejay <conway@uk.ibm.com>
Date: Mon, 29 Jun 2015 17:29:12 +0100
Subject: [PATCH] Let RBE node handle multiple msg.topic at the same time.

---
 function/rbe/README.md    |  3 +++
 function/rbe/package.json |  2 +-
 function/rbe/rbe.html     |  2 ++
 function/rbe/rbe.js       | 13 +++++++------
 4 files changed, 13 insertions(+), 7 deletions(-)

diff --git a/function/rbe/README.md b/function/rbe/README.md
index e7475bf5..c9a5da06 100644
--- a/function/rbe/README.md
+++ b/function/rbe/README.md
@@ -18,6 +18,9 @@ Usage
 A simple node to provide report by exception (RBE) and deadband function
 - only passes on data if it has changed.
 
+This works on a per **msg.topic** basis. This means that a single rbe node can
+handle multiple topics at the same time.
+
 ###RBE mode
 
 Outputs the **msg** if the **msg.payload** is different to the previous one.
diff --git a/function/rbe/package.json b/function/rbe/package.json
index 5add0be8..a0dde101 100644
--- a/function/rbe/package.json
+++ b/function/rbe/package.json
@@ -1,6 +1,6 @@
 {
     "name"          : "node-red-node-rbe",
-    "version"       : "0.0.4",
+    "version"       : "0.0.5",
     "description"   : "A Node-RED node that provides report-by-exception (RBE) and deadband capability.",
     "dependencies"  : {
     },
diff --git a/function/rbe/rbe.html b/function/rbe/rbe.html
index 2476fa95..9788b4b7 100644
--- a/function/rbe/rbe.html
+++ b/function/rbe/rbe.html
@@ -38,6 +38,8 @@
     different to the previous one. Works on numbers and strings.</p>
     <p>In <b>deadband</b> mode the incoming payload should contain a parseable <i>number</i> and is
     output only if greater than + or - the <i>band gap</i> away from the previous output.</p>
+    <p><b>Note:</b> This works on a per <b>msg.topic</b> basis. This means that a single rbe node can
+handle multiple topics at the same time.</p>
 </script>
 
 <script type="text/javascript">
diff --git a/function/rbe/rbe.js b/function/rbe/rbe.js
index 45e151f2..057e4a89 100644
--- a/function/rbe/rbe.js
+++ b/function/rbe/rbe.js
@@ -23,21 +23,22 @@ module.exports = function(RED) {
         this.gap = n.gap || 0;
         var node = this;
 
-        var previous = null;
+        node.previous = {};
         this.on("input",function(msg) {
             if (msg.hasOwnProperty("payload")) {
+                var t = msg.topic || "_no_topic";
                 if (this.func === "rbe") {
-                    if (msg.payload != previous) {
-                        previous = msg.payload;
+                    if (msg.payload != node.previous[t]) {
+                        node.previous[t] = msg.payload;
                         node.send(msg);
                     }
                 }
                 else {
                     var n = parseFloat(msg.payload);
                     if (!isNaN(n)) {
-                        if (previous == null) { previous = n - node.gap; }
-                        if (Math.abs(n - previous) >= node.gap) {
-                            previous = n;
+                        if (!node.previous.hasOwnProperty(t)) { node.previous[t] = n - node.gap; }
+                        if (Math.abs(n - node.previous[t]) >= node.gap) {
+                            node.previous[t] = n;
                             node.send(msg);
                         }
                     }