Add AquaLogic component (#16763)
* Add missing ups.status states. * Add missing DISCHRG state. * AquaLogic work-in-progress * - Fix dependencies - Switch updates * Add support for aqualogic 0.8 features. * Remove debugging. * Switch to async updates rather than using polling. * Rebase * Fix lint errors * Fix lint errors * Fix lint errors * Fix lint errors * Fix lint errors. * Bump aqualogic version to 0.11 * Update .coveragerc * Remove integration-specific I/O * Resolve code review issues. * Fixed init() call.
This commit is contained in:
Sean Wilson
Martin Hjelmare
parent
c3eff5773b
commit
284d4d49c7
5 changed files with 326 additions and 0 deletions
|
|
@ -28,6 +28,9 @@ omit =
|
|||
homeassistant/components/apple_tv.py
|
||||
homeassistant/components/*/apple_tv.py
|
||||
|
||||
homeassistant/components/aqualogic.py
|
||||
homeassistant/components/*/aqualogic.py
|
||||
|
||||
homeassistant/components/arduino.py
|
||||
homeassistant/components/*/arduino.py
|
||||
|
||||
|
|
|
|||
95
homeassistant/components/aqualogic.py
Normal file
95
homeassistant/components/aqualogic.py
Normal file
|
|
@ -0,0 +1,95 @@
|
|||
"""
|
||||
Support for AquaLogic component.
|
||||
|
||||
For more details about this platform, please refer to the documentation at
|
||||
https://home-assistant.io/components/aqualogic/
|
||||
"""
|
||||
from datetime import timedelta
|
||||
import logging
|
||||
import time
|
||||
import threading
|
||||
|
||||
import voluptuous as vol
|
||||
|
||||
from homeassistant.const import (CONF_HOST, CONF_PORT,
|
||||
EVENT_HOMEASSISTANT_START,
|
||||
EVENT_HOMEASSISTANT_STOP)
|
||||
from homeassistant.helpers import config_validation as cv
|
||||
|
||||
REQUIREMENTS = ["aqualogic==1.0"]
|
||||
|
||||
_LOGGER = logging.getLogger(__name__)
|
||||
|
||||
DOMAIN = "aqualogic"
|
||||
UPDATE_TOPIC = DOMAIN + "_update"
|
||||
CONF_UNIT = "unit"
|
||||
RECONNECT_INTERVAL = timedelta(seconds=10)
|
||||
|
||||
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, config):
|
||||
"""Set up AquaLogic platform."""
|
||||
host = config[DOMAIN][CONF_HOST]
|
||||
port = config[DOMAIN][CONF_PORT]
|
||||
processor = AquaLogicProcessor(hass, host, port)
|
||||
hass.data[DOMAIN] = processor
|
||||
hass.bus.listen_once(EVENT_HOMEASSISTANT_START,
|
||||
processor.start_listen)
|
||||
hass.bus.listen_once(EVENT_HOMEASSISTANT_STOP,
|
||||
processor.shutdown)
|
||||
_LOGGER.debug("AquaLogicProcessor %s:%i initialized", host, port)
|
||||
return True
|
||||
|
||||
|
||||
class AquaLogicProcessor(threading.Thread):
|
||||
"""AquaLogic event processor thread."""
|
||||
|
||||
def __init__(self, hass, host, port):
|
||||
"""Initialize the data object."""
|
||||
super().__init__(daemon=True)
|
||||
self._hass = hass
|
||||
self._host = host
|
||||
self._port = port
|
||||
self._shutdown = False
|
||||
self._panel = None
|
||||
|
||||
def start_listen(self, event):
|
||||
"""Start event-processing thread."""
|
||||
_LOGGER.debug("Event processing thread started")
|
||||
self.start()
|
||||
|
||||
def shutdown(self, event):
|
||||
"""Signal shutdown of processing event."""
|
||||
_LOGGER.debug("Event processing signaled exit")
|
||||
self._shutdown = True
|
||||
|
||||
def data_changed(self, panel):
|
||||
"""Aqualogic data changed callback."""
|
||||
self._hass.helpers.dispatcher.dispatcher_send(UPDATE_TOPIC)
|
||||
|
||||
def run(self):
|
||||
"""Event thread."""
|
||||
from aqualogic.core import AquaLogic
|
||||
|
||||
while True:
|
||||
self._panel = AquaLogic()
|
||||
self._panel.connect(self._host, self._port)
|
||||
self._panel.process(self.data_changed)
|
||||
|
||||
if self._shutdown:
|
||||
return
|
||||
|
||||
_LOGGER.error("Connection to %s:%d lost",
|
||||
self._host, self._port)
|
||||
time.sleep(RECONNECT_INTERVAL.seconds)
|
||||
|
||||
@property
|
||||
def panel(self):
|
||||
"""Retrieve the AquaLogic object."""
|
||||
return self._panel
|
||||
111
homeassistant/components/sensor/aqualogic.py
Normal file
111
homeassistant/components/sensor/aqualogic.py
Normal file
|
|
@ -0,0 +1,111 @@
|
|||
"""
|
||||
Support for AquaLogic sensors.
|
||||
|
||||
For more details about this platform, please refer to the documentation at
|
||||
https://home-assistant.io/components/sensor.aqualogic/
|
||||
"""
|
||||
import logging
|
||||
|
||||
import voluptuous as vol
|
||||
|
||||
from homeassistant.components.sensor import PLATFORM_SCHEMA
|
||||
from homeassistant.const import (CONF_MONITORED_CONDITIONS,
|
||||
TEMP_CELSIUS, TEMP_FAHRENHEIT)
|
||||
from homeassistant.core import callback
|
||||
from homeassistant.helpers.entity import Entity
|
||||
import homeassistant.components.aqualogic as aq
|
||||
import homeassistant.helpers.config_validation as cv
|
||||
|
||||
_LOGGER = logging.getLogger(__name__)
|
||||
|
||||
DEPENDENCIES = ['aqualogic']
|
||||
|
||||
TEMP_UNITS = [TEMP_CELSIUS, TEMP_FAHRENHEIT]
|
||||
PERCENT_UNITS = ['%', '%']
|
||||
SALT_UNITS = ['g/L', 'PPM']
|
||||
WATT_UNITS = ['W', 'W']
|
||||
NO_UNITS = [None, None]
|
||||
|
||||
# sensor_type [ description, unit, icon ]
|
||||
# sensor_type corresponds to property names in aqualogic.core.AquaLogic
|
||||
SENSOR_TYPES = {
|
||||
'air_temp': ['Air Temperature', TEMP_UNITS, 'mdi:thermometer'],
|
||||
'pool_temp': ['Pool Temperature', TEMP_UNITS, 'mdi:oil-temperature'],
|
||||
'spa_temp': ['Spa Temperature', TEMP_UNITS, 'mdi:oil-temperature'],
|
||||
'pool_chlorinator': ['Pool Chlorinator', PERCENT_UNITS, 'mdi:gauge'],
|
||||
'spa_chlorinator': ['Spa Chlorinator', PERCENT_UNITS, 'mdi:gauge'],
|
||||
'salt_level': ['Salt Level', SALT_UNITS, 'mdi:gauge'],
|
||||
'pump_speed': ['Pump Speed', PERCENT_UNITS, 'mdi:speedometer'],
|
||||
'pump_power': ['Pump Power', WATT_UNITS, 'mdi:gauge'],
|
||||
'status': ['Status', NO_UNITS, 'mdi:alert']
|
||||
}
|
||||
|
||||
PLATFORM_SCHEMA = PLATFORM_SCHEMA.extend({
|
||||
vol.Required(CONF_MONITORED_CONDITIONS, default=list(SENSOR_TYPES)):
|
||||
vol.All(cv.ensure_list, [vol.In(SENSOR_TYPES)])
|
||||
})
|
||||
|
||||
|
||||
async def async_setup_platform(hass, config, async_add_entities,
|
||||
discovery_info=None):
|
||||
"""Set up the sensor platform."""
|
||||
sensors = []
|
||||
|
||||
processor = hass.data[aq.DOMAIN]
|
||||
for sensor_type in config.get(CONF_MONITORED_CONDITIONS):
|
||||
sensors.append(AquaLogicSensor(processor, sensor_type))
|
||||
|
||||
async_add_entities(sensors)
|
||||
|
||||
|
||||
class AquaLogicSensor(Entity):
|
||||
"""Sensor implementation for the AquaLogic component."""
|
||||
|
||||
def __init__(self, processor, sensor_type):
|
||||
"""Initialize sensor."""
|
||||
self._processor = processor
|
||||
self._type = sensor_type
|
||||
self._state = None
|
||||
|
||||
@property
|
||||
def state(self):
|
||||
"""Return the state of the sensor."""
|
||||
return self._state
|
||||
|
||||
@property
|
||||
def name(self):
|
||||
"""Return the name of the sensor."""
|
||||
return "AquaLogic {}".format(SENSOR_TYPES[self._type][0])
|
||||
|
||||
@property
|
||||
def unit_of_measurement(self):
|
||||
"""Return the unit of measurement the value is expressed in."""
|
||||
panel = self._processor.panel
|
||||
if panel is None:
|
||||
return None
|
||||
if panel.is_metric:
|
||||
return SENSOR_TYPES[self._type][1][0]
|
||||
return SENSOR_TYPES[self._type][1][1]
|
||||
|
||||
@property
|
||||
def should_poll(self):
|
||||
"""Return the polling state."""
|
||||
return False
|
||||
|
||||
@property
|
||||
def icon(self):
|
||||
"""Icon to use in the frontend, if any."""
|
||||
return SENSOR_TYPES[self._type][2]
|
||||
|
||||
async def async_added_to_hass(self):
|
||||
"""Register callbacks."""
|
||||
self.hass.helpers.dispatcher.async_dispatcher_connect(
|
||||
aq.UPDATE_TOPIC, self.async_update_callback)
|
||||
|
||||
@callback
|
||||
def async_update_callback(self):
|
||||
"""Update callback."""
|
||||
panel = self._processor.panel
|
||||
if panel is not None:
|
||||
self._state = getattr(panel, self._type)
|
||||
self.async_schedule_update_ha_state()
|
||||
114
homeassistant/components/switch/aqualogic.py
Normal file
114
homeassistant/components/switch/aqualogic.py
Normal file
|
|
@ -0,0 +1,114 @@
|
|||
"""
|
||||
Support for AquaLogic switches.
|
||||
|
||||
For more details about this platform, please refer to the documentation at
|
||||
https://home-assistant.io/components/switch.aqualogic/
|
||||
"""
|
||||
import logging
|
||||
|
||||
import voluptuous as vol
|
||||
|
||||
import homeassistant.helpers.config_validation as cv
|
||||
from homeassistant.core import callback
|
||||
import homeassistant.components.aqualogic as aq
|
||||
from homeassistant.components.switch import SwitchDevice, PLATFORM_SCHEMA
|
||||
from homeassistant.const import (CONF_MONITORED_CONDITIONS)
|
||||
|
||||
DEPENDENCIES = ['aqualogic']
|
||||
|
||||
_LOGGER = logging.getLogger(__name__)
|
||||
|
||||
SWITCH_TYPES = {
|
||||
'lights': 'Lights',
|
||||
'filter': 'Filter',
|
||||
'filter_low_speed': 'Filter Low Speed',
|
||||
'aux_1': 'Aux 1',
|
||||
'aux_2': 'Aux 2',
|
||||
'aux_3': 'Aux 3',
|
||||
'aux_4': 'Aux 4',
|
||||
'aux_5': 'Aux 5',
|
||||
'aux_6': 'Aux 6',
|
||||
'aux_7': 'Aux 7',
|
||||
}
|
||||
|
||||
PLATFORM_SCHEMA = PLATFORM_SCHEMA.extend({
|
||||
vol.Optional(CONF_MONITORED_CONDITIONS, default=list(SWITCH_TYPES)):
|
||||
vol.All(cv.ensure_list, [vol.In(SWITCH_TYPES)]),
|
||||
})
|
||||
|
||||
|
||||
async def async_setup_platform(hass, config, async_add_entities,
|
||||
discovery_info=None):
|
||||
"""Set up the switch platform."""
|
||||
switches = []
|
||||
|
||||
processor = hass.data[aq.DOMAIN]
|
||||
for switch_type in config.get(CONF_MONITORED_CONDITIONS):
|
||||
switches.append(AquaLogicSwitch(processor, switch_type))
|
||||
|
||||
async_add_entities(switches)
|
||||
|
||||
|
||||
class AquaLogicSwitch(SwitchDevice):
|
||||
"""Switch implementation for the AquaLogic component."""
|
||||
|
||||
def __init__(self, processor, switch_type):
|
||||
"""Initialize switch."""
|
||||
from aqualogic.core import States
|
||||
self._processor = processor
|
||||
self._type = switch_type
|
||||
self._state_name = {
|
||||
'lights': States.LIGHTS,
|
||||
'filter': States.FILTER,
|
||||
'filter_low_speed': States.FILTER_LOW_SPEED,
|
||||
'aux_1': States.AUX_1,
|
||||
'aux_2': States.AUX_2,
|
||||
'aux_3': States.AUX_3,
|
||||
'aux_4': States.AUX_4,
|
||||
'aux_5': States.AUX_5,
|
||||
'aux_6': States.AUX_6,
|
||||
'aux_7': States.AUX_7
|
||||
}[switch_type]
|
||||
|
||||
@property
|
||||
def name(self):
|
||||
"""Return the name of the switch."""
|
||||
return "AquaLogic {}".format(SWITCH_TYPES[self._type])
|
||||
|
||||
@property
|
||||
def should_poll(self):
|
||||
"""Return the polling state."""
|
||||
return False
|
||||
|
||||
@property
|
||||
def is_on(self):
|
||||
"""Return true if device is on."""
|
||||
panel = self._processor.panel
|
||||
if panel is None:
|
||||
return False
|
||||
state = panel.get_state(self._state_name)
|
||||
return state
|
||||
|
||||
def turn_on(self, **kwargs):
|
||||
"""Turn the device on."""
|
||||
panel = self._processor.panel
|
||||
if panel is None:
|
||||
return
|
||||
panel.set_state(self._state_name, True)
|
||||
|
||||
def turn_off(self, **kwargs):
|
||||
"""Turn the device off."""
|
||||
panel = self._processor.panel
|
||||
if panel is None:
|
||||
return
|
||||
panel.set_state(self._state_name, False)
|
||||
|
||||
async def async_added_to_hass(self):
|
||||
"""Register callbacks."""
|
||||
self.hass.helpers.dispatcher.async_dispatcher_connect(
|
||||
aq.UPDATE_TOPIC, self.async_update_callback)
|
||||
|
||||
@callback
|
||||
def async_update_callback(self):
|
||||
"""Update callback."""
|
||||
self.async_schedule_update_ha_state()
|
||||
|
|
@ -139,6 +139,9 @@ apcaccess==0.0.13
|
|||
# homeassistant.components.notify.apns
|
||||
apns2==0.3.0
|
||||
|
||||
# homeassistant.components.aqualogic
|
||||
aqualogic==1.0
|
||||
|
||||
# homeassistant.components.asterisk_mbox
|
||||
asterisk_mbox==0.5.0
|
||||
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue