"""
homeassistant.components.apcupsd
~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
Sets up and provides access to the status output of APCUPSd via its Network
Information Server (NIS).
"""
import logging
from datetime import timedelta

from homeassistant.util import Throttle


DOMAIN = "apcupsd"
REQUIREMENTS = ("apcaccess==0.0.4",)

CONF_HOST = "host"
CONF_PORT = "port"
CONF_TYPE = "type"

DEFAULT_HOST = "localhost"
DEFAULT_PORT = 3551

KEY_STATUS = "STATUS"

VALUE_ONLINE = "ONLINE"

MIN_TIME_BETWEEN_UPDATES = timedelta(seconds=60)

DATA = None

_LOGGER = logging.getLogger(__name__)


def setup(hass, config):
    """ Use config values to set up a function enabling status retrieval. """
    global DATA

    host = config[DOMAIN].get(CONF_HOST, DEFAULT_HOST)
    port = config[DOMAIN].get(CONF_PORT, DEFAULT_PORT)

    DATA = APCUPSdData(host, port)

    # It doesn't really matter why we're not able to get the status, just that
    # we can't.
    # pylint: disable=broad-except
    try:
        DATA.update(no_throttle=True)
    except Exception:
        _LOGGER.exception("Failure while testing APCUPSd status retrieval.")
        return False
    return True


class APCUPSdData(object):
    """
    Stores the data retrieved from APCUPSd for each entity to use, acts as the
    single point responsible for fetching updates from the server.
    """
    def __init__(self, host, port):
        from apcaccess import status
        self._host = host
        self._port = port
        self._status = None
        self._get = status.get
        self._parse = status.parse

    @property
    def status(self):
        """ Get latest update if throttle allows. Return status. """
        self.update()
        return self._status

    def _get_status(self):
        """ Get the status from APCUPSd and parse it into a dict. """
        return self._parse(self._get(host=self._host, port=self._port))

    @Throttle(MIN_TIME_BETWEEN_UPDATES)
    def update(self, **kwargs):
        """
        Fetch the latest status from APCUPSd and store it in self._status.
        """
        self._status = self._get_status()