X-Git-Url: https://git.realraum.at/?p=svn42.git;a=blobdiff_plain;f=track-presence.py;h=3877c5c7aa1543191c506b084e95cb6fd0c8cb46;hp=9f0aa66d1bced0562c43ca0c5352b6c12c7cb7bd;hb=a34e51d757fe52cb19de2937ae1b211894167524;hpb=4022120de2abcbd8f71f199e2cb2d9fd73a05680 diff --git a/track-presence.py b/track-presence.py index 9f0aa66..3877c5c 100755 --- a/track-presence.py +++ b/track-presence.py @@ -47,10 +47,11 @@ class UWSConfig: self.config_parser.set('sensors','remote_shell',"usocket") self.config_parser.add_section('tracker') self.config_parser.set('tracker','sec_wait_after_close_using_cardphone',"4.2") - self.config_parser.set('tracker','sec_wait_for_movement_before_warning',"30") - self.config_parser.set('tracker','sec_wait_after_close_using_manualswitch',"25.0") - self.config_parser.set('tracker','sec_movement_before_manual_switch',"-1.0") #neg duration means: movement has to occur _after_ door was closed manually + self.config_parser.set('tracker','sec_wait_for_movement_before_warning',"60") + self.config_parser.set('tracker','sec_wait_after_close_using_manualswitch',"22.0") + self.config_parser.set('tracker','sec_movement_before_manual_switch',"-3.0") #neg duration means: movement has to occur _after_ door was closed manually self.config_parser.set('tracker','sec_general_movement_timeout',"3600") + self.config_parser.set('tracker','num_movements_req_on_nonpresence_until_present',"3") self.config_parser.set('tracker','server_socket',"/var/run/tuer/presence.socket") self.config_parser.set('tracker','photo_flashlight',"1020") self.config_parser.set('tracker','photo_artif_light',"970") @@ -149,9 +150,9 @@ threads_running=True def trackSensorStatusThread(uwscfg,status_tracker,connection_listener): global sshp, threads_running #RE_TEMP = re.compile(r'temp\d: (\d+\.\d+)') - RE_PHOTO = re.compile(r'photo\d: [^0-9]*?(\d+)') - RE_MOVEMENT = re.compile(r'movement|button\d?|PanicButton') - RE_ERROR = re.compile(r'Error: (.+)') + RE_PHOTO = re.compile(r'photo\d: [^0-9]*?(\d+)',re.I) + RE_MOVEMENT = re.compile(r'movement|button\d?|PanicButton',re.I) + RE_ERROR = re.compile(r'Error: (.+)',re.I) while threads_running: uwscfg.checkConfigUpdates() sshp = None @@ -213,9 +214,9 @@ door_socklock=threading.Lock() def trackDoorStatusThread(uwscfg, status_tracker,connection_listener): global door_sockhandle, door_socklock, threads_running #socket.setdefaulttimeout(10.0) #affects all new Socket Connections (urllib as well) - RE_STATUS = re.compile(r'Status: (\w+), idle') - RE_REQUEST = re.compile(r'Request: (\w+) (?:(Card|Phone) )?(.+)') - RE_ERROR = re.compile(r'Error: (.+)') + RE_STATUS = re.compile(r'Status: (closed|opened), (opening|waiting|closing|idle), (ajar|shut).*',re.I) + RE_REQUEST = re.compile(r'Request: (\w+) (?:(Card|Phone|SSH|ssh) )?(.+)',re.I) + RE_ERROR = re.compile(r'Error: (.+)',re.I) while threads_running: uwscfg.checkConfigUpdates() with door_socklock: @@ -247,13 +248,19 @@ def trackDoorStatusThread(uwscfg, status_tracker,connection_listener): m = RE_STATUS.match(line) if not m is None: - status = m.group(1) - if status == "opened": - status_tracker.doorOpen(last_who, last_how) - if status == "closed": - status_tracker.doorClosed(last_who, last_how) - last_who = None - last_how = None + (status, current_operation, ajar_status) = m.group(1,2,3) + #REALLY: doorOpen/Closed should be called before doorLocked/Unlocked + if ajar_status == "ajar": + status_tracker.doorOpen() + else: + status_tracker.doorClosed() + if current_operation == "idle": + if status == "opened": + status_tracker.doorUnlocked(last_who, last_how) + if status == "closed": + status_tracker.doorLocked(last_who, last_how) + last_who = None + last_how = None continue m = RE_REQUEST.match(line) if not m is None: @@ -287,8 +294,9 @@ class StatusTracker: #(threading.Thread): self.uwscfg=uwscfg self.status_change_handler = None #State locked by self.lock - self.door_open_previously=None - self.door_open=False + self.door_unlocked_previously=None + self.door_unlocked=False + self.door_closed=True self.door_manual_switch_used=False self.door_physically_present=True self.door_who=None @@ -296,59 +304,82 @@ class StatusTracker: #(threading.Thread): self.last_movement_unixts=0 self.last_light_value=0 self.last_light_unixts=0 - self.lock=threading.Lock() + self.lock=threading.RLock() #Notify State locked by self.presence_notify_lock self.last_somebody_present_result=False self.last_warning=None self.count_same_warning=0 - self.presence_notify_lock=threading.Lock() + self.who_might_be_here=None + self.presence_notify_lock=threading.RLock() #timer self.timer=None self.timer_timeout=0 - - def doorOpen(self,who,how): + self.num_movements_during_nonpresences = 0 + + def doorOpen(self): + logging.debug("doorOpen()") + self.door_closed=False + #future other stuff + + def doorClosed(self): + logging.debug("doorClosed()") + self.door_closed=True + #future other stuff + + def doorUnlocked(self,who,how): self.uwscfg.checkConfigUpdates() self.lock.acquire() - self.door_open=True - if self.door_open != self.door_open_previously: + self.door_unlocked=True + self.door_closed=True + if self.door_unlocked != self.door_unlocked_previously: self.door_who=who + self.lock.release() + self.updateWhoMightBeHere(who) + self.lock.acquire() self.door_manual_switch_used=(who is None or len(who) == 0) - self.door_physically_present=(self.door_manual_switch_used or how == "Card") - if not self.door_open_previously is None: + self.door_physically_present=(self.door_manual_switch_used or (not how is None and how.startswith("Card"))) + if not self.door_unlocked_previously is None: self.last_door_operation_unixts=time.time() self.lock.release() self.checkPresenceStateChangeAndNotify() self.lock.acquire() - self.door_open_previously = self.door_open + self.door_unlocked_previously = self.door_unlocked self.lock.release() + logging.debug("doorUnlocked: open: %s, who: %s, how: %s, manual_switch: %s; physically_present: %s" % (self.door_unlocked,self.door_who,how,self.door_manual_switch_used,self.door_physically_present)) - def doorClosed(self,who,how): + def doorLocked(self,who,how): self.uwscfg.checkConfigUpdates() self.lock.acquire() - self.door_open=False - if self.door_open != self.door_open_previously: + self.door_unlocked=False + if self.door_unlocked != self.door_unlocked_previously: self.door_who=who + self.lock.release() + self.updateWhoMightBeHere(who) + self.lock.acquire() self.door_manual_switch_used=(who is None or len(who) == 0) - self.door_physically_present=(self.door_manual_switch_used or how == "Card") - if not self.door_open_previously is None: + self.door_physically_present=(self.door_manual_switch_used or (not how is None and how.startswith("Card"))) + if not self.door_unlocked_previously is None: self.last_door_operation_unixts=time.time() self.lock.release() self.checkPresenceStateChangeAndNotify() self.lock.acquire() - self.door_open_previously = self.door_open + self.door_unlocked_previously = self.door_unlocked self.lock.release() + logging.debug("doorLocked: open: %s, who: %s, how:%s, manual_switch: %s; physically_present: %s" % (self.door_unlocked,self.door_who,how,self.door_manual_switch_used,self.door_physically_present)) def movementDetected(self): self.uwscfg.checkConfigUpdates() self.lock.acquire() self.last_movement_unixts=time.time() self.lock.release() + #FIXME: QUICKFIX ignore movement + return self.checkPresenceStateChangeAndNotify() def currentLightLevel(self, value): self.uwscfg.checkConfigUpdates() self.last_light_unixts=time.time() - self.last_light_value=value; + self.last_light_value=value self.checkPresenceStateChangeAndNotify() def checkLight(self, somebody_present=None): @@ -365,8 +396,9 @@ class StatusTracker: #(threading.Thread): else: return "Light: off" - def checkAgainIn(self, sec): + if sec <= 0.0: + return if self.timer_timeout < time.time(): logging.debug("checkAgainIn: starting Timer with timeout %fs" % sec) self.timer=threading.Timer(sec, self.checkPresenceStateChangeAndNotify) @@ -377,32 +409,57 @@ class StatusTracker: #(threading.Thread): def somebodyPresent(self): with self.lock: - if self.door_open: + #door unlocked: + if self.door_unlocked: + self.num_movements_during_nonpresences = 0 if self.door_physically_present: return True + #door is ajar and unlocked then we are here for sure: + elif self.door_closed == False: + return True elif self.last_movement_unixts > self.last_door_operation_unixts: return True else: return False - elif self.door_manual_switch_used and time.time() - self.last_door_operation_unixts <= float(self.uwscfg.tracker_sec_wait_after_close_using_manualswitch): - self.checkAgainIn(float(self.uwscfg.tracker_sec_wait_after_close_using_manualswitch)) - return self.last_somebody_present_result + # door locked but still ajar: + elif self.door_closed == False: #and elf.door_unlocked == False + return True + # door not locked from inside, but with card/phone .. check again in ... elif not self.door_manual_switch_used and time.time() - self.last_door_operation_unixts <= float(self.uwscfg.tracker_sec_wait_after_close_using_cardphone): + self.num_movements_during_nonpresences = 0 self.checkAgainIn(float(self.uwscfg.tracker_sec_wait_after_close_using_cardphone)) - return self.last_somebody_present_result - elif self.last_movement_unixts > self.last_door_operation_unixts - float(self.uwscfg.tracker_sec_movement_before_manual_switch) and self.door_manual_switch_used: - return True - elif self.last_movement_unixts > self.last_door_operation_unixts and time.time() - self.last_movement_unixts < float(self.uwscfg.tracker_sec_general_movement_timeout): + return self.last_somebody_present_result + # door locked from inside, and door not ajar + elif self.door_manual_switch_used and self.door_closed: return True +# # door locked from inside, stay on last status .... +# elif self.door_manual_switch_used and time.time() - self.last_door_operation_unixts <= float(self.uwscfg.tracker_sec_wait_after_close_using_manualswitch): +# self.num_movements_during_nonpresences = 0 +# self.checkAgainIn(float(self.uwscfg.tracker_sec_wait_after_close_using_manualswitch)) +# return self.last_somebody_present_result +# # door locked from inside and movement detected around that time +# elif self.door_manual_switch_used and self.last_movement_unixts > self.last_door_operation_unixts - float(self.uwscfg.tracker_sec_movement_before_manual_switch): +# self.num_movements_during_nonpresences = 0 +# return True + ##door was closed and nobody here But movement is dedected: + #elif self.last_movement_unixts > self.last_door_operation_unixts and time.time() - self.last_movement_unixts < float(self.uwscfg.tracker_sec_general_movement_timeout): + # self.num_movements_during_nonpresences += 1 + # if self.num_movements_during_nonpresences >= int(self.uwscfg.tracker_num_movements_req_on_nonpresence_until_present): + # return True + # else: + # return False else: + self.num_movements_during_nonpresences = 0 return False def getPossibleWarning(self): with self.lock: somebody_present=self.last_somebody_present_result - if self.door_open and not somebody_present and time.time() - self.last_door_operation_unixts >= float(self.uwscfg.tracker_sec_wait_for_movement_before_warning): - return "Door opened recently but nobody present" - elif self.door_open and not somebody_present: + if not somebody_present and not self.door_closed: + return "Nobody here but door ajar !" + elif self.door_unlocked and not somebody_present and time.time() - self.last_door_operation_unixts >= float(self.uwscfg.tracker_sec_wait_for_movement_before_warning): + return "Door unlocked recently but nobody present" + elif self.door_unlocked and not somebody_present: self.checkAgainIn(float(self.uwscfg.tracker_sec_wait_for_movement_before_warning)) return None # elif not somebody_present and self.last_light_unixts > self.last_door_operation_unixts and self.last_light_value > int(self.uwscfg.tracker_photo_artif_light): @@ -410,14 +467,25 @@ class StatusTracker: #(threading.Thread): else: return None + def updateWhoMightBeHere(self, who): + with self.presence_notify_lock: + self.who_might_be_here = who + + def forgetWhoMightBeHere(self, somebody_present): + with self.presence_notify_lock: + if not somebody_present: + self.who_might_be_here = None + def checkPresenceStateChangeAndNotify(self): + #no acquiring of self.lock, "just" reading. chance wrong reads in favour of avoiding race conditions (is python var _read_ threadsafe ?) with self.presence_notify_lock: somebody_present = self.somebodyPresent() - logging.debug("checkPresenceStateChangeAndNotify: somebody_present=%s, door_open=%s, who=%s, light=%s" % (somebody_present,self.door_open,self.door_who, str(self.last_light_value))) + logging.debug("checkPresenceStateChangeAndNotify: somebody_present=%s, door_locked=%s, door_ajar=%s, door_who=%s, who=%s, light=%s" % (somebody_present,not self.door_unlocked, not self.door_closed, self.door_who,self.who_might_be_here, str(self.last_light_value))) if somebody_present != self.last_somebody_present_result: self.last_somebody_present_result = somebody_present if not self.status_change_handler is None: - self.status_change_handler(somebody_present, door_open=self.door_open, who=self.door_who) + self.status_change_handler(somebody_present, door_open=self.door_unlocked, who=self.who_might_be_here) + self.forgetWhoMightBeHere(somebody_present) warning = self.getPossibleWarning() if warning == self.last_warning: self.count_same_warning+=1 @@ -427,8 +495,7 @@ class StatusTracker: #(threading.Thread): if not warning is None and self.count_same_warning < 3: logging.debug("checkPresenceStateChangeAndNotify: warning: " + str(warning)) if not self.status_change_handler is None: - self.status_change_handler(somebody_present=None, door_open=self.door_open, who=self.door_who, warning=warning) - + self.status_change_handler(somebody_present=None, door_open=self.door_unlocked, who=self.who_might_be_here, warning=warning) ############ Connection Listener ############ class ConnectionListener: