75 lines
2.2 KiB
Python
75 lines
2.2 KiB
Python
"""
|
|
homeassistant.components.automation
|
|
~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
|
|
|
|
Allows to setup simple automation rules via the config file.
|
|
"""
|
|
import logging
|
|
|
|
from homeassistant.bootstrap import prepare_setup_platform
|
|
from homeassistant.helpers import config_per_platform
|
|
from homeassistant.util import split_entity_id
|
|
from homeassistant.const import ATTR_ENTITY_ID
|
|
|
|
DOMAIN = "automation"
|
|
|
|
DEPENDENCIES = ["group"]
|
|
|
|
CONF_ALIAS = "alias"
|
|
CONF_SERVICE = "execute_service"
|
|
CONF_SERVICE_ENTITY_ID = "service_entity_id"
|
|
CONF_SERVICE_DATA = "service_data"
|
|
|
|
_LOGGER = logging.getLogger(__name__)
|
|
|
|
|
|
def setup(hass, config):
|
|
""" Sets up automation. """
|
|
success = False
|
|
|
|
for p_type, p_config in config_per_platform(config, DOMAIN, _LOGGER):
|
|
platform = prepare_setup_platform(hass, config, DOMAIN, p_type)
|
|
|
|
if platform is None:
|
|
_LOGGER.error("Unknown automation platform specified: %s", p_type)
|
|
continue
|
|
|
|
if platform.register(hass, p_config, _get_action(hass, p_config)):
|
|
_LOGGER.info(
|
|
"Initialized %s rule %s", p_type, p_config.get(CONF_ALIAS, ""))
|
|
success = True
|
|
else:
|
|
_LOGGER.error(
|
|
"Error setting up rule %s", p_config.get(CONF_ALIAS, ""))
|
|
|
|
return success
|
|
|
|
|
|
def _get_action(hass, config):
|
|
""" Return an action based on a config. """
|
|
|
|
def action():
|
|
""" Action to be executed. """
|
|
_LOGGER.info("Executing rule %s", config.get(CONF_ALIAS, ""))
|
|
|
|
if CONF_SERVICE in config:
|
|
domain, service = split_entity_id(config[CONF_SERVICE])
|
|
|
|
service_data = config.get(CONF_SERVICE_DATA, {})
|
|
|
|
if not isinstance(service_data, dict):
|
|
_LOGGER.error("%s should be a dictionary", CONF_SERVICE_DATA)
|
|
service_data = {}
|
|
|
|
if CONF_SERVICE_ENTITY_ID in config:
|
|
try:
|
|
service_data[ATTR_ENTITY_ID] = \
|
|
config[CONF_SERVICE_ENTITY_ID].split(",")
|
|
except AttributeError:
|
|
service_data[ATTR_ENTITY_ID] = \
|
|
config[CONF_SERVICE_ENTITY_ID]
|
|
|
|
hass.services.call(domain, service, service_data)
|
|
|
|
return action
|