apo
/
DoorControl
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

bell mqtt

Valentin Ochs 2022-11-21 18:10:54 +01:00
parent 9dbed1a51e
commit d8be5844e1
1 changed files with 30 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

48
door_pi_control/bell.py
View File

@ -20,11 +20,12 @@ msgs = {
}
class Reader(util.Loggable):
def __init__(self, should_open_immediately_cb = None):
def __init__(self, should_open_immediately_cb = None, mqttc = None):
super().__init__("bell")
self.tmp = bytes()
self.data = []
self.lock = threading.RLock()
self.cv = threading.Condition(self.lock)
self.times = []
@ -36,6 +37,9 @@ class Reader(util.Loggable):
self.closed = False
self.open_now_cb = should_open_immediately_cb
self._events = mqtt.Value(mqttc, "door/bell/event")
self._last_ring = datetime.datetime.now() - datetime.timedelta(days=1)
def connection_lost(self, exc):
if exc:
print(exc)
@ -94,26 +98,32 @@ class Reader(util.Loggable):
self.doing_light = not self.doing_light
elif msgs['ring_hs'] == msg:
open_now = self.open_now_cb and self.open_now_cb()
if open_now:
self._logger().info("Opening after a single button press")
self.open_door()
elif not self.start:
if not self.start:
self.start = datetime.datetime.now()
if self.last_symbol_timestamp and (self.start - self.last_symbol_timestamp).total_seconds() > 5:
self.times = []
elif msgs['release'] == msg and self.start:
t = datetime.datetime.now()
self.last_symbol_timestamp = t
dt = (t - self.start).total_seconds()
self.start = None
self.times = self.times[-3:] + [dt]
avg = sum(self.times) / len(self.times)
morse = [x>avg for x in self.times]
if len(self.times) == 4:
self._logger().info(", ".join([{True: "dah", False: "dit"}[x > avg] for x in self.times]))
if morse == [False, False, True, False]:
if open_now:
self._logger().info("Opening after a single button press")
self.open_door()
else:
t = datetime.datetime.now()
self.last_symbol_timestamp = t
dt = (t - self.start).total_seconds()
self.start = None
self.times = self.times[-3:] + [dt]
avg = sum(self.times) / len(self.times)
morse = [x>avg for x in self.times]
if len(self.times) == 4:
self._logger().info(", ".join([{True: "dah", False: "dit"}[x > avg] for x in self.times]))
if (t - self._last_ring).total_seconds() > 30:
self._events("ring", force=True)
self._last_ring = t
if morse == [False, False, True, False]:
self._events("morse", force=True)
self.open_door()
data = data[7:]
self.tmp = data
@ -139,6 +149,7 @@ class Reader(util.Loggable):
def open_door(self):
self._logger().info("Opening")
self._events("open", force=True)
self.alternate_msgs(['light_push', 'open_push'], dt = 0.04)
time.sleep(0.3)
self.alternate_msgs(['light_release', 'open_release'], dt = 0.04);
@ -155,11 +166,12 @@ class Reader(util.Loggable):
return rv
class Control(util.Loggable):
def __init__(self, port, open_immediately_cb = None):
def __init__(self, port, mqttc = None, open_immediately_cb = None):
super().__init__("bell")
self._port = port
self._task = None
self._cb = open_immediately_cb
self._mqttc = mqttc
def start(self):
if not self._task:
self._task = threading.Thread(target = self.run, daemon=True)
@ -171,7 +183,7 @@ class Control(util.Loggable):
if port is None or self._protocol.closed:
try:
port = serial.Serial(self._port, 9600)
self._protocol = serial.threaded.ReaderThread(port, lambda: Reader(self._cb))
self._protocol = serial.threaded.ReaderThread(port, lambda: Reader(self._cb, self._mqttc))
self._protocol.start()
self._protocol = self._protocol.protocol
except Exception as e: