sv/tsun-gen3-proxy
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

send ha registrations only if values have changed

Browse Source
This commit is contained in:
Stefan Allius
2023-10-06 20:02:38 +02:00
parent c791395e0e
commit 3db643cb87
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
app/src/inverter.py
View File

@@ -68,7 +68,9 @@ class Inverter(AsyncStream):
'''puplish data to MQTT broker''' '''puplish data to MQTT broker'''
db = self.db.db db = self.db.db
# check if new inverter or collector infos are available or when the home assistant has changed the status back to online # check if new inverter or collector infos are available or when the home assistant has changed the status back to online
if (self.new_data.keys() & {'inverter', 'collector'}) or self.mqtt.ha_restarts != self.ha_restarts: if (('inverter' in self.new_data and self.new_data['inverter']) or
('collector' in self.new_data and self.new_data['collector']) or
self.mqtt.ha_restarts != self.ha_restarts):
await self.__register_home_assistant() await self.__register_home_assistant()
self.ha_restarts = self.mqtt.ha_restarts self.ha_restarts = self.mqtt.ha_restarts
@@ -83,7 +85,7 @@ class Inverter(AsyncStream):
'''register all our topics at home assistant''' '''register all our topics at home assistant'''
try: try:
for data_json, component, id in self.db.ha_confs(self.entitiy_prfx + self.node_id, self.unique_id, self.sug_area): for data_json, component, id in self.db.ha_confs(self.entitiy_prfx + self.node_id, self.unique_id, self.sug_area):
logger.debug(f'MQTT Register: {data_json}') #logger.debug(f'MQTT Register: {data_json}')
await self.mqtt.publish(f"{self.discovery_prfx}{component}/{self.node_id}{id}/config", data_json) await self.mqtt.publish(f"{self.discovery_prfx}{component}/{self.node_id}{id}/config", data_json)
except Exception: except Exception:
logging.error( logging.error(