+ # TODO: share code with StateOpening, and possibly also with the nerv-mechanism from StateAboutToOpen
+ def __init__(self,callback,sm):
+ super().__init__(sm)
+ self.callbacks=[callback]
+ # FIXME: can we send "202 processing: Trying to close the door" here? Are the callbacks multi-use?
+ self.tries = 0
+ self.actor().act(Actor.CMD_CLOSE)
+ def notify(self, did_it_work):
+ s = "200 okay: door closed" if did_it_work else ("500 internal server error: Couldn't close door with %d tries à %f seconds" % (CLOSE_REPEAT_NUMBER,CLOSE_REPEAT_TIMEOUT))
+ for cb in self.callbacks:
+ if cb is not None:
+ cb(s)
+ def handle_pins_event(self):
+ pins = self.pins()
+ if not pins.door_locked:
+ self.notify(True)
+ return StateAboutToOpen(self.state_machine)
+ def handle_open_event(self,callback):
+ callback("409 conflict: The server is currently trying to close the door. Try again later.")
+ def handle_wakeup_event(self):
+ over = time.time() - self.time_entered
+ nexttry = (self.tries+1) * CLOSE_REPEAT_TIMEOUT
+ if over > nexttry:
+ if self.tries < CLOSE_REPEAT_NUMBER:
+ self.actor().act(Actor.CMD_CLOSE)
+ self.tries += 1
+ else:
+ logger.critical("Couldn't close door after %d tries. Going back to StateAboutToOpen." % CLOSE_REPEAT_NUMBER)
+ self.notify(False)
+ return StateAboutToOpen(self.state_machine)