From 925f612edef88066d017da623231ca21705e2a23 Mon Sep 17 00:00:00 2001 From: Josh Finlay Date: Wed, 8 Jan 2025 10:09:48 +1000 Subject: [PATCH] fix: mqtt subscription format - Updated subscribe calls to match gmqtt example - Added qos=1 parameter to subscriptions --- backend/mqtt_integration.py | 9 +++------ 1 file changed, 3 insertions(+), 6 deletions(-) diff --git a/backend/mqtt_integration.py b/backend/mqtt_integration.py index 177bce0..db4a233 100644 --- a/backend/mqtt_integration.py +++ b/backend/mqtt_integration.py @@ -3,7 +3,6 @@ import json import asyncio from typing import Optional, Callable, Union from gmqtt import Client as MQTTClient -from gmqtt.mqtt.subscription import Subscription import logging # Get logger @@ -103,9 +102,8 @@ class HomeAssistantMQTT: logger.info("Connected to MQTT broker") self._connected = True try: - # Subscribe to command topic using gmqtt's format - sub = Subscription(self.command_topic, qos=1) - await self.client.subscribe([sub]) + # Subscribe to command topic + await self.client.subscribe(self.command_topic, qos=1) logger.info(f"Subscribed to command topic: {self.command_topic}") # Publish discovery config @@ -194,8 +192,7 @@ class HomeAssistantMQTT: """Subscribe to a topic""" if self.client and self._connected: try: - sub = Subscription(topic, qos=1) - await self.client.subscribe([sub]) + await self.client.subscribe(topic, qos=1) except Exception as e: logger.error(f"Failed to subscribe to topic: {e}")