ha_gehome/ge_kitchen/water_heater.py

"""GE Kitchen Sensor Entities"""
import async_timeout
import logging
from typing import Callable

from homeassistant.components.water_heater import WaterHeaterEntity
from homeassistant.config_entries import ConfigEntry
from homeassistant.core import HomeAssistant

from .entities import GeWaterHeater
from .const import DOMAIN
from .update_coordinator import GeKitchenUpdateCoordinator

_LOGGER = logging.getLogger(__name__)

async def async_setup_entry(hass: HomeAssistant, config_entry: ConfigEntry, async_add_entities: Callable):
    """GE Kitchen Water Heaters."""
    _LOGGER.debug('Adding GE "Water Heaters"')
    coordinator: GeKitchenUpdateCoordinator = hass.data[DOMAIN][config_entry.entry_id]

    # This should be a NOP, but let's be safe
    with async_timeout.timeout(20):
        await coordinator.initialization_future
    _LOGGER.debug('Coordinator init future finished')

    apis = list(coordinator.appliance_apis.values())
    _LOGGER.debug(f'Found {len(apis):d} appliance APIs')
    entities = [
        entity 
        for api in apis 
        for entity in api.entities
        if isinstance(entity, GeWaterHeater)
    ]
    _LOGGER.debug(f'Found {len(entities):d} "water heaters"')
    async_add_entities(entities)