# HG changeset patch
# User drewp@bigasterisk.com
# Date 1379344818 25200
# Node ID c860b8c10de94dbcfea3ae162c6914928cd3eb26
# Parent 4cd065b97fa1f7b9572e97a9235ce383cfab5500
move watchpins from /room, add a graph
Ignore-this: 32e58e567fb1fc0567fd2877319aaeff
diff -r 4cd065b97fa1 -r c860b8c10de9 service/theaterArduino/watchpins.html
--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/service/theaterArduino/watchpins.html Mon Sep 16 08:20:18 2013 -0700
@@ -0,0 +1,98 @@
+
+
+
+
+ theater motion sensor history:
+
+max age:
+
+
+
+
+
+
diff -r 4cd065b97fa1 -r c860b8c10de9 service/theaterArduino/watchpins.py
--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/service/theaterArduino/watchpins.py Mon Sep 16 08:20:18 2013 -0700
@@ -0,0 +1,246 @@
+"""
+listener to the POST messages sent by theaterArduino.py when a pin changes.
+records interesting events to mongodb, sends further messages.
+
+Will also serve activity stream.
+"""
+import sys, os, datetime, cyclone.web, simplejson, time
+from twisted.internet import reactor
+from twisted.internet.error import ConnectError
+from twisted.internet.defer import inlineCallbacks, returnValue
+from twisted.web.client import getPage
+from dateutil.tz import tzutc
+from pymongo import Connection
+from rdflib import Namespace, Literal, Graph
+from rdflib.parser import StringInputSource
+sys.path.append("/my/site/magma")
+from activitystream import ActivityStream
+from stategraph import StateGraph
+
+sys.path.append("/my/proj/homeauto/lib")
+from cycloneerr import PrettyErrorHandler
+from logsetup import log
+
+DEV = Namespace("http://projects.bigasterisk.com/device/")
+ROOM = Namespace("http://projects.bigasterisk.com/room/")
+zeroTime = datetime.datetime.fromtimestamp(0, tzutc())
+
+class PinChange(PrettyErrorHandler, cyclone.web.RequestHandler):
+ def post(self):
+ # there should be per-pin debounce settings so we don't log
+ # all the noise of a transition change
+
+ msg = simplejson.loads(self.request.body)
+ msg['t'] = datetime.datetime.now(tzutc())
+ msg['name'] = {9: 'downstairsDoorOpen',
+ 10: 'downstairsDoorMotion',
+ }[msg['pin']]
+ log.info("pinchange post %r", msg)
+ self.settings.mongo.insert(msg)
+
+ history = self.settings.history
+ if msg['pin'] == 10:
+ history['motionHistory'] = (history.get('motionHistory', []) + [(msg['t'], msg['level'])])[-50:]
+ if msg['level'] == 1:
+ if history.get('prevMotion', 0) == 0:
+ history['motionStart'] = msg['t']
+
+ history['prevMotion'] = msg['level']
+
+
+class InputChange(PrettyErrorHandler, cyclone.web.RequestHandler):
+ """
+ several other inputs post to here to get their events recorded,
+ too. This file shouldn't be in theaterArduino. See bedroomArduino,
+ frontDoorArduino, garageArduino.
+ """
+ def post(self):
+ msg = simplejson.loads(self.request.body)
+ msg['t'] = datetime.datetime.now(tzutc())
+ log.info(msg)
+ self.settings.mongo.insert(msg)
+
+ # trigger to entrancemusic? rdf graph change PSHB?
+
+class GraphHandler(PrettyErrorHandler, cyclone.web.RequestHandler):
+ """
+ fetch the pins from drv right now (so we don't have stale data),
+ and return an rdf graph describing what we know about the world
+ """
+ @inlineCallbacks
+ def get(self):
+ g = StateGraph(ctx=DEV['houseSensors'])
+
+ frontDoorDefer = getPage("http://slash:9080/door", timeout=2) # head start?
+
+ doorOpen = int((yield getPage("http://bang:9056/pin/d9", timeout=1)))
+ g.add((DEV['theaterDoorOpen'], ROOM['state'],
+ ROOM['open'] if doorOpen else ROOM['closed']))
+
+ for s in self.motionStatements(
+ currentMotion=int((yield getPage("http://bang:9056/pin/d10",
+ timeout=1)))):
+ g.add(s)
+
+ try:
+ for s in (yield self.getBedroomStatements()):
+ g.add(s)
+ except ConnectError, e:
+ g.add((ROOM['bedroomStatementFetch'], ROOM['error'],
+ Literal("getBedroomStatements: %s" % e)))
+
+ try:
+ frontDoor = yield frontDoorDefer
+ g.add((DEV['frontDoorOpen'], ROOM['state'],
+ ROOM[frontDoor] if frontDoor in ['open', 'closed'] else
+ ROOM['error']))
+ except Exception, e:
+ g.add((DEV['frontDoorOpen'], ROOM['error'], Literal(str(e))))
+
+ self.set_header('Content-type', 'application/x-trig')
+ self.write(g.asTrig())
+
+ def motionStatements(self, currentMotion):
+ uri = DEV['theaterDoorOutsideMotion']
+
+ yield (uri, ROOM['state'], ROOM['motion'] if currentMotion else ROOM['noMotion'])
+
+ now = datetime.datetime.now(tzutc())
+ if currentMotion:
+ try:
+ dt = now - self.settings.history['motionStart']
+ yield (uri, ROOM['motionDurationSec'], Literal(dt.total_seconds()))
+ if dt > datetime.timedelta(seconds=4):
+ yield (uri, ROOM['state'], ROOM['sustainedMotion'])
+ except KeyError:
+ pass
+
+ # this is history without the db, which means the window is
+ # limited and it could reset any time
+ if 'motionHistory' in self.settings.history:
+ yield ((uri, ROOM['history'],
+ Literal(simplejson.dumps(
+ [(round((t - now).total_seconds(), ndigits=2), v)
+ for t,v in self.settings.history['motionHistory']]))))
+
+ @inlineCallbacks
+ def getBedroomStatements(self):
+ trig = yield getPage("http://bang:9088/graph", timeout=1)
+ stmts = set()
+ for line in trig.splitlines():
+ if "http://projects.bigasterisk.com/device/bedroomMotion" in line:
+ g = Graph()
+ g.parse(StringInputSource(line+"\n"), format="nt")
+ for s in g:
+ stmts.add(s)
+ returnValue(stmts)
+
+class Activity(PrettyErrorHandler, cyclone.web.RequestHandler):
+ def get(self):
+ a = ActivityStream()
+ self.settings.mongo.ensure_index('t')
+ remaining = {'downstairsDoorMotion':10, 'downstairsDoorOpen':10,
+ 'frontDoorMotion':10, 'frontDoor':50, 'bedroomMotion': 10}
+ recent = {}
+ toAdd = []
+ for row in list(self.settings.mongo.find(sort=[('t', -1)],
+ limit=5000)):
+ try:
+ r = remaining[row['name']]
+ if r < 1:
+ continue
+ remaining[row['name']] = r - 1
+ except KeyError:
+ pass
+
+ # lots todo
+ if row['name'] == 'downstairsDoorMotion':
+ if row['level'] == 0:
+ continue
+ kw = dict(
+ actorUri="http://...",
+ actorName="downstairs door",
+ verbUri="...",
+ verbEnglish="sees",
+ objectUri="...",
+ objectName="backyard motion",
+ objectIcon="/magma/static/backyardMotion.png")
+ elif row['name'] == 'downstairsDoorOpen':
+ kw = dict(actorUri="http://bigasterisk.com/foaf/someone",
+ actorName="someone",
+ verbUri="op",
+ verbEnglish="opens" if row['level'] else "closes",
+ objectUri="...",
+ objectName="downstairs door",
+ objectIcon="/magma/static/downstairsDoor.png")
+ elif row['name'] == 'frontDoor':
+ kw = dict(actorUri="http://bigasterisk.com/foaf/someone",
+ actorName="someone",
+ verbUri="op",
+ verbEnglish="opens" if row['state']=='open' else "closes",
+ objectUri="...",
+ objectName="front door",
+ objectIcon="/magma/static/frontDoor.png")
+ elif row['name'] == 'frontDoorMotion':
+ if row['state'] == False:
+ continue
+ if 'frontDoorMotion' in recent:
+ pass#if row['t'
+ kw = dict(
+ actorUri="http://...",
+ actorName="front door",
+ verbUri="...",
+ verbEnglish="sees",
+ objectUri="...",
+ objectName="front yard motion",
+ objectIcon="/magma/static/frontYardMotion.png")
+ recent['frontDoorMotion'] = kw
+ elif row['name'] == 'bedroomMotion':
+ if not row['state']:
+ continue
+ kw = dict(
+ actorUri="http://...",
+ actorName="bedroom",
+ verbUri="...",
+ verbEnglish="sees",
+ objectUri="...",
+ objectName="bedroom motion",
+ objectIcon="/magma/static/bedroomMotion.png")
+ recent['bedroomMotion'] = kw
+ else:
+ raise NotImplementedError(row)
+
+ kw.update({'published' : row['t'],
+ 'entryUriComponents' : ('sensor', row['board'])})
+ toAdd.append(kw)
+
+ toAdd.reverse()
+ for kw in toAdd:
+ a.addEntry(**kw)
+
+ self.set_header("Content-type", "application/atom+xml")
+ self.write(a.makeAtom())
+
+class Application(cyclone.web.Application):
+ def __init__(self):
+ handlers = [
+ (r'/()', cyclone.web.StaticFileHandler,
+ {"path" : ".", "default_filename" : "watchpins.html"}),
+ (r'/pinChange', PinChange),
+ (r'/inputChange', InputChange),
+ (r'/activity', Activity),
+ (r'/graph', GraphHandler),
+ ]
+ settings = {
+ 'mongo' : Connection('bang', 27017,
+ tz_aware=True)['house']['sensor'],
+ 'history' : {
+ },
+ }
+ cyclone.web.Application.__init__(self, handlers, **settings)
+
+if __name__ == '__main__':
+ #from twisted.python import log as twlog
+ #twlog.startLogging(sys.stdout)
+ reactor.listenTCP(9069, Application())
+ reactor.run()