Mercurial > code > home > repos > homeauto
annotate service/piNode/piNode.py @ 183:634d6e477953
get piNode working, for motionsensor at least
Ignore-this: 53f16373acb0613e01fdf3e98d8425f2
| author | drewp@bigasterisk.com |
|---|---|
| date | Sun, 31 May 2015 22:53:21 -0700 |
| parents | 9fff29ebca71 |
| children | e052416a2290 |
| rev | line source |
|---|---|
| 182 | 1 from __future__ import division |
|
183
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
2 import sys, logging, socket, json |
| 182 | 3 import cyclone.web |
|
183
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
4 from rdflib import Namespace, URIRef, Literal, Graph, RDF |
| 182 | 5 from twisted.internet import reactor, task |
| 6 from docopt import docopt | |
| 7 logging.basicConfig(level=logging.DEBUG) | |
| 8 sys.path.append("/my/site/magma") | |
|
183
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
9 sys.path.append("../../../../site/magma") |
|
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
10 |
| 182 | 11 from stategraph import StateGraph |
| 12 sys.path.append('/home/pi/dim/PIGPIO') | |
|
183
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
13 try: |
|
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
14 import pigpio |
|
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
15 except ImportError: |
|
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
16 class pigpio(object): |
|
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
17 @staticmethod |
|
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
18 def pi(): |
|
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
19 return None |
| 182 | 20 |
| 21 import devices | |
| 22 | |
| 23 log = logging.getLogger() | |
| 24 logging.getLogger('serial').setLevel(logging.WARN) | |
| 25 ROOM = Namespace('http://projects.bigasterisk.com/room/') | |
| 26 HOST = Namespace('http://bigasterisk.com/ruler/host/') | |
| 27 | |
| 28 hostname = socket.gethostname() | |
| 29 | |
|
183
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
30 class Config(object): |
|
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
31 def __init__(self): |
|
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
32 self.graph = Graph() |
|
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
33 log.info('read config') |
|
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
34 self.graph.parse('config.n3', format='n3') |
|
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
35 self.graph.bind('', ROOM) # not working |
|
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
36 self.graph.bind('rdf', RDF) |
|
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
37 |
| 182 | 38 class GraphPage(cyclone.web.RequestHandler): |
| 39 def get(self): | |
| 40 g = StateGraph(ctx=ROOM['pi/%s' % hostname]) | |
| 41 | |
| 42 for stmt in self.settings.board.currentGraph(): | |
| 43 g.add(stmt) | |
| 44 | |
| 45 if self.get_argument('config', 'no') == 'yes': | |
| 46 for stmt in self.settings.config.graph: | |
| 47 g.add(stmt) | |
| 48 | |
| 49 self.set_header('Content-type', 'application/x-trig') | |
| 50 self.write(g.asTrig()) | |
| 51 | |
| 52 class Board(object): | |
| 53 """similar to arduinoNode.Board but without the communications stuff""" | |
| 54 def __init__(self, graph, uri, onChange): | |
| 55 self.graph, self.uri = graph, uri | |
| 56 self.pi = pigpio.pi() | |
| 57 self._devs = devices.makeDevices(graph, self.uri, self.pi) | |
|
183
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
58 log.debug('found %s devices', len(self._devs)) |
| 182 | 59 self._statementsFromInputs = {} # input device uri: latest statements |
| 60 | |
| 61 def startPolling(self): | |
| 62 task.LoopingCall(self._poll).start(.5) | |
| 63 | |
| 64 def _poll(self): | |
| 65 for i in self._devs: | |
| 66 self._statementsFromInputs[i.uri] = i.poll() | |
| 67 | |
| 68 def outputStatements(self, stmts): | |
| 69 unused = set(stmts) | |
| 70 for dev in self._devs: | |
| 71 stmtsForDev = [] | |
| 72 for pat in dev.outputPatterns(): | |
| 73 if [term is None for term in pat] != [False, False, True]: | |
| 74 raise NotImplementedError | |
| 75 for stmt in stmts: | |
| 76 if stmt[:2] == pat[:2]: | |
| 77 stmtsForDev.append(stmt) | |
| 78 unused.discard(stmt) | |
| 79 if stmtsForDev: | |
| 80 log.info("output goes to action handler for %s" % dev.uri) | |
| 81 dev.sendOutput(stmtsForDev) | |
| 82 log.info("success") | |
| 83 if unused: | |
| 84 log.warn("No devices cared about these statements:") | |
| 85 for s in unused: | |
| 86 log.warn(repr(s)) | |
| 87 | |
|
183
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
88 def currentGraph(self): |
|
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
89 g = Graph() |
|
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
90 |
|
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
91 g.add((HOST[socket.gethostname()], ROOM['connectedTo'], self.uri)) |
|
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
92 |
|
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
93 for si in self._statementsFromInputs.values(): |
|
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
94 for s in si: |
|
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
95 g.add(s) |
|
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
96 return g |
|
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
97 |
|
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
98 def description(self): |
|
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
99 """for web page""" |
|
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
100 return { |
|
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
101 'uri': self.uri, |
|
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
102 'devices': [d.description() for d in self._devs], |
|
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
103 'graph': 'http://sticker:9059/graph', #todo |
|
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
104 } |
|
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
105 |
|
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
106 |
| 182 | 107 class OutputPage(cyclone.web.RequestHandler): |
| 108 def put(self): | |
| 109 subj = URIRef(self.get_argument('s')) | |
| 110 pred = URIRef(self.get_argument('p')) | |
| 111 | |
| 112 turtleLiteral = self.request.body | |
| 113 try: | |
| 114 obj = Literal(float(turtleLiteral)) | |
|
183
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
115 except ValueError: |
| 182 | 116 obj = Literal(turtleLiteral) |
| 117 | |
| 118 stmt = (subj, pred, obj) | |
| 119 self.settings.board.outputStatements([stmt]) | |
| 120 | |
|
183
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
121 class Boards(cyclone.web.RequestHandler): |
|
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
122 def get(self): |
|
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
123 self.set_header('Content-type', 'application/json') |
|
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
124 self.write(json.dumps({ |
|
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
125 'boards': [self.settings.board.description()] |
|
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
126 }, indent=2)) |
|
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
127 |
| 182 | 128 def main(): |
| 129 arg = docopt(""" | |
| 130 Usage: piNode.py [options] | |
| 131 | |
| 132 -v Verbose | |
| 133 """) | |
| 134 log.setLevel(logging.WARN) | |
| 135 if arg['-v']: | |
| 136 from twisted.python import log as twlog | |
| 137 twlog.startLogging(sys.stdout) | |
| 138 | |
| 139 log.setLevel(logging.DEBUG) | |
| 140 | |
| 141 config = Config() | |
| 142 | |
| 143 def onChange(): | |
| 144 # notify reasoning | |
| 145 pass | |
| 146 | |
| 147 thisBoard = URIRef('http://bigasterisk.com/homeauto/node2') | |
| 148 | |
| 149 board = Board(config.graph, thisBoard, onChange) | |
|
183
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
150 board.startPolling() |
| 182 | 151 |
| 152 reactor.listenTCP(9059, cyclone.web.Application([ | |
| 153 (r"/()", cyclone.web.StaticFileHandler, { | |
|
183
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
154 "path": "../arduinoNode/static", "default_filename": "index.html"}), |
|
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
155 (r'/static/(.*)', cyclone.web.StaticFileHandler, {"path": "../arduinoNode/static"}), |
| 182 | 156 (r"/graph", GraphPage), |
| 157 (r'/output', OutputPage), | |
|
183
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
158 (r'/boards', Boards), |
|
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
159 #(r'/dot', Dot), |
| 182 | 160 ], config=config, board=board)) |
| 161 reactor.run() | |
| 162 | |
| 163 main() |