1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
|
"""Component for interfacing to Lutron Homeworks Series 4 and 8 systems.
For more details about this component, please refer to the documentation at
https://home-assistant.io/components/homeworks/
"""
import logging
import voluptuous as vol
from homeassistant.const import (
CONF_HOST, CONF_PORT, EVENT_HOMEASSISTANT_STOP)
import homeassistant.helpers.config_validation as cv
from homeassistant.helpers.entity import Entity
REQUIREMENTS = ['pyhomeworks==0.0.4']
_LOGGER = logging.getLogger(__name__)
DOMAIN = 'homeworks'
HOMEWORKS_CONTROLLER = 'homeworks'
CONFIG_SCHEMA = vol.Schema({
DOMAIN: vol.Schema({
vol.Required(CONF_HOST): cv.string,
vol.Required(CONF_PORT): cv.port,
}),
}, extra=vol.ALLOW_EXTRA)
def setup(hass, base_config):
"""Start Homeworks controller."""
from pyhomeworks.pyhomeworks import Homeworks
class HomeworksController(Homeworks):
"""Interface between HASS and Homeworks controller."""
def __init__(self, host, port):
"""Host and port of Lutron Homeworks controller."""
Homeworks.__init__(self, host, port, self.callback)
self._subscribers = {}
def subscribe(self, device):
"""Add a device to subscribe to events."""
if device.addr not in self._subscribers:
self._subscribers[device.addr] = []
self._subscribers[device.addr].append(device)
if device.is_light:
self.request_dimmer_level(device.addr)
def callback(self, msg_type, values):
"""Dispatch state changes."""
_LOGGER.debug('callback: %s, %s', msg_type, values)
addr = values[0]
for sub in self._subscribers.get(addr, []):
_LOGGER.debug("callback: %s", sub)
if sub.callback(msg_type, values):
sub.schedule_update_ha_state()
config = base_config.get(DOMAIN)
host = config[CONF_HOST]
port = config[CONF_PORT]
controller = HomeworksController(host, port)
hass.data[HOMEWORKS_CONTROLLER] = controller
def cleanup(event):
controller.close()
hass.bus.listen_once(EVENT_HOMEASSISTANT_STOP, cleanup)
return True
class HomeworksDevice(Entity):
"""Base class of a Homeworks device."""
is_light = False
def __init__(self, controller, addr, name):
"""Controller, address, and name of the device."""
self._addr = addr
self._name = name
self._controller = controller
async def async_added_to_hass(self):
"""Register callback."""
self.hass.async_add_job(self._controller.subscribe, self)
@property
def addr(self):
"""Device address."""
return self._addr
@property
def name(self):
"""Device name."""
return self._name
@property
def should_poll(self):
"""No need to poll."""
return False
def callback(self, msg_type, values):
"""Run when Homeworks device changes state."""
pass
|
