Mercurial > code > home > repos > homeauto
annotate service/piNode/piNode.py @ 1154:5da3a85b59e4
more robust about not accumulating old stmts
Ignore-this: ee8618c8341d028fd7bd3596cd16a43d
darcs-hash:447cf599c2a1633481bc68fc3bc2fa5b8352fbf5
| author | drewp <drewp@bigasterisk.com> |
|---|---|
| date | Mon, 16 Apr 2018 22:16:15 -0700 |
| parents | 6d2eba4d0dfd |
| children | 61f1c529a9b7 |
| rev | line source |
|---|---|
| 987 | 1 from __future__ import division |
| 1152 | 2 import sys, logging, socket, json, time |
| 987 | 3 import cyclone.web |
|
1056
d2007482aec5
start sending oneshot events from some devices
drewp <drewp@bigasterisk.com>
parents:
1048
diff
changeset
|
4 from cyclone.httpclient import fetch |
|
1031
9328df09f679
piNode uses new graph SSE code
drewp <drewp@bigasterisk.com>
parents:
1030
diff
changeset
|
5 from rdflib import Namespace, URIRef, Literal, Graph, RDF, ConjunctiveGraph |
|
989
065fc9e07c10
piNode allow nt graphs as the body of a PUT /output
drewp <drewp@bigasterisk.com>
parents:
988
diff
changeset
|
6 from rdflib.parser import StringInputSource |
| 987 | 7 from twisted.internet import reactor, task |
| 1152 | 8 from twisted.internet.threads import deferToThread |
| 987 | 9 from docopt import docopt |
| 1152 | 10 import etcd3 |
|
1038
ffe6a00c6cef
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp <drewp@bigasterisk.com>
parents:
1035
diff
changeset
|
11 |
| 987 | 12 logging.basicConfig(level=logging.DEBUG) |
|
1136
1e43ec4a5f23
build and import updates for rdfdb, etc
drewp <drewp@bigasterisk.com>
parents:
1130
diff
changeset
|
13 |
|
1e43ec4a5f23
build and import updates for rdfdb, etc
drewp <drewp@bigasterisk.com>
parents:
1130
diff
changeset
|
14 sys.path.append("../../lib") |
|
1031
9328df09f679
piNode uses new graph SSE code
drewp <drewp@bigasterisk.com>
parents:
1030
diff
changeset
|
15 from patchablegraph import PatchableGraph, CycloneGraphHandler, CycloneGraphEventsHandler |
|
1143
d1bc88f67969
RgbPixelsAnimation and docker build updates
drewp <drewp@bigasterisk.com>
parents:
1136
diff
changeset
|
16 |
|
d1bc88f67969
RgbPixelsAnimation and docker build updates
drewp <drewp@bigasterisk.com>
parents:
1136
diff
changeset
|
17 from rdfdb.rdflibpatch import inContext |
|
d1bc88f67969
RgbPixelsAnimation and docker build updates
drewp <drewp@bigasterisk.com>
parents:
1136
diff
changeset
|
18 from rdfdb.patch import Patch |
|
d1bc88f67969
RgbPixelsAnimation and docker build updates
drewp <drewp@bigasterisk.com>
parents:
1136
diff
changeset
|
19 |
|
988
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
20 try: |
|
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
21 import pigpio |
|
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
22 except ImportError: |
|
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
23 class pigpio(object): |
|
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
24 @staticmethod |
|
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
25 def pi(): |
|
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
26 return None |
| 987 | 27 |
| 28 import devices | |
|
1098
b5906f6fce3f
save data to influxdb, not graphite
drewp <drewp@bigasterisk.com>
parents:
1076
diff
changeset
|
29 from export_to_influxdb import InfluxExporter |
|
1026
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
30 |
| 987 | 31 log = logging.getLogger() |
| 32 logging.getLogger('serial').setLevel(logging.WARN) | |
|
1038
ffe6a00c6cef
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp <drewp@bigasterisk.com>
parents:
1035
diff
changeset
|
33 |
| 987 | 34 ROOM = Namespace('http://projects.bigasterisk.com/room/') |
| 35 HOST = Namespace('http://bigasterisk.com/ruler/host/') | |
| 36 | |
| 37 hostname = socket.gethostname() | |
|
1038
ffe6a00c6cef
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp <drewp@bigasterisk.com>
parents:
1035
diff
changeset
|
38 CTX = ROOM['pi/%s' % hostname] |
| 1152 | 39 etcd = etcd3.client(host='bang6') |
|
1038
ffe6a00c6cef
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp <drewp@bigasterisk.com>
parents:
1035
diff
changeset
|
40 |
| 1063 | 41 def patchRandid(): |
| 42 """ | |
| 43 I'm concerned urandom is slow on raspberry pi, and I'm adding to | |
| 44 graphs a lot. Unclear what the ordered return values might do to | |
| 45 the balancing of the graph. | |
| 46 """ | |
| 47 _id_serial = [1000] | |
| 48 def randid(): | |
| 49 _id_serial[0] += 1 | |
| 50 return _id_serial[0] | |
| 51 import rdflib.plugins.memory | |
| 52 rdflib.plugins.memory.randid = randid | |
| 53 patchRandid() | |
| 54 | |
|
988
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
55 class Config(object): |
|
1031
9328df09f679
piNode uses new graph SSE code
drewp <drewp@bigasterisk.com>
parents:
1030
diff
changeset
|
56 def __init__(self, masterGraph): |
| 1152 | 57 self.masterGraph = masterGraph |
| 58 self.configGraph = ConjunctiveGraph() | |
| 59 self.boards = [] | |
| 60 self.etcPrefix = 'pi/' | |
| 61 | |
| 62 self.reread() | |
| 63 | |
| 64 deferToThread(self.watchEtcd) | |
| 65 | |
| 66 def watchEtcd(self): | |
| 67 events, cancel = etcd.watch_prefix(self.etcPrefix) | |
| 68 reactor.addSystemEventTrigger('before', 'shutdown', cancel) | |
| 69 for ev in events: | |
| 70 log.info('%s changed', ev.key) | |
| 71 reactor.callFromThread(self.configChanged) | |
| 72 | |
| 73 def configChanged(self): | |
| 74 self.cancelRead() | |
| 75 self.rereadLater = reactor.callLater(.1, self.reread) | |
| 76 | |
| 77 def cancelRead(self): | |
| 78 if getattr(self, 'rereadLater', None): | |
| 79 self.rereadLater.cancel() | |
| 80 self.rereadLater = None | |
| 81 | |
| 82 def reread(self): | |
| 83 self.rereadLater = None | |
|
988
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
84 log.info('read config') |
| 1152 | 85 self.configGraph = ConjunctiveGraph() |
| 86 for v, md in etcd.get_prefix(self.etcPrefix): | |
| 87 log.info(' read file %r', md.key) | |
| 88 self.configGraph.parse(StringInputSource(v), format='n3') | |
| 89 self.configGraph.bind('', ROOM) | |
| 90 self.configGraph.bind('rdf', RDF) | |
|
1038
ffe6a00c6cef
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp <drewp@bigasterisk.com>
parents:
1035
diff
changeset
|
91 # config graph is too noisy; maybe make it a separate resource |
| 1152 | 92 #masterGraph.patch(Patch(addGraph=self.configGraph)) |
| 93 self.setupBoards() | |
| 94 | |
| 95 def setupBoards(self): | |
| 96 thisHost = Literal(hostname) | |
| 97 for row in self.configGraph.query( | |
| 98 'SELECT ?board WHERE { ?board a :PiBoard; :hostname ?h }', | |
| 99 initBindings=dict(h=thisHost)): | |
| 100 thisBoard = row.board | |
| 101 break | |
| 102 else: | |
| 103 log.warn("config had no board for :hostname %s. Waiting for config update." % | |
| 104 thisHost) | |
| 105 self.boards = [] | |
| 106 return | |
| 107 | |
| 108 log.info("found config for board %r" % thisBoard) | |
| 109 self.boards = [Board(self.configGraph, self.masterGraph, thisBoard)] | |
| 110 self.boards[0].startPolling() | |
| 111 | |
| 987 | 112 |
| 113 class Board(object): | |
| 114 """similar to arduinoNode.Board but without the communications stuff""" | |
|
1031
9328df09f679
piNode uses new graph SSE code
drewp <drewp@bigasterisk.com>
parents:
1030
diff
changeset
|
115 def __init__(self, graph, masterGraph, uri): |
| 987 | 116 self.graph, self.uri = graph, uri |
|
1031
9328df09f679
piNode uses new graph SSE code
drewp <drewp@bigasterisk.com>
parents:
1030
diff
changeset
|
117 self.masterGraph = masterGraph |
|
1154
5da3a85b59e4
more robust about not accumulating old stmts
drewp <drewp@bigasterisk.com>
parents:
1152
diff
changeset
|
118 self.masterGraph.setToGraph(self.staticStmts()) |
| 987 | 119 self.pi = pigpio.pi() |
| 120 self._devs = devices.makeDevices(graph, self.uri, self.pi) | |
|
988
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
121 log.debug('found %s devices', len(self._devs)) |
| 987 | 122 self._statementsFromInputs = {} # input device uri: latest statements |
|
1048
f3c7f617c335
piNode poll switches much faster. mirror the logic in arduinoNode though vari-rate poll is not supported yet
drewp <drewp@bigasterisk.com>
parents:
1038
diff
changeset
|
123 self._lastPollTime = {} # input device uri: time() |
|
1098
b5906f6fce3f
save data to influxdb, not graphite
drewp <drewp@bigasterisk.com>
parents:
1076
diff
changeset
|
124 self._influx = InfluxExporter(self.graph) |
|
1038
ffe6a00c6cef
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp <drewp@bigasterisk.com>
parents:
1035
diff
changeset
|
125 for d in self._devs: |
|
ffe6a00c6cef
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp <drewp@bigasterisk.com>
parents:
1035
diff
changeset
|
126 self.syncMasterGraphToHostStatements(d) |
|
1048
f3c7f617c335
piNode poll switches much faster. mirror the logic in arduinoNode though vari-rate poll is not supported yet
drewp <drewp@bigasterisk.com>
parents:
1038
diff
changeset
|
127 |
| 987 | 128 def startPolling(self): |
|
1048
f3c7f617c335
piNode poll switches much faster. mirror the logic in arduinoNode though vari-rate poll is not supported yet
drewp <drewp@bigasterisk.com>
parents:
1038
diff
changeset
|
129 task.LoopingCall(self._poll).start(.05) |
| 987 | 130 |
| 131 def _poll(self): | |
|
1076
d0ca77a3faf4
rewrite oneShotPost to ease debugging. add try-block around polling
drewp <drewp@bigasterisk.com>
parents:
1074
diff
changeset
|
132 try: |
|
d0ca77a3faf4
rewrite oneShotPost to ease debugging. add try-block around polling
drewp <drewp@bigasterisk.com>
parents:
1074
diff
changeset
|
133 self._pollMaybeError() |
|
d0ca77a3faf4
rewrite oneShotPost to ease debugging. add try-block around polling
drewp <drewp@bigasterisk.com>
parents:
1074
diff
changeset
|
134 except Exception: |
|
d0ca77a3faf4
rewrite oneShotPost to ease debugging. add try-block around polling
drewp <drewp@bigasterisk.com>
parents:
1074
diff
changeset
|
135 log.exception("During poll:") |
|
d0ca77a3faf4
rewrite oneShotPost to ease debugging. add try-block around polling
drewp <drewp@bigasterisk.com>
parents:
1074
diff
changeset
|
136 |
|
d0ca77a3faf4
rewrite oneShotPost to ease debugging. add try-block around polling
drewp <drewp@bigasterisk.com>
parents:
1074
diff
changeset
|
137 def _pollMaybeError(self): |
|
1109
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1098
diff
changeset
|
138 pollTime = {} # uri: sec |
| 987 | 139 for i in self._devs: |
|
1048
f3c7f617c335
piNode poll switches much faster. mirror the logic in arduinoNode though vari-rate poll is not supported yet
drewp <drewp@bigasterisk.com>
parents:
1038
diff
changeset
|
140 now = time.time() |
|
f3c7f617c335
piNode poll switches much faster. mirror the logic in arduinoNode though vari-rate poll is not supported yet
drewp <drewp@bigasterisk.com>
parents:
1038
diff
changeset
|
141 if (hasattr(i, 'pollPeriod') and |
|
f3c7f617c335
piNode poll switches much faster. mirror the logic in arduinoNode though vari-rate poll is not supported yet
drewp <drewp@bigasterisk.com>
parents:
1038
diff
changeset
|
142 self._lastPollTime.get(i.uri, 0) + i.pollPeriod > now): |
|
f3c7f617c335
piNode poll switches much faster. mirror the logic in arduinoNode though vari-rate poll is not supported yet
drewp <drewp@bigasterisk.com>
parents:
1038
diff
changeset
|
143 continue |
|
f3c7f617c335
piNode poll switches much faster. mirror the logic in arduinoNode though vari-rate poll is not supported yet
drewp <drewp@bigasterisk.com>
parents:
1038
diff
changeset
|
144 new = i.poll() |
|
1109
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1098
diff
changeset
|
145 pollTime[i.uri] = time.time() - now |
|
1056
d2007482aec5
start sending oneshot events from some devices
drewp <drewp@bigasterisk.com>
parents:
1048
diff
changeset
|
146 if isinstance(new, dict): # new style |
|
d2007482aec5
start sending oneshot events from some devices
drewp <drewp@bigasterisk.com>
parents:
1048
diff
changeset
|
147 oneshot = new['oneshot'] |
|
d2007482aec5
start sending oneshot events from some devices
drewp <drewp@bigasterisk.com>
parents:
1048
diff
changeset
|
148 new = new['latest'] |
|
d2007482aec5
start sending oneshot events from some devices
drewp <drewp@bigasterisk.com>
parents:
1048
diff
changeset
|
149 else: |
|
d2007482aec5
start sending oneshot events from some devices
drewp <drewp@bigasterisk.com>
parents:
1048
diff
changeset
|
150 oneshot = None |
|
d2007482aec5
start sending oneshot events from some devices
drewp <drewp@bigasterisk.com>
parents:
1048
diff
changeset
|
151 |
|
1154
5da3a85b59e4
more robust about not accumulating old stmts
drewp <drewp@bigasterisk.com>
parents:
1152
diff
changeset
|
152 self._updateMasterWithNewPollStatements(i.uri, new) |
|
1056
d2007482aec5
start sending oneshot events from some devices
drewp <drewp@bigasterisk.com>
parents:
1048
diff
changeset
|
153 |
|
d2007482aec5
start sending oneshot events from some devices
drewp <drewp@bigasterisk.com>
parents:
1048
diff
changeset
|
154 if oneshot: |
|
d2007482aec5
start sending oneshot events from some devices
drewp <drewp@bigasterisk.com>
parents:
1048
diff
changeset
|
155 self._sendOneshot(oneshot) |
|
1048
f3c7f617c335
piNode poll switches much faster. mirror the logic in arduinoNode though vari-rate poll is not supported yet
drewp <drewp@bigasterisk.com>
parents:
1038
diff
changeset
|
156 self._lastPollTime[i.uri] = now |
|
1109
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1098
diff
changeset
|
157 if log.isEnabledFor(logging.DEBUG): |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1098
diff
changeset
|
158 log.debug('poll times:') |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1098
diff
changeset
|
159 for u, s in sorted(pollTime.items()): |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1098
diff
changeset
|
160 log.debug(" %.4f ms %s", s * 1000, u) |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1098
diff
changeset
|
161 log.debug('total poll time: %f ms', sum(pollTime.values()) * 1000) |
|
1143
d1bc88f67969
RgbPixelsAnimation and docker build updates
drewp <drewp@bigasterisk.com>
parents:
1136
diff
changeset
|
162 |
|
d1bc88f67969
RgbPixelsAnimation and docker build updates
drewp <drewp@bigasterisk.com>
parents:
1136
diff
changeset
|
163 pollResults = map(set, self._statementsFromInputs.values()) |
|
d1bc88f67969
RgbPixelsAnimation and docker build updates
drewp <drewp@bigasterisk.com>
parents:
1136
diff
changeset
|
164 if pollResults: |
|
d1bc88f67969
RgbPixelsAnimation and docker build updates
drewp <drewp@bigasterisk.com>
parents:
1136
diff
changeset
|
165 self._influx.exportToInflux(set.union(*pollResults)) |
|
1026
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
166 |
|
1154
5da3a85b59e4
more robust about not accumulating old stmts
drewp <drewp@bigasterisk.com>
parents:
1152
diff
changeset
|
167 def _updateMasterWithNewPollStatements(self, dev, new): |
|
5da3a85b59e4
more robust about not accumulating old stmts
drewp <drewp@bigasterisk.com>
parents:
1152
diff
changeset
|
168 prev = self._statementsFromInputs.get(dev, set()) |
|
5da3a85b59e4
more robust about not accumulating old stmts
drewp <drewp@bigasterisk.com>
parents:
1152
diff
changeset
|
169 |
|
5da3a85b59e4
more robust about not accumulating old stmts
drewp <drewp@bigasterisk.com>
parents:
1152
diff
changeset
|
170 # it's important that quads from different devices |
|
5da3a85b59e4
more robust about not accumulating old stmts
drewp <drewp@bigasterisk.com>
parents:
1152
diff
changeset
|
171 # don't clash, since that can lead to inconsistent |
|
5da3a85b59e4
more robust about not accumulating old stmts
drewp <drewp@bigasterisk.com>
parents:
1152
diff
changeset
|
172 # patches (e.g. |
|
5da3a85b59e4
more robust about not accumulating old stmts
drewp <drewp@bigasterisk.com>
parents:
1152
diff
changeset
|
173 # dev1 changes value from 1 to 2; |
|
5da3a85b59e4
more robust about not accumulating old stmts
drewp <drewp@bigasterisk.com>
parents:
1152
diff
changeset
|
174 # dev2 changes value from 2 to 3; |
|
5da3a85b59e4
more robust about not accumulating old stmts
drewp <drewp@bigasterisk.com>
parents:
1152
diff
changeset
|
175 # dev1 changes from 2 to 4 but this patch will |
|
5da3a85b59e4
more robust about not accumulating old stmts
drewp <drewp@bigasterisk.com>
parents:
1152
diff
changeset
|
176 # fail since the '2' statement is gone) |
|
5da3a85b59e4
more robust about not accumulating old stmts
drewp <drewp@bigasterisk.com>
parents:
1152
diff
changeset
|
177 self.masterGraph.patch(Patch.fromDiff(inContext(prev, dev), |
|
5da3a85b59e4
more robust about not accumulating old stmts
drewp <drewp@bigasterisk.com>
parents:
1152
diff
changeset
|
178 inContext(new, dev))) |
|
5da3a85b59e4
more robust about not accumulating old stmts
drewp <drewp@bigasterisk.com>
parents:
1152
diff
changeset
|
179 self._statementsFromInputs[dev] = new |
|
5da3a85b59e4
more robust about not accumulating old stmts
drewp <drewp@bigasterisk.com>
parents:
1152
diff
changeset
|
180 |
|
1056
d2007482aec5
start sending oneshot events from some devices
drewp <drewp@bigasterisk.com>
parents:
1048
diff
changeset
|
181 def _sendOneshot(self, oneshot): |
|
d2007482aec5
start sending oneshot events from some devices
drewp <drewp@bigasterisk.com>
parents:
1048
diff
changeset
|
182 body = (' '.join('%s %s %s .' % (s.n3(), p.n3(), o.n3()) |
|
d2007482aec5
start sending oneshot events from some devices
drewp <drewp@bigasterisk.com>
parents:
1048
diff
changeset
|
183 for s,p,o in oneshot)).encode('utf8') |
| 1152 | 184 url = 'http://bang6:9071/oneShot' |
|
1076
d0ca77a3faf4
rewrite oneShotPost to ease debugging. add try-block around polling
drewp <drewp@bigasterisk.com>
parents:
1074
diff
changeset
|
185 d = fetch(method='POST', |
|
d0ca77a3faf4
rewrite oneShotPost to ease debugging. add try-block around polling
drewp <drewp@bigasterisk.com>
parents:
1074
diff
changeset
|
186 url=url, |
|
d0ca77a3faf4
rewrite oneShotPost to ease debugging. add try-block around polling
drewp <drewp@bigasterisk.com>
parents:
1074
diff
changeset
|
187 headers={'Content-Type': ['text/n3']}, |
|
d0ca77a3faf4
rewrite oneShotPost to ease debugging. add try-block around polling
drewp <drewp@bigasterisk.com>
parents:
1074
diff
changeset
|
188 postdata=body, |
|
d0ca77a3faf4
rewrite oneShotPost to ease debugging. add try-block around polling
drewp <drewp@bigasterisk.com>
parents:
1074
diff
changeset
|
189 timeout=5) |
|
d0ca77a3faf4
rewrite oneShotPost to ease debugging. add try-block around polling
drewp <drewp@bigasterisk.com>
parents:
1074
diff
changeset
|
190 def err(e): |
|
d0ca77a3faf4
rewrite oneShotPost to ease debugging. add try-block around polling
drewp <drewp@bigasterisk.com>
parents:
1074
diff
changeset
|
191 log.info('oneshot post to %r failed: %s', |
|
d0ca77a3faf4
rewrite oneShotPost to ease debugging. add try-block around polling
drewp <drewp@bigasterisk.com>
parents:
1074
diff
changeset
|
192 url, e.getErrorMessage()) |
|
d0ca77a3faf4
rewrite oneShotPost to ease debugging. add try-block around polling
drewp <drewp@bigasterisk.com>
parents:
1074
diff
changeset
|
193 d.addErrback(err) |
|
1056
d2007482aec5
start sending oneshot events from some devices
drewp <drewp@bigasterisk.com>
parents:
1048
diff
changeset
|
194 |
|
1038
ffe6a00c6cef
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp <drewp@bigasterisk.com>
parents:
1035
diff
changeset
|
195 def outputStatements(self, stmts): |
|
ffe6a00c6cef
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp <drewp@bigasterisk.com>
parents:
1035
diff
changeset
|
196 unused = set(stmts) |
|
ffe6a00c6cef
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp <drewp@bigasterisk.com>
parents:
1035
diff
changeset
|
197 for dev in self._devs: |
|
ffe6a00c6cef
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp <drewp@bigasterisk.com>
parents:
1035
diff
changeset
|
198 stmtsForDev = [] |
|
ffe6a00c6cef
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp <drewp@bigasterisk.com>
parents:
1035
diff
changeset
|
199 for pat in dev.outputPatterns(): |
|
ffe6a00c6cef
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp <drewp@bigasterisk.com>
parents:
1035
diff
changeset
|
200 if [term is None for term in pat] != [False, False, True]: |
|
ffe6a00c6cef
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp <drewp@bigasterisk.com>
parents:
1035
diff
changeset
|
201 raise NotImplementedError |
|
ffe6a00c6cef
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp <drewp@bigasterisk.com>
parents:
1035
diff
changeset
|
202 for stmt in stmts: |
|
ffe6a00c6cef
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp <drewp@bigasterisk.com>
parents:
1035
diff
changeset
|
203 if stmt[:2] == pat[:2]: |
|
ffe6a00c6cef
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp <drewp@bigasterisk.com>
parents:
1035
diff
changeset
|
204 stmtsForDev.append(stmt) |
|
ffe6a00c6cef
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp <drewp@bigasterisk.com>
parents:
1035
diff
changeset
|
205 unused.discard(stmt) |
|
ffe6a00c6cef
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp <drewp@bigasterisk.com>
parents:
1035
diff
changeset
|
206 if stmtsForDev: |
|
ffe6a00c6cef
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp <drewp@bigasterisk.com>
parents:
1035
diff
changeset
|
207 log.info("output goes to action handler for %s" % dev.uri) |
|
ffe6a00c6cef
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp <drewp@bigasterisk.com>
parents:
1035
diff
changeset
|
208 dev.sendOutput(stmtsForDev) |
|
ffe6a00c6cef
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp <drewp@bigasterisk.com>
parents:
1035
diff
changeset
|
209 |
|
ffe6a00c6cef
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp <drewp@bigasterisk.com>
parents:
1035
diff
changeset
|
210 # Dev *could* change hostStatements at any time, and |
|
ffe6a00c6cef
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp <drewp@bigasterisk.com>
parents:
1035
diff
changeset
|
211 # we're not currently tracking that, but the usual is |
|
ffe6a00c6cef
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp <drewp@bigasterisk.com>
parents:
1035
diff
changeset
|
212 # to change them in response to sendOutput so this |
|
ffe6a00c6cef
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp <drewp@bigasterisk.com>
parents:
1035
diff
changeset
|
213 # should be good enough. The right answer is to give |
|
ffe6a00c6cef
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp <drewp@bigasterisk.com>
parents:
1035
diff
changeset
|
214 # each dev the masterGraph for it to write to. |
|
ffe6a00c6cef
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp <drewp@bigasterisk.com>
parents:
1035
diff
changeset
|
215 self.syncMasterGraphToHostStatements(dev) |
|
ffe6a00c6cef
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp <drewp@bigasterisk.com>
parents:
1035
diff
changeset
|
216 log.info("output and masterGraph sync complete") |
|
ffe6a00c6cef
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp <drewp@bigasterisk.com>
parents:
1035
diff
changeset
|
217 if unused: |
|
ffe6a00c6cef
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp <drewp@bigasterisk.com>
parents:
1035
diff
changeset
|
218 log.info("Board %s doesn't care about these statements:", self.uri) |
|
ffe6a00c6cef
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp <drewp@bigasterisk.com>
parents:
1035
diff
changeset
|
219 for s in unused: |
|
ffe6a00c6cef
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp <drewp@bigasterisk.com>
parents:
1035
diff
changeset
|
220 log.warn("%r", s) |
|
ffe6a00c6cef
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp <drewp@bigasterisk.com>
parents:
1035
diff
changeset
|
221 |
|
ffe6a00c6cef
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp <drewp@bigasterisk.com>
parents:
1035
diff
changeset
|
222 def syncMasterGraphToHostStatements(self, dev): |
|
ffe6a00c6cef
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp <drewp@bigasterisk.com>
parents:
1035
diff
changeset
|
223 hostStmtCtx = URIRef(dev.uri + '/host') |
|
ffe6a00c6cef
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp <drewp@bigasterisk.com>
parents:
1035
diff
changeset
|
224 newQuads = inContext(dev.hostStatements(), hostStmtCtx) |
|
ffe6a00c6cef
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp <drewp@bigasterisk.com>
parents:
1035
diff
changeset
|
225 p = self.masterGraph.patchSubgraph(hostStmtCtx, newQuads) |
|
ffe6a00c6cef
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp <drewp@bigasterisk.com>
parents:
1035
diff
changeset
|
226 log.debug("patch master with these host stmts %s", p) |
|
ffe6a00c6cef
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp <drewp@bigasterisk.com>
parents:
1035
diff
changeset
|
227 |
|
1031
9328df09f679
piNode uses new graph SSE code
drewp <drewp@bigasterisk.com>
parents:
1030
diff
changeset
|
228 def staticStmts(self): |
|
1038
ffe6a00c6cef
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp <drewp@bigasterisk.com>
parents:
1035
diff
changeset
|
229 return [(HOST[hostname], ROOM['connectedTo'], self.uri, CTX)] |
|
ffe6a00c6cef
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp <drewp@bigasterisk.com>
parents:
1035
diff
changeset
|
230 |
|
988
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
231 def description(self): |
|
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
232 """for web page""" |
|
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
233 return { |
|
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
234 'uri': self.uri, |
|
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
235 'devices': [d.description() for d in self._devs], |
|
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
236 'graph': 'http://sticker:9059/graph', #todo |
|
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
237 } |
|
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
238 |
|
1038
ffe6a00c6cef
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp <drewp@bigasterisk.com>
parents:
1035
diff
changeset
|
239 class Dot(cyclone.web.RequestHandler): |
|
ffe6a00c6cef
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp <drewp@bigasterisk.com>
parents:
1035
diff
changeset
|
240 def get(self): |
| 1152 | 241 configGraph = self.settings.config.configGraph |
| 242 dot = dotrender.render(configGraph, self.settings.config.boards) | |
|
1038
ffe6a00c6cef
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp <drewp@bigasterisk.com>
parents:
1035
diff
changeset
|
243 self.write(dot) |
|
ffe6a00c6cef
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp <drewp@bigasterisk.com>
parents:
1035
diff
changeset
|
244 |
|
989
065fc9e07c10
piNode allow nt graphs as the body of a PUT /output
drewp <drewp@bigasterisk.com>
parents:
988
diff
changeset
|
245 def rdfGraphBody(body, headers): |
|
065fc9e07c10
piNode allow nt graphs as the body of a PUT /output
drewp <drewp@bigasterisk.com>
parents:
988
diff
changeset
|
246 g = Graph() |
|
065fc9e07c10
piNode allow nt graphs as the body of a PUT /output
drewp <drewp@bigasterisk.com>
parents:
988
diff
changeset
|
247 g.parse(StringInputSource(body), format='nt') |
|
065fc9e07c10
piNode allow nt graphs as the body of a PUT /output
drewp <drewp@bigasterisk.com>
parents:
988
diff
changeset
|
248 return g |
|
988
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
249 |
| 987 | 250 class OutputPage(cyclone.web.RequestHandler): |
| 251 def put(self): | |
|
989
065fc9e07c10
piNode allow nt graphs as the body of a PUT /output
drewp <drewp@bigasterisk.com>
parents:
988
diff
changeset
|
252 arg = self.request.arguments |
|
065fc9e07c10
piNode allow nt graphs as the body of a PUT /output
drewp <drewp@bigasterisk.com>
parents:
988
diff
changeset
|
253 if arg.get('s') and arg.get('p'): |
|
065fc9e07c10
piNode allow nt graphs as the body of a PUT /output
drewp <drewp@bigasterisk.com>
parents:
988
diff
changeset
|
254 subj = URIRef(arg['s'][-1]) |
|
065fc9e07c10
piNode allow nt graphs as the body of a PUT /output
drewp <drewp@bigasterisk.com>
parents:
988
diff
changeset
|
255 pred = URIRef(arg['p'][-1]) |
|
065fc9e07c10
piNode allow nt graphs as the body of a PUT /output
drewp <drewp@bigasterisk.com>
parents:
988
diff
changeset
|
256 turtleLiteral = self.request.body |
|
065fc9e07c10
piNode allow nt graphs as the body of a PUT /output
drewp <drewp@bigasterisk.com>
parents:
988
diff
changeset
|
257 try: |
|
065fc9e07c10
piNode allow nt graphs as the body of a PUT /output
drewp <drewp@bigasterisk.com>
parents:
988
diff
changeset
|
258 obj = Literal(float(turtleLiteral)) |
|
065fc9e07c10
piNode allow nt graphs as the body of a PUT /output
drewp <drewp@bigasterisk.com>
parents:
988
diff
changeset
|
259 except ValueError: |
|
065fc9e07c10
piNode allow nt graphs as the body of a PUT /output
drewp <drewp@bigasterisk.com>
parents:
988
diff
changeset
|
260 obj = Literal(turtleLiteral) |
|
065fc9e07c10
piNode allow nt graphs as the body of a PUT /output
drewp <drewp@bigasterisk.com>
parents:
988
diff
changeset
|
261 stmt = (subj, pred, obj) |
|
065fc9e07c10
piNode allow nt graphs as the body of a PUT /output
drewp <drewp@bigasterisk.com>
parents:
988
diff
changeset
|
262 else: |
|
065fc9e07c10
piNode allow nt graphs as the body of a PUT /output
drewp <drewp@bigasterisk.com>
parents:
988
diff
changeset
|
263 g = rdfGraphBody(self.request.body, self.request.headers) |
|
065fc9e07c10
piNode allow nt graphs as the body of a PUT /output
drewp <drewp@bigasterisk.com>
parents:
988
diff
changeset
|
264 assert len(g) == 1, len(g) |
|
065fc9e07c10
piNode allow nt graphs as the body of a PUT /output
drewp <drewp@bigasterisk.com>
parents:
988
diff
changeset
|
265 stmt = g.triples((None, None, None)).next() |
| 987 | 266 |
| 1152 | 267 for b in self.settings.config.boards: |
| 268 b.outputStatements([stmt]) | |
| 987 | 269 |
|
988
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
270 class Boards(cyclone.web.RequestHandler): |
|
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
271 def get(self): |
|
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
272 self.set_header('Content-type', 'application/json') |
|
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
273 self.write(json.dumps({ |
|
1038
ffe6a00c6cef
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp <drewp@bigasterisk.com>
parents:
1035
diff
changeset
|
274 'host': hostname, |
| 1152 | 275 'boards': [b.description() for b in self.settings.config.boards] |
|
988
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
276 }, indent=2)) |
|
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
277 |
| 987 | 278 def main(): |
| 279 arg = docopt(""" | |
| 280 Usage: piNode.py [options] | |
| 281 | |
| 282 -v Verbose | |
| 283 """) | |
| 284 log.setLevel(logging.WARN) | |
| 285 if arg['-v']: | |
| 286 from twisted.python import log as twlog | |
| 287 twlog.startLogging(sys.stdout) | |
| 288 | |
| 289 log.setLevel(logging.DEBUG) | |
|
1038
ffe6a00c6cef
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp <drewp@bigasterisk.com>
parents:
1035
diff
changeset
|
290 |
|
1031
9328df09f679
piNode uses new graph SSE code
drewp <drewp@bigasterisk.com>
parents:
1030
diff
changeset
|
291 masterGraph = PatchableGraph() |
|
9328df09f679
piNode uses new graph SSE code
drewp <drewp@bigasterisk.com>
parents:
1030
diff
changeset
|
292 config = Config(masterGraph) |
| 987 | 293 |
| 294 reactor.listenTCP(9059, cyclone.web.Application([ | |
| 295 (r"/()", cyclone.web.StaticFileHandler, { | |
|
1143
d1bc88f67969
RgbPixelsAnimation and docker build updates
drewp <drewp@bigasterisk.com>
parents:
1136
diff
changeset
|
296 "path": "static", "default_filename": "index.html"}), |
|
d1bc88f67969
RgbPixelsAnimation and docker build updates
drewp <drewp@bigasterisk.com>
parents:
1136
diff
changeset
|
297 (r'/static/(.*)', cyclone.web.StaticFileHandler, {"path": "static"}), |
|
1038
ffe6a00c6cef
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp <drewp@bigasterisk.com>
parents:
1035
diff
changeset
|
298 (r'/boards', Boards), |
|
1031
9328df09f679
piNode uses new graph SSE code
drewp <drewp@bigasterisk.com>
parents:
1030
diff
changeset
|
299 (r"/graph", CycloneGraphHandler, {'masterGraph': masterGraph}), |
|
9328df09f679
piNode uses new graph SSE code
drewp <drewp@bigasterisk.com>
parents:
1030
diff
changeset
|
300 (r"/graph/events", CycloneGraphEventsHandler, {'masterGraph': masterGraph}), |
| 987 | 301 (r'/output', OutputPage), |
|
1038
ffe6a00c6cef
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp <drewp@bigasterisk.com>
parents:
1035
diff
changeset
|
302 (r'/dot', Dot), |
| 1152 | 303 ], config=config, debug=arg['-v']), interface='::') |
| 1063 | 304 log.warn('serving on 9059') |
| 987 | 305 reactor.run() |
| 306 | |
| 307 main() |