"""Support for the Mikrotik Router device tracker.""" import logging from homeassistant.core import callback from homeassistant.helpers.device_registry import CONNECTION_NETWORK_MAC from homeassistant.helpers.dispatcher import async_dispatcher_connect from homeassistant.components.device_tracker.config_entry import ScannerEntity from homeassistant.components.device_tracker.const import SOURCE_TYPE_ROUTER from homeassistant.const import ( CONF_NAME, ATTR_ATTRIBUTION, ) from .const import ( DOMAIN, DATA_CLIENT, ATTRIBUTION, ) _LOGGER = logging.getLogger(__name__) DEVICE_ATTRIBUTES = [ "running", "enabled", "comment", "client-ip-address", "client-mac-address", "port-mac-address", "last-link-down-time", "last-link-up-time", "link-downs", "actual-mtu", "type", "name", "default-name", ] def format_attribute(attr): res = attr.replace("-", " ") res = res.capitalize() res = res.replace(" ip ", " IP ") res = res.replace(" mac ", " MAC ") res = res.replace(" mtu", " MTU") return res # --------------------------- # async_setup_entry # --------------------------- async def async_setup_entry(hass, config_entry, async_add_entities): """Set up device tracker for Mikrotik Router component.""" inst = config_entry.data[CONF_NAME] mikrotik_controller = hass.data[DOMAIN][DATA_CLIENT][config_entry.entry_id] tracked = {} @callback def update_controller(): """Update the values of the controller.""" update_items(inst, mikrotik_controller, async_add_entities, tracked) mikrotik_controller.listeners.append( async_dispatcher_connect(hass, mikrotik_controller.signal_update, update_controller) ) update_controller() return # --------------------------- # update_items # --------------------------- @callback def update_items(inst, mikrotik_controller, async_add_entities, tracked): """Update tracked device state from the controller.""" new_tracked = [] for uid in mikrotik_controller.data['interface']: if mikrotik_controller.data['interface'][uid]['type'] == "ether": item_id = "{}-{}".format(inst, mikrotik_controller.data['interface'][uid]['default-name']) if item_id in tracked: if tracked[item_id].enabled: tracked[item_id].async_schedule_update_ha_state() continue tracked[item_id] = MikrotikControllerPortDeviceTracker(inst, uid, mikrotik_controller) new_tracked.append(tracked[item_id]) if new_tracked: async_add_entities(new_tracked) return # --------------------------- # MikrotikControllerPortDeviceTracker # --------------------------- class MikrotikControllerPortDeviceTracker(ScannerEntity): """Representation of a network port.""" def __init__(self, inst, uid, mikrotik_controller): """Set up tracked port.""" self._inst = inst self._ctrl = mikrotik_controller self._data = mikrotik_controller.data['interface'][uid] self._attrs = { ATTR_ATTRIBUTION: ATTRIBUTION, } @property def entity_registry_enabled_default(self): """Return if the entity should be enabled when first added to the entity registry.""" return True async def async_added_to_hass(self): """Port entity created.""" _LOGGER.debug("New port tracker %s (%s)", self._inst, self._data['port-mac-address']) return async def async_update(self): """Synchronize state with controller.""" return @property def is_connected(self): """Return true if the port is connected to the network.""" return self._data['running'] @property def source_type(self): """Return the source type of the port.""" return SOURCE_TYPE_ROUTER @property def name(self): """Return the name of the port.""" return "{} {}".format(self._inst, self._data['default-name']) @property def unique_id(self): """Return a unique identifier for this port.""" return "{}-{}".format(self._inst.lower(), self._data['port-mac-address']) @property def available(self): """Return if controller is available.""" return self._ctrl.connected() @property def icon(self): """Return the icon.""" if self._data['running']: icon = 'mdi:lan-connect' else: icon = 'mdi:lan-pending' if not self._data['enabled']: icon = 'mdi:lan-disconnect' return icon @property def device_info(self): """Return a port description for device registry.""" info = { "connections": {(CONNECTION_NETWORK_MAC, self._data['port-mac-address'])}, "manufacturer": self._ctrl.data['resource']['platform'], "model": self._ctrl.data['resource']['board-name'], "name": self._data['default-name'], } return info @property def device_state_attributes(self): """Return the port state attributes.""" attributes = self._attrs for variable in DEVICE_ATTRIBUTES: if variable in self._data: attributes[format_attribute(variable)] = self._data[variable] return attributes