camera_trigger.py

   1 import glob
   2 import os
   3 import time
   4 import trigger
   5 import utils
   6 from datetime import datetime
   7
   8 class any_camera_trigger(trigger.trigger):
   9     def __init__(self):
  10         self.triggers_in_the_past_seven_min = {
  11             "driveway" :       0,
  12             "frontdoor" :      0,
  13             "cabin_driveway" : 0,
  14             "backyard" :       0,
  15         }
  16         self.last_trigger = {
  17             "driveway" :       0,
  18             "frontdoor" :      0,
  19             "cabin_driveway" : 0,
  20             "backyard" :       0,
  21         }
  22
  23     def choose_priority(self, camera, age):
  24         base_priority_by_camera = {
  25             "driveway" : 1,
  26             "frontdoor" : 2,
  27             "cabin_driveway" : 1,
  28             "backyard" : 0,
  29         }
  30         priority = base_priority_by_camera[camera]
  31         if age < 10:
  32             priority += trigger.trigger.PRIORITY_HIGH
  33         elif age < 30:
  34             priority += trigger.trigger.PRIORITY_NORMAL + age
  35         else:
  36             priority += trigger.trigger.PRIORITY_LOW
  37         return priority
  38
  39     def get_triggered_page_list(self):
  40         triggers = []
  41         cameras_with_recent_triggers = 0
  42         camera_list = [ "driveway",
  43                         "frontdoor",
  44                         "cabin_driveway",
  45                         "backyard" ]
  46
  47         now = time.time()
  48         try:
  49             # First pass, just see whether each camera is triggered and,
  50             # if so, count how many times in the past 7m it has triggered.
  51             for camera in camera_list:
  52                 file = "/timestamps/last_camera_motion_%s" % camera
  53                 ts = os.stat(file).st_ctime
  54                 if (ts != self.last_trigger[camera] and
  55                     (now - ts) < 10):
  56                     print("Camera: %s, age %s" % (camera, (now - ts)))
  57                     self.last_trigger[camera] = ts
  58                     cameras_with_recent_triggers += 1
  59                     self.triggers_in_the_past_seven_min[camera] = 0
  60                     file = "/timestamps/camera_motion_history_%s" % camera
  61                     f = open(file, "r")
  62                     contents = f.readlines()
  63                     f.close()
  64                     for x in contents:
  65                         x.strip()
  66                         age = now - int(x)
  67                         if age < (60 * 7):
  68                             self.triggers_in_the_past_seven_min[camera] += 1
  69
  70             # Second pass, see whether we want to trigger due to
  71             # camera activity we found.  All cameras timestamps were
  72             # just considered and should be up-to-date.  Some logic to
  73             # squelch spammy cameras unless more than one is
  74             # triggered at the same time.
  75             for camera in camera_list:
  76                 if (now - self.last_trigger[camera]) < 10:
  77                     if (self.triggers_in_the_past_seven_min[camera] <= 4 or
  78                         cameras_with_recent_triggers > 1):
  79                         ts = utils.timestamp()
  80                         p = self.choose_priority(camera, age)
  81                         print(("%s: ****** %s[%d] CAMERA TRIGGER ******" % (
  82                             ts, camera, p)))
  83                         triggers.append( ( "hidden/%s.html" % camera,
  84                                            self.choose_priority(camera, age)) )
  85                     else:
  86                         print(("%s: Camera %s too spammy, squelching it" % (
  87                             ts, camera)))
  88         except Exception as e:
  89             print(e)
  90             pass
  91
  92         if len(triggers) == 0:
  93             return None
  94         else:
  95             return triggers
  96
  97 #x = any_camera_trigger()
  98 #print(x.get_triggered_page_list())