42 Commits
Author SHA1 Message Date
BlubbFish d1a8fa449b 2018-06-02 17:14:42 +00:00
BlubbFish 1da54f7416 [NF] Logrotate 2018-05-29 20:07:50 +00:00
BlubbFish eb4783c11e 2018-05-29 16:15:17 +00:00
BlubbFish c06d910356 [NF] Now sould dedect Strg+c on Linux 2018-05-15 20:52:54 +00:00
BlubbFish 02871e4d66 [BF] Fixinig installations dpkg script 2018-05-15 19:04:19 +00:00
BlubbFish edb59f01b6 [BF] Fixinig installations dpkg script 2018-05-15 18:59:32 +00:00
BlubbFish ce30132f5f Utils.csproj
[NF] Programmlogger added (v1.1.0)
[NF] Utils fixing tiny issues

Zway-Bot.csproj
[NF] changes Topics without beginning /
[NF] Using programmlogger (v1.4.0)
2018-05-15 18:49:03 +00:00
BlubbFish 64c9020bcb [BF] Fixing Issue with Math.Abs(l) 2018-05-12 12:36:32 +00:00
BlubbFish a22628b0d0 [BF] Some sensors make wrong measurements near 0 not exactly 0, so ABS(value) >= 0.1 is alse false 2018-05-10 06:26:39 +00:00
BlubbFish 64d74668cc [NF] Cleaning up
[NF] Create Debian Package
2018-05-08 17:25:39 +00:00
BlubbFish e53529b9d4 [BF] Fixing Senml
[NF] Senml now has a configure option to setup the guid
[NF] Zway-Bot now listen on /exit
[NF] Implment searchpath for Zway-Bot (/etc/zwaybot and %appdata%/zwaybot)
2018-05-07 16:52:24 +00:00
BlubbFish ca399a405c [NF] Now creating correct Senml for Linksmart 2018-05-07 14:02:57 +00:00
BlubbFish a931ed15f0 [NF] fixing Senml topics and data 2018-05-07 09:34:10 +00:00
BlubbFish ff35791819 [NF] Create Senml Messages for Linksmart 2018-05-03 14:43:50 +00:00
BlubbFish 6bce798689 [NF] Create Senml Messages for Linksmart 2018-05-03 14:39:08 +00:00
BlubbFish 317ae9b682 [NF] Create Senml Messages for Linksmart 2018-05-03 14:35:02 +00:00
BlubbFish b5e0c70b1e [DW] Flex4Grid deleted
[NF] BosMon Mqtt Plugin created
2018-03-31 20:42:28 +00:00
BlubbFish bd01c5df3f [NF] v1.3.6.0 Better levelcheck and Alarmsensor added 2018-01-01 02:09:55 +00:00
BlubbFish 8dd8605d73 [DW] Alarmsensor added 2017-12-29 13:09:52 +00:00
BlubbFish beea6c1ee0 [BF] v1.3.5.3 Change Level to numeric and create State for Bollean values, because telegraf only parse numeric 2017-12-25 18:11:01 +00:00
BlubbFish 1082ee0d2a [[BF] v1.3.5.2 Check to avoid megapeaks in data now also for temperature 2017-12-24 10:43:58 +00:00
BlubbFish 6d395107cb [BF] v1.3.5.1 Check to avoid megapeaks in Data 2017-12-23 22:37:36 +00:00
BlubbFish ae999384c7 [NF] v.1.3.5 Add Sensorbinary, Alarm and SceneControllerConf and changed DeviceUpdateEvent so its not as complicate as before. Also fixing the gernal Json Names to the right values 2017-12-22 22:09:26 +00:00
BlubbFish 9d09f09c12 [DW] Alarm and SceneControllerConf added. 2017-12-22 13:59:19 +00:00
BlubbFish 08047db287 [DW] Fixing some Json Topics 2017-12-21 22:59:55 +00:00
BlubbFish f406b09ffa [DW] Sensorbinary hinzugefügt 2017-12-21 15:52:05 +00:00
BlubbFish 0834e09178 [BF] v1.3.4.0 Fixing Json Names
[NF] v1.2.2.0 Mqtt can now get and set values
2017-12-19 20:18:30 +00:00
BlubbFish b29e1d2a14 [BF] v.1.3.3 fixing polling once bug 2017-12-19 17:33:31 +00:00
BlubbFish d9dfe7d63a [BF] v1.3.1.0 Forgot some settings, now configuration setting also works again 2017-12-18 16:02:18 +00:00
BlubbFish db935e019c [NF] Tiny fix for mqtt 2017-12-17 21:53:16 +00:00
BlubbFish d7f27fad4f [NF] v1.3.0.0 Adding Status Polling and Mqtt (not compelete)
[NF] Able to force loading modules, so dependencys are ok
[NF] Cleanup because its now easyer to implement Zway
2017-12-17 20:09:28 +00:00
BlubbFish d439471051 [NF] v1.3.0.0 Remove Interface ICommandClass.cs and dublicated classes CommandClass.cs and CommandClassSub.cs, put them into the abstracted class ACommandClass.cs
[NF] v1.2.0.0 Change classid to enum, so its more readable
[NF] v1.1.0.0 Rename a lot of internal functions
2017-12-17 20:05:03 +00:00
BlubbFish 1445a16930 [BF] v.1.2.1.1 Next try to emulate F4G Events 2017-12-09 12:33:15 +00:00
BlubbFish b51f88badb [NF] v1.1.2 Now complete Emulation of F4G Node
[NF] Possibility to attach internal cron events
2017-12-08 19:30:29 +00:00
BlubbFish 8166e6e646 [NF] Filter topics if usefull 2017-12-05 23:22:33 +00:00
BlubbFish 06e57c4559 [NF] Now possible to emulate F4G 2017-12-05 23:10:52 +00:00
BlubbFish 53e4ba9d14 2017-12-03 22:18:29 +00:00
BlubbFish c6dec361d5 [NF] Flex4Grid Plugin for Zway-Bot beginning 2017-12-03 22:07:33 +00:00
BlubbFish fffd2b3c2e [NF] Zway-Bot Module eingefügt 2017-12-02 18:04:43 +00:00
BlubbFish 57de0b4ce9 [BF] Fixing Bug with Cronjon (stupid bug) 2017-12-01 16:14:26 +00:00
BlubbFish 26b3a02d58 [NF] First Release of Zway-Bot 2017-11-25 11:14:04 +00:00
BlubbFish 99dc37d751 [NF] Zway-Bot hinzugefügt
[NF] Viele kleine Änderungen an Zwaylib zur Verbesserung der Kompatibilität
2017-11-25 11:00:48 +00:00
36 changed files with 1797 additions and 528 deletions
-97
View File
@@ -1,97 +0,0 @@
using System;
using System.Text.RegularExpressions;
using BlubbFish.IoT.Zway.Events;
using BlubbFish.IoT.Zway.lib;
using LitJson;
namespace BlubbFish.IoT.Zway.Devices {
public abstract class CommandClass {
protected HttpConnection http;
private enum Ignored {
Basic = 32,
Configuration = 112,
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 Name { get; }
public DateTime LastUpdate { get; private set; }
protected CommandClass(JsonData json, HttpConnection http, Tuple<Int32, Int32, Int32> id) {
this.DeviceId = id.Item1;
this.Instance = id.Item2;
this.Commandclass = id.Item3;
this.Name = this.DeviceId + "-" + this.Instance + "-" + this.Commandclass;
this.http = http;
this.LastUpdate = DateTime.Now;
}
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) {
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);
}
return null;
}
private static CommandClass GetInstanceConcrete(String objectName, JsonData json, HttpConnection http, Tuple<Int32, Int32, Int32> id) {
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>) }).Invoke(new Object[] { json, http, id });
}
protected abstract void InitComplex(JsonData json);
internal abstract void SetUpdate(JsonData json, Match match);
public delegate void UpdatedValue(Object sender, DeviceUpdateEvent e);
public abstract event UpdatedValue Update;
internal virtual void Poll() {
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 + ")");
}
}
}
-51
View File
@@ -1,51 +0,0 @@
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Text.RegularExpressions;
using System.Threading.Tasks;
using BlubbFish.IoT.Zway.Events;
using BlubbFish.IoT.Zway.lib;
using LitJson;
namespace BlubbFish.IoT.Zway.Devices {
public abstract class CommandClassSub {
protected HttpConnection http;
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; }
protected CommandClassSub(JsonData json, Tuple<Int32, Int32, Int32, Int32> id, HttpConnection http) {
this.DeviceId = id.Item1;
this.Instance = id.Item2;
this.Commandclass = id.Item3;
this.SensorId = id.Item4;
this.http = http;
this.Name = this.DeviceId + "-" + this.Instance + "-" + this.Commandclass + "-" + this.SensorId;
}
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;
}
}
protected abstract void InitComplex(JsonData json);
internal abstract void SetUpdate(JsonData json, Match match);
public delegate void UpdatedValue(Object sender, DeviceUpdateEvent e);
public abstract event UpdatedValue Update;
}
}
+78
View File
@@ -0,0 +1,78 @@
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 BlubbFish.Utils.IoT.Interfaces.Language;
using LitJson;
namespace BlubbFish.IoT.Zway.Devices.CommandClasses {
/// <summary>
/// 135 = Indicator
/// </summary>
class Alarm : ACommandClass {
public override event UpdatedValue Update;
#region Properties
/// <summary>
/// Unklar
/// </summary>
public Int32 Level { get; private set; }
/// <summary>
/// unklar
/// </summary>
public Int32 AlarmType { get; private set; }
#endregion
#region Constructor
public Alarm(JsonData json, Tuple<Int32, Int32, Classes> id, HttpConnection http, Boolean polling) : base(json, id, http, polling) {
this.InitComplex(json);
}
private void InitComplex(JsonData json) {
if (json.Keys.Contains("data") && json["data"].Keys.Contains("V1event") &&
json["data"]["V1event"].Keys.Contains("alarmType") && json["data"]["V1event"]["alarmType"].Keys.Contains("value") &&
json["data"]["V1event"].Keys.Contains("level") && json["data"]["V1event"]["level"].Keys.Contains("value")) {
this.AlarmType = Int32.Parse(json["data"]["V1event"]["alarmType"]["value"].ToString());
this.Level = Int32.Parse(json["data"]["V1event"]["level"]["value"].ToString());
}
}
#endregion
#region ACommandClass
public override String ToString() {
return "Alarm " + this.Name + " [" + this.Id + "]: " + this.AlarmType + " " + this.Level;
}
public override Dictionary<String, Object> ToDictionary() {
return new Dictionary<String, Object> {
{ "AlarmType", this.AlarmType },
{ "Level", this.Level },
};
}
internal override void SetUpdate(JsonData json, Match match) {
if (match.Groups[4].Value == ".data.V1event") {
if (json.Keys.Contains("alarmType") && json["alarmType"].Keys.Contains("value") &&
json.Keys.Contains("level") && json["level"].Keys.Contains("value") &&
this.CheckSetUpdateTime(json)) {
this.AlarmType = Int32.Parse(json["alarmType"]["value"].ToString());
this.Level = Int32.Parse(json["level"]["value"].ToString());
this.Update?.Invoke(this, new DeviceUpdateEvent(new Tuple<Int32, Int32>(this.AlarmType, this.Level), this.LastUpdate, this));
}
} else {
Helper.WriteError("Kenne in " + this.Name + " [" + this.Id + "] " + match.Groups[4].Value + " nicht!");
}
}
internal override void Poll() => this.PollNone();
#endregion
#region ISenml
protected override List<Senml> ToSenmlList() {
return new List<Senml>() { };
}
#endregion
}
}
@@ -0,0 +1,71 @@
using System;
using System.Collections.Generic;
using System.Collections.ObjectModel;
using System.Text.RegularExpressions;
using BlubbFish.IoT.Zway.Devices.CommandClasses.CommandClassSubs;
using BlubbFish.IoT.Zway.Events;
using BlubbFish.IoT.Zway.Interfaces;
using BlubbFish.IoT.Zway.lib;
using BlubbFish.Utils.IoT.Interfaces.Language;
using LitJson;
namespace BlubbFish.IoT.Zway.Devices.CommandClasses {
/// <summary>
/// 50 = Meter
/// </summary>
public class Alarmsensor : ACommandClass {
public override event UpdatedValue Update;
#region Constructor
public Alarmsensor(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, ACommandClass> item in this.Sub) {
item.Value.Update += this.DeviceUpdate;
}
}
private void InitComplex(JsonData json) {
if (json.Keys.Contains("data")) {
JsonData data = json["data"];
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("srcId") &&
data[item].Keys.Contains("sensorState") &&
data[item].Keys.Contains("sensorTime") &&
data[item].Keys.Contains("typeString")) {
subs.Add(subid, new Alarmsensorsub(data[item], new Tuple<Int32, Int32, Classes, Int32>(this.DeviceId, this.Instance, this.Commandclass, subid), this.http, this.Polling));
}
}
this.Sub = new ReadOnlyDictionary<Int32, ACommandClass>(subs);
}
}
private void DeviceUpdate(Object sender, DeviceUpdateEvent e) {
this.Update?.Invoke(this, e);
}
#endregion
#region ACommandClass
internal override void SetUpdate(JsonData json, Match match) {
if (match.Groups[4].Value.StartsWith(".data.")) {
Int32 subid = Int32.Parse(match.Groups[5].Value);
if (this.Sub.ContainsKey(subid)) {
this.Sub[subid].SetUpdate(json, match);
}
} else {
Helper.WriteError("Kenne in " + this.Name + " [" + this.Id + "] " + match.Groups[4].Value + " nicht!");
}
}
public override Dictionary<String, Object> ToDictionary() => this.ToDictionarySub();
internal override void Poll() => this.PollSubGlobal();
#endregion
#region ISenml
protected override List<Senml> ToSenmlList() => this.ToSenmlListSub();
#endregion
}
}
+42 -16
View File
@@ -1,50 +1,76 @@
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 BlubbFish.Utils.IoT.Interfaces.Language;
using LitJson;
namespace BlubbFish.IoT.Zway.Devices.CommandClasses {
public class Battery : CommandClass {
public Single Level { get; private set; }
/// <summary>
/// 128 = Battery
/// </summary>
public class Battery : ACommandClass {
public override event UpdatedValue Update;
public Battery(JsonData json, HttpConnection http, Tuple<Int32, Int32, Int32> id) : base(json, http, id) {
#region Properties
/// <summary>
/// Batterylevel in Percent
/// </summary>
public Double Level { get; private set; }
#endregion
#region Constructor
public Battery(JsonData json, Tuple<Int32, Int32, Classes> id, HttpConnection http, Boolean polling) : base(json, id, http, polling) {
this.InitComplex(json);
}
private void InitComplex(JsonData json) {
if (json.Keys.Contains("data") && json["data"].Keys.Contains("last") && json["data"]["last"].Keys.Contains("value")) {
this.Level = Double.Parse(json["data"]["last"]["value"].ToString());
}
}
#endregion
#region ACommandClass
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 },
};
}
internal override void SetUpdate(JsonData json, Match match) {
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.")) {
} else if (match.Groups[4].Value == ".data.lastChange") {
} else {
throw new NotImplementedException();
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));
}
}
#endregion
protected override 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());
}
#region ISenml
protected override List<Senml> ToSenmlList() {
return new List<Senml>() { new SenmlDouble("chargelevel", Senml.Units.Percent, this.Level) };
}
#endregion
public override String ToString() {
return "Battery " + this.Name + ": " + this.Level;
}
}
}
+56 -24
View File
@@ -3,45 +3,47 @@ using System.Collections.Generic;
using System.Collections.ObjectModel;
using System.Text.RegularExpressions;
using BlubbFish.IoT.Zway.Events;
using BlubbFish.IoT.Zway.Interfaces;
using BlubbFish.IoT.Zway.lib;
using BlubbFish.Utils.IoT.Interfaces.Language;
using LitJson;
namespace BlubbFish.IoT.Zway.Devices.CommandClasses {
public class Centralscene : CommandClass {
/// <summary>
/// 91 = CentralScene
/// </summary>
public class Centralscene : ACommandClass {
public override event UpdatedValue Update;
#region Properties
/// <summary>
/// Combination of Scenes and Modes
/// </summary>
public ReadOnlyDictionary<Int32, ReadOnlyCollection<Int32>> ValidScenesModes { get; private set; }
/// <summary>
/// Current active Senes
/// </summary>
public Int32 Scene { get; private set; }
/// <summary>
/// Current active mode
/// </summary>
public Int32 Key { get; private set; }
#endregion
public Centralscene(JsonData json, HttpConnection http, Tuple<Int32, Int32, Int32> id) : base(json, http, id) {
#region Constructor
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);
}
internal override void SetUpdate(JsonData json, Match match) {
if (match.Groups[4].Value == ".data.currentScene") {
if (json.Keys.Contains("value")) {
this.Scene = Int32.Parse(json["value"].ToString());
}
} 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));
}
} else {
throw new NotImplementedException();
}
}
protected override void InitComplex(JsonData json) {
private void InitComplex(JsonData json) {
if (json.Keys.Contains("data")) {
JsonData data = json["data"];
if(data.Keys.Contains("sceneSupportedKeyAttributesMask")) {
if (data.Keys.Contains("sceneSupportedKeyAttributesMask")) {
Dictionary<Int32, ReadOnlyCollection<Int32>> scenes = new Dictionary<Int32, ReadOnlyCollection<Int32>>();
foreach (String item in data["sceneSupportedKeyAttributesMask"].Keys) {
if (Int32.TryParse(item, out Int32 mode) &&
data["sceneSupportedKeyAttributesMask"][item].Keys.Contains("value") &&
if (Int32.TryParse(item, out Int32 mode) &&
data["sceneSupportedKeyAttributesMask"][item].Keys.Contains("value") &&
data["sceneSupportedKeyAttributesMask"][item]["value"].IsArray) {
JsonData values = data["sceneSupportedKeyAttributesMask"][item]["value"];
List<Int32> modes = new List<Int32>();
@@ -53,7 +55,7 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses {
}
this.ValidScenesModes = new ReadOnlyDictionary<Int32, ReadOnlyCollection<Int32>>(scenes);
if (data.Keys.Contains("currentScene") &&
data["currentScene"].Keys.Contains("value") &&
data["currentScene"].Keys.Contains("value") &&
data["currentScene"]["value"] != null) {
this.Scene = Int32.Parse(data["currentScene"]["value"].ToString());
}
@@ -65,12 +67,42 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses {
}
}
}
#endregion
#region ACommandClass
public override String ToString() {
return "CentralScene " + this.Name + ": "+this.Scene+"-"+this.Key;
return "CentralScene " + this.Name + " [" + this.Id + "]: " + this.Scene + "-" + this.Key;
}
internal override void Poll() {
public override Dictionary<String, Object> ToDictionary() {
return new Dictionary<String, Object> {
{ "Scene", this.Scene },
{ "Key", this.Key },
};
}
internal override void SetUpdate(JsonData json, Match match) {
if (match.Groups[4].Value == ".data.currentScene") {
if (json.Keys.Contains("value")) {
this.Scene = Int32.Parse(json["value"].ToString());
}
} 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));
}
} else {
Helper.WriteError("Kenne in " + this.Name + " [" + this.Id + "] " + match.Groups[4].Value + " nicht!");
}
}
internal override void Poll() => this.PollNone();
#endregion
#region ISenml
protected override List<Senml> ToSenmlList() {
return new List<Senml>() { new SenmlDouble("scene", Senml.Units.CounterValue, this.Scene), new SenmlDouble("key", Senml.Units.CounterValue, this.Key) };
}
#endregion
}
}
@@ -0,0 +1,89 @@
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 BlubbFish.Utils.IoT.Interfaces.Language;
using LitJson;
namespace BlubbFish.IoT.Zway.Devices.CommandClasses.CommandClassSubs {
public class Alarmsensorsub : ACommandClass {
public override event UpdatedValue Update;
#region Properties
/// <summary>
///
/// </summary>
public Int32 Source { get; private set; }
/// <summary>
///
/// </summary>
public Int32 Level { get; private set; }
/// <summary>
///
/// </summary>
public Int32 Time { get; private set; }
/// <summary>
///
/// </summary>
public String Type { get; private set; }
#endregion
#region Constructor
public Alarmsensorsub(JsonData json, Tuple<Int32, Int32, Classes, Int32> id, HttpConnection http, Boolean polling) : base(json, id, http, polling) {
this.IsSub = true;
InitComplex(json);
}
private void InitComplex(JsonData json) {
if (json.Keys.Contains("srcId") && json["srcId"].Keys.Contains("value") &&
json.Keys.Contains("sensorState") && json["sensorState"].Keys.Contains("value") &&
json.Keys.Contains("sensorTime") && json["sensorTime"].Keys.Contains("value") &&
json.Keys.Contains("typeString") && json["typeString"].Keys.Contains("value")) {
this.Source = Int32.Parse(json["srcId"]["value"].ToString());
this.Level = Int32.Parse(json["sensorState"]["value"].ToString());
this.Time = Int32.Parse(json["sensorTime"]["value"].ToString());
this.Type = json["typeString"]["value"].ToString();
}
}
#endregion
#region ACommandClass
public override String ToString() {
return "AlarmSensor " + this.Name + " [" + this.Id + "]: " + this.Type + " " + this.Source + " " + this.Level + " " + this.Time + " " + this.Type;
}
public override Dictionary<String, Object> ToDictionary() {
return new Dictionary<String, Object> {
{ "Source", this.Source },
{ "Level", this.Level },
{ "Time", this.Time },
{ "Type", this.Type }
};
}
internal override void SetUpdate(JsonData json, Match match) {
if (json.Keys.Contains("srcId") && json["srcId"].Keys.Contains("value") &&
json.Keys.Contains("sensorState") && json["sensorState"].Keys.Contains("value") &&
json.Keys.Contains("sensorTime") && json["sensorTime"].Keys.Contains("value") &&
json.Keys.Contains("typeString") && json["typeString"].Keys.Contains("value") &&
this.CheckSetUpdateTime(json)) {
this.Source = Int32.Parse(json["srcId"]["value"].ToString());
this.Level = Int32.Parse(json["sensorState"]["value"].ToString());
this.Time = Int32.Parse(json["sensorTime"]["value"].ToString());
this.Type = json["typeString"]["value"].ToString();
this.Update?.Invoke(this, new DeviceUpdateEvent(new Tuple<Int32, Int32, Int32, String>(this.Source, this.Level, this.Time, this.Type), this.LastUpdate, this));
}
}
internal override void Poll() => this.PollNone();
#endregion
#region ISenml
protected override List<Senml> ToSenmlList() {
return new List<Senml>() { };
}
#endregion
}
}
@@ -0,0 +1,88 @@
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 BlubbFish.Utils.IoT.Interfaces.Language;
using LitJson;
namespace BlubbFish.IoT.Zway.Devices.CommandClasses.CommandClassSubs {
class Configurationsub : ACommandClass {
public override event UpdatedValue Update;
#region Properties
private Int64 _level;
/// <summary>
/// Value of the Configuration Item
/// </summary>
public Int64 Level {
get {
return this._level;
}
set {
if (this.Size == 1 && Int16.TryParse(value.ToString(), out Int16 value16)) {
this.SetTriple(this.SensorId, value16, 1);
} else if(this.Size == 2 && Int32.TryParse(value.ToString(), out Int32 value32)) {
this.SetTriple(this.SensorId, value32, 2);
} else if(this.Size == 4) {
this.SetTriple(this.SensorId, value, 4);
}
}
}
/// <summary>
/// Size of the Configuration slot
/// </summary>
public Int32 Size { get; private set; }
#endregion
#region Constructor
public Configurationsub(JsonData json, Tuple<Int32, Int32, Classes, Int32> id, HttpConnection http, Boolean polling) : base(json, id, http, polling) {
this.IsSub = true;
InitComplex(json);
}
private void InitComplex(JsonData json) {
if (json.Keys.Contains("val") &&
json["val"].Keys.Contains("value") &&
json["val"]["value"] != null &&
json.Keys.Contains("size") &&
json["size"].Keys.Contains("value")) {
this._level = Int64.Parse(json["val"]["value"].ToString());
this.Size = Int32.Parse(json["size"]["value"].ToString());
}
}
#endregion
#region ACommandClass
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 },
};
}
internal override void SetUpdate(JsonData json, Match match) {
if (json.Keys.Contains("val") && json["val"].Keys.Contains("value") && json["val"]["value"] != null &&
json.Keys.Contains("size") && json["size"].Keys.Contains("value") &&
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));
}
}
internal override void Poll() => this.PollSub();
#endregion
#region ISenml
protected override List<Senml> ToSenmlList() {
return new List<Senml>() { };
}
#endregion
}
}
@@ -1,25 +1,39 @@
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 BlubbFish.Utils.IoT.Interfaces.Language;
using LitJson;
namespace BlubbFish.IoT.Zway.Devices.CommandClasses.CommandClassSubs {
class Metersub : CommandClassSub {
public class Metersub : ACommandClass {
public override event UpdatedValue Update;
#region Properties
/// <summary>
/// Type of the Sensor
/// </summary>
public String Type { get; private set; }
public Single Level { get; private set; }
/// <summary>
/// Actual value of the Sensor
/// </summary>
public Double Level { get; private set; }
/// <summary>
/// Scale of the Sensor
/// </summary>
public String Scale { get; private set; }
public Metersub(JsonData json, Tuple<Int32, Int32, Int32, Int32> id, HttpConnection http) : base(json, id, http) {
#endregion
#region Constructor
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);
}
public void Reset() {
this.http.GetVoid("ZWave.zway/Run/devices[" + this.DeviceId + "].instances[" + this.Instance + "].commandClasses[" + this.Commandclass + "].Reset()");
}
protected override void InitComplex(JsonData json) {
private void InitComplex(JsonData json) {
if (json.Keys.Contains("sensorTypeString") &&
json["sensorTypeString"].Keys.Contains("value") &&
json.Keys.Contains("val") &&
@@ -27,25 +41,49 @@ 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();
}
}
#endregion
#region ACommandClass
public override String ToString() {
return "Meter " + this.Name + " [" + this.Id + "]: " + this.Type + " " + this.Level + "" + this.Scale;
}
public override Dictionary<String, Object> ToDictionary() {
return new Dictionary<String, Object> {
{ "Level", this.Level },
{ "Type", this.Type },
{ "Scale", this.Scale },
};
}
internal override void SetUpdate(JsonData json, Match match) {
if (json.Keys.Contains("val") && json["val"].Keys.Contains("value") &&
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));
}
}
public override String ToString() {
return "Meter " + this.Name + ": " + this.Type + " " + this.Level + "" + this.Scale;
internal override void Poll() => this.PollNone();
#endregion
#region ISenml
protected override List<Senml> ToSenmlList() {
if (this.Scale == "W") {
return new List<Senml>() { new SenmlDouble("power", Senml.Units.Watt, this.Level) };
} else if(this.Scale == "kWh") {
return new List<Senml>() { new SenmlDouble("consumption", Senml.Units.Joule, this.Level * 1000 * 3.6 * 1000) };
}
return new List<Senml>() {};
}
#endregion
}
}
@@ -0,0 +1,71 @@
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 BlubbFish.Utils.IoT.Interfaces.Language;
using LitJson;
namespace BlubbFish.IoT.Zway.Devices.CommandClasses.CommandClassSubs {
public class Scenecontrollerconfsub : ACommandClass {
public override event UpdatedValue Update;
#region Properties
/// <summary>
///
/// </summary>
public Int32 Scene { get; private set; }
/// <summary>
///
/// </summary>
public Int32 Duration { get; private set; }
#endregion
#region Constructor
public Scenecontrollerconfsub(JsonData json, Tuple<Int32, Int32, Classes, Int32> id, HttpConnection http, Boolean polling) : base(json, id, http, polling) {
this.IsSub = true;
InitComplex(json);
}
private void InitComplex(JsonData json) {
if (json.Keys.Contains("scene") && json["scene"].Keys.Contains("value") &&
json.Keys.Contains("duration") && json["duration"].Keys.Contains("value")) {
this.Scene = Int32.Parse(json["scene"]["value"].ToString());
this.Duration = Int32.Parse(json["duration"]["value"].ToString());
}
}
#endregion
#region ACommandClass
public override String ToString() {
return "SceneControllerConf " + this.Name + " [" + this.Id + "]: " + this.Scene + " " + this.Duration;
}
public override Dictionary<String, Object> ToDictionary() {
return new Dictionary<String, Object> {
{ "Scene", this.Scene },
{ "Duration", this.Duration }
};
}
internal override void SetUpdate(JsonData json, Match match) {
if (json.Keys.Contains("scene") && json["scene"].Keys.Contains("value") &&
json.Keys.Contains("duration") && json["duration"].Keys.Contains("value") &&
this.CheckSetUpdateTime(json)) {
this.Scene = Int32.Parse(json["scene"]["value"].ToString());
this.Duration = Int32.Parse(json["duration"]["value"].ToString());
this.Update?.Invoke(this, new DeviceUpdateEvent(new Tuple<Int32, Int32>(this.Scene, this.Duration), this.LastUpdate, this));
}
}
internal override void Poll() => this.PollSub();
#endregion
#region ISenml
protected override List<Senml> ToSenmlList() {
return new List<Senml>() { };
}
#endregion
}
}
@@ -0,0 +1,82 @@
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 BlubbFish.Utils.IoT.Interfaces.Language;
using LitJson;
namespace BlubbFish.IoT.Zway.Devices.CommandClasses.CommandClassSubs {
public class Sensorbinarysub : ACommandClass {
public override event UpdatedValue Update;
#region Properties
/// <summary>
///
/// </summary>
public String Type { get; private set; }
/// <summary>
///
/// </summary>
public Boolean State { get; private set; }
/// <summary>
///
/// </summary>
public Int32 Level {
get {
return (this.State) ? 1 : 0;
}
}
#endregion
#region Constructor
public Sensorbinarysub(JsonData json, Tuple<Int32, Int32, Classes, Int32> id, HttpConnection http, Boolean polling) : base(json, id, http, polling) {
this.IsSub = true;
InitComplex(json);
}
private void InitComplex(JsonData json) {
if (json.Keys.Contains("sensorTypeString") &&
json["sensorTypeString"].Keys.Contains("value") &&
json.Keys.Contains("level") &&
json["level"].Keys.Contains("value")) {
this.Type = json["sensorTypeString"]["value"].ToString();
this.State = (Boolean)json["level"]["value"];
}
}
#endregion
#region ACommandClass
public override String ToString() {
return "SensorBinary " + this.Name + " [" + this.Id + "]: " + this.Type + " " + this.State.ToString();
}
public override Dictionary<String, Object> ToDictionary() {
return new Dictionary<String, Object> {
{ "State", this.State },
{ "Type", this.Type },
{ "Level", this.Level }
};
}
internal override void SetUpdate(JsonData json, Match match) {
if (json.Keys.Contains("level") && json["level"].Keys.Contains("value") &&
json.Keys.Contains("sensorTypeString") && json["sensorTypeString"].Keys.Contains("value") &&
this.CheckSetUpdateTime(json)) {
this.State = (Boolean)json["level"]["value"];
this.Type = json["sensorTypeString"]["value"].ToString();
this.Update?.Invoke(this, new DeviceUpdateEvent(new Tuple<String, Boolean>(this.Type, this.State), this.LastUpdate, this));
}
}
internal override void Poll() => this.PollNone();
#endregion
#region ISenml
protected override List<Senml> ToSenmlList() {
return new List<Senml>() { };
}
#endregion
}
}
@@ -1,23 +1,38 @@
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 BlubbFish.Utils.IoT.Interfaces.Language;
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 String Scale { get; private set; }
public Sensormultilevelsub(JsonData json, Tuple<Int32, Int32, Int32, Int32> id, HttpConnection http) : base(json, id, http) {
#region Properties
/// <summary>
/// Type of the Sensor
/// </summary>
public String Type { get; private set; }
/// <summary>
/// Level of the sensor
/// </summary>
public Double Level { get; private set; }
/// <summary>
/// Scale of the sensor
/// </summary>
public String Scale { get; private set; }
#endregion
#region Constructor
public Sensormultilevelsub(JsonData json, Tuple<Int32, Int32, Classes, Int32> id, HttpConnection http, Boolean polling) : base(json, id, http, polling) {
this.IsSub = true;
InitComplex(json);
}
protected override void InitComplex(JsonData json) {
private void InitComplex(JsonData json) {
if (json.Keys.Contains("sensorTypeString") &&
json["sensorTypeString"].Keys.Contains("value") &&
json.Keys.Contains("val") &&
@@ -25,25 +40,60 @@ 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();
}
}
#endregion
#region ACommandClass
public override String ToString() {
return "SensorMultilevel " + this.Name + " [" + this.Id + "]: " + this.Type + " " + this.Level + "" + this.Scale;
}
public override Dictionary<String, Object> ToDictionary() {
return new Dictionary<String, Object> {
{ "Level", this.Level },
{ "Type", this.Type },
{ "Scale", this.Scale },
};
}
internal override void SetUpdate(JsonData json, Match match) {
if(json.Keys.Contains("val") && json["val"].Keys.Contains("value") && json.Keys.Contains("sensorTypeString") && json["sensorTypeString"].Keys.Contains("value")) {
String t = json["sensorTypeString"]["value"].ToString();
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 && Math.Abs(l) <= 0.1)) {
return;
}
}
if(json.Keys.Contains("val") && json["val"].Keys.Contains("value") &&
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));
}
}
public override String ToString() {
return "SensorMultilevel " + this.Name + ": " + this.Type + " " + this.Level + "" + this.Scale;
internal override void Poll() => this.PollNone();
#endregion
#region ISenml
protected override List<Senml> ToSenmlList() {
if(this.Scale == "W") {
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>() { };
}
#endregion
}
}
@@ -1,80 +1,128 @@
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 BlubbFish.Utils.IoT.Interfaces.Language;
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 {
#region Properties
private Double _level;
/// <summary>
/// Target-Temperatur
/// </summary>
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);
}
}
}
/// <summary>
/// Scale of the actor
/// </summary>
public String Scale { get; private set; }
public Single TempMax { get; private set; }
public Single TempMin { get; private set; }
/// <summary>
/// Maximum Temperatur of the actor
/// </summary>
public Double TempMax { get; private set; }
/// <summary>
/// Minimum Temperatur of the actor
/// </summary>
public Double TempMin { get; private set; }
/// <summary>
/// Has Maximum and Minimum
/// </summary>
public Boolean HasMinMax { get; private set; }
/// <summary>
/// Type of the actor
/// </summary>
public String Type { get; private set; }
#endregion
public Thermostatsetpointsub(JsonData json, Tuple<Int32, Int32, Int32, Int32> id, HttpConnection http) : base(json, id, http) {
#region Constructor
public Thermostatsetpointsub(JsonData json, Tuple<Int32, Int32, Classes, Int32> id, HttpConnection http, Boolean polling) : base(json, id, http, polling) {
this.IsSub = true;
InitComplex(json);
}
protected override void InitComplex(JsonData json) {
private void InitComplex(JsonData json) {
if (json.Keys.Contains("modeName") && json["modeName"].Keys.Contains("value") &&
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") &&
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;
}
}
#endregion
#region ACommandClass
public override String ToString() {
return "ThermostatSetPoint " + this.Name + " [" + this.Id + "]: " + this.Type + " " + this.Level + "" + this.Scale + " [" + this.TempMin + "," + this.TempMax + "," + this.HasMinMax + "]";
}
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 },
};
}
internal override void SetUpdate(JsonData json, Match match) {
Boolean ret = false;
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));
}
}
public override String ToString() {
return "ThermostatSetPoint " + this.Name + ": " + this.Type + " " + this.Level + "" + this.Scale + " [" + this.TempMin + "," + this.TempMax + "," + this.HasMinMax + "]";
internal override void Poll() => this.PollSub();
#endregion
#region ISenml
protected override List<Senml> ToSenmlList() {
if(this.Scale == "°C") {
return new List<Senml>() { new SenmlDouble("temperatur", Senml.Units.Celsius, this.Level) };
}
return new List<Senml>() { };
}
#endregion
}
}
@@ -0,0 +1,71 @@
using System;
using System.Collections.Generic;
using System.Collections.ObjectModel;
using System.Text.RegularExpressions;
using BlubbFish.IoT.Zway.Devices.CommandClasses.CommandClassSubs;
using BlubbFish.IoT.Zway.Events;
using BlubbFish.IoT.Zway.Interfaces;
using BlubbFish.IoT.Zway.lib;
using BlubbFish.Utils.IoT.Interfaces.Language;
using LitJson;
namespace BlubbFish.IoT.Zway.Devices.CommandClasses {
/// <summary>
/// 112 = Configuration
/// </summary>
class Configuration : ACommandClass {
public override event UpdatedValue Update;
#region Constructor
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, ACommandClass> item in this.Sub) {
item.Value.Update += this.DeviceUpdate;
}
}
private void InitComplex(JsonData json) {
if (json.Keys.Contains("data")) {
JsonData data = json["data"];
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, Classes, Int32>(this.DeviceId, this.Instance, this.Commandclass, subid), this.http, this.Polling));
}
}
this.Sub = new ReadOnlyDictionary<Int32, ACommandClass>(subs);
}
}
private void DeviceUpdate(Object sender, DeviceUpdateEvent e) {
this.Update?.Invoke(this, e);
}
#endregion
#region ACommandClass
internal override void SetUpdate(JsonData json, Match match) {
if (match.Groups[4].Value.StartsWith(".data.")) {
Int32 subid = Int32.Parse(match.Groups[5].Value);
if (this.Sub.ContainsKey(subid)) {
this.Sub[subid].SetUpdate(json, match);
}
} else {
Helper.WriteError("Kenne in " + this.Name + " [" + this.Id + "] " + match.Groups[4].Value + " nicht!");
}
}
internal override void Poll() => this.PollPerSub();
public override Dictionary<String, Object> ToDictionary() => this.ToDictionarySub();
#endregion
#region ISenml
protected override List<Senml> ToSenmlList() => this.ToSenmlListSub();
#endregion
}
}
+54 -14
View File
@@ -1,46 +1,86 @@
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 BlubbFish.Utils.IoT.Interfaces.Language;
using LitJson;
namespace BlubbFish.IoT.Zway.Devices.CommandClasses {
class Indicator : CommandClass {
private Boolean _level;
/// <summary>
/// 135 = Indicator
/// </summary>
class Indicator : ACommandClass {
public override event UpdatedValue Update;
public Boolean Level {
#region Properties
private Boolean _state;
/// <summary>
/// Status of the Indicator
/// </summary>
public Boolean State {
get {
return this._level;
return this._state;
}
set {
this.SetInt(value ? 255 : 0);
}
}
/// <summary>
/// Int-Representation of the Indicator
/// </summary>
public Int32 Level {
get {
return (this.State) ? 1 : 0;
}
set {
this.State = (value == 1);
}
}
#endregion
public Indicator(JsonData json, HttpConnection http, Tuple<Int32, Int32, Int32> id) : base(json, http, id) {
#region Constructor
public Indicator(JsonData json, Tuple<Int32, Int32, Classes> id, HttpConnection http, Boolean polling) : base(json, id, http, polling) {
this.InitComplex(json);
}
protected override void InitComplex(JsonData json) {
if(json.Keys.Contains("data") && json["data"].Keys.Contains("stat") && json["data"]["stat"].Keys.Contains("value")) {
this._level = Int32.Parse(json["data"]["stat"]["value"].ToString()) == 255;
private void InitComplex(JsonData json) {
if (json.Keys.Contains("data") && json["data"].Keys.Contains("stat") && json["data"]["stat"].Keys.Contains("value")) {
this._state = Int32.Parse(json["data"]["stat"]["value"].ToString()) == 255;
}
}
#endregion
#region ACommandClass
public override String ToString() {
return "Indicator " + this.Name + " [" + this.Id + "]: " + this.State;
}
public override Dictionary<String, Object> ToDictionary() {
return new Dictionary<String, Object> {
{ "State", this.State },
{ "Level", this.Level }
};
}
internal override void SetUpdate(JsonData json, Match match) {
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._state = Int32.Parse(json["value"].ToString()) == 255;
this.Update?.Invoke(this, new DeviceUpdateEvent(this.State, this.LastUpdate, this));
}
} else {
throw new NotImplementedException();
Helper.WriteError("Kenne in " + this.Name + " [" + this.Id + "] " + match.Groups[4].Value + " nicht!");
}
}
#endregion
public override String ToString() {
return "Indicator " + this.Name + ": " + this.Level;
#region ISenml
protected override List<Senml> ToSenmlList() {
return new List<Senml>() { new SenmlBool("status", Senml.Units.CounterValue, this.State) };
}
#endregion
}
}
+39 -24
View File
@@ -4,27 +4,49 @@ using System.Collections.ObjectModel;
using System.Text.RegularExpressions;
using BlubbFish.IoT.Zway.Devices.CommandClasses.CommandClassSubs;
using BlubbFish.IoT.Zway.Events;
using BlubbFish.IoT.Zway.Interfaces;
using BlubbFish.IoT.Zway.lib;
using BlubbFish.Utils.IoT.Interfaces.Language;
using LitJson;
namespace BlubbFish.IoT.Zway.Devices.CommandClasses {
public class Meter : CommandClass {
/// <summary>
/// 50 = Meter
/// </summary>
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) : base(json, http, id) {
#region Constructor
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);
private void InitComplex(JsonData json) {
if (json.Keys.Contains("data")) {
JsonData data = json["data"];
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, Classes, Int32>(this.DeviceId, this.Instance, this.Commandclass, subid), this.http, this.Polling));
}
}
this.Sub = new ReadOnlyDictionary<Int32, ACommandClass>(subs);
}
}
private void DeviceUpdate(Object sender, DeviceUpdateEvent e) {
this.Update?.Invoke(this, e);
}
#endregion
#region ACommandClass
internal override void SetUpdate(JsonData json, Match match) {
if (match.Groups[4].Value.StartsWith(".data.")) {
Int32 subid = Int32.Parse(match.Groups[5].Value);
@@ -32,24 +54,17 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses {
this.Sub[subid].SetUpdate(json, match);
}
} else {
throw new NotImplementedException();
Helper.WriteError("Kenne in " + this.Name + " [" + this.Id + "] " + match.Groups[4].Value + " nicht!");
}
}
protected override void InitComplex(JsonData json) {
if (json.Keys.Contains("data")) {
JsonData data = json["data"];
Dictionary<Int32, CommandClassSub> subs = new Dictionary<Int32, CommandClassSub>();
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.Sub = new ReadOnlyDictionary<Int32, CommandClassSub>(subs);
}
}
internal override void Poll() => this.PollSubGlobal();
public override Dictionary<String, Object> ToDictionary() => this.ToDictionarySub();
#endregion
#region ISenml
protected override List<Senml> ToSenmlList() => this.ToSenmlListSub();
#endregion
}
}
@@ -0,0 +1,69 @@
using System;
using System.Collections.Generic;
using System.Collections.ObjectModel;
using System.Text.RegularExpressions;
using BlubbFish.IoT.Zway.Devices.CommandClasses.CommandClassSubs;
using BlubbFish.IoT.Zway.Events;
using BlubbFish.IoT.Zway.Interfaces;
using BlubbFish.IoT.Zway.lib;
using BlubbFish.Utils.IoT.Interfaces.Language;
using LitJson;
namespace BlubbFish.IoT.Zway.Devices.CommandClasses {
/// <summary>
/// 50 = Meter
/// </summary>
public class Scenecontrollerconf : ACommandClass {
public override event UpdatedValue Update;
#region Constructor
public Scenecontrollerconf(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, ACommandClass> item in this.Sub) {
item.Value.Update += this.DeviceUpdate;
}
}
private void InitComplex(JsonData json) {
if (json.Keys.Contains("data")) {
JsonData data = json["data"];
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("scene") &&
data[item].Keys.Contains("duration")) {
subs.Add(subid, new Scenecontrollerconfsub(data[item], new Tuple<Int32, Int32, Classes, Int32>(this.DeviceId, this.Instance, this.Commandclass, subid), this.http, this.Polling));
}
}
this.Sub = new ReadOnlyDictionary<Int32, ACommandClass>(subs);
}
}
private void DeviceUpdate(Object sender, DeviceUpdateEvent e) {
this.Update?.Invoke(this, e);
}
#endregion
#region ACommandClass
internal override void SetUpdate(JsonData json, Match match) {
if (match.Groups[4].Value.StartsWith(".data.")) {
Int32 subid = Int32.Parse(match.Groups[5].Value);
if (this.Sub.ContainsKey(subid)) {
this.Sub[subid].SetUpdate(json, match);
}
} else {
Helper.WriteError("Kenne in " + this.Name + " [" + this.Id + "] " + match.Groups[4].Value + " nicht!");
}
}
internal override void Poll() => this.PollPerSub();
public override Dictionary<String, Object> ToDictionary() => this.ToDictionarySub();
#endregion
#region ISenml
protected override List<Senml> ToSenmlList() => this.ToSenmlListSub();
#endregion
}
}
@@ -0,0 +1,69 @@
using System;
using System.Collections.Generic;
using System.Collections.ObjectModel;
using System.Text.RegularExpressions;
using BlubbFish.IoT.Zway.Devices.CommandClasses.CommandClassSubs;
using BlubbFish.IoT.Zway.Events;
using BlubbFish.IoT.Zway.Interfaces;
using BlubbFish.IoT.Zway.lib;
using BlubbFish.Utils.IoT.Interfaces.Language;
using LitJson;
namespace BlubbFish.IoT.Zway.Devices.CommandClasses {
/// <summary>
/// 48 = SensorBinary
/// </summary>
public class Sensorbinary : ACommandClass {
public override event UpdatedValue Update;
#region Constructor
public Sensorbinary(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, ACommandClass> item in this.Sub) {
item.Value.Update += this.DeviceUpdate;
}
}
private void InitComplex(JsonData json) {
if (json.Keys.Contains("data")) {
JsonData data = json["data"];
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("level")) {
subs.Add(subid, new Sensorbinarysub(data[item], new Tuple<Int32, Int32, Classes, Int32>(this.DeviceId, this.Instance, this.Commandclass, subid), this.http, this.Polling));
}
}
this.Sub = new ReadOnlyDictionary<Int32, ACommandClass>(subs);
}
}
private void DeviceUpdate(Object sender, DeviceUpdateEvent e) {
this.Update?.Invoke(this, e);
}
#endregion
#region ACommandClass
internal override void SetUpdate(JsonData json, Match match) {
if (match.Groups[4].Value.StartsWith(".data.")) {
Int32 subid = Int32.Parse(match.Groups[5].Value);
if (this.Sub.ContainsKey(subid)) {
this.Sub[subid].SetUpdate(json, match);
}
} else {
Helper.WriteError("Kenne in " + this.Name + " [" + this.Id + "] " + match.Groups[4].Value + " nicht!");
}
}
internal override void Poll() => this.PollSubGlobal();
public override Dictionary<String, Object> ToDictionary() => this.ToDictionarySub();
#endregion
#region ISenml
protected override List<Senml> ToSenmlList() => this.ToSenmlListSub();
#endregion
}
}
+39 -24
View File
@@ -4,27 +4,49 @@ using System.Collections.ObjectModel;
using System.Text.RegularExpressions;
using BlubbFish.IoT.Zway.Devices.CommandClasses.CommandClassSubs;
using BlubbFish.IoT.Zway.Events;
using BlubbFish.IoT.Zway.Interfaces;
using BlubbFish.IoT.Zway.lib;
using BlubbFish.Utils.IoT.Interfaces.Language;
using LitJson;
namespace BlubbFish.IoT.Zway.Devices.CommandClasses {
public class Sensormultilevel : CommandClass {
/// <summary>
/// 49 = SensorMultilevel
/// </summary>
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) : base(json, http, id) {
#region Constructor
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);
private void InitComplex(JsonData json) {
if (json.Keys.Contains("data")) {
JsonData data = json["data"];
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, Classes, Int32>(this.DeviceId, this.Instance, this.Commandclass, subid), this.http, this.Polling));
}
}
this.Sub = new ReadOnlyDictionary<Int32, ACommandClass>(subs);
}
}
private void DeviceUpdate(Object sender, DeviceUpdateEvent e) {
this.Update?.Invoke(this, e);
}
#endregion
#region ACommandClass
internal override void SetUpdate(JsonData json, Match match) {
if (match.Groups[4].Value.StartsWith(".data.")) {
Int32 subid = Int32.Parse(match.Groups[5].Value);
@@ -32,24 +54,17 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses {
this.Sub[subid].SetUpdate(json, match);
}
} else {
throw new NotImplementedException();
Helper.WriteError("Kenne in " + this.Name + " [" + this.Id + "] " + match.Groups[4].Value + " nicht!");
}
}
protected override void InitComplex(JsonData json) {
if (json.Keys.Contains("data")) {
JsonData data = json["data"];
Dictionary<Int32, CommandClassSub> subs = new Dictionary<Int32, CommandClassSub>();
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.Sub = new ReadOnlyDictionary<Int32, CommandClassSub>(subs);
}
}
internal override void Poll() => this.PollSubGlobal();
public override Dictionary<String, Object> ToDictionary() => this.ToDictionarySub();
#endregion
#region ISenml
protected override List<Senml> ToSenmlList() => this.ToSenmlListSub();
#endregion
}
}
+55 -17
View File
@@ -1,47 +1,85 @@
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 BlubbFish.Utils.IoT.Interfaces.Language;
using LitJson;
namespace BlubbFish.IoT.Zway.Devices.CommandClasses {
public class Switchbinary : CommandClass {
private Boolean _level;
/// <summary>
/// 37 = SwitchBinary
/// </summary>
public class Switchbinary : ACommandClass {
public override event UpdatedValue Update;
public Boolean Level {
#region Properties
/// <summary>
/// Int representation of Boolean
/// </summary>
public Int32 Level {
get {
return this._level;
return (this.State) ? 1 : 0;
}
set {
this.State = (value == 1);
}
}
private Boolean _state;
/// <summary>
/// State if Switch is activated
/// </summary>
public Boolean State {
get {
return this._state;
}
set {
this.SetInt(value ? 255 : 0);
}
}
#endregion
public Switchbinary(JsonData json, HttpConnection http, Tuple<Int32, Int32, Int32> id) : base(json, http, id) {
#region Constructor
public Switchbinary(JsonData json, Tuple<Int32, Int32, Classes> id, HttpConnection http, Boolean polling) : base(json, id, http, polling) {
this.InitComplex(json);
}
private void InitComplex(JsonData json) {
if (json.Keys.Contains("data") && json["data"].Keys.Contains("level") && json["data"]["level"].Keys.Contains("value") && json["data"]["level"]["value"].IsBoolean) {
this._state = (Boolean)json["data"]["level"]["value"];
}
}
#endregion
#region ACommandClass
public override String ToString() {
return "SwitchBinary " + this.Name + " [" + this.Id + "]: " + this.State;
}
public override Dictionary<String, Object> ToDictionary() {
return new Dictionary<String, Object> {
{ "State", this.State },
{ "Level", this.Level }
};
}
internal override void SetUpdate(JsonData json, Match match) {
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._state = (Boolean)json["value"];
this.Update?.Invoke(this, new DeviceUpdateEvent(this.State, this.LastUpdate, this));
}
} else {
throw new NotImplementedException();
Helper.WriteError("Kenne in " + this.Name + " [" + this.Id + "] " + match.Groups[4].Value + " nicht!");
}
}
#endregion
protected override void InitComplex(JsonData json) {
if (json.Keys.Contains("data") && json["data"].Keys.Contains("level") && json["data"]["level"].Keys.Contains("value") && json["data"]["level"]["value"].IsBoolean) {
this._level = (Boolean)json["data"]["level"]["value"];
}
}
public override String ToString() {
return "SwitchBinary " + this.Name + ": " + this.Level;
#region ISenml
protected override List<Senml> ToSenmlList() {
return new List<Senml>() { new SenmlBool("state", Senml.Units.CounterValue, this.State) };
}
#endregion
}
}
+41 -15
View File
@@ -1,50 +1,76 @@
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 BlubbFish.Utils.IoT.Interfaces.Language;
using LitJson;
namespace BlubbFish.IoT.Zway.Devices.CommandClasses {
public class Switchmultilevel : CommandClass {
private Int32 _level;
/// <summary>
/// 38 = SwitchMultilevel
/// </summary>
public class Switchmultilevel : ACommandClass {
public override event UpdatedValue Update;
#region Properties
private Int32 _level;
/// <summary>
/// Level of thw Switch
/// </summary>
public Int32 Level {
get {
return this._level;
}
set {
if(value == 0 || (value > 0 && value <= 99) || value == 255) {
this.SetIntTuple(value, 0);
this.SetTuple(value, 0);
}
}
}
#endregion
public Switchmultilevel(JsonData json, HttpConnection http, Tuple<Int32, Int32, Int32> id) : base(json, http, id) {
#region Constructor
public Switchmultilevel(JsonData json, Tuple<Int32, Int32, Classes> id, HttpConnection http, Boolean polling) : base(json, id, http, polling) {
this.InitComplex(json);
}
private void InitComplex(JsonData json) {
if (json.Keys.Contains("data") && json["data"].Keys.Contains("level") && json["data"]["level"].Keys.Contains("value")) {
this._level = Int32.Parse(json["data"]["level"]["value"].ToString());
}
}
#endregion
#region ACommandClass
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 }
};
}
internal override void SetUpdate(JsonData json, Match match) {
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 {
throw new NotImplementedException();
Helper.WriteError("Kenne in " + this.Name + " [" + this.Id + "] " + match.Groups[4].Value + " nicht!");
}
}
#endregion
protected override void InitComplex(JsonData json) {
if(json.Keys.Contains("data") && json["data"].Keys.Contains("level") && json["data"]["level"].Keys.Contains("value")) {
this._level = Int32.Parse(json["data"]["level"]["value"].ToString());
}
}
public override String ToString() {
return "SwitchMultilevel " + this.Name + ": " + this.Level;
#region ISenml
protected override List<Senml> ToSenmlList() {
return new List<Senml>() { new SenmlDouble("state", Senml.Units.Percent, (Double)this.Level/255) };
}
#endregion
}
}
+51 -17
View File
@@ -3,16 +3,27 @@ using System.Collections.Generic;
using System.Collections.ObjectModel;
using System.Text.RegularExpressions;
using BlubbFish.IoT.Zway.Events;
using BlubbFish.IoT.Zway.Interfaces;
using BlubbFish.IoT.Zway.lib;
using BlubbFish.Utils.IoT.Interfaces.Language;
using LitJson;
namespace BlubbFish.IoT.Zway.Devices.CommandClasses {
public class Thermostatmode : CommandClass {
private Int32 _level;
/// <summary>
/// 64 = ThermostatMode
/// </summary>
public class Thermostatmode : ACommandClass {
public override event UpdatedValue Update;
#region Properties
/// <summary>
/// Allowd Modes
/// </summary>
public ReadOnlyDictionary<Int32, String> ValidModes { get; private set; }
private Int32 _level;
/// <summary>
/// Actual mode
/// </summary>
public Int32 Level {
get { return this._level; }
set {
@@ -21,24 +32,15 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses {
}
}
}
#endregion
public Thermostatmode(JsonData json, HttpConnection http, Tuple<Int32, Int32, Int32> id) : base(json, http, id) {
#region Constructor
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);
}
internal override void SetUpdate(JsonData json, Match match) {
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));
}
} else {
throw new NotImplementedException();
}
}
protected override void InitComplex(JsonData json) {
private void InitComplex(JsonData json) {
if (json.Keys.Contains("data")) {
JsonData data = json["data"];
Dictionary<Int32, String> modes = new Dictionary<Int32, String>();
@@ -56,9 +58,41 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses {
}
}
}
#endregion
#region ACommandClass
public override String ToString() {
return "ThermostatMode " + this.Name + ": " + this.ValidModes[this.Level];
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;
}
internal override void SetUpdate(JsonData json, Match match) {
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));
}
} else {
Helper.WriteError("Kenne in " + this.Name + " [" + this.Id + "] " + match.Groups[4].Value + " nicht!");
}
}
#endregion
#region ISenml
protected override List<Senml> ToSenmlList() {
return new List<Senml>() { new SenmlDouble("mode", Senml.Units.CounterValue, this.Level) };
}
#endregion
}
}
@@ -4,26 +4,49 @@ using System.Collections.ObjectModel;
using System.Text.RegularExpressions;
using BlubbFish.IoT.Zway.Devices.CommandClasses.CommandClassSubs;
using BlubbFish.IoT.Zway.Events;
using BlubbFish.IoT.Zway.Interfaces;
using BlubbFish.IoT.Zway.lib;
using BlubbFish.Utils.IoT.Interfaces.Language;
using LitJson;
namespace BlubbFish.IoT.Zway.Devices.CommandClasses {
public class Thermostatsetpoint : CommandClass {
/// <summary>
/// 67 = ThermostatSetPoint
/// </summary>
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) : base(json, http, id) {
#region Constructor
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);
private void InitComplex(JsonData json) {
if (json.Keys.Contains("data")) {
JsonData data = json["data"];
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, Classes, Int32>(this.DeviceId, this.Instance, this.Commandclass, subid), this.http, this.Polling));
}
}
this.Sub = new ReadOnlyDictionary<Int32, ACommandClass>(subs);
}
}
private void DeviceUpdate(Object sender, DeviceUpdateEvent e) {
this.Update?.Invoke(this, e);
}
#endregion
#region ACommandClass
internal override void SetUpdate(JsonData json, Match match) {
if (match.Groups[4].Value.StartsWith(".data.")) {
Int32 subid = Int32.Parse(match.Groups[5].Value);
@@ -31,30 +54,17 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses {
this.Sub[subid].SetUpdate(json, match);
}
} else {
throw new NotImplementedException();
Helper.WriteError("Kenne in " + this.Name + " [" + this.Id + "] " + match.Groups[4].Value + " nicht!");
}
}
protected override void InitComplex(JsonData json) {
if (json.Keys.Contains("data")) {
JsonData data = json["data"];
Dictionary<Int32, CommandClassSub> subs = new Dictionary<Int32, CommandClassSub>();
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.Sub = new ReadOnlyDictionary<Int32, CommandClassSub>(subs);
}
}
internal override void Poll() => this.PollPerSub();
internal override void Poll() {
foreach (KeyValuePair<Int32, CommandClassSub> item in this.Sub) {
this.http.GetVoid("ZWave.zway/Run/devices[" + this.DeviceId + "].instances[" + this.Instance + "].commandClasses[" + this.Commandclass + "].Get(" + item.Key + ")");
}
}
public override Dictionary<String, Object> ToDictionary() => this.ToDictionarySub();
#endregion
#region ISenml
protected override List<Senml> ToSenmlList() => this.ToSenmlListSub();
#endregion
}
}
+70 -26
View File
@@ -1,48 +1,57 @@
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Text.RegularExpressions;
using System.Threading.Tasks;
using BlubbFish.IoT.Zway.Events;
using BlubbFish.IoT.Zway.Interfaces;
using BlubbFish.IoT.Zway.lib;
using BlubbFish.Utils.IoT.Interfaces.Language;
using LitJson;
namespace BlubbFish.IoT.Zway.Devices.CommandClasses {
class Wakeup : CommandClass {
private Int32 _interval;
private Int32 _againstNode;
/// <summary>
/// 132 = Wakeup
/// </summary>
class Wakeup : ACommandClass {
public override event UpdatedValue Update;
#region Properties
private Int32 _interval;
public Int32 Interval {
get {
return this._interval;
}
set {
if(value >= this.WakeupMin && value <= this.WakeupMax) {
this.SetIntTuple(value, this.AgainstNode);
this.SetTuple(value, this.AgainstNode);
}
}
}
private Int32 _againstNode;
public Int32 AgainstNode { get {
return this._againstNode;
}
set {
this.SetIntTuple(this.Interval, value);
this.SetTuple(this.Interval, value);
}
}
public Int32 WakeupMin { get; private set; }
public Int32 WakeupMax { get; private set; }
public Boolean HasMinMaxState { get; private set; }
public Int32 HasMinMaxLevel { get { return (this.HasMinMaxState) ? 1 : 0; } }
public Int32 WakeupDefault { get; private set; }
public Boolean HasDefaultState { get; private set; }
public Int32 HasDefaultLevel { get { return (this.HasDefaultState) ? 1 : 0; } }
public DateTime LastWakeup { get; private set; }
public DateTime LastSleep { get; private set; }
#endregion
public Wakeup(JsonData json, HttpConnection http, Tuple<Int32, Int32, Int32> id) : base(json, http, id) {
#region Constructor
public Wakeup(JsonData json, Tuple<Int32, Int32, Classes> id, HttpConnection http, Boolean polling) : base(json, id, http, polling) {
this.InitComplex(json);
}
protected override void InitComplex(JsonData json) {
if(json.Keys.Contains("data")) {
private void InitComplex(JsonData json) {
if (json.Keys.Contains("data")) {
JsonData data = json["data"];
if(data.Keys.Contains("interval") && data["interval"].Keys.Contains("value")) {
this._interval = Int32.Parse(data["interval"]["value"].ToString());
@@ -50,23 +59,50 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses {
if (data.Keys.Contains("nodeId") && data["nodeId"].Keys.Contains("value")) {
this._againstNode = Int32.Parse(data["nodeId"]["value"].ToString());
}
if (data.Keys.Contains("min") && data["min"].Keys.Contains("value")) {
this.HasMinMaxState = false;
if (data.Keys.Contains("min") && data["min"].Keys.Contains("value") && data["min"]["value"] != null) {
this.WakeupMin = Int32.Parse(data["min"]["value"].ToString());
this.HasMinMaxState = true;
}
if (data.Keys.Contains("max") && data["max"].Keys.Contains("value")) {
if (data.Keys.Contains("max") && data["max"].Keys.Contains("value") && data["max"]["value"] != null) {
this.WakeupMax = Int32.Parse(data["max"]["value"].ToString());
this.HasMinMaxState = true;
}
if (data.Keys.Contains("default") && data["default"].Keys.Contains("value")) {
this.HasDefaultState = false;
if (data.Keys.Contains("default") && data["default"].Keys.Contains("value") && data["default"]["value"] != null) {
this.WakeupDefault = Int32.Parse(data["default"]["value"].ToString());
this.HasDefaultState = true;
}
if (data.Keys.Contains("lastWakeup") && data["lastWakeup"].Keys.Contains("value")) {
if (data.Keys.Contains("lastWakeup") && data["lastWakeup"].Keys.Contains("value") && data["lastWakeup"]["value"] != null) {
this.LastWakeup = DateTimeOffset.FromUnixTimeSeconds(Int64.Parse(data["lastWakeup"]["value"].ToString())).DateTime.ToLocalTime();
}
if (data.Keys.Contains("lastSleep") && data["lastSleep"].Keys.Contains("value")) {
if (data.Keys.Contains("lastSleep") && data["lastSleep"].Keys.Contains("value") && data["lastSleep"]["value"] != null) {
this.LastSleep = DateTimeOffset.FromUnixTimeSeconds(Int64.Parse(data["lastSleep"]["value"].ToString())).DateTime.ToLocalTime();
}
}
}
#endregion
#region ACommandClass
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 },
{ "HasMinMaxState", this.HasMinMaxState },
{ "HasMinMaxLevel", this.HasMinMaxLevel },
{ "WakeupDefault", this.WakeupDefault },
{ "HasDefaultState", this.HasDefaultState },
{ "HasDefaultLevel", this.HasDefaultLevel },
{ "LastWakeup", this.LastWakeup.ToString() },
{ "LastSleep", this.LastSleep.ToString() }
};
}
internal override void SetUpdate(JsonData json, Match match) {
Boolean success = false;
@@ -89,36 +125,44 @@ namespace BlubbFish.IoT.Zway.Devices.CommandClasses {
this._againstNode = Int32.Parse(json["nodeId"]["value"].ToString());
success = true;
}
if (json.Keys.Contains("min") && json["min"].Keys.Contains("value")) {
this.HasMinMaxState = false;
if (json.Keys.Contains("min") && json["min"].Keys.Contains("value") && json["min"]["value"] != null) {
this.WakeupMin = Int32.Parse(json["min"]["value"].ToString());
success = true;
this.HasMinMaxState = true;
}
if (json.Keys.Contains("max") && json["max"].Keys.Contains("value")) {
if (json.Keys.Contains("max") && json["max"].Keys.Contains("value") && json["max"]["value"] != null) {
this.WakeupMax = Int32.Parse(json["max"]["value"].ToString());
success = true;
this.HasMinMaxState = true;
}
if (json.Keys.Contains("default") && json["default"].Keys.Contains("value")) {
this.HasDefaultState = false;
if (json.Keys.Contains("default") && json["default"].Keys.Contains("value") && json["default"]["value"] != null) {
this.WakeupDefault = Int32.Parse(json["default"]["value"].ToString());
success = true;
this.HasDefaultState = true;
}
if (json.Keys.Contains("lastWakeup") && json["lastWakeup"].Keys.Contains("value")) {
if (json.Keys.Contains("lastWakeup") && json["lastWakeup"].Keys.Contains("value") && json["lastWakeup"]["value"] != null) {
this.LastWakeup = DateTimeOffset.FromUnixTimeSeconds(Int64.Parse(json["lastWakeup"]["value"].ToString())).DateTime.ToLocalTime();
success = true;
}
if (json.Keys.Contains("lastSleep") && json["lastSleep"].Keys.Contains("value")) {
if (json.Keys.Contains("lastSleep") && json["lastSleep"].Keys.Contains("value") && json["lastSleep"]["value"] != null) {
this.LastSleep = DateTimeOffset.FromUnixTimeSeconds(Int64.Parse(json["lastSleep"]["value"].ToString())).DateTime.ToLocalTime();
success = true;
}
} else {
throw new NotImplementedException();
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));
}
}
#endregion
public override String ToString() {
return "Wakeup " + this.Name + ": " + this.LastWakeup + "-" + this.LastSleep + " " + this.Interval + " [" + this.WakeupMin + "," + this.WakeupMax + "," + this.WakeupDefault + "," + this.AgainstNode + "]";
#region ISenml
protected override List<Senml> ToSenmlList() {
return new List<Senml>() { };
}
#endregion
}
}
+20 -19
View File
@@ -1,30 +1,27 @@
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Collections.ObjectModel;
using System.Text.RegularExpressions;
using System.Threading.Tasks;
using BlubbFish.IoT.Zway.Events;
using BlubbFish.IoT.Zway.lib;
using LitJson;
namespace BlubbFish.IoT.Zway.Devices {
class Device {
private Dictionary<Int32, Instance> _instances = new Dictionary<Int32, Instance>();
public class Device {
private Boolean polling;
public delegate void UpdatedDevice(Object sender, DeviceUpdateEvent e);
public event UpdatedDevice Update;
public String Name { get; }
public Int32 Id { get; }
public Dictionary<Int32, Instance> Instances { get { return this._instances; } }
public ReadOnlyDictionary<Int32, Instance> Instances { get; private set; }
public DateTime LastUpdate { get; private set; }
private Device(JsonData json, Tuple<Int32> id, HttpConnection http) {
private Device(JsonData json, Tuple<Int32> id, HttpConnection http, Boolean polling) {
this.Id = id.Item1;
foreach (String instanceid in json["instances"].Keys) {
this.CreateInstances(Int32.Parse(instanceid), json["instances"][instanceid], http);
}
this.polling = polling;
this.CreateInstances(json["instances"], http);
if (json["data"].Keys.Contains("givenName") && json["data"]["givenName"].Keys.Contains("value")) {
this.Name = json["data"]["givenName"]["value"].ToString();
} else {
@@ -50,33 +47,37 @@ 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(Int32 instanceid, JsonData json, HttpConnection http) {
Instance i = Instance.CreateInstance(json, new Tuple<Int32, Int32>(this.Id, instanceid), http);
if (i != null) {
this._instances.Add(instanceid, i);
private void CreateInstances(JsonData json, HttpConnection http) {
Dictionary<Int32, Instance> instances = new Dictionary<Int32, Instance>();
foreach (String instanceid in json.Keys) {
Instance i = Instance.CreateInstance(json[instanceid], new Tuple<Int32, Int32>(this.Id, Int32.Parse(instanceid)), http, this.polling);
if (i != null) {
instances.Add(Int32.Parse(instanceid), i);
}
}
this.Instances = new ReadOnlyDictionary<Int32, Instance>(instances);
}
internal static Device CreateDevice(JsonData json, Tuple<Int32> id, HttpConnection http) {
internal static Device CreateDevice(JsonData json, Tuple<Int32> id, HttpConnection http, Boolean polling) {
if(json.Keys.Contains("instances") &&
json["instances"].Count > 0 &&
json.Keys.Contains("data") && id.Item1 != 1) {
return new Device(json, id, http);
return new Device(json, id, http, polling);
}
return null;
}
public override String ToString() {
return this.Name+"_"+this.Id+" ["+this._instances.Count+"]";
return this.Name+"_"+this.Id+" ["+this.Instances.Count+"]";
}
internal void SetUpdate(JsonData json, Match match) {
if (match.Groups[2].Value == "data.lastReceived") {
if (this.CheckSetUpdateTime(json)) {
this.Update?.Invoke(this, new DeviceUpdateEvent(this.LastUpdate, this.LastUpdate));
//this.Update?.Invoke(this, new DeviceUpdateEvent(this.LastUpdate, this.LastUpdate));
}
}
}
+28 -24
View File
@@ -1,71 +1,75 @@
using System;
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;
namespace BlubbFish.IoT.Zway.Devices {
class Instance {
private Dictionary<Int32, CommandClass> _commands = new Dictionary<Int32, CommandClass>();
public class Instance {
private DateTime nextwakeup;
private Boolean polling;
public delegate void UpdatedInstance(Object sender, DeviceUpdateEvent e);
public event UpdatedInstance Update;
public Dictionary<Int32, CommandClass> CommandClasses { get { return this._commands; } }
public Int32 DeviceId { get; }
public Int32 InstanceId { get; }
public ReadOnlyDictionary<ACommandClass.Classes, ACommandClass> CommandClasses { get; private set; }
private Instance(JsonData json, Tuple<Int32, Int32> id, HttpConnection http) {
this.Id = id.Item1;
this.Instanceid = id.Item2;
foreach (String commandid in json["commandClasses"].Keys) {
this.CreateInstances(Int32.Parse(commandid), json["commandClasses"][commandid], http);
}
foreach (KeyValuePair<Int32, CommandClass> item in this.CommandClasses) {
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<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(Int32 commandid, JsonData json, HttpConnection http) {
CommandClass c = CommandClass.CreateInstance(json, new Tuple<Int32, Int32, Int32>(this.Id, this.Instanceid, commandid), http);
if (c != null) {
this._commands.Add(commandid, c);
private void CreateInstances(JsonData json, HttpConnection http) {
Dictionary<ACommandClass.Classes, ACommandClass> commands = new Dictionary<ACommandClass.Classes, ACommandClass>();
foreach (String commandid in json.Keys) {
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((ACommandClass.Classes)Int32.Parse(commandid), c);
}
}
this.CommandClasses = new ReadOnlyDictionary<ACommandClass.Classes, ACommandClass>(commands);
}
public Int32 Id { get; }
public Int32 Instanceid { get; }
internal static Instance CreateInstance(JsonData json, Tuple<Int32, Int32> id, HttpConnection http) {
internal static Instance CreateInstance(JsonData json, Tuple<Int32, Int32> id, HttpConnection http, Boolean polling) {
if (json.Keys.Contains("commandClasses") &&
json["commandClasses"].Count > 0 &&
json.Keys.Contains("data")) {
return new Instance(json, id, http);
return new Instance(json, id, http, polling);
}
return null;
}
public override String ToString() {
return "Instance: " + this.Id + "-" + this.Instanceid + " [" + this._commands.Count + "]";
return "Instance: " + this.DeviceId + "-" + this.InstanceId + " [" + this.CommandClasses.Count + "]";
}
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();
}
}
+5 -32
View File
@@ -10,41 +10,14 @@ namespace BlubbFish.IoT.Zway.Events {
public DeviceUpdateEvent() {
}
public DeviceUpdateEvent(Single value, DateTime time) {
this.GetSingle = value;
public DeviceUpdateEvent(Object value, DateTime time, Object parent) {
this.GetValue = value;
this.UpdateTime = time;
this.Parent = parent;
}
public DeviceUpdateEvent(Boolean level, DateTime time) {
this.GetBoolean = level;
this.UpdateTime = time;
}
public DeviceUpdateEvent(DateTime value, DateTime time) {
this.GetDate = value;
this.UpdateTime = time;
}
public DeviceUpdateEvent(Tuple<String, String, Single> value, DateTime time) {
this.GetStringStringSingleTuple = value;
this.UpdateTime = time;
}
public DeviceUpdateEvent(Tuple<String, String, Single, Single, Single, Boolean> value, DateTime time) {
this.GetStringStringSingleSingleSingleSingleBooleanTuple = value;
this.UpdateTime = time;
}
public DeviceUpdateEvent(Tuple<Int32, Int32> value, DateTime time) {
this.GetIntegerTuple = value;
this.UpdateTime = time;
}
public Single GetSingle { get; }
public DateTime GetDate { get; }
public Tuple<String, String, Single> GetStringStringSingleTuple { get; }
public Tuple<String, String, Single, Single, Single, Boolean> GetStringStringSingleSingleSingleSingleBooleanTuple { get; }
public Object GetValue { get; }
public DateTime UpdateTime { get; }
public Boolean GetBoolean { get; }
public Tuple<Int32,Int32> GetIntegerTuple { get; }
public Object Parent { get; private set; }
}
}
+1 -4
View File
@@ -1,11 +1,8 @@
using System;
using System.Collections.Generic;
using System.Linq;
using System.Runtime.Serialization;
using System.Text;
using System.Threading.Tasks;
namespace BlubbFish.IoT.Zway.Exceptions {
[Serializable]
public class ConnectionException : Exception {
public ConnectionException() { }
public ConnectionException(String message) : base(message) { }
+282
View File
@@ -0,0 +1,282 @@
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 BlubbFish.Utils.IoT.Interfaces;
using BlubbFish.Utils.IoT.Interfaces.Language;
using LitJson;
namespace BlubbFish.IoT.Zway.Interfaces {
public abstract class ACommandClass : IMqtt, ISenml {
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,
SwitchAll = 39,
SceneActivation = 43,
SwitchColor = 51,
MeterPulse = 53,
MeterTableMonitor = 61,
ThermostatOperatingState = 66,
CRC16 = 86,
AssociationGroupInformation = 89,
DeviceResetLocally = 90,
ZWavePlusInfo = 94,
MultiChannel = 96,
DoorLock = 98,
ManufacturerSpecific = 114,
PowerLevel = 115,
InclusionController = 116,
Protection = 117,
NodeNaming = 119,
FirmwareUpdate = 122,
Association = 133,
Version = 134,
Proprietary = 136,
TimeParameters = 139,
MultiChannelAssociation = 142,
MultiCmd = 143,
Security = 152
}
public enum Classes : Int32 {
SwitchBinary = 37,
SwitchMultilevel = 38,
SceneControllerConf = 45,
SensorBinary = 48,
SensorMultilevel = 49,
Meter = 50,
ThermostatMode = 64,
ThermostatSetPoint = 67,
CentralScene = 91,
Configuration = 112,
Alarm = 113,
Battery = 128,
Wakeup = 132,
Indicator = 135,
AlarmSensor = 156
}
#region Properties
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; }
#endregion
#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. (" + id.Item1 + ", " + id.Item2 + ")");
}
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 InternalHelper
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;
}
protected List<Senml> ToSenmlListSub() {
List<Senml> list = new List<Senml>();
foreach (KeyValuePair<Int32, ACommandClass> item in this.Sub) {
list.AddRange(item.Value.ToSenmlList());
}
return list;
}
#endregion
#region IMqtt
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("LastUpdate", this.LastUpdate.ToString());
json.Add("Name", this.Name);
json.Add("Commandclass", this.Commandclass.ToString());
return JsonMapper.ToJson(json);
}
#endregion
#region ISenml
public String ToSenml() {
List<Senml> l = this.ToSenmlList();
if(l.Count == 0) {
return null;
}
Dictionary<String, Object> json = new Dictionary<String, Object> {
{ "e", l },
{ "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 "LS/v2/ZGW/";
}
#endregion
#region Abstract
protected abstract List<Senml> ToSenmlList();
public abstract Dictionary<String, Object> ToDictionary();
internal abstract void SetUpdate(JsonData json, Match match);
#endregion
}
}
+3 -3
View File
@@ -10,7 +10,7 @@ using System.Runtime.InteropServices;
[assembly: AssemblyConfiguration("")]
[assembly: AssemblyCompany("")]
[assembly: AssemblyProduct("Zway")]
[assembly: AssemblyCopyright("Copyright © 2017")]
[assembly: AssemblyCopyright("Copyright © 2017 - 03.05.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.0.0.0")]
[assembly: AssemblyFileVersion("1.0.0.0")]
[assembly: AssemblyVersion("1.4.4")]
[assembly: AssemblyFileVersion("1.4.4")]
+21 -8
View File
@@ -9,8 +9,9 @@
<AppDesignerFolder>Properties</AppDesignerFolder>
<RootNamespace>BlubbFish.IoT.Zway</RootNamespace>
<AssemblyName>Zway</AssemblyName>
<TargetFrameworkVersion>v4.6.1</TargetFrameworkVersion>
<TargetFrameworkVersion>v4.7.1</TargetFrameworkVersion>
<FileAlignment>512</FileAlignment>
<TargetFrameworkProfile />
</PropertyGroup>
<PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Debug|AnyCPU' ">
<DebugSymbols>true</DebugSymbols>
@@ -30,9 +31,6 @@
<WarningLevel>4</WarningLevel>
</PropertyGroup>
<ItemGroup>
<Reference Include="LitJson, Version=0.9.0.0, Culture=neutral, processorArchitecture=MSIL">
<HintPath>..\..\IoT-Bot\packages\LitJson.0.9.0\lib\LitJson.dll</HintPath>
</Reference>
<Reference Include="System" />
<Reference Include="System.Core" />
<Reference Include="System.Xml.Linq" />
@@ -43,16 +41,24 @@
<Reference Include="System.Xml" />
</ItemGroup>
<ItemGroup>
<Compile Include="Devices\CommandClasses\Alarm.cs" />
<Compile Include="Devices\CommandClasses\Battery.cs" />
<Compile Include="Devices\CommandClass.cs" />
<Compile Include="Devices\CommandClasses\CommandClassSubs\Configurationsub.cs" />
<Compile Include="Devices\CommandClasses\CommandClassSubs\Alarmsensorsub.cs" />
<Compile Include="Devices\CommandClasses\CommandClassSubs\SceneControllerConfSub.cs" />
<Compile Include="Devices\CommandClasses\CommandClassSubs\SensorBinarySub.cs" />
<Compile Include="Devices\CommandClasses\CommandClassSubs\ThermostatSetPointSub.cs" />
<Compile Include="Devices\CommandClasses\Configuration.cs" />
<Compile Include="Devices\CommandClasses\Indicator.cs" />
<Compile Include="Devices\CommandClasses\AlarmSensor.cs" />
<Compile Include="Devices\CommandClasses\Meter.cs" />
<Compile Include="Devices\CommandClasses\CommandClassSubs\MeterSub.cs" />
<Compile Include="Devices\CommandClasses\CommandClassSubs\SensorMultilevelSub.cs" />
<Compile Include="Devices\CommandClasses\SceneControllerConf.cs" />
<Compile Include="Devices\CommandClasses\SensorBinary.cs" />
<Compile Include="Devices\CommandClasses\Wakeup.cs" />
<Compile Include="Devices\CommandClassSub.cs" />
<Compile Include="Devices\Device.cs" />
<Compile Include="Interfaces\ACommandClass.cs" />
<Compile Include="Devices\Instance.cs" />
<Compile Include="Devices\CommandClasses\CentralScene.cs" />
<Compile Include="Devices\CommandClasses\SensorMultilevel.cs" />
@@ -62,13 +68,20 @@
<Compile Include="Devices\CommandClasses\ThermostatSetPoint.cs" />
<Compile Include="Events\DeviceUpdateEvent.cs" />
<Compile Include="Exceptions\ZwayExceptions.cs" />
<Compile Include="lib\Helper.cs" />
<Compile Include="lib\HttpClient.cs" />
<Compile Include="ZwayController.cs" />
<Compile Include="Properties\AssemblyInfo.cs" />
</ItemGroup>
<ItemGroup>
<None Include="packages.config" />
<ProjectReference Include="..\..\Librarys\litjson\litjson\litjson_4.7.1.csproj">
<Project>{91a14cd2-2940-4500-8193-56d37edddbaa}</Project>
<Name>litjson_4.7.1</Name>
</ProjectReference>
<ProjectReference Include="..\..\Utils\IoT\Interfaces\Iot-Interfaces.csproj">
<Project>{4daada29-c600-4cf3-8ad3-9c97c8d7f632}</Project>
<Name>Iot-Interfaces</Name>
</ProjectReference>
</ItemGroup>
<ItemGroup />
<Import Project="$(MSBuildToolsPath)\Microsoft.CSharp.targets" />
</Project>
+60 -28
View File
@@ -1,28 +1,37 @@
using System;
using System.Collections.Generic;
using System.Collections.ObjectModel;
using System.Globalization;
using System.Text.RegularExpressions;
using System.Threading;
using BlubbFish.IoT.Zway.Devices;
using BlubbFish.IoT.Zway.Events;
using BlubbFish.IoT.Zway.Interfaces;
using BlubbFish.IoT.Zway.lib;
using LitJson;
namespace BlubbFish.IoT.Zway {
public class ZwayController : IDisposable {
private HttpConnection http;
private Dictionary<Int32, Device> devices = new Dictionary<Int32, Device>();
private Thread updatethread;
private Thread pollthread;
public static ReadOnlyDictionary<String, String> namelist;
private Boolean polling;
public delegate void DataUpdate(Object sender, DeviceUpdateEvent e);
public event DataUpdate Update;
public ZwayController(String server, String user, String pass) {
public ReadOnlyDictionary<Int32, Device> Devices { get; private set; }
public ZwayController(String server, String user, String pass, Dictionary<String, String> names, Boolean enablePoll = true) {
namelist = new ReadOnlyDictionary<String, String>(names);
this.polling = enablePoll;
this.Connect(server, user, pass);
}
public ZwayController(Dictionary<String, String> settings) {
public ZwayController(Dictionary<String, String> settings, Dictionary<String, String> names, Boolean enablePoll = true) {
namelist = new ReadOnlyDictionary<String, String>(names);
this.polling = enablePoll;
this.Connect(settings["server"], settings["user"], settings["pass"]);
}
@@ -34,12 +43,12 @@ namespace BlubbFish.IoT.Zway {
CultureInfo.DefaultThreadCurrentUICulture = info;
Thread.CurrentThread.CurrentCulture = info;
Thread.CurrentThread.CurrentUICulture = info;
this.ParseNamespace(this.http.GetJson("ZWaveAPI/Run/devices"));
this.CreateDevices(this.http.GetJson("ZWaveAPI/Run/devices"));
this.updatethread = new Thread(this.Updater);
this.updatethread.Start();
this.pollthread = new Thread(this.Poll);
this.pollthread.Start();
foreach (KeyValuePair<Int32, Device> item in this.devices) {
foreach (KeyValuePair<Int32, Device> item in this.Devices) {
item.Value.Update += this.DeviceUpdate;
}
}
@@ -56,13 +65,38 @@ namespace BlubbFish.IoT.Zway {
Thread.CurrentThread.CurrentCulture = info;
Thread.CurrentThread.CurrentUICulture = info;
while(true) {
foreach (KeyValuePair<Int32, Device> item in this.devices) {
foreach (KeyValuePair<Int32, Device> item in this.Devices) {
item.Value.Poll();
}
Thread.Sleep(1000);
}
}
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 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];
}
}
}
}
return null;
}
private void Updater() {
CultureInfo info = new CultureInfo("de-DE");
info.NumberFormat.NumberDecimalSeparator = ".";
@@ -78,9 +112,9 @@ 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);
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);
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);
}
} /*else {
if(item.StartsWith("controller.")) { }
@@ -95,8 +129,8 @@ namespace BlubbFish.IoT.Zway {
match = new Regex("^devices\\.([0-9]+)\\.(data.*)", RegexOptions.IgnoreCase).Match(item);
if(match.Success) {
Int32 deviceid = Int32.Parse(match.Groups[1].Value);
if (this.devices.ContainsKey(deviceid)) {
this.devices[deviceid].SetUpdate(notifications[item], match);
if (this.Devices.ContainsKey(deviceid)) {
this.Devices[deviceid].SetUpdate(notifications[item], match);
}
}
}
@@ -104,26 +138,24 @@ namespace BlubbFish.IoT.Zway {
}
}
private void ParseNamespace(JsonData json) {
private void CreateDevices(JsonData json) {
Dictionary<Int32, Device> devices = new Dictionary<Int32, Device>();
foreach (String deviceid in json.Keys) {
this.CreateDevices(Int32.Parse(deviceid), json[deviceid]);
Device d = Device.CreateDevice(json[deviceid], new Tuple<Int32>(Int32.Parse(deviceid)), this.http, this.polling);
if (d != null) {
devices.Add(Int32.Parse(deviceid), d);
}
}
this.Devices = new ReadOnlyDictionary<Int32, Device>(devices);
}
private void CreateDevices(Int32 deviceid, JsonData json) {
Device d = Device.CreateDevice(json, new Tuple<Int32>(deviceid), this.http);
if(d != null) {
this.devices.Add(deviceid, d);
}
}
public List<T> GetCommandClasses<T>() {
List<T> ret = new List<T>();
foreach (KeyValuePair<Int32, Device> device in this.devices) {
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);
}
}
}
@@ -142,7 +174,7 @@ namespace BlubbFish.IoT.Zway {
}
this.updatethread = null;
this.pollthread = null;
this.devices.Clear();
this.Devices = null;
this.disposedValue = true;
}
}
@@ -151,7 +183,7 @@ namespace BlubbFish.IoT.Zway {
Dispose(false);
}
void IDisposable.Dispose() {
public void Dispose() {
Dispose(true);
GC.SuppressFinalize(this);
}
Binary file not shown.
+15
View File
@@ -0,0 +1,15 @@
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace BlubbFish.IoT.Zway.lib {
class Helper {
internal static void WriteError(String text) {
Console.ForegroundColor = ConsoleColor.Red;
Console.Error.WriteLine("ERROR: "+text);
Console.ResetColor();
}
}
}
+6 -6
View File
@@ -1,11 +1,7 @@
using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Net;
using System.Runtime.CompilerServices;
using System.Text;
using System.Threading.Tasks;
using LitJson;
namespace BlubbFish.IoT.Zway.lib {
@@ -26,6 +22,9 @@ namespace BlubbFish.IoT.Zway.lib {
internal JsonData GetJson(String v) {
String text = this.GetString(v);
if(text == null) {
return new JsonData();
}
try {
return JsonMapper.ToObject(text);
} catch(Exception) {
@@ -55,8 +54,9 @@ namespace BlubbFish.IoT.Zway.lib {
}
}
} catch (Exception e) {
Console.Error.WriteLine("Konnte keine Verbindung zum Razzbery Server herstellen: " + e.Message);
throw new Exceptions.ConnectionException("Konnte keine Verbindung zum Razzbery Server herstellen: " + e.Message);
Helper.WriteError("Konnte keine Verbindung zum Razzbery Server herstellen. Resource: \"" + this.server + v + "\" Fehler: " + e.Message);
return null;
//throw new Exceptions.ConnectionException("Konnte keine Verbindung zum Razzbery Server herstellen: " + e.Message);
}
}
return ret;
-4
View File
@@ -1,4 +0,0 @@
<?xml version="1.0" encoding="utf-8"?>
<packages>
<package id="LitJson" version="0.9.0" targetFramework="net461" />
</packages>