converters

deployment/configmap.yml

@@ -20,7 +20,7 @@ data:
       "status": "heating/system/status"
     }
   MQTT_STATUS_TOPIC: "heating/status"
-  MQTT_STATUSTEXT_TOPIC_PREFIX: "heating/statustext/"
+  MQTT_CONTEXT_TOPIC_PREFIX: "heating/context/"
   OFF_TEMPERATURE: "5.0"
   LOW_TEMPERATURE: "15.0"
   DEFAULT_HIGH_TEMPERATURE: "21.0"
@@ -30,63 +30,71 @@ data:
       "patty": {
         "label": "patty",
         "windows": [ 
-          { "topic": "homegear/instance1/plain/18/1/STATE", "label": "Garten rechts" },
-          { "topic": "homegear/instance1/plain/22/1/STATE", "label": "Garten links" }
+          { "topic": "homegear/instance1/plain/18/1/STATE", "label": "Garten rechts", "converter": "max" },
+          { "topic": "homegear/instance1/plain/22/1/STATE", "label": "Garten links", "converter": "max" }
         ],
-        "output_topic": "heating/homegear/instance1/set/39/1/SET_TEMPERATURE"
+        "output_topic": "heating/homegear/instance1/set/39/1/SET_TEMPERATURE",
+        "output_converter": "max"
       },
       "kueche": {
         "label": "kueche",
         "windows": [ 
-          { "topic": "homegear/instance1/plain/37/1/STATE", "label": "Garten Fenster" },
-          { "topic": "homegear/instance1/plain/36/1/STATE", "label": "Garten Tuer" },
-          { "topic": "homegear/instance1/plain/38/1/STATE", "label": "Strasse rechts" },
-          { "topic": "homegear/instance1/plain/13/1/STATE", "label": "Strasse links" }
+          { "topic": "homegear/instance1/plain/37/1/STATE", "label": "Garten Fenster", "converter": "max" },
+          { "topic": "homegear/instance1/plain/36/1/STATE", "label": "Garten Tuer", "converter": "max" },
+          { "topic": "homegear/instance1/plain/38/1/STATE", "label": "Strasse rechts", "converter": "max" },
+          { "topic": "homegear/instance1/plain/13/1/STATE", "label": "Strasse links", "converter": "max" }
         ],
-        "output_topic": "heating/homegear/instance1/set/40/1/SET_TEMPERATURE"
+        "output_topic": "heating/homegear/instance1/set/40/1/SET_TEMPERATURE",
+        "output_converter": "max"
       },
       "bad_oben": {
         "label": "bad_oben",
         "windows": [ 
         ],
-        "output_topic": "heating/homegear/instance1/set/41/1/SET_TEMPERATURE"
+        "output_topic": "heating/homegear/instance1/set/41/1/SET_TEMPERATURE",
+        "output_converter": "max"
       },
       "schlafzimmer": {
         "label": "schlafzimmer",
         "windows": [ 
-          { "topic": "homegear/instance1/plain/52/1/STATE", "label": "Strasse" }
+          { "topic": "homegear/instance1/plain/52/1/STATE", "label": "Strasse", "converter": "max" }
         ],
-        "output_topic": "heating/homegear/instance1/set/42/1/SET_TEMPERATURE"
+        "output_topic": "heating/homegear/instance1/set/42/1/SET_TEMPERATURE",
+        "output_converter": "max"
       },
       "wolfgang": {
         "label": "wolfgang",
         "windows": [ 
-          { "topic": "homegear/instance1/plain/24/1/STATE", "label": "Garten" }
+          { "topic": "homegear/instance1/plain/24/1/STATE", "label": "Garten", "converter": "aqara" }
         ],
-        "output_topic": "heating/homegear/instance1/set/43/1/SET_TEMPERATURE"
+        "output_topic": "heating/homegear/instance1/set/43/1/SET_TEMPERATURE",
+        "output_converter": "max"
       },
       "esszimmer": {
         "label": "esszimmer",
         "windows": [ 
-          { "topic": "homegear/instance1/plain/26/1/STATE", "label": "Strasse rechts" },
-          { "topic": "homegear/instance1/plain/27/1/STATE", "label": "Strasse links" }
+          { "topic": "homegear/instance1/plain/26/1/STATE", "label": "Strasse rechts", "converter": "max" },
+          { "topic": "homegear/instance1/plain/27/1/STATE", "label": "Strasse links", "converter": "max" }
         ],
-        "output_topic": "heating/homegear/instance1/set/45/1/SET_TEMPERATURE"
+        "output_topic": "heating/homegear/instance1/set/45/1/SET_TEMPERATURE",
+        "output_converter": "max"
       },
       "wohnzimmer": {
         "label": "wohnzimmer",
         "windows": [ 
-          { "topic": "homegear/instance1/plain/28/1/STATE", "label": "Garten rechts" },
-          { "topic": "homegear/instance1/plain/29/1/STATE", "label": "Garten links" }
+          { "topic": "homegear/instance1/plain/28/1/STATE", "label": "Garten rechts", "converter": "max" },
+          { "topic": "homegear/instance1/plain/29/1/STATE", "label": "Garten links", "converter": "max" }
         ],
-        "output_topic": "heating/homegear/instance1/set/46/1/SET_TEMPERATURE"
+        "output_topic": "heating/homegear/instance1/set/46/1/SET_TEMPERATURE",
+        "output_converter": "max"
       },
       "bad_unten": {
         "label": "bad_unten",
         "windows": [ 
-          { "topic": "homegear/instance1/plain/44/1/STATE", "label": "Strasse" }
+          { "topic": "homegear/instance1/plain/44/1/STATE", "label": "Strasse", "converter": "max" }
         ],
-        "output_topic": "heating/homegear/instance1/set/48/1/SET_TEMPERATURE"
+        "output_topic": "heating/homegear/instance1/set/48/1/SET_TEMPERATURE",
+        "output_converter": "max"
       }
     }
 

src/main.py

@@ -19,7 +19,7 @@ LOW_TEMPERATURE = os.getenv("LOW_TEMPERATURE", "15.0")
 DEFAULT_HIGH_TEMPERATURE = os.getenv("DEFAULT_HIGH_TEMPERATURE", "21.0")
 MAINTENANCE_TEMPERATURE = os.getenv("MAINTENANCE_TEMPERATURE", "30.0")
 STATUS_TOPIC = os.getenv("MQTT_STATUS_TOPIC")
-STATUSTEXT_TOPIC_PREFIX = os.getenv("MQTT_STATUSTEXT_TOPIC_PREFIX")
+CONTEXT_TOPIC_PREFIX = os.getenv("MQTT_CONTEXT_TOPIC_PREFIX")
 
 # Check if required environment variables are set
 missing_vars = []
@@ -33,8 +33,8 @@ if not CENTRAL_TOPICS_CONFIG:
     missing_vars.append('MQTT_CENTRAL_TOPICS')
 if not STATUS_TOPIC:
     missing_vars.append('MQTT_STATUS_TOPIC')
-if not STATUSTEXT_TOPIC_PREFIX:
-    missing_vars.append('MQTT_STATUSTEXT_TOPIC_PREFIX')
+if not CONTEXT_TOPIC_PREFIX:
+    missing_vars.append('MQTT_CONTEXT_TOPIC_PREFIX')
 
 if missing_vars:
     logger.error(f"Error: The following environment variables are not set: {', '.join(missing_vars)}")
@@ -49,7 +49,7 @@ context['low_temperature'] = LOW_TEMPERATURE
 context['default_high_temperature'] = DEFAULT_HIGH_TEMPERATURE
 context['maintenance_temperature'] = MAINTENANCE_TEMPERATURE
 context['status_topic'] = STATUS_TOPIC
-context['statustext_topic_prefix'] = STATUSTEXT_TOPIC_PREFIX
+context['context_topic_prefix'] = CONTEXT_TOPIC_PREFIX
 
 # Load box configurations from JSON
 try:

src/message_processor.py

@@ -2,6 +2,17 @@ from loguru import logger
 import json
 
 
+
+CONVERTERS = {
+    "target_temperature_output": {
+      "max": lambda x: x["output_temperature"],
+    },
+    "window_contact_input": {
+      "max": lambda x: 'closed' if (x.lower() in ('false', 'close', 'closed')) else 'open',
+      "aqara": lambda x: 'closed' if json.loads(x)["contact"] else 'open'
+    }
+}
+
 # context
 #   boxes: structure of boxes
 #   client: MQTT client
@@ -59,13 +70,13 @@ def process_message(box_name, topic_key, payload, context):
                 raise Error(f"Unexcepted topic_key: {topic_key}, {payload}") 
 
         if result:
-            (result_message, status) = result
-            publish_topic = box["output_topic"] if not status else context['status_topic']
+            result_message = CONVERTERS["target_temperature_output"][box["output_converter"]](local_context)
+            publish_topic = box["output_topic"]
             context['client'].publish(publish_topic, result_message)
-            logger.info(f"[{box_name}] Result published on '{publish_topic}': {status} {result_message}")
+            logger.info(f"[{box_name}] Result published on '{publish_topic}': {result_message}")
 
-            statustext_topic = f"{context['statustext_topic_prefix']}{box['label']}"
-            context['client'].publish(statustext_topic, json.dumps(local_context))
+        context_topic = f"{context['context_topic_prefix']}{box['label']}"
+        context['client'].publish(context_topic, json.dumps(local_context))
 
         logger.info(f"[{box_name}] Local context after: {local_context}")
     except Exception as e:
@@ -101,17 +112,17 @@ def _calculate_output_temperature(local_context):
     return
 
 def process_status(box_name, context, local_context, payload):
-    return (f"{local_context}", True)
+    return False
 
 def process_general_off(box_name, context, local_context, payload):
     local_context['general_off'] = (payload.lower() in ('true'))
     _calculate_output_temperature(local_context)
-    return (local_context['output_temperature'], False)
+    return True
 
 def process_maintenance_mode(box_name, context, local_context, payload):
     local_context['maintenance_mode'] = (payload.lower() in ('true'))
     _calculate_output_temperature(local_context)
-    return (local_context['output_temperature'], False)
+    return True
 
 def process_cmd(box_name, context, local_context, payload):
     if payload.lower() in ('high', 'low', 'off'):
@@ -119,20 +130,26 @@ def process_cmd(box_name, context, local_context, payload):
         _calculate_output_temperature(local_context)
     else:
         logger.error(f"Invalid cmd for {box_name} received: {payload}")
-    return (local_context['output_temperature'], False)
+    return True
 
 def process_overwrite_window(box_name, context, local_context, payload):
     local_context['overwrite_window'] = (payload.lower() in ('true'))
     _calculate_output_temperature(local_context)
-    return (local_context['output_temperature'], False)
+    return True
 
 def process_high_temp(box_name, context, local_context, payload):
     local_context['high_temperature'] = payload
     _calculate_output_temperature(local_context)
-    return (local_context['output_temperature'], False)
+    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 (local_context['output_temperature'], False)
+    return True