mirror of https://github.com/home-assistant/core
69 lines
2.2 KiB
Python
69 lines
2.2 KiB
Python
"""Data update coordinator for the Tautulli integration."""
|
|
|
|
from __future__ import annotations
|
|
|
|
import asyncio
|
|
from datetime import timedelta
|
|
from typing import TYPE_CHECKING
|
|
|
|
from pytautulli import (
|
|
PyTautulli,
|
|
PyTautulliApiActivity,
|
|
PyTautulliApiHomeStats,
|
|
PyTautulliApiUser,
|
|
)
|
|
from pytautulli.exceptions import (
|
|
PyTautulliAuthenticationException,
|
|
PyTautulliConnectionException,
|
|
)
|
|
from pytautulli.models.host_configuration import PyTautulliHostConfiguration
|
|
|
|
from homeassistant.core import HomeAssistant
|
|
from homeassistant.exceptions import ConfigEntryAuthFailed
|
|
from homeassistant.helpers.update_coordinator import DataUpdateCoordinator, UpdateFailed
|
|
|
|
from .const import DOMAIN, LOGGER
|
|
|
|
if TYPE_CHECKING:
|
|
from . import TautulliConfigEntry
|
|
|
|
|
|
class TautulliDataUpdateCoordinator(DataUpdateCoordinator[None]):
|
|
"""Data update coordinator for the Tautulli integration."""
|
|
|
|
config_entry: TautulliConfigEntry
|
|
|
|
def __init__(
|
|
self,
|
|
hass: HomeAssistant,
|
|
host_configuration: PyTautulliHostConfiguration,
|
|
api_client: PyTautulli,
|
|
) -> None:
|
|
"""Initialize the coordinator."""
|
|
super().__init__(
|
|
hass=hass,
|
|
logger=LOGGER,
|
|
name=DOMAIN,
|
|
update_interval=timedelta(seconds=10),
|
|
)
|
|
self.host_configuration = host_configuration
|
|
self.api_client = api_client
|
|
self.activity: PyTautulliApiActivity | None = None
|
|
self.home_stats: list[PyTautulliApiHomeStats] | None = None
|
|
self.users: list[PyTautulliApiUser] | None = None
|
|
|
|
async def _async_update_data(self) -> None:
|
|
"""Get the latest data from Tautulli."""
|
|
try:
|
|
[self.activity, self.home_stats, self.users] = await asyncio.gather(
|
|
*[
|
|
self.api_client.async_get_activity(),
|
|
self.api_client.async_get_home_stats(),
|
|
self.api_client.async_get_users(),
|
|
]
|
|
)
|
|
except PyTautulliConnectionException as ex:
|
|
raise UpdateFailed(ex) from ex
|
|
except PyTautulliAuthenticationException as ex:
|
|
raise ConfigEntryAuthFailed(ex) from ex
|