Add recorder platform to input_number (#70226)

This commit is contained in:
Franck Nijhof 2022-04-18 17:21:53 +02:00 committed by GitHub
parent 5d62f405f1
commit ec92c295d4
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
3 changed files with 88 additions and 0 deletions

View file

@ -19,6 +19,9 @@ from homeassistant.core import HomeAssistant, ServiceCall, callback
from homeassistant.helpers import collection
import homeassistant.helpers.config_validation as cv
from homeassistant.helpers.entity_component import EntityComponent
from homeassistant.helpers.integration_platform import (
async_process_integration_platform_for_component,
)
from homeassistant.helpers.restore_state import RestoreEntity
import homeassistant.helpers.service
from homeassistant.helpers.storage import Store
@ -115,6 +118,11 @@ STORAGE_VERSION = 1
async def async_setup(hass: HomeAssistant, config: ConfigType) -> bool:
"""Set up an input slider."""
component = EntityComponent(_LOGGER, DOMAIN, hass)
# Process integration platforms right away since
# we will create entities before firing EVENT_COMPONENT_LOADED
await async_process_integration_platform_for_component(hass, DOMAIN)
id_manager = collection.IDManager()
yaml_collection = collection.YamlCollection(

View file

@ -0,0 +1,19 @@
"""Integration platform for recorder."""
from __future__ import annotations
from homeassistant.const import ATTR_EDITABLE
from homeassistant.core import HomeAssistant, callback
from . import ATTR_MAX, ATTR_MIN, ATTR_MODE, ATTR_STEP
@callback
def exclude_attributes(hass: HomeAssistant) -> set[str]:
"""Exclude editable hint from being recorded in the database."""
return {
ATTR_EDITABLE,
ATTR_MAX,
ATTR_MIN,
ATTR_MODE,
ATTR_STEP,
}

View file

@ -0,0 +1,61 @@
"""The tests for recorder platform."""
from __future__ import annotations
from datetime import timedelta
from homeassistant.components.input_number import (
ATTR_MAX,
ATTR_MIN,
ATTR_MODE,
ATTR_STEP,
DOMAIN,
)
from homeassistant.components.recorder.models import StateAttributes, States
from homeassistant.components.recorder.util import session_scope
from homeassistant.const import ATTR_EDITABLE
from homeassistant.core import HomeAssistant, State
from homeassistant.setup import async_setup_component
from homeassistant.util import dt as dt_util
from tests.common import async_fire_time_changed, async_init_recorder_component
from tests.components.recorder.common import async_wait_recording_done_without_instance
async def test_exclude_attributes(
hass: HomeAssistant, enable_custom_integrations: None
):
"""Test attributes to be excluded."""
await async_init_recorder_component(hass)
assert await async_setup_component(
hass, DOMAIN, {DOMAIN: {"test": {"min": 0, "max": 100}}}
)
state = hass.states.get("input_number.test")
assert state
assert state.attributes[ATTR_EDITABLE] is False
assert state.attributes[ATTR_MIN] == 0
assert state.attributes[ATTR_MAX] == 100
assert state.attributes[ATTR_STEP] == 1
assert state.attributes[ATTR_MODE] == "slider"
await hass.async_block_till_done()
async_fire_time_changed(hass, dt_util.utcnow() + timedelta(minutes=5))
await hass.async_block_till_done()
await async_wait_recording_done_without_instance(hass)
def _fetch_states() -> list[State]:
with session_scope(hass=hass) as session:
native_states = []
for db_state, db_state_attributes in session.query(States, StateAttributes):
state = db_state.to_native()
state.attributes = db_state_attributes.to_native()
native_states.append(state)
return native_states
states: list[State] = await hass.async_add_executor_job(_fetch_states)
assert len(states) == 1
assert ATTR_EDITABLE not in states[0].attributes
assert ATTR_MIN not in states[0].attributes
assert ATTR_MAX not in states[0].attributes
assert ATTR_STEP not in states[0].attributes
assert ATTR_MODE not in states[0].attributes