homeauto: service/reasoning/reasoning.py annotate

annotate service/reasoning/reasoning.py @ 919:6ee2a90fc816

bugs in async http client. move trig helpers to rdflibtrig, which can work with rdflib 4 Ignore-this: 81dc30256f5d2658e53fce60abea66db darcs-hash:20130910073852-312f9-f863b729e4c75f160d0740ae9038b5fab084b86b

author	drewp <drewp@bigasterisk.com>
date	Tue, 10 Sep 2013 00:38:52 -0700
parents	1c3cc9633a6e
children	7179284779fd

rev	line source
825 fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	1 #!bin/python
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	2 """
851 0d86b3955bcd rewriting reasoning to use graphs for config drewp <drewp@bigasterisk.com> parents: 850 diff changeset	3 Graph consists of:
0d86b3955bcd rewriting reasoning to use graphs for config drewp <drewp@bigasterisk.com> parents: 850 diff changeset	4 input/* (read at startup)
0d86b3955bcd rewriting reasoning to use graphs for config drewp <drewp@bigasterisk.com> parents: 850 diff changeset	5 webinput/* (new files are noticed in here)
0d86b3955bcd rewriting reasoning to use graphs for config drewp <drewp@bigasterisk.com> parents: 850 diff changeset	6 any number of remote graphs, specified in the other graph as objects of (:reasoning, :source, *), reread constantly
0d86b3955bcd rewriting reasoning to use graphs for config drewp <drewp@bigasterisk.com> parents: 850 diff changeset	7
825 fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	8 gather subgraphs from various services, run them through a rules
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	9 engine, and make http requests with the conclusions.
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	10
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	11 E.g. 'when drew's phone is near the house, and someone is awake,
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	12 unlock the door when the door's motion sensor is activated'
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	13
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	14 When do we gather? The services should be able to trigger us, perhaps
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	15 with PSHB, that their graph has changed.
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	16 """
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	17
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	18
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	19 from twisted.internet import reactor, task
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	20 from twisted.web.client import getPage
852 6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	21 from twisted.python.filepath import FilePath
851 0d86b3955bcd rewriting reasoning to use graphs for config drewp <drewp@bigasterisk.com> parents: 850 diff changeset	22 import time, traceback, sys, json, logging
825 fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	23 from rdflib.Graph import Graph, ConjunctiveGraph
852 6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	24 from rdflib import Namespace, URIRef, Literal, RDF, StringInputSource
825 fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	25 from FuXi.Rete.RuleStore import N3RuleStore
916 e8cce78a79d6 switch reasoning from restkit to async cyclone http client drewp <drewp@bigasterisk.com> parents: 882 diff changeset	26 from cyclone.httpclient import fetch
869 15af9d8c7186 reasoning has a websocket server that broadcasts some events drewp <drewp@bigasterisk.com> parents: 859 diff changeset	27 import cyclone.web, cyclone.websocket
825 fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	28 from inference import addTrig, infer
853 39857f82922e refactor graph ops drewp <drewp@bigasterisk.com> parents: 852 diff changeset	29 from graphop import graphEqual
825 fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	30
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	31 sys.path.append("../../lib")
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	32 from logsetup import log
919 6ee2a90fc816 bugs in async http client. move trig helpers to rdflibtrig, which can work with rdflib 4 drewp <drewp@bigasterisk.com> parents: 917 diff changeset	33 log.setLevel(logging.INFO)
854 1815d2343a3f cleanup drewp <drewp@bigasterisk.com> parents: 853 diff changeset	34 outlog = logging.getLogger('output')
917 1c3cc9633a6e reasoning turn on debug log drewp <drewp@bigasterisk.com> parents: 916 diff changeset	35 outlog.setLevel(logging.DEBUG)
825 fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	36
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	37 ROOM = Namespace("http://projects.bigasterisk.com/room/")
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	38 DEV = Namespace("http://projects.bigasterisk.com/device/")
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	39
851 0d86b3955bcd rewriting reasoning to use graphs for config drewp <drewp@bigasterisk.com> parents: 850 diff changeset	40
0d86b3955bcd rewriting reasoning to use graphs for config drewp <drewp@bigasterisk.com> parents: 850 diff changeset	41 class InputGraph(object):
0d86b3955bcd rewriting reasoning to use graphs for config drewp <drewp@bigasterisk.com> parents: 850 diff changeset	42 def __init__(self, inputDirs, onChange):
0d86b3955bcd rewriting reasoning to use graphs for config drewp <drewp@bigasterisk.com> parents: 850 diff changeset	43 """
854 1815d2343a3f cleanup drewp <drewp@bigasterisk.com> parents: 853 diff changeset	44 this has one Graph that's made of:
1815d2343a3f cleanup drewp <drewp@bigasterisk.com> parents: 853 diff changeset	45 - all .n3 files from inputDirs (read at startup)
1815d2343a3f cleanup drewp <drewp@bigasterisk.com> parents: 853 diff changeset	46 - all the remote graphs, specified in the file graphs
1815d2343a3f cleanup drewp <drewp@bigasterisk.com> parents: 853 diff changeset	47
1815d2343a3f cleanup drewp <drewp@bigasterisk.com> parents: 853 diff changeset	48 call updateFileData or updateRemoteData to reread those
1815d2343a3f cleanup drewp <drewp@bigasterisk.com> parents: 853 diff changeset	49 graphs. getGraph to access the combined graph.
851 0d86b3955bcd rewriting reasoning to use graphs for config drewp <drewp@bigasterisk.com> parents: 850 diff changeset	50
854 1815d2343a3f cleanup drewp <drewp@bigasterisk.com> parents: 853 diff changeset	51 onChange(self) is called if the contents of the full graph
1815d2343a3f cleanup drewp <drewp@bigasterisk.com> parents: 853 diff changeset	52 change (in an interesting way) during updateFileData or
851 0d86b3955bcd rewriting reasoning to use graphs for config drewp <drewp@bigasterisk.com> parents: 850 diff changeset	53 updateRemoteData. Interesting means statements other than the
854 1815d2343a3f cleanup drewp <drewp@bigasterisk.com> parents: 853 diff changeset	54 ones with the predicates on the boring list. onChange(self,
1815d2343a3f cleanup drewp <drewp@bigasterisk.com> parents: 853 diff changeset	55 oneShot=True) means: don't store the result of this change
1815d2343a3f cleanup drewp <drewp@bigasterisk.com> parents: 853 diff changeset	56 anywhere; it needs to be processed only once
851 0d86b3955bcd rewriting reasoning to use graphs for config drewp <drewp@bigasterisk.com> parents: 850 diff changeset	57 """
0d86b3955bcd rewriting reasoning to use graphs for config drewp <drewp@bigasterisk.com> parents: 850 diff changeset	58 self.inputDirs = inputDirs
0d86b3955bcd rewriting reasoning to use graphs for config drewp <drewp@bigasterisk.com> parents: 850 diff changeset	59 self.onChange = onChange
0d86b3955bcd rewriting reasoning to use graphs for config drewp <drewp@bigasterisk.com> parents: 850 diff changeset	60 self._fileGraph = Graph()
0d86b3955bcd rewriting reasoning to use graphs for config drewp <drewp@bigasterisk.com> parents: 850 diff changeset	61 self._remoteGraph = None
852 6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	62 self._combinedGraph = None
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	63 self._oneShotAdditionGraph = None
851 0d86b3955bcd rewriting reasoning to use graphs for config drewp <drewp@bigasterisk.com> parents: 850 diff changeset	64
0d86b3955bcd rewriting reasoning to use graphs for config drewp <drewp@bigasterisk.com> parents: 850 diff changeset	65 def updateFileData(self):
0d86b3955bcd rewriting reasoning to use graphs for config drewp <drewp@bigasterisk.com> parents: 850 diff changeset	66 """
0d86b3955bcd rewriting reasoning to use graphs for config drewp <drewp@bigasterisk.com> parents: 850 diff changeset	67 make sure we contain the correct data from the files in inputDirs
0d86b3955bcd rewriting reasoning to use graphs for config drewp <drewp@bigasterisk.com> parents: 850 diff changeset	68 """
0d86b3955bcd rewriting reasoning to use graphs for config drewp <drewp@bigasterisk.com> parents: 850 diff changeset	69 # this sample one is actually only needed for the output, but I don't
0d86b3955bcd rewriting reasoning to use graphs for config drewp <drewp@bigasterisk.com> parents: 850 diff changeset	70 # think I want to have a separate graph for the output
0d86b3955bcd rewriting reasoning to use graphs for config drewp <drewp@bigasterisk.com> parents: 850 diff changeset	71 # handling
0d86b3955bcd rewriting reasoning to use graphs for config drewp <drewp@bigasterisk.com> parents: 850 diff changeset	72 log.debug("read file graphs")
852 6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	73 for fp in FilePath("input").walk():
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	74 if fp.isdir():
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	75 continue
916 e8cce78a79d6 switch reasoning from restkit to async cyclone http client drewp <drewp@bigasterisk.com> parents: 882 diff changeset	76 if fp.splitext()[1] != '.n3':
e8cce78a79d6 switch reasoning from restkit to async cyclone http client drewp <drewp@bigasterisk.com> parents: 882 diff changeset	77 continue
852 6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	78 log.debug("read %s", fp)
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	79 # todo: if this fails, leave the report in the graph
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	80 self._fileGraph.parse(fp.open(), format="n3")
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	81 self._combinedGraph = None
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	82
851 0d86b3955bcd rewriting reasoning to use graphs for config drewp <drewp@bigasterisk.com> parents: 850 diff changeset	83 self.onChange(self)
0d86b3955bcd rewriting reasoning to use graphs for config drewp <drewp@bigasterisk.com> parents: 850 diff changeset	84
0d86b3955bcd rewriting reasoning to use graphs for config drewp <drewp@bigasterisk.com> parents: 850 diff changeset	85 def updateRemoteData(self):
0d86b3955bcd rewriting reasoning to use graphs for config drewp <drewp@bigasterisk.com> parents: 850 diff changeset	86 """
0d86b3955bcd rewriting reasoning to use graphs for config drewp <drewp@bigasterisk.com> parents: 850 diff changeset	87 read all remote graphs (which are themselves enumerated within
0d86b3955bcd rewriting reasoning to use graphs for config drewp <drewp@bigasterisk.com> parents: 850 diff changeset	88 the file data)
0d86b3955bcd rewriting reasoning to use graphs for config drewp <drewp@bigasterisk.com> parents: 850 diff changeset	89 """
0d86b3955bcd rewriting reasoning to use graphs for config drewp <drewp@bigasterisk.com> parents: 850 diff changeset	90 log.debug("read remote graphs")
0d86b3955bcd rewriting reasoning to use graphs for config drewp <drewp@bigasterisk.com> parents: 850 diff changeset	91 g = ConjunctiveGraph()
0d86b3955bcd rewriting reasoning to use graphs for config drewp <drewp@bigasterisk.com> parents: 850 diff changeset	92 for source in self._fileGraph.objects(ROOM['reasoning'],
0d86b3955bcd rewriting reasoning to use graphs for config drewp <drewp@bigasterisk.com> parents: 850 diff changeset	93 ROOM['source']):
0d86b3955bcd rewriting reasoning to use graphs for config drewp <drewp@bigasterisk.com> parents: 850 diff changeset	94 try:
852 6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	95 # this part could be parallelized
851 0d86b3955bcd rewriting reasoning to use graphs for config drewp <drewp@bigasterisk.com> parents: 850 diff changeset	96 fetchTime = addTrig(g, source)
0d86b3955bcd rewriting reasoning to use graphs for config drewp <drewp@bigasterisk.com> parents: 850 diff changeset	97 except Exception, e:
852 6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	98 log.error(" adding source %s: %s", source, e)
851 0d86b3955bcd rewriting reasoning to use graphs for config drewp <drewp@bigasterisk.com> parents: 850 diff changeset	99 g.add((URIRef(source), ROOM['graphLoadError'], Literal(str(e))))
0d86b3955bcd rewriting reasoning to use graphs for config drewp <drewp@bigasterisk.com> parents: 850 diff changeset	100 g.add((URIRef(source), RDF.type, ROOM['FailedGraphLoad']))
0d86b3955bcd rewriting reasoning to use graphs for config drewp <drewp@bigasterisk.com> parents: 850 diff changeset	101 else:
0d86b3955bcd rewriting reasoning to use graphs for config drewp <drewp@bigasterisk.com> parents: 850 diff changeset	102 g.add((URIRef(source), ROOM['graphLoadSecs'],
0d86b3955bcd rewriting reasoning to use graphs for config drewp <drewp@bigasterisk.com> parents: 850 diff changeset	103 Literal(fetchTime)))
0d86b3955bcd rewriting reasoning to use graphs for config drewp <drewp@bigasterisk.com> parents: 850 diff changeset	104 prevGraph = self._remoteGraph
0d86b3955bcd rewriting reasoning to use graphs for config drewp <drewp@bigasterisk.com> parents: 850 diff changeset	105 self._remoteGraph = g
852 6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	106 self._combinedGraph = None
851 0d86b3955bcd rewriting reasoning to use graphs for config drewp <drewp@bigasterisk.com> parents: 850 diff changeset	107 if (prevGraph is None or
0d86b3955bcd rewriting reasoning to use graphs for config drewp <drewp@bigasterisk.com> parents: 850 diff changeset	108 not graphEqual(g, prevGraph, ignorePredicates=[
0d86b3955bcd rewriting reasoning to use graphs for config drewp <drewp@bigasterisk.com> parents: 850 diff changeset	109 ROOM.signalStrength,
852 6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	110 ROOM.graphLoadSecs,
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	111 # perhaps anything with a number-datatype for its
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	112 # object should be filtered out, and you have to make
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	113 # an upstream quantization (e.g. 'temp high'/'temp
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	114 # low') if you want to do reasoning on the difference
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	115 URIRef("http://bigasterisk.com/map#lastSeenAgoSec"),
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	116 URIRef("http://bigasterisk.com/map#lastSeenAgo"),
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	117 URIRef("http://projects.bigasterisk.com/room/usingPower"),
859 379cefec542e screen out more values that change on every update drewp <drewp@bigasterisk.com> parents: 854 diff changeset	118 URIRef("http://projects.bigasterisk.com/room/idleTimeMinutes"),
379cefec542e screen out more values that change on every update drewp <drewp@bigasterisk.com> parents: 854 diff changeset	119 URIRef("http://projects.bigasterisk.com/room/idleTimeMs"),
852 6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	120 ])):
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	121 log.debug(" remote graph changed")
851 0d86b3955bcd rewriting reasoning to use graphs for config drewp <drewp@bigasterisk.com> parents: 850 diff changeset	122 self.onChange(self)
0d86b3955bcd rewriting reasoning to use graphs for config drewp <drewp@bigasterisk.com> parents: 850 diff changeset	123 else:
852 6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	124 log.debug(" remote graph is unchanged")
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	125
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	126 def addOneShot(self, g):
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	127 """
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	128 add this graph to the total, call onChange, and then revert
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	129 the addition of this graph
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	130 """
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	131 self._oneShotAdditionGraph = g
854 1815d2343a3f cleanup drewp <drewp@bigasterisk.com> parents: 853 diff changeset	132 self._combinedGraph = None
852 6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	133 try:
854 1815d2343a3f cleanup drewp <drewp@bigasterisk.com> parents: 853 diff changeset	134 self.onChange(self, oneShot=True)
852 6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	135 finally:
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	136 self._oneShotAdditionGraph = None
854 1815d2343a3f cleanup drewp <drewp@bigasterisk.com> parents: 853 diff changeset	137 self._combinedGraph = None
851 0d86b3955bcd rewriting reasoning to use graphs for config drewp <drewp@bigasterisk.com> parents: 850 diff changeset	138
0d86b3955bcd rewriting reasoning to use graphs for config drewp <drewp@bigasterisk.com> parents: 850 diff changeset	139 def getGraph(self):
0d86b3955bcd rewriting reasoning to use graphs for config drewp <drewp@bigasterisk.com> parents: 850 diff changeset	140 """rdflib Graph with the file+remote contents of the input graph"""
852 6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	141 # this could be much faster with the combined readonly graph
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	142 # view from rdflib
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	143 if self._combinedGraph is None:
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	144 self._combinedGraph = Graph()
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	145 if self._fileGraph:
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	146 for s in self._fileGraph:
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	147 self._combinedGraph.add(s)
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	148 if self._remoteGraph:
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	149 for s in self._remoteGraph:
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	150 self._combinedGraph.add(s)
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	151 if self._oneShotAdditionGraph:
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	152 for s in self._oneShotAdditionGraph:
869 15af9d8c7186 reasoning has a websocket server that broadcasts some events drewp <drewp@bigasterisk.com> parents: 859 diff changeset	153 self._combinedGraph.add(s)
852 6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	154
869 15af9d8c7186 reasoning has a websocket server that broadcasts some events drewp <drewp@bigasterisk.com> parents: 859 diff changeset	155 return self._combinedGraph
825 fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	156
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	157 class Reasoning(object):
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	158 def __init__(self):
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	159 self.prevGraph = None
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	160 self.lastPollTime = 0
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	161 self.lastError = ""
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	162
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	163 self.rulesN3 = "(not read yet)"
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	164 self.inferred = Graph() # gets replaced in each graphChanged call
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	165
851 0d86b3955bcd rewriting reasoning to use graphs for config drewp <drewp@bigasterisk.com> parents: 850 diff changeset	166 self.inputGraph = InputGraph([], self.graphChanged)
852 6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	167 self.inputGraph.updateFileData()
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	168
851 0d86b3955bcd rewriting reasoning to use graphs for config drewp <drewp@bigasterisk.com> parents: 850 diff changeset	169
825 fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	170 def readRules(self):
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	171 self.rulesN3 = open('rules.n3').read() # for web display
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	172 self.ruleStore = N3RuleStore()
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	173 self.ruleGraph = Graph(self.ruleStore)
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	174 self.ruleGraph.parse('rules.n3', format='n3') # for inference
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	175
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	176 def poll(self):
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	177 try:
851 0d86b3955bcd rewriting reasoning to use graphs for config drewp <drewp@bigasterisk.com> parents: 850 diff changeset	178 self.inputGraph.updateRemoteData()
825 fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	179 self.lastPollTime = time.time()
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	180 except Exception, e:
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	181 log.error(traceback.format_exc())
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	182 self.lastError = str(e)
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	183
854 1815d2343a3f cleanup drewp <drewp@bigasterisk.com> parents: 853 diff changeset	184 def graphChanged(self, inputGraph, oneShot=False):
869 15af9d8c7186 reasoning has a websocket server that broadcasts some events drewp <drewp@bigasterisk.com> parents: 859 diff changeset	185 t1 = time.time()
854 1815d2343a3f cleanup drewp <drewp@bigasterisk.com> parents: 853 diff changeset	186 oldInferred = self.inferred
825 fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	187 try:
854 1815d2343a3f cleanup drewp <drewp@bigasterisk.com> parents: 853 diff changeset	188 try:
1815d2343a3f cleanup drewp <drewp@bigasterisk.com> parents: 853 diff changeset	189 t1 = time.time()
1815d2343a3f cleanup drewp <drewp@bigasterisk.com> parents: 853 diff changeset	190 self.readRules()
1815d2343a3f cleanup drewp <drewp@bigasterisk.com> parents: 853 diff changeset	191 ruleParseTime = time.time() - t1
1815d2343a3f cleanup drewp <drewp@bigasterisk.com> parents: 853 diff changeset	192 except ValueError, e:
1815d2343a3f cleanup drewp <drewp@bigasterisk.com> parents: 853 diff changeset	193 # this is so if you're just watching the inferred output,
1815d2343a3f cleanup drewp <drewp@bigasterisk.com> parents: 853 diff changeset	194 # you'll see the error too
1815d2343a3f cleanup drewp <drewp@bigasterisk.com> parents: 853 diff changeset	195 self.inferred = Graph()
1815d2343a3f cleanup drewp <drewp@bigasterisk.com> parents: 853 diff changeset	196 self.inferred.add((ROOM['reasoner'], ROOM['ruleParseError'],
1815d2343a3f cleanup drewp <drewp@bigasterisk.com> parents: 853 diff changeset	197 Literal(traceback.format_exc())))
1815d2343a3f cleanup drewp <drewp@bigasterisk.com> parents: 853 diff changeset	198 raise
825 fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	199
854 1815d2343a3f cleanup drewp <drewp@bigasterisk.com> parents: 853 diff changeset	200 g = inputGraph.getGraph()
1815d2343a3f cleanup drewp <drewp@bigasterisk.com> parents: 853 diff changeset	201 self.inferred = self._makeInferred(g)
1815d2343a3f cleanup drewp <drewp@bigasterisk.com> parents: 853 diff changeset	202 self.inferred.add((ROOM['reasoner'], ROOM['ruleParseTime'],
1815d2343a3f cleanup drewp <drewp@bigasterisk.com> parents: 853 diff changeset	203 Literal(ruleParseTime)))
1815d2343a3f cleanup drewp <drewp@bigasterisk.com> parents: 853 diff changeset	204
869 15af9d8c7186 reasoning has a websocket server that broadcasts some events drewp <drewp@bigasterisk.com> parents: 859 diff changeset	205 t2 = time.time()
854 1815d2343a3f cleanup drewp <drewp@bigasterisk.com> parents: 853 diff changeset	206 self.putResults(self.inferred)
869 15af9d8c7186 reasoning has a websocket server that broadcasts some events drewp <drewp@bigasterisk.com> parents: 859 diff changeset	207 putResultsTime = time.time() - t2
15af9d8c7186 reasoning has a websocket server that broadcasts some events drewp <drewp@bigasterisk.com> parents: 859 diff changeset	208 t3 = time.time()
854 1815d2343a3f cleanup drewp <drewp@bigasterisk.com> parents: 853 diff changeset	209 self._postToMagma(g)
869 15af9d8c7186 reasoning has a websocket server that broadcasts some events drewp <drewp@bigasterisk.com> parents: 859 diff changeset	210 postMagmaTime = time.time() - t3
854 1815d2343a3f cleanup drewp <drewp@bigasterisk.com> parents: 853 diff changeset	211 finally:
1815d2343a3f cleanup drewp <drewp@bigasterisk.com> parents: 853 diff changeset	212 if oneShot:
1815d2343a3f cleanup drewp <drewp@bigasterisk.com> parents: 853 diff changeset	213 self.inferred = oldInferred
869 15af9d8c7186 reasoning has a websocket server that broadcasts some events drewp <drewp@bigasterisk.com> parents: 859 diff changeset	214 log.info("graphChanged %.1f ms (putResults %.1f ms; postToMagma %.1f ms)" %
15af9d8c7186 reasoning has a websocket server that broadcasts some events drewp <drewp@bigasterisk.com> parents: 859 diff changeset	215 ((time.time() - t1) * 1000,
15af9d8c7186 reasoning has a websocket server that broadcasts some events drewp <drewp@bigasterisk.com> parents: 859 diff changeset	216 putResultsTime * 1000,
15af9d8c7186 reasoning has a websocket server that broadcasts some events drewp <drewp@bigasterisk.com> parents: 859 diff changeset	217 postMagmaTime * 1000))
854 1815d2343a3f cleanup drewp <drewp@bigasterisk.com> parents: 853 diff changeset	218
1815d2343a3f cleanup drewp <drewp@bigasterisk.com> parents: 853 diff changeset	219 def _makeInferred(self, inputGraph):
825 fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	220 t1 = time.time()
854 1815d2343a3f cleanup drewp <drewp@bigasterisk.com> parents: 853 diff changeset	221 out = infer(inputGraph, self.ruleStore)
825 fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	222 inferenceTime = time.time() - t1
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	223
854 1815d2343a3f cleanup drewp <drewp@bigasterisk.com> parents: 853 diff changeset	224 out.add((ROOM['reasoner'], ROOM['inferenceTime'],
916 e8cce78a79d6 switch reasoning from restkit to async cyclone http client drewp <drewp@bigasterisk.com> parents: 882 diff changeset	225 Literal(inferenceTime)))
854 1815d2343a3f cleanup drewp <drewp@bigasterisk.com> parents: 853 diff changeset	226 return out
825 fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	227
854 1815d2343a3f cleanup drewp <drewp@bigasterisk.com> parents: 853 diff changeset	228 def _postToMagma(self, inputGraph):
916 e8cce78a79d6 switch reasoning from restkit to async cyclone http client drewp <drewp@bigasterisk.com> parents: 882 diff changeset	229
e8cce78a79d6 switch reasoning from restkit to async cyclone http client drewp <drewp@bigasterisk.com> parents: 882 diff changeset	230 inputGraphNt = inputGraph.serialize(format="nt")
e8cce78a79d6 switch reasoning from restkit to async cyclone http client drewp <drewp@bigasterisk.com> parents: 882 diff changeset	231 inferredNt = self.inferred.serialize(format="nt")
e8cce78a79d6 switch reasoning from restkit to async cyclone http client drewp <drewp@bigasterisk.com> parents: 882 diff changeset	232 body = json.dumps({"input": inputGraphNt,
e8cce78a79d6 switch reasoning from restkit to async cyclone http client drewp <drewp@bigasterisk.com> parents: 882 diff changeset	233 "inferred": inferredNt})
e8cce78a79d6 switch reasoning from restkit to async cyclone http client drewp <drewp@bigasterisk.com> parents: 882 diff changeset	234 def err(e):
825 fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	235 log.error("while sending changes to magma:")
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	236 log.error(e)
851 0d86b3955bcd rewriting reasoning to use graphs for config drewp <drewp@bigasterisk.com> parents: 850 diff changeset	237
916 e8cce78a79d6 switch reasoning from restkit to async cyclone http client drewp <drewp@bigasterisk.com> parents: 882 diff changeset	238 fetch("http://bang:8014/reasoningChange",
e8cce78a79d6 switch reasoning from restkit to async cyclone http client drewp <drewp@bigasterisk.com> parents: 882 diff changeset	239 method="POST",
e8cce78a79d6 switch reasoning from restkit to async cyclone http client drewp <drewp@bigasterisk.com> parents: 882 diff changeset	240 timeout=2,
919 6ee2a90fc816 bugs in async http client. move trig helpers to rdflibtrig, which can work with rdflib 4 drewp <drewp@bigasterisk.com> parents: 917 diff changeset	241 postdata=body,
916 e8cce78a79d6 switch reasoning from restkit to async cyclone http client drewp <drewp@bigasterisk.com> parents: 882 diff changeset	242 headers={"content-type" : ["application/json"]}).addErrback(err)
e8cce78a79d6 switch reasoning from restkit to async cyclone http client drewp <drewp@bigasterisk.com> parents: 882 diff changeset	243
e8cce78a79d6 switch reasoning from restkit to async cyclone http client drewp <drewp@bigasterisk.com> parents: 882 diff changeset	244 def _put(self, url, payload):
e8cce78a79d6 switch reasoning from restkit to async cyclone http client drewp <drewp@bigasterisk.com> parents: 882 diff changeset	245 def err(e):
919 6ee2a90fc816 bugs in async http client. move trig helpers to rdflibtrig, which can work with rdflib 4 drewp <drewp@bigasterisk.com> parents: 917 diff changeset	246 outlog.warn("put %s failed", url)
916 e8cce78a79d6 switch reasoning from restkit to async cyclone http client drewp <drewp@bigasterisk.com> parents: 882 diff changeset	247 outlog.info("PUT %s payload=%r", url, payload)
919 6ee2a90fc816 bugs in async http client. move trig helpers to rdflibtrig, which can work with rdflib 4 drewp <drewp@bigasterisk.com> parents: 917 diff changeset	248 fetch(url, method="PUT", postdata=payload, timeout=2).addErrback(err)
916 e8cce78a79d6 switch reasoning from restkit to async cyclone http client drewp <drewp@bigasterisk.com> parents: 882 diff changeset	249
838 36dbbb01d689 redo the http PUT request part of the reasoner drewp <drewp@bigasterisk.com> parents: 825 diff changeset	250 def putResults(self, inferred):
36dbbb01d689 redo the http PUT request part of the reasoner drewp <drewp@bigasterisk.com> parents: 825 diff changeset	251 """
36dbbb01d689 redo the http PUT request part of the reasoner drewp <drewp@bigasterisk.com> parents: 825 diff changeset	252 some conclusions in the inferred graph lead to PUT requests
36dbbb01d689 redo the http PUT request part of the reasoner drewp <drewp@bigasterisk.com> parents: 825 diff changeset	253 getting made
36dbbb01d689 redo the http PUT request part of the reasoner drewp <drewp@bigasterisk.com> parents: 825 diff changeset	254
36dbbb01d689 redo the http PUT request part of the reasoner drewp <drewp@bigasterisk.com> parents: 825 diff changeset	255 if the graph contains (?d ?p ?o) and ?d and ?p are a device
36dbbb01d689 redo the http PUT request part of the reasoner drewp <drewp@bigasterisk.com> parents: 825 diff changeset	256 and predicate we support PUTs for, then we look up
36dbbb01d689 redo the http PUT request part of the reasoner drewp <drewp@bigasterisk.com> parents: 825 diff changeset	257 (?d :putUrl ?url) and (?o :putValue ?val) and call
36dbbb01d689 redo the http PUT request part of the reasoner drewp <drewp@bigasterisk.com> parents: 825 diff changeset	258 PUT ?url <- ?val
36dbbb01d689 redo the http PUT request part of the reasoner drewp <drewp@bigasterisk.com> parents: 825 diff changeset	259
36dbbb01d689 redo the http PUT request part of the reasoner drewp <drewp@bigasterisk.com> parents: 825 diff changeset	260 If the graph doesn't contain any matches, we use (?d
36dbbb01d689 redo the http PUT request part of the reasoner drewp <drewp@bigasterisk.com> parents: 825 diff changeset	261 :zeroValue ?val) for the value and PUT that.
36dbbb01d689 redo the http PUT request part of the reasoner drewp <drewp@bigasterisk.com> parents: 825 diff changeset	262 """
852 6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	263 deviceGraph = self.inputGraph.getGraph()
869 15af9d8c7186 reasoning has a websocket server that broadcasts some events drewp <drewp@bigasterisk.com> parents: 859 diff changeset	264 self.oneShotPostActions(deviceGraph, inferred)
838 36dbbb01d689 redo the http PUT request part of the reasoner drewp <drewp@bigasterisk.com> parents: 825 diff changeset	265 for dev, pred in [
36dbbb01d689 redo the http PUT request part of the reasoner drewp <drewp@bigasterisk.com> parents: 825 diff changeset	266 # the config of each putUrl should actually be in the
36dbbb01d689 redo the http PUT request part of the reasoner drewp <drewp@bigasterisk.com> parents: 825 diff changeset	267 # context of a dev and predicate pair, and then that would
36dbbb01d689 redo the http PUT request part of the reasoner drewp <drewp@bigasterisk.com> parents: 825 diff changeset	268 # be the source of this list
36dbbb01d689 redo the http PUT request part of the reasoner drewp <drewp@bigasterisk.com> parents: 825 diff changeset	269 (DEV.theaterDoorLock, ROOM.state),
36dbbb01d689 redo the http PUT request part of the reasoner drewp <drewp@bigasterisk.com> parents: 825 diff changeset	270 (URIRef('http://bigasterisk.com/host/bang/monitor'), ROOM.powerState),
852 6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	271 (URIRef('http://bigasterisk.com/host/dash/monitor'), ROOM.powerState),
838 36dbbb01d689 redo the http PUT request part of the reasoner drewp <drewp@bigasterisk.com> parents: 825 diff changeset	272 ]:
852 6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	273 url = deviceGraph.value(dev, ROOM.putUrl)
838 36dbbb01d689 redo the http PUT request part of the reasoner drewp <drewp@bigasterisk.com> parents: 825 diff changeset	274
916 e8cce78a79d6 switch reasoning from restkit to async cyclone http client drewp <drewp@bigasterisk.com> parents: 882 diff changeset	275 if url and dev == DEV.theaterDoorLock: # ew
e8cce78a79d6 switch reasoning from restkit to async cyclone http client drewp <drewp@bigasterisk.com> parents: 882 diff changeset	276 self._put(url+"/mode", payload="output")
838 36dbbb01d689 redo the http PUT request part of the reasoner drewp <drewp@bigasterisk.com> parents: 825 diff changeset	277
36dbbb01d689 redo the http PUT request part of the reasoner drewp <drewp@bigasterisk.com> parents: 825 diff changeset	278 inferredObjects = list(inferred.objects(dev, pred))
36dbbb01d689 redo the http PUT request part of the reasoner drewp <drewp@bigasterisk.com> parents: 825 diff changeset	279 if len(inferredObjects) == 0:
852 6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	280 self.putZero(deviceGraph, dev, pred, url)
838 36dbbb01d689 redo the http PUT request part of the reasoner drewp <drewp@bigasterisk.com> parents: 825 diff changeset	281 elif len(inferredObjects) == 1:
852 6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	282 self.putInferred(deviceGraph, dev, pred, url, inferredObjects[0])
838 36dbbb01d689 redo the http PUT request part of the reasoner drewp <drewp@bigasterisk.com> parents: 825 diff changeset	283 elif len(inferredObjects) > 1:
36dbbb01d689 redo the http PUT request part of the reasoner drewp <drewp@bigasterisk.com> parents: 825 diff changeset	284 log.info("conflict, ignoring: %s has %s of %s" %
36dbbb01d689 redo the http PUT request part of the reasoner drewp <drewp@bigasterisk.com> parents: 825 diff changeset	285 (dev, pred, inferredObjects))
36dbbb01d689 redo the http PUT request part of the reasoner drewp <drewp@bigasterisk.com> parents: 825 diff changeset	286 # write about it to the inferred graph?
850 887d47682d94 /status page, errors on failed graphs, time reports of successful fetches drewp <drewp@bigasterisk.com> parents: 838 diff changeset	287
852 6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	288 self.frontDoorPuts(deviceGraph, inferred)
838 36dbbb01d689 redo the http PUT request part of the reasoner drewp <drewp@bigasterisk.com> parents: 825 diff changeset	289
869 15af9d8c7186 reasoning has a websocket server that broadcasts some events drewp <drewp@bigasterisk.com> parents: 859 diff changeset	290
15af9d8c7186 reasoning has a websocket server that broadcasts some events drewp <drewp@bigasterisk.com> parents: 859 diff changeset	291 def oneShotPostActions(self, deviceGraph, inferred):
15af9d8c7186 reasoning has a websocket server that broadcasts some events drewp <drewp@bigasterisk.com> parents: 859 diff changeset	292 # nothing in this actually makes them one-shot yet. they'll
15af9d8c7186 reasoning has a websocket server that broadcasts some events drewp <drewp@bigasterisk.com> parents: 859 diff changeset	293 # just fire as often as we get in here, which is not desirable
15af9d8c7186 reasoning has a websocket server that broadcasts some events drewp <drewp@bigasterisk.com> parents: 859 diff changeset	294 for s, p in [
882 1e2a3f85c61a keep hacking reasoning to handle my output actions drewp <drewp@bigasterisk.com> parents: 869 diff changeset	295 (URIRef('http://bigasterisk.com/host/star/slideshow'), ROOM.postAction),
1e2a3f85c61a keep hacking reasoning to handle my output actions drewp <drewp@bigasterisk.com> parents: 869 diff changeset	296 (URIRef('http://bigasterisk.com/host/star/sound'), ROOM.postAction),
1e2a3f85c61a keep hacking reasoning to handle my output actions drewp <drewp@bigasterisk.com> parents: 869 diff changeset	297 (URIRef('http://bigasterisk.com/host/slash/sound'), ROOM.postAction),
869 15af9d8c7186 reasoning has a websocket server that broadcasts some events drewp <drewp@bigasterisk.com> parents: 859 diff changeset	298 ]:
882 1e2a3f85c61a keep hacking reasoning to handle my output actions drewp <drewp@bigasterisk.com> parents: 869 diff changeset	299 log.info("find inferred objs %r %r" % (s, p))
869 15af9d8c7186 reasoning has a websocket server that broadcasts some events drewp <drewp@bigasterisk.com> parents: 859 diff changeset	300 for postTarget in inferred.objects(s, p):
882 1e2a3f85c61a keep hacking reasoning to handle my output actions drewp <drewp@bigasterisk.com> parents: 869 diff changeset	301 log.info("post target %r", postTarget)
869 15af9d8c7186 reasoning has a websocket server that broadcasts some events drewp <drewp@bigasterisk.com> parents: 859 diff changeset	302 sendToLiveClients({"s":s, "p":p, "o":postTarget})
882 1e2a3f85c61a keep hacking reasoning to handle my output actions drewp <drewp@bigasterisk.com> parents: 869 diff changeset	303 if s in [URIRef('http://bigasterisk.com/host/star/sound'),
1e2a3f85c61a keep hacking reasoning to handle my output actions drewp <drewp@bigasterisk.com> parents: 869 diff changeset	304 URIRef('http://bigasterisk.com/host/slash/sound'),
1e2a3f85c61a keep hacking reasoning to handle my output actions drewp <drewp@bigasterisk.com> parents: 869 diff changeset	305 URIRef('http://bigasterisk.com/host/star/slideshow'),
1e2a3f85c61a keep hacking reasoning to handle my output actions drewp <drewp@bigasterisk.com> parents: 869 diff changeset	306 ]:
869 15af9d8c7186 reasoning has a websocket server that broadcasts some events drewp <drewp@bigasterisk.com> parents: 859 diff changeset	307 try:
15af9d8c7186 reasoning has a websocket server that broadcasts some events drewp <drewp@bigasterisk.com> parents: 859 diff changeset	308 response = restkit.request(url=postTarget, method="POST", body="")
15af9d8c7186 reasoning has a websocket server that broadcasts some events drewp <drewp@bigasterisk.com> parents: 859 diff changeset	309 except Exception, e:
15af9d8c7186 reasoning has a websocket server that broadcasts some events drewp <drewp@bigasterisk.com> parents: 859 diff changeset	310 log.warn("post to %s failed: %s" % (postTarget, e))
15af9d8c7186 reasoning has a websocket server that broadcasts some events drewp <drewp@bigasterisk.com> parents: 859 diff changeset	311 else:
15af9d8c7186 reasoning has a websocket server that broadcasts some events drewp <drewp@bigasterisk.com> parents: 859 diff changeset	312 log.info("post to %s got status %s" %
15af9d8c7186 reasoning has a websocket server that broadcasts some events drewp <drewp@bigasterisk.com> parents: 859 diff changeset	313 (postTarget, response.status))
15af9d8c7186 reasoning has a websocket server that broadcasts some events drewp <drewp@bigasterisk.com> parents: 859 diff changeset	314
852 6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	315 def putZero(self, deviceGraph, dev, pred, putUrl):
838 36dbbb01d689 redo the http PUT request part of the reasoner drewp <drewp@bigasterisk.com> parents: 825 diff changeset	316 # zerovalue should be a function of pred as well.
852 6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	317 value = deviceGraph.value(dev, ROOM.zeroValue)
838 36dbbb01d689 redo the http PUT request part of the reasoner drewp <drewp@bigasterisk.com> parents: 825 diff changeset	318 if value is not None:
854 1815d2343a3f cleanup drewp <drewp@bigasterisk.com> parents: 853 diff changeset	319 outlog.info("put zero (%r) to %s", value, putUrl)
919 6ee2a90fc816 bugs in async http client. move trig helpers to rdflibtrig, which can work with rdflib 4 drewp <drewp@bigasterisk.com> parents: 917 diff changeset	320 self._put(putUrl, payload=str(value))
838 36dbbb01d689 redo the http PUT request part of the reasoner drewp <drewp@bigasterisk.com> parents: 825 diff changeset	321 # this should be written back into the inferred graph
36dbbb01d689 redo the http PUT request part of the reasoner drewp <drewp@bigasterisk.com> parents: 825 diff changeset	322 # for feedback
36dbbb01d689 redo the http PUT request part of the reasoner drewp <drewp@bigasterisk.com> parents: 825 diff changeset	323
852 6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	324 def putInferred(self, deviceGraph, dev, pred, putUrl, obj):
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	325 value = deviceGraph.value(obj, ROOM.putValue)
838 36dbbb01d689 redo the http PUT request part of the reasoner drewp <drewp@bigasterisk.com> parents: 825 diff changeset	326 if value is not None:
854 1815d2343a3f cleanup drewp <drewp@bigasterisk.com> parents: 853 diff changeset	327 outlog.info("put %s to %s", value, putUrl)
919 6ee2a90fc816 bugs in async http client. move trig helpers to rdflibtrig, which can work with rdflib 4 drewp <drewp@bigasterisk.com> parents: 917 diff changeset	328 self._put(putUrl, payload=str(value))
838 36dbbb01d689 redo the http PUT request part of the reasoner drewp <drewp@bigasterisk.com> parents: 825 diff changeset	329 else:
854 1815d2343a3f cleanup drewp <drewp@bigasterisk.com> parents: 853 diff changeset	330 outlog.warn("%s %s %s has no :putValue" %
838 36dbbb01d689 redo the http PUT request part of the reasoner drewp <drewp@bigasterisk.com> parents: 825 diff changeset	331 (dev, pred, obj))
850 887d47682d94 /status page, errors on failed graphs, time reports of successful fetches drewp <drewp@bigasterisk.com> parents: 838 diff changeset	332
852 6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	333 def frontDoorPuts(self, deviceGraph, inferred):
838 36dbbb01d689 redo the http PUT request part of the reasoner drewp <drewp@bigasterisk.com> parents: 825 diff changeset	334 # todo: shouldn't have to be a special case
36dbbb01d689 redo the http PUT request part of the reasoner drewp <drewp@bigasterisk.com> parents: 825 diff changeset	335 brt = inferred.value(DEV.frontDoorLcd, ROOM.brightness)
852 6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	336 if brt is None:
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	337 return
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	338 url = deviceGraph.value(DEV.frontDoorLcdBrightness, ROOM.putUrl)
854 1815d2343a3f cleanup drewp <drewp@bigasterisk.com> parents: 853 diff changeset	339 outlog.info("put lcd %s brightness %s", url, brt)
919 6ee2a90fc816 bugs in async http client. move trig helpers to rdflibtrig, which can work with rdflib 4 drewp <drewp@bigasterisk.com> parents: 917 diff changeset	340 self._put(str(url) + "?brightness=%s" % str(brt), payload='')
838 36dbbb01d689 redo the http PUT request part of the reasoner drewp <drewp@bigasterisk.com> parents: 825 diff changeset	341
852 6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	342 msg = "open %s motion %s" % (
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	343 inferred.value(DEV['frontDoorOpenIndicator'], ROOM.text),
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	344 inferred.value(DEV['frontDoorMotionIndicator'], ROOM.text))
838 36dbbb01d689 redo the http PUT request part of the reasoner drewp <drewp@bigasterisk.com> parents: 825 diff changeset	345 # this was meant to be 2 chars in the bottom row, but the
36dbbb01d689 redo the http PUT request part of the reasoner drewp <drewp@bigasterisk.com> parents: 825 diff changeset	346 # easier test was to replace the whole top msg
36dbbb01d689 redo the http PUT request part of the reasoner drewp <drewp@bigasterisk.com> parents: 825 diff changeset	347 #restkit.Resource("http://slash:9080/").put("lcd", message=msg)
825 fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	348
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	349
852 6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	350
825 fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	351 class Index(cyclone.web.RequestHandler):
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	352 def get(self):
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	353 # make sure GET / fails if our poll loop died
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	354 ago = time.time() - self.settings.reasoning.lastPollTime
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	355 if ago > 2:
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	356 self.set_status(500)
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	357 self.finish("last poll was %s sec ago. last error: %s" %
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	358 (ago, self.settings.reasoning.lastError))
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	359 return
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	360 self.set_header("Content-Type", "application/xhtml+xml")
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	361 self.write(open('index.html').read())
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	362
852 6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	363 class ImmediateUpdate(cyclone.web.RequestHandler):
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	364 def put(self):
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	365 """
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	366 request an immediate load of the remote graphs; the thing we
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	367 do in the background anyway. No payload.
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	368
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	369 Using PUT because this is idempotent and retryable and
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	370 everything.
859 379cefec542e screen out more values that change on every update drewp <drewp@bigasterisk.com> parents: 854 diff changeset	371
379cefec542e screen out more values that change on every update drewp <drewp@bigasterisk.com> parents: 854 diff changeset	372 todo: this should do the right thing when many requests come
379cefec542e screen out more values that change on every update drewp <drewp@bigasterisk.com> parents: 854 diff changeset	373 in very quickly
852 6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	374 """
854 1815d2343a3f cleanup drewp <drewp@bigasterisk.com> parents: 853 diff changeset	375 print self.request.headers
1815d2343a3f cleanup drewp <drewp@bigasterisk.com> parents: 853 diff changeset	376 log.info("immediateUpdate from %s",
1815d2343a3f cleanup drewp <drewp@bigasterisk.com> parents: 853 diff changeset	377 self.request.headers.get('User-Agent', '?'))
852 6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	378 r.poll()
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	379 self.set_status(202)
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	380
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	381 def parseRdf(text, contentType):
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	382 g = Graph()
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	383 g.parse(StringInputSource(text), format={
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	384 'text/n3': 'n3',
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	385 }[contentType])
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	386 return g
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	387
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	388 class OneShot(cyclone.web.RequestHandler):
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	389 def post(self):
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	390 """
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	391 payload is an rdf graph. The statements are momentarily added
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	392 to the input graph for exactly one update.
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	393
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	394 todo: how do we go from a transition like doorclosed-to-open
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	395 to a oneshot event? the upstream shouldn't have to do it. Do
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	396 we make those oneshot events here? for every object change?
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	397 there are probably special cases regarding startup time when
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	398 everything appears to be a 'change'.
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	399 """
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	400 g = parseRdf(self.request.body, self.request.headers['content-type'])
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	401 self.settings.reasoning.inputGraph.addOneShot(g)
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	402
825 fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	403 # for reuse
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	404 class GraphResource(cyclone.web.RequestHandler):
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	405 def get(self, which):
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	406 self.set_header("Content-Type", "application/json")
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	407 r = self.settings.reasoning
852 6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	408 g = {'lastInput': r.inputGraph.getGraph(),
825 fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	409 'lastOutput': r.inferred,
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	410 }[which]
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	411 self.write(self.jsonRdf(g))
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	412
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	413 def jsonRdf(self, g):
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	414 return json.dumps(sorted(list(g)))
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	415
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	416 class NtGraphs(cyclone.web.RequestHandler):
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	417 """same as what gets posted above"""
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	418 def get(self):
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	419 r = self.settings.reasoning
852 6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	420 inputGraphNt = r.inputGraph.getGraph().serialize(format="nt")
825 fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	421 inferredNt = r.inferred.serialize(format="nt")
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	422 self.set_header("Content-Type", "application/json")
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	423 self.write(json.dumps({"input": inputGraphNt,
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	424 "inferred": inferredNt}))
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	425
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	426 class Rules(cyclone.web.RequestHandler):
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	427 def get(self):
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	428 self.set_header("Content-Type", "text/plain")
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	429 self.write(self.settings.reasoning.rulesN3)
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	430
850 887d47682d94 /status page, errors on failed graphs, time reports of successful fetches drewp <drewp@bigasterisk.com> parents: 838 diff changeset	431 class Status(cyclone.web.RequestHandler):
887d47682d94 /status page, errors on failed graphs, time reports of successful fetches drewp <drewp@bigasterisk.com> parents: 838 diff changeset	432 def get(self):
887d47682d94 /status page, errors on failed graphs, time reports of successful fetches drewp <drewp@bigasterisk.com> parents: 838 diff changeset	433 self.set_header("Content-Type", "text/plain")
852 6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	434 g = self.settings.reasoning.inputGraph.getGraph()
850 887d47682d94 /status page, errors on failed graphs, time reports of successful fetches drewp <drewp@bigasterisk.com> parents: 838 diff changeset	435 msg = ""
887d47682d94 /status page, errors on failed graphs, time reports of successful fetches drewp <drewp@bigasterisk.com> parents: 838 diff changeset	436 for badSource in g.subjects(RDF.type, ROOM['FailedGraphLoad']):
887d47682d94 /status page, errors on failed graphs, time reports of successful fetches drewp <drewp@bigasterisk.com> parents: 838 diff changeset	437 msg += "GET %s failed (%s). " % (
887d47682d94 /status page, errors on failed graphs, time reports of successful fetches drewp <drewp@bigasterisk.com> parents: 838 diff changeset	438 badSource, g.value(badSource, ROOM['graphLoadError']))
887d47682d94 /status page, errors on failed graphs, time reports of successful fetches drewp <drewp@bigasterisk.com> parents: 838 diff changeset	439 if not msg:
852 6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	440 self.finish("all inputs ok")
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	441 return
850 887d47682d94 /status page, errors on failed graphs, time reports of successful fetches drewp <drewp@bigasterisk.com> parents: 838 diff changeset	442 self.set_status(500)
887d47682d94 /status page, errors on failed graphs, time reports of successful fetches drewp <drewp@bigasterisk.com> parents: 838 diff changeset	443 self.finish(msg)
887d47682d94 /status page, errors on failed graphs, time reports of successful fetches drewp <drewp@bigasterisk.com> parents: 838 diff changeset	444
825 fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	445 class Static(cyclone.web.RequestHandler):
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	446 def get(self, p):
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	447 self.write(open(p).read())
850 887d47682d94 /status page, errors on failed graphs, time reports of successful fetches drewp <drewp@bigasterisk.com> parents: 838 diff changeset	448
869 15af9d8c7186 reasoning has a websocket server that broadcasts some events drewp <drewp@bigasterisk.com> parents: 859 diff changeset	449 liveClients = set()
15af9d8c7186 reasoning has a websocket server that broadcasts some events drewp <drewp@bigasterisk.com> parents: 859 diff changeset	450 def sendToLiveClients(d=None, asJson=None):
15af9d8c7186 reasoning has a websocket server that broadcasts some events drewp <drewp@bigasterisk.com> parents: 859 diff changeset	451 j = asJson or json.dumps(d)
15af9d8c7186 reasoning has a websocket server that broadcasts some events drewp <drewp@bigasterisk.com> parents: 859 diff changeset	452 for c in liveClients:
15af9d8c7186 reasoning has a websocket server that broadcasts some events drewp <drewp@bigasterisk.com> parents: 859 diff changeset	453 c.sendMessage(j)
15af9d8c7186 reasoning has a websocket server that broadcasts some events drewp <drewp@bigasterisk.com> parents: 859 diff changeset	454
15af9d8c7186 reasoning has a websocket server that broadcasts some events drewp <drewp@bigasterisk.com> parents: 859 diff changeset	455 class Events(cyclone.websocket.WebSocketHandler):
15af9d8c7186 reasoning has a websocket server that broadcasts some events drewp <drewp@bigasterisk.com> parents: 859 diff changeset	456
15af9d8c7186 reasoning has a websocket server that broadcasts some events drewp <drewp@bigasterisk.com> parents: 859 diff changeset	457 def connectionMade(self, args, *kwargs):
15af9d8c7186 reasoning has a websocket server that broadcasts some events drewp <drewp@bigasterisk.com> parents: 859 diff changeset	458 log.info("websocket opened")
15af9d8c7186 reasoning has a websocket server that broadcasts some events drewp <drewp@bigasterisk.com> parents: 859 diff changeset	459 liveClients.add(self)
15af9d8c7186 reasoning has a websocket server that broadcasts some events drewp <drewp@bigasterisk.com> parents: 859 diff changeset	460
15af9d8c7186 reasoning has a websocket server that broadcasts some events drewp <drewp@bigasterisk.com> parents: 859 diff changeset	461 def connectionLost(self, reason):
15af9d8c7186 reasoning has a websocket server that broadcasts some events drewp <drewp@bigasterisk.com> parents: 859 diff changeset	462 log.info("websocket closed")
15af9d8c7186 reasoning has a websocket server that broadcasts some events drewp <drewp@bigasterisk.com> parents: 859 diff changeset	463 liveClients.remove(self)
15af9d8c7186 reasoning has a websocket server that broadcasts some events drewp <drewp@bigasterisk.com> parents: 859 diff changeset	464
15af9d8c7186 reasoning has a websocket server that broadcasts some events drewp <drewp@bigasterisk.com> parents: 859 diff changeset	465 def messageReceived(self, message):
15af9d8c7186 reasoning has a websocket server that broadcasts some events drewp <drewp@bigasterisk.com> parents: 859 diff changeset	466 log.info("got message %s" % message)
15af9d8c7186 reasoning has a websocket server that broadcasts some events drewp <drewp@bigasterisk.com> parents: 859 diff changeset	467
825 fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	468 class Application(cyclone.web.Application):
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	469 def __init__(self, reasoning):
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	470 handlers = [
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	471 (r"/", Index),
852 6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	472 (r"/immediateUpdate", ImmediateUpdate),
6ccd930834d1 scan more input files. oneshot and immediate update features. drewp <drewp@bigasterisk.com> parents: 851 diff changeset	473 (r"/oneShot", OneShot),
825 fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	474 (r'/(jquery.min.js)', Static),
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	475 (r'/(lastInput\|lastOutput)Graph', GraphResource),
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	476 (r'/ntGraphs', NtGraphs),
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	477 (r'/rules', Rules),
850 887d47682d94 /status page, errors on failed graphs, time reports of successful fetches drewp <drewp@bigasterisk.com> parents: 838 diff changeset	478 (r'/status', Status),
869 15af9d8c7186 reasoning has a websocket server that broadcasts some events drewp <drewp@bigasterisk.com> parents: 859 diff changeset	479 (r'/events', Events),
825 fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	480 ]
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	481 cyclone.web.Application.__init__(self, handlers, reasoning=reasoning)
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	482
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	483 if __name__ == '__main__':
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	484 r = Reasoning()
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	485 #import twisted.python.log
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	486 #twisted.python.log.startLogging(sys.stdout)
850 887d47682d94 /status page, errors on failed graphs, time reports of successful fetches drewp <drewp@bigasterisk.com> parents: 838 diff changeset	487
825 fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	488 task.LoopingCall(r.poll).start(1.0)
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	489 reactor.listenTCP(9071, Application(r))
fc753b24f69a move reasoning from /my/proj/room, new integration with magma drewp <drewp@bigasterisk.com> parents: diff changeset	490 reactor.run()

Mercurial > code > home > repos > homeauto

annotate service/reasoning/reasoning.py @ 919:6ee2a90fc816