diff --git a/bumper/mqtt/helper_bot.py b/bumper/mqtt/helper_bot.py index 4dd6ccb..bcb62de 100644 --- a/bumper/mqtt/helper_bot.py +++ b/bumper/mqtt/helper_bot.py @@ -35,6 +35,9 @@ class CommandDto: self._event.set() +HELPER_BOT_CLIENT_ID = "helperbot@bumper/helperbot" + + class HelperBot: """Helper bot, which converts commands from the rest api to mqtt ones.""" @@ -44,9 +47,8 @@ class HelperBot: ) self._host = host self._port = port - self._client_id = "helperbot@bumper/helperbot" self._timeout = timeout - self._client = Client(self._client_id) + self._client = Client(HELPER_BOT_CLIENT_ID) # pylint: disable=unused-argument async def _on_message( diff --git a/bumper/mqtt/server.py b/bumper/mqtt/server.py index a2614f0..83733ae 100644 --- a/bumper/mqtt/server.py +++ b/bumper/mqtt/server.py @@ -20,6 +20,7 @@ from bumper.db import ( client_get, client_set_mqtt, ) +from bumper.mqtt.helper_bot import HELPER_BOT_CLIENT_ID from bumper.mqtt.proxy import ProxyClient from bumper.util import get_logger @@ -282,7 +283,7 @@ class BumperMQTTServerPlugin: proxymodelog.info( f"MQTT Proxy Mode - New MQTT Topic Subscription - Client: {client_id} - Topic: {topic}" ) - else: + elif client_id != HELPER_BOT_CLIENT_ID: proxymodelog.warning( f"MQTT Proxy Mode - No proxy client found! - Client: {client_id} - Topic: {topic}" )