Chaospott/foodoord
8
1
Fork 0
Code Issues Pull Requests Releases 9 Wiki Activity

Resend last known state on reconnect

Browse Source
This commit is contained in:
T 2025-01-27 23:50:22 +01:00
parent 1941698a52
commit 80573055d9
4 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
build-package
View File

@ -1,3 +1,3 @@
#!/bin/bash #!/bin/bash
VERSION=3.3.1 VERSION=$(grep -oP '(?<=Version: ).*$' debian/DEBIAN/control)
dpkg-deb --root-owner-group -b debian "foodoord_${VERSION}_all.deb" dpkg-deb --root-owner-group -b debian "foodoord_${VERSION}_all.deb"

2
debian/DEBIAN/control vendored
View File

@ -1,5 +1,5 @@
Package: foodoord Package: foodoord
Version: 3.3.1 Version: 3.3.2
Maintainer: Tobi <tobi@chaospott.de> Maintainer: Tobi <tobi@chaospott.de>
Architecture: all Architecture: all
Description: Control the doors of the club, ja! Description: Control the doors of the club, ja!

4
debian/usr/sbin/foodoord_oben vendored
View File

@ -24,6 +24,7 @@ class FoodoorMQTT:
self.client.on_connect = self.on_connect self.client.on_connect = self.on_connect
self.client.on_message = self.on_message self.client.on_message = self.on_message
self._last_state = None
self._connect_lock = threading.Condition() self._connect_lock = threading.Condition()
def connect(self): def connect(self):
@ -39,6 +40,8 @@ class FoodoorMQTT:
self.client.loop_stop() self.client.loop_stop()
def on_connect(self, client, userdata, flags, rc): def on_connect(self, client, userdata, flags, rc):
if self._last_state is not None:
self.send_state(self._last_state)
with self._connect_lock: with self._connect_lock:
self._connect_lock.notify() self._connect_lock.notify()
@ -46,6 +49,7 @@ class FoodoorMQTT:
print(f"MQTT-Server Message: {msg.topic} {msg.payload}") print(f"MQTT-Server Message: {msg.topic} {msg.payload}")
def send_state(self, locked: bool): def send_state(self, locked: bool):
self._last_state = locked
self.client.publish(f"foobar/{self.area}/foodoor/status", { self.client.publish(f"foobar/{self.area}/foodoor/status", {
False: "open", False: "open",
True: "closed", True: "closed",

4
debian/usr/sbin/foodoord_unten vendored
View File

@ -22,6 +22,7 @@ class FoodoorMQTT:
self.client.on_connect = self.on_connect self.client.on_connect = self.on_connect
self.client.on_message = self.on_message self.client.on_message = self.on_message
self._last_state = None
self._connect_lock = threading.Condition() self._connect_lock = threading.Condition()
def connect(self): def connect(self):
@ -37,6 +38,8 @@ class FoodoorMQTT:
self.client.loop_stop() self.client.loop_stop()
def on_connect(self, client, userdata, flags, rc): def on_connect(self, client, userdata, flags, rc):
if self._last_state is not None:
self.send_state(self._last_state)
with self._connect_lock: with self._connect_lock:
self._connect_lock.notify() self._connect_lock.notify()
@ -44,6 +47,7 @@ class FoodoorMQTT:
print(f"MQTT-Server Message: {msg.topic} {msg.payload}") print(f"MQTT-Server Message: {msg.topic} {msg.payload}")
def send_state(self, locked: bool): def send_state(self, locked: bool):
self._last_state = locked
self.client.publish(f"foobar/{self.area}/foodoor/status", { self.client.publish(f"foobar/{self.area}/foodoor/status", {
False: "open", False: "open",
True: "closed", True: "closed",