homeauto: service/arduinoNode/arduinoNode.py annotate

annotate service/arduinoNode/arduinoNode.py @ 1018:651e5c5b1f3d

write some values to carbon/graphite upon polling Ignore-this: 7f4f05ad994a8c18c61df2da421e0308 darcs-hash:0c36784979aa717161b954a9abddc77aa28434d4

author	drewp <drewp@bigasterisk.com>
date	Sun, 03 Jan 2016 02:24:27 -0800
parents	b24885725f59
children	254d656af72e

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
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	11 from rdflib import Graph, Namespace, URIRef, Literal, RDF
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
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	17 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	18 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	19 rdflib_patch.fixQnameOfUriWithTrailingSlash()
969 70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	20
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	21 logging.basicConfig(level=logging.DEBUG)
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	22
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	23 from loggingserial import LoggingSerial
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	24
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	25 sys.path.append("/my/site/magma")
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	26 from stategraph import StateGraph
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	27
1018 651e5c5b1f3d write some values to carbon/graphite upon polling drewp <drewp@bigasterisk.com> parents: 997 diff changeset	28 sys.path.append("/my/proj/room")
651e5c5b1f3d write some values to carbon/graphite upon polling drewp <drewp@bigasterisk.com> parents: 997 diff changeset	29 from carbondata import CarbonClient
651e5c5b1f3d write some values to carbon/graphite upon polling drewp <drewp@bigasterisk.com> parents: 997 diff changeset	30
969 70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	31 log = logging.getLogger()
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	32 logging.getLogger('serial').setLevel(logging.WARN)
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	33
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	34 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	35 HOST = Namespace('http://bigasterisk.com/ruler/host/')
969 70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	36
974 f707210c13bd new /output to post statements which devices can handle. led and lcd output working drewp <drewp@bigasterisk.com> parents: 971 diff changeset	37 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	38
969 70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	39 class Config(object):
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	40 def __init__(self):
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	41 self.graph = Graph()
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	42 log.info('read config')
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	43 self.graph.parse('config.n3', format='n3')
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	44 self.graph.bind('', ROOM) # not working
969 70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	45 self.graph.bind('rdf', RDF)
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	46
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	47 def serialDevices(self):
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	48 return dict([(row.dev, row.board) for row in self.graph.query(
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	49 """SELECT ?board ?dev WHERE {
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	50 ?board :device ?dev;
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	51 a :ArduinoBoard .
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	52 }""", 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	53
969 70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	54 class Board(object):
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	55 """an arduino connected to this computer"""
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	56 baudrate = 115200
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	57 def __init__(self, dev, graph, uri, onChange):
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	58 """
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	59 each connected thing has some pins.
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	60
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	61 We'll call onChange when we know the currentGraph() has
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	62 changed (and not just in creation time).
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	63 """
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	64 self.uri = uri
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	65 self.graph = graph
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	66 self.dev = dev
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	67
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	68 # The order of this list needs to be consistent between the
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	69 # deployToArduino call and the poll call.
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	70 self._devs = devices.makeDevices(graph, 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	71 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	72 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	73 self._polledDevs = [d for d in self._devs if d.generatePollCode()]
969 70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	74
990 11fff6301027 support for device code in the idle loop drewp <drewp@bigasterisk.com> parents: 981 diff changeset	75 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	76 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	77 self.open()
969 70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	78
975 f3023410d875 polymer board debug page with working output widgets drewp <drewp@bigasterisk.com> parents: 974 diff changeset	79 def description(self):
f3023410d875 polymer board debug page with working output widgets drewp <drewp@bigasterisk.com> parents: 974 diff changeset	80 """for web page"""
f3023410d875 polymer board debug page with working output widgets drewp <drewp@bigasterisk.com> parents: 974 diff changeset	81 return {
f3023410d875 polymer board debug page with working output widgets drewp <drewp@bigasterisk.com> parents: 974 diff changeset	82 'uri': self.uri,
f3023410d875 polymer board debug page with working output widgets drewp <drewp@bigasterisk.com> parents: 974 diff changeset	83 'dev': self.dev,
f3023410d875 polymer board debug page with working output widgets drewp <drewp@bigasterisk.com> parents: 974 diff changeset	84 'baudrate': self.baudrate,
f3023410d875 polymer board debug page with working output widgets drewp <drewp@bigasterisk.com> parents: 974 diff changeset	85 '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	86 '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	87 }
f3023410d875 polymer board debug page with working output widgets drewp <drewp@bigasterisk.com> parents: 974 diff changeset	88
969 70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	89 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	90 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	91 timeout=2)
969 70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	92
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	93 def startPolling(self):
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	94 task.LoopingCall(self._poll).start(.5)
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	95
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	96 def _poll(self):
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	97 """
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	98 even boards with no inputs need some polling to see if they're
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	99 still ok
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	100 """
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	101 try:
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	102 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	103 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	104 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	105 raise
969 70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	106 except Exception as e:
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	107 log.warn("poll: %r" % e)
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	108
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	109 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	110 t1 = time.time()
969 70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	111 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	112 for i in self._polledDevs:
969 70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	113 self._statementsFromInputs[i.uri] = i.readFromPoll(self.ser.read)
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	114 #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	115 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	116 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	117 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	118 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	119 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	120 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	121 self._exportToGraphite()
651e5c5b1f3d write some values to carbon/graphite upon polling drewp <drewp@bigasterisk.com> parents: 997 diff changeset	122
651e5c5b1f3d write some values to carbon/graphite upon polling drewp <drewp@bigasterisk.com> parents: 997 diff changeset	123 def _exportToGraphite(self):
651e5c5b1f3d write some values to carbon/graphite upon polling drewp <drewp@bigasterisk.com> parents: 997 diff changeset	124 # 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	125 now = time.time()
651e5c5b1f3d write some values to carbon/graphite upon polling drewp <drewp@bigasterisk.com> parents: 997 diff changeset	126 # 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	127 graphitePredicates = {ROOM['temperatureF']}
651e5c5b1f3d write some values to carbon/graphite upon polling drewp <drewp@bigasterisk.com> parents: 997 diff changeset	128 for s, graphiteName in self.graph.subject_objects(ROOM['graphiteName']):
651e5c5b1f3d write some values to carbon/graphite upon polling drewp <drewp@bigasterisk.com> parents: 997 diff changeset	129 for group in self._statementsFromInputs.values():
651e5c5b1f3d write some values to carbon/graphite upon polling drewp <drewp@bigasterisk.com> parents: 997 diff changeset	130 for stmt in group:
651e5c5b1f3d write some values to carbon/graphite upon polling drewp <drewp@bigasterisk.com> parents: 997 diff changeset	131 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	132 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	133
969 70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	134
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	135 def currentGraph(self):
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	136 g = Graph()
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	137
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	138 g.add((HOST[socket.gethostname()], ROOM['connectedTo'], self.uri))
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	139
969 70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	140 for si in self._statementsFromInputs.values():
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	141 for s in si:
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	142 g.add(s)
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	143 return g
974 f707210c13bd new /output to post statements which devices can handle. led and lcd output working drewp <drewp@bigasterisk.com> parents: 971 diff changeset	144
f707210c13bd new /output to post statements which devices can handle. led and lcd output working drewp <drewp@bigasterisk.com> parents: 971 diff changeset	145 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	146 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	147 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	148 stmtsForDev = []
f707210c13bd new /output to post statements which devices can handle. led and lcd output working drewp <drewp@bigasterisk.com> parents: 971 diff changeset	149 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	150 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	151 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	152 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	153 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	154 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	155 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	156 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	157 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	158 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	159 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	160 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	161 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	162 "%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	163 "matching output bytes" % dev.__class__)
f707210c13bd new /output to post statements which devices can handle. led and lcd output working drewp <drewp@bigasterisk.com> parents: 971 diff changeset	164 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	165 if unused:
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.warn("No devices cared about these statements:")
f707210c13bd new /output to post statements which devices can handle. led and lcd output working drewp <drewp@bigasterisk.com> parents: 971 diff changeset	167 for s in unused:
f707210c13bd new /output to post statements which devices can handle. led and lcd output working drewp <drewp@bigasterisk.com> parents: 971 diff changeset	168 log.warn(repr(s))
f707210c13bd new /output to post statements which devices can handle. led and lcd output working drewp <drewp@bigasterisk.com> parents: 971 diff changeset	169
969 70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	170 def generateArduinoCode(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	171 generated = {
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	172 '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	173 'includes': '',
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	174 'global': '',
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	175 'setups': '',
974 f707210c13bd new /output to post statements which devices can handle. led and lcd output working drewp <drewp@bigasterisk.com> parents: 971 diff changeset	176 'polls': '',
990 11fff6301027 support for device code in the idle loop drewp <drewp@bigasterisk.com> parents: 981 diff changeset	177 'idles': '',
974 f707210c13bd new /output to post statements which devices can handle. led and lcd output working drewp <drewp@bigasterisk.com> parents: 971 diff changeset	178 'actions': '',
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	179 }
990 11fff6301027 support for device code in the idle loop drewp <drewp@bigasterisk.com> parents: 981 diff changeset	180 for attr in ['includes', 'global', 'setups', 'polls', 'idles',
11fff6301027 support for device code in the idle loop drewp <drewp@bigasterisk.com> parents: 981 diff changeset	181 'actions']:
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 dev in 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	183 if attr == 'includes':
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	184 gen = '\n'.join('#include "%s"\n' % inc
974 f707210c13bd new /output to post statements which devices can handle. led and lcd output working drewp <drewp@bigasterisk.com> parents: 971 diff changeset	185 for inc in dev.generateIncludes())
f707210c13bd new /output to post statements which devices can handle. led and lcd output working drewp <drewp@bigasterisk.com> parents: 971 diff changeset	186 elif attr == 'global': gen = dev.generateGlobalCode()
f707210c13bd new /output to post statements which devices can handle. led and lcd output working drewp <drewp@bigasterisk.com> parents: 971 diff changeset	187 elif attr == 'setups': gen = dev.generateSetupCode()
f707210c13bd new /output to post statements which devices can handle. led and lcd output working drewp <drewp@bigasterisk.com> parents: 971 diff changeset	188 elif attr == 'polls': gen = dev.generatePollCode()
990 11fff6301027 support for device code in the idle loop drewp <drewp@bigasterisk.com> parents: 981 diff changeset	189 elif attr == 'idles': gen = dev.generateIdleCode()
974 f707210c13bd new /output to post statements which devices can handle. led and lcd output working drewp <drewp@bigasterisk.com> parents: 971 diff changeset	190 elif attr == 'actions':
f707210c13bd new /output to post statements which devices can handle. led and lcd output working drewp <drewp@bigasterisk.com> parents: 971 diff changeset	191 code = dev.generateActionCode()
f707210c13bd new /output to post statements which devices can handle. led and lcd output working drewp <drewp@bigasterisk.com> parents: 971 diff changeset	192 if code:
f707210c13bd new /output to post statements which devices can handle. led and lcd output working drewp <drewp@bigasterisk.com> parents: 971 diff changeset	193 gen = '''else if (cmd == %(cmdNum)s) {
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)s
f707210c13bd new /output to post statements which devices can handle. led and lcd output working drewp <drewp@bigasterisk.com> parents: 971 diff changeset	195 Serial.write('k');
f707210c13bd new /output to post statements which devices can handle. led and lcd output working drewp <drewp@bigasterisk.com> parents: 971 diff changeset	196 }
f707210c13bd new /output to post statements which devices can handle. led and lcd output working drewp <drewp@bigasterisk.com> parents: 971 diff changeset	197 ''' % dict(cmdNum=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	198 code=code)
f707210c13bd new /output to post statements which devices can handle. led and lcd output working drewp <drewp@bigasterisk.com> parents: 971 diff changeset	199 else:
f707210c13bd new /output to post statements which devices can handle. led and lcd output working drewp <drewp@bigasterisk.com> parents: 971 diff changeset	200 gen = ''
f707210c13bd new /output to post statements which devices can handle. led and lcd output working drewp <drewp@bigasterisk.com> parents: 971 diff changeset	201 else:
f707210c13bd new /output to post statements which devices can handle. led and lcd output working drewp <drewp@bigasterisk.com> parents: 971 diff changeset	202 raise NotImplementedError
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	203
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 gen:
997 b24885725f59 support for pwm board drewp <drewp@bigasterisk.com> parents: 995 diff changeset	205 generated[attr] += '// for %s\n%s\n' % (dev.uri, gen.strip())
969 70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	206
974 f707210c13bd new /output to post statements which devices can handle. led and lcd output working drewp <drewp@bigasterisk.com> parents: 971 diff changeset	207 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	208 %(includes)s
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	209
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 %(global)s
990 11fff6301027 support for device code in the idle loop drewp <drewp@bigasterisk.com> parents: 981 diff changeset	211 byte frame=0;
11fff6301027 support for device code in the idle loop drewp <drewp@bigasterisk.com> parents: 981 diff changeset	212 unsigned long lastFrame=0;
11fff6301027 support for device code in the idle loop drewp <drewp@bigasterisk.com> parents: 981 diff changeset	213
969 70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	214 void setup() {
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	215 Serial.begin(%(baudrate)d);
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	216 Serial.flush();
974 f707210c13bd new /output to post statements which devices can handle. led and lcd output working drewp <drewp@bigasterisk.com> parents: 971 diff changeset	217 %(setups)s
969 70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	218 }
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	219
990 11fff6301027 support for device code in the idle loop drewp <drewp@bigasterisk.com> parents: 981 diff changeset	220 void idle() {
11fff6301027 support for device code in the idle loop drewp <drewp@bigasterisk.com> parents: 981 diff changeset	221 // this slowdown is to spend somewhat less time PWMing, to reduce
11fff6301027 support for device code in the idle loop drewp <drewp@bigasterisk.com> parents: 981 diff changeset	222 // leaking from on channels to off ones (my shift register has no
11fff6301027 support for device code in the idle loop drewp <drewp@bigasterisk.com> parents: 981 diff changeset	223 // latching)
997 b24885725f59 support for pwm board drewp <drewp@bigasterisk.com> parents: 995 diff changeset	224 if (micros() < lastFrame + 80) {
990 11fff6301027 support for device code in the idle loop drewp <drewp@bigasterisk.com> parents: 981 diff changeset	225 return;
11fff6301027 support for device code in the idle loop drewp <drewp@bigasterisk.com> parents: 981 diff changeset	226 }
11fff6301027 support for device code in the idle loop drewp <drewp@bigasterisk.com> parents: 981 diff changeset	227 lastFrame = micros();
11fff6301027 support for device code in the idle loop drewp <drewp@bigasterisk.com> parents: 981 diff changeset	228 frame++;
11fff6301027 support for device code in the idle loop drewp <drewp@bigasterisk.com> parents: 981 diff changeset	229 %(idles)s
11fff6301027 support for device code in the idle loop drewp <drewp@bigasterisk.com> parents: 981 diff changeset	230 }
11fff6301027 support for device code in the idle loop drewp <drewp@bigasterisk.com> parents: 981 diff changeset	231
969 70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	232 void loop() {
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	233 byte head, cmd;
990 11fff6301027 support for device code in the idle loop drewp <drewp@bigasterisk.com> parents: 981 diff changeset	234 idle();
969 70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	235 if (Serial.available() >= 2) {
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	236 head = Serial.read();
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	237 if (head != 0x60) {
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	238 Serial.flush();
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	239 return;
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	240 }
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	241 cmd = Serial.read();
974 f707210c13bd new /output to post statements which devices can handle. led and lcd output working drewp <drewp@bigasterisk.com> parents: 971 diff changeset	242 if (cmd == 0x00) { // poll
f707210c13bd new /output to post statements which devices can handle. led and lcd output working drewp <drewp@bigasterisk.com> parents: 971 diff changeset	243 %(polls)s
f707210c13bd new /output to post statements which devices can handle. led and lcd output working drewp <drewp@bigasterisk.com> parents: 971 diff changeset	244 Serial.write('x');
f707210c13bd new /output to post statements which devices can handle. led and lcd output working drewp <drewp@bigasterisk.com> parents: 971 diff changeset	245 } else if (cmd == 0x01) { // get code checksum
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	246 Serial.write("CODE_CHECKSUM");
969 70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	247 }
974 f707210c13bd new /output to post statements which devices can handle. led and lcd output working drewp <drewp@bigasterisk.com> parents: 971 diff changeset	248 %(actions)s
969 70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	249 }
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	250 }
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	251 ''' % generated
974 f707210c13bd new /output to post statements which devices can handle. led and lcd output working drewp <drewp@bigasterisk.com> parents: 971 diff changeset	252 try:
f707210c13bd new /output to post statements which devices can handle. led and lcd output working drewp <drewp@bigasterisk.com> parents: 971 diff changeset	253 with tempfile.SpooledTemporaryFile() as codeFile:
f707210c13bd new /output to post statements which devices can handle. led and lcd output working drewp <drewp@bigasterisk.com> parents: 971 diff changeset	254 codeFile.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	255 codeFile.seek(0)
f707210c13bd new /output to post statements which devices can handle. led and lcd output working drewp <drewp@bigasterisk.com> parents: 971 diff changeset	256 code = subprocess.check_output([
f707210c13bd new /output to post statements which devices can handle. led and lcd output working drewp <drewp@bigasterisk.com> parents: 971 diff changeset	257 'indent',
f707210c13bd new /output to post statements which devices can handle. led and lcd output working drewp <drewp@bigasterisk.com> parents: 971 diff changeset	258 '-linux',
f707210c13bd new /output to post statements which devices can handle. led and lcd output working drewp <drewp@bigasterisk.com> parents: 971 diff changeset	259 '-fc1', # ok to indent comments
f707210c13bd new /output to post statements which devices can handle. led and lcd output working drewp <drewp@bigasterisk.com> parents: 971 diff changeset	260 '-i4', # 4-space indent
f707210c13bd new /output to post statements which devices can handle. led and lcd output working drewp <drewp@bigasterisk.com> parents: 971 diff changeset	261 '-sob' # swallow blanks (not working)
f707210c13bd new /output to post statements which devices can handle. led and lcd output working drewp <drewp@bigasterisk.com> parents: 971 diff changeset	262 ], stdin=codeFile)
f707210c13bd new /output to post statements which devices can handle. led and lcd output working drewp <drewp@bigasterisk.com> parents: 971 diff changeset	263 except OSError as e:
f707210c13bd new /output to post statements which devices can handle. led and lcd output working drewp <drewp@bigasterisk.com> parents: 971 diff changeset	264 log.warn("indent failed (%r)", e)
f707210c13bd new /output to post statements which devices can handle. led and lcd output working drewp <drewp@bigasterisk.com> parents: 971 diff changeset	265 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	266 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	267 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	268
974 f707210c13bd new /output to post statements which devices can handle. led and lcd output working drewp <drewp@bigasterisk.com> parents: 971 diff changeset	269 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	270 # 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	271 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	272 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	273 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	274 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	275 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	276 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	277 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	278 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	279 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	280
974 f707210c13bd new /output to post statements which devices can handle. led and lcd output working drewp <drewp@bigasterisk.com> parents: 971 diff changeset	281 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	282 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	283 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	284 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	285 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	286 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	287 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	288 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	289 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	290 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	291 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	292
969 70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	293 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	294 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	295
974 f707210c13bd new /output to post statements which devices can handle. led and lcd output working drewp <drewp@bigasterisk.com> parents: 971 diff changeset	296 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	297 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	298
969 70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	299 try:
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	300 if hasattr(self, 'ser'):
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	301 self.ser.close()
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	302 workDir = tempfile.mkdtemp(prefix='arduinoNode_board_deploy')
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	303 try:
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	304 self._arduinoMake(workDir, code)
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	305 finally:
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	306 shutil.rmtree(workDir)
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	307 finally:
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	308 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	309
969 70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	310 def _arduinoMake(self, workDir, code):
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	311 with open(workDir + '/makefile', 'w') as makefile:
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	312 makefile.write('''
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	313 BOARD_TAG = %(tag)s
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	314 USER_LIB_PATH := %(libs)s
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	315 ARDUINO_LIBS = %(arduinoLibs)s
969 70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	316 MONITOR_PORT = %(dev)s
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	317
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	318 include /usr/share/arduino/Arduino.mk
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	319 ''' % {
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	320 'dev': self.dev,
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	321 'tag': self.graph.value(self.uri, ROOM['boardTag']),
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	322 'libs': os.path.abspath('arduino-libraries'),
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	323 'arduinoLibs': ' '.join(sum((d.generateArduinoLibs()
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	324 for d in self._devs), [])),
969 70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	325 })
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	326
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	327 with open(workDir + '/main.ino', 'w') as main:
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	328 main.write(code)
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	329
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	330 subprocess.check_call(['make', 'upload'], cwd=workDir)
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	331
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	332
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	333 class GraphPage(cyclone.web.RequestHandler):
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	334 def get(self):
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	335 g = StateGraph(ctx=ROOM['arduinosOn%s' % 'host'])
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	336
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	337 for b in self.settings.boards:
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	338 for stmt in b.currentGraph():
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	339 g.add(stmt)
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	340
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	341 if self.get_argument('config', 'no') == 'yes':
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	342 for stmt in self.settings.config.graph:
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	343 g.add(stmt)
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	344
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	345 self.set_header('Content-type', 'application/x-trig')
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	346 self.write(g.asTrig())
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	347
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	348 class Dot(cyclone.web.RequestHandler):
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	349 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	350 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	351 dot = dotrender.render(configGraph, self.settings.boards)
969 70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	352 self.write(dot)
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	353
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	354 class ArduinoCode(cyclone.web.RequestHandler):
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	355 def get(self):
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	356 board = [b for b in self.settings.boards if
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	357 b.uri == URIRef(self.get_argument('board'))][0]
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	358 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	359 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	360 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	361
f707210c13bd new /output to post statements which devices can handle. led and lcd output working drewp <drewp@bigasterisk.com> parents: 971 diff changeset	362 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	363 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	364 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	365 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	366
974 f707210c13bd new /output to post statements which devices can handle. led and lcd output working drewp <drewp@bigasterisk.com> parents: 971 diff changeset	367 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	368 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	369 # 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	370 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	371 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	372 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	373
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	374 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	375 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	376 pred = URIRef(self.get_argument('p'))
975 f3023410d875 polymer board debug page with working output widgets drewp <drewp@bigasterisk.com> parents: 974 diff changeset	377
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	378 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	379 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	380 obj = Literal(float(turtleLiteral))
990 11fff6301027 support for device code in the idle loop drewp <drewp@bigasterisk.com> parents: 981 diff changeset	381 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	382 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	383
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	384 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	385 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	386 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	387
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	388
975 f3023410d875 polymer board debug page with working output widgets drewp <drewp@bigasterisk.com> parents: 974 diff changeset	389 class Boards(cyclone.web.RequestHandler):
f3023410d875 polymer board debug page with working output widgets drewp <drewp@bigasterisk.com> parents: 974 diff changeset	390 def get(self):
969 70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	391
975 f3023410d875 polymer board debug page with working output widgets drewp <drewp@bigasterisk.com> parents: 974 diff changeset	392 self.set_header('Content-type', 'application/json')
f3023410d875 polymer board debug page with working output widgets drewp <drewp@bigasterisk.com> parents: 974 diff changeset	393 self.write(json.dumps({
f3023410d875 polymer board debug page with working output widgets drewp <drewp@bigasterisk.com> parents: 974 diff changeset	394 '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	395 }, indent=2))
f3023410d875 polymer board debug page with working output widgets drewp <drewp@bigasterisk.com> parents: 974 diff changeset	396
969 70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	397 def currentSerialDevices():
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	398 log.info('find connected boards')
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	399 return glob.glob('/dev/serial/by-id/*')
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	400
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	401 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	402 arg = docopt("""
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	403 Usage: reasoning.py [options]
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	404
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	405 -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	406 """)
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	407 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	408 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	409 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	410 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	411
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	412 log.setLevel(logging.DEBUG)
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	413
969 70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	414 config = Config()
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	415 current = currentSerialDevices()
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	416
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	417 def onChange():
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	418 # notify reasoning
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	419 pass
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	420
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	421 boards = []
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	422 for dev, board in config.serialDevices().items():
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	423 if str(dev) not in current:
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	424 continue
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	425 log.info("we have board %s connected at %s" % (board, dev))
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	426 b = Board(dev, config.graph, board, onChange)
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	427 boards.append(b)
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	428
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	429 boards[0].deployToArduino()
969 70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	430
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	431 log.info('open boards')
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	432 for b in boards:
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	433 b.startPolling()
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	434
995 f72068e9d9d8 serve ipv6 and use localhost's ipv6 name for getting updates drewp <drewp@bigasterisk.com> parents: 990 diff changeset	435
f72068e9d9d8 serve ipv6 and use localhost's ipv6 name for getting updates drewp <drewp@bigasterisk.com> parents: 990 diff changeset	436 app = cyclone.web.Application([
975 f3023410d875 polymer board debug page with working output widgets drewp <drewp@bigasterisk.com> parents: 974 diff changeset	437 (r"/()", cyclone.web.StaticFileHandler, {
f3023410d875 polymer board debug page with working output widgets drewp <drewp@bigasterisk.com> parents: 974 diff changeset	438 "path": "static", "default_filename": "index.html"}),
f3023410d875 polymer board debug page with working output widgets drewp <drewp@bigasterisk.com> parents: 974 diff changeset	439 (r'/static/(.*)', cyclone.web.StaticFileHandler, {"path": "static"}),
f3023410d875 polymer board debug page with working output widgets drewp <drewp@bigasterisk.com> parents: 974 diff changeset	440 (r'/boards', Boards),
969 70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	441 (r"/graph", GraphPage),
974 f707210c13bd new /output to post statements which devices can handle. led and lcd output working drewp <drewp@bigasterisk.com> parents: 971 diff changeset	442 (r'/output', OutputPage),
969 70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	443 (r'/arduinoCode', ArduinoCode),
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	444 (r'/dot', Dot),
995 f72068e9d9d8 serve ipv6 and use localhost's ipv6 name for getting updates drewp <drewp@bigasterisk.com> parents: 990 diff changeset	445 ], config=config, boards=boards)
f72068e9d9d8 serve ipv6 and use localhost's ipv6 name for getting updates drewp <drewp@bigasterisk.com> parents: 990 diff changeset	446 reactor.listenTCP(9059, app, interface='::')
969 70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	447 reactor.run()
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	448
70a5392b24d3 start arduinonode drewp <drewp@bigasterisk.com> parents: diff changeset	449 main()

Mercurial > code > home > repos > homeauto

annotate service/arduinoNode/arduinoNode.py @ 1018:651e5c5b1f3d