Mercurial > code > home > repos > homeauto
annotate service/piNode/devices.py @ 262:9e388c3f032c
invert support for Pushbutton
Ignore-this: d4b994070114e26700857fcd2cd0118e
author | drewp@bigasterisk.com |
---|---|
date | Sat, 02 Apr 2016 23:33:43 -0700 |
parents | 54fad386d6f5 |
children | 1ae78fe6f36e |
rev | line source |
---|---|
182 | 1 from __future__ import division |
183
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
2 |
221
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
3 import time, logging, os |
243
141079644c45
piNode poll switches much faster. mirror the logic in arduinoNode though vari-rate poll is not supported yet
drewp@bigasterisk.com
parents:
233
diff
changeset
|
4 from rdflib import Namespace, URIRef, Literal |
182 | 5 |
183
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
6 try: |
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
7 import pigpio |
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
8 except ImportError: |
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
9 pigpio = None |
221
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
10 import w1thermsensor |
259 | 11 try: |
12 import NeoPixel | |
13 except ImportError: | |
14 NeoPixel = None | |
15 | |
221
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
16 import sys |
183
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
17 |
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
18 log = logging.getLogger() |
182 | 19 ROOM = Namespace('http://projects.bigasterisk.com/room/') |
209 | 20 XSD = Namespace('http://www.w3.org/2001/XMLSchema#') |
221
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
21 RDFS = Namespace('http://www.w3.org/2000/01/rdf-schema#') |
182 | 22 |
23 class DeviceType(object): | |
221
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
24 deviceType = NotImplementedError |
182 | 25 @classmethod |
26 def findInstances(cls, graph, board, pi): | |
27 """ | |
28 return any number of instances of this class for all the separately | |
29 controlled devices on the board. Two LEDS makes two instances, | |
30 but two sensors on the same onewire bus makes only one device | |
31 (which yields more statements). | |
32 """ | |
221
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
33 log.debug("graph has any connected devices of type %s?", cls.deviceType) |
183
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
34 for row in graph.query("""SELECT ?dev ?gpioNumber WHERE { |
182 | 35 ?board :hasPin ?pin . |
183
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
36 ?pin :gpioNumber ?gpioNumber; |
182 | 37 :connectedTo ?dev . |
38 ?dev a ?thisType . | |
39 } ORDER BY ?dev""", | |
40 initBindings=dict(board=board, | |
221
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
41 thisType=cls.deviceType)): |
183
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
42 yield cls(graph, row.dev, pi, int(row.gpioNumber)) |
182 | 43 |
44 def __init__(self, graph, uri, pi, pinNumber): | |
45 self.graph, self.uri, self.pi = graph, uri, pi | |
46 self.pinNumber = pinNumber | |
233
4ebb5cc30002
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp@bigasterisk.com
parents:
232
diff
changeset
|
47 self.hostStateInit() |
182 | 48 |
233
4ebb5cc30002
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp@bigasterisk.com
parents:
232
diff
changeset
|
49 def hostStateInit(self): |
4ebb5cc30002
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp@bigasterisk.com
parents:
232
diff
changeset
|
50 """ |
4ebb5cc30002
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp@bigasterisk.com
parents:
232
diff
changeset
|
51 If you don't want to use __init__, you can use this to set up |
4ebb5cc30002
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp@bigasterisk.com
parents:
232
diff
changeset
|
52 whatever storage you might need for hostStatements |
4ebb5cc30002
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp@bigasterisk.com
parents:
232
diff
changeset
|
53 """ |
4ebb5cc30002
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp@bigasterisk.com
parents:
232
diff
changeset
|
54 |
182 | 55 def description(self): |
56 return { | |
57 'uri': self.uri, | |
58 'className': self.__class__.__name__, | |
183
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
59 'pinNumber': getattr(self, 'pinNumber', None), |
182 | 60 'outputPatterns': self.outputPatterns(), |
61 'watchPrefixes': self.watchPrefixes(), | |
62 'outputWidgets': self.outputWidgets(), | |
63 } | |
64 | |
233
4ebb5cc30002
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp@bigasterisk.com
parents:
232
diff
changeset
|
65 def hostStatements(self): |
4ebb5cc30002
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp@bigasterisk.com
parents:
232
diff
changeset
|
66 """ |
4ebb5cc30002
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp@bigasterisk.com
parents:
232
diff
changeset
|
67 Like readFromPoll but these statements come from the host-side |
4ebb5cc30002
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp@bigasterisk.com
parents:
232
diff
changeset
|
68 python code, not the connected device. Include output state |
4ebb5cc30002
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp@bigasterisk.com
parents:
232
diff
changeset
|
69 (e.g. light brightness) if its master version is in this |
4ebb5cc30002
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp@bigasterisk.com
parents:
232
diff
changeset
|
70 object. This method is called on /graph requests so it should |
4ebb5cc30002
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp@bigasterisk.com
parents:
232
diff
changeset
|
71 be fast. |
4ebb5cc30002
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp@bigasterisk.com
parents:
232
diff
changeset
|
72 """ |
4ebb5cc30002
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp@bigasterisk.com
parents:
232
diff
changeset
|
73 return [] |
4ebb5cc30002
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp@bigasterisk.com
parents:
232
diff
changeset
|
74 |
182 | 75 def watchPrefixes(self): |
76 """ | |
77 subj,pred pairs of the statements that might be returned from | |
78 readFromPoll, so the dashboard knows what it should | |
79 watch. This should be eliminated, as the dashboard should just | |
80 always watch the whole tree of statements starting self.uri | |
81 """ | |
82 return [] | |
83 | |
84 def poll(self): | |
85 return [] # statements | |
86 | |
87 def outputPatterns(self): | |
88 """ | |
89 Triple patterns, using None as a wildcard, that should be routed | |
90 to sendOutput | |
91 """ | |
92 return [] | |
93 | |
94 def outputWidgets(self): | |
95 """ | |
96 structs to make output widgets on the dashboard. ~1 of these per | |
97 handler you have in sendOutput | |
98 """ | |
99 return [] | |
100 | |
101 def sendOutput(self, statements): | |
102 """ | |
103 If we got statements that match this class's outputPatterns, this | |
104 will be called with the statements that matched. | |
105 | |
106 Todo: it would be fine to read back confirmations or | |
107 whatever. Just need a way to collect them into graph statements. | |
108 """ | |
109 raise NotImplementedError | |
110 | |
111 _knownTypes = set() | |
112 def register(deviceType): | |
113 _knownTypes.add(deviceType) | |
114 return deviceType | |
115 | |
116 @register | |
117 class MotionSensorInput(DeviceType): | |
221
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
118 # compare motion sensor lib at http://pythonhosted.org/gpiozero/inputs/ |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
119 # which is a bit fancier |
182 | 120 deviceType = ROOM['MotionSensor'] |
121 | |
122 def setup(self): | |
123 self.pi.set_mode(17, pigpio.INPUT) | |
124 self.pi.set_pull_up_down(17, pigpio.PUD_DOWN) | |
125 | |
254
ba1149814877
pi device support for motionStart edge trigger
drewp@bigasterisk.com
parents:
251
diff
changeset
|
126 def hostStateInit(self): |
ba1149814877
pi device support for motionStart edge trigger
drewp@bigasterisk.com
parents:
251
diff
changeset
|
127 self.lastRead = None |
ba1149814877
pi device support for motionStart edge trigger
drewp@bigasterisk.com
parents:
251
diff
changeset
|
128 |
182 | 129 def poll(self): |
130 motion = self.pi.read(17) | |
131 | |
254
ba1149814877
pi device support for motionStart edge trigger
drewp@bigasterisk.com
parents:
251
diff
changeset
|
132 oneshot = [] |
ba1149814877
pi device support for motionStart edge trigger
drewp@bigasterisk.com
parents:
251
diff
changeset
|
133 if self.lastRead is not None and motion != self.lastRead: |
ba1149814877
pi device support for motionStart edge trigger
drewp@bigasterisk.com
parents:
251
diff
changeset
|
134 oneshot = [(self.uri, ROOM['sees'], ROOM['motionStart'])] |
ba1149814877
pi device support for motionStart edge trigger
drewp@bigasterisk.com
parents:
251
diff
changeset
|
135 self.lastRead = motion |
ba1149814877
pi device support for motionStart edge trigger
drewp@bigasterisk.com
parents:
251
diff
changeset
|
136 |
251
254df9f881a6
start sending oneshot events from some devices
drewp@bigasterisk.com
parents:
244
diff
changeset
|
137 return {'latest': [ |
182 | 138 (self.uri, ROOM['sees'], |
139 ROOM['motion'] if motion else ROOM['noMotion']), | |
140 self.recentMotionStatement(motion), | |
254
ba1149814877
pi device support for motionStart edge trigger
drewp@bigasterisk.com
parents:
251
diff
changeset
|
141 ], 'oneshot': oneshot} |
182 | 142 |
143 def recentMotionStatement(self, motion): | |
144 if not hasattr(self, 'lastMotionTime'): | |
145 self.lastMotionTime = 0 | |
146 now = time.time() | |
147 if motion: | |
148 self.lastMotionTime = now | |
149 recentMotion = now - self.lastMotionTime < 60 * 10 | |
150 return (self.uri, ROOM['seesRecently'], | |
151 ROOM['motion'] if recentMotion else ROOM['noMotion']) | |
152 | |
153 def watchPrefixes(self): | |
154 return [ | |
155 (self.uri, ROOM['sees']), | |
156 (self.uri, ROOM['seesRecently']), | |
157 ] | |
158 | |
183
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
159 |
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
160 @register |
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
161 class RgbStrip(DeviceType): |
220 | 162 """3 PWMs for r/g/b on a strip""" |
221
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
163 # pigpio daemon is working fine, but |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
164 # https://github.com/RPi-Distro/python-gpiozero/blob/59ba7154c5918745ac894ea03503667d6473c760/gpiozero/output_devices.py#L213 |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
165 # can also apparently do PWM |
183
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
166 deviceType = ROOM['RgbStrip'] |
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
167 |
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
168 @classmethod |
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
169 def findInstances(cls, graph, board, pi): |
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
170 for row in graph.query("""SELECT DISTINCT ?dev ?r ?g ?b WHERE { |
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
171 ?board |
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
172 :hasPin ?rpin; |
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
173 :hasPin ?gpin; |
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
174 :hasPin ?bpin . |
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
175 ?dev a :RgbStrip; |
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
176 :redChannel ?rpin; |
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
177 :greenChannel ?gpin; |
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
178 :blueChannel ?bpin . |
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
179 ?rpin :gpioNumber ?r . |
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
180 ?gpin :gpioNumber ?g . |
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
181 ?bpin :gpioNumber ?b . |
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
182 } ORDER BY ?dev""", |
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
183 initBindings=dict(board=board), |
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
184 initNs={'': ROOM}): |
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
185 log.debug('found rgb %r', row) |
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
186 yield cls(graph, row.dev, pi, row.r, row.g, row.b) |
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
187 |
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
188 def __init__(self, graph, uri, pi, r, g, b): |
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
189 self.graph, self.uri, self.pi = graph, uri, pi |
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
190 self.rgb = map(int, [r, g, b]) |
233
4ebb5cc30002
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp@bigasterisk.com
parents:
232
diff
changeset
|
191 self.value = '#000000' |
183
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
192 |
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
193 def setup(self): |
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
194 for i in self.rgb: |
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
195 self.pi.set_mode(i, pigpio.OUTPUT) |
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
196 self.pi.set_PWM_frequency(i, 200) |
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
197 self.pi.set_PWM_dutycycle(i, 0) |
233
4ebb5cc30002
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp@bigasterisk.com
parents:
232
diff
changeset
|
198 |
4ebb5cc30002
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp@bigasterisk.com
parents:
232
diff
changeset
|
199 def hostStatements(self): |
4ebb5cc30002
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp@bigasterisk.com
parents:
232
diff
changeset
|
200 return [(self.uri, ROOM['color'], Literal(self.value))] |
4ebb5cc30002
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp@bigasterisk.com
parents:
232
diff
changeset
|
201 |
183
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
202 def outputPatterns(self): |
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
203 return [(self.uri, ROOM['color'], None)] |
220 | 204 |
205 def _rgbFromHex(self, h): | |
206 rrggbb = h.lstrip('#') | |
207 return [int(x, 16) for x in [rrggbb[0:2], rrggbb[2:4], rrggbb[4:6]]] | |
183
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
208 |
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
209 def sendOutput(self, statements): |
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
210 assert len(statements) == 1 |
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
211 assert statements[0][:2] == (self.uri, ROOM['color']) |
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
212 |
220 | 213 rgb = self._rgbFromHex(statements[0][2]) |
233
4ebb5cc30002
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp@bigasterisk.com
parents:
232
diff
changeset
|
214 self.value = statements[0][2] |
183
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
215 |
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
216 for (i, v) in zip(self.rgb, rgb): |
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
217 self.pi.set_PWM_dutycycle(i, v) |
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
218 |
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
219 def outputWidgets(self): |
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
220 return [{ |
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
221 'element': 'output-rgb', |
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
222 'subj': self.uri, |
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
223 'pred': ROOM['color'], |
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
224 }] |
634d6e477953
get piNode working, for motionsensor at least
drewp@bigasterisk.com
parents:
182
diff
changeset
|
225 |
210 | 226 |
227 @register | |
221
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
228 class TempHumidSensor(DeviceType): |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
229 deviceType = ROOM['TempHumidSensor'] |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
230 |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
231 def __init__(self, *a, **kw): |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
232 DeviceType.__init__(self, *a, **kw) |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
233 sys.path.append('/opt/pigpio/EXAMPLES/Python/DHT22_AM2302_SENSOR') |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
234 import DHT22 |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
235 self.sensor = DHT22.sensor(self.pi, self.pinNumber) |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
236 |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
237 def poll(self): |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
238 self.sensor.trigger() |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
239 humid, tempC = self.sensor.humidity(), self.sensor.temperature() |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
240 |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
241 stmts = set() |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
242 if humid is not None: |
232
4e91f3ec460b
more round() workarounds for mismatching literals not patching themselves out
drewp@bigasterisk.com
parents:
221
diff
changeset
|
243 stmts.add((self.uri, ROOM['humidity'], Literal(round(humid, 2)))) |
221
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
244 else: |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
245 stmts.add((self.uri, RDFS['comment'], |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
246 Literal('DHT read returned None'))) |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
247 if tempC is not None: |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
248 stmts.add((self.uri, ROOM['temperatureF'], |
232
4e91f3ec460b
more round() workarounds for mismatching literals not patching themselves out
drewp@bigasterisk.com
parents:
221
diff
changeset
|
249 # see round() note in arduinoNode/devices.py |
4e91f3ec460b
more round() workarounds for mismatching literals not patching themselves out
drewp@bigasterisk.com
parents:
221
diff
changeset
|
250 Literal(round(tempC * 9 / 5 + 32, 2)))) |
221
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
251 else: |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
252 stmts.add((self.uri, RDFS['comment'], |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
253 Literal('DHT read returned None'))) |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
254 return stmts |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
255 |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
256 def watchPrefixes(self): |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
257 return [ |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
258 (self.uri, ROOM['temperatureF']), |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
259 (self.uri, ROOM['humidity']), |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
260 ] |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
261 |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
262 @register |
244 | 263 class PushbuttonInput(DeviceType): |
264 """add a switch to ground; we'll turn on pullup""" | |
265 deviceType = ROOM['Pushbutton'] | |
266 | |
267 def __init__(self, *a, **kw): | |
268 DeviceType.__init__(self, *a, **kw) | |
269 log.debug("setup switch on %r", self.pinNumber) | |
270 self.pi.set_mode(self.pinNumber, pigpio.INPUT) | |
271 self.pi.set_pull_up_down(self.pinNumber, pigpio.PUD_UP) | |
251
254df9f881a6
start sending oneshot events from some devices
drewp@bigasterisk.com
parents:
244
diff
changeset
|
272 self.lastClosed = None |
262 | 273 self.invert = (self.uri, ROOM['style'], |
274 ROOM['inverted']) in self.graph | |
244 | 275 |
276 def poll(self): | |
277 closed = not self.pi.read(self.pinNumber) | |
262 | 278 if self.invert: |
279 closed = not closed | |
251
254df9f881a6
start sending oneshot events from some devices
drewp@bigasterisk.com
parents:
244
diff
changeset
|
280 |
254df9f881a6
start sending oneshot events from some devices
drewp@bigasterisk.com
parents:
244
diff
changeset
|
281 if self.lastClosed is not None and closed != self.lastClosed: |
262 | 282 log.debug('%s changed to %s', self.uri, closed) |
251
254df9f881a6
start sending oneshot events from some devices
drewp@bigasterisk.com
parents:
244
diff
changeset
|
283 oneshot = [ |
254df9f881a6
start sending oneshot events from some devices
drewp@bigasterisk.com
parents:
244
diff
changeset
|
284 (self.uri, ROOM['buttonState'], |
254df9f881a6
start sending oneshot events from some devices
drewp@bigasterisk.com
parents:
244
diff
changeset
|
285 ROOM['press'] if closed else ROOM['release']), |
254df9f881a6
start sending oneshot events from some devices
drewp@bigasterisk.com
parents:
244
diff
changeset
|
286 ] |
254df9f881a6
start sending oneshot events from some devices
drewp@bigasterisk.com
parents:
244
diff
changeset
|
287 else: |
254df9f881a6
start sending oneshot events from some devices
drewp@bigasterisk.com
parents:
244
diff
changeset
|
288 oneshot = [] |
254df9f881a6
start sending oneshot events from some devices
drewp@bigasterisk.com
parents:
244
diff
changeset
|
289 self.lastClosed = closed |
254df9f881a6
start sending oneshot events from some devices
drewp@bigasterisk.com
parents:
244
diff
changeset
|
290 |
254df9f881a6
start sending oneshot events from some devices
drewp@bigasterisk.com
parents:
244
diff
changeset
|
291 return {'latest': [ |
244 | 292 (self.uri, ROOM['buttonState'], |
293 ROOM['pressed'] if closed else ROOM['notPressed']), | |
251
254df9f881a6
start sending oneshot events from some devices
drewp@bigasterisk.com
parents:
244
diff
changeset
|
294 ], |
254df9f881a6
start sending oneshot events from some devices
drewp@bigasterisk.com
parents:
244
diff
changeset
|
295 'oneshot':oneshot} |
244 | 296 |
297 def watchPrefixes(self): | |
298 return [ | |
299 (self.uri, ROOM['buttonState']), | |
300 ] | |
301 | |
302 @register | |
221
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
303 class OneWire(DeviceType): |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
304 """ |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
305 Also see /my/proj/ansible/roles/raspi_io_node/tasks/main.yml for |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
306 some system config that contains the pin number that you want to |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
307 use for onewire. The pin number in this config is currently ignored. |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
308 """ |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
309 deviceType = ROOM['OneWire'] |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
310 # deliberately written like arduinoNode's one for an easier merge. |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
311 def __init__(self, *a, **kw): |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
312 DeviceType.__init__(self, *a, **kw) |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
313 log.info("scan for w1 devices") |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
314 self._sensors = w1thermsensor.W1ThermSensor.get_available_sensors() |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
315 for s in self._sensors: |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
316 # Something looks different about these ids |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
317 # ('000003a5a94c') vs the ones I get from arduino |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
318 # ('2813bea50300003d'). Not sure if I'm parsing them |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
319 # differently or what. |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
320 s.uri = URIRef(os.path.join(self.uri, 'dev-%s' % s.id)) |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
321 log.info(' found temperature sensor %s' % s.uri) |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
322 |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
323 def poll(self): |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
324 try: |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
325 stmts = [] |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
326 for sensor in self._sensors: |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
327 stmts.append((self.uri, ROOM['connectedTo'], sensor.uri)) |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
328 try: |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
329 tempF = sensor.get_temperature(sensor.DEGREES_F) |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
330 stmts.append((sensor.uri, ROOM['temperatureF'], |
232
4e91f3ec460b
more round() workarounds for mismatching literals not patching themselves out
drewp@bigasterisk.com
parents:
221
diff
changeset
|
331 # see round() note in arduinoNode/devices.py |
4e91f3ec460b
more round() workarounds for mismatching literals not patching themselves out
drewp@bigasterisk.com
parents:
221
diff
changeset
|
332 Literal(round(tempF, 2)))) |
221
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
333 except w1thermsensor.core.SensorNotReadyError as e: |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
334 log.warning(e) |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
335 |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
336 return stmts |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
337 except Exception as e: |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
338 log.error(e) |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
339 os.abort() |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
340 |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
341 def watchPrefixes(self): |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
342 return [(s.uri, ROOM['temperatureF']) for s in self._sensors] |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
343 |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
344 |
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
345 @register |
210 | 346 class LedOutput(DeviceType): |
347 deviceType = ROOM['LedOutput'] | |
233
4ebb5cc30002
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp@bigasterisk.com
parents:
232
diff
changeset
|
348 |
4ebb5cc30002
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp@bigasterisk.com
parents:
232
diff
changeset
|
349 def hostStateInit(self): |
4ebb5cc30002
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp@bigasterisk.com
parents:
232
diff
changeset
|
350 self.value = 0 |
4ebb5cc30002
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp@bigasterisk.com
parents:
232
diff
changeset
|
351 |
210 | 352 def setup(self): |
353 self.pi.set_mode(self.pinNumber, pigpio.OUTPUT) | |
354 self.pi.set_PWM_frequency(self.pinNumber, 200) | |
355 self.pi.set_PWM_dutycycle(self.pinNumber, 0) | |
356 | |
357 def outputPatterns(self): | |
358 return [(self.uri, ROOM['brightness'], None)] | |
359 | |
360 def sendOutput(self, statements): | |
361 assert len(statements) == 1 | |
362 assert statements[0][:2] == (self.uri, ROOM['brightness']) | |
233
4ebb5cc30002
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp@bigasterisk.com
parents:
232
diff
changeset
|
363 self.value = float(statements[0][2]) |
4ebb5cc30002
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp@bigasterisk.com
parents:
232
diff
changeset
|
364 v = int(self.value * 255) |
210 | 365 self.pi.set_PWM_dutycycle(self.pinNumber, v) |
233
4ebb5cc30002
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp@bigasterisk.com
parents:
232
diff
changeset
|
366 |
4ebb5cc30002
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp@bigasterisk.com
parents:
232
diff
changeset
|
367 def hostStatements(self): |
4ebb5cc30002
server/browser graph sync. cut dependency on the WS version. merge some changes between arduino/pi code.
drewp@bigasterisk.com
parents:
232
diff
changeset
|
368 return [(self.uri, ROOM['brightness'], Literal(self.value))] |
210 | 369 |
370 def outputWidgets(self): | |
371 return [{ | |
372 'element': 'output-slider', | |
373 'min': 0, | |
374 'max': 1, | |
375 'step': 1 / 255, | |
376 'subj': self.uri, | |
377 'pred': ROOM['brightness'], | |
378 }] | |
379 | |
380 | |
205 | 381 @register |
382 class OnboardTemperature(DeviceType): | |
383 deviceType = ROOM['OnboardTemperature'] | |
243
141079644c45
piNode poll switches much faster. mirror the logic in arduinoNode though vari-rate poll is not supported yet
drewp@bigasterisk.com
parents:
233
diff
changeset
|
384 pollPeriod = 10 |
205 | 385 @classmethod |
386 def findInstances(cls, graph, board, pi): | |
259 | 387 log.debug('graph has any connected devices of type OnboardTemperature on %r?', board) |
207 | 388 for row in graph.query('''SELECT DISTINCT ?uri WHERE { |
205 | 389 ?board :onboardDevice ?uri . |
390 ?uri a :OnboardTemperature . | |
221
666e0e756ce6
piNode support for temp sensors. proper hostname lookup
drewp@bigasterisk.com
parents:
220
diff
changeset
|
391 }''', initBindings=dict(board=board)): |
259 | 392 log.debug(' found %s', row.uri) |
205 | 393 yield cls(graph, row.uri, pi, pinNumber=None) |
394 | |
208 | 395 def poll(self): |
205 | 396 milliC = open('/sys/class/thermal/thermal_zone0/temp').read().strip() |
397 c = float(milliC) / 1000. | |
398 f = c * 1.8 + 32 | |
399 return [ | |
400 (self.uri, ROOM['temperatureF'], Literal(f, datatype=XSD['decimal'])), | |
401 ] | |
402 | |
403 def watchPrefixes(self): | |
404 # these uris will become dynamic! see note on watchPrefixes | |
405 # about eliminating it. | |
406 return [(self.uri, ROOM['temperatureF']), | |
407 ] | |
259 | 408 |
409 @register | |
410 class RgbPixels(DeviceType): | |
411 """chain of ws2812 rgb pixels on pin GPIO18""" | |
412 deviceType = ROOM['RgbPixels'] | |
413 | |
414 def hostStateInit(self): | |
415 px = self.graph.value(self.uri, ROOM['pixels']) | |
416 self.pixelUris = list(self.graph.items(px)) | |
417 self.values = dict((uri, Literal('#000000')) for uri in self.pixelUris) | |
418 self.replace = {'ledArray': 'leds_%s' % self.pinNumber, | |
419 'ledCount': len(self.pixelUris), | |
420 'pin': self.pinNumber, | |
421 'ledType': 'WS2812', | |
422 } | |
423 self.neo = NeoPixel.NeoPixel(len(self.values)) | |
424 self.neo.begin() | |
425 | |
426 def _rgbFromHex(self, h): | |
427 rrggbb = h.lstrip('#') | |
428 return [int(x, 16) for x in [rrggbb[0:2], rrggbb[2:4], rrggbb[4:6]]] | |
429 | |
430 def sendOutput(self, statements): | |
431 px, pred, color = statements[0] | |
432 if pred != ROOM['color']: | |
433 raise ValueError(pred) | |
434 rgb = self._rgbFromHex(color) | |
435 if px not in self.values: | |
436 raise ValueError(px) | |
437 self.values[px] = Literal(color) | |
438 self.neo.setPixelColor(self.pixelUris.index(px), rgb[0], rgb[1], rgb[2]) | |
439 self.neo.show() | |
440 | |
441 def hostStatements(self): | |
442 return [(uri, ROOM['color'], hexCol) | |
443 for uri, hexCol in self.values.items()] | |
444 | |
445 def outputPatterns(self): | |
446 return [(px, ROOM['color'], None) for px in self.pixelUris] | |
447 | |
448 def outputWidgets(self): | |
449 return [{ | |
450 'element': 'output-rgb', | |
451 'subj': px, | |
452 'pred': ROOM['color'], | |
453 } for px in self.pixelUris] | |
454 | |
205 | 455 |
182 | 456 def makeDevices(graph, board, pi): |
457 out = [] | |
458 for dt in sorted(_knownTypes, key=lambda cls: cls.__name__): | |
459 out.extend(dt.findInstances(graph, board, pi)) | |
460 return out | |
461 |