100 lines
3.9 KiB
Python
100 lines
3.9 KiB
Python
"""FHEM integration"""
|
|
|
|
import logging
|
|
import voluptuous as vol
|
|
from collections import defaultdict
|
|
import homeassistant.helpers.config_validation as cv
|
|
from homeassistant.const import CONF_HOST, CONF_PORT
|
|
from ..reconnecting_client import ReconnectingClient
|
|
|
|
_LOGGER = logging.getLogger(__name__)
|
|
CONF_CUL_DEVICE_NAME = 'cul_device_name'
|
|
CONF_FHEM_SENSOR_TYPE = 'fhem_sensor_type'
|
|
CONF_FHEM_IDS = 'fhem_ids'
|
|
DOMAIN = 'fhem'
|
|
DATA_FHEM = "data_fhem"
|
|
CONFIG_SCHEMA = vol.Schema({
|
|
DOMAIN: vol.Schema({
|
|
vol.Required(CONF_HOST): cv.string,
|
|
vol.Optional(CONF_PORT, default=7072): cv.port,
|
|
vol.Required(CONF_CUL_DEVICE_NAME): cv.string,
|
|
})
|
|
}, extra=vol.ALLOW_EXTRA)
|
|
|
|
|
|
async def async_setup(hass, config):
|
|
connection = FhemConnection(hass, config[DOMAIN])
|
|
hass.data[DATA_FHEM] = connection
|
|
await connection.start()
|
|
return True
|
|
|
|
|
|
class FhemConnection(ReconnectingClient):
|
|
|
|
def __init__(self, hass, config):
|
|
super().__init__(hass, config[CONF_HOST], config[CONF_PORT], "FHEM",
|
|
receive_line_callback=self._process_line,
|
|
connection_status_changed_callback=self._update_all_devices)
|
|
self._cul_device_name = config[CONF_CUL_DEVICE_NAME]
|
|
self._devices = defaultdict(list)
|
|
|
|
def register_device(self, id, d):
|
|
self._devices[id].append(d)
|
|
if self._writer:
|
|
d.refresh()
|
|
|
|
async def _update_all_devices(self, state):
|
|
if state == 'connected':
|
|
self.write_line("displayattr .*")
|
|
self.write_line("inform on")
|
|
for device_list in self._devices.values():
|
|
for device in device_list:
|
|
device.refresh()
|
|
# await device.async_update_ha_state()
|
|
|
|
async def _process_line(self, line):
|
|
if line.startswith(self._cul_device_name + " "): # Status update message
|
|
_, device_name, command = line.split(" ", 2)
|
|
for device in self._devices[device_name]:
|
|
#_LOGGER.debug("FHEM line received (device): " + device_name + ": " + line)
|
|
await device.line_received(command.strip())
|
|
else: # potential response to displayattr
|
|
split_line = line.split(" ", 1)
|
|
if len(split_line) == 2:
|
|
device_name, command = split_line
|
|
for device in self._devices[device_name]:
|
|
await device.line_received(command.strip())
|
|
|
|
def write_line(self, line):
|
|
if self._writer:
|
|
line += '\n'
|
|
self._writer.write(line.encode())
|
|
#_LOGGER.debug(f"FHEM write line {line}")
|
|
else:
|
|
_LOGGER.debug(f"FHEM Failed to write line {line}")
|
|
|
|
def fhem_set(self, id, *arguments):
|
|
"""
|
|
Send command to FHEM using this device
|
|
:param arguments: string or list of strings containing command parameters
|
|
"""
|
|
arguments = " ".join([str(a) for a in arguments])
|
|
self.write_line("set {} {}\n".format(id, arguments))
|
|
|
|
|
|
def device_error_reporting(hass, received_line, component_type, component_name):
|
|
if received_line.startswith('overheat'):
|
|
overheat = received_line.split(':')[1]
|
|
overheat = overheat.strip().lower()
|
|
assert overheat == 'on' or overheat == 'off'
|
|
if overheat == 'on':
|
|
text = "FHEM: {} overheated: <br><b>{}</b>".format(component_type, component_name)
|
|
hass.components.persistent_notification.async_create(text, title="{} overheat".format(component_type))
|
|
elif received_line.startswith('overload'):
|
|
overload = received_line.split(':')[1]
|
|
overload = overload.strip().lower()
|
|
assert overload == 'on' or overload == 'off'
|
|
if overload == 'on':
|
|
text = "FHEM: {} overloaded: <br><b>{}</b>".format(component_type, component_name)
|
|
hass.components.persistent_notification.async_create(text, title="{} overloaded".format(component_type))
|