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