Mercurial > code > home > repos > homeauto

annotate service/arduinoNode/arduinoNode.py @ 243:141079644c45

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
piNode poll switches much faster. mirror the logic in arduinoNode though vari-rate poll is not supported yet Ignore-this: 4ef38c7a2ed35f77035209bffeffc245
author drewp@bigasterisk.com
date Tue, 02 Feb 2016 22:37:11 -0800
parents 4ebb5cc30002
children 254df9f881a6
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
166
c0180bd2b33a only recompile if the C code is new. redo Device class api. single temperature sensor is working
drewp@bigasterisk.com
parents: 164
diff changeset
1 """
169
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
2 depends on packages:
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
3 arduino-mk
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
4 indent
166
c0180bd2b33a only recompile if the C code is new. redo Device class api. single temperature sensor is working
drewp@bigasterisk.com
parents: 164
diff changeset
5 """
169
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
6 from __future__ import division
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
7 import glob, sys, logging, subprocess, socket, os, hashlib, time, tempfile
170
376599552a4c polymer board debug page with working output widgets
drewp@bigasterisk.com
parents: 169
diff changeset
8 import shutil, json
169
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
9 import serial
164
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
10 import cyclone.web
230
0aa54404df19 update arduinoNode to support streamed graph output
drewp@bigasterisk.com
parents: 229
diff changeset
11 from rdflib import Graph, Namespace, URIRef, Literal, RDF, ConjunctiveGraph
169
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
12 from rdflib.parser import StringInputSource
164
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
13 from twisted.internet import reactor, task
176
f81c4d3d774b arduinoNode: use -v for logging; support a PUT with subj+pred in query, obj in body
drewp@bigasterisk.com
parents: 170
diff changeset
14 from docopt import docopt
169
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
15
164
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
16 import devices
229
07ee72a042db refactor to write_arduino_node
drewp@bigasterisk.com
parents: 222
diff changeset
17 import write_arduino_code
166
c0180bd2b33a only recompile if the C code is new. redo Device class api. single temperature sensor is working
drewp@bigasterisk.com
parents: 164
diff changeset
18 import dotrender
169
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
19 import rdflib_patch
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
20 rdflib_patch.fixQnameOfUriWithTrailingSlash()
164
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
21
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
22 logging.basicConfig(level=logging.DEBUG)
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
23
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
24 from loggingserial import LoggingSerial
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
25
230
0aa54404df19 update arduinoNode to support streamed graph output
drewp@bigasterisk.com
parents: 229
diff changeset
26 sys.path.append("../../lib")
0aa54404df19 update arduinoNode to support streamed graph output
drewp@bigasterisk.com
parents: 229
diff changeset
27 from patchablegraph import PatchableGraph, CycloneGraphHandler, CycloneGraphEventsHandler
0aa54404df19 update arduinoNode to support streamed graph output
drewp@bigasterisk.com
parents: 229
diff changeset
28
0aa54404df19 update arduinoNode to support streamed graph output
drewp@bigasterisk.com
parents: 229
diff changeset
29 sys.path.append("/my/proj/light9")
0aa54404df19 update arduinoNode to support streamed graph output
drewp@bigasterisk.com
parents: 229
diff changeset
30 from light9.rdfdb.patch import Patch
0aa54404df19 update arduinoNode to support streamed graph output
drewp@bigasterisk.com
parents: 229
diff changeset
31 from light9.rdfdb.rdflibpatch import inContext
164
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
32
213
9c8674329a13 write some values to carbon/graphite upon polling
drewp@bigasterisk.com
parents: 192
diff changeset
33 sys.path.append("/my/proj/room")
9c8674329a13 write some values to carbon/graphite upon polling
drewp@bigasterisk.com
parents: 192
diff changeset
34 from carbondata import CarbonClient
9c8674329a13 write some values to carbon/graphite upon polling
drewp@bigasterisk.com
parents: 192
diff changeset
35
164
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
36 log = logging.getLogger()
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
37 logging.getLogger('serial').setLevel(logging.WARN)
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
38
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
39 ROOM = Namespace('http://projects.bigasterisk.com/room/')
166
c0180bd2b33a only recompile if the C code is new. redo Device class api. single temperature sensor is working
drewp@bigasterisk.com
parents: 164
diff changeset
40 HOST = Namespace('http://bigasterisk.com/ruler/host/')
164
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
41
169
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
42 ACTION_BASE = 10 # higher than any of the fixed command numbers
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
43
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
44 hostname = socket.gethostname()
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
45 CTX = ROOM['arduinosOn%s' % hostname]
230
0aa54404df19 update arduinoNode to support streamed graph output
drewp@bigasterisk.com
parents: 229
diff changeset
46
164
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
47 class Config(object):
230
0aa54404df19 update arduinoNode to support streamed graph output
drewp@bigasterisk.com
parents: 229
diff changeset
48 def __init__(self, masterGraph):
0aa54404df19 update arduinoNode to support streamed graph output
drewp@bigasterisk.com
parents: 229
diff changeset
49 self.graph = ConjunctiveGraph()
164
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
50 log.info('read config')
214
254d656af72e support a dir of config files
drewp@bigasterisk.com
parents: 213
diff changeset
51 for f in os.listdir('config'):
254d656af72e support a dir of config files
drewp@bigasterisk.com
parents: 213
diff changeset
52 if f.startswith('.'): continue
254d656af72e support a dir of config files
drewp@bigasterisk.com
parents: 213
diff changeset
53 self.graph.parse('config/%s' % f, format='n3')
166
c0180bd2b33a only recompile if the C code is new. redo Device class api. single temperature sensor is working
drewp@bigasterisk.com
parents: 164
diff changeset
54 self.graph.bind('', ROOM) # not working
164
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
55 self.graph.bind('rdf', RDF)
230
0aa54404df19 update arduinoNode to support streamed graph output
drewp@bigasterisk.com
parents: 229
diff changeset
56 # config graph is too noisy; maybe make it a separate resource
0aa54404df19 update arduinoNode to support streamed graph output
drewp@bigasterisk.com
parents: 229
diff changeset
57 #masterGraph.patch(Patch(addGraph=self.graph))
164
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
58
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
59 def serialDevices(self):
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
60 return dict([(row.dev, row.board) for row in self.graph.query(
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
61 """SELECT ?board ?dev WHERE {
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
62 ?board :device ?dev;
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
63 a :ArduinoBoard .
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
64 }""", initNs={'': ROOM})])
166
c0180bd2b33a only recompile if the C code is new. redo Device class api. single temperature sensor is working
drewp@bigasterisk.com
parents: 164
diff changeset
65
164
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
66 class Board(object):
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
67 """an arduino connected to this computer"""
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
68 baudrate = 115200
230
0aa54404df19 update arduinoNode to support streamed graph output
drewp@bigasterisk.com
parents: 229
diff changeset
69 def __init__(self, dev, configGraph, masterGraph, uri):
164
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
70 """
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
71 each connected thing has some pins.
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
72 """
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
73 self.uri = uri
230
0aa54404df19 update arduinoNode to support streamed graph output
drewp@bigasterisk.com
parents: 229
diff changeset
74 self.configGraph = configGraph
0aa54404df19 update arduinoNode to support streamed graph output
drewp@bigasterisk.com
parents: 229
diff changeset
75 self.masterGraph = masterGraph
164
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
76 self.dev = dev
230
0aa54404df19 update arduinoNode to support streamed graph output
drewp@bigasterisk.com
parents: 229
diff changeset
77
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
78 self.masterGraph.patch(Patch(addQuads=self.staticStmts()))
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
79
164
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
80 # The order of this list needs to be consistent between the
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
81 # deployToArduino call and the poll call.
230
0aa54404df19 update arduinoNode to support streamed graph output
drewp@bigasterisk.com
parents: 229
diff changeset
82 self._devs = devices.makeDevices(configGraph, self.uri)
169
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
83 self._devCommandNum = dict((dev.uri, ACTION_BASE + devIndex)
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
84 for devIndex, dev in enumerate(self._devs))
166
c0180bd2b33a only recompile if the C code is new. redo Device class api. single temperature sensor is working
drewp@bigasterisk.com
parents: 164
diff changeset
85 self._polledDevs = [d for d in self._devs if d.generatePollCode()]
164
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
86
185
2161c71c7b02 support for device code in the idle loop
drewp@bigasterisk.com
parents: 176
diff changeset
87 self._statementsFromInputs = {} # input device uri: latest statements
243
141079644c45 piNode poll switches much faster. mirror the logic in arduinoNode though vari-rate poll is not supported yet
drewp@bigasterisk.com
parents: 233
diff changeset
88 self._lastPollTime = {} # input device uri: time()
213
9c8674329a13 write some values to carbon/graphite upon polling
drewp@bigasterisk.com
parents: 192
diff changeset
89 self._carbon = CarbonClient(serverHost='bang')
166
c0180bd2b33a only recompile if the C code is new. redo Device class api. single temperature sensor is working
drewp@bigasterisk.com
parents: 164
diff changeset
90 self.open()
230
0aa54404df19 update arduinoNode to support streamed graph output
drewp@bigasterisk.com
parents: 229
diff changeset
91 for d in self._devs:
0aa54404df19 update arduinoNode to support streamed graph output
drewp@bigasterisk.com
parents: 229
diff changeset
92 self.syncMasterGraphToHostStatements(d)
164
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
93
170
376599552a4c polymer board debug page with working output widgets
drewp@bigasterisk.com
parents: 169
diff changeset
94 def description(self):
376599552a4c polymer board debug page with working output widgets
drewp@bigasterisk.com
parents: 169
diff changeset
95 """for web page"""
376599552a4c polymer board debug page with working output widgets
drewp@bigasterisk.com
parents: 169
diff changeset
96 return {
376599552a4c polymer board debug page with working output widgets
drewp@bigasterisk.com
parents: 169
diff changeset
97 'uri': self.uri,
376599552a4c polymer board debug page with working output widgets
drewp@bigasterisk.com
parents: 169
diff changeset
98 'dev': self.dev,
376599552a4c polymer board debug page with working output widgets
drewp@bigasterisk.com
parents: 169
diff changeset
99 'baudrate': self.baudrate,
376599552a4c polymer board debug page with working output widgets
drewp@bigasterisk.com
parents: 169
diff changeset
100 'devices': [d.description() for d in self._devs],
376599552a4c polymer board debug page with working output widgets
drewp@bigasterisk.com
parents: 169
diff changeset
101 }
376599552a4c polymer board debug page with working output widgets
drewp@bigasterisk.com
parents: 169
diff changeset
102
164
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
103 def open(self):
166
c0180bd2b33a only recompile if the C code is new. redo Device class api. single temperature sensor is working
drewp@bigasterisk.com
parents: 164
diff changeset
104 self.ser = LoggingSerial(port=self.dev, baudrate=self.baudrate,
c0180bd2b33a only recompile if the C code is new. redo Device class api. single temperature sensor is working
drewp@bigasterisk.com
parents: 164
diff changeset
105 timeout=2)
164
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
106
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
107 def startPolling(self):
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
108 task.LoopingCall(self._poll).start(.5)
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
109
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
110 def _poll(self):
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
111 """
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
112 even boards with no inputs need some polling to see if they're
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
113 still ok
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
114 """
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
115 try:
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
116 self._pollWork()
169
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
117 except serial.SerialException:
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
118 reactor.crash()
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
119 raise
164
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
120 except Exception as e:
230
0aa54404df19 update arduinoNode to support streamed graph output
drewp@bigasterisk.com
parents: 229
diff changeset
121 import traceback; traceback.print_exc()
164
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
122 log.warn("poll: %r" % e)
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
123
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
124 def _pollWork(self):
169
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
125 t1 = time.time()
243
141079644c45 piNode poll switches much faster. mirror the logic in arduinoNode though vari-rate poll is not supported yet
drewp@bigasterisk.com
parents: 233
diff changeset
126 self.ser.write("\x60\x00") # "poll everything"
166
c0180bd2b33a only recompile if the C code is new. redo Device class api. single temperature sensor is working
drewp@bigasterisk.com
parents: 164
diff changeset
127 for i in self._polledDevs:
243
141079644c45 piNode poll switches much faster. mirror the logic in arduinoNode though vari-rate poll is not supported yet
drewp@bigasterisk.com
parents: 233
diff changeset
128 now = time.time()
141079644c45 piNode poll switches much faster. mirror the logic in arduinoNode though vari-rate poll is not supported yet
drewp@bigasterisk.com
parents: 233
diff changeset
129 new = i.readFromPoll(self.ser.read)
230
0aa54404df19 update arduinoNode to support streamed graph output
drewp@bigasterisk.com
parents: 229
diff changeset
130 prev = self._statementsFromInputs.get(i.uri, [])
243
141079644c45 piNode poll switches much faster. mirror the logic in arduinoNode though vari-rate poll is not supported yet
drewp@bigasterisk.com
parents: 233
diff changeset
131 if new or prev:
141079644c45 piNode poll switches much faster. mirror the logic in arduinoNode though vari-rate poll is not supported yet
drewp@bigasterisk.com
parents: 233
diff changeset
132 self._statementsFromInputs[i.uri] = new
141079644c45 piNode poll switches much faster. mirror the logic in arduinoNode though vari-rate poll is not supported yet
drewp@bigasterisk.com
parents: 233
diff changeset
133 # it's important that quads from different devices
141079644c45 piNode poll switches much faster. mirror the logic in arduinoNode though vari-rate poll is not supported yet
drewp@bigasterisk.com
parents: 233
diff changeset
134 # don't clash, since that can lead to inconsistent
141079644c45 piNode poll switches much faster. mirror the logic in arduinoNode though vari-rate poll is not supported yet
drewp@bigasterisk.com
parents: 233
diff changeset
135 # patches (e.g.
141079644c45 piNode poll switches much faster. mirror the logic in arduinoNode though vari-rate poll is not supported yet
drewp@bigasterisk.com
parents: 233
diff changeset
136 # dev1 changes value from 1 to 2;
141079644c45 piNode poll switches much faster. mirror the logic in arduinoNode though vari-rate poll is not supported yet
drewp@bigasterisk.com
parents: 233
diff changeset
137 # dev2 changes value from 2 to 3;
141079644c45 piNode poll switches much faster. mirror the logic in arduinoNode though vari-rate poll is not supported yet
drewp@bigasterisk.com
parents: 233
diff changeset
138 # dev1 changes from 2 to 4 but this patch will
141079644c45 piNode poll switches much faster. mirror the logic in arduinoNode though vari-rate poll is not supported yet
drewp@bigasterisk.com
parents: 233
diff changeset
139 # fail since the '2' statement is gone)
141079644c45 piNode poll switches much faster. mirror the logic in arduinoNode though vari-rate poll is not supported yet
drewp@bigasterisk.com
parents: 233
diff changeset
140 self.masterGraph.patch(Patch.fromDiff(inContext(prev, i.uri),
141079644c45 piNode poll switches much faster. mirror the logic in arduinoNode though vari-rate poll is not supported yet
drewp@bigasterisk.com
parents: 233
diff changeset
141 inContext(new, i.uri)))
141079644c45 piNode poll switches much faster. mirror the logic in arduinoNode though vari-rate poll is not supported yet
drewp@bigasterisk.com
parents: 233
diff changeset
142 self._lastPollTime[i.uri] = now
230
0aa54404df19 update arduinoNode to support streamed graph output
drewp@bigasterisk.com
parents: 229
diff changeset
143
164
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
144 #plus statements about succeeding or erroring on the last poll
169
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
145 byte = self.ser.read(1)
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
146 if byte != 'x':
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
147 raise ValueError("after poll, got %x instead of 'x'" % byte)
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
148 elapsed = time.time() - t1
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
149 if elapsed > 1.0:
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
150 log.warn('poll took %.1f seconds' % elapsed)
213
9c8674329a13 write some values to carbon/graphite upon polling
drewp@bigasterisk.com
parents: 192
diff changeset
151 self._exportToGraphite()
9c8674329a13 write some values to carbon/graphite upon polling
drewp@bigasterisk.com
parents: 192
diff changeset
152
9c8674329a13 write some values to carbon/graphite upon polling
drewp@bigasterisk.com
parents: 192
diff changeset
153 def _exportToGraphite(self):
9c8674329a13 write some values to carbon/graphite upon polling
drewp@bigasterisk.com
parents: 192
diff changeset
154 # note this is writing way too often- graphite is storing at a lower res
9c8674329a13 write some values to carbon/graphite upon polling
drewp@bigasterisk.com
parents: 192
diff changeset
155 now = time.time()
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
156 # 20 sec is not precise; just trying to reduce wifi traffic
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
157 if getattr(self, 'lastGraphiteExport', 0) + 20 > now:
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
158 return
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
159 self.lastGraphiteExport = now
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
160 log.debug('graphite export:')
213
9c8674329a13 write some values to carbon/graphite upon polling
drewp@bigasterisk.com
parents: 192
diff changeset
161 # objects of these statements are suitable as graphite values.
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
162 graphitePredicates = {ROOM['temperatureF']}
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
163 # bug: one sensor can have temp and humid- this will be ambiguous
230
0aa54404df19 update arduinoNode to support streamed graph output
drewp@bigasterisk.com
parents: 229
diff changeset
164 for s, graphiteName in self.configGraph.subject_objects(ROOM['graphiteName']):
213
9c8674329a13 write some values to carbon/graphite upon polling
drewp@bigasterisk.com
parents: 192
diff changeset
165 for group in self._statementsFromInputs.values():
9c8674329a13 write some values to carbon/graphite upon polling
drewp@bigasterisk.com
parents: 192
diff changeset
166 for stmt in group:
9c8674329a13 write some values to carbon/graphite upon polling
drewp@bigasterisk.com
parents: 192
diff changeset
167 if stmt[0] == s and stmt[1] in graphitePredicates:
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
168 log.debug(' sending %s -> %s', stmt[0], graphiteName)
213
9c8674329a13 write some values to carbon/graphite upon polling
drewp@bigasterisk.com
parents: 192
diff changeset
169 self._carbon.send(graphiteName, stmt[2].toPython(), now)
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
170
169
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
171 def outputStatements(self, stmts):
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
172 unused = set(stmts)
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
173 for dev in self._devs:
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
174 stmtsForDev = []
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
175 for pat in dev.outputPatterns():
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
176 if [term is None for term in pat] != [False, False, True]:
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
177 raise NotImplementedError
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
178 for stmt in stmts:
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
179 if stmt[:2] == pat[:2]:
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
180 stmtsForDev.append(stmt)
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
181 unused.discard(stmt)
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
182 if stmtsForDev:
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
183 log.info("output goes to action handler for %s" % dev.uri)
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
184 self.ser.write("\x60" + chr(self._devCommandNum[dev.uri]))
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
185 dev.sendOutput(stmtsForDev, self.ser.write, self.ser.read)
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
186 if self.ser.read(1) != 'k':
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
187 raise ValueError(
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
188 "%s sendOutput/generateActionCode didn't use "
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
189 "matching output bytes" % dev.__class__)
230
0aa54404df19 update arduinoNode to support streamed graph output
drewp@bigasterisk.com
parents: 229
diff changeset
190 # Dev *could* change hostStatements at any time, and
0aa54404df19 update arduinoNode to support streamed graph output
drewp@bigasterisk.com
parents: 229
diff changeset
191 # we're not currently tracking that, but the usual is
0aa54404df19 update arduinoNode to support streamed graph output
drewp@bigasterisk.com
parents: 229
diff changeset
192 # to change them in response to sendOutput so this
0aa54404df19 update arduinoNode to support streamed graph output
drewp@bigasterisk.com
parents: 229
diff changeset
193 # should be good enough. The right answer is to give
0aa54404df19 update arduinoNode to support streamed graph output
drewp@bigasterisk.com
parents: 229
diff changeset
194 # each dev the masterGraph for it to write to.
0aa54404df19 update arduinoNode to support streamed graph output
drewp@bigasterisk.com
parents: 229
diff changeset
195 self.syncMasterGraphToHostStatements(dev)
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
196 log.info("output and masterGraph sync complete")
169
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
197 if unused:
218
f8ffb9d8d982 multi-boards on one service, new devices, devices return their current
drewp@bigasterisk.com
parents: 214
diff changeset
198 log.info("Board %s doesn't care about these statements:", self.uri)
169
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
199 for s in unused:
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
200 log.warn("%r", s)
230
0aa54404df19 update arduinoNode to support streamed graph output
drewp@bigasterisk.com
parents: 229
diff changeset
201
0aa54404df19 update arduinoNode to support streamed graph output
drewp@bigasterisk.com
parents: 229
diff changeset
202 def syncMasterGraphToHostStatements(self, dev):
0aa54404df19 update arduinoNode to support streamed graph output
drewp@bigasterisk.com
parents: 229
diff changeset
203 hostStmtCtx = URIRef(dev.uri + '/host')
0aa54404df19 update arduinoNode to support streamed graph output
drewp@bigasterisk.com
parents: 229
diff changeset
204 newQuads = inContext(dev.hostStatements(), hostStmtCtx)
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
205 p = self.masterGraph.patchSubgraph(hostStmtCtx, newQuads)
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
206 log.debug("patch master with these host stmts %s", p)
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
207
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
208 def staticStmts(self):
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
209 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
210
164
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
211 def generateArduinoCode(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
212 code = write_arduino_code.writeCode(self.baudrate, self._devs,
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
213 self._devCommandNum)
229
07ee72a042db refactor to write_arduino_node
drewp@bigasterisk.com
parents: 222
diff changeset
214 code = write_arduino_code.indent(code)
169
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
215 cksum = hashlib.sha1(code).hexdigest()
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
216 code = code.replace('CODE_CHECKSUM', cksum)
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
217 return code, cksum
166
c0180bd2b33a only recompile if the C code is new. redo Device class api. single temperature sensor is working
drewp@bigasterisk.com
parents: 164
diff changeset
218
169
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
219 def _readBoardChecksum(self, length):
166
c0180bd2b33a only recompile if the C code is new. redo Device class api. single temperature sensor is working
drewp@bigasterisk.com
parents: 164
diff changeset
220 # this is likely right after reset, so it might take 2 seconds
c0180bd2b33a only recompile if the C code is new. redo Device class api. single temperature sensor is working
drewp@bigasterisk.com
parents: 164
diff changeset
221 for tries in range(6):
c0180bd2b33a only recompile if the C code is new. redo Device class api. single temperature sensor is working
drewp@bigasterisk.com
parents: 164
diff changeset
222 self.ser.write("\x60\x01")
c0180bd2b33a only recompile if the C code is new. redo Device class api. single temperature sensor is working
drewp@bigasterisk.com
parents: 164
diff changeset
223 try:
c0180bd2b33a only recompile if the C code is new. redo Device class api. single temperature sensor is working
drewp@bigasterisk.com
parents: 164
diff changeset
224 return self.ser.read(length)
c0180bd2b33a only recompile if the C code is new. redo Device class api. single temperature sensor is working
drewp@bigasterisk.com
parents: 164
diff changeset
225 except ValueError:
c0180bd2b33a only recompile if the C code is new. redo Device class api. single temperature sensor is working
drewp@bigasterisk.com
parents: 164
diff changeset
226 if tries == 5:
c0180bd2b33a only recompile if the C code is new. redo Device class api. single temperature sensor is working
drewp@bigasterisk.com
parents: 164
diff changeset
227 raise
c0180bd2b33a only recompile if the C code is new. redo Device class api. single temperature sensor is working
drewp@bigasterisk.com
parents: 164
diff changeset
228 time.sleep(.5)
c0180bd2b33a only recompile if the C code is new. redo Device class api. single temperature sensor is working
drewp@bigasterisk.com
parents: 164
diff changeset
229 raise ValueError
c0180bd2b33a only recompile if the C code is new. redo Device class api. single temperature sensor is working
drewp@bigasterisk.com
parents: 164
diff changeset
230
169
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
231 def _boardIsCurrent(self, currentChecksum):
166
c0180bd2b33a only recompile if the C code is new. redo Device class api. single temperature sensor is working
drewp@bigasterisk.com
parents: 164
diff changeset
232 try:
169
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
233 boardCksum = self._readBoardChecksum(len(currentChecksum))
166
c0180bd2b33a only recompile if the C code is new. redo Device class api. single temperature sensor is working
drewp@bigasterisk.com
parents: 164
diff changeset
234 if boardCksum == currentChecksum:
c0180bd2b33a only recompile if the C code is new. redo Device class api. single temperature sensor is working
drewp@bigasterisk.com
parents: 164
diff changeset
235 log.info("board has current code (%s)" % currentChecksum)
c0180bd2b33a only recompile if the C code is new. redo Device class api. single temperature sensor is working
drewp@bigasterisk.com
parents: 164
diff changeset
236 return True
c0180bd2b33a only recompile if the C code is new. redo Device class api. single temperature sensor is working
drewp@bigasterisk.com
parents: 164
diff changeset
237 else:
c0180bd2b33a only recompile if the C code is new. redo Device class api. single temperature sensor is working
drewp@bigasterisk.com
parents: 164
diff changeset
238 log.info("board responds with incorrect code version")
c0180bd2b33a only recompile if the C code is new. redo Device class api. single temperature sensor is working
drewp@bigasterisk.com
parents: 164
diff changeset
239 except Exception as e:
c0180bd2b33a only recompile if the C code is new. redo Device class api. single temperature sensor is working
drewp@bigasterisk.com
parents: 164
diff changeset
240 log.info("can't get code version from board: %r" % e)
c0180bd2b33a only recompile if the C code is new. redo Device class api. single temperature sensor is working
drewp@bigasterisk.com
parents: 164
diff changeset
241 return False
c0180bd2b33a only recompile if the C code is new. redo Device class api. single temperature sensor is working
drewp@bigasterisk.com
parents: 164
diff changeset
242
164
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
243 def deployToArduino(self):
169
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
244 code, cksum = self.generateArduinoCode()
166
c0180bd2b33a only recompile if the C code is new. redo Device class api. single temperature sensor is working
drewp@bigasterisk.com
parents: 164
diff changeset
245
169
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
246 if self._boardIsCurrent(cksum):
166
c0180bd2b33a only recompile if the C code is new. redo Device class api. single temperature sensor is working
drewp@bigasterisk.com
parents: 164
diff changeset
247 return
c0180bd2b33a only recompile if the C code is new. redo Device class api. single temperature sensor is working
drewp@bigasterisk.com
parents: 164
diff changeset
248
164
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
249 try:
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
250 if hasattr(self, 'ser'):
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
251 self.ser.close()
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
252 workDir = tempfile.mkdtemp(prefix='arduinoNode_board_deploy')
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
253 try:
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
254 self._arduinoMake(workDir, code)
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
255 finally:
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
256 shutil.rmtree(workDir)
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
257 finally:
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
258 self.open()
169
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
259
164
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
260 def _arduinoMake(self, workDir, code):
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
261 with open(workDir + '/makefile', 'w') as makefile:
229
07ee72a042db refactor to write_arduino_node
drewp@bigasterisk.com
parents: 222
diff changeset
262 makefile.write(write_arduino_code.writeMakefile(
07ee72a042db refactor to write_arduino_node
drewp@bigasterisk.com
parents: 222
diff changeset
263 dev=self.dev,
230
0aa54404df19 update arduinoNode to support streamed graph output
drewp@bigasterisk.com
parents: 229
diff changeset
264 tag=self.configGraph.value(self.uri, ROOM['boardTag']),
229
07ee72a042db refactor to write_arduino_node
drewp@bigasterisk.com
parents: 222
diff changeset
265 allLibs=sum((d.generateArduinoLibs() for d in self._devs), [])))
164
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
266
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
267 with open(workDir + '/main.ino', 'w') as main:
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
268 main.write(code)
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
269
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
270 subprocess.check_call(['make', 'upload'], cwd=workDir)
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
271
230
0aa54404df19 update arduinoNode to support streamed graph output
drewp@bigasterisk.com
parents: 229
diff changeset
272
0aa54404df19 update arduinoNode to support streamed graph output
drewp@bigasterisk.com
parents: 229
diff changeset
273 def currentGraph(self):
0aa54404df19 update arduinoNode to support streamed graph output
drewp@bigasterisk.com
parents: 229
diff changeset
274 g = Graph()
164
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
275
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
276
230
0aa54404df19 update arduinoNode to support streamed graph output
drewp@bigasterisk.com
parents: 229
diff changeset
277 for dev in self._devs:
0aa54404df19 update arduinoNode to support streamed graph output
drewp@bigasterisk.com
parents: 229
diff changeset
278 for stmt in dev.hostStatements():
164
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
279 g.add(stmt)
230
0aa54404df19 update arduinoNode to support streamed graph output
drewp@bigasterisk.com
parents: 229
diff changeset
280 return g
164
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
281
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
282 class Dot(cyclone.web.RequestHandler):
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
283 def get(self):
166
c0180bd2b33a only recompile if the C code is new. redo Device class api. single temperature sensor is working
drewp@bigasterisk.com
parents: 164
diff changeset
284 configGraph = self.settings.config.graph
c0180bd2b33a only recompile if the C code is new. redo Device class api. single temperature sensor is working
drewp@bigasterisk.com
parents: 164
diff changeset
285 dot = dotrender.render(configGraph, self.settings.boards)
164
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
286 self.write(dot)
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
287
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
288 class ArduinoCode(cyclone.web.RequestHandler):
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
289 def get(self):
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
290 board = [b for b in self.settings.boards if
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
291 b.uri == URIRef(self.get_argument('board'))][0]
218
f8ffb9d8d982 multi-boards on one service, new devices, devices return their current
drewp@bigasterisk.com
parents: 214
diff changeset
292 self.set_header('Content-Type', 'text/plain')
169
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
293 code, cksum = board.generateArduinoCode()
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
294 self.write(code)
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
295
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
296 def rdfGraphBody(body, headers):
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
297 g = Graph()
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
298 g.parse(StringInputSource(body), format='nt')
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
299 return g
176
f81c4d3d774b arduinoNode: use -v for logging; support a PUT with subj+pred in query, obj in body
drewp@bigasterisk.com
parents: 170
diff changeset
300
169
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
301 class OutputPage(cyclone.web.RequestHandler):
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
302 def post(self):
176
f81c4d3d774b arduinoNode: use -v for logging; support a PUT with subj+pred in query, obj in body
drewp@bigasterisk.com
parents: 170
diff changeset
303 # for old ui; use PUT instead
169
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
304 stmts = list(rdfGraphBody(self.request.body, self.request.headers))
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
305 for b in self.settings.boards:
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
306 b.outputStatements(stmts)
176
f81c4d3d774b arduinoNode: use -v for logging; support a PUT with subj+pred in query, obj in body
drewp@bigasterisk.com
parents: 170
diff changeset
307
f81c4d3d774b arduinoNode: use -v for logging; support a PUT with subj+pred in query, obj in body
drewp@bigasterisk.com
parents: 170
diff changeset
308 def put(self):
f81c4d3d774b arduinoNode: use -v for logging; support a PUT with subj+pred in query, obj in body
drewp@bigasterisk.com
parents: 170
diff changeset
309 subj = URIRef(self.get_argument('s'))
f81c4d3d774b arduinoNode: use -v for logging; support a PUT with subj+pred in query, obj in body
drewp@bigasterisk.com
parents: 170
diff changeset
310 pred = URIRef(self.get_argument('p'))
170
376599552a4c polymer board debug page with working output widgets
drewp@bigasterisk.com
parents: 169
diff changeset
311
176
f81c4d3d774b arduinoNode: use -v for logging; support a PUT with subj+pred in query, obj in body
drewp@bigasterisk.com
parents: 170
diff changeset
312 turtleLiteral = self.request.body
f81c4d3d774b arduinoNode: use -v for logging; support a PUT with subj+pred in query, obj in body
drewp@bigasterisk.com
parents: 170
diff changeset
313 try:
f81c4d3d774b arduinoNode: use -v for logging; support a PUT with subj+pred in query, obj in body
drewp@bigasterisk.com
parents: 170
diff changeset
314 obj = Literal(float(turtleLiteral))
185
2161c71c7b02 support for device code in the idle loop
drewp@bigasterisk.com
parents: 176
diff changeset
315 except ValueError:
176
f81c4d3d774b arduinoNode: use -v for logging; support a PUT with subj+pred in query, obj in body
drewp@bigasterisk.com
parents: 170
diff changeset
316 obj = Literal(turtleLiteral)
f81c4d3d774b arduinoNode: use -v for logging; support a PUT with subj+pred in query, obj in body
drewp@bigasterisk.com
parents: 170
diff changeset
317
f81c4d3d774b arduinoNode: use -v for logging; support a PUT with subj+pred in query, obj in body
drewp@bigasterisk.com
parents: 170
diff changeset
318 stmt = (subj, pred, obj)
f81c4d3d774b arduinoNode: use -v for logging; support a PUT with subj+pred in query, obj in body
drewp@bigasterisk.com
parents: 170
diff changeset
319 for b in self.settings.boards:
f81c4d3d774b arduinoNode: use -v for logging; support a PUT with subj+pred in query, obj in body
drewp@bigasterisk.com
parents: 170
diff changeset
320 b.outputStatements([stmt])
f81c4d3d774b arduinoNode: use -v for logging; support a PUT with subj+pred in query, obj in body
drewp@bigasterisk.com
parents: 170
diff changeset
321
f81c4d3d774b arduinoNode: use -v for logging; support a PUT with subj+pred in query, obj in body
drewp@bigasterisk.com
parents: 170
diff changeset
322
170
376599552a4c polymer board debug page with working output widgets
drewp@bigasterisk.com
parents: 169
diff changeset
323 class Boards(cyclone.web.RequestHandler):
376599552a4c polymer board debug page with working output widgets
drewp@bigasterisk.com
parents: 169
diff changeset
324 def get(self):
376599552a4c polymer board debug page with working output widgets
drewp@bigasterisk.com
parents: 169
diff changeset
325 self.set_header('Content-type', 'application/json')
376599552a4c polymer board debug page with working output widgets
drewp@bigasterisk.com
parents: 169
diff changeset
326 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
327 'host': hostname,
170
376599552a4c polymer board debug page with working output widgets
drewp@bigasterisk.com
parents: 169
diff changeset
328 'boards': [b.description() for b in self.settings.boards]
376599552a4c polymer board debug page with working output widgets
drewp@bigasterisk.com
parents: 169
diff changeset
329 }, indent=2))
376599552a4c polymer board debug page with working output widgets
drewp@bigasterisk.com
parents: 169
diff changeset
330
164
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
331 def currentSerialDevices():
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
332 log.info('find connected boards')
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
333 return glob.glob('/dev/serial/by-id/*')
230
0aa54404df19 update arduinoNode to support streamed graph output
drewp@bigasterisk.com
parents: 229
diff changeset
334
164
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
335 def main():
176
f81c4d3d774b arduinoNode: use -v for logging; support a PUT with subj+pred in query, obj in body
drewp@bigasterisk.com
parents: 170
diff changeset
336 arg = docopt("""
218
f8ffb9d8d982 multi-boards on one service, new devices, devices return their current
drewp@bigasterisk.com
parents: 214
diff changeset
337 Usage: arduinoNode.py [options]
176
f81c4d3d774b arduinoNode: use -v for logging; support a PUT with subj+pred in query, obj in body
drewp@bigasterisk.com
parents: 170
diff changeset
338
f81c4d3d774b arduinoNode: use -v for logging; support a PUT with subj+pred in query, obj in body
drewp@bigasterisk.com
parents: 170
diff changeset
339 -v Verbose
f81c4d3d774b arduinoNode: use -v for logging; support a PUT with subj+pred in query, obj in body
drewp@bigasterisk.com
parents: 170
diff changeset
340 """)
f81c4d3d774b arduinoNode: use -v for logging; support a PUT with subj+pred in query, obj in body
drewp@bigasterisk.com
parents: 170
diff changeset
341 log.setLevel(logging.WARN)
f81c4d3d774b arduinoNode: use -v for logging; support a PUT with subj+pred in query, obj in body
drewp@bigasterisk.com
parents: 170
diff changeset
342 if arg['-v']:
f81c4d3d774b arduinoNode: use -v for logging; support a PUT with subj+pred in query, obj in body
drewp@bigasterisk.com
parents: 170
diff changeset
343 from twisted.python import log as twlog
f81c4d3d774b arduinoNode: use -v for logging; support a PUT with subj+pred in query, obj in body
drewp@bigasterisk.com
parents: 170
diff changeset
344 twlog.startLogging(sys.stdout)
f81c4d3d774b arduinoNode: use -v for logging; support a PUT with subj+pred in query, obj in body
drewp@bigasterisk.com
parents: 170
diff changeset
345
f81c4d3d774b arduinoNode: use -v for logging; support a PUT with subj+pred in query, obj in body
drewp@bigasterisk.com
parents: 170
diff changeset
346 log.setLevel(logging.DEBUG)
230
0aa54404df19 update arduinoNode to support streamed graph output
drewp@bigasterisk.com
parents: 229
diff changeset
347
0aa54404df19 update arduinoNode to support streamed graph output
drewp@bigasterisk.com
parents: 229
diff changeset
348 masterGraph = PatchableGraph()
0aa54404df19 update arduinoNode to support streamed graph output
drewp@bigasterisk.com
parents: 229
diff changeset
349 config = Config(masterGraph)
164
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
350 current = currentSerialDevices()
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
351
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
352 boards = []
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
353 for dev, board in config.serialDevices().items():
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
354 if str(dev) not in current:
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
355 continue
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
356 log.info("we have board %s connected at %s" % (board, dev))
230
0aa54404df19 update arduinoNode to support streamed graph output
drewp@bigasterisk.com
parents: 229
diff changeset
357 b = Board(dev, config.graph, masterGraph, board)
164
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
358 boards.append(b)
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
359
218
f8ffb9d8d982 multi-boards on one service, new devices, devices return their current
drewp@bigasterisk.com
parents: 214
diff changeset
360 for b in boards:
f8ffb9d8d982 multi-boards on one service, new devices, devices return their current
drewp@bigasterisk.com
parents: 214
diff changeset
361 b.deployToArduino()
164
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
362
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
363 log.info('open boards')
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
364 for b in boards:
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
365 b.startPolling()
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
366
190
ad20e5cb4feb serve ipv6 and use localhost's ipv6 name for getting updates
drewp@bigasterisk.com
parents: 185
diff changeset
367
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
368 reactor.listenTCP(9059, cyclone.web.Application([
170
376599552a4c polymer board debug page with working output widgets
drewp@bigasterisk.com
parents: 169
diff changeset
369 (r"/()", cyclone.web.StaticFileHandler, {
376599552a4c polymer board debug page with working output widgets
drewp@bigasterisk.com
parents: 169
diff changeset
370 "path": "static", "default_filename": "index.html"}),
376599552a4c polymer board debug page with working output widgets
drewp@bigasterisk.com
parents: 169
diff changeset
371 (r'/static/(.*)', cyclone.web.StaticFileHandler, {"path": "static"}),
376599552a4c polymer board debug page with working output widgets
drewp@bigasterisk.com
parents: 169
diff changeset
372 (r'/boards', Boards),
230
0aa54404df19 update arduinoNode to support streamed graph output
drewp@bigasterisk.com
parents: 229
diff changeset
373 (r"/graph", CycloneGraphHandler, {'masterGraph': masterGraph}),
0aa54404df19 update arduinoNode to support streamed graph output
drewp@bigasterisk.com
parents: 229
diff changeset
374 (r"/graph/events", CycloneGraphEventsHandler, {'masterGraph': masterGraph}),
169
d228105749ac new /output to post statements which devices can handle. led and lcd output working
drewp@bigasterisk.com
parents: 166
diff changeset
375 (r'/output', OutputPage),
164
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
376 (r'/arduinoCode', ArduinoCode),
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
377 (r'/dot', Dot),
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
378 ], config=config, boards=boards), interface='::')
164
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
379 reactor.run()
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
380
49c1756b2edb start arduinonode
drewp@bigasterisk.com
parents:
diff changeset
381 main()