jeans/core
jeans/core
1
0
Fork 0
mirror of https://github.com/home-assistant/core.git synced 2025-07-24 13:47:35 +00:00
Code Issues Packages Projects Releases Wiki Activity

Use CoordinatorEntity for supla (#39621)

Browse Source
This commit is contained in:
Chris Talkington 2020-09-03 12:11:14 -05:00 committed by GitHub
parent a0663d84d2
commit 17b4c1a2ca
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
homeassistant/components/supla/__init__.py
View File

@ -11,8 +11,10 @@ from homeassistant.const import CONF_ACCESS_TOKEN
from homeassistant.helpers.aiohttp_client import async_get_clientsession
import homeassistant.helpers.config_validation as cv
from homeassistant.helpers.discovery import async_load_platform
from homeassistant.helpers.entity import Entity
from homeassistant.helpers.update_coordinator import DataUpdateCoordinator
from homeassistant.helpers.update_coordinator import (
CoordinatorEntity,
DataUpdateCoordinator,
)
_LOGGER = logging.getLogger(__name__)
@ -154,26 +156,21 @@ async def discover_devices(hass, hass_config):
await async_load_platform(hass, component_name, DOMAIN, config, hass_config)
class SuplaChannel(Entity):
class SuplaChannel(CoordinatorEntity):
"""Base class of a Supla Channel (an equivalent of HA's Entity)."""
def __init__(self, config, server, coordinator):
"""Init from config, hookup[ server and coordinator."""
super().__init__(coordinator)
self.server_name = config["server_name"]
self.channel_id = config["channel_id"]
self.server = server
self.coordinator = coordinator
@property
def channel_data(self):
"""Return channel data taken from coordinator."""
return self.coordinator.data.get(self.channel_id)
@property
def should_poll(self):
"""Supla uses DataUpdateCoordinator, so no additional polling needed."""
return False
@property
def unique_id(self) -> str:
"""Return a unique ID."""
@ -197,12 +194,6 @@ class SuplaChannel(Entity):
return False
return state.get("connected")
async def async_added_to_hass(self):
"""When entity is added to hass."""
self.async_on_remove(
self.coordinator.async_add_listener(self.async_write_ha_state)
)
async def async_action(self, action, **add_pars):
"""
Run server action.
@ -220,10 +211,3 @@ class SuplaChannel(Entity):
# Update state
await self.coordinator.async_request_refresh()
async def async_update(self):
"""Update the entity.
Only used by the generic entity update service.
"""
await self.coordinator.async_request_refresh()