Compare commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
0834e09178 | ||
|
|
b29e1d2a14 | ||
|
|
d9dfe7d63a | ||
|
|
db935e019c | ||
|
|
d7f27fad4f | ||
|
|
d439471051 | ||
|
|
1445a16930 | ||
|
|
b51f88badb | ||
|
|
8166e6e646 | ||
|
|
06e57c4559 | ||
|
|
53e4ba9d14 |
@@ -1,103 +0,0 @@
|
||||
using System;
|
||||
using System.Collections.Generic;
|
||||
using System.Text.RegularExpressions;
|
||||
using BlubbFish.IoT.Zway.Events;
|
||||
using BlubbFish.IoT.Zway.Interfaces;
|
||||
using BlubbFish.IoT.Zway.lib;
|
||||
using LitJson;
|
||||
|
||||
namespace BlubbFish.IoT.Zway.Devices {
|
||||
public abstract class CommandClass : ICommandClass {
|
||||
protected HttpConnection http;
|
||||
|
||||
public abstract event UpdatedValue Update;
|
||||
private enum Ignored {
|
||||
Basic = 32,
|
||||
ManufacturerSpecific = 114,
|
||||
PowerLevel = 115,
|
||||
Protection = 117,
|
||||
NodeNaming = 119,
|
||||
FirmwareUpdate = 122,
|
||||
Association = 133,
|
||||
Version = 134,
|
||||
MultiChannelAssociation = 142,
|
||||
MultiCmd = 143
|
||||
}
|
||||
|
||||
public Int32 DeviceId { get; }
|
||||
public Int32 Instance { get; }
|
||||
public Int32 Commandclass { get; }
|
||||
public String Id { get; }
|
||||
public DateTime LastUpdate { get; private set; }
|
||||
public String Name { get; }
|
||||
public Boolean Polling { get; set; }
|
||||
|
||||
protected CommandClass(JsonData json, HttpConnection http, Tuple<Int32, Int32, Int32> id, Boolean polling) {
|
||||
this.DeviceId = id.Item1;
|
||||
this.Instance = id.Item2;
|
||||
this.Commandclass = id.Item3;
|
||||
this.http = http;
|
||||
this.LastUpdate = DateTime.Now;
|
||||
this.Polling = polling;
|
||||
this.Id = this.DeviceId + "-" + this.Instance + "-" + this.Commandclass;
|
||||
if (ZwayController.namelist.ContainsKey(this.Id)) {
|
||||
this.Name = ZwayController.namelist[this.Id];
|
||||
}
|
||||
}
|
||||
|
||||
protected Boolean CheckSetUpdateTime(JsonData json) {
|
||||
if (json.Keys.Contains("updateTime") && (json["updateTime"].IsInt || json["updateTime"].IsLong)) {
|
||||
DateTime newdate = DateTimeOffset.FromUnixTimeSeconds(Int64.Parse(json["updateTime"].ToString())).ToLocalTime().DateTime;
|
||||
if(newdate > this.LastUpdate) {
|
||||
this.LastUpdate = newdate;
|
||||
return true;
|
||||
} else {
|
||||
return false;
|
||||
}
|
||||
} else {
|
||||
return true;
|
||||
}
|
||||
}
|
||||
|
||||
internal static CommandClass CreateInstance(JsonData json, Tuple<Int32, Int32, Int32> id, HttpConnection http, Boolean polling) {
|
||||
if (json.Keys.Contains("name") &&
|
||||
json.Keys.Contains("data") &&
|
||||
json["data"].Keys.Contains("supported") &&
|
||||
json["data"]["supported"].Keys.Contains("value") &&
|
||||
Boolean.Parse(json["data"]["supported"]["value"].ToString()) &&
|
||||
!Enum.IsDefined(typeof(Ignored), id.Item3)) {
|
||||
String name = json["name"].ToString();
|
||||
String objectName = "BlubbFish.IoT.Zway.Devices.CommandClasses." + name[0].ToString().ToUpper() + name.Substring(1).ToLower();
|
||||
return GetInstanceConcrete(objectName, json, http, id, polling);
|
||||
}
|
||||
return null;
|
||||
}
|
||||
|
||||
private static CommandClass GetInstanceConcrete(String objectName, JsonData json, HttpConnection http, Tuple<Int32, Int32, Int32> id, Boolean polling) {
|
||||
Type t = null;
|
||||
try {
|
||||
t = Type.GetType(objectName, true);
|
||||
} catch (TypeLoadException) {
|
||||
Console.Error.WriteLine("Konnte Type " + objectName + " nicht laden!");
|
||||
return null;
|
||||
}
|
||||
return (CommandClass)t.GetConstructor(new Type[] { typeof(JsonData), typeof(HttpConnection), typeof(Tuple<Int32, Int32, Int32>), typeof(Boolean) }).Invoke(new Object[] { json, http, id, polling });
|
||||
}
|
||||
|
||||
internal abstract void SetUpdate(JsonData json, Match match);
|
||||
|
||||
internal virtual void Poll() {
|
||||
if(this.Polling) {
|
||||
this.http.GetVoid("ZWave.zway/Run/devices[" + this.DeviceId + "].instances[" + this.Instance + "].commandClasses[" + this.Commandclass + "].Get()");
|
||||
}
|
||||
}
|
||||
|
||||
protected void SetInt(Int32 value) {
|
||||
this.http.GetVoid("ZWave.zway/Run/devices[" + this.DeviceId + "].instances[" + this.Instance + "].commandClasses[" + this.Commandclass + "].Set("+value+")");
|
||||
}
|
||||
|
||||
protected void SetIntTuple(Int32 value1, Int32 value2) {
|
||||
this.http.GetVoid("ZWave.zway/Run/devices[" + this.DeviceId + "].instances[" + this.Instance + "].commandClasses[" + this.Commandclass + "].Set(" + value1 + "," + value2 + ")");
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -1,52 +0,0 @@
|
||||
using System;
|
||||
using System.Text.RegularExpressions;
|
||||
using BlubbFish.IoT.Zway.Interfaces;
|
||||
using BlubbFish.IoT.Zway.lib;
|
||||
using LitJson;
|
||||
|
||||
namespace BlubbFish.IoT.Zway.Devices {
|
||||
public abstract class CommandClassSub : ICommandClass {
|
||||
protected HttpConnection http;
|
||||
|
||||
public abstract event UpdatedValue Update;
|
||||
public String Id { get; }
|
||||
public Int32 DeviceId { get; }
|
||||
public Int32 Instance { get; }
|
||||
public Int32 Commandclass { get; }
|
||||
public Int32 SensorId { get; }
|
||||
public String Name { get; }
|
||||
public DateTime LastUpdate { get; private set; }
|
||||
public Boolean Polling { get; set; }
|
||||
|
||||
protected CommandClassSub(JsonData json, Tuple<Int32, Int32, Int32, Int32> id, HttpConnection http, Boolean polling) {
|
||||
this.DeviceId = id.Item1;
|
||||
this.Instance = id.Item2;
|
||||
this.Commandclass = id.Item3;
|
||||
this.SensorId = id.Item4;
|
||||
this.http = http;
|
||||
this.LastUpdate = DateTime.Now;
|
||||
this.Polling = polling;
|
||||
this.Id = this.DeviceId + "-" + this.Instance + "-" + this.Commandclass + "-" + this.SensorId;
|
||||
if (ZwayController.namelist.ContainsKey(this.Id)) {
|
||||
this.Name = ZwayController.namelist[this.Id];
|
||||
}
|
||||
}
|
||||
|
||||
protected Boolean CheckSetUpdateTime(JsonData json) {
|
||||
if (json.Keys.Contains("updateTime") && (json["updateTime"].IsInt || json["updateTime"].IsLong)) {
|
||||
DateTime newdate = DateTimeOffset.FromUnixTimeSeconds(Int64.Parse(json["updateTime"].ToString())).ToLocalTime().DateTime;
|
||||
if (newdate > this.LastUpdate) {
|
||||
this.LastUpdate = newdate;
|
||||
return true;
|
||||
} else {
|
||||
return false;
|
||||
}
|
||||
} else {
|
||||
return true;
|
||||
}
|
||||
}
|
||||
internal abstract void SetUpdate(JsonData json, Match match);
|
||||
|
||||
internal abstract void Poll();
|
||||
}
|
||||
}
|
||||
@@ -1,4 +1,5 @@
|
||||
using System;
|
||||
using System.Collections.Generic;
|
||||
using System.Text.RegularExpressions;
|
||||
using BlubbFish.IoT.Zway.Events;
|
||||
using BlubbFish.IoT.Zway.Interfaces;
|
||||
@@ -9,13 +10,13 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses {
|
||||
/// <summary>
|
||||
/// 128 = Battery
|
||||
/// </summary>
|
||||
public class Battery : CommandClass {
|
||||
public class Battery : ACommandClass {
|
||||
|
||||
public Single Level { get; private set; }
|
||||
public Double Level { get; private set; }
|
||||
|
||||
public override event UpdatedValue Update;
|
||||
|
||||
public Battery(JsonData json, HttpConnection http, Tuple<Int32, Int32, Int32> id, Boolean polling) : base(json, http, id, polling) {
|
||||
public Battery(JsonData json, Tuple<Int32, Int32, Classes> id, HttpConnection http, Boolean polling) : base(json, id, http, polling) {
|
||||
this.InitComplex(json);
|
||||
}
|
||||
|
||||
@@ -23,12 +24,12 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses {
|
||||
Boolean success = false;
|
||||
if (match.Groups[4].Value == ".data") {
|
||||
if (json.Keys.Contains("last") && json["last"].Keys.Contains("value")) {
|
||||
this.Level = Single.Parse(json["last"]["value"].ToString());
|
||||
this.Level = Double.Parse(json["last"]["value"].ToString());
|
||||
success = true;
|
||||
}
|
||||
} else if (match.Groups[4].Value == ".data.last") {
|
||||
if (json.Keys.Contains("value")) {
|
||||
this.Level = Single.Parse(json["value"].ToString());
|
||||
this.Level = Double.Parse(json["value"].ToString());
|
||||
success = true;
|
||||
}
|
||||
} else if (match.Groups[4].Value.StartsWith(".data.history.")) {
|
||||
@@ -37,18 +38,24 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses {
|
||||
Helper.WriteError("Kenne in "+this.Name+" ["+this.Id+"] "+ match.Groups[4].Value+" nicht!");
|
||||
}
|
||||
if (success && this.CheckSetUpdateTime(json)) {
|
||||
this.Update?.Invoke(this, new DeviceUpdateEvent(this.Level, this.LastUpdate));
|
||||
this.Update?.Invoke(this, new DeviceUpdateEvent(this.Level, this.LastUpdate, this));
|
||||
}
|
||||
}
|
||||
|
||||
private void InitComplex(JsonData json) {
|
||||
if (json.Keys.Contains("data") && json["data"].Keys.Contains("last") && json["data"]["last"].Keys.Contains("value")) {
|
||||
this.Level = Single.Parse(json["data"]["last"]["value"].ToString());
|
||||
this.Level = Double.Parse(json["data"]["last"]["value"].ToString());
|
||||
}
|
||||
}
|
||||
|
||||
public override String ToString() {
|
||||
return "Battery " + this.Name + " [" + this.Id + "]: " + this.Level;
|
||||
}
|
||||
|
||||
public override Dictionary<String, Object> ToDictionary() {
|
||||
return new Dictionary<String, Object> {
|
||||
{ "Level", this.Level },
|
||||
};
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@@ -11,14 +11,14 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses {
|
||||
/// <summary>
|
||||
/// 91 = CentralScene
|
||||
/// </summary>
|
||||
public class Centralscene : CommandClass {
|
||||
public class Centralscene : ACommandClass {
|
||||
public override event UpdatedValue Update;
|
||||
|
||||
public ReadOnlyDictionary<Int32, ReadOnlyCollection<Int32>> ValidScenesModes { get; private set; }
|
||||
public Int32 Scene { get; private set; }
|
||||
public Int32 Key { get; private set; }
|
||||
|
||||
public Centralscene(JsonData json, HttpConnection http, Tuple<Int32, Int32, Int32> id, Boolean polling) : base(json, http, id, polling) {
|
||||
public Centralscene(JsonData json, Tuple<Int32, Int32, Classes> id, HttpConnection http, Boolean polling) : base(json, id, http, polling) {
|
||||
this.ValidScenesModes = new ReadOnlyDictionary<Int32, ReadOnlyCollection<Int32>>(new Dictionary<Int32, ReadOnlyCollection<Int32>>());
|
||||
this.InitComplex(json);
|
||||
}
|
||||
@@ -31,7 +31,7 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses {
|
||||
} else if (match.Groups[4].Value == ".data.keyAttribute") {
|
||||
if (json.Keys.Contains("value") && this.CheckSetUpdateTime(json)) {
|
||||
this.Key = Int32.Parse(json["value"].ToString());
|
||||
this.Update?.Invoke(this, new DeviceUpdateEvent(new Tuple<Int32, Int32>(this.Scene, this.Key), this.LastUpdate));
|
||||
this.Update?.Invoke(this, new DeviceUpdateEvent(new Tuple<Int32, Int32>(this.Scene, this.Key), this.LastUpdate, this));
|
||||
}
|
||||
} else {
|
||||
Helper.WriteError("Kenne in " + this.Name + " [" + this.Id + "] " + match.Groups[4].Value + " nicht!");
|
||||
@@ -74,7 +74,13 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses {
|
||||
return "CentralScene " + this.Name + " [" + this.Id + "]: " + this.Scene+"-"+this.Key;
|
||||
}
|
||||
|
||||
internal override void Poll() {
|
||||
internal override void Poll() => this.PollNone();
|
||||
|
||||
public override Dictionary<String, Object> ToDictionary() {
|
||||
return new Dictionary<String, Object> {
|
||||
{ "Scene", this.Scene },
|
||||
{ "Key", this.Key },
|
||||
};
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@@ -1,4 +1,5 @@
|
||||
using System;
|
||||
using System.Collections.Generic;
|
||||
using System.Text.RegularExpressions;
|
||||
using BlubbFish.IoT.Zway.Events;
|
||||
using BlubbFish.IoT.Zway.Interfaces;
|
||||
@@ -6,10 +7,9 @@ using BlubbFish.IoT.Zway.lib;
|
||||
using LitJson;
|
||||
|
||||
namespace BlubbFish.IoT.Zway.Devices.CommandClasses.CommandClassSubs {
|
||||
class Configurationsub : CommandClassSub {
|
||||
private Int64 _level;
|
||||
|
||||
class Configurationsub : ACommandClass {
|
||||
public override event UpdatedValue Update;
|
||||
private Int64 _level;
|
||||
|
||||
public Int64 Level {
|
||||
get {
|
||||
@@ -17,17 +17,18 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses.CommandClassSubs {
|
||||
}
|
||||
set {
|
||||
if (this.Size == 1 && Int16.TryParse(value.ToString(), out Int16 value16)) {
|
||||
this.http.GetVoid("ZWave.zway/Run/devices[" + this.DeviceId + "].instances[" + this.Instance + "].commandClasses[" + this.Commandclass + "].Set(" + this.SensorId + "," + value16 + ",1)");
|
||||
this.SetTriple(this.SensorId, value16, 1);
|
||||
} else if(this.Size == 2 && Int32.TryParse(value.ToString(), out Int32 value32)) {
|
||||
this.http.GetVoid("ZWave.zway/Run/devices[" + this.DeviceId + "].instances[" + this.Instance + "].commandClasses[" + this.Commandclass + "].Set(" + this.SensorId + "," + value32 + ",2)");
|
||||
this.SetTriple(this.SensorId, value32, 2);
|
||||
} else if(this.Size == 4) {
|
||||
this.http.GetVoid("ZWave.zway/Run/devices[" + this.DeviceId + "].instances[" + this.Instance + "].commandClasses[" + this.Commandclass + "].Set(" + this.SensorId + "," + value + ",4)");
|
||||
this.SetTriple(this.SensorId, value, 4);
|
||||
}
|
||||
}
|
||||
}
|
||||
public Int32 Size { get; private set; }
|
||||
|
||||
public Configurationsub(JsonData json, Tuple<Int32, Int32, Int32, Int32> id, HttpConnection http, Boolean polling) : base(json, id, http, polling) {
|
||||
public Configurationsub(JsonData json, Tuple<Int32, Int32, Classes, Int32> id, HttpConnection http, Boolean polling) : base(json, id, http, polling) {
|
||||
this.IsSub = true;
|
||||
InitComplex(json);
|
||||
}
|
||||
|
||||
@@ -42,11 +43,7 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses.CommandClassSubs {
|
||||
}
|
||||
}
|
||||
|
||||
internal override void Poll() {
|
||||
if(this.Polling) {
|
||||
this.http.GetVoid("ZWave.zway/Run/devices[" + this.DeviceId + "].instances[" + this.Instance + "].commandClasses[" + this.Commandclass + "].Get("+this.SensorId+")");
|
||||
}
|
||||
}
|
||||
internal override void Poll() => this.PollSub();
|
||||
|
||||
internal override void SetUpdate(JsonData json, Match match) {
|
||||
if (json.Keys.Contains("val") && json["val"].Keys.Contains("value") && json["val"]["value"] != null &&
|
||||
@@ -54,12 +51,19 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses.CommandClassSubs {
|
||||
this.CheckSetUpdateTime(json)) {
|
||||
this._level = Int64.Parse(json["val"]["value"].ToString());
|
||||
this.Size = Int32.Parse(json["size"]["value"].ToString());
|
||||
this.Update?.Invoke(this, new DeviceUpdateEvent(new Tuple<Int64, Int32>(this.Level, this.Size), this.LastUpdate));
|
||||
this.Update?.Invoke(this, new DeviceUpdateEvent(new Tuple<Int64, Int32>(this.Level, this.Size), this.LastUpdate, this));
|
||||
}
|
||||
}
|
||||
|
||||
public override String ToString() {
|
||||
return "Configuration " + this.Name + " [" + this.Id + "]: " + this.Level;
|
||||
}
|
||||
|
||||
public override Dictionary<String, Object> ToDictionary() {
|
||||
return new Dictionary<String, Object> {
|
||||
{ "Level", this.Level },
|
||||
{ "Size", this.Size },
|
||||
};
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -1,4 +1,5 @@
|
||||
using System;
|
||||
using System.Collections.Generic;
|
||||
using System.Text.RegularExpressions;
|
||||
using BlubbFish.IoT.Zway.Events;
|
||||
using BlubbFish.IoT.Zway.Interfaces;
|
||||
@@ -6,18 +7,16 @@ using BlubbFish.IoT.Zway.lib;
|
||||
using LitJson;
|
||||
|
||||
namespace BlubbFish.IoT.Zway.Devices.CommandClasses.CommandClassSubs {
|
||||
public class Metersub : CommandClassSub {
|
||||
|
||||
public class Metersub : ACommandClass {
|
||||
public override event UpdatedValue Update;
|
||||
public String Type { get; private set; }
|
||||
public Single Level { get; private set; }
|
||||
public String Scale { get; private set; }
|
||||
public Metersub(JsonData json, Tuple<Int32, Int32, Int32, Int32> id, HttpConnection http, Boolean polling) : base(json, id, http, polling) {
|
||||
InitComplex(json);
|
||||
}
|
||||
|
||||
public void Reset() {
|
||||
this.http.GetVoid("ZWave.zway/Run/devices[" + this.DeviceId + "].instances[" + this.Instance + "].commandClasses[" + this.Commandclass + "].Reset()");
|
||||
public String Type { get; private set; }
|
||||
public Double Level { get; private set; }
|
||||
public String Scale { get; private set; }
|
||||
public Metersub(JsonData json, Tuple<Int32, Int32, Classes, Int32> id, HttpConnection http, Boolean polling) : base(json, id, http, polling) {
|
||||
this.HasReset = true;
|
||||
this.IsSub = true;
|
||||
InitComplex(json);
|
||||
}
|
||||
|
||||
private void InitComplex(JsonData json) {
|
||||
@@ -28,7 +27,7 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses.CommandClassSubs {
|
||||
json.Keys.Contains("scaleString") &&
|
||||
json["scaleString"].Keys.Contains("value")) {
|
||||
this.Type = json["sensorTypeString"]["value"].ToString();
|
||||
this.Level = Single.Parse(json["val"]["value"].ToString());
|
||||
this.Level = Double.Parse(json["val"]["value"].ToString());
|
||||
this.Scale = json["scaleString"]["value"].ToString();
|
||||
}
|
||||
}
|
||||
@@ -38,10 +37,10 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses.CommandClassSubs {
|
||||
json.Keys.Contains("sensorTypeString") && json["sensorTypeString"].Keys.Contains("value") &&
|
||||
json.Keys.Contains("scaleString") && json["scaleString"].Keys.Contains("value") &&
|
||||
this.CheckSetUpdateTime(json)) {
|
||||
this.Level = Single.Parse(json["val"]["value"].ToString());
|
||||
this.Level = Double.Parse(json["val"]["value"].ToString());
|
||||
this.Type = json["sensorTypeString"]["value"].ToString();
|
||||
this.Scale = json["scaleString"]["value"].ToString();
|
||||
this.Update?.Invoke(this, new DeviceUpdateEvent(new Tuple<String, String, Single>(this.Type, this.Scale, this.Level), this.LastUpdate));
|
||||
this.Update?.Invoke(this, new DeviceUpdateEvent(new Tuple<String, String, Double>(this.Type, this.Scale, this.Level), this.LastUpdate, this));
|
||||
}
|
||||
}
|
||||
|
||||
@@ -49,6 +48,14 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses.CommandClassSubs {
|
||||
return "Meter " + this.Name + " [" + this.Id + "]: " + this.Type + " " + this.Level + "" + this.Scale;
|
||||
}
|
||||
|
||||
internal override void Poll() { }
|
||||
internal override void Poll() => this.PollNone();
|
||||
|
||||
public override Dictionary<String, Object> ToDictionary() {
|
||||
return new Dictionary<String, Object> {
|
||||
{ "Level", this.Level },
|
||||
{ "Type", this.Type },
|
||||
{ "Scale", this.Scale },
|
||||
};
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -1,4 +1,5 @@
|
||||
using System;
|
||||
using System.Collections.Generic;
|
||||
using System.Text.RegularExpressions;
|
||||
using BlubbFish.IoT.Zway.Events;
|
||||
using BlubbFish.IoT.Zway.Interfaces;
|
||||
@@ -6,13 +7,15 @@ using BlubbFish.IoT.Zway.lib;
|
||||
using LitJson;
|
||||
|
||||
namespace BlubbFish.IoT.Zway.Devices.CommandClasses.CommandClassSubs {
|
||||
public class Sensormultilevelsub : CommandClassSub {
|
||||
public class Sensormultilevelsub : ACommandClass {
|
||||
public override event UpdatedValue Update;
|
||||
|
||||
public String Type { get; private set; }
|
||||
public Single Level { get; private set; }
|
||||
public Double Level { get; private set; }
|
||||
public String Scale { get; private set; }
|
||||
|
||||
public Sensormultilevelsub(JsonData json, Tuple<Int32, Int32, Int32, Int32> id, HttpConnection http, Boolean polling) : base(json, id, http, polling) {
|
||||
public Sensormultilevelsub(JsonData json, Tuple<Int32, Int32, Classes, Int32> id, HttpConnection http, Boolean polling) : base(json, id, http, polling) {
|
||||
this.IsSub = true;
|
||||
InitComplex(json);
|
||||
}
|
||||
|
||||
@@ -24,7 +27,7 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses.CommandClassSubs {
|
||||
json.Keys.Contains("scaleString") &&
|
||||
json["scaleString"].Keys.Contains("value")) {
|
||||
this.Type = json["sensorTypeString"]["value"].ToString();
|
||||
this.Level = Single.Parse(json["val"]["value"].ToString());
|
||||
this.Level = Double.Parse(json["val"]["value"].ToString());
|
||||
this.Scale = json["scaleString"]["value"].ToString();
|
||||
}
|
||||
}
|
||||
@@ -34,10 +37,10 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses.CommandClassSubs {
|
||||
json.Keys.Contains("sensorTypeString") && json["sensorTypeString"].Keys.Contains("value") &&
|
||||
json.Keys.Contains("scaleString") && json["scaleString"].Keys.Contains("value") &&
|
||||
this.CheckSetUpdateTime(json)) {
|
||||
this.Level = Single.Parse(json["val"]["value"].ToString());
|
||||
this.Level = Double.Parse(json["val"]["value"].ToString());
|
||||
this.Type = json["sensorTypeString"]["value"].ToString();
|
||||
this.Scale = json["scaleString"]["value"].ToString();
|
||||
this.Update?.Invoke(this, new DeviceUpdateEvent(new Tuple<String, String, Single>(this.Type, this.Scale, this.Level), this.LastUpdate));
|
||||
this.Update?.Invoke(this, new DeviceUpdateEvent(new Tuple<String, String, Double>(this.Type, this.Scale, this.Level), this.LastUpdate, this));
|
||||
}
|
||||
}
|
||||
|
||||
@@ -45,6 +48,14 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses.CommandClassSubs {
|
||||
return "SensorMultilevel " + this.Name + " [" + this.Id + "]: " + this.Type + " " + this.Level + "" + this.Scale;
|
||||
}
|
||||
|
||||
internal override void Poll() { }
|
||||
internal override void Poll() => this.PollNone();
|
||||
|
||||
public override Dictionary<String, Object> ToDictionary() {
|
||||
return new Dictionary<String, Object> {
|
||||
{ "Level", this.Level },
|
||||
{ "Type", this.Type },
|
||||
{ "Scale", this.Scale },
|
||||
};
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -1,4 +1,5 @@
|
||||
using System;
|
||||
using System.Collections.Generic;
|
||||
using System.Text.RegularExpressions;
|
||||
using BlubbFish.IoT.Zway.Events;
|
||||
using BlubbFish.IoT.Zway.Interfaces;
|
||||
@@ -6,29 +7,28 @@ using BlubbFish.IoT.Zway.lib;
|
||||
using LitJson;
|
||||
|
||||
namespace BlubbFish.IoT.Zway.Devices.CommandClasses.CommandClassSubs {
|
||||
class Thermostatsetpointsub : CommandClassSub {
|
||||
private Single _level;
|
||||
|
||||
class Thermostatsetpointsub : ACommandClass {
|
||||
public override event UpdatedValue Update;
|
||||
|
||||
public Single Level {
|
||||
private Double _level;
|
||||
public Double Level {
|
||||
get {
|
||||
return this._level;
|
||||
}
|
||||
set {
|
||||
if (!this.HasMinMax || (this.HasMinMax && value >= this.TempMin && value <= this.TempMax)) {
|
||||
Single t = (Single)Math.Round(value * 2, MidpointRounding.AwayFromZero) / 2;
|
||||
this.http.GetVoid("ZWave.zway/Run/devices[" + this.DeviceId + "].instances[" + this.Instance + "].commandClasses[" + this.Commandclass + "].Set(" + this.SensorId + "," + t + ")");
|
||||
this.SetTuple(this.SensorId, (Double)Math.Round(value * 2, MidpointRounding.AwayFromZero) / 2);
|
||||
}
|
||||
}
|
||||
}
|
||||
public String Scale { get; private set; }
|
||||
public Single TempMax { get; private set; }
|
||||
public Single TempMin { get; private set; }
|
||||
public Double TempMax { get; private set; }
|
||||
public Double TempMin { get; private set; }
|
||||
public Boolean HasMinMax { get; private set; }
|
||||
public String Type { get; private set; }
|
||||
|
||||
public Thermostatsetpointsub(JsonData json, Tuple<Int32, Int32, Int32, Int32> id, HttpConnection http, Boolean polling) : base(json, id, http, polling) {
|
||||
public Thermostatsetpointsub(JsonData json, Tuple<Int32, Int32, Classes, Int32> id, HttpConnection http, Boolean polling) : base(json, id, http, polling) {
|
||||
this.IsSub = true;
|
||||
InitComplex(json);
|
||||
}
|
||||
|
||||
@@ -37,13 +37,13 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses.CommandClassSubs {
|
||||
json.Keys.Contains("val") && json["val"].Keys.Contains("value") &&
|
||||
json.Keys.Contains("deviceScaleString") && json["deviceScaleString"].Keys.Contains("value")) {
|
||||
this.Type = json["modeName"]["value"].ToString();
|
||||
this._level = Single.Parse(json["val"]["value"].ToString());
|
||||
this._level = Double.Parse(json["val"]["value"].ToString());
|
||||
this.Scale = json["deviceScaleString"]["value"].ToString();
|
||||
}
|
||||
if (json.Keys.Contains("min") && json["min"].Keys.Contains("value") &&
|
||||
json.Keys.Contains("max") && json["max"].Keys.Contains("value")) {
|
||||
this.TempMin = Single.Parse(json["min"]["value"].ToString());
|
||||
this.TempMax = Single.Parse(json["max"]["value"].ToString());
|
||||
this.TempMin = Double.Parse(json["min"]["value"].ToString());
|
||||
this.TempMax = Double.Parse(json["max"]["value"].ToString());
|
||||
this.HasMinMax = true;
|
||||
} else {
|
||||
this.HasMinMax = false;
|
||||
@@ -55,22 +55,22 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses.CommandClassSubs {
|
||||
if (json.Keys.Contains("val") && json["val"].Keys.Contains("value") &&
|
||||
json.Keys.Contains("deviceScaleString") && json["deviceScaleString"].Keys.Contains("value") &&
|
||||
json.Keys.Contains("modeName") && json["modeName"].Keys.Contains("value")) {
|
||||
this._level = Single.Parse(json["val"]["value"].ToString());
|
||||
this._level = Double.Parse(json["val"]["value"].ToString());
|
||||
this.Scale = json["deviceScaleString"]["value"].ToString();
|
||||
this.Type = json["modeName"]["value"].ToString();
|
||||
ret = true;
|
||||
}
|
||||
if (json.Keys.Contains("min") && json["val"].Keys.Contains("value") &&
|
||||
json.Keys.Contains("max") && json["max"].Keys.Contains("value")) {
|
||||
this.TempMin = Single.Parse(json["min"]["value"].ToString());
|
||||
this.TempMax = Single.Parse(json["max"]["value"].ToString());
|
||||
this.TempMin = Double.Parse(json["min"]["value"].ToString());
|
||||
this.TempMax = Double.Parse(json["max"]["value"].ToString());
|
||||
this.HasMinMax = true;
|
||||
ret = true;
|
||||
} else {
|
||||
this.HasMinMax = false;
|
||||
}
|
||||
if (ret && this.CheckSetUpdateTime(json)) {
|
||||
this.Update?.Invoke(this, new DeviceUpdateEvent(new Tuple<String, String, Single, Single, Single, Boolean>(this.Type, this.Scale, this.Level, this.TempMin, this.TempMax, this.HasMinMax), this.LastUpdate));
|
||||
this.Update?.Invoke(this, new DeviceUpdateEvent(new Tuple<String, String, Double, Double, Double, Boolean>(this.Type, this.Scale, this.Level, this.TempMin, this.TempMax, this.HasMinMax), this.LastUpdate, this));
|
||||
}
|
||||
}
|
||||
|
||||
@@ -78,10 +78,17 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses.CommandClassSubs {
|
||||
return "ThermostatSetPoint " + this.Name + " [" + this.Id + "]: " + this.Type + " " + this.Level + "" + this.Scale + " [" + this.TempMin + "," + this.TempMax + "," + this.HasMinMax + "]";
|
||||
}
|
||||
|
||||
internal override void Poll() {
|
||||
if (this.Polling) {
|
||||
this.http.GetVoid("ZWave.zway/Run/devices[" + this.DeviceId + "].instances[" + this.Instance + "].commandClasses[" + this.Commandclass + "].Get(" + this.SensorId + ")");
|
||||
}
|
||||
internal override void Poll() => this.PollSub();
|
||||
|
||||
public override Dictionary<String, Object> ToDictionary() {
|
||||
return new Dictionary<String, Object> {
|
||||
{ "Level", this.Level },
|
||||
{ "Type", this.Type },
|
||||
{ "Scale", this.Scale },
|
||||
{ "TempMax", this.TempMax },
|
||||
{ "TempMin", this.TempMin },
|
||||
{ "HasMinMax", this.HasMinMax },
|
||||
};
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -12,35 +12,35 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses {
|
||||
/// <summary>
|
||||
/// 112 = Configuration
|
||||
/// </summary>
|
||||
class Configuration : CommandClass {
|
||||
class Configuration : ACommandClass {
|
||||
public override event UpdatedValue Update;
|
||||
|
||||
public ReadOnlyDictionary<Int32, CommandClassSub> Sub { get; private set; }
|
||||
public Configuration(JsonData json, HttpConnection http, Tuple<Int32, Int32, Int32> id, Boolean polling) : base(json, http, id, polling) {
|
||||
public Configuration(JsonData json, Tuple<Int32, Int32, Classes> id, HttpConnection http, Boolean polling) : base(json, id, http, polling) {
|
||||
this.HasSub = true;
|
||||
this.InitComplex(json);
|
||||
foreach (KeyValuePair<Int32, CommandClassSub> item in this.Sub) {
|
||||
foreach (KeyValuePair<Int32, ACommandClass> item in this.Sub) {
|
||||
item.Value.Update += this.DeviceUpdate;
|
||||
}
|
||||
}
|
||||
|
||||
private void DeviceUpdate(Object sender, DeviceUpdateEvent e) {
|
||||
this.Update?.Invoke(sender, e);
|
||||
this.Update?.Invoke(this, e);
|
||||
}
|
||||
|
||||
private void InitComplex(JsonData json) {
|
||||
if (json.Keys.Contains("data")) {
|
||||
JsonData data = json["data"];
|
||||
Dictionary<Int32, CommandClassSub> subs = new Dictionary<Int32, CommandClassSub>();
|
||||
Dictionary<Int32, ACommandClass> subs = new Dictionary<Int32, ACommandClass>();
|
||||
foreach (String item in data.Keys) {
|
||||
if (Int32.TryParse(item, out Int32 subid) &&
|
||||
data[item].Keys.Contains("size") &&
|
||||
data[item].Keys.Contains("val") &&
|
||||
data[item]["val"].Keys.Contains("value") &&
|
||||
data[item]["val"]["value"] != null) {
|
||||
subs.Add(subid, new Configurationsub(data[item], new Tuple<Int32, Int32, Int32, Int32>(this.DeviceId, this.Instance, this.Commandclass, subid), this.http, this.Polling));
|
||||
subs.Add(subid, new Configurationsub(data[item], new Tuple<Int32, Int32, Classes, Int32>(this.DeviceId, this.Instance, this.Commandclass, subid), this.http, this.Polling));
|
||||
}
|
||||
}
|
||||
this.Sub = new ReadOnlyDictionary<Int32, CommandClassSub>(subs);
|
||||
this.Sub = new ReadOnlyDictionary<Int32, ACommandClass>(subs);
|
||||
}
|
||||
}
|
||||
|
||||
@@ -55,10 +55,8 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses {
|
||||
}
|
||||
}
|
||||
|
||||
internal override void Poll() {
|
||||
foreach (KeyValuePair<Int32, CommandClassSub> item in this.Sub) {
|
||||
item.Value.Poll();
|
||||
}
|
||||
}
|
||||
internal override void Poll() => this.PollPerSub();
|
||||
|
||||
public override Dictionary<String, Object> ToDictionary() => this.ToDictionarySub();
|
||||
}
|
||||
}
|
||||
|
||||
@@ -1,4 +1,5 @@
|
||||
using System;
|
||||
using System.Collections.Generic;
|
||||
using System.Text.RegularExpressions;
|
||||
using BlubbFish.IoT.Zway.Events;
|
||||
using BlubbFish.IoT.Zway.Interfaces;
|
||||
@@ -9,7 +10,7 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses {
|
||||
/// <summary>
|
||||
/// 135 = Indicator
|
||||
/// </summary>
|
||||
class Indicator : CommandClass {
|
||||
class Indicator : ACommandClass {
|
||||
private Boolean _level;
|
||||
|
||||
public override event UpdatedValue Update;
|
||||
@@ -22,7 +23,7 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses {
|
||||
}
|
||||
}
|
||||
|
||||
public Indicator(JsonData json, HttpConnection http, Tuple<Int32, Int32, Int32> id, Boolean polling) : base(json, http, id, polling) {
|
||||
public Indicator(JsonData json, Tuple<Int32, Int32, Classes> id, HttpConnection http, Boolean polling) : base(json, id, http, polling) {
|
||||
this.InitComplex(json);
|
||||
}
|
||||
|
||||
@@ -36,7 +37,7 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses {
|
||||
if(match.Groups[4].Value == ".data.stat") {
|
||||
if (json.Keys.Contains("value") && this.CheckSetUpdateTime(json)) {
|
||||
this._level = Int32.Parse(json["value"].ToString()) == 255;
|
||||
this.Update?.Invoke(this, new DeviceUpdateEvent(this.Level, this.LastUpdate));
|
||||
this.Update?.Invoke(this, new DeviceUpdateEvent(this.Level, this.LastUpdate, this));
|
||||
}
|
||||
} else {
|
||||
Helper.WriteError("Kenne in " + this.Name + " [" + this.Id + "] " + match.Groups[4].Value + " nicht!");
|
||||
@@ -46,5 +47,11 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses {
|
||||
public override String ToString() {
|
||||
return "Indicator " + this.Name + " [" + this.Id + "]: " + this.Level;
|
||||
}
|
||||
|
||||
public override Dictionary<String, Object> ToDictionary() {
|
||||
return new Dictionary<String, Object> {
|
||||
{ "Level", this.Level },
|
||||
};
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@@ -12,21 +12,19 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses {
|
||||
/// <summary>
|
||||
/// 50 = Meter
|
||||
/// </summary>
|
||||
public class Meter : CommandClass {
|
||||
public class Meter : ACommandClass {
|
||||
public override event UpdatedValue Update;
|
||||
|
||||
public ReadOnlyDictionary<Int32, CommandClassSub> Sub { get; private set; }
|
||||
|
||||
|
||||
public Meter(JsonData json, HttpConnection http, Tuple<Int32, Int32, Int32> id, Boolean polling) : base(json, http, id, polling) {
|
||||
public Meter(JsonData json, Tuple<Int32, Int32, Classes> id, HttpConnection http, Boolean polling) : base(json, id, http, polling) {
|
||||
this.HasSub = true;
|
||||
this.InitComplex(json);
|
||||
foreach (KeyValuePair<Int32, CommandClassSub> item in this.Sub) {
|
||||
foreach (KeyValuePair<Int32, ACommandClass> item in this.Sub) {
|
||||
item.Value.Update += this.DeviceUpdate;
|
||||
}
|
||||
}
|
||||
|
||||
private void DeviceUpdate(Object sender, DeviceUpdateEvent e) {
|
||||
this.Update?.Invoke(sender, e);
|
||||
this.Update?.Invoke(this, e);
|
||||
}
|
||||
|
||||
internal override void SetUpdate(JsonData json, Match match) {
|
||||
@@ -43,29 +41,21 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses {
|
||||
private void InitComplex(JsonData json) {
|
||||
if (json.Keys.Contains("data")) {
|
||||
JsonData data = json["data"];
|
||||
Dictionary<Int32, CommandClassSub> subs = new Dictionary<Int32, CommandClassSub>();
|
||||
Dictionary<Int32, ACommandClass> subs = new Dictionary<Int32, ACommandClass>();
|
||||
foreach (String item in data.Keys) {
|
||||
if (Int32.TryParse(item, out Int32 subid) &&
|
||||
data[item].Keys.Contains("sensorTypeString") &&
|
||||
data[item].Keys.Contains("val") &&
|
||||
data[item].Keys.Contains("scaleString")) {
|
||||
subs.Add(subid, new Metersub(data[item], new Tuple<Int32, Int32, Int32, Int32>(this.DeviceId, this.Instance, this.Commandclass, subid), this.http, this.Polling));
|
||||
subs.Add(subid, new Metersub(data[item], new Tuple<Int32, Int32, Classes, Int32>(this.DeviceId, this.Instance, this.Commandclass, subid), this.http, this.Polling));
|
||||
}
|
||||
}
|
||||
this.Sub = new ReadOnlyDictionary<Int32, CommandClassSub>(subs);
|
||||
this.Sub = new ReadOnlyDictionary<Int32, ACommandClass>(subs);
|
||||
}
|
||||
}
|
||||
|
||||
internal override void Poll() {
|
||||
Boolean poll = false;
|
||||
foreach (KeyValuePair<Int32, CommandClassSub> item in this.Sub) {
|
||||
if (item.Value.Polling) {
|
||||
poll = true;
|
||||
}
|
||||
}
|
||||
if (poll) {
|
||||
this.http.GetVoid("ZWave.zway/Run/devices[" + this.DeviceId + "].instances[" + this.Instance + "].commandClasses[" + this.Commandclass + "].Get()");
|
||||
}
|
||||
}
|
||||
internal override void Poll() => this.PollSubGlobal();
|
||||
|
||||
public override Dictionary<String, Object> ToDictionary() => this.ToDictionarySub();
|
||||
}
|
||||
}
|
||||
|
||||
@@ -12,21 +12,19 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses {
|
||||
/// <summary>
|
||||
/// 49 = SensorMultilevel
|
||||
/// </summary>
|
||||
public class Sensormultilevel : CommandClass {
|
||||
public class Sensormultilevel : ACommandClass {
|
||||
public override event UpdatedValue Update;
|
||||
|
||||
public ReadOnlyDictionary<Int32, CommandClassSub> Sub { get; private set; }
|
||||
|
||||
|
||||
public Sensormultilevel(JsonData json, HttpConnection http, Tuple<Int32, Int32, Int32> id, Boolean polling) : base(json, http, id, polling) {
|
||||
public Sensormultilevel(JsonData json, Tuple<Int32, Int32, Classes> id, HttpConnection http, Boolean polling) : base(json, id, http, polling) {
|
||||
this.HasSub = true;
|
||||
this.InitComplex(json);
|
||||
foreach (KeyValuePair<Int32, CommandClassSub> item in this.Sub) {
|
||||
foreach (KeyValuePair<Int32, ACommandClass> item in this.Sub) {
|
||||
item.Value.Update += this.DeviceUpdate;
|
||||
}
|
||||
}
|
||||
|
||||
private void DeviceUpdate(Object sender, DeviceUpdateEvent e) {
|
||||
this.Update?.Invoke(sender, e);
|
||||
this.Update?.Invoke(this, e);
|
||||
}
|
||||
|
||||
internal override void SetUpdate(JsonData json, Match match) {
|
||||
@@ -43,29 +41,21 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses {
|
||||
private void InitComplex(JsonData json) {
|
||||
if (json.Keys.Contains("data")) {
|
||||
JsonData data = json["data"];
|
||||
Dictionary<Int32, CommandClassSub> subs = new Dictionary<Int32, CommandClassSub>();
|
||||
Dictionary<Int32, ACommandClass> subs = new Dictionary<Int32, ACommandClass>();
|
||||
foreach (String item in data.Keys) {
|
||||
if (Int32.TryParse(item, out Int32 subid) &&
|
||||
data[item].Keys.Contains("sensorTypeString") &&
|
||||
data[item].Keys.Contains("val") &&
|
||||
data[item].Keys.Contains("scaleString")) {
|
||||
subs.Add(subid, new Sensormultilevelsub(data[item], new Tuple<Int32, Int32, Int32, Int32>(this.DeviceId, this.Instance, this.Commandclass, subid), this.http, this.Polling));
|
||||
subs.Add(subid, new Sensormultilevelsub(data[item], new Tuple<Int32, Int32, Classes, Int32>(this.DeviceId, this.Instance, this.Commandclass, subid), this.http, this.Polling));
|
||||
}
|
||||
}
|
||||
this.Sub = new ReadOnlyDictionary<Int32, CommandClassSub>(subs);
|
||||
this.Sub = new ReadOnlyDictionary<Int32, ACommandClass>(subs);
|
||||
}
|
||||
}
|
||||
|
||||
internal override void Poll() {
|
||||
Boolean poll = false;
|
||||
foreach (KeyValuePair<Int32, CommandClassSub> item in this.Sub) {
|
||||
if (item.Value.Polling) {
|
||||
poll = true;
|
||||
}
|
||||
}
|
||||
if (poll) {
|
||||
this.http.GetVoid("ZWave.zway/Run/devices[" + this.DeviceId + "].instances[" + this.Instance + "].commandClasses[" + this.Commandclass + "].Get()");
|
||||
}
|
||||
}
|
||||
internal override void Poll() => this.PollSubGlobal();
|
||||
|
||||
public override Dictionary<String, Object> ToDictionary() => this.ToDictionarySub();
|
||||
}
|
||||
}
|
||||
|
||||
@@ -1,4 +1,5 @@
|
||||
using System;
|
||||
using System.Collections.Generic;
|
||||
using System.Text.RegularExpressions;
|
||||
using BlubbFish.IoT.Zway.Events;
|
||||
using BlubbFish.IoT.Zway.Interfaces;
|
||||
@@ -9,7 +10,7 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses {
|
||||
/// <summary>
|
||||
/// 37 = SwitchBinary
|
||||
/// </summary>
|
||||
public class Switchbinary : CommandClass {
|
||||
public class Switchbinary : ACommandClass {
|
||||
private Boolean _level;
|
||||
|
||||
public override event UpdatedValue Update;
|
||||
@@ -23,7 +24,7 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses {
|
||||
}
|
||||
}
|
||||
|
||||
public Switchbinary(JsonData json, HttpConnection http, Tuple<Int32, Int32, Int32> id, Boolean polling) : base(json, http, id, polling) {
|
||||
public Switchbinary(JsonData json, Tuple<Int32, Int32, Classes> id, HttpConnection http, Boolean polling) : base(json, id, http, polling) {
|
||||
this.InitComplex(json);
|
||||
}
|
||||
|
||||
@@ -31,7 +32,7 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses {
|
||||
if(match.Groups[4].Value == ".data.level") {
|
||||
if (json.Keys.Contains("value") && json["value"].IsBoolean && this.CheckSetUpdateTime(json)) {
|
||||
this._level = (Boolean)json["value"];
|
||||
this.Update?.Invoke(this, new DeviceUpdateEvent(this.Level, this.LastUpdate));
|
||||
this.Update?.Invoke(this, new DeviceUpdateEvent(this.Level, this.LastUpdate, this));
|
||||
}
|
||||
} else {
|
||||
Helper.WriteError("Kenne in " + this.Name + " [" + this.Id + "] " + match.Groups[4].Value + " nicht!");
|
||||
@@ -47,5 +48,11 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses {
|
||||
public override String ToString() {
|
||||
return "SwitchBinary " + this.Name + " [" + this.Id + "]: " + this.Level;
|
||||
}
|
||||
|
||||
public override Dictionary<String, Object> ToDictionary() {
|
||||
return new Dictionary<String, Object> {
|
||||
{ "Level", this.Level }
|
||||
};
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@@ -1,4 +1,5 @@
|
||||
using System;
|
||||
using System.Collections.Generic;
|
||||
using System.Text.RegularExpressions;
|
||||
using BlubbFish.IoT.Zway.Events;
|
||||
using BlubbFish.IoT.Zway.Interfaces;
|
||||
@@ -9,7 +10,7 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses {
|
||||
/// <summary>
|
||||
/// 38 = SwitchMultilevel
|
||||
/// </summary>
|
||||
public class Switchmultilevel : CommandClass {
|
||||
public class Switchmultilevel : ACommandClass {
|
||||
private Int32 _level;
|
||||
|
||||
public override event UpdatedValue Update;
|
||||
@@ -20,12 +21,12 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses {
|
||||
}
|
||||
set {
|
||||
if(value == 0 || (value > 0 && value <= 99) || value == 255) {
|
||||
this.SetIntTuple(value, 0);
|
||||
this.SetTuple(value, 0);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
public Switchmultilevel(JsonData json, HttpConnection http, Tuple<Int32, Int32, Int32> id, Boolean polling) : base(json, http, id, polling) {
|
||||
public Switchmultilevel(JsonData json, Tuple<Int32, Int32, Classes> id, HttpConnection http, Boolean polling) : base(json, id, http, polling) {
|
||||
this.InitComplex(json);
|
||||
}
|
||||
|
||||
@@ -33,7 +34,7 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses {
|
||||
if(match.Groups[4].Value == ".data.level") {
|
||||
if(json.Keys.Contains("value") && this.CheckSetUpdateTime(json)) {
|
||||
this._level = Int32.Parse(json["value"].ToString());
|
||||
this.Update?.Invoke(this, new DeviceUpdateEvent(this.Level, this.LastUpdate));
|
||||
this.Update?.Invoke(this, new DeviceUpdateEvent(this.Level, this.LastUpdate, this));
|
||||
}
|
||||
} else if (match.Groups[4].Value == ".data.prevLevel") {
|
||||
} else {
|
||||
@@ -50,5 +51,11 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses {
|
||||
public override String ToString() {
|
||||
return "SwitchMultilevel " + this.Name + " [" + this.Id + "]: " + this.Level;
|
||||
}
|
||||
|
||||
public override Dictionary<String, Object> ToDictionary() {
|
||||
return new Dictionary<String, Object> {
|
||||
{ "Level", this.Level }
|
||||
};
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@@ -11,7 +11,7 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses {
|
||||
/// <summary>
|
||||
/// 64 = ThermostatMode
|
||||
/// </summary>
|
||||
public class Thermostatmode : CommandClass {
|
||||
public class Thermostatmode : ACommandClass {
|
||||
private Int32 _level;
|
||||
|
||||
public override event UpdatedValue Update;
|
||||
@@ -26,7 +26,7 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses {
|
||||
}
|
||||
}
|
||||
|
||||
public Thermostatmode(JsonData json, HttpConnection http, Tuple<Int32, Int32, Int32> id, Boolean polling) : base(json, http, id, polling) {
|
||||
public Thermostatmode(JsonData json, Tuple<Int32, Int32, Classes> id, HttpConnection http, Boolean polling) : base(json, id, http, polling) {
|
||||
this.ValidModes = new ReadOnlyDictionary<Int32, String>(new Dictionary<Int32, String>());
|
||||
this.InitComplex(json);
|
||||
}
|
||||
@@ -35,7 +35,7 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses {
|
||||
if(match.Groups[4].Value == ".data.mode") {
|
||||
if(json.Keys.Contains("value") && this.CheckSetUpdateTime(json)) {
|
||||
this._level = Int32.Parse(json["value"].ToString());
|
||||
this.Update?.Invoke(this, new DeviceUpdateEvent(this.Level, this.LastUpdate));
|
||||
this.Update?.Invoke(this, new DeviceUpdateEvent(this.Level, this.LastUpdate, this));
|
||||
}
|
||||
} else {
|
||||
Helper.WriteError("Kenne in " + this.Name + " [" + this.Id + "] " + match.Groups[4].Value + " nicht!");
|
||||
@@ -64,5 +64,17 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses {
|
||||
public override String ToString() {
|
||||
return "ThermostatMode " + this.Name + " [" + this.Id + "]: " + this.ValidModes[this.Level];
|
||||
}
|
||||
|
||||
public override Dictionary<String, Object> ToDictionary() {
|
||||
Dictionary<String, String> modes = new Dictionary<String, String>();
|
||||
foreach (KeyValuePair<Int32, String> item in this.ValidModes) {
|
||||
modes.Add(item.Key.ToString(), item.Value);
|
||||
}
|
||||
Dictionary<String, Object> json = new Dictionary<String, Object> {
|
||||
{ "Level", this.Level },
|
||||
{ "ValidModes", modes }
|
||||
};
|
||||
return json;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@@ -12,20 +12,19 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses {
|
||||
/// <summary>
|
||||
/// 67 = ThermostatSetPoint
|
||||
/// </summary>
|
||||
public class Thermostatsetpoint : CommandClass {
|
||||
public class Thermostatsetpoint : ACommandClass {
|
||||
public override event UpdatedValue Update;
|
||||
|
||||
public ReadOnlyDictionary<Int32, CommandClassSub> Sub { get; private set; }
|
||||
|
||||
public Thermostatsetpoint(JsonData json, HttpConnection http, Tuple<Int32, Int32, Int32> id, Boolean polling) : base(json, http, id, polling) {
|
||||
public Thermostatsetpoint(JsonData json, Tuple<Int32, Int32, Classes> id, HttpConnection http, Boolean polling) : base(json, id, http, polling) {
|
||||
this.HasSub = true;
|
||||
this.InitComplex(json);
|
||||
foreach (KeyValuePair<Int32, CommandClassSub> item in this.Sub) {
|
||||
foreach (KeyValuePair<Int32, ACommandClass> item in this.Sub) {
|
||||
item.Value.Update += this.DeviceUpdate;
|
||||
}
|
||||
}
|
||||
|
||||
private void DeviceUpdate(Object sender, DeviceUpdateEvent e) {
|
||||
this.Update?.Invoke(sender, e);
|
||||
this.Update?.Invoke(this, e);
|
||||
}
|
||||
|
||||
internal override void SetUpdate(JsonData json, Match match) {
|
||||
@@ -42,23 +41,21 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses {
|
||||
private void InitComplex(JsonData json) {
|
||||
if (json.Keys.Contains("data")) {
|
||||
JsonData data = json["data"];
|
||||
Dictionary<Int32, CommandClassSub> subs = new Dictionary<Int32, CommandClassSub>();
|
||||
Dictionary<Int32, ACommandClass> subs = new Dictionary<Int32, ACommandClass>();
|
||||
foreach (String item in data.Keys) {
|
||||
if (Int32.TryParse(item, out Int32 subid) &&
|
||||
data[item].Keys.Contains("modeName") &&
|
||||
data[item].Keys.Contains("val") &&
|
||||
data[item].Keys.Contains("deviceScaleString")) {
|
||||
subs.Add(subid, new Thermostatsetpointsub(data[item], new Tuple<Int32, Int32, Int32, Int32>(this.DeviceId, this.Instance, this.Commandclass, subid), this.http, this.Polling));
|
||||
subs.Add(subid, new Thermostatsetpointsub(data[item], new Tuple<Int32, Int32, Classes, Int32>(this.DeviceId, this.Instance, this.Commandclass, subid), this.http, this.Polling));
|
||||
}
|
||||
}
|
||||
this.Sub = new ReadOnlyDictionary<Int32, CommandClassSub>(subs);
|
||||
this.Sub = new ReadOnlyDictionary<Int32, ACommandClass>(subs);
|
||||
}
|
||||
}
|
||||
|
||||
internal override void Poll() {
|
||||
foreach (KeyValuePair<Int32, CommandClassSub> item in this.Sub) {
|
||||
item.Value.Poll();
|
||||
}
|
||||
}
|
||||
internal override void Poll() => this.PollPerSub();
|
||||
|
||||
public override Dictionary<String, Object> ToDictionary() => this.ToDictionarySub();
|
||||
}
|
||||
}
|
||||
|
||||
@@ -1,4 +1,5 @@
|
||||
using System;
|
||||
using System.Collections.Generic;
|
||||
using System.Text.RegularExpressions;
|
||||
using BlubbFish.IoT.Zway.Events;
|
||||
using BlubbFish.IoT.Zway.Interfaces;
|
||||
@@ -9,7 +10,7 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses {
|
||||
/// <summary>
|
||||
/// 132 = Wakeup
|
||||
/// </summary>
|
||||
class Wakeup : CommandClass {
|
||||
class Wakeup : ACommandClass {
|
||||
private Int32 _interval;
|
||||
private Int32 _againstNode;
|
||||
|
||||
@@ -20,7 +21,7 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses {
|
||||
}
|
||||
set {
|
||||
if(value >= this.WakeupMin && value <= this.WakeupMax) {
|
||||
this.SetIntTuple(value, this.AgainstNode);
|
||||
this.SetTuple(value, this.AgainstNode);
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -28,7 +29,7 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses {
|
||||
return this._againstNode;
|
||||
}
|
||||
set {
|
||||
this.SetIntTuple(this.Interval, value);
|
||||
this.SetTuple(this.Interval, value);
|
||||
}
|
||||
}
|
||||
public Int32 WakeupMin { get; private set; }
|
||||
@@ -37,7 +38,7 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses {
|
||||
public DateTime LastWakeup { get; private set; }
|
||||
public DateTime LastSleep { get; private set; }
|
||||
|
||||
public Wakeup(JsonData json, HttpConnection http, Tuple<Int32, Int32, Int32> id, Boolean polling) : base(json, http, id, polling) {
|
||||
public Wakeup(JsonData json, Tuple<Int32, Int32, Classes> id, HttpConnection http, Boolean polling) : base(json, id, http, polling) {
|
||||
this.InitComplex(json);
|
||||
}
|
||||
|
||||
@@ -113,12 +114,24 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses {
|
||||
Helper.WriteError("Kenne in " + this.Name + " [" + this.Id + "] " + match.Groups[4].Value + " nicht!");
|
||||
}
|
||||
if (success && this.CheckSetUpdateTime(json)) {
|
||||
this.Update?.Invoke(this, new DeviceUpdateEvent(0, this.LastUpdate));
|
||||
this.Update?.Invoke(this, new DeviceUpdateEvent(0, this.LastUpdate, this));
|
||||
}
|
||||
}
|
||||
|
||||
public override String ToString() {
|
||||
return "Wakeup " + this.Name + " [" + this.Id + "]: " + this.LastWakeup + "-" + this.LastSleep + " " + this.Interval + " [" + this.WakeupMin + "," + this.WakeupMax + "," + this.WakeupDefault + "," + this.AgainstNode + "]";
|
||||
}
|
||||
|
||||
public override Dictionary<String, Object> ToDictionary() {
|
||||
return new Dictionary<String, Object> {
|
||||
{ "Interval", this.Interval },
|
||||
{ "AgainstNode", this.AgainstNode },
|
||||
{ "WakeupMin", this.WakeupMin },
|
||||
{ "WakeupMax", this.WakeupMax },
|
||||
{ "WakeupDefault", this.WakeupDefault },
|
||||
{ "LastWakeup", this.LastWakeup.ToString() },
|
||||
{ "LastSleep", this.LastSleep.ToString() }
|
||||
};
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@@ -47,7 +47,7 @@ namespace BlubbFish.IoT.Zway.Devices {
|
||||
}
|
||||
|
||||
private void InstanceUpdate(Object sender, DeviceUpdateEvent e) {
|
||||
this.Update?.Invoke(sender, e);
|
||||
this.Update?.Invoke(this, e);
|
||||
}
|
||||
|
||||
private void CreateInstances(JsonData json, HttpConnection http) {
|
||||
|
||||
+11
-10
@@ -3,6 +3,7 @@ using System.Collections.Generic;
|
||||
using System.Collections.ObjectModel;
|
||||
using BlubbFish.IoT.Zway.Devices.CommandClasses;
|
||||
using BlubbFish.IoT.Zway.Events;
|
||||
using BlubbFish.IoT.Zway.Interfaces;
|
||||
using BlubbFish.IoT.Zway.lib;
|
||||
using LitJson;
|
||||
|
||||
@@ -16,40 +17,40 @@ namespace BlubbFish.IoT.Zway.Devices {
|
||||
|
||||
public Int32 DeviceId { get; }
|
||||
public Int32 InstanceId { get; }
|
||||
public ReadOnlyDictionary<Int32, CommandClass> CommandClasses { get; private set; }
|
||||
public ReadOnlyDictionary<ACommandClass.Classes, ACommandClass> CommandClasses { get; private set; }
|
||||
|
||||
private Instance(JsonData json, Tuple<Int32, Int32> id, HttpConnection http, Boolean polling) {
|
||||
this.DeviceId = id.Item1;
|
||||
this.InstanceId = id.Item2;
|
||||
this.polling = polling;
|
||||
this.CreateInstances(json["commandClasses"], http);
|
||||
foreach (KeyValuePair<Int32, CommandClass> item in this.CommandClasses) {
|
||||
foreach (KeyValuePair<ACommandClass.Classes, ACommandClass> item in this.CommandClasses) {
|
||||
item.Value.Update += this.ClassUpdate;
|
||||
}
|
||||
this.MakePolltimer();
|
||||
}
|
||||
|
||||
private void MakePolltimer() {
|
||||
if(this.CommandClasses.ContainsKey(132)) {
|
||||
this.nextwakeup = ((Wakeup)this.CommandClasses[132]).LastWakeup.AddSeconds(((Wakeup)this.CommandClasses[132]).Interval).AddSeconds(-20);
|
||||
if(this.CommandClasses.ContainsKey(ACommandClass.Classes.Wakeup)) {
|
||||
this.nextwakeup = ((Wakeup)this.CommandClasses[ACommandClass.Classes.Wakeup]).LastWakeup.AddSeconds(((Wakeup)this.CommandClasses[ACommandClass.Classes.Wakeup]).Interval).AddSeconds(-20);
|
||||
} else {
|
||||
this.nextwakeup = DateTime.Now.AddSeconds(60);
|
||||
}
|
||||
}
|
||||
|
||||
private void ClassUpdate(Object sender, DeviceUpdateEvent e) {
|
||||
this.Update?.Invoke(sender, e);
|
||||
this.Update?.Invoke(this, e);
|
||||
}
|
||||
|
||||
private void CreateInstances(JsonData json, HttpConnection http) {
|
||||
Dictionary<Int32, CommandClass> commands = new Dictionary<Int32, CommandClass>();
|
||||
Dictionary<ACommandClass.Classes, ACommandClass> commands = new Dictionary<ACommandClass.Classes, ACommandClass>();
|
||||
foreach (String commandid in json.Keys) {
|
||||
CommandClass c = CommandClass.CreateInstance(json[commandid], new Tuple<Int32, Int32, Int32>(this.DeviceId, this.InstanceId, Int32.Parse(commandid)), http, this.polling);
|
||||
ACommandClass c = ACommandClass.CreateInstance(json[commandid], new Tuple<Int32, Int32, ACommandClass.Classes>(this.DeviceId, this.InstanceId, (ACommandClass.Classes)Int32.Parse(commandid)), http, this.polling);
|
||||
if (c != null) {
|
||||
commands.Add(Int32.Parse(commandid), c);
|
||||
commands.Add((ACommandClass.Classes)Int32.Parse(commandid), c);
|
||||
}
|
||||
}
|
||||
this.CommandClasses = new ReadOnlyDictionary<Int32, CommandClass>(commands);
|
||||
this.CommandClasses = new ReadOnlyDictionary<ACommandClass.Classes, ACommandClass>(commands);
|
||||
}
|
||||
|
||||
internal static Instance CreateInstance(JsonData json, Tuple<Int32, Int32> id, HttpConnection http, Boolean polling) {
|
||||
@@ -68,7 +69,7 @@ namespace BlubbFish.IoT.Zway.Devices {
|
||||
internal void Poll() {
|
||||
if(DateTime.Now > this.nextwakeup) {
|
||||
this.MakePolltimer();
|
||||
foreach (KeyValuePair<Int32, CommandClass> item in this.CommandClasses) {
|
||||
foreach (KeyValuePair<ACommandClass.Classes, ACommandClass> item in this.CommandClasses) {
|
||||
item.Value.Poll();
|
||||
}
|
||||
}
|
||||
|
||||
@@ -10,46 +10,54 @@ namespace BlubbFish.IoT.Zway.Events {
|
||||
public DeviceUpdateEvent() {
|
||||
}
|
||||
|
||||
public DeviceUpdateEvent(Single value, DateTime time) {
|
||||
this.GetSingle = value;
|
||||
public DeviceUpdateEvent(Double value, DateTime time, Object parent) {
|
||||
this.GetDouble = value;
|
||||
this.UpdateTime = time;
|
||||
this.Parent = parent;
|
||||
}
|
||||
|
||||
public DeviceUpdateEvent(Boolean value, DateTime time) {
|
||||
public DeviceUpdateEvent(Boolean value, DateTime time, Object parent) {
|
||||
this.GetBoolean = value;
|
||||
this.UpdateTime = time;
|
||||
this.Parent = parent;
|
||||
}
|
||||
|
||||
public DeviceUpdateEvent(DateTime value, DateTime time) {
|
||||
public DeviceUpdateEvent(DateTime value, DateTime time, Object parent) {
|
||||
this.GetDate = value;
|
||||
this.UpdateTime = time;
|
||||
this.Parent = parent;
|
||||
}
|
||||
|
||||
public DeviceUpdateEvent(Tuple<String, String, Single> value, DateTime time) {
|
||||
this.GetStringStringSingleTuple = value;
|
||||
public DeviceUpdateEvent(Tuple<String, String, Double> value, DateTime time, Object parent) {
|
||||
this.GetStringStringDoubleTuple = value;
|
||||
this.UpdateTime = time;
|
||||
this.Parent = parent;
|
||||
}
|
||||
public DeviceUpdateEvent(Tuple<String, String, Single, Single, Single, Boolean> value, DateTime time) {
|
||||
this.GetStringStringSingleSingleSingleSingleBooleanTuple = value;
|
||||
public DeviceUpdateEvent(Tuple<String, String, Double, Double, Double, Boolean> value, DateTime time, Object parent) {
|
||||
this.GetStringStringDoubleDoubleDoubleDoubleBooleanTuple = value;
|
||||
this.UpdateTime = time;
|
||||
this.Parent = parent;
|
||||
}
|
||||
|
||||
public DeviceUpdateEvent(Tuple<Int32, Int32> value, DateTime time) {
|
||||
public DeviceUpdateEvent(Tuple<Int32, Int32> value, DateTime time, Object parent) {
|
||||
this.GetIntegerTuple = value;
|
||||
this.UpdateTime = time;
|
||||
this.Parent = parent;
|
||||
}
|
||||
|
||||
public DeviceUpdateEvent(Tuple<Int64, Int32> value, DateTime time) {
|
||||
public DeviceUpdateEvent(Tuple<Int64, Int32> value, DateTime time, Object parent) {
|
||||
this.GetLongIntegerTuple = value;
|
||||
this.UpdateTime = time;
|
||||
this.Parent = parent;
|
||||
}
|
||||
|
||||
public Single GetSingle { get; }
|
||||
public Double GetDouble { get; }
|
||||
public DateTime GetDate { get; }
|
||||
public Tuple<String, String, Single> GetStringStringSingleTuple { get; }
|
||||
public Tuple<String, String, Single, Single, Single, Boolean> GetStringStringSingleSingleSingleSingleBooleanTuple { get; }
|
||||
public Tuple<String, String, Double> GetStringStringDoubleTuple { get; }
|
||||
public Tuple<String, String, Double, Double, Double, Boolean> GetStringStringDoubleDoubleDoubleDoubleBooleanTuple { get; }
|
||||
public Tuple<Int64, Int32> GetLongIntegerTuple { get; }
|
||||
public DateTime UpdateTime { get; }
|
||||
public Object Parent { get; private set; }
|
||||
public Boolean GetBoolean { get; }
|
||||
public Tuple<Int32,Int32> GetIntegerTuple { get; }
|
||||
}
|
||||
|
||||
@@ -0,0 +1,236 @@
|
||||
using System;
|
||||
using System.Collections.Generic;
|
||||
using System.Collections.ObjectModel;
|
||||
using System.Text.RegularExpressions;
|
||||
using BlubbFish.IoT.Zway.Events;
|
||||
using BlubbFish.IoT.Zway.lib;
|
||||
using LitJson;
|
||||
|
||||
namespace BlubbFish.IoT.Zway.Interfaces {
|
||||
public abstract class ACommandClass {
|
||||
protected HttpConnection http;
|
||||
|
||||
public delegate void UpdatedValue(Object sender, DeviceUpdateEvent e);
|
||||
public abstract event UpdatedValue Update;
|
||||
protected enum IgnoredClasses : Int32 {
|
||||
Basic = 32,
|
||||
ControllerReplication = 33,
|
||||
ApplicationStatus = 34,
|
||||
SensorBinary = 48,
|
||||
SwitchColor = 51,
|
||||
MeterPulse = 53,
|
||||
MultiChannel = 96,
|
||||
Alarm = 113,
|
||||
ManufacturerSpecific = 114,
|
||||
PowerLevel = 115,
|
||||
Protection = 117,
|
||||
NodeNaming = 119,
|
||||
FirmwareUpdate = 122,
|
||||
Association = 133,
|
||||
Version = 134,
|
||||
MultiChannelAssociation = 142,
|
||||
MultiCmd = 143
|
||||
}
|
||||
|
||||
public enum Classes : Int32 {
|
||||
SwitchBinary = 37,
|
||||
SwitchMultilevel = 38,
|
||||
SensorMultilevel = 49,
|
||||
Meter = 50,
|
||||
ThermostatMode = 64,
|
||||
ThermostatSetPoint = 67,
|
||||
CentralScene = 91,
|
||||
Configuration = 112,
|
||||
Battery = 128,
|
||||
Wakeup = 132,
|
||||
Indicator = 135
|
||||
}
|
||||
|
||||
public Int32 DeviceId { get; }
|
||||
public Int32 Instance { get; }
|
||||
public Classes Commandclass { get; }
|
||||
public String Id { get; }
|
||||
public Int32 SensorId { get; }
|
||||
public DateTime LastUpdate { get; protected set; }
|
||||
public String Name { get; }
|
||||
public Boolean Polling { get; set; }
|
||||
public Boolean PollOnce { get; set; }
|
||||
public ReadOnlyDictionary<Int32, ACommandClass> Sub { get; protected set; }
|
||||
public Boolean HasSub { get; protected set; }
|
||||
public Boolean IsSub { get; protected set; }
|
||||
public Boolean HasReset { get; protected set; }
|
||||
|
||||
#region Constructor
|
||||
|
||||
protected ACommandClass(JsonData json, Tuple<Int32, Int32, Classes, Int32> id, HttpConnection http, Boolean polling) {
|
||||
this.DeviceId = id.Item1;
|
||||
this.Instance = id.Item2;
|
||||
this.Commandclass = id.Item3;
|
||||
this.SensorId = id.Item4;
|
||||
this.http = http;
|
||||
this.LastUpdate = DateTime.Now;
|
||||
this.Polling = polling;
|
||||
this.HasSub = false;
|
||||
this.HasReset = false;
|
||||
this.IsSub = false;
|
||||
this.Id = this.DeviceId + "-" + this.Instance + "-" + (Int32)this.Commandclass + "-" + this.SensorId;
|
||||
if (ZwayController.namelist.ContainsKey(this.Id)) {
|
||||
this.Name = ZwayController.namelist[this.Id];
|
||||
}
|
||||
}
|
||||
|
||||
protected ACommandClass(JsonData json, Tuple<Int32, Int32, Classes> id, HttpConnection http, Boolean polling) {
|
||||
this.DeviceId = id.Item1;
|
||||
this.Instance = id.Item2;
|
||||
this.Commandclass = id.Item3;
|
||||
this.http = http;
|
||||
this.LastUpdate = DateTime.Now;
|
||||
this.Polling = polling;
|
||||
this.HasSub = false;
|
||||
this.HasReset = false;
|
||||
this.IsSub = false;
|
||||
this.Id = this.DeviceId + "-" + this.Instance + "-" + (Int32)this.Commandclass;
|
||||
if (ZwayController.namelist.ContainsKey(this.Id)) {
|
||||
this.Name = ZwayController.namelist[this.Id];
|
||||
}
|
||||
}
|
||||
|
||||
internal static ACommandClass CreateInstance(JsonData json, Tuple<Int32, Int32, Classes> id, HttpConnection http, Boolean polling) {
|
||||
if (json.Keys.Contains("name") &&
|
||||
json.Keys.Contains("data") &&
|
||||
json["data"].Keys.Contains("supported") &&
|
||||
json["data"]["supported"].Keys.Contains("value") &&
|
||||
Boolean.Parse(json["data"]["supported"]["value"].ToString()) &&
|
||||
!Enum.IsDefined(typeof(IgnoredClasses), (Int32)id.Item3) && Enum.IsDefined(typeof(Classes), id.Item3)) {
|
||||
String name = id.Item3.ToString();
|
||||
String objectName = "BlubbFish.IoT.Zway.Devices.CommandClasses." + name[0].ToString().ToUpper() + name.Substring(1).ToLower();
|
||||
return GetInstanceConcrete(objectName, json, http, id, polling);
|
||||
}
|
||||
if (!Enum.IsDefined(typeof(IgnoredClasses), (Int32)id.Item3) && !Enum.IsDefined(typeof(Classes), id.Item3)) {
|
||||
Helper.WriteError("CommandClass " + id.Item3 + " not exist.");
|
||||
}
|
||||
return null;
|
||||
}
|
||||
|
||||
private static ACommandClass GetInstanceConcrete(String objectName, JsonData json, HttpConnection http, Tuple<Int32, Int32, Classes> id, Boolean polling) {
|
||||
Type t = null;
|
||||
try {
|
||||
t = Type.GetType(objectName, true);
|
||||
} catch (TypeLoadException) {
|
||||
Console.Error.WriteLine("Konnte Type " + objectName + " nicht laden!");
|
||||
return null;
|
||||
}
|
||||
return (ACommandClass)t.GetConstructor(new Type[] { typeof(JsonData), typeof(Tuple<Int32, Int32, Classes>), typeof(HttpConnection), typeof(Boolean) }).Invoke(new Object[] { json, id, http, polling });
|
||||
}
|
||||
|
||||
#endregion
|
||||
|
||||
#region Polling
|
||||
|
||||
internal virtual void Poll() {
|
||||
if (this.Polling || this.PollOnce) {
|
||||
this.PollOnce = false;
|
||||
this.http.GetVoid("ZWave.zway/Run/devices[" + this.DeviceId + "].instances[" + this.Instance + "].commandClasses[" + ((Int32)this.Commandclass).ToString() + "].Get()");
|
||||
}
|
||||
}
|
||||
|
||||
protected void PollNone() {
|
||||
this.PollOnce = false;
|
||||
}
|
||||
|
||||
protected void PollSub() {
|
||||
if (this.Polling || this.PollOnce) {
|
||||
this.PollOnce = false;
|
||||
this.http.GetVoid("ZWave.zway/Run/devices[" + this.DeviceId + "].instances[" + this.Instance + "].commandClasses[" + ((Int32)this.Commandclass).ToString() + "].Get(" + this.SensorId + ")");
|
||||
}
|
||||
}
|
||||
|
||||
protected void PollPerSub() {
|
||||
foreach (KeyValuePair<Int32, ACommandClass> item in this.Sub) {
|
||||
item.Value.Poll();
|
||||
}
|
||||
}
|
||||
|
||||
protected void PollSubGlobal() {
|
||||
Boolean poll = false;
|
||||
Boolean pollonce = false;
|
||||
foreach (KeyValuePair<Int32, ACommandClass> item in this.Sub) {
|
||||
if (item.Value.Polling) {
|
||||
poll = true;
|
||||
}
|
||||
if(item.Value.PollOnce) {
|
||||
pollonce = true;
|
||||
}
|
||||
}
|
||||
if (poll || pollonce) {
|
||||
this.http.GetVoid("ZWave.zway/Run/devices[" + this.DeviceId + "].instances[" + this.Instance + "].commandClasses[" + ((Int32)this.Commandclass).ToString() + "].Get()");
|
||||
}
|
||||
}
|
||||
|
||||
#endregion
|
||||
|
||||
#region SetValues
|
||||
|
||||
protected void SetInt(Int32 value) {
|
||||
this.http.GetVoid("ZWave.zway/Run/devices[" + this.DeviceId + "].instances[" + this.Instance + "].commandClasses[" + ((Int32)this.Commandclass).ToString() + "].Set(" + value + ")");
|
||||
}
|
||||
|
||||
protected void SetTuple(Double value1, Double value2) {
|
||||
this.http.GetVoid("ZWave.zway/Run/devices[" + this.DeviceId + "].instances[" + this.Instance + "].commandClasses[" + ((Int32)this.Commandclass).ToString() + "].Set(" + value1 + "," + value2 + ")");
|
||||
}
|
||||
|
||||
protected void SetTriple(Double v1, Double v2, Double v3) {
|
||||
this.http.GetVoid("ZWave.zway/Run/devices[" + this.DeviceId + "].instances[" + this.Instance + "].commandClasses[" + ((Int32)this.Commandclass).ToString() + "].Set(" + v1 + "," + v2 + "," + v3 + ")");
|
||||
}
|
||||
|
||||
protected Boolean CheckSetUpdateTime(JsonData json) {
|
||||
if (json.Keys.Contains("updateTime") && (json["updateTime"].IsInt || json["updateTime"].IsLong)) {
|
||||
DateTime newdate = DateTimeOffset.FromUnixTimeSeconds(Int64.Parse(json["updateTime"].ToString())).ToLocalTime().DateTime;
|
||||
if (newdate > this.LastUpdate) {
|
||||
this.LastUpdate = newdate;
|
||||
return true;
|
||||
} else {
|
||||
return false;
|
||||
}
|
||||
} else {
|
||||
return true;
|
||||
}
|
||||
}
|
||||
|
||||
public virtual void Reset() {
|
||||
if (this.HasReset) {
|
||||
this.http.GetVoid("ZWave.zway/Run/devices[" + this.DeviceId + "].instances[" + this.Instance + "].commandClasses[" + ((Int32)this.Commandclass).ToString() + "].Reset()");
|
||||
}
|
||||
}
|
||||
|
||||
#endregion
|
||||
|
||||
#region Output
|
||||
|
||||
public String MqttTopic() {
|
||||
return this.DeviceId + "/" + this.Instance + "/" + ((Int32)this.Commandclass).ToString() + (this.IsSub ? "/" + this.SensorId : "");
|
||||
}
|
||||
|
||||
public String ToJson() {
|
||||
Dictionary<String, Object> json = this.ToDictionary();
|
||||
json.Add("date", this.LastUpdate.ToString());
|
||||
json.Add("name", this.Name);
|
||||
json.Add("class", this.Commandclass.ToString());
|
||||
return JsonMapper.ToJson(json);
|
||||
}
|
||||
|
||||
public abstract Dictionary<String, Object> ToDictionary();
|
||||
|
||||
protected Dictionary<String, Object> ToDictionarySub() {
|
||||
Dictionary<String, Object> json = new Dictionary<String, Object>();
|
||||
foreach (KeyValuePair<Int32, ACommandClass> item in this.Sub) {
|
||||
json.Add(item.Key.ToString(), item.Value.ToDictionary());
|
||||
}
|
||||
return json;
|
||||
}
|
||||
|
||||
#endregion
|
||||
|
||||
internal abstract void SetUpdate(JsonData json, Match match);
|
||||
}
|
||||
}
|
||||
@@ -1,14 +0,0 @@
|
||||
using System;
|
||||
using BlubbFish.IoT.Zway.Events;
|
||||
|
||||
namespace BlubbFish.IoT.Zway.Interfaces {
|
||||
public delegate void UpdatedValue(Object sender, DeviceUpdateEvent e);
|
||||
public interface ICommandClass {
|
||||
String Name { get; }
|
||||
String Id { get; }
|
||||
DateTime LastUpdate { get; }
|
||||
Boolean Polling { get; set; }
|
||||
|
||||
event UpdatedValue Update;
|
||||
}
|
||||
}
|
||||
@@ -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.0.0.0")]
|
||||
[assembly: AssemblyFileVersion("1.0.0.0")]
|
||||
[assembly: AssemblyVersion("1.3.4.0")]
|
||||
[assembly: AssemblyFileVersion("1.3.4.0")]
|
||||
|
||||
+1
-3
@@ -44,7 +44,6 @@
|
||||
</ItemGroup>
|
||||
<ItemGroup>
|
||||
<Compile Include="Devices\CommandClasses\Battery.cs" />
|
||||
<Compile Include="Devices\CommandClass.cs" />
|
||||
<Compile Include="Devices\CommandClasses\CommandClassSubs\Configurationsub.cs" />
|
||||
<Compile Include="Devices\CommandClasses\CommandClassSubs\ThermostatSetPointSub.cs" />
|
||||
<Compile Include="Devices\CommandClasses\Configuration.cs" />
|
||||
@@ -53,9 +52,8 @@
|
||||
<Compile Include="Devices\CommandClasses\CommandClassSubs\MeterSub.cs" />
|
||||
<Compile Include="Devices\CommandClasses\CommandClassSubs\SensorMultilevelSub.cs" />
|
||||
<Compile Include="Devices\CommandClasses\Wakeup.cs" />
|
||||
<Compile Include="Devices\CommandClassSub.cs" />
|
||||
<Compile Include="Devices\Device.cs" />
|
||||
<Compile Include="Interfaces\ICommandClass.cs" />
|
||||
<Compile Include="Interfaces\ACommandClass.cs" />
|
||||
<Compile Include="Devices\Instance.cs" />
|
||||
<Compile Include="Devices\CommandClasses\CentralScene.cs" />
|
||||
<Compile Include="Devices\CommandClasses\SensorMultilevel.cs" />
|
||||
|
||||
+19
-18
@@ -73,23 +73,24 @@ namespace BlubbFish.IoT.Zway {
|
||||
}
|
||||
}
|
||||
|
||||
public ICommandClass GetCommandClass(Int32 deviceid, Int32 instanceid, Int32 classid) {
|
||||
if(this.Devices.ContainsKey(deviceid) && this.Devices[deviceid].Instances.ContainsKey(instanceid) && this.Devices[deviceid].Instances[instanceid].CommandClasses.ContainsKey(classid)) {
|
||||
return this.Devices[deviceid].Instances[instanceid].CommandClasses[classid];
|
||||
public ACommandClass GetCommandClass(String id) {
|
||||
String[] addr = id.Split('-');
|
||||
if (addr.Length == 3 || addr.Length == 4) {
|
||||
return this.GetCommandClass(Int32.Parse(addr[0]), Int32.Parse(addr[1]), (ACommandClass.Classes)Int32.Parse(addr[2]), (addr.Length == 4 ? Int32.Parse(addr[3]) : -1));
|
||||
}
|
||||
return null;
|
||||
}
|
||||
|
||||
public ICommandClass GetCommandClassSub(Int32 deviceid, Int32 instanceid, Int32 classid, Int32 subcid) {
|
||||
ICommandClass comandclass = this.GetCommandClass(deviceid, instanceid, classid);
|
||||
if (comandclass != null) {
|
||||
foreach (PropertyInfo item in comandclass.GetType().GetProperties()) {
|
||||
if (item.Name == "Sub") {
|
||||
if (comandclass.GetType().GetProperty("Sub").PropertyType == typeof(ReadOnlyDictionary<Int32, CommandClassSub>)) {
|
||||
ReadOnlyDictionary<Int32, CommandClassSub> commandclasssub = (ReadOnlyDictionary<Int32, CommandClassSub>)comandclass.GetType().GetProperty("Sub").GetValue(comandclass);
|
||||
if (commandclasssub.ContainsKey(subcid)) {
|
||||
return commandclasssub[subcid];
|
||||
public ACommandClass GetCommandClass(Int32 deviceid, Int32 instanceid, ACommandClass.Classes classid, Int32 subcid = -1) {
|
||||
if(this.Devices.ContainsKey(deviceid) && this.Devices[deviceid].Instances.ContainsKey(instanceid) && this.Devices[deviceid].Instances[instanceid].CommandClasses.ContainsKey(classid)) {
|
||||
ACommandClass commandclass = this.Devices[deviceid].Instances[instanceid].CommandClasses[classid];
|
||||
if(subcid == -1) {
|
||||
return commandclass;
|
||||
}
|
||||
if (commandclass != null) {
|
||||
if(commandclass.HasSub) {
|
||||
if(commandclass.Sub.ContainsKey(subcid)) {
|
||||
return commandclass.Sub[subcid];
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -112,7 +113,7 @@ namespace BlubbFish.IoT.Zway {
|
||||
if(match.Success) {
|
||||
Int32 deviceid = Int32.Parse(match.Groups[1].Value);
|
||||
Int32 instanceid = Int32.Parse(match.Groups[2].Value);
|
||||
Int32 commandid = Int32.Parse(match.Groups[3].Value);
|
||||
ACommandClass.Classes commandid = (ACommandClass.Classes)Int32.Parse(match.Groups[3].Value);
|
||||
if (this.Devices.ContainsKey(deviceid) && this.Devices[deviceid].Instances.ContainsKey(instanceid) && this.Devices[deviceid].Instances[instanceid].CommandClasses.ContainsKey(commandid)) {
|
||||
this.Devices[deviceid].Instances[instanceid].CommandClasses[commandid].SetUpdate(notifications[item], match);
|
||||
}
|
||||
@@ -149,13 +150,13 @@ namespace BlubbFish.IoT.Zway {
|
||||
this.Devices = new ReadOnlyDictionary<Int32, Device>(devices);
|
||||
}
|
||||
|
||||
public List<T> GetCommandClasses<T>() {
|
||||
List<T> ret = new List<T>();
|
||||
public Dictionary<String, ACommandClass> GetCommandClasses(ACommandClass.Classes classes) {
|
||||
Dictionary<String, ACommandClass> ret = new Dictionary<String, ACommandClass>();
|
||||
foreach (KeyValuePair<Int32, Device> device in this.Devices) {
|
||||
foreach (KeyValuePair<Int32, Instance> instance in device.Value.Instances) {
|
||||
foreach (KeyValuePair<Int32, CommandClass> commandclass in instance.Value.CommandClasses) {
|
||||
if (commandclass.Value is T) {
|
||||
ret.Add((T)Convert.ChangeType(commandclass.Value, typeof(T)));
|
||||
foreach (KeyValuePair<ACommandClass.Classes, ACommandClass> commandclass in instance.Value.CommandClasses) {
|
||||
if (commandclass.Key == classes) {
|
||||
ret.Add(commandclass.Value.Id, commandclass.Value);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
Binary file not shown.
Reference in New Issue
Block a user