homeauto: service/piNode/devices.py annotate

annotate service/piNode/devices.py @ 1401:2ec49c958f91

rule updates Ignore-this: e0e881f196303f76ee6f8a4a16dfad44 darcs-hash:995049f78867de2cbcbe23a0b4a0b3e1afc42a52

author	drewp <drewp@bigasterisk.com>
date	Tue, 23 Jul 2019 10:15:33 -0700
parents	83043957c809
children	1249dcc657b8

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

Mercurial > code > home > repos > homeauto

annotate service/piNode/devices.py @ 1401:2ec49c958f91