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

Explicitly pass in the config_entry in gree coordinator (#137844)

Browse Source 
explicitly pass in the config_entry in coordinator
This commit is contained in:
Michael 2025-02-08 13:15:13 +01:00 committed by GitHub
parent a797b09bcb
commit 36a0c49cee
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 12 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
homeassistant/components/gree/__init__.py
View File

@ -26,7 +26,7 @@ PLATFORMS = [Platform.CLIMATE, Platform.SWITCH]
async def async_setup_entry(hass: HomeAssistant, entry: ConfigEntry) -> bool: async def async_setup_entry(hass: HomeAssistant, entry: ConfigEntry) -> bool:
"""Set up Gree Climate from a config entry.""" """Set up Gree Climate from a config entry."""
hass.data.setdefault(DOMAIN, {}) hass.data.setdefault(DOMAIN, {})
gree_discovery = DiscoveryService(hass) gree_discovery = DiscoveryService(hass, entry)
hass.data[DATA_DISCOVERY_SERVICE] = gree_discovery hass.data[DATA_DISCOVERY_SERVICE] = gree_discovery
async def _async_scan_update(_=None): async def _async_scan_update(_=None):

16
homeassistant/components/gree/coordinator.py
View File

@ -11,6 +11,7 @@ from greeclimate.discovery import Discovery, Listener
from greeclimate.exceptions import DeviceNotBoundError, DeviceTimeoutError from greeclimate.exceptions import DeviceNotBoundError, DeviceTimeoutError
from greeclimate.network import Response from greeclimate.network import Response
from homeassistant.config_entries import ConfigEntry
from homeassistant.core import HomeAssistant from homeassistant.core import HomeAssistant
from homeassistant.helpers.dispatcher import async_dispatcher_send from homeassistant.helpers.dispatcher import async_dispatcher_send
from homeassistant.helpers.json import json_dumps from homeassistant.helpers.json import json_dumps
@ -32,12 +33,16 @@ _LOGGER = logging.getLogger(__name__)
class DeviceDataUpdateCoordinator(DataUpdateCoordinator[dict[str, Any]]): class DeviceDataUpdateCoordinator(DataUpdateCoordinator[dict[str, Any]]):
"""Manages polling for state changes from the device.""" """Manages polling for state changes from the device."""
def __init__(self, hass: HomeAssistant, device: Device) -> None: config_entry: ConfigEntry
def __init__(
self, hass: HomeAssistant, config_entry: ConfigEntry, device: Device
) -> None:
"""Initialize the data update coordinator.""" """Initialize the data update coordinator."""
DataUpdateCoordinator.__init__( super().__init__(
self,
hass, hass,
_LOGGER, _LOGGER,
config_entry=config_entry,
name=f"{DOMAIN}-{device.device_info.name}", name=f"{DOMAIN}-{device.device_info.name}",
update_interval=timedelta(seconds=UPDATE_INTERVAL), update_interval=timedelta(seconds=UPDATE_INTERVAL),
always_update=False, always_update=False,
@ -117,10 +122,11 @@ class DeviceDataUpdateCoordinator(DataUpdateCoordinator[dict[str, Any]]):
class DiscoveryService(Listener): class DiscoveryService(Listener):
"""Discovery event handler for gree devices.""" """Discovery event handler for gree devices."""
def __init__(self, hass: HomeAssistant) -> None: def __init__(self, hass: HomeAssistant, entry: ConfigEntry) -> None:
"""Initialize discovery service.""" """Initialize discovery service."""
super().__init__() super().__init__()
self.hass = hass self.hass = hass
self.entry = entry
self.discovery = Discovery(DISCOVERY_TIMEOUT) self.discovery = Discovery(DISCOVERY_TIMEOUT)
self.discovery.add_listener(self) self.discovery.add_listener(self)
@ -144,7 +150,7 @@ class DiscoveryService(Listener):
device.device_info.ip, device.device_info.ip,
device.device_info.port, device.device_info.port,
) )
coordo = DeviceDataUpdateCoordinator(self.hass, device) coordo = DeviceDataUpdateCoordinator(self.hass, self.entry, device)
self.hass.data[DOMAIN][COORDINATORS].append(coordo) self.hass.data[DOMAIN][COORDINATORS].append(coordo)
await coordo.async_refresh() await coordo.async_refresh()