Mercurial > code > home > repos > homeauto

annotate service/arduinoNode/arduinoNode.py @ 1035:f01d9892ed79

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