mirror of
https://github.com/home-assistant/core.git
synced 2025-07-22 20:57:21 +00:00
Move TemplateEntity to template (#98957)
* Move TemplateEntity to template * Rename template_entity in helpers
This commit is contained in:
parent
99e97782b6
commit
61c17291fb
@ -29,7 +29,7 @@ from homeassistant.helpers.entity_platform import AddEntitiesCallback
|
|||||||
from homeassistant.helpers.event import async_track_time_interval
|
from homeassistant.helpers.event import async_track_time_interval
|
||||||
from homeassistant.helpers.issue_registry import IssueSeverity, async_create_issue
|
from homeassistant.helpers.issue_registry import IssueSeverity, async_create_issue
|
||||||
from homeassistant.helpers.template import Template
|
from homeassistant.helpers.template import Template
|
||||||
from homeassistant.helpers.template_entity import ManualTriggerEntity
|
from homeassistant.helpers.trigger_template_entity import ManualTriggerEntity
|
||||||
from homeassistant.helpers.typing import ConfigType, DiscoveryInfoType
|
from homeassistant.helpers.typing import ConfigType, DiscoveryInfoType
|
||||||
from homeassistant.util import dt as dt_util
|
from homeassistant.util import dt as dt_util
|
||||||
|
|
||||||
|
@ -30,7 +30,7 @@ from homeassistant.helpers.entity_platform import AddEntitiesCallback
|
|||||||
from homeassistant.helpers.event import async_track_time_interval
|
from homeassistant.helpers.event import async_track_time_interval
|
||||||
from homeassistant.helpers.issue_registry import IssueSeverity, async_create_issue
|
from homeassistant.helpers.issue_registry import IssueSeverity, async_create_issue
|
||||||
from homeassistant.helpers.template import Template
|
from homeassistant.helpers.template import Template
|
||||||
from homeassistant.helpers.template_entity import ManualTriggerEntity
|
from homeassistant.helpers.trigger_template_entity import ManualTriggerEntity
|
||||||
from homeassistant.helpers.typing import ConfigType, DiscoveryInfoType
|
from homeassistant.helpers.typing import ConfigType, DiscoveryInfoType
|
||||||
from homeassistant.util import dt as dt_util, slugify
|
from homeassistant.util import dt as dt_util, slugify
|
||||||
|
|
||||||
|
@ -35,7 +35,7 @@ from homeassistant.helpers.entity_platform import AddEntitiesCallback
|
|||||||
from homeassistant.helpers.event import async_track_time_interval
|
from homeassistant.helpers.event import async_track_time_interval
|
||||||
from homeassistant.helpers.issue_registry import IssueSeverity, async_create_issue
|
from homeassistant.helpers.issue_registry import IssueSeverity, async_create_issue
|
||||||
from homeassistant.helpers.template import Template
|
from homeassistant.helpers.template import Template
|
||||||
from homeassistant.helpers.template_entity import (
|
from homeassistant.helpers.trigger_template_entity import (
|
||||||
CONF_AVAILABILITY,
|
CONF_AVAILABILITY,
|
||||||
CONF_PICTURE,
|
CONF_PICTURE,
|
||||||
ManualTriggerSensorEntity,
|
ManualTriggerSensorEntity,
|
||||||
|
@ -32,7 +32,7 @@ from homeassistant.helpers.entity_platform import AddEntitiesCallback
|
|||||||
from homeassistant.helpers.event import async_track_time_interval
|
from homeassistant.helpers.event import async_track_time_interval
|
||||||
from homeassistant.helpers.issue_registry import IssueSeverity, async_create_issue
|
from homeassistant.helpers.issue_registry import IssueSeverity, async_create_issue
|
||||||
from homeassistant.helpers.template import Template
|
from homeassistant.helpers.template import Template
|
||||||
from homeassistant.helpers.template_entity import ManualTriggerEntity
|
from homeassistant.helpers.trigger_template_entity import ManualTriggerEntity
|
||||||
from homeassistant.helpers.typing import ConfigType, DiscoveryInfoType
|
from homeassistant.helpers.typing import ConfigType, DiscoveryInfoType
|
||||||
from homeassistant.util import dt as dt_util, slugify
|
from homeassistant.util import dt as dt_util, slugify
|
||||||
|
|
||||||
|
@ -26,7 +26,7 @@ from homeassistant.exceptions import PlatformNotReady
|
|||||||
import homeassistant.helpers.config_validation as cv
|
import homeassistant.helpers.config_validation as cv
|
||||||
from homeassistant.helpers.entity_platform import AddEntitiesCallback
|
from homeassistant.helpers.entity_platform import AddEntitiesCallback
|
||||||
from homeassistant.helpers.template import Template
|
from homeassistant.helpers.template import Template
|
||||||
from homeassistant.helpers.template_entity import (
|
from homeassistant.helpers.trigger_template_entity import (
|
||||||
CONF_AVAILABILITY,
|
CONF_AVAILABILITY,
|
||||||
CONF_PICTURE,
|
CONF_PICTURE,
|
||||||
ManualTriggerEntity,
|
ManualTriggerEntity,
|
||||||
|
@ -27,7 +27,7 @@ from homeassistant.const import (
|
|||||||
HTTP_DIGEST_AUTHENTICATION,
|
HTTP_DIGEST_AUTHENTICATION,
|
||||||
)
|
)
|
||||||
import homeassistant.helpers.config_validation as cv
|
import homeassistant.helpers.config_validation as cv
|
||||||
from homeassistant.helpers.template_entity import (
|
from homeassistant.helpers.trigger_template_entity import (
|
||||||
CONF_AVAILABILITY,
|
CONF_AVAILABILITY,
|
||||||
TEMPLATE_ENTITY_BASE_SCHEMA,
|
TEMPLATE_ENTITY_BASE_SCHEMA,
|
||||||
TEMPLATE_SENSOR_BASE_SCHEMA,
|
TEMPLATE_SENSOR_BASE_SCHEMA,
|
||||||
|
@ -30,7 +30,7 @@ from homeassistant.exceptions import PlatformNotReady
|
|||||||
import homeassistant.helpers.config_validation as cv
|
import homeassistant.helpers.config_validation as cv
|
||||||
from homeassistant.helpers.entity_platform import AddEntitiesCallback
|
from homeassistant.helpers.entity_platform import AddEntitiesCallback
|
||||||
from homeassistant.helpers.template import Template
|
from homeassistant.helpers.template import Template
|
||||||
from homeassistant.helpers.template_entity import (
|
from homeassistant.helpers.trigger_template_entity import (
|
||||||
CONF_AVAILABILITY,
|
CONF_AVAILABILITY,
|
||||||
CONF_PICTURE,
|
CONF_PICTURE,
|
||||||
ManualTriggerSensorEntity,
|
ManualTriggerSensorEntity,
|
||||||
|
@ -33,7 +33,7 @@ from homeassistant.exceptions import PlatformNotReady
|
|||||||
from homeassistant.helpers import config_validation as cv, template
|
from homeassistant.helpers import config_validation as cv, template
|
||||||
from homeassistant.helpers.entity_platform import AddEntitiesCallback
|
from homeassistant.helpers.entity_platform import AddEntitiesCallback
|
||||||
from homeassistant.helpers.httpx_client import get_async_client
|
from homeassistant.helpers.httpx_client import get_async_client
|
||||||
from homeassistant.helpers.template_entity import (
|
from homeassistant.helpers.trigger_template_entity import (
|
||||||
CONF_AVAILABILITY,
|
CONF_AVAILABILITY,
|
||||||
CONF_PICTURE,
|
CONF_PICTURE,
|
||||||
TEMPLATE_ENTITY_BASE_SCHEMA,
|
TEMPLATE_ENTITY_BASE_SCHEMA,
|
||||||
|
@ -20,7 +20,7 @@ from homeassistant.const import (
|
|||||||
from homeassistant.core import HomeAssistant
|
from homeassistant.core import HomeAssistant
|
||||||
from homeassistant.helpers import discovery
|
from homeassistant.helpers import discovery
|
||||||
import homeassistant.helpers.config_validation as cv
|
import homeassistant.helpers.config_validation as cv
|
||||||
from homeassistant.helpers.template_entity import (
|
from homeassistant.helpers.trigger_template_entity import (
|
||||||
CONF_AVAILABILITY,
|
CONF_AVAILABILITY,
|
||||||
TEMPLATE_SENSOR_BASE_SCHEMA,
|
TEMPLATE_SENSOR_BASE_SCHEMA,
|
||||||
)
|
)
|
||||||
|
@ -23,7 +23,7 @@ from homeassistant.exceptions import PlatformNotReady
|
|||||||
from homeassistant.helpers.device_registry import DeviceEntryType, DeviceInfo
|
from homeassistant.helpers.device_registry import DeviceEntryType, DeviceInfo
|
||||||
from homeassistant.helpers.entity_platform import AddEntitiesCallback
|
from homeassistant.helpers.entity_platform import AddEntitiesCallback
|
||||||
from homeassistant.helpers.template import Template
|
from homeassistant.helpers.template import Template
|
||||||
from homeassistant.helpers.template_entity import (
|
from homeassistant.helpers.trigger_template_entity import (
|
||||||
CONF_AVAILABILITY,
|
CONF_AVAILABILITY,
|
||||||
CONF_PICTURE,
|
CONF_PICTURE,
|
||||||
TEMPLATE_SENSOR_BASE_SCHEMA,
|
TEMPLATE_SENSOR_BASE_SCHEMA,
|
||||||
|
@ -36,7 +36,7 @@ from homeassistant.core import HomeAssistant
|
|||||||
import homeassistant.helpers.config_validation as cv
|
import homeassistant.helpers.config_validation as cv
|
||||||
from homeassistant.helpers.entity_platform import AddEntitiesCallback
|
from homeassistant.helpers.entity_platform import AddEntitiesCallback
|
||||||
from homeassistant.helpers.template import Template
|
from homeassistant.helpers.template import Template
|
||||||
from homeassistant.helpers.template_entity import (
|
from homeassistant.helpers.trigger_template_entity import (
|
||||||
CONF_AVAILABILITY,
|
CONF_AVAILABILITY,
|
||||||
CONF_PICTURE,
|
CONF_PICTURE,
|
||||||
TEMPLATE_SENSOR_BASE_SCHEMA,
|
TEMPLATE_SENSOR_BASE_SCHEMA,
|
||||||
|
@ -24,7 +24,10 @@ from homeassistant.const import (
|
|||||||
from homeassistant.core import HomeAssistant
|
from homeassistant.core import HomeAssistant
|
||||||
from homeassistant.helpers import discovery
|
from homeassistant.helpers import discovery
|
||||||
import homeassistant.helpers.config_validation as cv
|
import homeassistant.helpers.config_validation as cv
|
||||||
from homeassistant.helpers.template_entity import CONF_AVAILABILITY, CONF_PICTURE
|
from homeassistant.helpers.trigger_template_entity import (
|
||||||
|
CONF_AVAILABILITY,
|
||||||
|
CONF_PICTURE,
|
||||||
|
)
|
||||||
from homeassistant.helpers.typing import ConfigType
|
from homeassistant.helpers.typing import ConfigType
|
||||||
|
|
||||||
from .const import CONF_COLUMN_NAME, CONF_QUERY, DOMAIN, PLATFORMS
|
from .const import CONF_COLUMN_NAME, CONF_QUERY, DOMAIN, PLATFORMS
|
||||||
|
@ -36,7 +36,7 @@ from homeassistant.helpers import issue_registry as ir
|
|||||||
from homeassistant.helpers.device_registry import DeviceEntryType, DeviceInfo
|
from homeassistant.helpers.device_registry import DeviceEntryType, DeviceInfo
|
||||||
from homeassistant.helpers.entity_platform import AddEntitiesCallback
|
from homeassistant.helpers.entity_platform import AddEntitiesCallback
|
||||||
from homeassistant.helpers.template import Template
|
from homeassistant.helpers.template import Template
|
||||||
from homeassistant.helpers.template_entity import (
|
from homeassistant.helpers.trigger_template_entity import (
|
||||||
CONF_AVAILABILITY,
|
CONF_AVAILABILITY,
|
||||||
CONF_PICTURE,
|
CONF_PICTURE,
|
||||||
ManualTriggerSensorEntity,
|
ManualTriggerSensorEntity,
|
||||||
|
@ -38,10 +38,7 @@ from homeassistant.exceptions import TemplateError
|
|||||||
from homeassistant.helpers import config_validation as cv, template
|
from homeassistant.helpers import config_validation as cv, template
|
||||||
from homeassistant.helpers.entity import async_generate_entity_id
|
from homeassistant.helpers.entity import async_generate_entity_id
|
||||||
from homeassistant.helpers.entity_platform import AddEntitiesCallback
|
from homeassistant.helpers.entity_platform import AddEntitiesCallback
|
||||||
from homeassistant.helpers.template_entity import (
|
from homeassistant.helpers.trigger_template_entity import TEMPLATE_SENSOR_BASE_SCHEMA
|
||||||
TEMPLATE_SENSOR_BASE_SCHEMA,
|
|
||||||
TemplateEntity,
|
|
||||||
)
|
|
||||||
from homeassistant.helpers.typing import ConfigType, DiscoveryInfoType
|
from homeassistant.helpers.typing import ConfigType, DiscoveryInfoType
|
||||||
|
|
||||||
from .const import (
|
from .const import (
|
||||||
@ -52,6 +49,7 @@ from .const import (
|
|||||||
)
|
)
|
||||||
from .template_entity import (
|
from .template_entity import (
|
||||||
TEMPLATE_ENTITY_COMMON_SCHEMA,
|
TEMPLATE_ENTITY_COMMON_SCHEMA,
|
||||||
|
TemplateEntity,
|
||||||
rewrite_common_legacy_to_modern_conf,
|
rewrite_common_legacy_to_modern_conf,
|
||||||
)
|
)
|
||||||
from .trigger_entity import TriggerEntity
|
from .trigger_entity import TriggerEntity
|
||||||
|
@ -1,7 +1,10 @@
|
|||||||
"""TemplateEntity utility class."""
|
"""TemplateEntity utility class."""
|
||||||
from __future__ import annotations
|
from __future__ import annotations
|
||||||
|
|
||||||
|
from collections.abc import Callable
|
||||||
|
import contextlib
|
||||||
import itertools
|
import itertools
|
||||||
|
import logging
|
||||||
from typing import Any
|
from typing import Any
|
||||||
|
|
||||||
import voluptuous as vol
|
import voluptuous as vol
|
||||||
@ -12,14 +15,30 @@ from homeassistant.const import (
|
|||||||
CONF_ICON,
|
CONF_ICON,
|
||||||
CONF_ICON_TEMPLATE,
|
CONF_ICON_TEMPLATE,
|
||||||
CONF_NAME,
|
CONF_NAME,
|
||||||
|
EVENT_HOMEASSISTANT_START,
|
||||||
|
STATE_UNKNOWN,
|
||||||
)
|
)
|
||||||
|
from homeassistant.core import Context, CoreState, HomeAssistant, State, callback
|
||||||
|
from homeassistant.exceptions import TemplateError
|
||||||
import homeassistant.helpers.config_validation as cv
|
import homeassistant.helpers.config_validation as cv
|
||||||
from homeassistant.helpers.template import Template
|
from homeassistant.helpers.entity import Entity
|
||||||
from homeassistant.helpers.template_entity import ( # noqa: F401
|
from homeassistant.helpers.event import (
|
||||||
|
EventStateChangedData,
|
||||||
|
TrackTemplate,
|
||||||
|
TrackTemplateResult,
|
||||||
|
async_track_template_result,
|
||||||
|
)
|
||||||
|
from homeassistant.helpers.script import Script, _VarsType
|
||||||
|
from homeassistant.helpers.template import (
|
||||||
|
Template,
|
||||||
|
TemplateStateFromEntityId,
|
||||||
|
result_as_boolean,
|
||||||
|
)
|
||||||
|
from homeassistant.helpers.trigger_template_entity import (
|
||||||
TEMPLATE_ENTITY_BASE_SCHEMA,
|
TEMPLATE_ENTITY_BASE_SCHEMA,
|
||||||
TemplateEntity,
|
|
||||||
make_template_entity_base_schema,
|
make_template_entity_base_schema,
|
||||||
)
|
)
|
||||||
|
from homeassistant.helpers.typing import ConfigType, EventType
|
||||||
|
|
||||||
from .const import (
|
from .const import (
|
||||||
CONF_ATTRIBUTE_TEMPLATES,
|
CONF_ATTRIBUTE_TEMPLATES,
|
||||||
@ -29,6 +48,8 @@ from .const import (
|
|||||||
CONF_PICTURE,
|
CONF_PICTURE,
|
||||||
)
|
)
|
||||||
|
|
||||||
|
_LOGGER = logging.getLogger(__name__)
|
||||||
|
|
||||||
TEMPLATE_ENTITY_AVAILABILITY_SCHEMA = vol.Schema(
|
TEMPLATE_ENTITY_AVAILABILITY_SCHEMA = vol.Schema(
|
||||||
{
|
{
|
||||||
vol.Optional(CONF_AVAILABILITY): cv.template,
|
vol.Optional(CONF_AVAILABILITY): cv.template,
|
||||||
@ -113,3 +134,366 @@ def rewrite_common_legacy_to_modern_conf(
|
|||||||
entity_cfg[CONF_NAME] = Template(entity_cfg[CONF_NAME])
|
entity_cfg[CONF_NAME] = Template(entity_cfg[CONF_NAME])
|
||||||
|
|
||||||
return entity_cfg
|
return entity_cfg
|
||||||
|
|
||||||
|
|
||||||
|
class _TemplateAttribute:
|
||||||
|
"""Attribute value linked to template result."""
|
||||||
|
|
||||||
|
def __init__(
|
||||||
|
self,
|
||||||
|
entity: Entity,
|
||||||
|
attribute: str,
|
||||||
|
template: Template,
|
||||||
|
validator: Callable[[Any], Any] | None = None,
|
||||||
|
on_update: Callable[[Any], None] | None = None,
|
||||||
|
none_on_template_error: bool | None = False,
|
||||||
|
) -> None:
|
||||||
|
"""Template attribute."""
|
||||||
|
self._entity = entity
|
||||||
|
self._attribute = attribute
|
||||||
|
self.template = template
|
||||||
|
self.validator = validator
|
||||||
|
self.on_update = on_update
|
||||||
|
self.async_update = None
|
||||||
|
self.none_on_template_error = none_on_template_error
|
||||||
|
|
||||||
|
@callback
|
||||||
|
def async_setup(self) -> None:
|
||||||
|
"""Config update path for the attribute."""
|
||||||
|
if self.on_update:
|
||||||
|
return
|
||||||
|
|
||||||
|
if not hasattr(self._entity, self._attribute):
|
||||||
|
raise AttributeError(f"Attribute '{self._attribute}' does not exist.")
|
||||||
|
|
||||||
|
self.on_update = self._default_update
|
||||||
|
|
||||||
|
@callback
|
||||||
|
def _default_update(self, result: str | TemplateError) -> None:
|
||||||
|
attr_result = None if isinstance(result, TemplateError) else result
|
||||||
|
setattr(self._entity, self._attribute, attr_result)
|
||||||
|
|
||||||
|
@callback
|
||||||
|
def handle_result(
|
||||||
|
self,
|
||||||
|
event: EventType[EventStateChangedData] | None,
|
||||||
|
template: Template,
|
||||||
|
last_result: str | None | TemplateError,
|
||||||
|
result: str | TemplateError,
|
||||||
|
) -> None:
|
||||||
|
"""Handle a template result event callback."""
|
||||||
|
if isinstance(result, TemplateError):
|
||||||
|
_LOGGER.error(
|
||||||
|
(
|
||||||
|
"TemplateError('%s') "
|
||||||
|
"while processing template '%s' "
|
||||||
|
"for attribute '%s' in entity '%s'"
|
||||||
|
),
|
||||||
|
result,
|
||||||
|
self.template,
|
||||||
|
self._attribute,
|
||||||
|
self._entity.entity_id,
|
||||||
|
)
|
||||||
|
if self.none_on_template_error:
|
||||||
|
self._default_update(result)
|
||||||
|
else:
|
||||||
|
assert self.on_update
|
||||||
|
self.on_update(result)
|
||||||
|
return
|
||||||
|
|
||||||
|
if not self.validator:
|
||||||
|
assert self.on_update
|
||||||
|
self.on_update(result)
|
||||||
|
return
|
||||||
|
|
||||||
|
try:
|
||||||
|
validated = self.validator(result)
|
||||||
|
except vol.Invalid as ex:
|
||||||
|
_LOGGER.error(
|
||||||
|
(
|
||||||
|
"Error validating template result '%s' "
|
||||||
|
"from template '%s' "
|
||||||
|
"for attribute '%s' in entity %s "
|
||||||
|
"validation message '%s'"
|
||||||
|
),
|
||||||
|
result,
|
||||||
|
self.template,
|
||||||
|
self._attribute,
|
||||||
|
self._entity.entity_id,
|
||||||
|
ex.msg,
|
||||||
|
)
|
||||||
|
assert self.on_update
|
||||||
|
self.on_update(None)
|
||||||
|
return
|
||||||
|
|
||||||
|
assert self.on_update
|
||||||
|
self.on_update(validated)
|
||||||
|
return
|
||||||
|
|
||||||
|
|
||||||
|
class TemplateEntity(Entity):
|
||||||
|
"""Entity that uses templates to calculate attributes."""
|
||||||
|
|
||||||
|
_attr_available = True
|
||||||
|
_attr_entity_picture = None
|
||||||
|
_attr_icon = None
|
||||||
|
|
||||||
|
def __init__(
|
||||||
|
self,
|
||||||
|
hass: HomeAssistant,
|
||||||
|
*,
|
||||||
|
availability_template: Template | None = None,
|
||||||
|
icon_template: Template | None = None,
|
||||||
|
entity_picture_template: Template | None = None,
|
||||||
|
attribute_templates: dict[str, Template] | None = None,
|
||||||
|
config: ConfigType | None = None,
|
||||||
|
fallback_name: str | None = None,
|
||||||
|
unique_id: str | None = None,
|
||||||
|
) -> None:
|
||||||
|
"""Template Entity."""
|
||||||
|
self._template_attrs: dict[Template, list[_TemplateAttribute]] = {}
|
||||||
|
self._async_update: Callable[[], None] | None = None
|
||||||
|
self._attr_extra_state_attributes = {}
|
||||||
|
self._self_ref_update_count = 0
|
||||||
|
self._attr_unique_id = unique_id
|
||||||
|
if config is None:
|
||||||
|
self._attribute_templates = attribute_templates
|
||||||
|
self._availability_template = availability_template
|
||||||
|
self._icon_template = icon_template
|
||||||
|
self._entity_picture_template = entity_picture_template
|
||||||
|
self._friendly_name_template = None
|
||||||
|
else:
|
||||||
|
self._attribute_templates = config.get(CONF_ATTRIBUTES)
|
||||||
|
self._availability_template = config.get(CONF_AVAILABILITY)
|
||||||
|
self._icon_template = config.get(CONF_ICON)
|
||||||
|
self._entity_picture_template = config.get(CONF_PICTURE)
|
||||||
|
self._friendly_name_template = config.get(CONF_NAME)
|
||||||
|
|
||||||
|
class DummyState(State):
|
||||||
|
"""None-state for template entities not yet added to the state machine."""
|
||||||
|
|
||||||
|
def __init__(self) -> None:
|
||||||
|
"""Initialize a new state."""
|
||||||
|
super().__init__("unknown.unknown", STATE_UNKNOWN)
|
||||||
|
self.entity_id = None # type: ignore[assignment]
|
||||||
|
|
||||||
|
@property
|
||||||
|
def name(self) -> str:
|
||||||
|
"""Name of this state."""
|
||||||
|
return "<None>"
|
||||||
|
|
||||||
|
variables = {"this": DummyState()}
|
||||||
|
|
||||||
|
# Try to render the name as it can influence the entity ID
|
||||||
|
self._attr_name = fallback_name
|
||||||
|
if self._friendly_name_template:
|
||||||
|
self._friendly_name_template.hass = hass
|
||||||
|
with contextlib.suppress(TemplateError):
|
||||||
|
self._attr_name = self._friendly_name_template.async_render(
|
||||||
|
variables=variables, parse_result=False
|
||||||
|
)
|
||||||
|
|
||||||
|
# Templates will not render while the entity is unavailable, try to render the
|
||||||
|
# icon and picture templates.
|
||||||
|
if self._entity_picture_template:
|
||||||
|
self._entity_picture_template.hass = hass
|
||||||
|
with contextlib.suppress(TemplateError):
|
||||||
|
self._attr_entity_picture = self._entity_picture_template.async_render(
|
||||||
|
variables=variables, parse_result=False
|
||||||
|
)
|
||||||
|
|
||||||
|
if self._icon_template:
|
||||||
|
self._icon_template.hass = hass
|
||||||
|
with contextlib.suppress(TemplateError):
|
||||||
|
self._attr_icon = self._icon_template.async_render(
|
||||||
|
variables=variables, parse_result=False
|
||||||
|
)
|
||||||
|
|
||||||
|
@callback
|
||||||
|
def _update_available(self, result: str | TemplateError) -> None:
|
||||||
|
if isinstance(result, TemplateError):
|
||||||
|
self._attr_available = True
|
||||||
|
return
|
||||||
|
|
||||||
|
self._attr_available = result_as_boolean(result)
|
||||||
|
|
||||||
|
@callback
|
||||||
|
def _update_state(self, result: str | TemplateError) -> None:
|
||||||
|
if self._availability_template:
|
||||||
|
return
|
||||||
|
|
||||||
|
self._attr_available = not isinstance(result, TemplateError)
|
||||||
|
|
||||||
|
@callback
|
||||||
|
def _add_attribute_template(
|
||||||
|
self, attribute_key: str, attribute_template: Template
|
||||||
|
) -> None:
|
||||||
|
"""Create a template tracker for the attribute."""
|
||||||
|
|
||||||
|
def _update_attribute(result: str | TemplateError) -> None:
|
||||||
|
attr_result = None if isinstance(result, TemplateError) else result
|
||||||
|
self._attr_extra_state_attributes[attribute_key] = attr_result
|
||||||
|
|
||||||
|
self.add_template_attribute(
|
||||||
|
attribute_key, attribute_template, None, _update_attribute
|
||||||
|
)
|
||||||
|
|
||||||
|
def add_template_attribute(
|
||||||
|
self,
|
||||||
|
attribute: str,
|
||||||
|
template: Template,
|
||||||
|
validator: Callable[[Any], Any] | None = None,
|
||||||
|
on_update: Callable[[Any], None] | None = None,
|
||||||
|
none_on_template_error: bool = False,
|
||||||
|
) -> None:
|
||||||
|
"""Call in the constructor to add a template linked to a attribute.
|
||||||
|
|
||||||
|
Parameters
|
||||||
|
----------
|
||||||
|
attribute
|
||||||
|
The name of the attribute to link to. This attribute must exist
|
||||||
|
unless a custom on_update method is supplied.
|
||||||
|
template
|
||||||
|
The template to calculate.
|
||||||
|
validator
|
||||||
|
Validator function to parse the result and ensure it's valid.
|
||||||
|
on_update
|
||||||
|
Called to store the template result rather than storing it
|
||||||
|
the supplied attribute. Passed the result of the validator, or None
|
||||||
|
if the template or validator resulted in an error.
|
||||||
|
none_on_template_error
|
||||||
|
If True, the attribute will be set to None if the template errors.
|
||||||
|
|
||||||
|
"""
|
||||||
|
assert self.hass is not None, "hass cannot be None"
|
||||||
|
template.hass = self.hass
|
||||||
|
template_attribute = _TemplateAttribute(
|
||||||
|
self, attribute, template, validator, on_update, none_on_template_error
|
||||||
|
)
|
||||||
|
self._template_attrs.setdefault(template, [])
|
||||||
|
self._template_attrs[template].append(template_attribute)
|
||||||
|
|
||||||
|
@callback
|
||||||
|
def _handle_results(
|
||||||
|
self,
|
||||||
|
event: EventType[EventStateChangedData] | None,
|
||||||
|
updates: list[TrackTemplateResult],
|
||||||
|
) -> None:
|
||||||
|
"""Call back the results to the attributes."""
|
||||||
|
if event:
|
||||||
|
self.async_set_context(event.context)
|
||||||
|
|
||||||
|
entity_id = event and event.data["entity_id"]
|
||||||
|
|
||||||
|
if entity_id and entity_id == self.entity_id:
|
||||||
|
self._self_ref_update_count += 1
|
||||||
|
else:
|
||||||
|
self._self_ref_update_count = 0
|
||||||
|
|
||||||
|
if self._self_ref_update_count > len(self._template_attrs):
|
||||||
|
for update in updates:
|
||||||
|
_LOGGER.warning(
|
||||||
|
(
|
||||||
|
"Template loop detected while processing event: %s, skipping"
|
||||||
|
" template render for Template[%s]"
|
||||||
|
),
|
||||||
|
event,
|
||||||
|
update.template.template,
|
||||||
|
)
|
||||||
|
return
|
||||||
|
|
||||||
|
for update in updates:
|
||||||
|
for attr in self._template_attrs[update.template]:
|
||||||
|
attr.handle_result(
|
||||||
|
event, update.template, update.last_result, update.result
|
||||||
|
)
|
||||||
|
|
||||||
|
self.async_write_ha_state()
|
||||||
|
|
||||||
|
async def _async_template_startup(self, *_: Any) -> None:
|
||||||
|
template_var_tups: list[TrackTemplate] = []
|
||||||
|
has_availability_template = False
|
||||||
|
|
||||||
|
variables = {"this": TemplateStateFromEntityId(self.hass, self.entity_id)}
|
||||||
|
|
||||||
|
for template, attributes in self._template_attrs.items():
|
||||||
|
template_var_tup = TrackTemplate(template, variables)
|
||||||
|
is_availability_template = False
|
||||||
|
for attribute in attributes:
|
||||||
|
# pylint: disable-next=protected-access
|
||||||
|
if attribute._attribute == "_attr_available":
|
||||||
|
has_availability_template = True
|
||||||
|
is_availability_template = True
|
||||||
|
attribute.async_setup()
|
||||||
|
# Insert the availability template first in the list
|
||||||
|
if is_availability_template:
|
||||||
|
template_var_tups.insert(0, template_var_tup)
|
||||||
|
else:
|
||||||
|
template_var_tups.append(template_var_tup)
|
||||||
|
|
||||||
|
result_info = async_track_template_result(
|
||||||
|
self.hass,
|
||||||
|
template_var_tups,
|
||||||
|
self._handle_results,
|
||||||
|
has_super_template=has_availability_template,
|
||||||
|
)
|
||||||
|
self.async_on_remove(result_info.async_remove)
|
||||||
|
self._async_update = result_info.async_refresh
|
||||||
|
result_info.async_refresh()
|
||||||
|
|
||||||
|
async def async_added_to_hass(self) -> None:
|
||||||
|
"""Run when entity about to be added to hass."""
|
||||||
|
if self._availability_template is not None:
|
||||||
|
self.add_template_attribute(
|
||||||
|
"_attr_available",
|
||||||
|
self._availability_template,
|
||||||
|
None,
|
||||||
|
self._update_available,
|
||||||
|
)
|
||||||
|
if self._attribute_templates is not None:
|
||||||
|
for key, value in self._attribute_templates.items():
|
||||||
|
self._add_attribute_template(key, value)
|
||||||
|
if self._icon_template is not None:
|
||||||
|
self.add_template_attribute(
|
||||||
|
"_attr_icon", self._icon_template, vol.Or(cv.whitespace, cv.icon)
|
||||||
|
)
|
||||||
|
if self._entity_picture_template is not None:
|
||||||
|
self.add_template_attribute(
|
||||||
|
"_attr_entity_picture", self._entity_picture_template
|
||||||
|
)
|
||||||
|
if (
|
||||||
|
self._friendly_name_template is not None
|
||||||
|
and not self._friendly_name_template.is_static
|
||||||
|
):
|
||||||
|
self.add_template_attribute("_attr_name", self._friendly_name_template)
|
||||||
|
|
||||||
|
if self.hass.state == CoreState.running:
|
||||||
|
await self._async_template_startup()
|
||||||
|
return
|
||||||
|
|
||||||
|
self.hass.bus.async_listen_once(
|
||||||
|
EVENT_HOMEASSISTANT_START, self._async_template_startup
|
||||||
|
)
|
||||||
|
|
||||||
|
async def async_update(self) -> None:
|
||||||
|
"""Call for forced update."""
|
||||||
|
assert self._async_update
|
||||||
|
self._async_update()
|
||||||
|
|
||||||
|
async def async_run_script(
|
||||||
|
self,
|
||||||
|
script: Script,
|
||||||
|
*,
|
||||||
|
run_variables: _VarsType | None = None,
|
||||||
|
context: Context | None = None,
|
||||||
|
) -> None:
|
||||||
|
"""Run an action script."""
|
||||||
|
if run_variables is None:
|
||||||
|
run_variables = {}
|
||||||
|
await script.async_run(
|
||||||
|
run_variables={
|
||||||
|
"this": TemplateStateFromEntityId(self.hass, self.entity_id),
|
||||||
|
**run_variables,
|
||||||
|
},
|
||||||
|
context=context,
|
||||||
|
)
|
||||||
|
@ -2,7 +2,7 @@
|
|||||||
from __future__ import annotations
|
from __future__ import annotations
|
||||||
|
|
||||||
from homeassistant.core import HomeAssistant, callback
|
from homeassistant.core import HomeAssistant, callback
|
||||||
from homeassistant.helpers.template_entity import TriggerBaseEntity
|
from homeassistant.helpers.trigger_template_entity import TriggerBaseEntity
|
||||||
from homeassistant.helpers.update_coordinator import CoordinatorEntity
|
from homeassistant.helpers.update_coordinator import CoordinatorEntity
|
||||||
|
|
||||||
from . import TriggerUpdateCoordinator
|
from . import TriggerUpdateCoordinator
|
||||||
|
@ -1,648 +0,0 @@
|
|||||||
"""TemplateEntity utility class."""
|
|
||||||
from __future__ import annotations
|
|
||||||
|
|
||||||
from collections.abc import Callable
|
|
||||||
import contextlib
|
|
||||||
import logging
|
|
||||||
from typing import Any
|
|
||||||
|
|
||||||
import voluptuous as vol
|
|
||||||
|
|
||||||
from homeassistant.components.sensor import (
|
|
||||||
CONF_STATE_CLASS,
|
|
||||||
DEVICE_CLASSES_SCHEMA,
|
|
||||||
STATE_CLASSES_SCHEMA,
|
|
||||||
SensorEntity,
|
|
||||||
)
|
|
||||||
from homeassistant.const import (
|
|
||||||
ATTR_ENTITY_PICTURE,
|
|
||||||
ATTR_FRIENDLY_NAME,
|
|
||||||
ATTR_ICON,
|
|
||||||
CONF_DEVICE_CLASS,
|
|
||||||
CONF_ICON,
|
|
||||||
CONF_NAME,
|
|
||||||
CONF_UNIQUE_ID,
|
|
||||||
CONF_UNIT_OF_MEASUREMENT,
|
|
||||||
EVENT_HOMEASSISTANT_START,
|
|
||||||
STATE_UNKNOWN,
|
|
||||||
)
|
|
||||||
from homeassistant.core import Context, CoreState, HomeAssistant, State, callback
|
|
||||||
from homeassistant.exceptions import TemplateError
|
|
||||||
from homeassistant.util.json import JSON_DECODE_EXCEPTIONS, json_loads
|
|
||||||
|
|
||||||
from . import config_validation as cv
|
|
||||||
from .entity import Entity
|
|
||||||
from .event import (
|
|
||||||
EventStateChangedData,
|
|
||||||
TrackTemplate,
|
|
||||||
TrackTemplateResult,
|
|
||||||
async_track_template_result,
|
|
||||||
)
|
|
||||||
from .script import Script, _VarsType
|
|
||||||
from .template import (
|
|
||||||
Template,
|
|
||||||
TemplateStateFromEntityId,
|
|
||||||
attach as template_attach,
|
|
||||||
render_complex,
|
|
||||||
result_as_boolean,
|
|
||||||
)
|
|
||||||
from .typing import ConfigType, EventType
|
|
||||||
|
|
||||||
_LOGGER = logging.getLogger(__name__)
|
|
||||||
|
|
||||||
CONF_AVAILABILITY = "availability"
|
|
||||||
CONF_ATTRIBUTES = "attributes"
|
|
||||||
CONF_PICTURE = "picture"
|
|
||||||
|
|
||||||
CONF_TO_ATTRIBUTE = {
|
|
||||||
CONF_ICON: ATTR_ICON,
|
|
||||||
CONF_NAME: ATTR_FRIENDLY_NAME,
|
|
||||||
CONF_PICTURE: ATTR_ENTITY_PICTURE,
|
|
||||||
}
|
|
||||||
|
|
||||||
TEMPLATE_ENTITY_BASE_SCHEMA = vol.Schema(
|
|
||||||
{
|
|
||||||
vol.Optional(CONF_ICON): cv.template,
|
|
||||||
vol.Optional(CONF_NAME): cv.template,
|
|
||||||
vol.Optional(CONF_PICTURE): cv.template,
|
|
||||||
vol.Optional(CONF_UNIQUE_ID): cv.string,
|
|
||||||
}
|
|
||||||
)
|
|
||||||
|
|
||||||
|
|
||||||
def make_template_entity_base_schema(default_name: str) -> vol.Schema:
|
|
||||||
"""Return a schema with default name."""
|
|
||||||
return vol.Schema(
|
|
||||||
{
|
|
||||||
vol.Optional(CONF_ICON): cv.template,
|
|
||||||
vol.Optional(CONF_NAME, default=default_name): cv.template,
|
|
||||||
vol.Optional(CONF_PICTURE): cv.template,
|
|
||||||
vol.Optional(CONF_UNIQUE_ID): cv.string,
|
|
||||||
}
|
|
||||||
)
|
|
||||||
|
|
||||||
|
|
||||||
TEMPLATE_SENSOR_BASE_SCHEMA = vol.Schema(
|
|
||||||
{
|
|
||||||
vol.Optional(CONF_DEVICE_CLASS): DEVICE_CLASSES_SCHEMA,
|
|
||||||
vol.Optional(CONF_STATE_CLASS): STATE_CLASSES_SCHEMA,
|
|
||||||
vol.Optional(CONF_UNIT_OF_MEASUREMENT): cv.string,
|
|
||||||
}
|
|
||||||
).extend(TEMPLATE_ENTITY_BASE_SCHEMA.schema)
|
|
||||||
|
|
||||||
|
|
||||||
class _TemplateAttribute:
|
|
||||||
"""Attribute value linked to template result."""
|
|
||||||
|
|
||||||
def __init__(
|
|
||||||
self,
|
|
||||||
entity: Entity,
|
|
||||||
attribute: str,
|
|
||||||
template: Template,
|
|
||||||
validator: Callable[[Any], Any] | None = None,
|
|
||||||
on_update: Callable[[Any], None] | None = None,
|
|
||||||
none_on_template_error: bool | None = False,
|
|
||||||
) -> None:
|
|
||||||
"""Template attribute."""
|
|
||||||
self._entity = entity
|
|
||||||
self._attribute = attribute
|
|
||||||
self.template = template
|
|
||||||
self.validator = validator
|
|
||||||
self.on_update = on_update
|
|
||||||
self.async_update = None
|
|
||||||
self.none_on_template_error = none_on_template_error
|
|
||||||
|
|
||||||
@callback
|
|
||||||
def async_setup(self) -> None:
|
|
||||||
"""Config update path for the attribute."""
|
|
||||||
if self.on_update:
|
|
||||||
return
|
|
||||||
|
|
||||||
if not hasattr(self._entity, self._attribute):
|
|
||||||
raise AttributeError(f"Attribute '{self._attribute}' does not exist.")
|
|
||||||
|
|
||||||
self.on_update = self._default_update
|
|
||||||
|
|
||||||
@callback
|
|
||||||
def _default_update(self, result: str | TemplateError) -> None:
|
|
||||||
attr_result = None if isinstance(result, TemplateError) else result
|
|
||||||
setattr(self._entity, self._attribute, attr_result)
|
|
||||||
|
|
||||||
@callback
|
|
||||||
def handle_result(
|
|
||||||
self,
|
|
||||||
event: EventType[EventStateChangedData] | None,
|
|
||||||
template: Template,
|
|
||||||
last_result: str | None | TemplateError,
|
|
||||||
result: str | TemplateError,
|
|
||||||
) -> None:
|
|
||||||
"""Handle a template result event callback."""
|
|
||||||
if isinstance(result, TemplateError):
|
|
||||||
_LOGGER.error(
|
|
||||||
(
|
|
||||||
"TemplateError('%s') "
|
|
||||||
"while processing template '%s' "
|
|
||||||
"for attribute '%s' in entity '%s'"
|
|
||||||
),
|
|
||||||
result,
|
|
||||||
self.template,
|
|
||||||
self._attribute,
|
|
||||||
self._entity.entity_id,
|
|
||||||
)
|
|
||||||
if self.none_on_template_error:
|
|
||||||
self._default_update(result)
|
|
||||||
else:
|
|
||||||
assert self.on_update
|
|
||||||
self.on_update(result)
|
|
||||||
return
|
|
||||||
|
|
||||||
if not self.validator:
|
|
||||||
assert self.on_update
|
|
||||||
self.on_update(result)
|
|
||||||
return
|
|
||||||
|
|
||||||
try:
|
|
||||||
validated = self.validator(result)
|
|
||||||
except vol.Invalid as ex:
|
|
||||||
_LOGGER.error(
|
|
||||||
(
|
|
||||||
"Error validating template result '%s' "
|
|
||||||
"from template '%s' "
|
|
||||||
"for attribute '%s' in entity %s "
|
|
||||||
"validation message '%s'"
|
|
||||||
),
|
|
||||||
result,
|
|
||||||
self.template,
|
|
||||||
self._attribute,
|
|
||||||
self._entity.entity_id,
|
|
||||||
ex.msg,
|
|
||||||
)
|
|
||||||
assert self.on_update
|
|
||||||
self.on_update(None)
|
|
||||||
return
|
|
||||||
|
|
||||||
assert self.on_update
|
|
||||||
self.on_update(validated)
|
|
||||||
return
|
|
||||||
|
|
||||||
|
|
||||||
class TemplateEntity(Entity):
|
|
||||||
"""Entity that uses templates to calculate attributes."""
|
|
||||||
|
|
||||||
_attr_available = True
|
|
||||||
_attr_entity_picture = None
|
|
||||||
_attr_icon = None
|
|
||||||
|
|
||||||
def __init__(
|
|
||||||
self,
|
|
||||||
hass: HomeAssistant,
|
|
||||||
*,
|
|
||||||
availability_template: Template | None = None,
|
|
||||||
icon_template: Template | None = None,
|
|
||||||
entity_picture_template: Template | None = None,
|
|
||||||
attribute_templates: dict[str, Template] | None = None,
|
|
||||||
config: ConfigType | None = None,
|
|
||||||
fallback_name: str | None = None,
|
|
||||||
unique_id: str | None = None,
|
|
||||||
) -> None:
|
|
||||||
"""Template Entity."""
|
|
||||||
self._template_attrs: dict[Template, list[_TemplateAttribute]] = {}
|
|
||||||
self._async_update: Callable[[], None] | None = None
|
|
||||||
self._attr_extra_state_attributes = {}
|
|
||||||
self._self_ref_update_count = 0
|
|
||||||
self._attr_unique_id = unique_id
|
|
||||||
if config is None:
|
|
||||||
self._attribute_templates = attribute_templates
|
|
||||||
self._availability_template = availability_template
|
|
||||||
self._icon_template = icon_template
|
|
||||||
self._entity_picture_template = entity_picture_template
|
|
||||||
self._friendly_name_template = None
|
|
||||||
else:
|
|
||||||
self._attribute_templates = config.get(CONF_ATTRIBUTES)
|
|
||||||
self._availability_template = config.get(CONF_AVAILABILITY)
|
|
||||||
self._icon_template = config.get(CONF_ICON)
|
|
||||||
self._entity_picture_template = config.get(CONF_PICTURE)
|
|
||||||
self._friendly_name_template = config.get(CONF_NAME)
|
|
||||||
|
|
||||||
class DummyState(State):
|
|
||||||
"""None-state for template entities not yet added to the state machine."""
|
|
||||||
|
|
||||||
def __init__(self) -> None:
|
|
||||||
"""Initialize a new state."""
|
|
||||||
super().__init__("unknown.unknown", STATE_UNKNOWN)
|
|
||||||
self.entity_id = None # type: ignore[assignment]
|
|
||||||
|
|
||||||
@property
|
|
||||||
def name(self) -> str:
|
|
||||||
"""Name of this state."""
|
|
||||||
return "<None>"
|
|
||||||
|
|
||||||
variables = {"this": DummyState()}
|
|
||||||
|
|
||||||
# Try to render the name as it can influence the entity ID
|
|
||||||
self._attr_name = fallback_name
|
|
||||||
if self._friendly_name_template:
|
|
||||||
self._friendly_name_template.hass = hass
|
|
||||||
with contextlib.suppress(TemplateError):
|
|
||||||
self._attr_name = self._friendly_name_template.async_render(
|
|
||||||
variables=variables, parse_result=False
|
|
||||||
)
|
|
||||||
|
|
||||||
# Templates will not render while the entity is unavailable, try to render the
|
|
||||||
# icon and picture templates.
|
|
||||||
if self._entity_picture_template:
|
|
||||||
self._entity_picture_template.hass = hass
|
|
||||||
with contextlib.suppress(TemplateError):
|
|
||||||
self._attr_entity_picture = self._entity_picture_template.async_render(
|
|
||||||
variables=variables, parse_result=False
|
|
||||||
)
|
|
||||||
|
|
||||||
if self._icon_template:
|
|
||||||
self._icon_template.hass = hass
|
|
||||||
with contextlib.suppress(TemplateError):
|
|
||||||
self._attr_icon = self._icon_template.async_render(
|
|
||||||
variables=variables, parse_result=False
|
|
||||||
)
|
|
||||||
|
|
||||||
@callback
|
|
||||||
def _update_available(self, result: str | TemplateError) -> None:
|
|
||||||
if isinstance(result, TemplateError):
|
|
||||||
self._attr_available = True
|
|
||||||
return
|
|
||||||
|
|
||||||
self._attr_available = result_as_boolean(result)
|
|
||||||
|
|
||||||
@callback
|
|
||||||
def _update_state(self, result: str | TemplateError) -> None:
|
|
||||||
if self._availability_template:
|
|
||||||
return
|
|
||||||
|
|
||||||
self._attr_available = not isinstance(result, TemplateError)
|
|
||||||
|
|
||||||
@callback
|
|
||||||
def _add_attribute_template(
|
|
||||||
self, attribute_key: str, attribute_template: Template
|
|
||||||
) -> None:
|
|
||||||
"""Create a template tracker for the attribute."""
|
|
||||||
|
|
||||||
def _update_attribute(result: str | TemplateError) -> None:
|
|
||||||
attr_result = None if isinstance(result, TemplateError) else result
|
|
||||||
self._attr_extra_state_attributes[attribute_key] = attr_result
|
|
||||||
|
|
||||||
self.add_template_attribute(
|
|
||||||
attribute_key, attribute_template, None, _update_attribute
|
|
||||||
)
|
|
||||||
|
|
||||||
def add_template_attribute(
|
|
||||||
self,
|
|
||||||
attribute: str,
|
|
||||||
template: Template,
|
|
||||||
validator: Callable[[Any], Any] | None = None,
|
|
||||||
on_update: Callable[[Any], None] | None = None,
|
|
||||||
none_on_template_error: bool = False,
|
|
||||||
) -> None:
|
|
||||||
"""Call in the constructor to add a template linked to a attribute.
|
|
||||||
|
|
||||||
Parameters
|
|
||||||
----------
|
|
||||||
attribute
|
|
||||||
The name of the attribute to link to. This attribute must exist
|
|
||||||
unless a custom on_update method is supplied.
|
|
||||||
template
|
|
||||||
The template to calculate.
|
|
||||||
validator
|
|
||||||
Validator function to parse the result and ensure it's valid.
|
|
||||||
on_update
|
|
||||||
Called to store the template result rather than storing it
|
|
||||||
the supplied attribute. Passed the result of the validator, or None
|
|
||||||
if the template or validator resulted in an error.
|
|
||||||
none_on_template_error
|
|
||||||
If True, the attribute will be set to None if the template errors.
|
|
||||||
|
|
||||||
"""
|
|
||||||
assert self.hass is not None, "hass cannot be None"
|
|
||||||
template.hass = self.hass
|
|
||||||
template_attribute = _TemplateAttribute(
|
|
||||||
self, attribute, template, validator, on_update, none_on_template_error
|
|
||||||
)
|
|
||||||
self._template_attrs.setdefault(template, [])
|
|
||||||
self._template_attrs[template].append(template_attribute)
|
|
||||||
|
|
||||||
@callback
|
|
||||||
def _handle_results(
|
|
||||||
self,
|
|
||||||
event: EventType[EventStateChangedData] | None,
|
|
||||||
updates: list[TrackTemplateResult],
|
|
||||||
) -> None:
|
|
||||||
"""Call back the results to the attributes."""
|
|
||||||
if event:
|
|
||||||
self.async_set_context(event.context)
|
|
||||||
|
|
||||||
entity_id = event and event.data["entity_id"]
|
|
||||||
|
|
||||||
if entity_id and entity_id == self.entity_id:
|
|
||||||
self._self_ref_update_count += 1
|
|
||||||
else:
|
|
||||||
self._self_ref_update_count = 0
|
|
||||||
|
|
||||||
if self._self_ref_update_count > len(self._template_attrs):
|
|
||||||
for update in updates:
|
|
||||||
_LOGGER.warning(
|
|
||||||
(
|
|
||||||
"Template loop detected while processing event: %s, skipping"
|
|
||||||
" template render for Template[%s]"
|
|
||||||
),
|
|
||||||
event,
|
|
||||||
update.template.template,
|
|
||||||
)
|
|
||||||
return
|
|
||||||
|
|
||||||
for update in updates:
|
|
||||||
for attr in self._template_attrs[update.template]:
|
|
||||||
attr.handle_result(
|
|
||||||
event, update.template, update.last_result, update.result
|
|
||||||
)
|
|
||||||
|
|
||||||
self.async_write_ha_state()
|
|
||||||
|
|
||||||
async def _async_template_startup(self, *_: Any) -> None:
|
|
||||||
template_var_tups: list[TrackTemplate] = []
|
|
||||||
has_availability_template = False
|
|
||||||
|
|
||||||
variables = {"this": TemplateStateFromEntityId(self.hass, self.entity_id)}
|
|
||||||
|
|
||||||
for template, attributes in self._template_attrs.items():
|
|
||||||
template_var_tup = TrackTemplate(template, variables)
|
|
||||||
is_availability_template = False
|
|
||||||
for attribute in attributes:
|
|
||||||
# pylint: disable-next=protected-access
|
|
||||||
if attribute._attribute == "_attr_available":
|
|
||||||
has_availability_template = True
|
|
||||||
is_availability_template = True
|
|
||||||
attribute.async_setup()
|
|
||||||
# Insert the availability template first in the list
|
|
||||||
if is_availability_template:
|
|
||||||
template_var_tups.insert(0, template_var_tup)
|
|
||||||
else:
|
|
||||||
template_var_tups.append(template_var_tup)
|
|
||||||
|
|
||||||
result_info = async_track_template_result(
|
|
||||||
self.hass,
|
|
||||||
template_var_tups,
|
|
||||||
self._handle_results,
|
|
||||||
has_super_template=has_availability_template,
|
|
||||||
)
|
|
||||||
self.async_on_remove(result_info.async_remove)
|
|
||||||
self._async_update = result_info.async_refresh
|
|
||||||
result_info.async_refresh()
|
|
||||||
|
|
||||||
async def async_added_to_hass(self) -> None:
|
|
||||||
"""Run when entity about to be added to hass."""
|
|
||||||
if self._availability_template is not None:
|
|
||||||
self.add_template_attribute(
|
|
||||||
"_attr_available",
|
|
||||||
self._availability_template,
|
|
||||||
None,
|
|
||||||
self._update_available,
|
|
||||||
)
|
|
||||||
if self._attribute_templates is not None:
|
|
||||||
for key, value in self._attribute_templates.items():
|
|
||||||
self._add_attribute_template(key, value)
|
|
||||||
if self._icon_template is not None:
|
|
||||||
self.add_template_attribute(
|
|
||||||
"_attr_icon", self._icon_template, vol.Or(cv.whitespace, cv.icon)
|
|
||||||
)
|
|
||||||
if self._entity_picture_template is not None:
|
|
||||||
self.add_template_attribute(
|
|
||||||
"_attr_entity_picture", self._entity_picture_template
|
|
||||||
)
|
|
||||||
if (
|
|
||||||
self._friendly_name_template is not None
|
|
||||||
and not self._friendly_name_template.is_static
|
|
||||||
):
|
|
||||||
self.add_template_attribute("_attr_name", self._friendly_name_template)
|
|
||||||
|
|
||||||
if self.hass.state == CoreState.running:
|
|
||||||
await self._async_template_startup()
|
|
||||||
return
|
|
||||||
|
|
||||||
self.hass.bus.async_listen_once(
|
|
||||||
EVENT_HOMEASSISTANT_START, self._async_template_startup
|
|
||||||
)
|
|
||||||
|
|
||||||
async def async_update(self) -> None:
|
|
||||||
"""Call for forced update."""
|
|
||||||
assert self._async_update
|
|
||||||
self._async_update()
|
|
||||||
|
|
||||||
async def async_run_script(
|
|
||||||
self,
|
|
||||||
script: Script,
|
|
||||||
*,
|
|
||||||
run_variables: _VarsType | None = None,
|
|
||||||
context: Context | None = None,
|
|
||||||
) -> None:
|
|
||||||
"""Run an action script."""
|
|
||||||
if run_variables is None:
|
|
||||||
run_variables = {}
|
|
||||||
await script.async_run(
|
|
||||||
run_variables={
|
|
||||||
"this": TemplateStateFromEntityId(self.hass, self.entity_id),
|
|
||||||
**run_variables,
|
|
||||||
},
|
|
||||||
context=context,
|
|
||||||
)
|
|
||||||
|
|
||||||
|
|
||||||
class TriggerBaseEntity(Entity):
|
|
||||||
"""Template Base entity based on trigger data."""
|
|
||||||
|
|
||||||
domain: str
|
|
||||||
extra_template_keys: tuple | None = None
|
|
||||||
extra_template_keys_complex: tuple | None = None
|
|
||||||
_unique_id: str | None
|
|
||||||
|
|
||||||
def __init__(
|
|
||||||
self,
|
|
||||||
hass: HomeAssistant,
|
|
||||||
config: ConfigType,
|
|
||||||
) -> None:
|
|
||||||
"""Initialize the entity."""
|
|
||||||
self.hass = hass
|
|
||||||
|
|
||||||
self._set_unique_id(config.get(CONF_UNIQUE_ID))
|
|
||||||
|
|
||||||
self._config = config
|
|
||||||
|
|
||||||
self._static_rendered = {}
|
|
||||||
self._to_render_simple = []
|
|
||||||
self._to_render_complex: list[str] = []
|
|
||||||
|
|
||||||
for itm in (
|
|
||||||
CONF_AVAILABILITY,
|
|
||||||
CONF_ICON,
|
|
||||||
CONF_NAME,
|
|
||||||
CONF_PICTURE,
|
|
||||||
):
|
|
||||||
if itm not in config or config[itm] is None:
|
|
||||||
continue
|
|
||||||
if config[itm].is_static:
|
|
||||||
self._static_rendered[itm] = config[itm].template
|
|
||||||
else:
|
|
||||||
self._to_render_simple.append(itm)
|
|
||||||
|
|
||||||
if self.extra_template_keys is not None:
|
|
||||||
self._to_render_simple.extend(self.extra_template_keys)
|
|
||||||
|
|
||||||
if self.extra_template_keys_complex is not None:
|
|
||||||
self._to_render_complex.extend(self.extra_template_keys_complex)
|
|
||||||
|
|
||||||
# We make a copy so our initial render is 'unknown' and not 'unavailable'
|
|
||||||
self._rendered = dict(self._static_rendered)
|
|
||||||
self._parse_result = {CONF_AVAILABILITY}
|
|
||||||
|
|
||||||
@property
|
|
||||||
def name(self) -> str | None:
|
|
||||||
"""Name of the entity."""
|
|
||||||
return self._rendered.get(CONF_NAME)
|
|
||||||
|
|
||||||
@property
|
|
||||||
def unique_id(self) -> str | None:
|
|
||||||
"""Return unique ID of the entity."""
|
|
||||||
return self._unique_id
|
|
||||||
|
|
||||||
@property
|
|
||||||
def device_class(self): # type: ignore[no-untyped-def]
|
|
||||||
"""Return device class of the entity."""
|
|
||||||
return self._config.get(CONF_DEVICE_CLASS)
|
|
||||||
|
|
||||||
@property
|
|
||||||
def icon(self) -> str | None:
|
|
||||||
"""Return icon."""
|
|
||||||
return self._rendered.get(CONF_ICON)
|
|
||||||
|
|
||||||
@property
|
|
||||||
def entity_picture(self) -> str | None:
|
|
||||||
"""Return entity picture."""
|
|
||||||
return self._rendered.get(CONF_PICTURE)
|
|
||||||
|
|
||||||
@property
|
|
||||||
def available(self) -> bool:
|
|
||||||
"""Return availability of the entity."""
|
|
||||||
return (
|
|
||||||
self._rendered is not self._static_rendered
|
|
||||||
and
|
|
||||||
# Check against False so `None` is ok
|
|
||||||
self._rendered.get(CONF_AVAILABILITY) is not False
|
|
||||||
)
|
|
||||||
|
|
||||||
@property
|
|
||||||
def extra_state_attributes(self) -> dict[str, Any] | None:
|
|
||||||
"""Return extra attributes."""
|
|
||||||
return self._rendered.get(CONF_ATTRIBUTES)
|
|
||||||
|
|
||||||
async def async_added_to_hass(self) -> None:
|
|
||||||
"""Handle being added to Home Assistant."""
|
|
||||||
await super().async_added_to_hass()
|
|
||||||
template_attach(self.hass, self._config)
|
|
||||||
|
|
||||||
def _set_unique_id(self, unique_id: str | None) -> None:
|
|
||||||
"""Set unique id."""
|
|
||||||
self._unique_id = unique_id
|
|
||||||
|
|
||||||
def restore_attributes(self, last_state: State) -> None:
|
|
||||||
"""Restore attributes."""
|
|
||||||
for conf_key, attr in CONF_TO_ATTRIBUTE.items():
|
|
||||||
if conf_key not in self._config or attr not in last_state.attributes:
|
|
||||||
continue
|
|
||||||
self._rendered[conf_key] = last_state.attributes[attr]
|
|
||||||
|
|
||||||
if CONF_ATTRIBUTES in self._config:
|
|
||||||
extra_state_attributes = {}
|
|
||||||
for attr in self._config[CONF_ATTRIBUTES]:
|
|
||||||
if attr not in last_state.attributes:
|
|
||||||
continue
|
|
||||||
extra_state_attributes[attr] = last_state.attributes[attr]
|
|
||||||
self._rendered[CONF_ATTRIBUTES] = extra_state_attributes
|
|
||||||
|
|
||||||
def _render_templates(self, variables: dict[str, Any]) -> None:
|
|
||||||
"""Render templates."""
|
|
||||||
try:
|
|
||||||
rendered = dict(self._static_rendered)
|
|
||||||
|
|
||||||
for key in self._to_render_simple:
|
|
||||||
rendered[key] = self._config[key].async_render(
|
|
||||||
variables,
|
|
||||||
parse_result=key in self._parse_result,
|
|
||||||
)
|
|
||||||
|
|
||||||
for key in self._to_render_complex:
|
|
||||||
rendered[key] = render_complex(
|
|
||||||
self._config[key],
|
|
||||||
variables,
|
|
||||||
)
|
|
||||||
|
|
||||||
if CONF_ATTRIBUTES in self._config:
|
|
||||||
rendered[CONF_ATTRIBUTES] = render_complex(
|
|
||||||
self._config[CONF_ATTRIBUTES],
|
|
||||||
variables,
|
|
||||||
)
|
|
||||||
|
|
||||||
self._rendered = rendered
|
|
||||||
except TemplateError as err:
|
|
||||||
logging.getLogger(f"{__package__}.{self.entity_id.split('.')[0]}").error(
|
|
||||||
"Error rendering %s template for %s: %s", key, self.entity_id, err
|
|
||||||
)
|
|
||||||
self._rendered = self._static_rendered
|
|
||||||
|
|
||||||
|
|
||||||
class ManualTriggerEntity(TriggerBaseEntity):
|
|
||||||
"""Template entity based on manual trigger data."""
|
|
||||||
|
|
||||||
def __init__(
|
|
||||||
self,
|
|
||||||
hass: HomeAssistant,
|
|
||||||
config: ConfigType,
|
|
||||||
) -> None:
|
|
||||||
"""Initialize the entity."""
|
|
||||||
TriggerBaseEntity.__init__(self, hass, config)
|
|
||||||
# Need initial rendering on `name` as it influence the `entity_id`
|
|
||||||
self._rendered[CONF_NAME] = config[CONF_NAME].async_render(
|
|
||||||
{},
|
|
||||||
parse_result=CONF_NAME in self._parse_result,
|
|
||||||
)
|
|
||||||
|
|
||||||
@callback
|
|
||||||
def _process_manual_data(self, value: Any | None = None) -> None:
|
|
||||||
"""Process new data manually.
|
|
||||||
|
|
||||||
Implementing class should call this last in update method to render templates.
|
|
||||||
Ex: self._process_manual_data(payload)
|
|
||||||
"""
|
|
||||||
|
|
||||||
self.async_write_ha_state()
|
|
||||||
this = None
|
|
||||||
if state := self.hass.states.get(self.entity_id):
|
|
||||||
this = state.as_dict()
|
|
||||||
|
|
||||||
run_variables: dict[str, Any] = {"value": value}
|
|
||||||
# Silently try if variable is a json and store result in `value_json` if it is.
|
|
||||||
with contextlib.suppress(*JSON_DECODE_EXCEPTIONS):
|
|
||||||
run_variables["value_json"] = json_loads(run_variables["value"])
|
|
||||||
variables = {"this": this, **(run_variables or {})}
|
|
||||||
|
|
||||||
self._render_templates(variables)
|
|
||||||
|
|
||||||
|
|
||||||
class ManualTriggerSensorEntity(ManualTriggerEntity, SensorEntity):
|
|
||||||
"""Template entity based on manual trigger data for sensor."""
|
|
||||||
|
|
||||||
def __init__(
|
|
||||||
self,
|
|
||||||
hass: HomeAssistant,
|
|
||||||
config: ConfigType,
|
|
||||||
) -> None:
|
|
||||||
"""Initialize the sensor entity."""
|
|
||||||
ManualTriggerEntity.__init__(self, hass, config)
|
|
||||||
self._attr_native_unit_of_measurement = config.get(CONF_UNIT_OF_MEASUREMENT)
|
|
||||||
self._attr_state_class = config.get(CONF_STATE_CLASS)
|
|
267
homeassistant/helpers/trigger_template_entity.py
Normal file
267
homeassistant/helpers/trigger_template_entity.py
Normal file
@ -0,0 +1,267 @@
|
|||||||
|
"""TemplateEntity utility class."""
|
||||||
|
from __future__ import annotations
|
||||||
|
|
||||||
|
import contextlib
|
||||||
|
import logging
|
||||||
|
from typing import Any
|
||||||
|
|
||||||
|
import voluptuous as vol
|
||||||
|
|
||||||
|
from homeassistant.components.sensor import (
|
||||||
|
CONF_STATE_CLASS,
|
||||||
|
DEVICE_CLASSES_SCHEMA,
|
||||||
|
STATE_CLASSES_SCHEMA,
|
||||||
|
SensorEntity,
|
||||||
|
)
|
||||||
|
from homeassistant.const import (
|
||||||
|
ATTR_ENTITY_PICTURE,
|
||||||
|
ATTR_FRIENDLY_NAME,
|
||||||
|
ATTR_ICON,
|
||||||
|
CONF_DEVICE_CLASS,
|
||||||
|
CONF_ICON,
|
||||||
|
CONF_NAME,
|
||||||
|
CONF_UNIQUE_ID,
|
||||||
|
CONF_UNIT_OF_MEASUREMENT,
|
||||||
|
)
|
||||||
|
from homeassistant.core import HomeAssistant, State, callback
|
||||||
|
from homeassistant.exceptions import TemplateError
|
||||||
|
from homeassistant.util.json import JSON_DECODE_EXCEPTIONS, json_loads
|
||||||
|
|
||||||
|
from . import config_validation as cv
|
||||||
|
from .entity import Entity
|
||||||
|
from .template import attach as template_attach, render_complex
|
||||||
|
from .typing import ConfigType
|
||||||
|
|
||||||
|
CONF_AVAILABILITY = "availability"
|
||||||
|
CONF_ATTRIBUTES = "attributes"
|
||||||
|
CONF_PICTURE = "picture"
|
||||||
|
|
||||||
|
CONF_TO_ATTRIBUTE = {
|
||||||
|
CONF_ICON: ATTR_ICON,
|
||||||
|
CONF_NAME: ATTR_FRIENDLY_NAME,
|
||||||
|
CONF_PICTURE: ATTR_ENTITY_PICTURE,
|
||||||
|
}
|
||||||
|
|
||||||
|
TEMPLATE_ENTITY_BASE_SCHEMA = vol.Schema(
|
||||||
|
{
|
||||||
|
vol.Optional(CONF_ICON): cv.template,
|
||||||
|
vol.Optional(CONF_NAME): cv.template,
|
||||||
|
vol.Optional(CONF_PICTURE): cv.template,
|
||||||
|
vol.Optional(CONF_UNIQUE_ID): cv.string,
|
||||||
|
}
|
||||||
|
)
|
||||||
|
|
||||||
|
|
||||||
|
def make_template_entity_base_schema(default_name: str) -> vol.Schema:
|
||||||
|
"""Return a schema with default name."""
|
||||||
|
return vol.Schema(
|
||||||
|
{
|
||||||
|
vol.Optional(CONF_ICON): cv.template,
|
||||||
|
vol.Optional(CONF_NAME, default=default_name): cv.template,
|
||||||
|
vol.Optional(CONF_PICTURE): cv.template,
|
||||||
|
vol.Optional(CONF_UNIQUE_ID): cv.string,
|
||||||
|
}
|
||||||
|
)
|
||||||
|
|
||||||
|
|
||||||
|
TEMPLATE_SENSOR_BASE_SCHEMA = vol.Schema(
|
||||||
|
{
|
||||||
|
vol.Optional(CONF_DEVICE_CLASS): DEVICE_CLASSES_SCHEMA,
|
||||||
|
vol.Optional(CONF_STATE_CLASS): STATE_CLASSES_SCHEMA,
|
||||||
|
vol.Optional(CONF_UNIT_OF_MEASUREMENT): cv.string,
|
||||||
|
}
|
||||||
|
).extend(TEMPLATE_ENTITY_BASE_SCHEMA.schema)
|
||||||
|
|
||||||
|
|
||||||
|
class TriggerBaseEntity(Entity):
|
||||||
|
"""Template Base entity based on trigger data."""
|
||||||
|
|
||||||
|
domain: str
|
||||||
|
extra_template_keys: tuple | None = None
|
||||||
|
extra_template_keys_complex: tuple | None = None
|
||||||
|
_unique_id: str | None
|
||||||
|
|
||||||
|
def __init__(
|
||||||
|
self,
|
||||||
|
hass: HomeAssistant,
|
||||||
|
config: ConfigType,
|
||||||
|
) -> None:
|
||||||
|
"""Initialize the entity."""
|
||||||
|
self.hass = hass
|
||||||
|
|
||||||
|
self._set_unique_id(config.get(CONF_UNIQUE_ID))
|
||||||
|
|
||||||
|
self._config = config
|
||||||
|
|
||||||
|
self._static_rendered = {}
|
||||||
|
self._to_render_simple = []
|
||||||
|
self._to_render_complex: list[str] = []
|
||||||
|
|
||||||
|
for itm in (
|
||||||
|
CONF_AVAILABILITY,
|
||||||
|
CONF_ICON,
|
||||||
|
CONF_NAME,
|
||||||
|
CONF_PICTURE,
|
||||||
|
):
|
||||||
|
if itm not in config or config[itm] is None:
|
||||||
|
continue
|
||||||
|
if config[itm].is_static:
|
||||||
|
self._static_rendered[itm] = config[itm].template
|
||||||
|
else:
|
||||||
|
self._to_render_simple.append(itm)
|
||||||
|
|
||||||
|
if self.extra_template_keys is not None:
|
||||||
|
self._to_render_simple.extend(self.extra_template_keys)
|
||||||
|
|
||||||
|
if self.extra_template_keys_complex is not None:
|
||||||
|
self._to_render_complex.extend(self.extra_template_keys_complex)
|
||||||
|
|
||||||
|
# We make a copy so our initial render is 'unknown' and not 'unavailable'
|
||||||
|
self._rendered = dict(self._static_rendered)
|
||||||
|
self._parse_result = {CONF_AVAILABILITY}
|
||||||
|
|
||||||
|
@property
|
||||||
|
def name(self) -> str | None:
|
||||||
|
"""Name of the entity."""
|
||||||
|
return self._rendered.get(CONF_NAME)
|
||||||
|
|
||||||
|
@property
|
||||||
|
def unique_id(self) -> str | None:
|
||||||
|
"""Return unique ID of the entity."""
|
||||||
|
return self._unique_id
|
||||||
|
|
||||||
|
@property
|
||||||
|
def device_class(self): # type: ignore[no-untyped-def]
|
||||||
|
"""Return device class of the entity."""
|
||||||
|
return self._config.get(CONF_DEVICE_CLASS)
|
||||||
|
|
||||||
|
@property
|
||||||
|
def icon(self) -> str | None:
|
||||||
|
"""Return icon."""
|
||||||
|
return self._rendered.get(CONF_ICON)
|
||||||
|
|
||||||
|
@property
|
||||||
|
def entity_picture(self) -> str | None:
|
||||||
|
"""Return entity picture."""
|
||||||
|
return self._rendered.get(CONF_PICTURE)
|
||||||
|
|
||||||
|
@property
|
||||||
|
def available(self) -> bool:
|
||||||
|
"""Return availability of the entity."""
|
||||||
|
return (
|
||||||
|
self._rendered is not self._static_rendered
|
||||||
|
and
|
||||||
|
# Check against False so `None` is ok
|
||||||
|
self._rendered.get(CONF_AVAILABILITY) is not False
|
||||||
|
)
|
||||||
|
|
||||||
|
@property
|
||||||
|
def extra_state_attributes(self) -> dict[str, Any] | None:
|
||||||
|
"""Return extra attributes."""
|
||||||
|
return self._rendered.get(CONF_ATTRIBUTES)
|
||||||
|
|
||||||
|
async def async_added_to_hass(self) -> None:
|
||||||
|
"""Handle being added to Home Assistant."""
|
||||||
|
await super().async_added_to_hass()
|
||||||
|
template_attach(self.hass, self._config)
|
||||||
|
|
||||||
|
def _set_unique_id(self, unique_id: str | None) -> None:
|
||||||
|
"""Set unique id."""
|
||||||
|
self._unique_id = unique_id
|
||||||
|
|
||||||
|
def restore_attributes(self, last_state: State) -> None:
|
||||||
|
"""Restore attributes."""
|
||||||
|
for conf_key, attr in CONF_TO_ATTRIBUTE.items():
|
||||||
|
if conf_key not in self._config or attr not in last_state.attributes:
|
||||||
|
continue
|
||||||
|
self._rendered[conf_key] = last_state.attributes[attr]
|
||||||
|
|
||||||
|
if CONF_ATTRIBUTES in self._config:
|
||||||
|
extra_state_attributes = {}
|
||||||
|
for attr in self._config[CONF_ATTRIBUTES]:
|
||||||
|
if attr not in last_state.attributes:
|
||||||
|
continue
|
||||||
|
extra_state_attributes[attr] = last_state.attributes[attr]
|
||||||
|
self._rendered[CONF_ATTRIBUTES] = extra_state_attributes
|
||||||
|
|
||||||
|
def _render_templates(self, variables: dict[str, Any]) -> None:
|
||||||
|
"""Render templates."""
|
||||||
|
try:
|
||||||
|
rendered = dict(self._static_rendered)
|
||||||
|
|
||||||
|
for key in self._to_render_simple:
|
||||||
|
rendered[key] = self._config[key].async_render(
|
||||||
|
variables,
|
||||||
|
parse_result=key in self._parse_result,
|
||||||
|
)
|
||||||
|
|
||||||
|
for key in self._to_render_complex:
|
||||||
|
rendered[key] = render_complex(
|
||||||
|
self._config[key],
|
||||||
|
variables,
|
||||||
|
)
|
||||||
|
|
||||||
|
if CONF_ATTRIBUTES in self._config:
|
||||||
|
rendered[CONF_ATTRIBUTES] = render_complex(
|
||||||
|
self._config[CONF_ATTRIBUTES],
|
||||||
|
variables,
|
||||||
|
)
|
||||||
|
|
||||||
|
self._rendered = rendered
|
||||||
|
except TemplateError as err:
|
||||||
|
logging.getLogger(f"{__package__}.{self.entity_id.split('.')[0]}").error(
|
||||||
|
"Error rendering %s template for %s: %s", key, self.entity_id, err
|
||||||
|
)
|
||||||
|
self._rendered = self._static_rendered
|
||||||
|
|
||||||
|
|
||||||
|
class ManualTriggerEntity(TriggerBaseEntity):
|
||||||
|
"""Template entity based on manual trigger data."""
|
||||||
|
|
||||||
|
def __init__(
|
||||||
|
self,
|
||||||
|
hass: HomeAssistant,
|
||||||
|
config: ConfigType,
|
||||||
|
) -> None:
|
||||||
|
"""Initialize the entity."""
|
||||||
|
TriggerBaseEntity.__init__(self, hass, config)
|
||||||
|
# Need initial rendering on `name` as it influence the `entity_id`
|
||||||
|
self._rendered[CONF_NAME] = config[CONF_NAME].async_render(
|
||||||
|
{},
|
||||||
|
parse_result=CONF_NAME in self._parse_result,
|
||||||
|
)
|
||||||
|
|
||||||
|
@callback
|
||||||
|
def _process_manual_data(self, value: Any | None = None) -> None:
|
||||||
|
"""Process new data manually.
|
||||||
|
|
||||||
|
Implementing class should call this last in update method to render templates.
|
||||||
|
Ex: self._process_manual_data(payload)
|
||||||
|
"""
|
||||||
|
|
||||||
|
self.async_write_ha_state()
|
||||||
|
this = None
|
||||||
|
if state := self.hass.states.get(self.entity_id):
|
||||||
|
this = state.as_dict()
|
||||||
|
|
||||||
|
run_variables: dict[str, Any] = {"value": value}
|
||||||
|
# Silently try if variable is a json and store result in `value_json` if it is.
|
||||||
|
with contextlib.suppress(*JSON_DECODE_EXCEPTIONS):
|
||||||
|
run_variables["value_json"] = json_loads(run_variables["value"])
|
||||||
|
variables = {"this": this, **(run_variables or {})}
|
||||||
|
|
||||||
|
self._render_templates(variables)
|
||||||
|
|
||||||
|
|
||||||
|
class ManualTriggerSensorEntity(ManualTriggerEntity, SensorEntity):
|
||||||
|
"""Template entity based on manual trigger data for sensor."""
|
||||||
|
|
||||||
|
def __init__(
|
||||||
|
self,
|
||||||
|
hass: HomeAssistant,
|
||||||
|
config: ConfigType,
|
||||||
|
) -> None:
|
||||||
|
"""Initialize the sensor entity."""
|
||||||
|
ManualTriggerEntity.__init__(self, hass, config)
|
||||||
|
self._attr_native_unit_of_measurement = config.get(CONF_UNIT_OF_MEASUREMENT)
|
||||||
|
self._attr_state_class = config.get(CONF_STATE_CLASS)
|
@ -41,7 +41,7 @@ from homeassistant.const import (
|
|||||||
)
|
)
|
||||||
from homeassistant.core import HomeAssistant
|
from homeassistant.core import HomeAssistant
|
||||||
from homeassistant.helpers import entity_registry as er
|
from homeassistant.helpers import entity_registry as er
|
||||||
from homeassistant.helpers.template_entity import CONF_PICTURE
|
from homeassistant.helpers.trigger_template_entity import CONF_PICTURE
|
||||||
from homeassistant.setup import async_setup_component
|
from homeassistant.setup import async_setup_component
|
||||||
from homeassistant.util.dt import utcnow
|
from homeassistant.util.dt import utcnow
|
||||||
|
|
||||||
|
@ -28,7 +28,10 @@ from homeassistant.const import (
|
|||||||
)
|
)
|
||||||
from homeassistant.core import HomeAssistant
|
from homeassistant.core import HomeAssistant
|
||||||
from homeassistant.helpers import entity_registry as er
|
from homeassistant.helpers import entity_registry as er
|
||||||
from homeassistant.helpers.template_entity import CONF_AVAILABILITY, CONF_PICTURE
|
from homeassistant.helpers.trigger_template_entity import (
|
||||||
|
CONF_AVAILABILITY,
|
||||||
|
CONF_PICTURE,
|
||||||
|
)
|
||||||
from homeassistant.setup import async_setup_component
|
from homeassistant.setup import async_setup_component
|
||||||
from homeassistant.util import dt as dt_util
|
from homeassistant.util import dt as dt_util
|
||||||
|
|
||||||
|
@ -20,7 +20,10 @@ from homeassistant.const import (
|
|||||||
CONF_VALUE_TEMPLATE,
|
CONF_VALUE_TEMPLATE,
|
||||||
)
|
)
|
||||||
from homeassistant.core import HomeAssistant
|
from homeassistant.core import HomeAssistant
|
||||||
from homeassistant.helpers.template_entity import CONF_AVAILABILITY, CONF_PICTURE
|
from homeassistant.helpers.trigger_template_entity import (
|
||||||
|
CONF_AVAILABILITY,
|
||||||
|
CONF_PICTURE,
|
||||||
|
)
|
||||||
|
|
||||||
from tests.common import MockConfigEntry
|
from tests.common import MockConfigEntry
|
||||||
|
|
||||||
|
@ -2,7 +2,7 @@
|
|||||||
|
|
||||||
from homeassistant.core import HomeAssistant
|
from homeassistant.core import HomeAssistant
|
||||||
from homeassistant.helpers import template
|
from homeassistant.helpers import template
|
||||||
from homeassistant.helpers.template_entity import ManualTriggerEntity
|
from homeassistant.helpers.trigger_template_entity import ManualTriggerEntity
|
||||||
|
|
||||||
|
|
||||||
async def test_template_entity_requires_hass_set(hass: HomeAssistant) -> None:
|
async def test_template_entity_requires_hass_set(hass: HomeAssistant) -> None:
|
||||||
|
Loading…
x
Reference in New Issue
Block a user