Mercurial > code > home > repos > homeauto

annotate service/piNode/devices.py @ 1444:4afb1830bb5e

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