diff --git a/.coveragerc b/.coveragerc index 445d3e163ee..248e242faaf 100644 --- a/.coveragerc +++ b/.coveragerc @@ -158,7 +158,6 @@ omit = homeassistant/components/ecovacs/* homeassistant/components/eddystone_temperature/sensor.py homeassistant/components/edimax/switch.py - homeassistant/components/edp_redy/* homeassistant/components/egardia/* homeassistant/components/eight_sleep/* homeassistant/components/eliqonline/sensor.py diff --git a/CODEOWNERS b/CODEOWNERS index ff565d79d9d..07501e27f5e 100644 --- a/CODEOWNERS +++ b/CODEOWNERS @@ -74,7 +74,6 @@ homeassistant/components/discogs/* @thibmaek homeassistant/components/doorbird/* @oblogic7 homeassistant/components/dweet/* @fabaff homeassistant/components/ecovacs/* @OverloadUT -homeassistant/components/edp_redy/* @abmantis homeassistant/components/egardia/* @jeroenterheerdt homeassistant/components/eight_sleep/* @mezz64 homeassistant/components/elv/* @majuss diff --git a/homeassistant/components/edp_redy/__init__.py b/homeassistant/components/edp_redy/__init__.py deleted file mode 100644 index 8c079078176..00000000000 --- a/homeassistant/components/edp_redy/__init__.py +++ /dev/null @@ -1,135 +0,0 @@ -"""Support for EDP re:dy.""" -from datetime import timedelta -import logging - -import voluptuous as vol - -from homeassistant.const import CONF_PASSWORD, CONF_USERNAME, EVENT_HOMEASSISTANT_START -from homeassistant.core import callback -from homeassistant.helpers import aiohttp_client, discovery, dispatcher -import homeassistant.helpers.config_validation as cv -from homeassistant.helpers.entity import Entity -from homeassistant.helpers.event import async_track_point_in_time -from homeassistant.util import dt as dt_util - -_LOGGER = logging.getLogger(__name__) - -DOMAIN = "edp_redy" -EDP_REDY = "edp_redy" -DATA_UPDATE_TOPIC = "{0}_data_update".format(DOMAIN) -UPDATE_INTERVAL = 60 - -CONFIG_SCHEMA = vol.Schema( - { - DOMAIN: vol.Schema( - { - vol.Required(CONF_USERNAME): cv.string, - vol.Required(CONF_PASSWORD): cv.string, - } - ) - }, - extra=vol.ALLOW_EXTRA, -) - - -async def async_setup(hass, config): - """Set up the EDP re:dy component.""" - from edp_redy import EdpRedySession - - session = EdpRedySession( - config[DOMAIN][CONF_USERNAME], - config[DOMAIN][CONF_PASSWORD], - aiohttp_client.async_get_clientsession(hass), - hass.loop, - ) - hass.data[EDP_REDY] = session - platform_loaded = False - - async def async_update_and_sched(time): - update_success = await session.async_update() - - if update_success: - nonlocal platform_loaded - # pylint: disable=used-before-assignment - if not platform_loaded: - for component in ["sensor", "switch"]: - await discovery.async_load_platform( - hass, component, DOMAIN, {}, config - ) - platform_loaded = True - - dispatcher.async_dispatcher_send(hass, DATA_UPDATE_TOPIC) - - # schedule next update - async_track_point_in_time( - hass, async_update_and_sched, time + timedelta(seconds=UPDATE_INTERVAL) - ) - - async def start_component(event): - _LOGGER.debug("Starting updates") - await async_update_and_sched(dt_util.utcnow()) - - # only start fetching data after HA boots to prevent delaying the boot - # process - hass.bus.async_listen_once(EVENT_HOMEASSISTANT_START, start_component) - - return True - - -class EdpRedyDevice(Entity): - """Representation a base re:dy device.""" - - def __init__(self, session, device_id, name): - """Initialize the device.""" - self._session = session - self._state = None - self._is_available = True - self._device_state_attributes = {} - self._id = device_id - self._unique_id = device_id - self._name = name if name else device_id - - async def async_added_to_hass(self): - """Subscribe to the data updates topic.""" - dispatcher.async_dispatcher_connect( - self.hass, DATA_UPDATE_TOPIC, self._data_updated - ) - - @property - def name(self): - """Return the name of the device.""" - return self._name - - @property - def unique_id(self) -> str: - """Return a unique ID.""" - return self._unique_id - - @property - def available(self): - """Return True if entity is available.""" - return self._is_available - - @property - def should_poll(self): - """Return the polling state. No polling needed.""" - return False - - @property - def device_state_attributes(self): - """Return the state attributes.""" - return self._device_state_attributes - - @callback - def _data_updated(self): - """Update state, trigger updates.""" - self.async_schedule_update_ha_state(True) - - def _parse_data(self, data): - """Parse data received from the server.""" - if "OutOfOrder" in data: - try: - self._is_available = not data["OutOfOrder"] - except ValueError: - _LOGGER.error("Could not parse OutOfOrder for %s", self._id) - self._is_available = False diff --git a/homeassistant/components/edp_redy/manifest.json b/homeassistant/components/edp_redy/manifest.json deleted file mode 100644 index 90404b21678..00000000000 --- a/homeassistant/components/edp_redy/manifest.json +++ /dev/null @@ -1,12 +0,0 @@ -{ - "domain": "edp_redy", - "name": "Edp redy", - "documentation": "https://www.home-assistant.io/components/edp_redy", - "requirements": [ - "edp_redy==0.0.3" - ], - "dependencies": [], - "codeowners": [ - "@abmantis" - ] -} diff --git a/homeassistant/components/edp_redy/sensor.py b/homeassistant/components/edp_redy/sensor.py deleted file mode 100644 index f8fffefb5da..00000000000 --- a/homeassistant/components/edp_redy/sensor.py +++ /dev/null @@ -1,115 +0,0 @@ -"""Support for EDP re:dy sensors.""" -import logging - -from homeassistant.const import POWER_WATT -from homeassistant.helpers.entity import Entity - -from . import EDP_REDY, EdpRedyDevice - -_LOGGER = logging.getLogger(__name__) - -# Load power in watts (W) -ATTR_ACTIVE_POWER = "active_power" - - -async def async_setup_platform(hass, config, async_add_entities, discovery_info=None): - """Perform the setup for re:dy devices.""" - from edp_redy.session import ACTIVE_POWER_ID - - session = hass.data[EDP_REDY] - devices = [] - - # Create sensors for modules - for device_json in session.modules_dict.values(): - if "HA_POWER_METER" not in device_json["Capabilities"]: - continue - devices.append(EdpRedyModuleSensor(session, device_json)) - - # Create a sensor for global active power - devices.append( - EdpRedySensor(session, ACTIVE_POWER_ID, "Power Home", "mdi:flash", POWER_WATT) - ) - - async_add_entities(devices, True) - - -class EdpRedySensor(EdpRedyDevice, Entity): - """Representation of a EDP re:dy generic sensor.""" - - def __init__(self, session, sensor_id, name, icon, unit): - """Initialize the sensor.""" - super().__init__(session, sensor_id, name) - - self._icon = icon - self._unit = unit - - @property - def state(self): - """Return the state of the sensor.""" - return self._state - - @property - def icon(self): - """Return the icon to use in the frontend.""" - return self._icon - - @property - def unit_of_measurement(self): - """Return the unit of measurement of this sensor.""" - return self._unit - - async def async_update(self): - """Parse the data for this sensor.""" - if self._id in self._session.values_dict: - self._state = self._session.values_dict[self._id] - self._is_available = True - else: - self._is_available = False - - -class EdpRedyModuleSensor(EdpRedyDevice, Entity): - """Representation of a EDP re:dy module sensor.""" - - def __init__(self, session, device_json): - """Initialize the sensor.""" - super().__init__( - session, device_json["PKID"], "Power {0}".format(device_json["Name"]) - ) - - @property - def state(self): - """Return the state of the sensor.""" - return self._state - - @property - def icon(self): - """Return the icon to use in the frontend.""" - return "mdi:flash" - - @property - def unit_of_measurement(self): - """Return the unit of measurement of this sensor.""" - return POWER_WATT - - async def async_update(self): - """Parse the data for this sensor.""" - if self._id in self._session.modules_dict: - device_json = self._session.modules_dict[self._id] - self._parse_data(device_json) - else: - self._is_available = False - - def _parse_data(self, data): - """Parse data received from the server.""" - super()._parse_data(data) - - _LOGGER.debug("Sensor data: %s", str(data)) - - for state_var in data["StateVars"]: - if state_var["Name"] == "ActivePower": - try: - self._state = float(state_var["Value"]) * 1000 - except ValueError: - _LOGGER.error("Could not parse power for %s", self._id) - self._state = 0 - self._is_available = False diff --git a/homeassistant/components/edp_redy/switch.py b/homeassistant/components/edp_redy/switch.py deleted file mode 100644 index 18078fab537..00000000000 --- a/homeassistant/components/edp_redy/switch.py +++ /dev/null @@ -1,91 +0,0 @@ -"""Support for EDP re:dy plugs/switches.""" -import logging - -from homeassistant.components.switch import SwitchDevice - -from . import EDP_REDY, EdpRedyDevice - -_LOGGER = logging.getLogger(__name__) - -# Load power in watts (W) -ATTR_ACTIVE_POWER = "active_power" - - -async def async_setup_platform(hass, config, async_add_entities, discovery_info=None): - """Perform the setup for re:dy devices.""" - session = hass.data[EDP_REDY] - devices = [] - for device_json in session.modules_dict.values(): - if "HA_SWITCH" not in device_json["Capabilities"]: - continue - devices.append(EdpRedySwitch(session, device_json)) - - async_add_entities(devices, True) - - -class EdpRedySwitch(EdpRedyDevice, SwitchDevice): - """Representation of a Edp re:dy switch (plugs, switches, etc).""" - - def __init__(self, session, device_json): - """Initialize the switch.""" - super().__init__(session, device_json["PKID"], device_json["Name"]) - - self._active_power = None - - @property - def icon(self): - """Return the icon to use in the frontend.""" - return "mdi:power-plug" - - @property - def is_on(self): - """Return true if it is on.""" - return self._state - - @property - def device_state_attributes(self): - """Return the state attributes.""" - if self._active_power is not None: - attrs = {ATTR_ACTIVE_POWER: self._active_power} - else: - attrs = {} - attrs.update(super().device_state_attributes) - return attrs - - async def async_turn_on(self, **kwargs): - """Turn the switch on.""" - if await self._async_send_state_cmd(True): - self._state = True - self.async_schedule_update_ha_state() - - async def async_turn_off(self, **kwargs): - """Turn the switch off.""" - if await self._async_send_state_cmd(False): - self._state = False - self.async_schedule_update_ha_state() - - async def _async_send_state_cmd(self, state): - state_json = {"devModuleId": self._id, "key": "RelayState", "value": state} - return await self._session.async_set_state_var(state_json) - - async def async_update(self): - """Parse the data for this switch.""" - if self._id in self._session.modules_dict: - device_json = self._session.modules_dict[self._id] - self._parse_data(device_json) - else: - self._is_available = False - - def _parse_data(self, data): - """Parse data received from the server.""" - super()._parse_data(data) - - for state_var in data["StateVars"]: - if state_var["Name"] == "RelayState": - self._state = state_var["Value"] == "true" - elif state_var["Name"] == "ActivePower": - try: - self._active_power = float(state_var["Value"]) * 1000 - except ValueError: - _LOGGER.error("Could not parse power for %s", self._id) - self._active_power = None diff --git a/requirements_all.txt b/requirements_all.txt index b970f95e763..cdf01a607f1 100644 --- a/requirements_all.txt +++ b/requirements_all.txt @@ -418,9 +418,6 @@ ebusdpy==0.0.16 # homeassistant.components.ecoal_boiler ecoaliface==0.4.0 -# homeassistant.components.edp_redy -edp_redy==0.0.3 - # homeassistant.components.ee_brightbox eebrightbox==0.0.4