Filtered update broadcast. (#367) (#6)

Author: ATATC

src/Device.h

@@ -23,7 +23,7 @@ class Device {
     void initializeAsRoot() { initialize(ArrayList<String>()); }
     virtual T read() { return T(); }
     virtual void write(const T &payload) {}
-    virtual void update(T data) {}
+    virtual void update(const T &data) {}
     virtual void close() {}
 };
 

src/Peer.cpp

@@ -24,12 +24,16 @@ String Peer::read() {
     return "";
 }
 void Peer::write(const String &payload) { Serial.print(payload + _separator); }
+void Peer::update(const String &data) {
+    for (Device<String> d: _devices)
+        if (data.startsWith(d.tag() + ":"))
+            d.update(data.substring(d.tag().length() + 1));
+}
 void Peer::refresh() {
     String msg = read();
     if (msg == "")
         return;
     if (msg == "ic")
         return write(_tag);
-    for (Device<String> d: _devices)
-        d.update(msg);
+    update(msg);
 }

src/Peer.h

@@ -15,6 +15,7 @@ class Peer : public Controller<String, String> {
     void initialize(const ArrayList<String> &parentTags) override;
     String read() override;
     void write(const String &payload) override;
+    void update(const String &data) override;
     void refresh();
 };