Mercurial > code > home > repos > homeauto
annotate service/piNode/devices.py @ 1432:ff868a0abac7
add pytype dockerfile
Ignore-this: b32fd623ecc2a0e1ce400e80c077c33f
darcs-hash:f05b73e7a21c46fe2ce9e4d6cda9fa0f1f7904d2
| author | drewp <drewp@bigasterisk.com> |
|---|---|
| date | Sat, 10 Aug 2019 23:44:17 -0700 |
| parents | 262ad47a9743 |
| children | 42dab8c6200a |
| rev | line source |
|---|---|
|
1109
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
1 """ |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
2 https://github.com/juniorug/libsensorPy is a similar project |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
3 """ |
| 987 | 4 from __future__ import division |
|
988
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
5 |
|
1026
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
6 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
|
7 from rdflib import Namespace, URIRef, Literal |
|
1392
83043957c809
pinode devs can now poll in parallel (within one poll step). doesn't help much.
drewp <drewp@bigasterisk.com>
parents:
1210
diff
changeset
|
8 from twisted.internet import reactor, threads |
|
83043957c809
pinode devs can now poll in parallel (within one poll step). doesn't help much.
drewp <drewp@bigasterisk.com>
parents:
1210
diff
changeset
|
9 from twisted.internet.defer import inlineCallbacks, returnValue |
|
83043957c809
pinode devs can now poll in parallel (within one poll step). doesn't help much.
drewp <drewp@bigasterisk.com>
parents:
1210
diff
changeset
|
10 from greplin import scales |
| 987 | 11 |
|
1136
1e43ec4a5f23
build and import updates for rdfdb, etc
drewp <drewp@bigasterisk.com>
parents:
1129
diff
changeset
|
12 from devices_shared import RgbPixelsAnimation |
|
1e43ec4a5f23
build and import updates for rdfdb, etc
drewp <drewp@bigasterisk.com>
parents:
1129
diff
changeset
|
13 |
|
1e43ec4a5f23
build and import updates for rdfdb, etc
drewp <drewp@bigasterisk.com>
parents:
1129
diff
changeset
|
14 log = logging.getLogger() |
|
1e43ec4a5f23
build and import updates for rdfdb, etc
drewp <drewp@bigasterisk.com>
parents:
1129
diff
changeset
|
15 ROOM = Namespace('http://projects.bigasterisk.com/room/') |
|
1e43ec4a5f23
build and import updates for rdfdb, etc
drewp <drewp@bigasterisk.com>
parents:
1129
diff
changeset
|
16 XSD = Namespace('http://www.w3.org/2001/XMLSchema#') |
|
1e43ec4a5f23
build and import updates for rdfdb, etc
drewp <drewp@bigasterisk.com>
parents:
1129
diff
changeset
|
17 RDFS = Namespace('http://www.w3.org/2000/01/rdf-schema#') |
|
1e43ec4a5f23
build and import updates for rdfdb, etc
drewp <drewp@bigasterisk.com>
parents:
1129
diff
changeset
|
18 |
|
988
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
19 try: |
|
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
20 import pigpio |
|
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
21 except ImportError: |
|
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
22 pigpio = None |
|
1143
d1bc88f67969
RgbPixelsAnimation and docker build updates
drewp <drewp@bigasterisk.com>
parents:
1136
diff
changeset
|
23 try: |
|
d1bc88f67969
RgbPixelsAnimation and docker build updates
drewp <drewp@bigasterisk.com>
parents:
1136
diff
changeset
|
24 import rpi_ws281x |
|
d1bc88f67969
RgbPixelsAnimation and docker build updates
drewp <drewp@bigasterisk.com>
parents:
1136
diff
changeset
|
25 except ImportError: |
|
d1bc88f67969
RgbPixelsAnimation and docker build updates
drewp <drewp@bigasterisk.com>
parents:
1136
diff
changeset
|
26 rpi_ws281x = None |
|
1071
9a8897fac103
neopixel lib change. factor out pwm setup and try another pwm rate
drewp <drewp@bigasterisk.com>
parents:
1067
diff
changeset
|
27 |
|
9a8897fac103
neopixel lib change. factor out pwm setup and try another pwm rate
drewp <drewp@bigasterisk.com>
parents:
1067
diff
changeset
|
28 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
|
29 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
|
30 # 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
|
31 # 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
|
32 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
|
33 if actual != hz: |
|
9a8897fac103
neopixel lib change. factor out pwm setup and try another pwm rate
drewp <drewp@bigasterisk.com>
parents:
1067
diff
changeset
|
34 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
|
35 pi.set_PWM_dutycycle(pinNumber, 0) |
|
1064
d29b9212c4c5
add support for rgb leds on rpi
drewp <drewp@bigasterisk.com>
parents:
1059
diff
changeset
|
36 |
| 987 | 37 |
| 38 class DeviceType(object): | |
|
1026
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
39 deviceType = NotImplementedError |
| 987 | 40 @classmethod |
| 41 def findInstances(cls, graph, board, pi): | |
| 42 """ | |
| 43 return any number of instances of this class for all the separately | |
| 44 controlled devices on the board. Two LEDS makes two instances, | |
| 45 but two sensors on the same onewire bus makes only one device | |
| 46 (which yields more statements). | |
| 47 """ | |
|
1026
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
48 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
|
49 for row in graph.query("""SELECT ?dev ?gpioNumber WHERE { |
| 987 | 50 ?board :hasPin ?pin . |
|
988
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
51 ?pin :gpioNumber ?gpioNumber; |
| 987 | 52 :connectedTo ?dev . |
| 53 ?dev a ?thisType . | |
| 54 } ORDER BY ?dev""", | |
| 55 initBindings=dict(board=board, | |
|
1026
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
56 thisType=cls.deviceType)): |
|
988
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
57 yield cls(graph, row.dev, pi, int(row.gpioNumber)) |
| 987 | 58 |
| 59 def __init__(self, graph, uri, pi, pinNumber): | |
| 60 self.graph, self.uri, self.pi = graph, uri, pi | |
| 61 self.pinNumber = pinNumber | |
|
1428
56e07d3f0930
frontdoor configs; move device class timing to greplin stats
drewp <drewp@bigasterisk.com>
parents:
1427
diff
changeset
|
62 scales.init(self, self.__class__.__name__) |
|
56e07d3f0930
frontdoor configs; move device class timing to greplin stats
drewp <drewp@bigasterisk.com>
parents:
1427
diff
changeset
|
63 self.stats = scales.collection(self.__class__.__name__, |
|
56e07d3f0930
frontdoor configs; move device class timing to greplin stats
drewp <drewp@bigasterisk.com>
parents:
1427
diff
changeset
|
64 scales.PmfStat('poll'), |
|
56e07d3f0930
frontdoor configs; move device class timing to greplin stats
drewp <drewp@bigasterisk.com>
parents:
1427
diff
changeset
|
65 scales.PmfStat('output'), |
|
56e07d3f0930
frontdoor configs; move device class timing to greplin stats
drewp <drewp@bigasterisk.com>
parents:
1427
diff
changeset
|
66 ) |
|
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
|
67 self.hostStateInit() |
| 987 | 68 |
|
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
|
69 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
|
70 """ |
|
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
|
71 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
|
72 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
|
73 """ |
| 1427 | 74 |
| 987 | 75 def description(self): |
| 76 return { | |
| 77 'uri': self.uri, | |
| 78 'className': self.__class__.__name__, | |
|
988
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
79 'pinNumber': getattr(self, 'pinNumber', None), |
| 987 | 80 'outputPatterns': self.outputPatterns(), |
| 81 'watchPrefixes': self.watchPrefixes(), | |
| 82 'outputWidgets': self.outputWidgets(), | |
| 83 } | |
| 84 | |
|
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
|
85 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
|
86 """ |
|
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
|
87 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
|
88 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
|
89 (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
|
90 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
|
91 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
|
92 """ |
|
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
|
93 return [] |
| 1427 | 94 |
| 987 | 95 def watchPrefixes(self): |
| 96 """ | |
| 97 subj,pred pairs of the statements that might be returned from | |
| 98 readFromPoll, so the dashboard knows what it should | |
| 99 watch. This should be eliminated, as the dashboard should just | |
| 100 always watch the whole tree of statements starting self.uri | |
| 101 """ | |
| 102 return [] | |
| 103 | |
| 104 def poll(self): | |
| 105 return [] # statements | |
| 1427 | 106 |
| 987 | 107 def outputPatterns(self): |
| 108 """ | |
| 109 Triple patterns, using None as a wildcard, that should be routed | |
| 110 to sendOutput | |
| 111 """ | |
| 112 return [] | |
| 113 | |
| 114 def outputWidgets(self): | |
| 115 """ | |
| 116 structs to make output widgets on the dashboard. ~1 of these per | |
| 117 handler you have in sendOutput | |
| 118 """ | |
| 119 return [] | |
| 1427 | 120 |
| 987 | 121 def sendOutput(self, statements): |
| 122 """ | |
| 123 If we got statements that match this class's outputPatterns, this | |
| 1427 | 124 will be called with the statements that matched. |
| 987 | 125 |
| 126 Todo: it would be fine to read back confirmations or | |
| 127 whatever. Just need a way to collect them into graph statements. | |
| 128 """ | |
| 129 raise NotImplementedError | |
| 1427 | 130 |
| 987 | 131 _knownTypes = set() |
| 132 def register(deviceType): | |
| 133 _knownTypes.add(deviceType) | |
| 134 return deviceType | |
| 135 | |
|
1429
262ad47a9743
try to workaround pigpio not supporting pullup modes on pi4 yet (didn't work, I think)
drewp <drewp@bigasterisk.com>
parents:
1428
diff
changeset
|
136 def setPud(pi, pinNumber, p): |
|
262ad47a9743
try to workaround pigpio not supporting pullup modes on pi4 yet (didn't work, I think)
drewp <drewp@bigasterisk.com>
parents:
1428
diff
changeset
|
137 import socket |
|
262ad47a9743
try to workaround pigpio not supporting pullup modes on pi4 yet (didn't work, I think)
drewp <drewp@bigasterisk.com>
parents:
1428
diff
changeset
|
138 if socket.gethostname() == 'frontdoor': |
|
262ad47a9743
try to workaround pigpio not supporting pullup modes on pi4 yet (didn't work, I think)
drewp <drewp@bigasterisk.com>
parents:
1428
diff
changeset
|
139 log.warn( |
|
262ad47a9743
try to workaround pigpio not supporting pullup modes on pi4 yet (didn't work, I think)
drewp <drewp@bigasterisk.com>
parents:
1428
diff
changeset
|
140 'pud currently broken on pi4, using RPi.GPIO.' |
|
262ad47a9743
try to workaround pigpio not supporting pullup modes on pi4 yet (didn't work, I think)
drewp <drewp@bigasterisk.com>
parents:
1428
diff
changeset
|
141 ' https://github.com/joan2937/pigpio/issues/278#issuecomment-506650549', |
|
262ad47a9743
try to workaround pigpio not supporting pullup modes on pi4 yet (didn't work, I think)
drewp <drewp@bigasterisk.com>
parents:
1428
diff
changeset
|
142 ) |
|
262ad47a9743
try to workaround pigpio not supporting pullup modes on pi4 yet (didn't work, I think)
drewp <drewp@bigasterisk.com>
parents:
1428
diff
changeset
|
143 import RPi.GPIO as GPIO |
|
262ad47a9743
try to workaround pigpio not supporting pullup modes on pi4 yet (didn't work, I think)
drewp <drewp@bigasterisk.com>
parents:
1428
diff
changeset
|
144 GPIO.setmode(GPIO.BCM) |
|
262ad47a9743
try to workaround pigpio not supporting pullup modes on pi4 yet (didn't work, I think)
drewp <drewp@bigasterisk.com>
parents:
1428
diff
changeset
|
145 GPIO.setup(pinNumber, GPIO.IN, pull_up_down={pigpio.PUD_UP:GPIO.PUD_UP,pigpio.PUD_DOWN:GPIO.PUD_DOWN}[p]) |
|
262ad47a9743
try to workaround pigpio not supporting pullup modes on pi4 yet (didn't work, I think)
drewp <drewp@bigasterisk.com>
parents:
1428
diff
changeset
|
146 log.warn(' RPi.GPIO says pin %s is %r', pinNumber, GPIO.input(pinNumber)) |
|
262ad47a9743
try to workaround pigpio not supporting pullup modes on pi4 yet (didn't work, I think)
drewp <drewp@bigasterisk.com>
parents:
1428
diff
changeset
|
147 return |
|
262ad47a9743
try to workaround pigpio not supporting pullup modes on pi4 yet (didn't work, I think)
drewp <drewp@bigasterisk.com>
parents:
1428
diff
changeset
|
148 pi.set_pull_up_down(pinNumber, p) |
|
262ad47a9743
try to workaround pigpio not supporting pullup modes on pi4 yet (didn't work, I think)
drewp <drewp@bigasterisk.com>
parents:
1428
diff
changeset
|
149 |
| 987 | 150 @register |
| 151 class MotionSensorInput(DeviceType): | |
|
1095
870d1bbae402
more motion sensor statements
drewp <drewp@bigasterisk.com>
parents:
1094
diff
changeset
|
152 """ |
|
1210
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
153 Triggering all the time? Try 5V VCC, per https://electronics.stackexchange.com/a/416295 |
| 1427 | 154 |
|
1095
870d1bbae402
more motion sensor statements
drewp <drewp@bigasterisk.com>
parents:
1094
diff
changeset
|
155 0 30s 60s 90s 10min |
| 1427 | 156 | | | | ... | |
|
1095
870d1bbae402
more motion sensor statements
drewp <drewp@bigasterisk.com>
parents:
1094
diff
changeset
|
157 Sensor input ******** ** ******* **** |
|
870d1bbae402
more motion sensor statements
drewp <drewp@bigasterisk.com>
parents:
1094
diff
changeset
|
158 :sees output ........ .. ....... .... |
|
870d1bbae402
more motion sensor statements
drewp <drewp@bigasterisk.com>
parents:
1094
diff
changeset
|
159 :seesRecently ............................................................. |
|
870d1bbae402
more motion sensor statements
drewp <drewp@bigasterisk.com>
parents:
1094
diff
changeset
|
160 :seesRecently30 .................................... |
|
870d1bbae402
more motion sensor statements
drewp <drewp@bigasterisk.com>
parents:
1094
diff
changeset
|
161 :motionStart x x x x |
|
870d1bbae402
more motion sensor statements
drewp <drewp@bigasterisk.com>
parents:
1094
diff
changeset
|
162 :motionStart30 x x |
|
870d1bbae402
more motion sensor statements
drewp <drewp@bigasterisk.com>
parents:
1094
diff
changeset
|
163 """ |
|
870d1bbae402
more motion sensor statements
drewp <drewp@bigasterisk.com>
parents:
1094
diff
changeset
|
164 # compare motion sensor lib at |
|
870d1bbae402
more motion sensor statements
drewp <drewp@bigasterisk.com>
parents:
1094
diff
changeset
|
165 # https://gpiozero.readthedocs.org/en/v1.2.0/api_input.html#motion-sensor-d-sun-pir |
|
1026
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
166 # which is a bit fancier |
| 987 | 167 deviceType = ROOM['MotionSensor'] |
| 168 | |
|
1109
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
169 def __init__(self, graph, uri, pi, pinNumber): |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
170 super(MotionSensorInput, self).__init__(graph, uri, pi, pinNumber) |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
171 self.pi.set_mode(pinNumber, pigpio.INPUT) |
|
1429
262ad47a9743
try to workaround pigpio not supporting pullup modes on pi4 yet (didn't work, I think)
drewp <drewp@bigasterisk.com>
parents:
1428
diff
changeset
|
172 setPud(self.pi, pinNumber, pigpio.PUD_DOWN) |
| 987 | 173 |
|
1059
faf1f8677a91
pi device support for motionStart edge trigger
drewp <drewp@bigasterisk.com>
parents:
1056
diff
changeset
|
174 def hostStateInit(self): |
|
faf1f8677a91
pi device support for motionStart edge trigger
drewp <drewp@bigasterisk.com>
parents:
1056
diff
changeset
|
175 self.lastRead = None |
|
1095
870d1bbae402
more motion sensor statements
drewp <drewp@bigasterisk.com>
parents:
1094
diff
changeset
|
176 self.lastMotionStart30 = 0 |
|
870d1bbae402
more motion sensor statements
drewp <drewp@bigasterisk.com>
parents:
1094
diff
changeset
|
177 self.lastMotionStart90 = 0 |
|
1059
faf1f8677a91
pi device support for motionStart edge trigger
drewp <drewp@bigasterisk.com>
parents:
1056
diff
changeset
|
178 |
| 987 | 179 def poll(self): |
|
1109
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
180 motion = self.pi.read(self.pinNumber) |
|
1095
870d1bbae402
more motion sensor statements
drewp <drewp@bigasterisk.com>
parents:
1094
diff
changeset
|
181 now = time.time() |
| 1427 | 182 |
|
1059
faf1f8677a91
pi device support for motionStart edge trigger
drewp <drewp@bigasterisk.com>
parents:
1056
diff
changeset
|
183 oneshot = [] |
|
faf1f8677a91
pi device support for motionStart edge trigger
drewp <drewp@bigasterisk.com>
parents:
1056
diff
changeset
|
184 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
|
185 oneshot = [(self.uri, ROOM['sees'], ROOM['motionStart'])] |
|
1095
870d1bbae402
more motion sensor statements
drewp <drewp@bigasterisk.com>
parents:
1094
diff
changeset
|
186 for v, t in [('lastMotionStart30', 30), ('lastMotionStart90', 90)]: |
|
870d1bbae402
more motion sensor statements
drewp <drewp@bigasterisk.com>
parents:
1094
diff
changeset
|
187 if now - getattr(self, v) > t: |
|
870d1bbae402
more motion sensor statements
drewp <drewp@bigasterisk.com>
parents:
1094
diff
changeset
|
188 oneshot.append((self.uri, ROOM['sees'], ROOM['motionStart%s' % t])) |
|
870d1bbae402
more motion sensor statements
drewp <drewp@bigasterisk.com>
parents:
1094
diff
changeset
|
189 setattr(self, v, now) |
|
1059
faf1f8677a91
pi device support for motionStart edge trigger
drewp <drewp@bigasterisk.com>
parents:
1056
diff
changeset
|
190 self.lastRead = motion |
| 1427 | 191 |
|
1056
d2007482aec5
start sending oneshot events from some devices
drewp <drewp@bigasterisk.com>
parents:
1049
diff
changeset
|
192 return {'latest': [ |
| 987 | 193 (self.uri, ROOM['sees'], |
| 194 ROOM['motion'] if motion else ROOM['noMotion']), | |
|
1095
870d1bbae402
more motion sensor statements
drewp <drewp@bigasterisk.com>
parents:
1094
diff
changeset
|
195 ] + self.recentMotionStatements(now, motion), |
| 1072 | 196 'oneshot': oneshot} |
| 987 | 197 |
|
1095
870d1bbae402
more motion sensor statements
drewp <drewp@bigasterisk.com>
parents:
1094
diff
changeset
|
198 def recentMotionStatements(self, now, motion): |
| 987 | 199 if not hasattr(self, 'lastMotionTime'): |
| 200 self.lastMotionTime = 0 | |
| 201 if motion: | |
| 202 self.lastMotionTime = now | |
| 1072 | 203 dt = now - self.lastMotionTime |
| 204 return [(self.uri, ROOM['seesRecently'], | |
| 205 ROOM['motion'] if (dt < 60 * 10) else ROOM['noMotion']), | |
| 206 (self.uri, ROOM['seesRecently30'], | |
| 207 ROOM['motion'] if (dt < 30) else ROOM['noMotion'])] | |
| 1427 | 208 |
| 987 | 209 def watchPrefixes(self): |
| 210 return [ | |
| 211 (self.uri, ROOM['sees']), | |
| 212 (self.uri, ROOM['seesRecently']), | |
| 1072 | 213 (self.uri, ROOM['seesRecently30']), |
| 987 | 214 ] |
| 215 | |
|
988
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
216 |
|
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
217 @register |
|
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
218 class RgbStrip(DeviceType): |
| 1025 | 219 """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
|
220 # pigpio daemon is working fine, but |
|
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
221 # 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
|
222 # can also apparently do PWM |
|
988
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
223 deviceType = ROOM['RgbStrip'] |
| 1427 | 224 |
|
988
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
225 @classmethod |
|
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
226 def findInstances(cls, graph, board, pi): |
|
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
227 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
|
228 ?board |
|
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
229 :hasPin ?rpin; |
|
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
230 :hasPin ?gpin; |
|
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
231 :hasPin ?bpin . |
|
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
232 ?dev a :RgbStrip; |
|
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
233 :redChannel ?rpin; |
|
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
234 :greenChannel ?gpin; |
|
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
235 :blueChannel ?bpin . |
|
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
236 ?rpin :gpioNumber ?r . |
|
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
237 ?gpin :gpioNumber ?g . |
|
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
238 ?bpin :gpioNumber ?b . |
|
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
239 } ORDER BY ?dev""", |
|
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
240 initBindings=dict(board=board), |
|
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
241 initNs={'': ROOM}): |
|
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
242 log.debug('found rgb %r', row) |
|
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
243 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
|
244 |
|
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
245 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
|
246 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
|
247 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
|
248 self.value = '#000000' |
| 1427 | 249 |
|
988
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
250 def setup(self): |
|
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
251 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
|
252 setupPwm(self.pi, i) |
| 1427 | 253 |
|
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
|
254 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
|
255 return [(self.uri, ROOM['color'], Literal(self.value))] |
| 1427 | 256 |
|
988
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
257 def outputPatterns(self): |
|
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
258 return [(self.uri, ROOM['color'], None)] |
| 1025 | 259 |
| 260 def _rgbFromHex(self, h): | |
| 261 rrggbb = h.lstrip('#') | |
| 262 return [int(x, 16) for x in [rrggbb[0:2], rrggbb[2:4], rrggbb[4:6]]] | |
| 1427 | 263 |
|
988
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
264 def sendOutput(self, statements): |
|
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
265 assert len(statements) == 1 |
|
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
266 assert statements[0][:2] == (self.uri, ROOM['color']) |
|
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
267 |
| 1025 | 268 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
|
269 self.value = statements[0][2] |
|
988
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
270 |
|
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
271 for (i, v) in zip(self.rgb, rgb): |
|
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
272 self.pi.set_PWM_dutycycle(i, v) |
| 1427 | 273 |
|
988
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
274 def outputWidgets(self): |
|
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
275 return [{ |
|
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
276 'element': 'output-rgb', |
|
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
277 'subj': self.uri, |
|
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
278 'pred': ROOM['color'], |
|
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
279 }] |
|
63c172316239
get piNode working, for motionsensor at least
drewp <drewp@bigasterisk.com>
parents:
987
diff
changeset
|
280 |
|
1015
4d80718a47e5
ledoutput support for piNode
drewp <drewp@bigasterisk.com>
parents:
1014
diff
changeset
|
281 |
|
4d80718a47e5
ledoutput support for piNode
drewp <drewp@bigasterisk.com>
parents:
1014
diff
changeset
|
282 @register |
|
1026
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
283 class TempHumidSensor(DeviceType): |
|
1210
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
284 """ |
|
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
285 AM2302/DHT22 pinout is vcc-data-nc-gnd. VCC to 3.3V. Add 10k pullup on data. |
|
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
286 """ |
|
1026
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
287 deviceType = ROOM['TempHumidSensor'] |
|
1109
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
288 pollPeriod = 5 |
|
1026
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
289 |
|
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
290 def __init__(self, *a, **kw): |
|
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
291 DeviceType.__init__(self, *a, **kw) |
|
1150
2b3079126b81
switch to pigpio for reading DHT sensor
drewp <drewp@bigasterisk.com>
parents:
1143
diff
changeset
|
292 import DHT22 |
|
2b3079126b81
switch to pigpio for reading DHT sensor
drewp <drewp@bigasterisk.com>
parents:
1143
diff
changeset
|
293 self.sens = DHT22.sensor(self.pi, self.pinNumber) |
|
1172
d9abb93515c2
kitchen button, device code fixes
drewp <drewp@bigasterisk.com>
parents:
1150
diff
changeset
|
294 self.recentLowTemp = (0, None) # time, temp |
|
d9abb93515c2
kitchen button, device code fixes
drewp <drewp@bigasterisk.com>
parents:
1150
diff
changeset
|
295 self.recentPeriodSec = 30 |
| 1427 | 296 |
|
1026
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
297 def poll(self): |
|
1150
2b3079126b81
switch to pigpio for reading DHT sensor
drewp <drewp@bigasterisk.com>
parents:
1143
diff
changeset
|
298 stmts = set() |
|
1026
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
299 |
|
1172
d9abb93515c2
kitchen button, device code fixes
drewp <drewp@bigasterisk.com>
parents:
1150
diff
changeset
|
300 now = time.time() |
|
d9abb93515c2
kitchen button, device code fixes
drewp <drewp@bigasterisk.com>
parents:
1150
diff
changeset
|
301 if self.recentLowTemp[0] < now - self.recentPeriodSec: |
|
d9abb93515c2
kitchen button, device code fixes
drewp <drewp@bigasterisk.com>
parents:
1150
diff
changeset
|
302 self.recentLowTemp = (0, None) |
|
d9abb93515c2
kitchen button, device code fixes
drewp <drewp@bigasterisk.com>
parents:
1150
diff
changeset
|
303 |
|
1150
2b3079126b81
switch to pigpio for reading DHT sensor
drewp <drewp@bigasterisk.com>
parents:
1143
diff
changeset
|
304 if self.sens.staleness() < self.pollPeriod * 2: |
|
2b3079126b81
switch to pigpio for reading DHT sensor
drewp <drewp@bigasterisk.com>
parents:
1143
diff
changeset
|
305 humid, tempC = self.sens.humidity(), self.sens.temperature() |
|
2b3079126b81
switch to pigpio for reading DHT sensor
drewp <drewp@bigasterisk.com>
parents:
1143
diff
changeset
|
306 if humid > -999: |
|
2b3079126b81
switch to pigpio for reading DHT sensor
drewp <drewp@bigasterisk.com>
parents:
1143
diff
changeset
|
307 stmts.add((self.uri, ROOM['humidity'], Literal(round(humid, 2)))) |
|
2b3079126b81
switch to pigpio for reading DHT sensor
drewp <drewp@bigasterisk.com>
parents:
1143
diff
changeset
|
308 else: |
|
2b3079126b81
switch to pigpio for reading DHT sensor
drewp <drewp@bigasterisk.com>
parents:
1143
diff
changeset
|
309 stmts.add((self.uri, RDFS['comment'], Literal('No recent humidity measurement'))) |
|
2b3079126b81
switch to pigpio for reading DHT sensor
drewp <drewp@bigasterisk.com>
parents:
1143
diff
changeset
|
310 if tempC > -999: |
|
1172
d9abb93515c2
kitchen button, device code fixes
drewp <drewp@bigasterisk.com>
parents:
1150
diff
changeset
|
311 # see round() note in arduinoNode/devices.py |
|
d9abb93515c2
kitchen button, device code fixes
drewp <drewp@bigasterisk.com>
parents:
1150
diff
changeset
|
312 tempF = round(tempC * 9 / 5 + 32, 2) |
|
d9abb93515c2
kitchen button, device code fixes
drewp <drewp@bigasterisk.com>
parents:
1150
diff
changeset
|
313 stmts.add((self.uri, ROOM['temperatureF'], Literal(tempF))) |
|
d9abb93515c2
kitchen button, device code fixes
drewp <drewp@bigasterisk.com>
parents:
1150
diff
changeset
|
314 if self.recentLowTemp[1] is None or tempF < self.recentLowTemp[1]: |
|
d9abb93515c2
kitchen button, device code fixes
drewp <drewp@bigasterisk.com>
parents:
1150
diff
changeset
|
315 self.recentLowTemp = (now, tempF) |
|
1150
2b3079126b81
switch to pigpio for reading DHT sensor
drewp <drewp@bigasterisk.com>
parents:
1143
diff
changeset
|
316 else: |
|
2b3079126b81
switch to pigpio for reading DHT sensor
drewp <drewp@bigasterisk.com>
parents:
1143
diff
changeset
|
317 stmts.add((self.uri, RDFS['comment'], Literal('No recent temperature measurement'))) |
|
1026
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
318 else: |
|
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
319 stmts.add((self.uri, RDFS['comment'], |
|
1150
2b3079126b81
switch to pigpio for reading DHT sensor
drewp <drewp@bigasterisk.com>
parents:
1143
diff
changeset
|
320 Literal('No recent DHT response (%.02f sec old)' % self.sens.staleness()))) |
|
1172
d9abb93515c2
kitchen button, device code fixes
drewp <drewp@bigasterisk.com>
parents:
1150
diff
changeset
|
321 |
|
d9abb93515c2
kitchen button, device code fixes
drewp <drewp@bigasterisk.com>
parents:
1150
diff
changeset
|
322 if self.recentLowTemp[1] is not None: |
|
d9abb93515c2
kitchen button, device code fixes
drewp <drewp@bigasterisk.com>
parents:
1150
diff
changeset
|
323 stmts.add((self.uri, ROOM['recentLowTemperatureF'], Literal(self.recentLowTemp[1]))) |
| 1427 | 324 |
|
1150
2b3079126b81
switch to pigpio for reading DHT sensor
drewp <drewp@bigasterisk.com>
parents:
1143
diff
changeset
|
325 self.sens.trigger() |
| 1427 | 326 |
|
1026
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
327 return stmts |
| 1427 | 328 |
|
1026
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
329 def watchPrefixes(self): |
|
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
330 return [ |
|
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
331 (self.uri, ROOM['temperatureF']), |
|
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
332 (self.uri, ROOM['humidity']), |
|
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
333 ] |
|
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
334 |
|
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
335 @register |
| 1049 | 336 class PushbuttonInput(DeviceType): |
| 337 """add a switch to ground; we'll turn on pullup""" | |
| 338 deviceType = ROOM['Pushbutton'] | |
| 339 | |
| 340 def __init__(self, *a, **kw): | |
| 341 DeviceType.__init__(self, *a, **kw) | |
| 342 log.debug("setup switch on %r", self.pinNumber) | |
| 343 self.pi.set_mode(self.pinNumber, pigpio.INPUT) | |
|
1429
262ad47a9743
try to workaround pigpio not supporting pullup modes on pi4 yet (didn't work, I think)
drewp <drewp@bigasterisk.com>
parents:
1428
diff
changeset
|
344 setPud(self.pi, self.pinNumber, pigpio.PUD_UP) |
|
1056
d2007482aec5
start sending oneshot events from some devices
drewp <drewp@bigasterisk.com>
parents:
1049
diff
changeset
|
345 self.lastClosed = None |
|
1067
dfb284fb025c
invert support for Pushbutton
drewp <drewp@bigasterisk.com>
parents:
1064
diff
changeset
|
346 self.invert = (self.uri, ROOM['style'], |
|
dfb284fb025c
invert support for Pushbutton
drewp <drewp@bigasterisk.com>
parents:
1064
diff
changeset
|
347 ROOM['inverted']) in self.graph |
| 1049 | 348 |
| 349 def poll(self): | |
| 350 closed = not self.pi.read(self.pinNumber) | |
|
1067
dfb284fb025c
invert support for Pushbutton
drewp <drewp@bigasterisk.com>
parents:
1064
diff
changeset
|
351 if self.invert: |
|
dfb284fb025c
invert support for Pushbutton
drewp <drewp@bigasterisk.com>
parents:
1064
diff
changeset
|
352 closed = not closed |
|
1056
d2007482aec5
start sending oneshot events from some devices
drewp <drewp@bigasterisk.com>
parents:
1049
diff
changeset
|
353 |
|
d2007482aec5
start sending oneshot events from some devices
drewp <drewp@bigasterisk.com>
parents:
1049
diff
changeset
|
354 if self.lastClosed is not None and closed != self.lastClosed: |
|
1067
dfb284fb025c
invert support for Pushbutton
drewp <drewp@bigasterisk.com>
parents:
1064
diff
changeset
|
355 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
|
356 oneshot = [ |
|
d2007482aec5
start sending oneshot events from some devices
drewp <drewp@bigasterisk.com>
parents:
1049
diff
changeset
|
357 (self.uri, ROOM['buttonState'], |
|
d2007482aec5
start sending oneshot events from some devices
drewp <drewp@bigasterisk.com>
parents:
1049
diff
changeset
|
358 ROOM['press'] if closed else ROOM['release']), |
|
d2007482aec5
start sending oneshot events from some devices
drewp <drewp@bigasterisk.com>
parents:
1049
diff
changeset
|
359 ] |
|
d2007482aec5
start sending oneshot events from some devices
drewp <drewp@bigasterisk.com>
parents:
1049
diff
changeset
|
360 else: |
|
d2007482aec5
start sending oneshot events from some devices
drewp <drewp@bigasterisk.com>
parents:
1049
diff
changeset
|
361 oneshot = [] |
|
d2007482aec5
start sending oneshot events from some devices
drewp <drewp@bigasterisk.com>
parents:
1049
diff
changeset
|
362 self.lastClosed = closed |
| 1427 | 363 |
|
1056
d2007482aec5
start sending oneshot events from some devices
drewp <drewp@bigasterisk.com>
parents:
1049
diff
changeset
|
364 return {'latest': [ |
| 1049 | 365 (self.uri, ROOM['buttonState'], |
| 366 ROOM['pressed'] if closed else ROOM['notPressed']), | |
|
1056
d2007482aec5
start sending oneshot events from some devices
drewp <drewp@bigasterisk.com>
parents:
1049
diff
changeset
|
367 ], |
|
d2007482aec5
start sending oneshot events from some devices
drewp <drewp@bigasterisk.com>
parents:
1049
diff
changeset
|
368 'oneshot':oneshot} |
| 1427 | 369 |
| 1049 | 370 def watchPrefixes(self): |
| 371 return [ | |
| 372 (self.uri, ROOM['buttonState']), | |
| 373 ] | |
| 1427 | 374 |
| 1049 | 375 @register |
|
1026
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
376 class OneWire(DeviceType): |
|
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
377 """ |
|
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
378 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
|
379 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
|
380 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
|
381 """ |
|
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
382 deviceType = ROOM['OneWire'] |
|
1109
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
383 pollPeriod = 2 |
|
1026
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
384 # 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
|
385 def __init__(self, *a, **kw): |
|
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
386 DeviceType.__init__(self, *a, **kw) |
|
1186
732a8861a75c
defer import of w1thermsensor
drewp <drewp@bigasterisk.com>
parents:
1173
diff
changeset
|
387 import w1thermsensor |
|
1026
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
388 log.info("scan for w1 devices") |
|
1186
732a8861a75c
defer import of w1thermsensor
drewp <drewp@bigasterisk.com>
parents:
1173
diff
changeset
|
389 self.SensorNotReadyError = w1thermsensor.core.SensorNotReadyError |
|
1210
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
390 self.ResetValueError = w1thermsensor.core.ResetValueError |
|
1026
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
391 self._sensors = w1thermsensor.W1ThermSensor.get_available_sensors() |
|
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
392 for s in self._sensors: |
|
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
393 # Something looks different about these ids |
|
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
394 # ('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
|
395 # ('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
|
396 # differently or what. |
|
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
397 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
|
398 log.info(' found temperature sensor %s' % s.uri) |
|
1392
83043957c809
pinode devs can now poll in parallel (within one poll step). doesn't help much.
drewp <drewp@bigasterisk.com>
parents:
1210
diff
changeset
|
399 |
|
83043957c809
pinode devs can now poll in parallel (within one poll step). doesn't help much.
drewp <drewp@bigasterisk.com>
parents:
1210
diff
changeset
|
400 @inlineCallbacks |
|
1026
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
401 def poll(self): |
|
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
402 try: |
|
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
403 stmts = [] |
|
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
404 for sensor in self._sensors: |
|
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
405 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
|
406 try: |
|
1392
83043957c809
pinode devs can now poll in parallel (within one poll step). doesn't help much.
drewp <drewp@bigasterisk.com>
parents:
1210
diff
changeset
|
407 tempF = yield threads.deferToThread(sensor.get_temperature, sensor.DEGREES_F) |
|
1026
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
408 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
|
409 # 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
|
410 Literal(round(tempF, 2)))) |
|
1210
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
411 except (self.SensorNotReadyError, self.ResetValueError) as e: |
|
1026
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
412 log.warning(e) |
|
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
413 |
|
1392
83043957c809
pinode devs can now poll in parallel (within one poll step). doesn't help much.
drewp <drewp@bigasterisk.com>
parents:
1210
diff
changeset
|
414 returnValue(stmts) |
|
1026
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
415 except Exception as e: |
|
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
416 log.error(e) |
|
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
417 os.abort() |
| 1427 | 418 |
|
1026
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
419 def watchPrefixes(self): |
|
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
420 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
|
421 |
|
1079
3d0133cdce90
smooth output fading support
drewp <drewp@bigasterisk.com>
parents:
1072
diff
changeset
|
422 class FilteredValue(object): |
|
3d0133cdce90
smooth output fading support
drewp <drewp@bigasterisk.com>
parents:
1072
diff
changeset
|
423 def __init__(self, setter, |
|
3d0133cdce90
smooth output fading support
drewp <drewp@bigasterisk.com>
parents:
1072
diff
changeset
|
424 slew=2.0, # step/sec max slew rate |
|
3d0133cdce90
smooth output fading support
drewp <drewp@bigasterisk.com>
parents:
1072
diff
changeset
|
425 accel=5, # step/sec^2 acceleration |
|
3d0133cdce90
smooth output fading support
drewp <drewp@bigasterisk.com>
parents:
1072
diff
changeset
|
426 ): |
|
3d0133cdce90
smooth output fading support
drewp <drewp@bigasterisk.com>
parents:
1072
diff
changeset
|
427 self.setter = setter |
|
3d0133cdce90
smooth output fading support
drewp <drewp@bigasterisk.com>
parents:
1072
diff
changeset
|
428 self.slew, self.accel = slew, accel |
| 1427 | 429 |
|
1079
3d0133cdce90
smooth output fading support
drewp <drewp@bigasterisk.com>
parents:
1072
diff
changeset
|
430 self.x = None |
|
3d0133cdce90
smooth output fading support
drewp <drewp@bigasterisk.com>
parents:
1072
diff
changeset
|
431 self.dx = 0 |
|
3d0133cdce90
smooth output fading support
drewp <drewp@bigasterisk.com>
parents:
1072
diff
changeset
|
432 self.goal = self.x |
|
3d0133cdce90
smooth output fading support
drewp <drewp@bigasterisk.com>
parents:
1072
diff
changeset
|
433 self.lastStep = 0 |
|
3d0133cdce90
smooth output fading support
drewp <drewp@bigasterisk.com>
parents:
1072
diff
changeset
|
434 |
|
3d0133cdce90
smooth output fading support
drewp <drewp@bigasterisk.com>
parents:
1072
diff
changeset
|
435 def set(self, goal): |
|
3d0133cdce90
smooth output fading support
drewp <drewp@bigasterisk.com>
parents:
1072
diff
changeset
|
436 self.goal = goal |
|
3d0133cdce90
smooth output fading support
drewp <drewp@bigasterisk.com>
parents:
1072
diff
changeset
|
437 self.step() |
|
3d0133cdce90
smooth output fading support
drewp <drewp@bigasterisk.com>
parents:
1072
diff
changeset
|
438 |
|
3d0133cdce90
smooth output fading support
drewp <drewp@bigasterisk.com>
parents:
1072
diff
changeset
|
439 def step(self): |
|
3d0133cdce90
smooth output fading support
drewp <drewp@bigasterisk.com>
parents:
1072
diff
changeset
|
440 now = time.time() |
|
3d0133cdce90
smooth output fading support
drewp <drewp@bigasterisk.com>
parents:
1072
diff
changeset
|
441 dt = min(.1, now - self.lastStep) |
|
3d0133cdce90
smooth output fading support
drewp <drewp@bigasterisk.com>
parents:
1072
diff
changeset
|
442 self.lastStep = now |
|
3d0133cdce90
smooth output fading support
drewp <drewp@bigasterisk.com>
parents:
1072
diff
changeset
|
443 |
|
3d0133cdce90
smooth output fading support
drewp <drewp@bigasterisk.com>
parents:
1072
diff
changeset
|
444 if self.x is None: |
|
3d0133cdce90
smooth output fading support
drewp <drewp@bigasterisk.com>
parents:
1072
diff
changeset
|
445 self.x = self.goal |
|
3d0133cdce90
smooth output fading support
drewp <drewp@bigasterisk.com>
parents:
1072
diff
changeset
|
446 |
|
3d0133cdce90
smooth output fading support
drewp <drewp@bigasterisk.com>
parents:
1072
diff
changeset
|
447 if self.goal > self.x: |
|
3d0133cdce90
smooth output fading support
drewp <drewp@bigasterisk.com>
parents:
1072
diff
changeset
|
448 self.dx = min(self.slew, self.dx + self.accel * dt) |
|
3d0133cdce90
smooth output fading support
drewp <drewp@bigasterisk.com>
parents:
1072
diff
changeset
|
449 else: |
|
3d0133cdce90
smooth output fading support
drewp <drewp@bigasterisk.com>
parents:
1072
diff
changeset
|
450 self.dx = max(-self.slew, self.dx - self.accel * dt) |
|
3d0133cdce90
smooth output fading support
drewp <drewp@bigasterisk.com>
parents:
1072
diff
changeset
|
451 |
|
3d0133cdce90
smooth output fading support
drewp <drewp@bigasterisk.com>
parents:
1072
diff
changeset
|
452 nextX = self.x + self.dx * dt |
|
3d0133cdce90
smooth output fading support
drewp <drewp@bigasterisk.com>
parents:
1072
diff
changeset
|
453 if self.x == self.goal or (self.x < self.goal < nextX) or (self.x > self.goal > nextX): |
|
3d0133cdce90
smooth output fading support
drewp <drewp@bigasterisk.com>
parents:
1072
diff
changeset
|
454 self.x = self.goal |
|
3d0133cdce90
smooth output fading support
drewp <drewp@bigasterisk.com>
parents:
1072
diff
changeset
|
455 self.dx = 0 |
|
3d0133cdce90
smooth output fading support
drewp <drewp@bigasterisk.com>
parents:
1072
diff
changeset
|
456 else: |
|
3d0133cdce90
smooth output fading support
drewp <drewp@bigasterisk.com>
parents:
1072
diff
changeset
|
457 self.x = nextX |
|
3d0133cdce90
smooth output fading support
drewp <drewp@bigasterisk.com>
parents:
1072
diff
changeset
|
458 reactor.callLater(.05, self.step) |
|
3d0133cdce90
smooth output fading support
drewp <drewp@bigasterisk.com>
parents:
1072
diff
changeset
|
459 |
|
3d0133cdce90
smooth output fading support
drewp <drewp@bigasterisk.com>
parents:
1072
diff
changeset
|
460 #print "x= %(x)s dx= %(dx)s goal= %(goal)s" % self.__dict__ |
|
3d0133cdce90
smooth output fading support
drewp <drewp@bigasterisk.com>
parents:
1072
diff
changeset
|
461 self.setter(self.x) |
| 1427 | 462 |
|
1026
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
463 @register |
|
1015
4d80718a47e5
ledoutput support for piNode
drewp <drewp@bigasterisk.com>
parents:
1014
diff
changeset
|
464 class LedOutput(DeviceType): |
|
4d80718a47e5
ledoutput support for piNode
drewp <drewp@bigasterisk.com>
parents:
1014
diff
changeset
|
465 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
|
466 |
|
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
|
467 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
|
468 self.value = 0 |
|
1109
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
469 if (self.uri, ROOM['fade'], None) in self.graph: |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
470 # incomplete- the object could be fade settings |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
471 self.fv = FilteredValue(self._setPwm) |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
472 else: |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
473 _setPwm = self._setPwm |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
474 class Instant(object): |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
475 def set(self, goal): |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
476 _setPwm(goal) |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
477 self.fv = Instant() |
| 1094 | 478 self.gamma = float(self.graph.value(self.uri, ROOM['gamma'], default=1)) |
| 1427 | 479 |
|
1015
4d80718a47e5
ledoutput support for piNode
drewp <drewp@bigasterisk.com>
parents:
1014
diff
changeset
|
480 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
|
481 setupPwm(self.pi, self.pinNumber) |
|
1015
4d80718a47e5
ledoutput support for piNode
drewp <drewp@bigasterisk.com>
parents:
1014
diff
changeset
|
482 |
|
4d80718a47e5
ledoutput support for piNode
drewp <drewp@bigasterisk.com>
parents:
1014
diff
changeset
|
483 def outputPatterns(self): |
|
4d80718a47e5
ledoutput support for piNode
drewp <drewp@bigasterisk.com>
parents:
1014
diff
changeset
|
484 return [(self.uri, ROOM['brightness'], None)] |
| 1427 | 485 |
|
1015
4d80718a47e5
ledoutput support for piNode
drewp <drewp@bigasterisk.com>
parents:
1014
diff
changeset
|
486 def sendOutput(self, statements): |
|
4d80718a47e5
ledoutput support for piNode
drewp <drewp@bigasterisk.com>
parents:
1014
diff
changeset
|
487 assert len(statements) == 1 |
|
4d80718a47e5
ledoutput support for piNode
drewp <drewp@bigasterisk.com>
parents:
1014
diff
changeset
|
488 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
|
489 self.value = float(statements[0][2]) |
|
1079
3d0133cdce90
smooth output fading support
drewp <drewp@bigasterisk.com>
parents:
1072
diff
changeset
|
490 self.fv.set(self.value) |
|
3d0133cdce90
smooth output fading support
drewp <drewp@bigasterisk.com>
parents:
1072
diff
changeset
|
491 |
|
3d0133cdce90
smooth output fading support
drewp <drewp@bigasterisk.com>
parents:
1072
diff
changeset
|
492 def _setPwm(self, x): |
| 1129 | 493 v = max(0, min(255, int((x ** self.gamma)* 255))) |
|
1015
4d80718a47e5
ledoutput support for piNode
drewp <drewp@bigasterisk.com>
parents:
1014
diff
changeset
|
494 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
|
495 |
|
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
|
496 def hostStatements(self): |
| 1427 | 497 return [(self.uri, ROOM['brightness'], Literal(self.value))] |
| 498 | |
|
1015
4d80718a47e5
ledoutput support for piNode
drewp <drewp@bigasterisk.com>
parents:
1014
diff
changeset
|
499 def outputWidgets(self): |
|
4d80718a47e5
ledoutput support for piNode
drewp <drewp@bigasterisk.com>
parents:
1014
diff
changeset
|
500 return [{ |
|
4d80718a47e5
ledoutput support for piNode
drewp <drewp@bigasterisk.com>
parents:
1014
diff
changeset
|
501 'element': 'output-slider', |
|
4d80718a47e5
ledoutput support for piNode
drewp <drewp@bigasterisk.com>
parents:
1014
diff
changeset
|
502 'min': 0, |
|
4d80718a47e5
ledoutput support for piNode
drewp <drewp@bigasterisk.com>
parents:
1014
diff
changeset
|
503 'max': 1, |
|
4d80718a47e5
ledoutput support for piNode
drewp <drewp@bigasterisk.com>
parents:
1014
diff
changeset
|
504 'step': 1 / 255, |
|
4d80718a47e5
ledoutput support for piNode
drewp <drewp@bigasterisk.com>
parents:
1014
diff
changeset
|
505 'subj': self.uri, |
|
4d80718a47e5
ledoutput support for piNode
drewp <drewp@bigasterisk.com>
parents:
1014
diff
changeset
|
506 'pred': ROOM['brightness'], |
|
4d80718a47e5
ledoutput support for piNode
drewp <drewp@bigasterisk.com>
parents:
1014
diff
changeset
|
507 }] |
|
4d80718a47e5
ledoutput support for piNode
drewp <drewp@bigasterisk.com>
parents:
1014
diff
changeset
|
508 |
| 1427 | 509 |
| 1010 | 510 @register |
| 511 class OnboardTemperature(DeviceType): | |
| 512 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
|
513 pollPeriod = 10 |
| 1010 | 514 @classmethod |
| 515 def findInstances(cls, graph, board, pi): | |
|
1064
d29b9212c4c5
add support for rgb leds on rpi
drewp <drewp@bigasterisk.com>
parents:
1059
diff
changeset
|
516 log.debug('graph has any connected devices of type OnboardTemperature on %r?', board) |
| 1012 | 517 for row in graph.query('''SELECT DISTINCT ?uri WHERE { |
| 1427 | 518 ?board :onboardDevice ?uri . |
| 1010 | 519 ?uri a :OnboardTemperature . |
|
1026
8e075449ba0a
piNode support for temp sensors. proper hostname lookup
drewp <drewp@bigasterisk.com>
parents:
1025
diff
changeset
|
520 }''', initBindings=dict(board=board)): |
|
1064
d29b9212c4c5
add support for rgb leds on rpi
drewp <drewp@bigasterisk.com>
parents:
1059
diff
changeset
|
521 log.debug(' found %s', row.uri) |
| 1010 | 522 yield cls(graph, row.uri, pi, pinNumber=None) |
| 1427 | 523 |
| 1013 | 524 def poll(self): |
| 1010 | 525 milliC = open('/sys/class/thermal/thermal_zone0/temp').read().strip() |
| 526 c = float(milliC) / 1000. | |
| 527 f = c * 1.8 + 32 | |
| 528 return [ | |
| 529 (self.uri, ROOM['temperatureF'], Literal(f, datatype=XSD['decimal'])), | |
| 530 ] | |
| 531 | |
| 532 def watchPrefixes(self): | |
| 533 # these uris will become dynamic! see note on watchPrefixes | |
| 534 # about eliminating it. | |
| 535 return [(self.uri, ROOM['temperatureF']), | |
| 536 ] | |
|
1064
d29b9212c4c5
add support for rgb leds on rpi
drewp <drewp@bigasterisk.com>
parents:
1059
diff
changeset
|
537 |
|
1392
83043957c809
pinode devs can now poll in parallel (within one poll step). doesn't help much.
drewp <drewp@bigasterisk.com>
parents:
1210
diff
changeset
|
538 pixelStats = scales.collection('/rgbPixels', |
|
83043957c809
pinode devs can now poll in parallel (within one poll step). doesn't help much.
drewp <drewp@bigasterisk.com>
parents:
1210
diff
changeset
|
539 scales.PmfStat('updateOutput'), |
|
83043957c809
pinode devs can now poll in parallel (within one poll step). doesn't help much.
drewp <drewp@bigasterisk.com>
parents:
1210
diff
changeset
|
540 scales.PmfStat('currentColors'), |
|
83043957c809
pinode devs can now poll in parallel (within one poll step). doesn't help much.
drewp <drewp@bigasterisk.com>
parents:
1210
diff
changeset
|
541 scales.PmfStat('poll'), |
|
83043957c809
pinode devs can now poll in parallel (within one poll step). doesn't help much.
drewp <drewp@bigasterisk.com>
parents:
1210
diff
changeset
|
542 ) |
| 1427 | 543 |
|
1064
d29b9212c4c5
add support for rgb leds on rpi
drewp <drewp@bigasterisk.com>
parents:
1059
diff
changeset
|
544 @register |
|
d29b9212c4c5
add support for rgb leds on rpi
drewp <drewp@bigasterisk.com>
parents:
1059
diff
changeset
|
545 class RgbPixels(DeviceType): |
|
d29b9212c4c5
add support for rgb leds on rpi
drewp <drewp@bigasterisk.com>
parents:
1059
diff
changeset
|
546 """chain of ws2812 rgb pixels on pin GPIO18""" |
|
d29b9212c4c5
add support for rgb leds on rpi
drewp <drewp@bigasterisk.com>
parents:
1059
diff
changeset
|
547 deviceType = ROOM['RgbPixels'] |
|
d29b9212c4c5
add support for rgb leds on rpi
drewp <drewp@bigasterisk.com>
parents:
1059
diff
changeset
|
548 |
|
d29b9212c4c5
add support for rgb leds on rpi
drewp <drewp@bigasterisk.com>
parents:
1059
diff
changeset
|
549 def hostStateInit(self): |
|
1143
d1bc88f67969
RgbPixelsAnimation and docker build updates
drewp <drewp@bigasterisk.com>
parents:
1136
diff
changeset
|
550 self.anim = RgbPixelsAnimation(self.graph, self.uri, self.updateOutput) |
| 1173 | 551 log.debug('%s maxIndex = %s', self.uri, self.anim.maxIndex()) |
| 552 self.neo = rpi_ws281x.Adafruit_NeoPixel(self.anim.maxIndex() + 1, pin=18) | |
|
1064
d29b9212c4c5
add support for rgb leds on rpi
drewp <drewp@bigasterisk.com>
parents:
1059
diff
changeset
|
553 self.neo.begin() |
| 1427 | 554 |
|
1143
d1bc88f67969
RgbPixelsAnimation and docker build updates
drewp <drewp@bigasterisk.com>
parents:
1136
diff
changeset
|
555 colorOrder, stripType = self.anim.getColorOrder(self.graph, self.uri) |
| 1427 | 556 |
|
1143
d1bc88f67969
RgbPixelsAnimation and docker build updates
drewp <drewp@bigasterisk.com>
parents:
1136
diff
changeset
|
557 def sendOutput(self, statements): |
|
d1bc88f67969
RgbPixelsAnimation and docker build updates
drewp <drewp@bigasterisk.com>
parents:
1136
diff
changeset
|
558 self.anim.onStatements(statements) |
|
1071
9a8897fac103
neopixel lib change. factor out pwm setup and try another pwm rate
drewp <drewp@bigasterisk.com>
parents:
1067
diff
changeset
|
559 |
|
1392
83043957c809
pinode devs can now poll in parallel (within one poll step). doesn't help much.
drewp <drewp@bigasterisk.com>
parents:
1210
diff
changeset
|
560 @pixelStats.updateOutput.time() |
|
1143
d1bc88f67969
RgbPixelsAnimation and docker build updates
drewp <drewp@bigasterisk.com>
parents:
1136
diff
changeset
|
561 def updateOutput(self): |
|
d1bc88f67969
RgbPixelsAnimation and docker build updates
drewp <drewp@bigasterisk.com>
parents:
1136
diff
changeset
|
562 if 0: |
|
d1bc88f67969
RgbPixelsAnimation and docker build updates
drewp <drewp@bigasterisk.com>
parents:
1136
diff
changeset
|
563 for _, _, sg in self.anim.groups.values(): |
|
1428
56e07d3f0930
frontdoor configs; move device class timing to greplin stats
drewp <drewp@bigasterisk.com>
parents:
1427
diff
changeset
|
564 print (sg.uri, sg.current) |
|
56e07d3f0930
frontdoor configs; move device class timing to greplin stats
drewp <drewp@bigasterisk.com>
parents:
1427
diff
changeset
|
565 print (list(self.anim.currentColors())) |
|
1143
d1bc88f67969
RgbPixelsAnimation and docker build updates
drewp <drewp@bigasterisk.com>
parents:
1136
diff
changeset
|
566 return |
|
1392
83043957c809
pinode devs can now poll in parallel (within one poll step). doesn't help much.
drewp <drewp@bigasterisk.com>
parents:
1210
diff
changeset
|
567 |
|
83043957c809
pinode devs can now poll in parallel (within one poll step). doesn't help much.
drewp <drewp@bigasterisk.com>
parents:
1210
diff
changeset
|
568 with pixelStats.currentColors.time(): |
|
83043957c809
pinode devs can now poll in parallel (within one poll step). doesn't help much.
drewp <drewp@bigasterisk.com>
parents:
1210
diff
changeset
|
569 colors = self.anim.currentColors() |
| 1427 | 570 |
|
1392
83043957c809
pinode devs can now poll in parallel (within one poll step). doesn't help much.
drewp <drewp@bigasterisk.com>
parents:
1210
diff
changeset
|
571 for idx, (r, g, b) in colors: |
|
83043957c809
pinode devs can now poll in parallel (within one poll step). doesn't help much.
drewp <drewp@bigasterisk.com>
parents:
1210
diff
changeset
|
572 if idx < 4: |
|
83043957c809
pinode devs can now poll in parallel (within one poll step). doesn't help much.
drewp <drewp@bigasterisk.com>
parents:
1210
diff
changeset
|
573 log.debug('out color %s (%s,%s,%s)', idx, r, g, b) |
|
1143
d1bc88f67969
RgbPixelsAnimation and docker build updates
drewp <drewp@bigasterisk.com>
parents:
1136
diff
changeset
|
574 self.neo.setPixelColorRGB(idx, r, g, b) |
|
1064
d29b9212c4c5
add support for rgb leds on rpi
drewp <drewp@bigasterisk.com>
parents:
1059
diff
changeset
|
575 self.neo.show() |
|
d29b9212c4c5
add support for rgb leds on rpi
drewp <drewp@bigasterisk.com>
parents:
1059
diff
changeset
|
576 |
|
1392
83043957c809
pinode devs can now poll in parallel (within one poll step). doesn't help much.
drewp <drewp@bigasterisk.com>
parents:
1210
diff
changeset
|
577 @pixelStats.poll.time() |
|
1143
d1bc88f67969
RgbPixelsAnimation and docker build updates
drewp <drewp@bigasterisk.com>
parents:
1136
diff
changeset
|
578 def poll(self): |
|
d1bc88f67969
RgbPixelsAnimation and docker build updates
drewp <drewp@bigasterisk.com>
parents:
1136
diff
changeset
|
579 self.anim.step() |
|
d1bc88f67969
RgbPixelsAnimation and docker build updates
drewp <drewp@bigasterisk.com>
parents:
1136
diff
changeset
|
580 return [] |
|
d1bc88f67969
RgbPixelsAnimation and docker build updates
drewp <drewp@bigasterisk.com>
parents:
1136
diff
changeset
|
581 |
|
1064
d29b9212c4c5
add support for rgb leds on rpi
drewp <drewp@bigasterisk.com>
parents:
1059
diff
changeset
|
582 def hostStatements(self): |
|
1143
d1bc88f67969
RgbPixelsAnimation and docker build updates
drewp <drewp@bigasterisk.com>
parents:
1136
diff
changeset
|
583 return self.anim.hostStatements() |
| 1427 | 584 |
|
1064
d29b9212c4c5
add support for rgb leds on rpi
drewp <drewp@bigasterisk.com>
parents:
1059
diff
changeset
|
585 def outputPatterns(self): |
|
1143
d1bc88f67969
RgbPixelsAnimation and docker build updates
drewp <drewp@bigasterisk.com>
parents:
1136
diff
changeset
|
586 return self.anim.outputPatterns() |
|
1064
d29b9212c4c5
add support for rgb leds on rpi
drewp <drewp@bigasterisk.com>
parents:
1059
diff
changeset
|
587 |
|
d29b9212c4c5
add support for rgb leds on rpi
drewp <drewp@bigasterisk.com>
parents:
1059
diff
changeset
|
588 def outputWidgets(self): |
|
1143
d1bc88f67969
RgbPixelsAnimation and docker build updates
drewp <drewp@bigasterisk.com>
parents:
1136
diff
changeset
|
589 return self.anim.outputWidgets() |
|
1064
d29b9212c4c5
add support for rgb leds on rpi
drewp <drewp@bigasterisk.com>
parents:
1059
diff
changeset
|
590 |
|
1109
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
591 @register |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
592 class Lcd8544(DeviceType): |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
593 """PCD8544 lcd (nokia 5110)""" |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
594 deviceType = ROOM['RgbStrip'] |
| 1427 | 595 |
|
1109
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
596 @classmethod |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
597 def findInstances(cls, graph, board, pi): |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
598 for row in graph.query(""" |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
599 SELECT DISTINCT ?dev ?din ?clk ?dc ?rst WHERE { |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
600 ?dev a :Lcd8544 . |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
601 ?board :hasPin ?dinPin . ?dev :din ?dinPin . ?dinPin :gpioNumber ?din . |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
602 ?board :hasPin ?clkPin . ?dev :clk ?clkPin . ?clkPin :gpioNumber ?clk . |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
603 ?board :hasPin ?dcPin . ?dev :dc ?dcPin . ?dcPin :gpioNumber ?dc . |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
604 ?board :hasPin ?rstPin . ?dev :rst ?rstPin . ?rstPin :gpioNumber ?rst . |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
605 } ORDER BY ?dev""", |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
606 initBindings=dict(board=board), |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
607 initNs={'': ROOM}): |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
608 log.debug('found lcd %r', row) |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
609 yield cls(graph, row.dev, pi, |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
610 int(row.din), int(row.clk), |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
611 int(row.dc), int(row.rst)) |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
612 |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
613 def __init__(self, graph, uri, pi, din, clk, dc, rst): |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
614 super(Lcd8544, self).__init__(graph, uri, pi, None) |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
615 |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
616 |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
617 import RPi.GPIO |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
618 import Adafruit_Nokia_LCD |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
619 import Adafruit_GPIO.SPI |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
620 self.lcd = Adafruit_Nokia_LCD.PCD8544( |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
621 dc=8, rst=7, |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
622 spi=Adafruit_GPIO.SPI.BitBang( |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
623 Adafruit_Nokia_LCD.GPIO.RPiGPIOAdapter(RPi.GPIO), |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
624 sclk=clk, |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
625 mosi=din)) |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
626 self.lcd.begin(contrast=60) |
| 1427 | 627 |
|
1109
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
628 def hostStatements(self): |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
629 return [] |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
630 return [(self.uri, ROOM['color'], Literal(self.value))] |
| 1427 | 631 |
|
1109
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
632 def outputPatterns(self): |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
633 return [] |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
634 return [(self.uri, ROOM['color'], None)] |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
635 |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
636 def sendOutput(self, statements): |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
637 return |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
638 assert len(statements) == 1 |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
639 assert statements[0][:2] == (self.uri, ROOM['color']) |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
640 |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
641 rgb = self._rgbFromHex(statements[0][2]) |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
642 self.value = statements[0][2] |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
643 |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
644 for (i, v) in zip(self.rgb, rgb): |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
645 self.pi.set_PWM_dutycycle(i, v) |
| 1427 | 646 |
|
1109
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
647 def outputWidgets(self): |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
648 return [] |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
649 return [{ |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
650 'element': 'output-rgb', |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
651 'subj': self.uri, |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
652 'pred': ROOM['color'], |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
653 }] |
|
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
654 |
|
1210
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
655 @register |
|
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
656 class PwmBoard(DeviceType): |
|
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
657 """ |
|
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
658 need this in /boot/config.txt |
|
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
659 dtparam=i2c_arm=on |
|
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
660 check for devices with |
|
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
661 apt-get install -y i2c-tools |
|
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
662 sudo i2cdetect -y 1 |
|
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
663 |
|
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
664 gpio8 = bcm2 = sda1 |
|
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
665 gpio9 = bcm3 = scl1 |
|
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
666 They're next to the 3v3 pin. |
|
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
667 """ |
|
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
668 deviceType = ROOM['PwmBoard'] |
|
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
669 @classmethod |
|
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
670 def findInstances(cls, graph, board, pi): |
|
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
671 for row in graph.query("""SELECT DISTINCT ?dev WHERE { |
|
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
672 ?board :hasI2cBus ?bus . |
|
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
673 ?bus :connectedTo ?dev . |
|
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
674 ?dev a :PwmBoard . |
|
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
675 }""", initBindings=dict(board=board), initNs={'': ROOM}): |
|
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
676 outs = {} |
|
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
677 for out in graph.query("""SELECT DISTINCT ?area ?chan WHERE { |
|
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
678 ?dev :output [:area ?area; :channel ?chan] . |
|
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
679 }""", initBindings=dict(dev=row.dev), initNs={'': ROOM}): |
|
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
680 outs[out.area] = out.chan.toPython() |
|
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
681 yield cls(graph, row.dev, pi, outs) |
| 1427 | 682 |
|
1210
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
683 def __init__(self, graph, dev, pi, outs): |
|
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
684 super(PwmBoard, self).__init__(graph, dev, pi, pinNumber=None) |
|
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
685 import PCA9685 |
|
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
686 self.pwm = PCA9685.PWM(pi, bus=1, address=0x40) |
|
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
687 self.pwm.set_frequency(1200) |
|
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
688 self.outs = outs |
|
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
689 self.values = {uri: 0 for uri in self.outs.keys()} # uri: brightness |
|
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
690 |
|
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
691 def hostStatements(self): |
|
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
692 return [(uri, ROOM['brightness'], Literal(b)) |
|
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
693 for uri, b in self.values.items()] |
|
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
694 |
|
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
695 def outputPatterns(self): |
|
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
696 return [(area, ROOM['brightness'], None) for area in self.outs] |
|
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
697 |
|
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
698 def sendOutput(self, statements): |
|
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
699 assert len(statements) == 1 |
|
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
700 assert statements[0][1] == ROOM['brightness']; |
|
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
701 chan = self.outs[statements[0][0]] |
|
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
702 value = float(statements[0][2]) |
|
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
703 self.values[statements[0][0]] = value |
|
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
704 self.pwm.set_duty_cycle(chan, value * 100) |
| 1427 | 705 |
|
1210
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
706 def outputWidgets(self): |
|
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
707 return [{ |
|
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
708 'element': 'output-slider', |
|
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
709 'min': 0, |
|
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
710 'max': 1, |
|
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
711 'step': 1 / 255, |
|
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
712 'subj': area, |
|
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
713 'pred': ROOM['brightness'], |
|
e65d7b62364f
PCA9685 pwm board support on piNode
drewp <drewp@bigasterisk.com>
parents:
1186
diff
changeset
|
714 } for area in self.outs] |
|
1109
77f6117e002f
influx output, fade support, switch to Adafruit_DHT, start of Lcd8544
drewp <drewp@bigasterisk.com>
parents:
1095
diff
changeset
|
715 |
| 1427 | 716 |
| 987 | 717 def makeDevices(graph, board, pi): |
| 718 out = [] | |
| 719 for dt in sorted(_knownTypes, key=lambda cls: cls.__name__): | |
| 720 out.extend(dt.findInstances(graph, board, pi)) | |
| 721 return out |