annotate service/piNode/devices.py @ 262:9e388c3f032c

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