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/CommandClasses/CommandClassSubs/SensorMultilevelSub.cs

@@ -65,7 +65,7 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses.CommandClassSubs {
         Double l = Double.Parse(json["val"]["value"].ToString());
         if (t == "Power" && (l > 3660 || l < 0) ||
           t == "Temperature" && (l > 65 || l < -25) ||
-          (t == "Temperature" && this.Level >= 4 && l == 0)) {
+          (t == "Temperature" && this.Level >= 4 && Math.Abs(l) <= 0.1)) {
           return;
         }
       }
@@ -89,6 +89,8 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses.CommandClassSubs {
         return new List<Senml>() { new SenmlDouble("power", Senml.Units.Watt, this.Level) };
       } else if(this.Scale == "°C") {
         return new List<Senml>() { new SenmlDouble("temperatur", Senml.Units.Celsius, this.Level) };
+      } else if(this.Scale == "Lux") {
+        return new List<Senml>() { new SenmlDouble("luminiscence", Senml.Units.Lux, this.Level) };
       }
       return new List<Senml>() { };
     }

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

@@ -23,22 +23,29 @@ namespace BlubbFish.IoT.Zway.Interfaces {
       SwitchColor = 51,
       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
     }
 
@@ -259,14 +266,14 @@ namespace BlubbFish.IoT.Zway.Interfaces {
       }
       Dictionary<String, Object> json = new Dictionary<String, Object> {
         { "e", l },
-        { "bn", "urn:dev:id:" + this.SenmlTopic() },
+        { "bn", this.DeviceId + "/" + this.Instance + "/" + ((Int32)this.Commandclass).ToString() + (this.IsSub ? "/" + this.SensorId : "") + "/" },
         { "bt", ((DateTimeOffset)this.LastUpdate).ToUnixTimeSeconds() }
       };
       return JsonMapper.ToJson(json);
     }
 
     public String SenmlTopic() {
-      return this.DeviceId + "/" + this.Instance + "/" + ((Int32)this.Commandclass).ToString() + (this.IsSub ? "/" + this.SensorId : "");
+      return "LS/v2/ZGW/";
     }
     #endregion
 

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.0.0")]
+[assembly: AssemblyVersion("1.5.0")]
-[assembly: AssemblyFileVersion("1.4.0.0")]
+[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,9 +104,11 @@ 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();
-        JsonData notifications = this.http.GetJson("ZWave.zway/Data/"+date);
+        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);
           if(match.Success) {

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) {
-      this.GetString(v, false);
+      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;