annotate service/arduinoNode/devices.py @ 1038:ffe6a00c6cef

server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code. Ignore-this: cf7d20d54e134e8ff33a9ee405610846 darcs-hash:b4350a6308480857b2846a8518190b956981eef4
author drewp <drewp@bigasterisk.com>
date Sat, 30 Jan 2016 06:40:00 -0800
parents f01d9892ed79
children 254df9f881a6
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
974
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
1 from __future__ import division
1023
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
2 import itertools, logging, struct, os
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
3 from rdflib import Namespace, RDF, URIRef, Literal
981
d9bbbd8d86f6 arduinoNode: use -v for logging; support a PUT with subj+pred in query, obj in body
drewp <drewp@bigasterisk.com>
parents: 977
diff changeset
4 import time
969
70a5392b24d3 start arduinonode
drewp <drewp@bigasterisk.com>
parents:
diff changeset
5
70a5392b24d3 start arduinonode
drewp <drewp@bigasterisk.com>
parents:
diff changeset
6 ROOM = Namespace('http://projects.bigasterisk.com/room/')
974
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
7 XSD = Namespace('http://www.w3.org/2001/XMLSchema#')
1023
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
8 log = logging.getLogger()
969
70a5392b24d3 start arduinonode
drewp <drewp@bigasterisk.com>
parents:
diff changeset
9
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
10 def readLine(read):
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
11 buf = ''
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
12 for c in iter(lambda: read(1), '\n'):
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
13 buf += c
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
14 return buf
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
15
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
16 class DeviceType(object):
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 deviceType = None
fbe72d44f15a only recompile if the C code is new. redo Device class api. single temperature sensor is working
drewp <drewp@bigasterisk.com>
parents: 969
diff changeset
18 @classmethod
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
19 def findInstances(cls, graph, board):
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
20 """
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
21 return any number of instances of this class for all the separately
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
22 controlled devices on the board. Two LEDS makes two instances,
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
23 but two sensors on the same onewire bus makes only one device
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
24 (which yields more statements).
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
25 """
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
26 for row in graph.query("""SELECT ?dev ?pinNumber WHERE {
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
27 ?board :hasPin ?pin .
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
28 ?pin :pinNumber ?pinNumber;
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
29 :connectedTo ?dev .
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
30 ?dev a ?thisType .
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
31 } ORDER BY ?dev""",
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
32 initBindings=dict(board=board,
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
33 thisType=cls.deviceType),
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
34 initNs={'': ROOM}):
1023
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
35 log.info('found %s, a %s', row.dev, cls.deviceType)
974
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
36 yield cls(graph, row.dev, int(row.pinNumber))
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
37
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
38 # subclasses may add args to this
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
39 def __init__(self, graph, uri, pinNumber):
969
70a5392b24d3 start arduinonode
drewp <drewp@bigasterisk.com>
parents:
diff changeset
40 self.graph, self.uri = graph, uri
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
41 self.pinNumber = pinNumber
1023
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
42 self.hostStateInit()
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
43
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
44 def hostStateInit(self):
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
45 """
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
46 If you don't want to use __init__, you can use this to set up
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
47 whatever storage you might need for hostStatements
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
48 """
975
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
49
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
50 def description(self):
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
51 return {
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
52 'uri': self.uri,
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
53 'className': self.__class__.__name__,
1038
ffe6a00c6cef server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp <drewp@bigasterisk.com>
parents: 1035
diff changeset
54 'pinNumber': getattr(self, 'pinNumber', None),
975
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
55 'outputPatterns': self.outputPatterns(),
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
56 'watchPrefixes': self.watchPrefixes(),
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
57 'outputWidgets': self.outputWidgets(),
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
58 }
969
70a5392b24d3 start arduinonode
drewp <drewp@bigasterisk.com>
parents:
diff changeset
59
70a5392b24d3 start arduinonode
drewp <drewp@bigasterisk.com>
parents:
diff changeset
60 def readFromPoll(self, read):
70a5392b24d3 start arduinonode
drewp <drewp@bigasterisk.com>
parents:
diff changeset
61 """
70a5392b24d3 start arduinonode
drewp <drewp@bigasterisk.com>
parents:
diff changeset
62 read an update message returned as part of a poll bundle. This may
70a5392b24d3 start arduinonode
drewp <drewp@bigasterisk.com>
parents:
diff changeset
63 consume a varying number of bytes depending on the type of
70a5392b24d3 start arduinonode
drewp <drewp@bigasterisk.com>
parents:
diff changeset
64 input (e.g. IR receiver).
70a5392b24d3 start arduinonode
drewp <drewp@bigasterisk.com>
parents:
diff changeset
65 Returns rdf statements.
70a5392b24d3 start arduinonode
drewp <drewp@bigasterisk.com>
parents:
diff changeset
66 """
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
67 raise NotImplementedError('readFromPoll in %s' % self.__class__)
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
68
1023
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
69 def hostStatements(self):
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
70 """
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
71 Like readFromPoll but these statements come from the host-side
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
72 python code, not the connected device. Include output state
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
73 (e.g. light brightness) if its master version is in this
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
74 object. This method is called on /graph requests so it should
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
75 be fast.
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
76 """
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
77 return []
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
78
975
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
79 def watchPrefixes(self):
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
80 """
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
81 subj,pred pairs of the statements that might be returned from
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
82 readFromPoll, so the dashboard knows what it should
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
83 watch. This should be eliminated, as the dashboard should just
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
84 always watch the whole tree of statements starting self.uri
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
85 """
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
86 return []
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
87
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
88 def generateIncludes(self):
975
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
89 """filenames of .h files to #include"""
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 return []
969
70a5392b24d3 start arduinonode
drewp <drewp@bigasterisk.com>
parents:
diff changeset
91
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
92 def generateArduinoLibs(self):
975
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
93 """names of libraries for the ARDUINO_LIBS line in the makefile"""
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
94 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
95
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
96 def generateGlobalCode(self):
990
11fff6301027 support for device code in the idle loop
drewp <drewp@bigasterisk.com>
parents: 981
diff changeset
97 """C code to emit in the global section.
11fff6301027 support for device code in the idle loop
drewp <drewp@bigasterisk.com>
parents: 981
diff changeset
98
11fff6301027 support for device code in the idle loop
drewp <drewp@bigasterisk.com>
parents: 981
diff changeset
99 Note that 'frame' (uint8) is available and increments each frame.
11fff6301027 support for device code in the idle loop
drewp <drewp@bigasterisk.com>
parents: 981
diff changeset
100 """
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
101 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
102
969
70a5392b24d3 start arduinonode
drewp <drewp@bigasterisk.com>
parents:
diff changeset
103 def generateSetupCode(self):
975
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
104 """C code to emit in setup()"""
969
70a5392b24d3 start arduinonode
drewp <drewp@bigasterisk.com>
parents:
diff changeset
105 return ''
70a5392b24d3 start arduinonode
drewp <drewp@bigasterisk.com>
parents:
diff changeset
106
990
11fff6301027 support for device code in the idle loop
drewp <drewp@bigasterisk.com>
parents: 981
diff changeset
107 def generateIdleCode(self):
11fff6301027 support for device code in the idle loop
drewp <drewp@bigasterisk.com>
parents: 981
diff changeset
108 """C code to emit in the serial-read loop"""
11fff6301027 support for device code in the idle loop
drewp <drewp@bigasterisk.com>
parents: 981
diff changeset
109 return ''
11fff6301027 support for device code in the idle loop
drewp <drewp@bigasterisk.com>
parents: 981
diff changeset
110
969
70a5392b24d3 start arduinonode
drewp <drewp@bigasterisk.com>
parents:
diff changeset
111 def generatePollCode(self):
975
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
112 """
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
113 C code to run a poll update. This should Serial.write its output
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
114 for readFromPoll to consume. If this returns nothing, we don't
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
115 try to poll this device.
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
116 """
969
70a5392b24d3 start arduinonode
drewp <drewp@bigasterisk.com>
parents:
diff changeset
117 return ''
70a5392b24d3 start arduinonode
drewp <drewp@bigasterisk.com>
parents:
diff changeset
118
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
119 def generateActionCode(self):
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
120 """
974
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
121 If the host side runs sendOutput, this C code will be run on the
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
122 board to receive whatever sendOutput writes. Each sendOutput
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
123 write(buf) call should be matched with len(buf) Serial.read()
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
124 calls in here.
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
125 """
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
126 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
127
974
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
128 def outputPatterns(self):
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
129 """
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
130 Triple patterns, using None as a wildcard, that should be routed
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
131 to sendOutput
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
132 """
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
133 return []
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
134
975
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
135 def outputWidgets(self):
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
136 """
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
137 structs to make output widgets on the dashboard. ~1 of these per
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
138 handler you have in sendOutput
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
139 """
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
140 return []
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
141
974
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
142 def sendOutput(self, statements, write, read):
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
143 """
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
144 If we got statements that match this class's outputPatterns, this
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
145 will be called with the statements that matched, and a serial
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
146 write method. What you write here will be available as
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
147 Serial.read in the generateActionCode C code.
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
148
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
149 Todo: it would be fine to read back confirmations or
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
150 whatever. Just need a way to collect them into graph statements.
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
151 """
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
152 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
153
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
154 _knownTypes = set()
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
155 def register(deviceType):
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
156 _knownTypes.add(deviceType)
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
157 return deviceType
969
70a5392b24d3 start arduinonode
drewp <drewp@bigasterisk.com>
parents:
diff changeset
158
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
159 @register
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
160 class PingInput(DeviceType):
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
161 @classmethod
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
162 def findInstances(cls, graph, board):
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
163 return [cls(graph, board, None)]
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
164
969
70a5392b24d3 start arduinonode
drewp <drewp@bigasterisk.com>
parents:
diff changeset
165 def generatePollCode(self):
70a5392b24d3 start arduinonode
drewp <drewp@bigasterisk.com>
parents:
diff changeset
166 return "Serial.write('k');"
975
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
167
969
70a5392b24d3 start arduinonode
drewp <drewp@bigasterisk.com>
parents:
diff changeset
168 def readFromPoll(self, read):
1023
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
169 byte = read(1)
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
170 if byte != 'k':
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
171 raise ValueError('invalid ping response: chr(%s)' % ord(byte))
969
70a5392b24d3 start arduinonode
drewp <drewp@bigasterisk.com>
parents:
diff changeset
172 return [(self.uri, ROOM['ping'], ROOM['ok'])]
70a5392b24d3 start arduinonode
drewp <drewp@bigasterisk.com>
parents:
diff changeset
173
975
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
174 def watchPrefixes(self):
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
175 return [(self.uri, ROOM['ping'])]
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
176
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
177 @register
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
178 class MotionSensorInput(DeviceType):
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 deviceType = ROOM['MotionSensor']
969
70a5392b24d3 start arduinonode
drewp <drewp@bigasterisk.com>
parents:
diff changeset
180 def generateSetupCode(self):
70a5392b24d3 start arduinonode
drewp <drewp@bigasterisk.com>
parents:
diff changeset
181 return 'pinMode(%(pin)d, INPUT); digitalWrite(%(pin)d, LOW);' % {
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 'pin': self.pinNumber,
969
70a5392b24d3 start arduinonode
drewp <drewp@bigasterisk.com>
parents:
diff changeset
183 }
70a5392b24d3 start arduinonode
drewp <drewp@bigasterisk.com>
parents:
diff changeset
184
70a5392b24d3 start arduinonode
drewp <drewp@bigasterisk.com>
parents:
diff changeset
185 def generatePollCode(self):
70a5392b24d3 start arduinonode
drewp <drewp@bigasterisk.com>
parents:
diff changeset
186 return "Serial.write(digitalRead(%(pin)d) ? 'y' : 'n');" % {
974
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
187 'pin': self.pinNumber
969
70a5392b24d3 start arduinonode
drewp <drewp@bigasterisk.com>
parents:
diff changeset
188 }
70a5392b24d3 start arduinonode
drewp <drewp@bigasterisk.com>
parents:
diff changeset
189
70a5392b24d3 start arduinonode
drewp <drewp@bigasterisk.com>
parents:
diff changeset
190 def readFromPoll(self, read):
70a5392b24d3 start arduinonode
drewp <drewp@bigasterisk.com>
parents:
diff changeset
191 b = read(1)
70a5392b24d3 start arduinonode
drewp <drewp@bigasterisk.com>
parents:
diff changeset
192 if b not in 'yn':
70a5392b24d3 start arduinonode
drewp <drewp@bigasterisk.com>
parents:
diff changeset
193 raise ValueError('unexpected response %r' % b)
70a5392b24d3 start arduinonode
drewp <drewp@bigasterisk.com>
parents:
diff changeset
194 motion = b == 'y'
981
d9bbbd8d86f6 arduinoNode: use -v for logging; support a PUT with subj+pred in query, obj in body
drewp <drewp@bigasterisk.com>
parents: 977
diff changeset
195
d9bbbd8d86f6 arduinoNode: use -v for logging; support a PUT with subj+pred in query, obj in body
drewp <drewp@bigasterisk.com>
parents: 977
diff changeset
196 return [
d9bbbd8d86f6 arduinoNode: use -v for logging; support a PUT with subj+pred in query, obj in body
drewp <drewp@bigasterisk.com>
parents: 977
diff changeset
197 (self.uri, ROOM['sees'],
d9bbbd8d86f6 arduinoNode: use -v for logging; support a PUT with subj+pred in query, obj in body
drewp <drewp@bigasterisk.com>
parents: 977
diff changeset
198 ROOM['motion'] if motion else ROOM['noMotion']),
d9bbbd8d86f6 arduinoNode: use -v for logging; support a PUT with subj+pred in query, obj in body
drewp <drewp@bigasterisk.com>
parents: 977
diff changeset
199 self.recentMotionStatement(motion),
d9bbbd8d86f6 arduinoNode: use -v for logging; support a PUT with subj+pred in query, obj in body
drewp <drewp@bigasterisk.com>
parents: 977
diff changeset
200 ]
969
70a5392b24d3 start arduinonode
drewp <drewp@bigasterisk.com>
parents:
diff changeset
201
981
d9bbbd8d86f6 arduinoNode: use -v for logging; support a PUT with subj+pred in query, obj in body
drewp <drewp@bigasterisk.com>
parents: 977
diff changeset
202 def recentMotionStatement(self, motion):
d9bbbd8d86f6 arduinoNode: use -v for logging; support a PUT with subj+pred in query, obj in body
drewp <drewp@bigasterisk.com>
parents: 977
diff changeset
203 if not hasattr(self, 'lastMotionTime'):
d9bbbd8d86f6 arduinoNode: use -v for logging; support a PUT with subj+pred in query, obj in body
drewp <drewp@bigasterisk.com>
parents: 977
diff changeset
204 self.lastMotionTime = 0
d9bbbd8d86f6 arduinoNode: use -v for logging; support a PUT with subj+pred in query, obj in body
drewp <drewp@bigasterisk.com>
parents: 977
diff changeset
205 now = time.time()
d9bbbd8d86f6 arduinoNode: use -v for logging; support a PUT with subj+pred in query, obj in body
drewp <drewp@bigasterisk.com>
parents: 977
diff changeset
206 if motion:
d9bbbd8d86f6 arduinoNode: use -v for logging; support a PUT with subj+pred in query, obj in body
drewp <drewp@bigasterisk.com>
parents: 977
diff changeset
207 self.lastMotionTime = now
d9bbbd8d86f6 arduinoNode: use -v for logging; support a PUT with subj+pred in query, obj in body
drewp <drewp@bigasterisk.com>
parents: 977
diff changeset
208 recentMotion = now - self.lastMotionTime < 60 * 10
d9bbbd8d86f6 arduinoNode: use -v for logging; support a PUT with subj+pred in query, obj in body
drewp <drewp@bigasterisk.com>
parents: 977
diff changeset
209 return (self.uri, ROOM['seesRecently'],
d9bbbd8d86f6 arduinoNode: use -v for logging; support a PUT with subj+pred in query, obj in body
drewp <drewp@bigasterisk.com>
parents: 977
diff changeset
210 ROOM['motion'] if recentMotion else ROOM['noMotion'])
d9bbbd8d86f6 arduinoNode: use -v for logging; support a PUT with subj+pred in query, obj in body
drewp <drewp@bigasterisk.com>
parents: 977
diff changeset
211
975
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
212 def watchPrefixes(self):
981
d9bbbd8d86f6 arduinoNode: use -v for logging; support a PUT with subj+pred in query, obj in body
drewp <drewp@bigasterisk.com>
parents: 977
diff changeset
213 return [
d9bbbd8d86f6 arduinoNode: use -v for logging; support a PUT with subj+pred in query, obj in body
drewp <drewp@bigasterisk.com>
parents: 977
diff changeset
214 (self.uri, ROOM['sees']),
d9bbbd8d86f6 arduinoNode: use -v for logging; support a PUT with subj+pred in query, obj in body
drewp <drewp@bigasterisk.com>
parents: 977
diff changeset
215 (self.uri, ROOM['seesRecently']),
d9bbbd8d86f6 arduinoNode: use -v for logging; support a PUT with subj+pred in query, obj in body
drewp <drewp@bigasterisk.com>
parents: 977
diff changeset
216 ]
975
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
217
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
218 @register
1023
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
219 class PushbuttonInput(DeviceType):
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
220 """add a switch to ground; we'll turn on pullup"""
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
221 deviceType = ROOM['Pushbutton']
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
222 def generateSetupCode(self):
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
223 return 'pinMode(%(pin)d, INPUT); digitalWrite(%(pin)d, HIGH);' % {
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
224 'pin': self.pinNumber,
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
225 }
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
226
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
227 def generatePollCode(self):
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
228 # note: pulldown means unpressed reads as a 1
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
229 return "Serial.write(digitalRead(%(pin)d) ? '0' : '1');" % {
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
230 'pin': self.pinNumber
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
231 }
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
232
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
233 def readFromPoll(self, read):
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
234 b = read(1)
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
235 if b not in '01':
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
236 raise ValueError('unexpected response %r' % b)
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
237 motion = b == '1'
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
238
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
239 #and exactly once for the transition
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
240 return [
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
241 (self.uri, ROOM['buttonState'],
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
242 ROOM['pressed'] if motion else ROOM['notPressed']),
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
243 ]
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
244
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
245 def watchPrefixes(self):
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
246 return [
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
247 (self.uri, ROOM['buttonState']),
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
248 ]
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
249
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
250 @register
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
251 class OneWire(DeviceType):
975
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
252 """
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
253 A OW bus with temperature sensors (and maybe other devices, which
1023
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
254 are also to be handled under this object). We return graph
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
255 statements for all devices we find, even if we don't scan them, so
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
256 you can more easily add them to your config. Onewire search
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
257 happens only at device startup (not even program startup, yet).
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
258
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
259 self.uri is a resource representing the bus.
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
260
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
261 DS18S20 pin 1: ground, pin 2: data and pull-up with 4.7k.
975
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
262 """
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
263 deviceType = ROOM['OneWire']
1023
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
264 def hostStateInit(self):
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
265 # eliminate this as part of removing watchPrefixes
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
266 self._knownTempSubjects = set()
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
267 def generateIncludes(self):
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 return ['OneWire.h', 'DallasTemperature.h']
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
269
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 def generateArduinoLibs(self):
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 return ['OneWire', 'DallasTemperature']
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
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 def generateGlobalCode(self):
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 # not yet isolated to support multiple OW buses
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 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
276 OneWire oneWire(%(pinNumber)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
277 DallasTemperature sensors(&oneWire);
1023
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
278 #define MAX_DEVICES 8
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
279 DeviceAddress tempSensorAddress[MAX_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
280
1023
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
281 void initSensors() {
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 sensors.begin();
1023
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
283 sensors.setResolution(12);
991
c6989dcf1f4f temp sensor try to work with idle loop (but there are still stutters)
drewp <drewp@bigasterisk.com>
parents: 990
diff changeset
284 sensors.setWaitForConversion(false);
1023
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
285 for (uint8_t i=0; i < sensors.getDeviceCount(); ++i) {
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
286 sensors.getAddress(tempSensorAddress[i], i);
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
287 }
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
288 }
974
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
289 ''' % dict(pinNumber=self.pinNumber)
991
c6989dcf1f4f temp sensor try to work with idle loop (but there are still stutters)
drewp <drewp@bigasterisk.com>
parents: 990
diff changeset
290
c6989dcf1f4f temp sensor try to work with idle loop (but there are still stutters)
drewp <drewp@bigasterisk.com>
parents: 990
diff changeset
291 def generateSetupCode(self):
c6989dcf1f4f temp sensor try to work with idle loop (but there are still stutters)
drewp <drewp@bigasterisk.com>
parents: 990
diff changeset
292 return 'initSensors();'
c6989dcf1f4f temp sensor try to work with idle loop (but there are still stutters)
drewp <drewp@bigasterisk.com>
parents: 990
diff changeset
293
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
294 def generatePollCode(self):
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 return r'''
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
296 sensors.requestTemperatures();
1023
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
297
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
298 // If we need frequent idle calls or fast polling again, this needs
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
299 // to be changed, but it makes temp sensing work. I had a note that I
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
300 // could just wait until the next cycle to get my reading, but that's
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
301 // not working today, maybe because of a changed poll rate.
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
302 sensors.setWaitForConversion(true); // ~100ms
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
303
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
304 Serial.write((uint8_t)sensors.getDeviceCount());
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
305 for (uint8_t i=0; i < sensors.getDeviceCount(); ++i) {
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
306 float newTemp = sensors.getTempF(tempSensorAddress[i]);
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
307
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
308 Serial.write(tempSensorAddress[i], 8);
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
309 Serial.write((uint8_t*)(&newTemp), 4);
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
310 }
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
311 '''
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
312
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
313 def readFromPoll(self, read):
1023
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
314 t1 = time.time()
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
315 count = ord(read(1))
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
316 stmts = []
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
317 for i in range(count):
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
318 addr = struct.unpack('>Q', read(8))[0]
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
319 tempF = struct.unpack('<f', read(4))[0]
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
320 sensorUri = URIRef(os.path.join(self.uri, 'dev-%s' % hex(addr)[2:]))
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
321 stmts.extend([
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
322 (self.uri, ROOM['connectedTo'], sensorUri),
1035
f01d9892ed79 update arduinoNode to support streamed graph output
drewp <drewp@bigasterisk.com>
parents: 1023
diff changeset
323 # rounding may be working around a bug where the
f01d9892ed79 update arduinoNode to support streamed graph output
drewp <drewp@bigasterisk.com>
parents: 1023
diff changeset
324 # Literal gets two representations (at different
f01d9892ed79 update arduinoNode to support streamed graph output
drewp <drewp@bigasterisk.com>
parents: 1023
diff changeset
325 # roundings), and this makes an extra value linger on
f01d9892ed79 update arduinoNode to support streamed graph output
drewp <drewp@bigasterisk.com>
parents: 1023
diff changeset
326 # the client.
f01d9892ed79 update arduinoNode to support streamed graph output
drewp <drewp@bigasterisk.com>
parents: 1023
diff changeset
327 (sensorUri, ROOM['temperatureF'], Literal(round(tempF, 2)))])
1023
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
328 self._knownTempSubjects.add(sensorUri)
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
329
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
330 log.debug("read temp in %.1fms" % ((time.time() - t1) * 1000))
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
331 return stmts
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
332
975
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
333 def watchPrefixes(self):
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
334 # these uris will become dynamic! see note on watchPrefixes
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
335 # about eliminating it.
1023
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
336 return [(uri, ROOM['temperatureF']) for uri in self._knownTempSubjects]
975
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
337
974
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
338 def byteFromFloat(f):
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
339 return chr(int(min(255, max(0, f * 255))))
997
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
340
974
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
341 @register
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
342 class LedOutput(DeviceType):
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
343 deviceType = ROOM['LedOutput']
1023
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
344 def hostStateInit(self):
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
345 self.value = 0
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
346
974
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
347 def generateSetupCode(self):
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
348 return 'pinMode(%(pin)d, OUTPUT); digitalWrite(%(pin)d, LOW);' % {
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
349 'pin': self.pinNumber,
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
350 }
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
351
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
352 def outputPatterns(self):
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
353 return [(self.uri, ROOM['brightness'], None)]
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
354
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
355 def sendOutput(self, statements, write, read):
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
356 assert len(statements) == 1
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
357 assert statements[0][:2] == (self.uri, ROOM['brightness'])
1023
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
358 self.value = float(statements[0][2])
977
03cfee8f9154 obey ActiveLowOutput correctly
drewp <drewp@bigasterisk.com>
parents: 975
diff changeset
359 if (self.uri, RDF.type, ROOM['ActiveLowOutput']) in self.graph:
1023
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
360 self.value = 1 - self.value
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
361 write(byteFromFloat(self.value))
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
362
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
363 def hostStatements(self):
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
364 return [(self.uri, ROOM['brightness'], Literal(self.value))]
974
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
365
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
366 def generateActionCode(self):
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
367 return r'''
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
368 while(Serial.available() < 1) NULL;
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
369 analogWrite(%(pin)d, Serial.read());
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
370 ''' % dict(pin=self.pinNumber)
975
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
371
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
372 def outputWidgets(self):
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
373 return [{
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
374 'element': 'output-slider',
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
375 'min': 0,
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
376 'max': 1,
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
377 'step': 1 / 255,
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
378 'subj': self.uri,
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
379 'pred': ROOM['brightness'],
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
380 }]
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
381
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
382 @register
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
383 class DigitalOutput(DeviceType):
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
384 deviceType = ROOM['DigitalOutput']
1023
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
385 def hostStateInit(self):
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
386 self.value = 0
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
387
975
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
388 def generateSetupCode(self):
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
389 return 'pinMode(%(pin)d, OUTPUT); digitalWrite(%(pin)d, LOW);' % {
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
390 'pin': self.pinNumber,
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
391 }
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
392
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
393 def outputPatterns(self):
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
394 return [(self.uri, ROOM['level'], None)]
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
395
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
396 def sendOutput(self, statements, write, read):
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
397 assert len(statements) == 1
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
398 assert statements[0][:2] == (self.uri, ROOM['level'])
1023
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
399 self.value = {"high": 1, "low": 0}[str(statements[0][2])]
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
400 write(chr(self.value))
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
401
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
402 def hostStatements(self):
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
403 return [(self.uri, ROOM['level'],
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
404 Literal('high' if self.value else 'low'))]
975
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
405
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
406 def generateActionCode(self):
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
407 return r'''
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
408 while(Serial.available() < 1) NULL;
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
409 digitalWrite(%(pin)d, Serial.read());
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
410 ''' % dict(pin=self.pinNumber)
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
411
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
412 def outputWidgets(self):
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
413 return [{
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
414 'element': 'output-switch',
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
415 'subj': self.uri,
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
416 'pred': ROOM['level'],
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
417 }]
997
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
418
1023
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
419
997
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
420 @register
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
421 class PwmBoard(DeviceType):
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
422 deviceType = ROOM['PwmBoard']
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
423 @classmethod
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
424 def findInstances(cls, graph, board):
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
425 for row in graph.query("""SELECT DISTINCT ?dev ?sda ?scl WHERE {
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
426 ?board :hasPin ?sdaPin .
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
427 ?board :hasPin ?sclPin .
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
428 ?sdaPin :pinNumber ?sda; :connectedTo ?sdaConn .
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
429 ?sclPin :pinNumber ?scl; :connectedTo ?sclConn .
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
430 ?dev a :PwmBoard;
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
431 :scl ?sclConn;
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
432 :sda ?sdaConn .
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
433 }""", initBindings=dict(board=board), initNs={'': ROOM}):
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
434 if (row.sda, row.scl) != (Literal('a4'), Literal('a5')):
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
435 raise NotImplementedError(row)
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
436 outs = {}
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
437 for out in graph.query("""SELECT DISTINCT ?area ?chan WHERE {
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
438 ?dev :output [:area ?area; :channel ?chan] .
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
439 }""", initBindings=dict(dev=row.dev), initNs={'': ROOM}):
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
440 outs[out.area] = out.chan.toPython()
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
441 yield cls(graph, row.dev, outs=outs)
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
997
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
443 def __init__(self, graph, dev, outs):
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
444 self.codeVals = {'pwm': 'pwm%s' % (hash(str(dev)) % 99999)}
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
445 self.outs = outs
1023
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
446 super(PwmBoard, self).__init__(graph, dev, pinNumber=None)
997
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
447
1023
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
448 def hostStateInit(self):
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
449 self.values = {uri: 0 for uri in self.outs.keys()} # uri: brightness
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
450
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
451 def hostStatements(self):
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
452 return [(uri, ROOM['brightness'], Literal(b))
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
453 for uri, b in self.values.items()]
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
454
997
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
455 def generateIncludes(self):
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
456 return ['Wire.h', 'Adafruit_PWMServoDriver.h']
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
457
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
458 def generateArduinoLibs(self):
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
459 return ['Wire', 'Adafruit-PWM-Servo-Driver-Library']
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
460
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
461 def generateGlobalCode(self):
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
462 return r'''
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
463 Adafruit_PWMServoDriver %(pwm)s = Adafruit_PWMServoDriver(0x40);
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
464 ''' % self.codeVals
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
465
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
466 def generateSetupCode(self):
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
467 return '''
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
468 %(pwm)s.begin();
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
469 %(pwm)s.setPWMFreq(1200);
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
470 ''' % self.codeVals
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
471
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
472 def generateActionCode(self):
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
473 return r'''
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
474 while(Serial.available() < 3) NULL;
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
475 byte chan = Serial.read();
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
476 uint16_t level = uint16_t(Serial.read()) << 8;
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
477 level |= Serial.read();
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
478 %(pwm)s.setPWM(chan, 0, level);
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
479 ''' % self.codeVals
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
480
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
481 def outputPatterns(self):
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
482 return [(area, ROOM['brightness'], None) for area in self.outs]
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
483
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
484 def sendOutput(self, statements, write, read):
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
485 assert len(statements) == 1
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
486 assert statements[0][1] == ROOM['brightness'];
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
487 chan = self.outs[statements[0][0]]
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
488 value = float(statements[0][2])
1023
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
489 self.values[statements[0][0]] = value
997
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
490 v12 = int(min(4095, max(0, value * 4095)))
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
491 write(chr(chan) + chr(v12 >> 8) + chr(v12 & 0xff))
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
492
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
493 def outputWidgets(self):
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
494 return [{
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
495 'element': 'output-slider',
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
496 'min': 0,
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
497 'max': 1,
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
498 'step': 1 / 255,
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
499 'subj': area,
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
500 'pred': ROOM['brightness'],
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
501 } for area in self.outs]
b24885725f59 support for pwm board
drewp <drewp@bigasterisk.com>
parents: 991
diff changeset
502
974
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
503 @register
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
504 class ST7576Lcd(DeviceType):
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
505 deviceType = ROOM['ST7565Lcd']
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
506 @classmethod
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
507 def findInstances(cls, graph, board):
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
508 grouped = itertools.groupby(
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
509 graph.query("""SELECT DISTINCT ?dev ?pred ?pinNumber WHERE {
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
510 ?board :hasPin ?pin .
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
511 ?pin :pinNumber ?pinNumber;
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
512 :connectedTo ?devPin .
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
513 ?dev a :ST7565Lcd .
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
514 ?dev ?pred ?devPin .
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
515 } ORDER BY ?dev""",
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
516 initBindings=dict(board=board,
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
517 thisType=cls.deviceType),
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
518 initNs={'': ROOM}),
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
519 lambda row: row.dev)
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
520 for dev, connections in grouped:
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
521 connections = dict((role, int(num)) for unused_dev, role, num
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
522 in connections)
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
523 yield cls(graph, dev, connections=connections)
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
524
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
525 def __init__(self, graph, dev, connections):
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
526 super(ST7576Lcd, self).__init__(graph, dev, pinNumber=None)
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
527 self.connections = connections
1023
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
528 self.text = ''
974
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
529
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
530 def generateIncludes(self):
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
531 return ['ST7565.h']
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
532
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
533 def generateArduinoLibs(self):
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
534 return ['ST7565']
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
535
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
536 def generateGlobalCode(self):
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
537 return '''
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
538 ST7565 glcd(%(SID)d, %(SCLK)d, %(A0)d, %(RST)d, %(CS)d);
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
539 char newtxt[21*8+1];
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
540 unsigned int written;
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
541 ''' % dict(SID=self.connections[ROOM['lcdSID']],
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
542 SCLK=self.connections[ROOM['lcdSCLK']],
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
543 A0=self.connections[ROOM['lcdA0']],
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
544 RST=self.connections[ROOM['lcdRST']],
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
545 CS=self.connections[ROOM['lcdCS']])
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
546
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
547 def generateSetupCode(self):
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
548 return '''
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
549 glcd.st7565_init();
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
550 glcd.st7565_command(CMD_DISPLAY_ON);
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
551 glcd.st7565_command(CMD_SET_ALLPTS_NORMAL);
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
552 glcd.st7565_set_brightness(0x18);
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
553
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
554 glcd.display(); // show splashscreen
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
555 '''
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
556
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
557 def outputPatterns(self):
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
558 return [(self.uri, ROOM['text'], None)]
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
559
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
560 def sendOutput(self, statements, write, read):
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
561 assert len(statements) == 1
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
562 assert statements[0][:2] == (self.uri, ROOM['text'])
1023
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
563 self.text = str(statements[0][2])
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
564 assert len(self.text) < 254, repr(self.text)
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
565 write(chr(len(self.text)) + self.text)
974
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
566
1023
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
567 def hostStatements(self):
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
568 return [(self.uri, ROOM['text'], Literal(self.text))]
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
569
975
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
570 def outputWidgets(self):
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
571 return [{
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
572 'element': 'output-fixed-text',
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
573 'cols': 21,
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
574 'rows': 8,
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
575 'subj': self.uri,
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
576 'pred': ROOM['text'],
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
577 }]
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
578
974
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
579 def generateActionCode(self):
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
580 return '''
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
581 while(Serial.available() < 1) NULL;
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
582 byte bufSize = Serial.read();
975
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
583 for (byte i = 0; i < bufSize; ++i) {
974
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
584 while(Serial.available() < 1) NULL;
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
585 newtxt[i] = Serial.read();
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
586 }
975
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
587 for (byte i = bufSize; i < sizeof(newtxt); ++i) {
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
588 newtxt[i] = 0;
f3023410d875 polymer board debug page with working output widgets
drewp <drewp@bigasterisk.com>
parents: 974
diff changeset
589 }
974
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
590 glcd.clear();
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
591 glcd.drawstring(0,0, newtxt);
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
592 glcd.display();
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
593 '''
f707210c13bd new /output to post statements which devices can handle. led and lcd output working
drewp <drewp@bigasterisk.com>
parents: 971
diff changeset
594
1023
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
595 @register
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
596 class RgbPixels(DeviceType):
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
597 """chain of FastLED-controllable rgb pixels"""
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
598 deviceType = ROOM['RgbPixels']
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
599
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
600 def __init__(self, graph, uri, pinNumber):
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
601 super(RgbPixels, self).__init__(graph, uri, pinNumber)
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
602 px = graph.value(self.uri, ROOM['pixels'])
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
603 self.pixelUris = list(graph.items(px))
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
604 self.values = dict((uri, Literal('#000000')) for uri in self.pixelUris)
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
605 self.replace = {'ledArray': 'leds_%s' % self.pinNumber,
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
606 'ledCount': len(self.pixelUris),
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
607 'pin': self.pinNumber,
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
608 'ledType': 'WS2812',
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
609 }
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
610
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
611 def generateIncludes(self):
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
612 """filenames of .h files to #include"""
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
613 return ['FastLED.h']
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
614
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
615 def generateArduinoLibs(self):
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
616 """names of libraries for the ARDUINO_LIBS line in the makefile"""
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
617 return ['FastLED-3.1.0']
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
618
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
619 def myId(self):
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
620 return 'rgb_%s' % self.pinNumber
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
621
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
622 def generateGlobalCode(self):
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
623 return 'CRGB {ledArray}[{ledCount}];'.format(**self.replace)
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
624
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
625 def generateSetupCode(self):
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
626 return 'FastLED.addLeds<{ledType}, {pin}>({ledArray}, {ledCount});'.format(**self.replace)
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
627
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
628 def _rgbFromHex(self, h):
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
629 rrggbb = h.lstrip('#')
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
630 return [int(x, 16) for x in [rrggbb[0:2], rrggbb[2:4], rrggbb[4:6]]]
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
631
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
632 def sendOutput(self, statements, write, read):
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
633 px, pred, color = statements[0]
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
634 if pred != ROOM['color']:
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
635 raise ValueError(pred)
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
636 rgb = self._rgbFromHex(color)
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
637 if px not in self.values:
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
638 raise ValueError(px)
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
639 self.values[px] = Literal(color)
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
640 write(chr(self.pixelUris.index(px)) +
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
641 chr(rgb[1]) + # my WS2812 need these flipped
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
642 chr(rgb[0]) +
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
643 chr(rgb[2]))
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
644
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
645 def hostStatements(self):
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
646 return [(uri, ROOM['color'], hexCol)
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
647 for uri, hexCol in self.values.items()]
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
648
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
649 def outputPatterns(self):
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
650 return [(px, ROOM['color'], None) for px in self.pixelUris]
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
651
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
652 def generateActionCode(self):
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
653
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
654 return '''
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
655
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
656 while(Serial.available() < 1) NULL;
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
657 byte id = Serial.read();
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
658
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
659 while(Serial.available() < 1) NULL;
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
660 byte r = Serial.read();
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
661
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
662 while(Serial.available() < 1) NULL;
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
663 byte g = Serial.read();
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
664
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
665 while(Serial.available() < 1) NULL;
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
666 byte b = Serial.read();
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
667
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
668 {ledArray}[id] = CRGB(r, g, b); FastLED.show();
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
669
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
670 '''.format(**self.replace)
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
671
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
672 def outputWidgets(self):
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
673 return [{
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
674 'element': 'output-rgb',
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
675 'subj': px,
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
676 'pred': ROOM['color'],
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
677 } for px in self.pixelUris]
3e6fac8569cd multi-boards on one service, new devices, devices return their current
drewp <drewp@bigasterisk.com>
parents: 997
diff changeset
678
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
679 def makeDevices(graph, board):
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
680 out = []
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
681 for dt in sorted(_knownTypes, key=lambda cls: cls.__name__):
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
682 out.extend(dt.findInstances(graph, board))
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
683 return out
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
684