Mercurial > code > home > repos > homeauto

annotate service/piNode/devices.py @ 1072:34a2afdcef2f

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