From 583fc50bf6c8bd6e1e63339c9955f3d75508d4a7 Mon Sep 17 00:00:00 2001 From: William Friconneau <4367901+mrwiwi@users.noreply.github.com> Date: Mon, 10 May 2021 20:44:49 +0200 Subject: [PATCH] Fix for alarm pin + Reintroduce MQTT refresh on connect --- alarm_control_panel.py | 2 +- mqtt_client.py | 4 +++- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/alarm_control_panel.py b/alarm_control_panel.py index 2dbe0bd..43a3f7e 100644 --- a/alarm_control_panel.py +++ b/alarm_control_panel.py @@ -38,7 +38,7 @@ async def setup(self): self.config['command_topic'] = alarm_command_topic.format(id=self.id) self.config['state_topic'] = alarm_state_topic.format(id=self.id) self.config['code'] = self.alarm_pin - if (self.alarm_pin != None): + if (self.alarm_pin == None): self.config['code_arm_required'] = 'true' else: self.config['code_arm_required'] = 'false' diff --git a/mqtt_client.py b/mqtt_client.py index 25cfb99..156de29 100644 --- a/mqtt_client.py +++ b/mqtt_client.py @@ -71,6 +71,7 @@ def on_connect(self, client, flags, rc, properties): try: print("Subscribing to : ", tydom_topic) # client.subscribe('homeassistant/#', qos=0) + client.subscribe('homeassistant/status', qos=0) client.subscribe(tydom_topic, qos=0) except Exception as e: print("Error on connect : ", e) @@ -93,7 +94,8 @@ async def on_message(self, client, topic, payload, qos, properties): elif (topic == "homeassistant/requests/tydom/scenarii"): print('Incoming MQTT scenarii request : ', topic, payload) await self.tydom.get_scenarii() - + elif (topic == "homeassistant/status" and payload.decode() == 'online'): + await self.tydom.get_devices_data() elif (topic == "/tydom/init"): print('Incoming MQTT init request : ', topic, payload) await self.tydom.connect()