adebaumann/arduino_gauge_controller
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

MQTT doesn't like non-ASCII...

Browse Source
This commit is contained in:
Adrian A. Baumann
2026-04-17 19:15:01 +02:00
parent ef986c2881
commit f78d090f95
1 changed files with 15 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
gauge.py
View File

@@ -804,6 +804,12 @@ def check_mqtt():
return False return False
def _discovery_pause(client, count=2, delay_ms=10):
for _ in range(count):
client.check_msg()
utime.sleep_ms(delay_ms)
def publish_discovery(client): def publish_discovery(client):
"""Publish all HA MQTT discovery payloads for gauges and LEDs.""" """Publish all HA MQTT discovery payloads for gauges and LEDs."""
_dev_ref = _DEVICE _dev_ref = _DEVICE
@@ -841,6 +847,7 @@ def publish_discovery(client):
retain=True, retain=True,
) )
info(f"Discovery: gauge {i} ({g['name']})") info(f"Discovery: gauge {i} ({g['name']})")
_discovery_pause(client)
client.publish( client.publish(
gt["speed_disc"], gt["speed_disc"],
@@ -865,6 +872,7 @@ def publish_discovery(client):
retain=True, retain=True,
) )
info(f"Discovery: gauge {i} speed") info(f"Discovery: gauge {i} speed")
_discovery_pause(client)
client.publish( client.publish(
gt["acceleration_disc"], gt["acceleration_disc"],
@@ -879,7 +887,7 @@ def publish_discovery(client):
"max": 100000, "max": 100000,
"step": 1, "step": 1,
"mode": "box", "mode": "box",
"unit_of_meas": "steps/s²", "unit_of_meas": "steps/s2",
"icon": "mdi:chart-bell-curve-cumulative", "icon": "mdi:chart-bell-curve-cumulative",
"enabled_by_default": False, "enabled_by_default": False,
"entity_category": "config", "entity_category": "config",
@@ -889,10 +897,7 @@ def publish_discovery(client):
retain=True, retain=True,
) )
info(f"Discovery: gauge {i} acceleration") info(f"Discovery: gauge {i} acceleration")
_discovery_pause(client)
for _ in range(5):
client.check_msg()
utime.sleep_ms(10)
client.publish( client.publish(
gt["led_red_disc"], gt["led_red_disc"],
@@ -912,6 +917,7 @@ def publish_discovery(client):
retain=True, retain=True,
) )
info(f"Discovery: gauge {i} red LED") info(f"Discovery: gauge {i} red LED")
_discovery_pause(client)
client.publish( client.publish(
gt["led_green_disc"], gt["led_green_disc"],
@@ -931,10 +937,7 @@ def publish_discovery(client):
retain=True, retain=True,
) )
info(f"Discovery: gauge {i} green LED") info(f"Discovery: gauge {i} green LED")
_discovery_pause(client)
for _ in range(5):
client.check_msg()
utime.sleep_ms(10)
client.publish( client.publish(
gt["led_bl_disc"], gt["led_bl_disc"],
@@ -956,6 +959,7 @@ def publish_discovery(client):
retain=True, retain=True,
) )
info(f"Discovery: gauge {i} backlight") info(f"Discovery: gauge {i} backlight")
_discovery_pause(client)
client.publish( client.publish(
gt["status_red_disc"], gt["status_red_disc"],
@@ -975,6 +979,7 @@ def publish_discovery(client):
retain=True, retain=True,
) )
info(f"Discovery: gauge {i} status red") info(f"Discovery: gauge {i} status red")
_discovery_pause(client)
client.publish( client.publish(
gt["status_green_disc"], gt["status_green_disc"],
@@ -994,10 +999,7 @@ def publish_discovery(client):
retain=True, retain=True,
) )
info(f"Discovery: gauge {i} status green") info(f"Discovery: gauge {i} status green")
_discovery_pause(client)
for _ in range(5):
client.check_msg()
utime.sleep_ms(10)
def publish_online(client): def publish_online(client):