[NF] Filter nun auch für FMS und ZVEI

BosmonMqtt/MqttEventProcessor.cs

@@ -17,7 +17,9 @@ namespace BlubbFish.BosmonMqtt {
     private IBosMonHost pluginhost;
     private MqttClient client;
     private FilterList filter;
-    private List<PocsagFilterItem> pfilter = new List<PocsagFilterItem>();
+    private List<FilterItem> pfilter = new List<FilterItem>();
+    private List<FilterItem> ffilter = new List<FilterItem>();
+    private List<FilterItem> zfilter = new List<FilterItem>();
     Thread connectionWatcher;
 
     public MqttEventProcessor(PluginConfiguration pluginconfiguration, IBosMonHost pluginHost) {
@@ -102,6 +104,12 @@ namespace BlubbFish.BosmonMqtt {
           if (item.GetType() == typeof(PocsagFilterItem)) {
             this.pfilter.Add(item as PocsagFilterItem);
           }
+          if (item.GetType() == typeof(FmsFilterItem)) {
+            this.ffilter.Add(item as FmsFilterItem);
+          }
+          if (item.GetType() == typeof(ZveiFilterItem)) {
+            this.zfilter.Add(item as ZveiFilterItem);
+          }
         }
         this.Log("Connect", "Erfolgreich verbunden.");
       }
@@ -109,6 +117,8 @@ namespace BlubbFish.BosmonMqtt {
 
     private void Disconnect() {
       this.pfilter.Clear();
+      this.ffilter.Clear();
+      this.zfilter.Clear();
       if (this.client != null && this.client.IsConnected) {
         this.client.Unsubscribe(new String[] { this.pluginconfig.Topic });
         this.client.Disconnect();
@@ -122,20 +132,52 @@ namespace BlubbFish.BosmonMqtt {
         try {
           Telegram t = e.Telegram as Telegram;
           if (this.client != null && this.client.IsConnected && this.filter != null) {
-            if (t.Type == PocsagTelegram.TYPE_POCSAG) {
+            if (this.FilterMatch(t)) {
-              PocsagTelegram p = t as PocsagTelegram;
+              if (t.Type == PocsagTelegram.TYPE_POCSAG) {
-              foreach (PocsagFilterItem item in this.pfilter) {
+                PocsagTelegram p = t as PocsagTelegram;
-                if ((item.IsMatching(p) && item.Negated)) {
+                this.client.Publish(this.pluginconfig.Topic + "pocsag/" + p.Address + p.Func, Encoding.UTF8.GetBytes(p.Msg));
-                  return;
+              } else if(t.Type == FmsTelegram.TYPE_FMS) {
-                }
+                FmsTelegram f = t as FmsTelegram;
+                this.client.Publish(this.pluginconfig.Topic + "fms/" + f.Address, Encoding.UTF8.GetBytes(f.Bos + "\t" + f.Fzg + "\t" + f.Info + "\t" + f.Lkz + "\t" + f.Msg + "\t" + f.Okz + "\t" + f.Status));
+              } else if(t.Type == ZveiTelegram.TYPE_ZVEI) {
+                ZveiTelegram z = t as ZveiTelegram;
+                this.client.Publish(this.pluginconfig.Topic + "zvei/" + z.Address, Encoding.UTF8.GetBytes(""));
+              } else if (t.Type == ZveiDtmfTelegram.TYPE_ZVEIDTMF) {
+                ZveiDtmfTelegram z = t as ZveiDtmfTelegram;
+                this.client.Publish(this.pluginconfig.Topic + "zveidmf/" + z.Address, Encoding.UTF8.GetBytes(z.DtmfTone));
               }
-              this.client.Publish(this.pluginconfig.Topic + p.Address + p.Func, Encoding.UTF8.GetBytes(p.Msg));
             }
           }
         } catch (Exception) { }
       }
     }
 
+    private Boolean FilterMatch(Telegram t) {
+      if (t.Type == PocsagTelegram.TYPE_POCSAG) {
+        return this.FilterMatchType(this.pfilter, t);
+      } else if(t.Type == FmsTelegram.TYPE_FMS) {
+        return this.FilterMatchType(this.ffilter, t);
+      } else {
+        return this.FilterMatchType(this.zfilter, t);
+      }
+    }
+
+    private Boolean FilterMatchType(List<FilterItem> filter, Telegram t) {
+      Boolean negatedInList = false;
+      foreach (FilterItem item in filter) {
+        if (item.IsMatching(t) && item.Negated) {
+          return false;
+        }
+        if(item.IsMatching(t) && !item.Negated) {
+          return true;
+        }
+        if(item.Negated) {
+          negatedInList = true;
+        }
+      }
+      return negatedInList;
+    }
+
     private void Log(String method, String text) {
       BosMonLog.Logger.WriteLine(LogSeverity.Info, "BosmonMqtt.MqttEventProcessor", method, text);
       this.pluginhost.AddMessage(DateTime.Now.Ticks, MessageType.Message, "BosmonMqtt " + text);

BosmonMqtt/MqttPlugin.cs

@@ -21,7 +21,7 @@ namespace BlubbFish.BosmonMqtt {
 
     Int32 IBosMonPlugin.PluginVersion {
       get {
-        return 1;
+        return 2;
       }
     }
 

BosmonMqtt/Properties/AssemblyInfo.cs

@@ -33,7 +33,7 @@ using System.Runtime.InteropServices;
 // Sie können alle Werte angeben oder Standardwerte für die Build- und Revisionsnummern verwenden,
 // indem Sie "*" wie unten gezeigt eingeben:
 // [assembly: AssemblyVersion("1.0.*")]
-[assembly: AssemblyVersion("1.0.0.0")]
+[assembly: AssemblyVersion("1.2.0.0")]
-[assembly: AssemblyFileVersion("1.0.0.0")]
+[assembly: AssemblyFileVersion("1.2.0.0")]
 [assembly: NeutralResourcesLanguage("de")]