Fixed diagnostics currupting stored config_entry
This commit is contained in:
@@ -268,6 +268,12 @@ async def async_setup_entry(hass: HomeAssistant, entry: ConfigEntry):
|
|||||||
async def async_unload_entry(hass: HomeAssistant, entry: ConfigEntry):
|
async def async_unload_entry(hass: HomeAssistant, entry: ConfigEntry):
|
||||||
"""Unload a config entry."""
|
"""Unload a config entry."""
|
||||||
platforms = {}
|
platforms = {}
|
||||||
|
|
||||||
|
hass.data[DOMAIN][UNSUB_LISTENER]()
|
||||||
|
for dev_id, device in hass.data[DOMAIN][TUYA_DEVICES].items():
|
||||||
|
if device.connected:
|
||||||
|
await device.close()
|
||||||
|
|
||||||
for dev_id, dev_entry in entry.data[CONF_DEVICES].items():
|
for dev_id, dev_entry in entry.data[CONF_DEVICES].items():
|
||||||
for entity in dev_entry[CONF_ENTITIES]:
|
for entity in dev_entry[CONF_ENTITIES]:
|
||||||
platforms[entity[CONF_PLATFORM]] = True
|
platforms[entity[CONF_PLATFORM]] = True
|
||||||
@@ -280,12 +286,6 @@ async def async_unload_entry(hass: HomeAssistant, entry: ConfigEntry):
|
|||||||
]
|
]
|
||||||
)
|
)
|
||||||
)
|
)
|
||||||
|
|
||||||
hass.data[DOMAIN][UNSUB_LISTENER]()
|
|
||||||
for dev_id, device in hass.data[DOMAIN][TUYA_DEVICES].items():
|
|
||||||
if device.connected:
|
|
||||||
await device.close()
|
|
||||||
|
|
||||||
if unload_ok:
|
if unload_ok:
|
||||||
hass.data[DOMAIN][TUYA_DEVICES] = {}
|
hass.data[DOMAIN][TUYA_DEVICES] = {}
|
||||||
|
|
||||||
|
@@ -1,5 +1,7 @@
|
|||||||
"""Diagnostics support for LocalTuya."""
|
"""Diagnostics support for LocalTuya."""
|
||||||
from __future__ import annotations
|
from __future__ import annotations
|
||||||
|
import logging
|
||||||
|
import copy
|
||||||
|
|
||||||
from typing import Any
|
from typing import Any
|
||||||
|
|
||||||
@@ -14,21 +16,24 @@ CLOUD_DEVICES = "cloud_devices"
|
|||||||
DEVICE_CONFIG = "device_config"
|
DEVICE_CONFIG = "device_config"
|
||||||
DEVICE_CLOUD_INFO = "device_cloud_info"
|
DEVICE_CLOUD_INFO = "device_cloud_info"
|
||||||
|
|
||||||
|
_LOGGER = logging.getLogger(__name__)
|
||||||
|
|
||||||
|
|
||||||
async def async_get_config_entry_diagnostics(
|
async def async_get_config_entry_diagnostics(
|
||||||
hass: HomeAssistant, entry: ConfigEntry
|
hass: HomeAssistant, entry: ConfigEntry
|
||||||
) -> dict[str, Any]:
|
) -> dict[str, Any]:
|
||||||
"""Return diagnostics for a config entry."""
|
"""Return diagnostics for a config entry."""
|
||||||
data = {}
|
data = {}
|
||||||
data = entry.data.copy()
|
data = dict(entry.data)
|
||||||
tuya_api = hass.data[DOMAIN][DATA_CLOUD]
|
tuya_api = hass.data[DOMAIN][DATA_CLOUD]
|
||||||
# censoring private information on integration diagnostic data
|
# censoring private information on integration diagnostic data
|
||||||
for field in [CONF_CLIENT_ID, CONF_CLIENT_SECRET, CONF_USER_ID]:
|
for field in [CONF_CLIENT_ID, CONF_CLIENT_SECRET, CONF_USER_ID]:
|
||||||
data[field] = f"{data[field][0:3]}...{data[field][-3:]}"
|
data[field] = f"{data[field][0:3]}...{data[field][-3:]}"
|
||||||
|
data[CONF_DEVICES] = copy.deepcopy(entry.data[CONF_DEVICES])
|
||||||
for dev_id, dev in data[CONF_DEVICES].items():
|
for dev_id, dev in data[CONF_DEVICES].items():
|
||||||
local_key = data[CONF_DEVICES][dev_id][CONF_LOCAL_KEY]
|
local_key = dev[CONF_LOCAL_KEY]
|
||||||
local_key_obfuscated = f"{local_key[0:3]}...{local_key[-3:]}"
|
local_key_obfuscated = f"{local_key[0:3]}...{local_key[-3:]}"
|
||||||
data[CONF_DEVICES][dev_id][CONF_LOCAL_KEY] = local_key_obfuscated
|
dev[CONF_LOCAL_KEY] = local_key_obfuscated
|
||||||
data[CLOUD_DEVICES] = tuya_api.device_list
|
data[CLOUD_DEVICES] = tuya_api.device_list
|
||||||
for dev_id, dev in data[CLOUD_DEVICES].items():
|
for dev_id, dev in data[CLOUD_DEVICES].items():
|
||||||
local_key = data[CLOUD_DEVICES][dev_id][CONF_LOCAL_KEY]
|
local_key = data[CLOUD_DEVICES][dev_id][CONF_LOCAL_KEY]
|
||||||
|
Reference in New Issue
Block a user