Upstream/esphome
1
0
Fork 0
mirror of https://github.com/esphome/esphome.git synced 2024-09-25 03:43:41 +02:00
Code Issues Projects Releases Wiki Activity

Fix MQTT dashboard discovery (Exception in MqttStatusThread). (#6775)

Browse Source
This commit is contained in:
Markus 2024-05-20 01:52:14 +02:00 committed by Jesse Hills
parent 7452879fb1
commit ec6d86c8f5
No known key found for this signature in database
GPG Key ID: BEAAE804EFD8E83A
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
esphome/dashboard/status/mqtt.py
View File

@ -18,7 +18,7 @@ class MqttStatusThread(threading.Thread):
"""Run the status thread.""" """Run the status thread."""
dashboard = DASHBOARD dashboard = DASHBOARD
entries = dashboard.entries entries = dashboard.entries
current_entries = entries.all() current_entries = entries.async_all()
config = mqtt.config_from_env() config = mqtt.config_from_env()
topic = "esphome/discover/#" topic = "esphome/discover/#"
@ -33,7 +33,7 @@ class MqttStatusThread(threading.Thread):
return return
for entry in current_entries: for entry in current_entries:
if entry.name == data["name"]: if entry.name == data["name"]:
entries.set_state(entry, EntryState.ONLINE) entries.async_set_state(entry, EntryState.ONLINE)
return return
def on_connect(client, userdata, flags, return_code): def on_connect(client, userdata, flags, return_code):
@ -53,11 +53,11 @@ class MqttStatusThread(threading.Thread):
client.loop_start() client.loop_start()
while not dashboard.stop_event.wait(2): while not dashboard.stop_event.wait(2):
current_entries = entries.all() current_entries = entries.async_all()
# will be set to true on on_message # will be set to true on on_message
for entry in current_entries: for entry in current_entries:
if entry.no_mdns: if entry.no_mdns:
entries.set_state(entry, EntryState.OFFLINE) entries.async_set_state(entry, EntryState.OFFLINE)
client.publish("esphome/discover", None, retain=False) client.publish("esphome/discover", None, retain=False)
dashboard.mqtt_ping_request.wait() dashboard.mqtt_ping_request.wait()