eswyft/homekit
0
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge branch 'mqtt-refactoring' of ch1p.io:homekit into mqtt-refactoring

Browse Source
This commit is contained in:
Evgeny Zinoviev 2023-06-06 19:02:16 +03:00
commit 5e36053275
2 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/home/mqtt/_module.py
View File

@ -27,6 +27,9 @@ class MqttModule(abc.ABC):
def set_initialized(self):
self._initialized = True
def unset_initialized(self):
self._initialized = False
def tick(self, mqtt: MqttNode):
pass

5
src/home/mqtt/_node.py
View File

@ -38,6 +38,11 @@ class MqttNode(MqttBase):
module.init(self)
module.set_initialized()
def on_disconnect(self, client: mqtt.Client, userdata, rc):
super().on_disconnect(client, userdata, rc)
for module in self._modules:
module.unset_initialized()
def on_publish(self, client: mqtt.Client, userdata, mid):
pass # FIXME
# if self._ota_mid is not None and mid == self._ota_mid and self._ota_publish_callback: