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

Publish state changes.

Browse Source 
At the moment this publishes all entity states every time one thing
changes, which is not optimal.
This commit is contained in:
James Muscat
2024-07-20 23:21:42 +01:00
parent 0a812e75a0
commit c111df49cb
1 changed files with 7 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
HADiscovery.py
View File

@@ -13,7 +13,10 @@ HA_DISCOVERY_PREFIX = "homeassistant"
def publish_ha_states(state, client, mqtt_topic): def publish_ha_states(state, client, mqtt_topic):
pass for key, value in state.items():
state_topic = f"{mqtt_topic}/{key}"
print(f"{now()} Publishing state for {key} at {state_topic}")
client.publish(state_topic, json.dumps(value))
def publish_ha_discovery(device, client, mqtt_topic): def publish_ha_discovery(device, client, mqtt_topic):
@@ -45,12 +48,12 @@ def publish_ha_discovery(device, client, mqtt_topic):
if available and (access == "read" or access == "readWrite"): if available and (access == "read" or access == "readWrite"):
name_parts = feature["name"].split(".") name_parts = feature["name"].split(".")
name = name_parts[-1] name = name_parts[-1]
feature_type = name_parts[-2] # feature_type = name_parts[-2]
component_type = "sensor" # TODO use appropriate types component_type = "sensor" # TODO use appropriate types
discovery_topic = f"{HA_DISCOVERY_PREFIX}/{component_type}/hcpy/{device_ident}_{name}/config" discovery_topic = f"{HA_DISCOVERY_PREFIX}/{component_type}/hcpy/{device_ident}_{name}/config"
state_topic = f"{mqtt_topic}/{feature_type}/{name}" state_topic = f"{mqtt_topic}/{name}"
# print(discovery_topic, state_topic) # print(discovery_topic, state_topic)
discovery_payload = json.dumps({ discovery_payload = json.dumps({
@@ -63,4 +66,4 @@ def publish_ha_discovery(device, client, mqtt_topic):
print(discovery_topic) print(discovery_topic)
# print(discovery_payload) # print(discovery_payload)
client.publish(discovery_topic, discovery_payload, retain=False) # TODO make retain=True when stable client.publish(discovery_topic, discovery_payload, retain=True)