mirror of
https://github.com/home-assistant/core.git
synced 2025-07-17 10:17:09 +00:00
Don't allow partial update of input_datetime settings (#78373)
This commit is contained in:
parent
e2a0dd9955
commit
33fa4ec8b2
@ -61,20 +61,13 @@ def validate_set_datetime_attrs(config):
|
|||||||
STORAGE_KEY = DOMAIN
|
STORAGE_KEY = DOMAIN
|
||||||
STORAGE_VERSION = 1
|
STORAGE_VERSION = 1
|
||||||
|
|
||||||
CREATE_FIELDS = {
|
STORAGE_FIELDS = {
|
||||||
vol.Required(CONF_NAME): vol.All(str, vol.Length(min=1)),
|
vol.Required(CONF_NAME): vol.All(str, vol.Length(min=1)),
|
||||||
vol.Optional(CONF_HAS_DATE, default=False): cv.boolean,
|
vol.Optional(CONF_HAS_DATE, default=False): cv.boolean,
|
||||||
vol.Optional(CONF_HAS_TIME, default=False): cv.boolean,
|
vol.Optional(CONF_HAS_TIME, default=False): cv.boolean,
|
||||||
vol.Optional(CONF_ICON): cv.icon,
|
vol.Optional(CONF_ICON): cv.icon,
|
||||||
vol.Optional(CONF_INITIAL): cv.string,
|
vol.Optional(CONF_INITIAL): cv.string,
|
||||||
}
|
}
|
||||||
UPDATE_FIELDS = {
|
|
||||||
vol.Optional(CONF_NAME): cv.string,
|
|
||||||
vol.Optional(CONF_HAS_DATE): cv.boolean,
|
|
||||||
vol.Optional(CONF_HAS_TIME): cv.boolean,
|
|
||||||
vol.Optional(CONF_ICON): cv.icon,
|
|
||||||
vol.Optional(CONF_INITIAL): cv.string,
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
def has_date_or_time(conf):
|
def has_date_or_time(conf):
|
||||||
@ -167,7 +160,7 @@ async def async_setup(hass: HomeAssistant, config: ConfigType) -> bool:
|
|||||||
await storage_collection.async_load()
|
await storage_collection.async_load()
|
||||||
|
|
||||||
collection.StorageCollectionWebsocket(
|
collection.StorageCollectionWebsocket(
|
||||||
storage_collection, DOMAIN, DOMAIN, CREATE_FIELDS, UPDATE_FIELDS
|
storage_collection, DOMAIN, DOMAIN, STORAGE_FIELDS, STORAGE_FIELDS
|
||||||
).async_setup(hass)
|
).async_setup(hass)
|
||||||
|
|
||||||
async def reload_service_handler(service_call: ServiceCall) -> None:
|
async def reload_service_handler(service_call: ServiceCall) -> None:
|
||||||
@ -213,12 +206,11 @@ async def async_setup(hass: HomeAssistant, config: ConfigType) -> bool:
|
|||||||
class DateTimeStorageCollection(collection.StorageCollection):
|
class DateTimeStorageCollection(collection.StorageCollection):
|
||||||
"""Input storage based collection."""
|
"""Input storage based collection."""
|
||||||
|
|
||||||
CREATE_SCHEMA = vol.Schema(vol.All(CREATE_FIELDS, has_date_or_time))
|
CREATE_UPDATE_SCHEMA = vol.Schema(vol.All(STORAGE_FIELDS, has_date_or_time))
|
||||||
UPDATE_SCHEMA = vol.Schema(UPDATE_FIELDS)
|
|
||||||
|
|
||||||
async def _process_create_data(self, data: dict) -> dict:
|
async def _process_create_data(self, data: dict) -> dict:
|
||||||
"""Validate the config is valid."""
|
"""Validate the config is valid."""
|
||||||
return self.CREATE_SCHEMA(data)
|
return self.CREATE_UPDATE_SCHEMA(data)
|
||||||
|
|
||||||
@callback
|
@callback
|
||||||
def _get_suggested_id(self, info: dict) -> str:
|
def _get_suggested_id(self, info: dict) -> str:
|
||||||
@ -227,8 +219,8 @@ class DateTimeStorageCollection(collection.StorageCollection):
|
|||||||
|
|
||||||
async def _update_data(self, data: dict, update_data: dict) -> dict:
|
async def _update_data(self, data: dict, update_data: dict) -> dict:
|
||||||
"""Return a new updated data object."""
|
"""Return a new updated data object."""
|
||||||
update_data = self.UPDATE_SCHEMA(update_data)
|
update_data = self.CREATE_UPDATE_SCHEMA(update_data)
|
||||||
return has_date_or_time({**data, **update_data})
|
return {CONF_ID: data[CONF_ID]} | update_data
|
||||||
|
|
||||||
|
|
||||||
class InputDatetime(collection.CollectionEntity, RestoreEntity):
|
class InputDatetime(collection.CollectionEntity, RestoreEntity):
|
||||||
|
@ -583,17 +583,23 @@ async def test_update(hass, hass_ws_client, storage_setup):
|
|||||||
|
|
||||||
client = await hass_ws_client(hass)
|
client = await hass_ws_client(hass)
|
||||||
|
|
||||||
|
updated_settings = {
|
||||||
|
CONF_NAME: "even newer name",
|
||||||
|
CONF_HAS_DATE: False,
|
||||||
|
CONF_HAS_TIME: True,
|
||||||
|
CONF_INITIAL: INITIAL_DATETIME,
|
||||||
|
}
|
||||||
await client.send_json(
|
await client.send_json(
|
||||||
{
|
{
|
||||||
"id": 6,
|
"id": 6,
|
||||||
"type": f"{DOMAIN}/update",
|
"type": f"{DOMAIN}/update",
|
||||||
f"{DOMAIN}_id": f"{input_id}",
|
f"{DOMAIN}_id": f"{input_id}",
|
||||||
ATTR_NAME: "even newer name",
|
**updated_settings,
|
||||||
CONF_HAS_DATE: False,
|
|
||||||
}
|
}
|
||||||
)
|
)
|
||||||
resp = await client.receive_json()
|
resp = await client.receive_json()
|
||||||
assert resp["success"]
|
assert resp["success"]
|
||||||
|
assert resp["result"] == {"id": "from_storage"} | updated_settings
|
||||||
|
|
||||||
state = hass.states.get(input_entity_id)
|
state = hass.states.get(input_entity_id)
|
||||||
assert state.state == INITIAL_TIME
|
assert state.state == INITIAL_TIME
|
||||||
|
Loading…
x
Reference in New Issue
Block a user