new thermostat

deployment/configmap.yml

@@ -65,10 +65,10 @@ data:
       "wolfgang": {
         "label": "wolfgang",
         "windows": [ 
-          { "topic": "homegear/instance1/plain/24/1/STATE", "label": "Garten", "converter": "max" }
+          { "topic": "zigbee2mqtt/0x00158d008b3328da", "label": "Garten", "converter": "aqara" }
         ],
-        "output_topic": "heating/homegear/instance1/set/43/1/SET_TEMPERATURE",
-        "output_converter": "max"
+        "output_topic": "zigbee2mqtt/0x540f57fffe7e3cfe/set",
+        "output_converter": "brennenstuhl"
       },
       "esszimmer": {
         "label": "esszimmer",

src/message_processor.py

@@ -6,9 +6,11 @@ import json
 CONVERTERS = {
     "target_temperature_output": {
       "max": lambda x: x["output_temperature"],
+      "brennenstuhl": lambda x: json.dumps({"current_heating_setpoint":x["output_temperature"]}),
     },
     "window_contact_input": {
-      "max": lambda x: 'closed' if (x.lower() in ('false', 'close', 'closed')) else 'open'
+      "max": lambda x: 'closed' if (x.lower() in ('false', 'close', 'closed')) else 'open',
+      "aqara": lambda x: 'closed' if json.loads(x)["contact"] else 'open',
     }
 }
 
@@ -142,7 +144,13 @@ def process_high_temp(box_name, context, local_context, payload):
     return True
 
 def process_window(box_name, context, local_context, sub_key, payload):
-    local_context['window_state'][sub_key] = 'closed' if (payload.lower() in ('false', 'close', 'closed')) else 'open'
+    # default converter
+    converter = lambda x:x
+    for sk in context["boxes"][box_name]["windows"]:
+        if sk["label"] == sub_key:
+            converter = CONVERTERS["window_contact_input"][sk["converter"]]
+            break
+    local_context['window_state'][sub_key] = converter(payload)
     _calculate_output_temperature(local_context)
     return True