Zway [v1.5.0] Throw Exception if 3 times failed to connect to Raspberry server, add 3 new commandlcasses to IgnoredClasses

Zway-Bot [v1.7.0] rewrite to Threaded Modules, edit service file for systemd

Zway/Devices/Device.cs

@@ -8,7 +8,7 @@ using LitJson;
 
 namespace BlubbFish.IoT.Zway.Devices {
   public class Device {
-    private Boolean polling;
+    private readonly Boolean polling;
 
     public delegate void UpdatedDevice(Object sender, DeviceUpdateEvent e);
     public event UpdatedDevice Update;

Zway/Devices/Instance.cs

@@ -10,7 +10,7 @@ using LitJson;
 namespace BlubbFish.IoT.Zway.Devices {
   public class Instance {
     private DateTime nextwakeup;
-    private Boolean polling;
+    private readonly Boolean polling;
 
     public delegate void UpdatedInstance(Object sender, DeviceUpdateEvent e);
     public event UpdatedInstance Update;

Zway/Interfaces/ACommandClass.cs

@@ -24,24 +24,28 @@ namespace BlubbFish.IoT.Zway.Interfaces {
       MeterPulse = 53,
       MeterTableMonitor = 61,
       ThermostatOperatingState = 66,
+      ClimateControlSchedule = 70,
       CRC16 = 86,
       AssociationGroupInformation = 89,
       DeviceResetLocally = 90,
       ZWavePlusInfo = 94,
       MultiChannel = 96,
       DoorLock = 98,
+      BarrierOperator = 102,
       ManufacturerSpecific = 114,
       PowerLevel = 115,
       InclusionController = 116,
       Protection = 117,
       NodeNaming = 119,
       FirmwareUpdate = 122,
+      Clock = 129,
       Association = 133,
       Version = 134,
       Proprietary = 136,
       TimeParameters = 139,
       MultiChannelAssociation = 142,
       MultiCmd = 143,
+      SimpleAVControl = 148,
       Security = 152
     }
 

Zway/Properties/AssemblyInfo.cs

@@ -10,7 +10,7 @@ using System.Runtime.InteropServices;
 [assembly: AssemblyConfiguration("")]
 [assembly: AssemblyCompany("")]
 [assembly: AssemblyProduct("Zway")]
-[assembly: AssemblyCopyright("Copyright ©  2017 - 03.05.2018")]
+[assembly: AssemblyCopyright("Copyright ©  2017 - 29.09.2018")]
 [assembly: AssemblyTrademark("")]
 [assembly: AssemblyCulture("")]
 
@@ -32,5 +32,5 @@ 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.4.4")]
+[assembly: AssemblyVersion("1.5.0")]
-[assembly: AssemblyFileVersion("1.4.4")]
+[assembly: AssemblyFileVersion("1.5.0")]

Zway/ZwayController.cs

@@ -16,7 +16,7 @@ namespace BlubbFish.IoT.Zway {
     private Thread updatethread;
     private Thread pollthread;
     public static ReadOnlyDictionary<String, String> namelist;
-    private Boolean polling;
+    private readonly Boolean polling;
 
     public delegate void DataUpdate(Object sender, DeviceUpdateEvent e);
     public event DataUpdate Update;
@@ -104,8 +104,10 @@ namespace BlubbFish.IoT.Zway {
       CultureInfo.DefaultThreadCurrentUICulture = info;
       Thread.CurrentThread.CurrentCulture = info;
       Thread.CurrentThread.CurrentUICulture = info;
+      DateTime lastRequest = DateTime.Now.AddSeconds(-2);
       while (true) {
-        Int64 date = ((DateTimeOffset)DateTime.Now.AddSeconds(-2)).ToUnixTimeSeconds();
+        Int64 date = ((DateTimeOffset)lastRequest).ToUnixTimeSeconds();
+        lastRequest = DateTime.Now;
         JsonData notifications = this.http.GetJson("ZWave.zway/Data/" + date);         
         foreach (String item in notifications.Keys) {
           Match match = new Regex("^devices\\.([0-9]+)\\.instances\\.([0-9]+)\\.commandClasses\\.([0-9]+)(\\.data\\.([0-9]+)|\\.data\\.[a-z].*|\\.data)$", RegexOptions.IgnoreCase).Match(item);

Zway/lib/HttpClient.cs

@@ -6,9 +6,9 @@ using LitJson;
 
 namespace BlubbFish.IoT.Zway.lib {
   public class HttpConnection {
-    private String auth;
+    private readonly String auth;
-    private String server;
+    private readonly String server;
-    private Object getLock = new Object();
+    private static readonly Object getLock = new Object();
 
     internal HttpConnection(String server, String user, String pass) {
       this.auth = "Basic " + Convert.ToBase64String(Encoding.ASCII.GetBytes(user + ":" + pass));
@@ -17,11 +17,23 @@ namespace BlubbFish.IoT.Zway.lib {
     }
 
     private void Init() {
-      this.GetString("ZAutomation/api/v1/status");
+      this.GetVoid("ZAutomation/api/v1/status");
     }
 
     internal JsonData GetJson(String v) {
-      String text = this.GetString(v);
+      String text = null;
+      for (Int32 i = 0; i < 3; i++) {
+        try {
+          text = this.GetString(v);
+          break;
+        } catch (Exception e) {
+          Helper.WriteError(e.Message);
+          if(i==2) {
+            throw;
+          }
+          System.Threading.Thread.Sleep(30000);
+        }
+      }
       if(text == null) {
         return new JsonData();
       }
@@ -33,14 +45,25 @@ namespace BlubbFish.IoT.Zway.lib {
     }
 
     internal void GetVoid(String v) {
+      for (Int32 i = 0; i < 3; i++) {
+        try {
           this.GetString(v, false);
+          break;
+        } catch (Exception e) {
+          Helper.WriteError(e.Message);
+          if (i == 2) {
+            throw;
+          }
+          System.Threading.Thread.Sleep(30000);
+        }
+      }
     }
 
     private String GetString(String v, Boolean withoutput = true) {
       String ret = null;
-      lock (this.getLock) {
+      lock (getLock) {
         HttpWebRequest request = WebRequest.CreateHttp(this.server + v);
-        request.Timeout = 5000;
+        request.Timeout = 10000;
         request.Headers.Add(HttpRequestHeader.Authorization, this.auth);
         try {
           using (HttpWebResponse response = (HttpWebResponse)request.GetResponse()) {
@@ -54,9 +77,9 @@ namespace BlubbFish.IoT.Zway.lib {
             }
           }
         } catch (Exception e) {
-          Helper.WriteError("Konnte keine Verbindung zum Razzbery Server herstellen. Resource: \"" + this.server + v + "\" Fehler: " + e.Message);
+          //Helper.WriteError("Konnte keine Verbindung zum Razzbery Server herstellen. Resource: \"" + this.server + v + "\" Fehler: " + e.Message);
-          return null;
+          //return null;
-          //throw new Exceptions.ConnectionException("Konnte keine Verbindung zum Razzbery Server herstellen: " + e.Message);
+          throw new Exceptions.ConnectionException("Konnte keine Verbindung zum Razzbery Server herstellen: " + e.Message);
         }
       }
       return ret;