From bdf4adf1c9155148f713dd6e7eda955c495155b3 Mon Sep 17 00:00:00 2001 From: Constantin Berhard Date: Thu, 24 Oct 2013 15:45:14 +0200 Subject: [PATCH 1/1] added fallback mode, TODO: test&debug mode for when some of the sensors don't work, just using one state in the statemachine and using only the space switch sensor in this mode the red LED blinks, use this mode only if it is really necessary, use it with parameter --fallback --- statemachine.py | 57 ++++++++++++++++++++++++++++++++++++++++++++++--- tuerd | 10 ++++++++- 2 files changed, 63 insertions(+), 4 deletions(-) diff --git a/statemachine.py b/statemachine.py index d8b7c53..3a27ada 100644 --- a/statemachine.py +++ b/statemachine.py @@ -1,6 +1,6 @@ from libtuer import ThreadFunction, logger, fire_and_forget from actor import Actor -import os, random, time +import os, random, time, threading # logger.{debug,info,warning,error,critical} @@ -22,6 +22,10 @@ OPEN_REPEAT_NUMBER = 3 CLOSE_REPEAT_TIMEOUT = 7 CLOSE_REPEAT_NUMBER = 3 +# StateFallback constants +FALLBACK_BLINK_SPEED = 0.5 # seconds +FALLBACK_LEAVE_DELAY_LOCK = 5 # seconds + # StateAboutToOpen constants ABOUTOPEN_NERVLIST = [(5, lambda : play_sound("flipswitch")), (5, lambda:play_sound("flipswitch")), (0, lambda:logger.warning("Space open but switch not flipped for 10 seconds")),\ (10, lambda:play_sound("flipswitch")), (10, lambda:play_sound("flipswitch")), (0, lambda:logger.error("Space open but switch not flipped for 30 seconds")),\ @@ -133,16 +137,63 @@ class StateMachine(): return super().handle_pins_event() class StateStart(State): + def __init__(self, sm, nervlist = None, fallback=False): + super().__init__(self, sm, nervlist) + self.fallback = fallback def handle_pins_event(self): pins = self.pins() if not (pins.door_locked is None or pins.door_closed is None or pins.space_active is None or pins.bell_ringing is None): logger.info("All sensors got a value, switching to a proper state") + if self.fallback: + logger.info("Going to StateFallback because running in fallback mode") + return StateMachine.StateFallback(self.state_machine) if pins.door_locked: return StateMachine.StateZu(self.state_machine) else: return StateMachine.StateAboutToOpen(self.state_machine) return super().handle_pins_event() + class StateFallback(State): + def __init__(self, sm, nervlist = None): + super().__init__(self, sm, nervlist) + self._last_blink_time = time.time() + self._red_state = False + def handle_pins_event(self): + pins = self.pins() + # buzz if open and bell rang + if pins.space_active and pins.bell_ringing and not self.old_pins().bell_ringing: + logger.info("StateFallback: Space switch on and door bell rung => buzzing") + self.actor().act(Actor.CMD_BUZZ) + # set green LED according to space switch + if pins.space_active: + self.actor().act(Actor.CMD_GREEN_ON) + else: + self.actor().act(Actor.CMD_GREEN_OFF) + # primitive leaving procedure if space switch turned off + if not pins.space_active and self.old_pins().space_active: + def _close_after_time(): + time.sleep(FALLBACK_LEAVE_DELAY_LOCK) + self.actor().act(Actor.CMD_LOCK) + t = threading.Thread(target=_close_after_time) + t.start() + # without return because we want to stay in fallback mode + super().handle_pins_event() + def handle_wakeup_event(self): + # blink red LED + now = time.time() + if now - self._last_blink_time < FALLBACK_BLINK_SPEED: + if self._red_state: + self.actor().act(Actor.CMD_RED_OFF) + self._red_state = False + else: + self.actor().act(Actor.CMD_RED_ON) + self._red_state = True + self._last_blink_time = now + def handle_cmd_unlock_event(self,arg): + if arg is not None: + arg("298 Fallback Okay: Trying to unlock the door. The System is in fallback mode, success information is not available.") + self.actor().act(Actor.CMD_UNLOCK) + class StateZu(AbstractLockedState): def handle_cmd_unlock_event(self,callback): return StateMachine.StateUnlocking(self.state_machine, callback) @@ -254,10 +305,10 @@ class StateMachine(): return StateMachine.StateAuf(self.state_machine) return super().handle_pins_event() - def __init__(self, actor): + def __init__(self, actor, fallback = False): self.actor = actor self.callback = ThreadFunction(self._callback, name="StateMachine") - self.current_state = StateMachine.StateStart(self) + self.current_state = StateMachine.StateStart(self, fallback) self.pins = None self.old_pins = None diff --git a/tuerd b/tuerd index 1bee788..50fe03f 100755 --- a/tuerd +++ b/tuerd @@ -9,17 +9,25 @@ parser = argparse.ArgumentParser(description='Run a door') parser.add_argument("-d", "--debug", action="store_true", dest="debug", help="Don't send emails") +parser.add_argument("-f", "--fallback", + action="store_true", dest="fallback", + help="Fallback mode for unfunctional hardware: Depend on less sensor input") args = parser.parse_args() if args.debug: import libtuer libtuer.mailAddress = [] +if args.fallback: + logger.info("Starting in fallback mode") +else: + # to avoid exceptions or getting None + args.fallback = False # initialize GPIO stuff GPIO.setmode(GPIO.BOARD) # bring 'em all up the_actor = actor.Actor() -the_machine = statemachine.StateMachine(the_actor) +the_machine = statemachine.StateMachine(the_actor, args.fallback) the_socket = tysock.TySocket(the_machine) the_pins = pins.PinsWatcher(the_machine) the_waker = waker.Waker(the_machine) -- 2.30.2