Discovery problems
This commit is contained in:
@@ -570,9 +570,20 @@ def connect_mqtt():
|
|||||||
client.connect()
|
client.connect()
|
||||||
client_ref = client
|
client_ref = client
|
||||||
|
|
||||||
# Subscriptions
|
# Subscriptions - skip state/status topics to avoid receiving own publishes
|
||||||
def _subscribe_all(c):
|
def _subscribe_all(c):
|
||||||
c.subscribe(f"{MQTT_PREFIX}/#")
|
c.subscribe(f"{MQTT_PREFIX}/set")
|
||||||
|
c.subscribe(f"{MQTT_PREFIX}/zero")
|
||||||
|
c.subscribe(f"{MQTT_PREFIX}/resetdiscovery")
|
||||||
|
for i in range(num_gauges):
|
||||||
|
prefix = f"{MQTT_PREFIX}/gauge{i}"
|
||||||
|
c.subscribe(f"{prefix}/set")
|
||||||
|
c.subscribe(f"{prefix}/zero")
|
||||||
|
c.subscribe(f"{prefix}/led/red/set")
|
||||||
|
c.subscribe(f"{prefix}/led/green/set")
|
||||||
|
c.subscribe(f"{prefix}/led/backlight/set")
|
||||||
|
c.subscribe(f"{prefix}/status_led/red/set")
|
||||||
|
c.subscribe(f"{prefix}/status_led/green/set")
|
||||||
|
|
||||||
_subscribe_all(client)
|
_subscribe_all(client)
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user