bartek/hcpy
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Add some basic MQTT connectivity messages

Browse Source
This commit is contained in:
Meatballs1
2024-03-20 12:56:46 +00:00
parent 4a5449dbd6
commit 7e66669365
1 changed files with 11 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
hc2mqtt
View File

@@ -43,7 +43,16 @@ def hc2mqtt(
): ):
def on_connect(client, userdata, flags, rc): def on_connect(client, userdata, flags, rc):
client.publish(f"{mqtt_prefix}LWT", payload="Online", qos=0, retain=True) if rc == 5:
print(now(), f"ERROR MQTT connection failed: unauthorized - {rc}")
elif rc == 0:
print(now(), f"MQTT connection established: {rc}")
client.publish(f"{mqtt_prefix}LWT", payload="Online", qos=0, retain=True)
else:
print(now(), f"ERROR MQTT connection failed: {rc}")
def on_disconnect(client, userdata, rc):
print(now(), "ERROR MQTT client disconnected")
click.echo( click.echo(
f"Hello {devices_file=} {mqtt_host=} {mqtt_prefix=} " f"Hello {devices_file=} {mqtt_host=} {mqtt_prefix=} "
@@ -72,6 +81,7 @@ def hc2mqtt(
client.will_set(f"{mqtt_prefix}LWT", payload="Offline", qos=0, retain=True) client.will_set(f"{mqtt_prefix}LWT", payload="Offline", qos=0, retain=True)
client.on_connect = on_connect client.on_connect = on_connect
client.on_disconnect = on_disconnect
client.connect(host=mqtt_host, port=mqtt_port, keepalive=70) client.connect(host=mqtt_host, port=mqtt_port, keepalive=70)
for device in devices: for device in devices: