[NF] Thread that checks if a MQTT Connection exists and if not reopen it

[NF] ConnectorDataMqtt now supports user and password

Zway-Bot.sln

@@ -17,7 +17,9 @@ Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Iot-Interfaces", "..\Utils\
 EndProject
 Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "litjson_4.7.1", "..\Librarys\litjson\litjson\litjson_4.7.1.csproj", "{91A14CD2-2940-4500-8193-56D37EDDDBAA}"
 EndProject
-Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "M2Mqtt", "..\Librarys\mqtt\M2Mqtt\M2Mqtt_4.7.1.csproj", "{A11AEF5A-B246-4FE8-8330-06DB73CC8074}"
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "M2Mqtt_4.7.1", "..\Librarys\mqtt\M2Mqtt\M2Mqtt_4.7.1.csproj", "{A11AEF5A-B246-4FE8-8330-06DB73CC8074}"
+EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Bot-Utils", "..\Utils\Bot-Utils\Bot-Utils.csproj", "{BB7BFCB5-3DB0-49E1-802A-3CE3EECC59F9}"
 EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
@@ -57,6 +59,10 @@ Global
 		{A11AEF5A-B246-4FE8-8330-06DB73CC8074}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{A11AEF5A-B246-4FE8-8330-06DB73CC8074}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{A11AEF5A-B246-4FE8-8330-06DB73CC8074}.Release|Any CPU.Build.0 = Release|Any CPU
+		{BB7BFCB5-3DB0-49E1-802A-3CE3EECC59F9}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{BB7BFCB5-3DB0-49E1-802A-3CE3EECC59F9}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{BB7BFCB5-3DB0-49E1-802A-3CE3EECC59F9}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{BB7BFCB5-3DB0-49E1-802A-3CE3EECC59F9}.Release|Any CPU.Build.0 = Release|Any CPU
 	EndGlobalSection
 	GlobalSection(SolutionProperties) = preSolution
 		HideSolutionNode = FALSE

Zway-Bot/Moduls/Mqtt.cs

@@ -1,6 +1,7 @@
 using System;
 using System.Collections.Generic;
 using System.Text.RegularExpressions;
+using System.Threading;
 using BlubbFish.IoT.Zway;
 using BlubbFish.IoT.Zway.Events;
 using BlubbFish.IoT.Zway.Interfaces;
@@ -11,19 +12,52 @@ using LitJson;
 
 namespace ZwayBot.Moduls {
   class Mqtt : AModul, IDisposable {
-    private readonly ABackend mqtt;
+    private ABackend mqtt;
+    private readonly Thread connectionWatcher;
     private Dictionary<String, AModul> modules;
 
     public override event ModulEvent Update;
 
     public Mqtt(ZwayController zway, InIReader settings) : base(zway, settings) {
       if (this.config.ContainsKey("settings")) {
-        this.mqtt = ABackend.GetInstance(this.config["settings"], ABackend.BackendType.Data);
-        this.mqtt.MessageIncomming += this.Mqtt_MessageIncomming;
-        this.zw.Update += this.ZwayEvent;
+        this.connectionWatcher = new Thread(this.ConnectionWatcherRunner);
+        this.connectionWatcher.Start();
       }
     }
 
+    private void ConnectionWatcherRunner() {
+      while (true) {
+        try {
+          if (this.mqtt == null || !this.mqtt.IsConnected) {
+            this.Reconnect();
+          }
+          Thread.Sleep(10000);
+        } catch (Exception) { }
+      }
+    }
+
+    private void Reconnect() {
+      this.Disconnect();
+      this.Connect();
+    }
+
+    private void Disconnect() {
+      if (this.mqtt != null) {
+        this.mqtt.MessageIncomming -= this.Mqtt_MessageIncomming;
+      }
+      this.zw.Update -= this.ZwayEvent;
+      if (this.mqtt != null) {
+        this.mqtt.Dispose();
+      }
+      this.mqtt = null;
+    }
+
+    private void Connect() {
+      this.mqtt = ABackend.GetInstance(this.config["settings"], ABackend.BackendType.Data);
+      this.mqtt.MessageIncomming += this.Mqtt_MessageIncomming;
+      this.zw.Update += this.ZwayEvent;
+    }
+
     private void ZwayEvent(Object sender, DeviceUpdateEvent e) {
       String topic = "";
       String data = "";
@@ -119,7 +153,9 @@ namespace ZwayBot.Moduls {
     protected virtual void Dispose(Boolean disposing) {
       if (!this.disposedValue) {
         if (disposing) {
-          this.mqtt.Dispose();
+          this.connectionWatcher.Abort();
+          while(this.connectionWatcher.ThreadState == ThreadState.Running) { Thread.Sleep(10); }
+          this.Disconnect();
         }
         this.disposedValue = true;
       }

Zway-Bot/Properties/AssemblyInfo.cs

@@ -10,7 +10,7 @@ using System.Runtime.InteropServices;
 [assembly: AssemblyConfiguration("")]
 [assembly: AssemblyCompany("BlubbFish")]
 [assembly: AssemblyProduct("Zway-Bot")]
-[assembly: AssemblyCopyright("Copyright ©  2017 - 15.05.2018")]
+[assembly: AssemblyCopyright("Copyright ©  2017 - 05.06.2018")]
 [assembly: AssemblyTrademark("BlubbFish")]
 [assembly: AssemblyCulture("")]
 
@@ -31,8 +31,8 @@ using System.Runtime.InteropServices;
 // Sie können alle Werte angeben oder Standardwerte für die Build- und Revisionsnummern verwenden,
 // übernehmen, indem Sie "*" eingeben:
 // [assembly: AssemblyVersion("1.0.*")]
-[assembly: AssemblyVersion("1.5.7")]
-[assembly: AssemblyFileVersion("1.5.7")]
+[assembly: AssemblyVersion("1.6.0")]
+[assembly: AssemblyFileVersion("1.6.0")]
 [assembly: NeutralResourcesLanguage("de-DE")]
 
 // “Internet Of Things” icon by By Michael Wohlwend, US, from thenounproject.com.