Hopeless-Automations/laptop2mqtt
1
0
Fork 0
forked from sthope/battery2mqtt
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Only send MQTT payload if info has changed from previous payload

Browse Source
This commit is contained in:
Tediore
2021-08-17 23:53:48 -05:00
parent dfecf44afc
commit d3b2e5e428
1 changed files with 7 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
battery2mqtt.py
View File

@@ -28,6 +28,7 @@ path = "/sys/class/power_supply/"
dirs = os.listdir(path) dirs = os.listdir(path)
payload = {} payload = {}
prev_payload = {}
health_calc = {} health_calc = {}
time_remaining = {} time_remaining = {}
mqtt_connected = False mqtt_connected = False
@@ -62,6 +63,8 @@ def check_conditions():
def get_info(): def get_info():
# Get requested conditions and generate/send MQTT payload # Get requested conditions and generate/send MQTT payload
global payload
global prev_payload
for dir in dirs: for dir in dirs:
if AC_ADAPTER: if AC_ADAPTER:
if dir.startswith('AC'): if dir.startswith('AC'):
@@ -120,7 +123,10 @@ def get_info():
pass pass
try: try:
client.publish("battery2mqtt/" + MQTT_TOPIC + '/' + dir, json.dumps(payload), MQTT_QOS, False) if prev_payload != payload:
# only send MQTT payload if information has changed from previous payload
client.publish("battery2mqtt/" + MQTT_TOPIC + '/' + dir, json.dumps(payload), MQTT_QOS, False)
prev_payload = payload
if LOG_LEVEL == 'DEBUG': if LOG_LEVEL == 'DEBUG':
logging.debug('Sending MQTT payload: ' + str(payload)) logging.debug('Sending MQTT payload: ' + str(payload))
except Exception as e: except Exception as e: