Mercurial > code > home > repos > homeauto

annotate service/piNode/devices.py @ 589:f397ec8bd13d

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