mia/bumper
1
0
Fork 0
Code Issues 47 Pull requests 11 Projects Releases Packages Wiki Activity Actions

improve logging

Browse source
This commit is contained in:
Robert Resch 2023-03-20 20:23:37 +01:00
parent b2f2ebb59b
commit 3730954391
1 changed files with 4 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

7
bumper/mqtt/helper_bot.py
View file

@ -56,11 +56,12 @@ class HelperBot:
client: Client, topic: str, payload: bytes, qos: int, properties: dict client: Client, topic: str, payload: bytes, qos: int, properties: dict
) -> None: ) -> None:
try: try:
decoded_payload = payload.decode()
_LOGGER.debug( _LOGGER.debug(
"Got message: topic=%s; payload=%s;", topic, payload.decode() "Got message: topic=%s; payload=%s;", topic, decoded_payload
) )
topic_split = topic.split("/") topic_split = topic.split("/")
data_decoded = str(payload.decode()) data_decoded = str(decoded_payload)
if topic_split[10] in self._commands: if topic_split[10] in self._commands:
self._commands[topic_split[10]].add_response(data_decoded) self._commands[topic_split[10]].add_response(data_decoded)
except Exception: # pylint: disable=broad-except except Exception: # pylint: disable=broad-except
@ -137,7 +138,7 @@ class HelperBot:
command_dto = CommandDto(cmdjson["payloadType"]) command_dto = CommandDto(cmdjson["payloadType"])
self._commands[request_id] = command_dto self._commands[request_id] = command_dto
_LOGGER.debug("Sending message %s", topic) _LOGGER.debug("Sending message: topic=%s; payload=%s;", topic, payload)
self._client.publish(topic, payload.encode()) self._client.publish(topic, payload.encode())
resp = await self._wait_for_resp(command_dto, request_id) resp = await self._wait_for_resp(command_dto, request_id)