From: Martin Mareš <mj@ucw.cz>
Date: Sat, 16 Aug 2025 16:15:58 +0000 (+0200)
Subject: iris: Compatibility with aiomqtt 2.0
X-Git-Url: http://mj.ucw.cz/gitweb/?a=commitdiff_plain;h=826f0cf041cd8964b1d45a970453d7743e3937ed;p=home-hw.git

iris: Compatibility with aiomqtt 2.0
---

diff --git a/rainbow/iris/burrow-iris.py b/rainbow/iris/burrow-iris.py
index a734b2a..50bfc1d 100755
--- a/rainbow/iris/burrow-iris.py
+++ b/rainbow/iris/burrow-iris.py
@@ -159,17 +159,15 @@ async def mqtt_loop():
 
     will = aiomqtt.Will(topic='status/iris', payload='dead', qos=1, retain=True)
 
-    mqtt = aiomqtt.Client(client_id='iris', hostname="burrow-mqtt", port=8883, tls_context=sctx, will=will)
-    await mqtt.connect()
-    global st
-    st = State(mqtt)
-    async with mqtt.messages() as messages:
+    async with aiomqtt.Client(hostname="burrow-mqtt", port=8883, tls_context=sctx, will=will) as mqtt:
+        global st
+        st = State(mqtt)
         await mqtt.subscribe("burrow/air/ac-on")
         await mqtt.subscribe("burrow/heating/#")
         await mqtt.subscribe("burrow/temp/#")
         await mqtt.subscribe("burrow/power/current/#")
         await mqtt.publish("status/iris", "ok", retain=True)
-        async for msg in messages:
+        async for msg in mqtt.messages:
             await mqtt_process_msg(msg.topic.value, msg.payload.decode())