Revert "Fix MQTT dashboard discovery (Exception in MqttStatusThread)." (#6782)

This commit is contained in:
J. Nick Koston 2024-05-20 01:49:00 -10:00 committed by GitHub
parent 81ef67cfbb
commit 25ee24299a
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194

View File

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