config.py 1.6 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455
  1. """
  2. Helper for general config
  3. """
  4. import logging
  5. from .. import DOMAIN
  6. from ..const import CONF_DEVICE_CID, CONF_DEVICE_ID, CONF_TYPE
  7. from .device_config import get_config
  8. _LOGGER = logging.getLogger(__name__)
  9. async def async_tuya_setup_platform(
  10. hass, async_add_entities, discovery_info, platform, entity_class
  11. ):
  12. """Common functions for async_setup_platform for each entity platform."""
  13. data = hass.data[DOMAIN][get_device_id(discovery_info)]
  14. device = data["device"]
  15. entities = []
  16. cfg = await hass.async_add_executor_job(
  17. get_config,
  18. discovery_info[CONF_TYPE],
  19. )
  20. if cfg is None:
  21. raise ValueError(f"No device config found for {discovery_info}")
  22. for ecfg in cfg.all_entities():
  23. if ecfg.entity == platform:
  24. try:
  25. data[ecfg.config_id] = entity_class(device, ecfg)
  26. entities.append(data[ecfg.config_id])
  27. if ecfg.deprecated:
  28. _LOGGER.warning(ecfg.deprecation_message)
  29. _LOGGER.debug("Adding %s for %s", platform, ecfg.config_id)
  30. except Exception as e:
  31. _LOGGER.error(
  32. "Error adding %s for %s: %s",
  33. ecfg.config_id,
  34. cfg.config,
  35. e,
  36. )
  37. if not entities:
  38. raise ValueError(f"{device.name} does not support use as a {platform} device.")
  39. async_add_entities(entities)
  40. def get_device_id(config: dict):
  41. return (
  42. config[CONF_DEVICE_CID]
  43. if CONF_DEVICE_CID in config and config[CONF_DEVICE_CID] != ""
  44. else config[CONF_DEVICE_ID]
  45. )