homeauto: service/arduinoNode/arduinoNode.py annotate

annotate service/arduinoNode/arduinoNode.py @ 428:d6a6076fce6e

use :connectedToNetwork on index table Ignore-this: c48bd43f2b18291ec1df2b70591a74d8

author	drewp@bigasterisk.com
date	Thu, 04 Apr 2019 02:22:04 -0700
parents	13b2a61650c1
children	12f9f1838fb5

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

Mercurial > code > home > repos > homeauto

annotate service/arduinoNode/arduinoNode.py @ 428:d6a6076fce6e