jeans/core
jeans/core
1
0
Fork 0
mirror of https://github.com/home-assistant/core.git synced 2025-04-29 03:37:51 +00:00
Code Issues Packages Projects Releases Wiki Activity

Save config entry after updating system options (#26077)

Browse Source
This commit is contained in:
Paulus Schoutsen 2019-08-19 16:45:17 -07:00 committed by Andrew Sayre
parent d1483b6f29
commit a1dbdbba6a
2 changed files with 16 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
homeassistant/components/config/config_entries.py
View File

@ -272,7 +272,11 @@ async def system_options_update(hass, connection, msg):
entry_id = changes.pop("entry_id") entry_id = changes.pop("entry_id")
entry = hass.config_entries.async_get_entry(entry_id) entry = hass.config_entries.async_get_entry(entry_id)
if entry and changes: if entry is None:
entry.system_options.update(**changes) connection.send_error(
msg["id"], websocket_api.const.ERR_NOT_FOUND, "Config entry not found"
)
return
connection.send_result(msg["id"], entry.system_options.as_dict()) hass.config_entries.async_update_entry(entry, system_options=changes)
connection.send_result(msg["id"], entry.system_options.as_dict())

14
homeassistant/config_entries.py
View File

@ -522,7 +522,9 @@ class ConfigEntries:
return await self.async_setup(entry_id) return await self.async_setup(entry_id)
@callback @callback
def async_update_entry(self, entry, *, data=_UNDEF, options=_UNDEF): def async_update_entry(
self, entry, *, data=_UNDEF, options=_UNDEF, system_options=_UNDEF
):
"""Update a config entry.""" """Update a config entry."""
if data is not _UNDEF: if data is not _UNDEF:
entry.data = data entry.data = data
@ -530,10 +532,12 @@ class ConfigEntries:
if options is not _UNDEF: if options is not _UNDEF:
entry.options = options entry.options = options
if data is not _UNDEF or options is not _UNDEF: if system_options is not _UNDEF:
for listener_ref in entry.update_listeners: entry.system_options.update(**system_options)
listener = listener_ref()
self.hass.async_create_task(listener(self.hass, entry)) for listener_ref in entry.update_listeners:
listener = listener_ref()
self.hass.async_create_task(listener(self.hass, entry))
self._async_schedule_save() self._async_schedule_save()