Mercurial > code > home > repos > homeauto
annotate service/piNode/piNode.py @ 732:fdddbdaf07b5
more service renaming; start a lot more serv.n3 job files
Ignore-this: 635aaefc7bd2fa5558eefb8b3fc9ec75
| author | drewp@bigasterisk.com |
|---|---|
| date | Thu, 06 Feb 2020 16:36:35 -0800 |
| parents | 0a39cb133ce5 |
| children | 9d074317e16a |
| rev | line source |
|---|---|
| 636 | 1 import logging, socket, json, time, pkg_resources |
| 182 | 2 import cyclone.web |
| 226 | 3 from rdflib import Namespace, URIRef, Literal, Graph, RDF, ConjunctiveGraph |
|
184
e052416a2290
piNode allow nt graphs as the body of a PUT /output
drewp@bigasterisk.com
parents:
183
diff
changeset
|
4 from rdflib.parser import StringInputSource |
| 636 | 5 from twisted.internet import reactor |
| 6 from twisted.internet.defer import inlineCallbacks, maybeDeferred, returnValue | |
| 347 | 7 from twisted.internet.threads import deferToThread |
| 182 | 8 from docopt import docopt |
| 636 | 9 import etcd3 |
|
466
1122016d16eb
stats handler, events output fix, build updaets
drewp@bigasterisk.com
parents:
408
diff
changeset
|
10 from greplin import scales |
|
1122016d16eb
stats handler, events output fix, build updaets
drewp@bigasterisk.com
parents:
408
diff
changeset
|
11 from greplin.scales.cyclonehandler import StatsHandler |
| 636 | 12 import pigpio |
| 13 import treq | |
|
331
a94f2a522d41
build and import updates for rdfdb, etc
drewp@bigasterisk.com
parents:
325
diff
changeset
|
14 |
| 226 | 15 from patchablegraph import PatchableGraph, CycloneGraphHandler, CycloneGraphEventsHandler |
|
589
f397ec8bd13d
pinode devs can now poll in parallel (within one poll step). doesn't help much.
drewp@bigasterisk.com
parents:
553
diff
changeset
|
16 from cycloneerr import PrettyErrorHandler |
|
640
23ab244aa649
move bnode id optimization to its own file. more logging cleanups
drewp@bigasterisk.com
parents:
639
diff
changeset
|
17 from standardservice.logsetup import log, verboseLogging |
|
338
f64e20d3407e
RgbPixelsAnimation and docker build updates
drewp@bigasterisk.com
parents:
331
diff
changeset
|
18 from rdfdb.rdflibpatch import inContext |
|
f64e20d3407e
RgbPixelsAnimation and docker build updates
drewp@bigasterisk.com
parents:
331
diff
changeset
|
19 from rdfdb.patch import Patch |
|
640
23ab244aa649
move bnode id optimization to its own file. more logging cleanups
drewp@bigasterisk.com
parents:
639
diff
changeset
|
20 from rdflib_pi_opt import patchRandid |
|
23ab244aa649
move bnode id optimization to its own file. more logging cleanups
drewp@bigasterisk.com
parents:
639
diff
changeset
|
21 from export_to_influxdb import InfluxExporter |
| 182 | 22 |
| 23 import devices | |
|
233
4ebb5cc30002
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp@bigasterisk.com
parents:
230
diff
changeset
|
24 |
| 182 | 25 ROOM = Namespace('http://projects.bigasterisk.com/room/') |
| 26 HOST = Namespace('http://bigasterisk.com/ruler/host/') | |
| 27 | |
| 28 hostname = socket.gethostname() | |
|
233
4ebb5cc30002
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp@bigasterisk.com
parents:
230
diff
changeset
|
29 CTX = ROOM['pi/%s' % hostname] |
|
4ebb5cc30002
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp@bigasterisk.com
parents:
230
diff
changeset
|
30 |
|
466
1122016d16eb
stats handler, events output fix, build updaets
drewp@bigasterisk.com
parents:
408
diff
changeset
|
31 STATS = scales.collection('/root', |
|
552
98384c3ccd33
update build and deps to use invoke and to use new lib layout, plus more stats collection
drewp@bigasterisk.com
parents:
466
diff
changeset
|
32 scales.PmfStat('configReread'), |
|
98384c3ccd33
update build and deps to use invoke and to use new lib layout, plus more stats collection
drewp@bigasterisk.com
parents:
466
diff
changeset
|
33 scales.IntStat('pollException'), |
|
625
69a84b3d1dfa
frontdoor configs; move device class timing to greplin stats
drewp@bigasterisk.com
parents:
624
diff
changeset
|
34 scales.PmfStat('pollAll'), |
|
552
98384c3ccd33
update build and deps to use invoke and to use new lib layout, plus more stats collection
drewp@bigasterisk.com
parents:
466
diff
changeset
|
35 scales.PmfStat('sendOneshot'), |
|
98384c3ccd33
update build and deps to use invoke and to use new lib layout, plus more stats collection
drewp@bigasterisk.com
parents:
466
diff
changeset
|
36 scales.PmfStat('outputStatements'), |
|
98384c3ccd33
update build and deps to use invoke and to use new lib layout, plus more stats collection
drewp@bigasterisk.com
parents:
466
diff
changeset
|
37 |
|
466
1122016d16eb
stats handler, events output fix, build updaets
drewp@bigasterisk.com
parents:
408
diff
changeset
|
38 ) |
| 258 | 39 |
|
183
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
40 class Config(object): |
|
408
0787cd64ecf8
cmdline flag on piNode to pick hub host
drewp@bigasterisk.com
parents:
382
diff
changeset
|
41 def __init__(self, masterGraph, hubHost): |
|
0787cd64ecf8
cmdline flag on piNode to pick hub host
drewp@bigasterisk.com
parents:
382
diff
changeset
|
42 self.etcd = etcd3.client(host=hubHost, port=9022) |
|
0787cd64ecf8
cmdline flag on piNode to pick hub host
drewp@bigasterisk.com
parents:
382
diff
changeset
|
43 |
| 347 | 44 self.masterGraph = masterGraph |
|
408
0787cd64ecf8
cmdline flag on piNode to pick hub host
drewp@bigasterisk.com
parents:
382
diff
changeset
|
45 self.hubHost = hubHost |
| 347 | 46 self.configGraph = ConjunctiveGraph() |
| 47 self.boards = [] | |
| 48 self.etcPrefix = 'pi/' | |
|
628
accbbd521ecd
wip for pytype support and separate device run loops on piNode
drewp@bigasterisk.com
parents:
627
diff
changeset
|
49 self.rereadLater = None |
| 347 | 50 |
| 51 self.reread() | |
| 52 | |
| 53 deferToThread(self.watchEtcd) | |
| 54 | |
| 55 def watchEtcd(self): | |
|
408
0787cd64ecf8
cmdline flag on piNode to pick hub host
drewp@bigasterisk.com
parents:
382
diff
changeset
|
56 events, cancel = self.etcd.watch_prefix(self.etcPrefix) |
| 347 | 57 reactor.addSystemEventTrigger('before', 'shutdown', cancel) |
| 58 for ev in events: | |
| 59 log.info('%s changed', ev.key) | |
| 60 reactor.callFromThread(self.configChanged) | |
| 61 | |
| 62 def configChanged(self): | |
| 63 self.cancelRead() | |
| 64 self.rereadLater = reactor.callLater(.1, self.reread) | |
| 65 | |
| 66 def cancelRead(self): | |
|
628
accbbd521ecd
wip for pytype support and separate device run loops on piNode
drewp@bigasterisk.com
parents:
627
diff
changeset
|
67 if self.rereadLater: |
| 347 | 68 self.rereadLater.cancel() |
| 69 self.rereadLater = None | |
|
552
98384c3ccd33
update build and deps to use invoke and to use new lib layout, plus more stats collection
drewp@bigasterisk.com
parents:
466
diff
changeset
|
70 |
|
98384c3ccd33
update build and deps to use invoke and to use new lib layout, plus more stats collection
drewp@bigasterisk.com
parents:
466
diff
changeset
|
71 @STATS.configReread.time() |
| 347 | 72 def reread(self): |
| 73 self.rereadLater = None | |
|
183
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
74 log.info('read config') |
| 347 | 75 self.configGraph = ConjunctiveGraph() |
|
408
0787cd64ecf8
cmdline flag on piNode to pick hub host
drewp@bigasterisk.com
parents:
382
diff
changeset
|
76 for v, md in self.etcd.get_prefix(self.etcPrefix): |
| 347 | 77 log.info(' read file %r', md.key) |
| 78 self.configGraph.parse(StringInputSource(v), format='n3') | |
| 79 self.configGraph.bind('', ROOM) | |
| 80 self.configGraph.bind('rdf', RDF) | |
|
233
4ebb5cc30002
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp@bigasterisk.com
parents:
230
diff
changeset
|
81 # config graph is too noisy; maybe make it a separate resource |
| 347 | 82 #masterGraph.patch(Patch(addGraph=self.configGraph)) |
| 83 self.setupBoards() | |
| 624 | 84 |
| 85 def setupBoards(self): | |
| 347 | 86 thisHost = Literal(hostname) |
| 87 for row in self.configGraph.query( | |
| 88 'SELECT ?board WHERE { ?board a :PiBoard; :hostname ?h }', | |
| 89 initBindings=dict(h=thisHost)): | |
| 90 thisBoard = row.board | |
| 91 break | |
| 92 else: | |
| 93 log.warn("config had no board for :hostname %s. Waiting for config update." % | |
| 94 thisHost) | |
| 95 self.boards = [] | |
| 96 return | |
| 97 | |
| 98 log.info("found config for board %r" % thisBoard) | |
|
408
0787cd64ecf8
cmdline flag on piNode to pick hub host
drewp@bigasterisk.com
parents:
382
diff
changeset
|
99 self.boards = [Board(self.configGraph, self.masterGraph, thisBoard, self.hubHost)] |
| 347 | 100 |
| 182 | 101 |
|
628
accbbd521ecd
wip for pytype support and separate device run loops on piNode
drewp@bigasterisk.com
parents:
627
diff
changeset
|
102 class DeviceRunner(object): |
| 642 | 103 def __init__(self, dev, masterGraph, sendOneshot, influx): |
|
628
accbbd521ecd
wip for pytype support and separate device run loops on piNode
drewp@bigasterisk.com
parents:
627
diff
changeset
|
104 self.dev = dev |
| 642 | 105 self.masterGraph = masterGraph |
| 106 self.sendOneshot = sendOneshot | |
| 107 self.influx = influx | |
|
628
accbbd521ecd
wip for pytype support and separate device run loops on piNode
drewp@bigasterisk.com
parents:
627
diff
changeset
|
108 self.period = getattr(self.dev, 'pollPeriod', .05) |
| 642 | 109 self.latestStatementsFromInputs = set() |
| 110 self.lastPollTime = None | |
|
628
accbbd521ecd
wip for pytype support and separate device run loops on piNode
drewp@bigasterisk.com
parents:
627
diff
changeset
|
111 |
|
accbbd521ecd
wip for pytype support and separate device run loops on piNode
drewp@bigasterisk.com
parents:
627
diff
changeset
|
112 reactor.callLater(0, self.poll) |
|
accbbd521ecd
wip for pytype support and separate device run loops on piNode
drewp@bigasterisk.com
parents:
627
diff
changeset
|
113 |
| 642 | 114 def syncMasterGraphToHostStatements(self): |
| 115 hostStmtCtx = URIRef(self.dev.uri + '/host') | |
| 116 newQuads = inContext(self.dev.hostStatements(), hostStmtCtx) | |
| 117 p = self.masterGraph.patchSubgraph(hostStmtCtx, newQuads) | |
| 118 if p: | |
| 119 log.debug("patch master with these host stmts %s", p) | |
| 120 | |
|
628
accbbd521ecd
wip for pytype support and separate device run loops on piNode
drewp@bigasterisk.com
parents:
627
diff
changeset
|
121 @inlineCallbacks |
|
accbbd521ecd
wip for pytype support and separate device run loops on piNode
drewp@bigasterisk.com
parents:
627
diff
changeset
|
122 def poll(self): |
|
accbbd521ecd
wip for pytype support and separate device run loops on piNode
drewp@bigasterisk.com
parents:
627
diff
changeset
|
123 now = time.time() |
|
accbbd521ecd
wip for pytype support and separate device run loops on piNode
drewp@bigasterisk.com
parents:
627
diff
changeset
|
124 try: |
|
accbbd521ecd
wip for pytype support and separate device run loops on piNode
drewp@bigasterisk.com
parents:
627
diff
changeset
|
125 with self.dev.stats.poll.time(): |
|
accbbd521ecd
wip for pytype support and separate device run loops on piNode
drewp@bigasterisk.com
parents:
627
diff
changeset
|
126 new = yield maybeDeferred(self.dev.poll) |
|
accbbd521ecd
wip for pytype support and separate device run loops on piNode
drewp@bigasterisk.com
parents:
627
diff
changeset
|
127 finally: |
| 642 | 128 reactor.callLater(max(0, self.period - (time.time() - now)), self.poll) |
| 129 | |
| 130 if isinstance(new, dict): # new style | |
| 131 oneshot = set(new['oneshot']) | |
| 132 new = set(new['latest']) | |
| 133 else: | |
| 134 oneshot = set() | |
| 135 new = set(new) | |
| 136 | |
| 137 prev = self.latestStatementsFromInputs | |
| 138 # it's important that quads from different devices | |
| 139 # don't clash, since that can lead to inconsistent | |
| 140 # patches (e.g. | |
| 141 # dev1 changes value from 1 to 2; | |
| 142 # dev2 changes value from 2 to 3; | |
| 143 # dev1 changes from 2 to 4 but this patch will | |
| 144 # fail since the '2' statement is gone) | |
| 145 self.masterGraph.patch(Patch.fromDiff(inContext(prev, self.dev.uri), | |
| 146 inContext(new, self.dev.uri))) | |
| 147 self.latestStatementsFromInputs = new | |
| 148 | |
| 149 self.syncMasterGraphToHostStatements() # needed? | |
| 150 | |
| 151 if oneshot: | |
| 152 self.sendOneshot(oneshot) | |
| 153 self.lastPollTime = now | |
| 154 | |
| 155 if self.latestStatementsFromInputs: | |
| 156 self.influx.exportToInflux(set.union(set(self.latestStatementsFromInputs))) | |
| 157 | |
|
628
accbbd521ecd
wip for pytype support and separate device run loops on piNode
drewp@bigasterisk.com
parents:
627
diff
changeset
|
158 returnValue(new) |
|
accbbd521ecd
wip for pytype support and separate device run loops on piNode
drewp@bigasterisk.com
parents:
627
diff
changeset
|
159 |
| 642 | 160 def filterIncomingStatements(self, stmts): |
| 161 wanted = set() | |
| 162 unwanted = set(stmts) | |
| 163 for pat in self.dev.outputPatterns(): | |
| 164 if [term is None for term in pat] != [False, False, True]: | |
| 165 raise NotImplementedError | |
| 166 for stmt in stmts: | |
| 167 if stmt[:2] == pat[:2]: | |
| 168 wanted.add(stmt) | |
| 169 unwanted.discard(stmt) | |
| 170 return wanted, unwanted | |
| 171 | |
| 172 def onPutStatements(self, stmts): | |
| 173 log.info("output goes to action handler for %s" % self.dev.uri) | |
| 174 with self.dev.stats.output.time(): | |
| 175 self.dev.sendOutput(stmts) | |
| 176 self.syncMasterGraphToHostStatements() | |
| 177 | |
| 182 | 178 class Board(object): |
| 179 """similar to arduinoNode.Board but without the communications stuff""" | |
|
408
0787cd64ecf8
cmdline flag on piNode to pick hub host
drewp@bigasterisk.com
parents:
382
diff
changeset
|
180 def __init__(self, graph, masterGraph, uri, hubHost): |
| 182 | 181 self.graph, self.uri = graph, uri |
|
408
0787cd64ecf8
cmdline flag on piNode to pick hub host
drewp@bigasterisk.com
parents:
382
diff
changeset
|
182 self.hubHost = hubHost |
| 226 | 183 self.masterGraph = masterGraph |
| 636 | 184 |
|
349
88bd46f4e28c
more robust about not accumulating old stmts
drewp@bigasterisk.com
parents:
347
diff
changeset
|
185 self.masterGraph.setToGraph(self.staticStmts()) |
| 182 | 186 self.pi = pigpio.pi() |
| 642 | 187 |
| 293 | 188 self._influx = InfluxExporter(self.graph) |
| 642 | 189 self._runners = [DeviceRunner(d, self.masterGraph, self.sendOneshot, self._influx) |
| 190 for d in devices.makeDevices(graph, self.uri, self.pi)] | |
| 191 log.debug('found %s devices', len(self._runners)) | |
|
552
98384c3ccd33
update build and deps to use invoke and to use new lib layout, plus more stats collection
drewp@bigasterisk.com
parents:
466
diff
changeset
|
192 |
|
98384c3ccd33
update build and deps to use invoke and to use new lib layout, plus more stats collection
drewp@bigasterisk.com
parents:
466
diff
changeset
|
193 @STATS.sendOneshot.time() |
| 642 | 194 def sendOneshot(self, oneshot): |
|
251
254df9f881a6
start sending oneshot events from some devices
drewp@bigasterisk.com
parents:
243
diff
changeset
|
195 body = (' '.join('%s %s %s .' % (s.n3(), p.n3(), o.n3()) |
|
254df9f881a6
start sending oneshot events from some devices
drewp@bigasterisk.com
parents:
243
diff
changeset
|
196 for s,p,o in oneshot)).encode('utf8') |
|
408
0787cd64ecf8
cmdline flag on piNode to pick hub host
drewp@bigasterisk.com
parents:
382
diff
changeset
|
197 url = 'http://%s:9071/oneShot' % self.hubHost |
| 642 | 198 d = treq.post( |
| 199 url=url.encode('ascii'), | |
| 200 headers={b'Content-Type': [b'text/n3']}, | |
| 201 data=body, | |
|
271
e7a30f72536a
rewrite oneShotPost to ease debugging. add try-block around polling
drewp@bigasterisk.com
parents:
269
diff
changeset
|
202 timeout=5) |
|
e7a30f72536a
rewrite oneShotPost to ease debugging. add try-block around polling
drewp@bigasterisk.com
parents:
269
diff
changeset
|
203 def err(e): |
|
e7a30f72536a
rewrite oneShotPost to ease debugging. add try-block around polling
drewp@bigasterisk.com
parents:
269
diff
changeset
|
204 log.info('oneshot post to %r failed: %s', |
|
e7a30f72536a
rewrite oneShotPost to ease debugging. add try-block around polling
drewp@bigasterisk.com
parents:
269
diff
changeset
|
205 url, e.getErrorMessage()) |
|
e7a30f72536a
rewrite oneShotPost to ease debugging. add try-block around polling
drewp@bigasterisk.com
parents:
269
diff
changeset
|
206 d.addErrback(err) |
|
251
254df9f881a6
start sending oneshot events from some devices
drewp@bigasterisk.com
parents:
243
diff
changeset
|
207 |
|
552
98384c3ccd33
update build and deps to use invoke and to use new lib layout, plus more stats collection
drewp@bigasterisk.com
parents:
466
diff
changeset
|
208 @STATS.outputStatements.time() |
| 642 | 209 def outputStatements(self, stmts: set): |
| 210 if not stmts: | |
| 211 return | |
| 212 for devRunner in self._runners: | |
| 213 wanted, unwanted = devRunner.filterIncomingStatements(stmts) | |
| 214 log.info(f'\ndev {devRunner.dev.uri}:n wanted {wanted}. unwanted {unwanted}') | |
| 215 if len(wanted) == len(stmts): | |
| 216 devRunner.onPutStatements(stmts) | |
| 217 break | |
| 218 elif len(unwanted) == len(stmts): | |
| 219 continue | |
| 220 else: | |
| 221 raise NotImplementedError(f'dev {devRunner.dev.uri} wanted only {wanted}') | |
| 222 else: | |
|
233
4ebb5cc30002
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp@bigasterisk.com
parents:
230
diff
changeset
|
223 log.info("Board %s doesn't care about these statements:", self.uri) |
|
4ebb5cc30002
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp@bigasterisk.com
parents:
230
diff
changeset
|
224 for s in unused: |
|
4ebb5cc30002
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp@bigasterisk.com
parents:
230
diff
changeset
|
225 log.warn("%r", s) |
|
4ebb5cc30002
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp@bigasterisk.com
parents:
230
diff
changeset
|
226 |
| 226 | 227 def staticStmts(self): |
|
233
4ebb5cc30002
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp@bigasterisk.com
parents:
230
diff
changeset
|
228 return [(HOST[hostname], ROOM['connectedTo'], self.uri, CTX)] |
|
4ebb5cc30002
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp@bigasterisk.com
parents:
230
diff
changeset
|
229 |
|
183
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
230 def description(self): |
|
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
231 """for web page""" |
|
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
232 return { |
|
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
233 'uri': self.uri, |
| 642 | 234 'devices': [d.dev.description() for d in self._runners], |
|
183
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
235 'graph': 'http://sticker:9059/graph', #todo |
|
628
accbbd521ecd
wip for pytype support and separate device run loops on piNode
drewp@bigasterisk.com
parents:
627
diff
changeset
|
236 } |
| 624 | 237 |
|
184
e052416a2290
piNode allow nt graphs as the body of a PUT /output
drewp@bigasterisk.com
parents:
183
diff
changeset
|
238 def rdfGraphBody(body, headers): |
|
e052416a2290
piNode allow nt graphs as the body of a PUT /output
drewp@bigasterisk.com
parents:
183
diff
changeset
|
239 g = Graph() |
|
e052416a2290
piNode allow nt graphs as the body of a PUT /output
drewp@bigasterisk.com
parents:
183
diff
changeset
|
240 g.parse(StringInputSource(body), format='nt') |
|
e052416a2290
piNode allow nt graphs as the body of a PUT /output
drewp@bigasterisk.com
parents:
183
diff
changeset
|
241 return g |
|
183
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
242 |
| 591 | 243 class OutputPage(PrettyErrorHandler, cyclone.web.RequestHandler): |
| 182 | 244 def put(self): |
|
184
e052416a2290
piNode allow nt graphs as the body of a PUT /output
drewp@bigasterisk.com
parents:
183
diff
changeset
|
245 arg = self.request.arguments |
|
e052416a2290
piNode allow nt graphs as the body of a PUT /output
drewp@bigasterisk.com
parents:
183
diff
changeset
|
246 if arg.get('s') and arg.get('p'): |
|
e052416a2290
piNode allow nt graphs as the body of a PUT /output
drewp@bigasterisk.com
parents:
183
diff
changeset
|
247 subj = URIRef(arg['s'][-1]) |
|
e052416a2290
piNode allow nt graphs as the body of a PUT /output
drewp@bigasterisk.com
parents:
183
diff
changeset
|
248 pred = URIRef(arg['p'][-1]) |
|
e052416a2290
piNode allow nt graphs as the body of a PUT /output
drewp@bigasterisk.com
parents:
183
diff
changeset
|
249 turtleLiteral = self.request.body |
|
e052416a2290
piNode allow nt graphs as the body of a PUT /output
drewp@bigasterisk.com
parents:
183
diff
changeset
|
250 try: |
|
e052416a2290
piNode allow nt graphs as the body of a PUT /output
drewp@bigasterisk.com
parents:
183
diff
changeset
|
251 obj = Literal(float(turtleLiteral)) |
|
e052416a2290
piNode allow nt graphs as the body of a PUT /output
drewp@bigasterisk.com
parents:
183
diff
changeset
|
252 except ValueError: |
|
e052416a2290
piNode allow nt graphs as the body of a PUT /output
drewp@bigasterisk.com
parents:
183
diff
changeset
|
253 obj = Literal(turtleLiteral) |
|
e052416a2290
piNode allow nt graphs as the body of a PUT /output
drewp@bigasterisk.com
parents:
183
diff
changeset
|
254 stmt = (subj, pred, obj) |
|
e052416a2290
piNode allow nt graphs as the body of a PUT /output
drewp@bigasterisk.com
parents:
183
diff
changeset
|
255 else: |
|
e052416a2290
piNode allow nt graphs as the body of a PUT /output
drewp@bigasterisk.com
parents:
183
diff
changeset
|
256 g = rdfGraphBody(self.request.body, self.request.headers) |
|
e052416a2290
piNode allow nt graphs as the body of a PUT /output
drewp@bigasterisk.com
parents:
183
diff
changeset
|
257 assert len(g) == 1, len(g) |
| 636 | 258 stmt = next(g.triples((None, None, None))) |
| 182 | 259 |
| 347 | 260 for b in self.settings.config.boards: |
| 636 | 261 b.outputStatements({stmt}) |
| 182 | 262 |
| 591 | 263 class Boards(PrettyErrorHandler, cyclone.web.RequestHandler): |
|
183
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
264 def get(self): |
|
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
265 self.set_header('Content-type', 'application/json') |
|
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
266 self.write(json.dumps({ |
|
233
4ebb5cc30002
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp@bigasterisk.com
parents:
230
diff
changeset
|
267 'host': hostname, |
| 347 | 268 'boards': [b.description() for b in self.settings.config.boards] |
|
183
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
269 }, indent=2)) |
| 624 | 270 |
| 182 | 271 def main(): |
| 272 arg = docopt(""" | |
| 273 Usage: piNode.py [options] | |
| 274 | |
|
408
0787cd64ecf8
cmdline flag on piNode to pick hub host
drewp@bigasterisk.com
parents:
382
diff
changeset
|
275 -v Verbose |
|
0787cd64ecf8
cmdline flag on piNode to pick hub host
drewp@bigasterisk.com
parents:
382
diff
changeset
|
276 --ow Just report onewire device URIs and readings, then exit. |
|
0787cd64ecf8
cmdline flag on piNode to pick hub host
drewp@bigasterisk.com
parents:
382
diff
changeset
|
277 --hub=HOST Hostname for etc3 and oneshot posts. [default: bang.vpn-home.bigasterisk.com] |
| 182 | 278 """) |
|
640
23ab244aa649
move bnode id optimization to its own file. more logging cleanups
drewp@bigasterisk.com
parents:
639
diff
changeset
|
279 verboseLogging(arg['-v']) |
|
233
4ebb5cc30002
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp@bigasterisk.com
parents:
230
diff
changeset
|
280 |
|
408
0787cd64ecf8
cmdline flag on piNode to pick hub host
drewp@bigasterisk.com
parents:
382
diff
changeset
|
281 if arg['--ow']: |
|
0787cd64ecf8
cmdline flag on piNode to pick hub host
drewp@bigasterisk.com
parents:
382
diff
changeset
|
282 log.setLevel(logging.INFO) |
|
0787cd64ecf8
cmdline flag on piNode to pick hub host
drewp@bigasterisk.com
parents:
382
diff
changeset
|
283 for stmt in devices.OneWire().poll(): |
| 636 | 284 print(stmt) |
|
408
0787cd64ecf8
cmdline flag on piNode to pick hub host
drewp@bigasterisk.com
parents:
382
diff
changeset
|
285 return |
| 624 | 286 |
|
640
23ab244aa649
move bnode id optimization to its own file. more logging cleanups
drewp@bigasterisk.com
parents:
639
diff
changeset
|
287 patchRandid() |
|
23ab244aa649
move bnode id optimization to its own file. more logging cleanups
drewp@bigasterisk.com
parents:
639
diff
changeset
|
288 |
| 226 | 289 masterGraph = PatchableGraph() |
|
408
0787cd64ecf8
cmdline flag on piNode to pick hub host
drewp@bigasterisk.com
parents:
382
diff
changeset
|
290 config = Config(masterGraph, arg['--hub']) |
| 624 | 291 |
|
552
98384c3ccd33
update build and deps to use invoke and to use new lib layout, plus more stats collection
drewp@bigasterisk.com
parents:
466
diff
changeset
|
292 static = pkg_resources.resource_filename('homeauto_anynode', 'static/') |
|
98384c3ccd33
update build and deps to use invoke and to use new lib layout, plus more stats collection
drewp@bigasterisk.com
parents:
466
diff
changeset
|
293 |
| 182 | 294 reactor.listenTCP(9059, cyclone.web.Application([ |
|
627
c3f0a98fa65d
lib upgrades; fix a static http server path
drewp@bigasterisk.com
parents:
625
diff
changeset
|
295 (r"/(|output-widgets.html)", cyclone.web.StaticFileHandler, { |
|
552
98384c3ccd33
update build and deps to use invoke and to use new lib layout, plus more stats collection
drewp@bigasterisk.com
parents:
466
diff
changeset
|
296 "path": static, "default_filename": "index.html"}), |
| 553 | 297 (r'/static/(.*)', cyclone.web.StaticFileHandler, {"path": static}), |
|
466
1122016d16eb
stats handler, events output fix, build updaets
drewp@bigasterisk.com
parents:
408
diff
changeset
|
298 (r'/stats/(.*)', StatsHandler, {'serverName': 'piNode'}), |
|
233
4ebb5cc30002
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp@bigasterisk.com
parents:
230
diff
changeset
|
299 (r'/boards', Boards), |
| 226 | 300 (r"/graph", CycloneGraphHandler, {'masterGraph': masterGraph}), |
| 301 (r"/graph/events", CycloneGraphEventsHandler, {'masterGraph': masterGraph}), | |
| 182 | 302 (r'/output', OutputPage), |
|
466
1122016d16eb
stats handler, events output fix, build updaets
drewp@bigasterisk.com
parents:
408
diff
changeset
|
303 ], config=config, debug=arg['-v']), interface='::') |
| 258 | 304 log.warn('serving on 9059') |
| 182 | 305 reactor.run() |
| 306 | |
| 307 main() |