Skip to content

Commit 4de303e

Browse files
add publish status message
1 parent 9e374f9 commit 4de303e

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

functions/broker.py

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -77,7 +77,10 @@ def publish(self, message):
7777
message = self.wrap_message(message)
7878

7979
device_id_str = self.state.token["token"]["unencoded"]["bot"]
80-
self.client.publish(f'bot/{device_id_str}/from_clients', payload=json.dumps(message))
80+
topic = f"bot/{device_id_str}/from_clients"
81+
self.client.publish(topic, payload=json.dumps(message))
82+
self.state.print_status(description=f"Publishing to {topic}:")
83+
self.state.print_status(endpoint_json=message, update_only=True)
8184

8285
def on_connect(self, _client, _userdata, _flags, _rc, channel):
8386
"""Callback function when connection to message broker is successful."""

0 commit comments

Comments
 (0)