Mercurial > code > home > repos > homeauto
annotate service/piNode/devices.py @ 1037:8d1a8a96e895
more round() workarounds for mismatching literals not patching themselves out
Ignore-this: 9e173ff490ca2b4cea54ffad40beed49
darcs-hash:7af87eaa585900fdbf1a004c3764798171caa28d
author | drewp <drewp@bigasterisk.com> |
---|---|
date | Thu, 28 Jan 2016 02:48:54 -0800 |
parents | 8e075449ba0a |
children | 4ebb5cc30002 |
rev | line source |
---|---|
987 | 1 from __future__ import division |
988
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
2 |
1026
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
3 import time, logging, os |
987 | 4 from rdflib import Namespace, RDF, URIRef, Literal |
5 | |
988
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
6 try: |
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
7 import pigpio |
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
8 except ImportError: |
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
9 pigpio = None |
1026
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
10 import w1thermsensor |
988
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
11 |
1026
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
12 import sys |
988
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
13 |
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
14 log = logging.getLogger() |
987 | 15 ROOM = Namespace('http://projects.bigasterisk.com/room/') |
1014 | 16 XSD = Namespace('http://www.w3.org/2001/XMLSchema#') |
1026
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
17 RDFS = Namespace('http://www.w3.org/2000/01/rdf-schema#') |
987 | 18 |
19 class DeviceType(object): | |
1026
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
20 deviceType = NotImplementedError |
987 | 21 @classmethod |
22 def findInstances(cls, graph, board, pi): | |
23 """ | |
24 return any number of instances of this class for all the separately | |
25 controlled devices on the board. Two LEDS makes two instances, | |
26 but two sensors on the same onewire bus makes only one device | |
27 (which yields more statements). | |
28 """ | |
1026
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
29 log.debug("graph has any connected devices of type %s?", cls.deviceType) |
988
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
30 for row in graph.query("""SELECT ?dev ?gpioNumber WHERE { |
987 | 31 ?board :hasPin ?pin . |
988
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
32 ?pin :gpioNumber ?gpioNumber; |
987 | 33 :connectedTo ?dev . |
34 ?dev a ?thisType . | |
35 } ORDER BY ?dev""", | |
36 initBindings=dict(board=board, | |
1026
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
37 thisType=cls.deviceType)): |
988
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
38 yield cls(graph, row.dev, pi, int(row.gpioNumber)) |
987 | 39 |
40 def __init__(self, graph, uri, pi, pinNumber): | |
41 self.graph, self.uri, self.pi = graph, uri, pi | |
42 self.pinNumber = pinNumber | |
43 | |
44 def description(self): | |
45 return { | |
46 'uri': self.uri, | |
47 'className': self.__class__.__name__, | |
988
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
48 'pinNumber': getattr(self, 'pinNumber', None), |
987 | 49 'outputPatterns': self.outputPatterns(), |
50 'watchPrefixes': self.watchPrefixes(), | |
51 'outputWidgets': self.outputWidgets(), | |
52 } | |
53 | |
54 def watchPrefixes(self): | |
55 """ | |
56 subj,pred pairs of the statements that might be returned from | |
57 readFromPoll, so the dashboard knows what it should | |
58 watch. This should be eliminated, as the dashboard should just | |
59 always watch the whole tree of statements starting self.uri | |
60 """ | |
61 return [] | |
62 | |
63 def poll(self): | |
64 return [] # statements | |
65 | |
66 def outputPatterns(self): | |
67 """ | |
68 Triple patterns, using None as a wildcard, that should be routed | |
69 to sendOutput | |
70 """ | |
71 return [] | |
72 | |
73 def outputWidgets(self): | |
74 """ | |
75 structs to make output widgets on the dashboard. ~1 of these per | |
76 handler you have in sendOutput | |
77 """ | |
78 return [] | |
79 | |
80 def sendOutput(self, statements): | |
81 """ | |
82 If we got statements that match this class's outputPatterns, this | |
83 will be called with the statements that matched. | |
84 | |
85 Todo: it would be fine to read back confirmations or | |
86 whatever. Just need a way to collect them into graph statements. | |
87 """ | |
88 raise NotImplementedError | |
89 | |
90 _knownTypes = set() | |
91 def register(deviceType): | |
92 _knownTypes.add(deviceType) | |
93 return deviceType | |
94 | |
95 @register | |
96 class MotionSensorInput(DeviceType): | |
1026
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
97 # compare motion sensor lib at http://pythonhosted.org/gpiozero/inputs/ |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
98 # which is a bit fancier |
987 | 99 deviceType = ROOM['MotionSensor'] |
100 | |
101 def setup(self): | |
102 self.pi.set_mode(17, pigpio.INPUT) | |
103 self.pi.set_pull_up_down(17, pigpio.PUD_DOWN) | |
104 | |
105 def poll(self): | |
106 motion = self.pi.read(17) | |
107 | |
108 return [ | |
109 (self.uri, ROOM['sees'], | |
110 ROOM['motion'] if motion else ROOM['noMotion']), | |
111 self.recentMotionStatement(motion), | |
112 ] | |
113 | |
114 def recentMotionStatement(self, motion): | |
115 if not hasattr(self, 'lastMotionTime'): | |
116 self.lastMotionTime = 0 | |
117 now = time.time() | |
118 if motion: | |
119 self.lastMotionTime = now | |
120 recentMotion = now - self.lastMotionTime < 60 * 10 | |
121 return (self.uri, ROOM['seesRecently'], | |
122 ROOM['motion'] if recentMotion else ROOM['noMotion']) | |
123 | |
124 def watchPrefixes(self): | |
125 return [ | |
126 (self.uri, ROOM['sees']), | |
127 (self.uri, ROOM['seesRecently']), | |
128 ] | |
129 | |
988
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
130 |
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
131 @register |
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
132 class RgbStrip(DeviceType): |
1025 | 133 """3 PWMs for r/g/b on a strip""" |
1026
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
134 # pigpio daemon is working fine, but |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
135 # https://github.com/RPi-Distro/python-gpiozero/blob/59ba7154c5918745ac894ea03503667d6473c760/gpiozero/output_devices.py#L213 |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
136 # can also apparently do PWM |
988
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
137 deviceType = ROOM['RgbStrip'] |
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
138 |
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
139 @classmethod |
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
140 def findInstances(cls, graph, board, pi): |
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
141 for row in graph.query("""SELECT DISTINCT ?dev ?r ?g ?b WHERE { |
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
142 ?board |
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
143 :hasPin ?rpin; |
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
144 :hasPin ?gpin; |
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
145 :hasPin ?bpin . |
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
146 ?dev a :RgbStrip; |
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
147 :redChannel ?rpin; |
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
148 :greenChannel ?gpin; |
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
149 :blueChannel ?bpin . |
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
150 ?rpin :gpioNumber ?r . |
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
151 ?gpin :gpioNumber ?g . |
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
152 ?bpin :gpioNumber ?b . |
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
153 } ORDER BY ?dev""", |
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
154 initBindings=dict(board=board), |
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
155 initNs={'': ROOM}): |
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
156 log.debug('found rgb %r', row) |
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
157 yield cls(graph, row.dev, pi, row.r, row.g, row.b) |
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
158 |
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
159 def __init__(self, graph, uri, pi, r, g, b): |
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
160 self.graph, self.uri, self.pi = graph, uri, pi |
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
161 self.rgb = map(int, [r, g, b]) |
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
162 |
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
163 def setup(self): |
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
164 for i in self.rgb: |
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
165 self.pi.set_mode(i, pigpio.OUTPUT) |
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
166 self.pi.set_PWM_frequency(i, 200) |
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
167 self.pi.set_PWM_dutycycle(i, 0) |
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
168 |
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
169 def outputPatterns(self): |
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
170 return [(self.uri, ROOM['color'], None)] |
1025 | 171 |
172 def _rgbFromHex(self, h): | |
173 rrggbb = h.lstrip('#') | |
174 return [int(x, 16) for x in [rrggbb[0:2], rrggbb[2:4], rrggbb[4:6]]] | |
988
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
175 |
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
176 def sendOutput(self, statements): |
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
177 assert len(statements) == 1 |
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
178 assert statements[0][:2] == (self.uri, ROOM['color']) |
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
179 |
1025 | 180 rgb = self._rgbFromHex(statements[0][2]) |
988
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
181 |
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
182 for (i, v) in zip(self.rgb, rgb): |
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
183 self.pi.set_PWM_dutycycle(i, v) |
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
184 |
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
185 def outputWidgets(self): |
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
186 return [{ |
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
187 'element': 'output-rgb', |
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
188 'subj': self.uri, |
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
189 'pred': ROOM['color'], |
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
190 }] |
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
191 |
1015
4d80718a47e5
ledoutput support for piNode
drewp <drewp@bigasterisk.com>
parents:
1014
diff
changeset
|
192 |
4d80718a47e5
ledoutput support for piNode
drewp <drewp@bigasterisk.com>
parents:
1014
diff
changeset
|
193 @register |
1026
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
194 class TempHumidSensor(DeviceType): |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
195 deviceType = ROOM['TempHumidSensor'] |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
196 |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
197 def __init__(self, *a, **kw): |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
198 DeviceType.__init__(self, *a, **kw) |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
199 sys.path.append('/opt/pigpio/EXAMPLES/Python/DHT22_AM2302_SENSOR') |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
200 import DHT22 |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
201 self.sensor = DHT22.sensor(self.pi, self.pinNumber) |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
202 |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
203 def poll(self): |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
204 self.sensor.trigger() |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
205 humid, tempC = self.sensor.humidity(), self.sensor.temperature() |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
206 |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
207 stmts = set() |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
208 if humid is not None: |
1037
8d1a8a96e895
more round() workarounds for mismatching literals not patching themselves out
drewp <drewp@bigasterisk.com>
parents:
1026
diff
changeset
|
209 stmts.add((self.uri, ROOM['humidity'], Literal(round(humid, 2)))) |
1026
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
210 else: |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
211 stmts.add((self.uri, RDFS['comment'], |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
212 Literal('DHT read returned None'))) |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
213 if tempC is not None: |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
214 stmts.add((self.uri, ROOM['temperatureF'], |
1037
8d1a8a96e895
more round() workarounds for mismatching literals not patching themselves out
drewp <drewp@bigasterisk.com>
parents:
1026
diff
changeset
|
215 # see round() note in arduinoNode/devices.py |
8d1a8a96e895
more round() workarounds for mismatching literals not patching themselves out
drewp <drewp@bigasterisk.com>
parents:
1026
diff
changeset
|
216 Literal(round(tempC * 9 / 5 + 32, 2)))) |
1026
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
217 else: |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
218 stmts.add((self.uri, RDFS['comment'], |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
219 Literal('DHT read returned None'))) |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
220 return stmts |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
221 |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
222 def watchPrefixes(self): |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
223 return [ |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
224 (self.uri, ROOM['temperatureF']), |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
225 (self.uri, ROOM['humidity']), |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
226 ] |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
227 |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
228 @register |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
229 class OneWire(DeviceType): |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
230 """ |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
231 Also see /my/proj/ansible/roles/raspi_io_node/tasks/main.yml for |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
232 some system config that contains the pin number that you want to |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
233 use for onewire. The pin number in this config is currently ignored. |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
234 """ |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
235 deviceType = ROOM['OneWire'] |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
236 # deliberately written like arduinoNode's one for an easier merge. |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
237 def __init__(self, *a, **kw): |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
238 DeviceType.__init__(self, *a, **kw) |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
239 log.info("scan for w1 devices") |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
240 self._sensors = w1thermsensor.W1ThermSensor.get_available_sensors() |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
241 for s in self._sensors: |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
242 # Something looks different about these ids |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
243 # ('000003a5a94c') vs the ones I get from arduino |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
244 # ('2813bea50300003d'). Not sure if I'm parsing them |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
245 # differently or what. |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
246 s.uri = URIRef(os.path.join(self.uri, 'dev-%s' % s.id)) |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
247 log.info(' found temperature sensor %s' % s.uri) |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
248 |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
249 def poll(self): |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
250 try: |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
251 stmts = [] |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
252 for sensor in self._sensors: |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
253 stmts.append((self.uri, ROOM['connectedTo'], sensor.uri)) |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
254 try: |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
255 tempF = sensor.get_temperature(sensor.DEGREES_F) |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
256 stmts.append((sensor.uri, ROOM['temperatureF'], |
1037
8d1a8a96e895
more round() workarounds for mismatching literals not patching themselves out
drewp <drewp@bigasterisk.com>
parents:
1026
diff
changeset
|
257 # see round() note in arduinoNode/devices.py |
8d1a8a96e895
more round() workarounds for mismatching literals not patching themselves out
drewp <drewp@bigasterisk.com>
parents:
1026
diff
changeset
|
258 Literal(round(tempF, 2)))) |
1026
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
259 except w1thermsensor.core.SensorNotReadyError as e: |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
260 log.warning(e) |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
261 |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
262 return stmts |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
263 except Exception as e: |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
264 log.error(e) |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
265 os.abort() |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
266 |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
267 def watchPrefixes(self): |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
268 return [(s.uri, ROOM['temperatureF']) for s in self._sensors] |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
269 |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
270 |
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
271 @register |
1015
4d80718a47e5
ledoutput support for piNode
drewp <drewp@bigasterisk.com>
parents:
1014
diff
changeset
|
272 class LedOutput(DeviceType): |
4d80718a47e5
ledoutput support for piNode
drewp <drewp@bigasterisk.com>
parents:
1014
diff
changeset
|
273 deviceType = ROOM['LedOutput'] |
4d80718a47e5
ledoutput support for piNode
drewp <drewp@bigasterisk.com>
parents:
1014
diff
changeset
|
274 |
4d80718a47e5
ledoutput support for piNode
drewp <drewp@bigasterisk.com>
parents:
1014
diff
changeset
|
275 def setup(self): |
4d80718a47e5
ledoutput support for piNode
drewp <drewp@bigasterisk.com>
parents:
1014
diff
changeset
|
276 self.pi.set_mode(self.pinNumber, pigpio.OUTPUT) |
4d80718a47e5
ledoutput support for piNode
drewp <drewp@bigasterisk.com>
parents:
1014
diff
changeset
|
277 self.pi.set_PWM_frequency(self.pinNumber, 200) |
4d80718a47e5
ledoutput support for piNode
drewp <drewp@bigasterisk.com>
parents:
1014
diff
changeset
|
278 self.pi.set_PWM_dutycycle(self.pinNumber, 0) |
4d80718a47e5
ledoutput support for piNode
drewp <drewp@bigasterisk.com>
parents:
1014
diff
changeset
|
279 |
4d80718a47e5
ledoutput support for piNode
drewp <drewp@bigasterisk.com>
parents:
1014
diff
changeset
|
280 def outputPatterns(self): |
4d80718a47e5
ledoutput support for piNode
drewp <drewp@bigasterisk.com>
parents:
1014
diff
changeset
|
281 return [(self.uri, ROOM['brightness'], None)] |
4d80718a47e5
ledoutput support for piNode
drewp <drewp@bigasterisk.com>
parents:
1014
diff
changeset
|
282 |
4d80718a47e5
ledoutput support for piNode
drewp <drewp@bigasterisk.com>
parents:
1014
diff
changeset
|
283 def sendOutput(self, statements): |
4d80718a47e5
ledoutput support for piNode
drewp <drewp@bigasterisk.com>
parents:
1014
diff
changeset
|
284 assert len(statements) == 1 |
4d80718a47e5
ledoutput support for piNode
drewp <drewp@bigasterisk.com>
parents:
1014
diff
changeset
|
285 assert statements[0][:2] == (self.uri, ROOM['brightness']) |
4d80718a47e5
ledoutput support for piNode
drewp <drewp@bigasterisk.com>
parents:
1014
diff
changeset
|
286 v = int(float(statements[0][2]) * 255) |
4d80718a47e5
ledoutput support for piNode
drewp <drewp@bigasterisk.com>
parents:
1014
diff
changeset
|
287 self.pi.set_PWM_dutycycle(self.pinNumber, v) |
4d80718a47e5
ledoutput support for piNode
drewp <drewp@bigasterisk.com>
parents:
1014
diff
changeset
|
288 |
4d80718a47e5
ledoutput support for piNode
drewp <drewp@bigasterisk.com>
parents:
1014
diff
changeset
|
289 def outputWidgets(self): |
4d80718a47e5
ledoutput support for piNode
drewp <drewp@bigasterisk.com>
parents:
1014
diff
changeset
|
290 return [{ |
4d80718a47e5
ledoutput support for piNode
drewp <drewp@bigasterisk.com>
parents:
1014
diff
changeset
|
291 'element': 'output-slider', |
4d80718a47e5
ledoutput support for piNode
drewp <drewp@bigasterisk.com>
parents:
1014
diff
changeset
|
292 'min': 0, |
4d80718a47e5
ledoutput support for piNode
drewp <drewp@bigasterisk.com>
parents:
1014
diff
changeset
|
293 'max': 1, |
4d80718a47e5
ledoutput support for piNode
drewp <drewp@bigasterisk.com>
parents:
1014
diff
changeset
|
294 'step': 1 / 255, |
4d80718a47e5
ledoutput support for piNode
drewp <drewp@bigasterisk.com>
parents:
1014
diff
changeset
|
295 'subj': self.uri, |
4d80718a47e5
ledoutput support for piNode
drewp <drewp@bigasterisk.com>
parents:
1014
diff
changeset
|
296 'pred': ROOM['brightness'], |
4d80718a47e5
ledoutput support for piNode
drewp <drewp@bigasterisk.com>
parents:
1014
diff
changeset
|
297 }] |
4d80718a47e5
ledoutput support for piNode
drewp <drewp@bigasterisk.com>
parents:
1014
diff
changeset
|
298 |
4d80718a47e5
ledoutput support for piNode
drewp <drewp@bigasterisk.com>
parents:
1014
diff
changeset
|
299 |
1010 | 300 @register |
301 class OnboardTemperature(DeviceType): | |
302 deviceType = ROOM['OnboardTemperature'] | |
303 @classmethod | |
304 def findInstances(cls, graph, board, pi): | |
1012 | 305 for row in graph.query('''SELECT DISTINCT ?uri WHERE { |
1010 | 306 ?board :onboardDevice ?uri . |
307 ?uri a :OnboardTemperature . | |
1026
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
308 }''', initBindings=dict(board=board)): |
1010 | 309 yield cls(graph, row.uri, pi, pinNumber=None) |
310 | |
1013 | 311 def poll(self): |
1010 | 312 milliC = open('/sys/class/thermal/thermal_zone0/temp').read().strip() |
313 c = float(milliC) / 1000. | |
314 f = c * 1.8 + 32 | |
315 return [ | |
316 (self.uri, ROOM['temperatureF'], Literal(f, datatype=XSD['decimal'])), | |
317 ] | |
318 | |
319 def watchPrefixes(self): | |
320 # these uris will become dynamic! see note on watchPrefixes | |
321 # about eliminating it. | |
322 return [(self.uri, ROOM['temperatureF']), | |
323 ] | |
324 | |
987 | 325 def makeDevices(graph, board, pi): |
326 out = [] | |
327 for dt in sorted(_knownTypes, key=lambda cls: cls.__name__): | |
328 out.extend(dt.findInstances(graph, board, pi)) | |
329 return out | |
330 |