-
-
Notifications
You must be signed in to change notification settings - Fork 35
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
6 changed files
with
224 additions
and
27 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,193 @@ | ||
| """Luxtronik heatpump number.""" | ||
| # region Imports | ||
| import logging | ||
| import time | ||
| from threading import Timer | ||
| from typing import Any, Final, Literal | ||
|
|
||
| from homeassistant.components.number import NumberEntity | ||
| from homeassistant.components.sensor import (ENTITY_ID_FORMAT, | ||
| STATE_CLASS_MEASUREMENT, | ||
| SensorEntity) | ||
| from homeassistant.config_entries import ConfigEntry | ||
| from homeassistant.const import (CONF_SENSORS, DEVICE_CLASS_TEMPERATURE, | ||
| DEVICE_CLASS_TIMESTAMP, PRECISION_HALVES, | ||
| PRECISION_TENTHS, TEMP_CELSIUS, TIME_SECONDS) | ||
| from homeassistant.core import HomeAssistant | ||
| from homeassistant.helpers.debounce import Debouncer | ||
| from homeassistant.helpers.entity import DeviceInfo, async_generate_entity_id | ||
| from homeassistant.helpers.entity_platform import AddEntitiesCallback | ||
| from homeassistant.helpers.typing import ConfigType, StateType | ||
| from homeassistant.helpers.update_coordinator import CoordinatorEntity | ||
|
|
||
| from . import LuxtronikDevice | ||
| from .const import * | ||
|
|
||
| # from .debounce import debounce | ||
|
|
||
| # from homeassistant.components.number.const import MODE_AUTO, MODE_BOX, MODE_SLIDER | ||
|
|
||
|
|
||
| # endregion Imports | ||
|
|
||
| # region Constants | ||
| # endregion Constants | ||
|
|
||
| def debounce(wait): | ||
| """ Decorator that will postpone a functions | ||
| execution until after wait seconds | ||
| have elapsed since the last time it was invoked. """ | ||
|
|
||
| def decorator(fn): | ||
| def debounced(*args, **kwargs): | ||
| def call_it(): | ||
| debounced._timer = None | ||
| debounced._last_call = time.time() | ||
| return fn(*args, **kwargs) | ||
|
|
||
| time_since_last_call = time.time() - debounced._last_call | ||
| if time_since_last_call >= wait: | ||
| return call_it() | ||
|
|
||
| if debounced._timer is None: | ||
| debounced._timer = Timer(wait - time_since_last_call, call_it) | ||
| debounced._timer.start() | ||
|
|
||
| debounced._timer = None | ||
| debounced._last_call = 0 | ||
|
|
||
| return debounced | ||
|
|
||
| return decorator | ||
|
|
||
|
|
||
| async def async_setup_platform( | ||
| hass: HomeAssistant, config: ConfigType, async_add_entities: AddEntitiesCallback, discovery_info: dict[str, Any] = None, | ||
| ) -> None: | ||
| luxtronik: LuxtronikDevice = hass.data.get(DOMAIN) | ||
| if not luxtronik: | ||
| LOGGER.warning("number.async_setup_platform no luxtronik!") | ||
| return False | ||
|
|
||
| deviceInfo = hass.data[f"{DOMAIN}_DeviceInfo"] | ||
| deviceInfoDomesticWater = hass.data[f"{DOMAIN}_DeviceInfo_Domestic_Water"] | ||
| deviceInfoHeating = hass.data[f"{DOMAIN}_DeviceInfo_Heating"] | ||
| entities = [ | ||
| LuxtronikNumber(hass, luxtronik, deviceInfoHeating, 'parameters.ID_Einst_WK_akt', | ||
| 'heating_temperature_correction', 'Temperature Correction', False, | ||
| 'mdi:plus-minus-variant', DEVICE_CLASS_TEMPERATURE, STATE_CLASS_MEASUREMENT, | ||
| TEMP_CELSIUS, -5.0, 5.0, 0.5), | ||
| ] | ||
| if luxtronik.get_value(LUX_SENSOR_DETECT_COOLING): | ||
| deviceInfoCooling = hass.data[f"{DOMAIN}_DeviceInfo_Cooling"] | ||
|
|
||
| async_add_entities(entities) | ||
|
|
||
|
|
||
| async def async_setup_entry( | ||
| hass: HomeAssistant, entry: ConfigEntry, async_add_entities: AddEntitiesCallback | ||
| ) -> None: | ||
| """Set up a Luxtronik number from ConfigEntry.""" | ||
| await async_setup_platform(hass, {}, async_add_entities) | ||
|
|
||
|
|
||
| class LuxtronikNumber(NumberEntity): | ||
| """Representation of a Luxtronik number.""" | ||
| _attr_should_poll = True | ||
|
|
||
| def __init__( | ||
| self, | ||
| hass: HomeAssistant, | ||
| luxtronik: LuxtronikDevice, | ||
| deviceInfo: DeviceInfo, | ||
| number_key: str, | ||
| unique_id: str, | ||
| name: str, | ||
| assumed: bool, | ||
| icon: str = 'mdi:thermometer', | ||
| device_class: str = DEVICE_CLASS_TEMPERATURE, | ||
| state_class: str = STATE_CLASS_MEASUREMENT, | ||
| unit_of_measurement: str = TEMP_CELSIUS, | ||
|
|
||
| min_value: float = None, # | None = None, | ||
| max_value: float = None, # | None = None, | ||
| step: float = None, # | None = None, | ||
| mode: Literal["auto", "box", "slider"] = "auto", # MODE_AUTO, | ||
| ) -> None: | ||
| """Initialize the number.""" | ||
| self._hass = hass | ||
| self._luxtronik = luxtronik | ||
| self._number_key = number_key | ||
|
|
||
| self.entity_id = ENTITY_ID_FORMAT.format(f"{DOMAIN}_{unique_id}") | ||
| self._attr_unique_id = self.entity_id | ||
| self._attr_device_class = device_class | ||
| self._attr_name = name | ||
| self._attr_assumed_state = assumed | ||
| self._icon = icon | ||
| # self._attr_icon = icon | ||
| self._attr_native_unit_of_measurement = unit_of_measurement | ||
| self._attr_state_class = state_class | ||
|
|
||
| self._attr_device_info = deviceInfo | ||
| self._attr_mode = mode | ||
|
|
||
| if min_value is not None: | ||
| self._attr_min_value = min_value | ||
| if max_value is not None: | ||
| self._attr_max_value = max_value | ||
| if step is not None: | ||
| self._attr_step = step | ||
|
|
||
| @property | ||
| def icon(self): # -> str | None: | ||
| """Return the icon to be used for this entity.""" | ||
| # if type(self._icon) is dict and not isinstance(self._icon, str): | ||
| # return self._icon[self.native_value()] | ||
| return self._icon | ||
|
|
||
| # @property | ||
| # def native_value(self): # -> float | int | None: | ||
| # """Return the state of the number.""" | ||
| # return self._luxtronik.get_value(self._number_key) | ||
|
|
||
| def update(self): | ||
| """Get the latest status and use it to update our sensor state.""" | ||
| self._luxtronik.update() | ||
|
|
||
| @property | ||
| def value(self) -> float: | ||
| """Return the state of the entity.""" | ||
| return self._luxtronik.get_value(self._number_key) | ||
|
|
||
| # @debounce(5) | ||
| async def async_set_value(self, value: float) -> None: | ||
| # def set_value(self, value: float) -> None: | ||
| """Update the current value.""" | ||
| LOGGER.info('async_set_value value: "%s"', value) | ||
|
|
||
| self._luxtronik.write(self._number_key.split('.')[1], value, False) | ||
|
|
||
| async def __async_set_value_internal(): | ||
| await self.__async_set_value_internal(value) | ||
|
|
||
| # Debouncer( | ||
| # self._hass, | ||
| # LOGGER, | ||
| # cooldown=3, | ||
| # immediate=True, | ||
| # function=__async_set_value_internal, | ||
| # ).async_call() | ||
|
|
||
| async def __async_set_value_internal(self, value) -> None: | ||
| LOGGER.info('__async_set_value_internal value: "%s"', value) | ||
| # self._attr_value = value | ||
| self._luxtronik.write(self._number_key.split('.')[1], value, True) | ||
| # await self.async_write_ha_state() | ||
| LOGGER.info('__async_set_value_internal ready value: "%s"', value) | ||
|
|
||
| # @callback | ||
| # def _update_and_write_state(self, *_): | ||
| # """Update the number and write state.""" | ||
| # self._update() | ||
| # self.async_write_ha_state() |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters