CCCHH/dooris
1
1
Fork 0
Code Issues 1 Pull requests 1 Releases Packages 1 Activity Actions

api: implement automatic mqtt reconnect in ccujack cron
All checks were successful
Build Container / Build Container (push) Successful in 1m27s
Details

Browse source
This commit is contained in:
lilly 2026-05-28 16:23:03 +02:00
commit 6bbfc5dc68
Signed by: lilly
SSH key fingerprint: SHA256:y9T5GFw2A20WVklhetIxG1+kcg/Ce0shnQmbu1LQ37g
2 changed files with 12 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

8
api/src/dooris_api/mqtt_client.py
View file

@ -154,8 +154,16 @@ class AsyncMqttClient:
await self.fut_connected
# re-establish all supposed mqtt subscriptions
if len(self.active_subscriptions > 0):
qos = 1
await self.client.subscribe((i, qos) for i in self.active_subscriptions)
async def disconnect(self):
logger.info("Disconnecting mqtt client from broker")
self.fut_disconnect = asyncio.get_running_loop().create_future()
self.client.disconnect()
await self.fut_disconnect
def is_connected(self) -> bool:
return self.client.is_connected()