124 lines
3.4 KiB
Python
124 lines
3.4 KiB
Python
"""The ONVIF integration."""
|
|
import asyncio
|
|
|
|
import voluptuous as vol
|
|
|
|
from homeassistant.components.ffmpeg import CONF_EXTRA_ARGUMENTS
|
|
from homeassistant.config_entries import SOURCE_IMPORT, ConfigEntry
|
|
from homeassistant.const import (
|
|
CONF_HOST,
|
|
CONF_NAME,
|
|
CONF_PASSWORD,
|
|
CONF_PORT,
|
|
CONF_USERNAME,
|
|
EVENT_HOMEASSISTANT_STOP,
|
|
)
|
|
from homeassistant.core import HomeAssistant
|
|
from homeassistant.exceptions import ConfigEntryNotReady
|
|
from homeassistant.helpers import config_per_platform
|
|
|
|
from .const import (
|
|
CONF_RTSP_TRANSPORT,
|
|
DEFAULT_ARGUMENTS,
|
|
DEFAULT_NAME,
|
|
DEFAULT_PASSWORD,
|
|
DEFAULT_PORT,
|
|
DEFAULT_USERNAME,
|
|
DOMAIN,
|
|
RTSP_TRANS_PROTOCOLS,
|
|
)
|
|
from .device import ONVIFDevice
|
|
|
|
CONFIG_SCHEMA = vol.Schema({DOMAIN: vol.Schema({})}, extra=vol.ALLOW_EXTRA)
|
|
|
|
|
|
async def async_setup(hass: HomeAssistant, config: dict):
|
|
"""Set up the ONVIF component."""
|
|
# Import from yaml
|
|
configs = {}
|
|
for p_type, p_config in config_per_platform(config, "camera"):
|
|
if p_type != DOMAIN:
|
|
continue
|
|
|
|
config = p_config.copy()
|
|
if config[CONF_HOST] not in configs.keys():
|
|
configs[config[CONF_HOST]] = {
|
|
CONF_HOST: config[CONF_HOST],
|
|
CONF_NAME: config.get(CONF_NAME, DEFAULT_NAME),
|
|
CONF_PASSWORD: config.get(CONF_PASSWORD, DEFAULT_PASSWORD),
|
|
CONF_PORT: config.get(CONF_PORT, DEFAULT_PORT),
|
|
CONF_USERNAME: config.get(CONF_USERNAME, DEFAULT_USERNAME),
|
|
}
|
|
|
|
for conf in configs.values():
|
|
hass.async_create_task(
|
|
hass.config_entries.flow.async_init(
|
|
DOMAIN, context={"source": SOURCE_IMPORT}, data=conf
|
|
)
|
|
)
|
|
|
|
return True
|
|
|
|
|
|
async def async_setup_entry(hass: HomeAssistant, entry: ConfigEntry):
|
|
"""Set up ONVIF from a config entry."""
|
|
if DOMAIN not in hass.data:
|
|
hass.data[DOMAIN] = {}
|
|
|
|
if not entry.options:
|
|
await async_populate_options(hass, entry)
|
|
|
|
device = ONVIFDevice(hass, entry)
|
|
|
|
if not await device.async_setup():
|
|
return False
|
|
|
|
if not device.available:
|
|
raise ConfigEntryNotReady()
|
|
|
|
hass.data[DOMAIN][entry.unique_id] = device
|
|
|
|
platforms = ["camera"]
|
|
|
|
if device.capabilities.events and await device.events.async_start():
|
|
platforms += ["binary_sensor", "sensor"]
|
|
|
|
for component in platforms:
|
|
hass.async_create_task(
|
|
hass.config_entries.async_forward_entry_setup(entry, component)
|
|
)
|
|
|
|
hass.bus.async_listen_once(EVENT_HOMEASSISTANT_STOP, device.async_stop)
|
|
|
|
return True
|
|
|
|
|
|
async def async_unload_entry(hass: HomeAssistant, entry: ConfigEntry):
|
|
"""Unload a config entry."""
|
|
|
|
device = hass.data[DOMAIN][entry.unique_id]
|
|
platforms = ["camera"]
|
|
|
|
if device.capabilities.events and device.events.started:
|
|
platforms += ["binary_sensor", "sensor"]
|
|
await device.events.async_stop()
|
|
|
|
return all(
|
|
await asyncio.gather(
|
|
*[
|
|
hass.config_entries.async_forward_entry_unload(entry, component)
|
|
for component in platforms
|
|
]
|
|
)
|
|
)
|
|
|
|
|
|
async def async_populate_options(hass, entry):
|
|
"""Populate default options for device."""
|
|
options = {
|
|
CONF_EXTRA_ARGUMENTS: DEFAULT_ARGUMENTS,
|
|
CONF_RTSP_TRANSPORT: RTSP_TRANS_PROTOCOLS[0],
|
|
}
|
|
|
|
hass.config_entries.async_update_entry(entry, options=options)
|