""" device tracker for GeoRide object """ import logging from homeassistant.core import callback from homeassistant.components.switch import SwitchEntity from homeassistant.components.switch import ENTITY_ID_FORMAT import georideapilib.api as GeoRideApi from .const import DOMAIN as GEORIDE_DOMAIN _LOGGER = logging.getLogger(__name__) async def async_setup_entry(hass, config_entry, async_add_entities): # pylint: disable=W0613 """Set up GeoRide tracker based off an entry.""" georide_context = hass.data[GEORIDE_DOMAIN]["context"] token = await georide_context.get_token() if token is None: return False _LOGGER.info('Current georide token: %s', token) trackers = await hass.async_add_executor_job(GeoRideApi.get_trackers, token) lock_switch_entities = [] for tracker in trackers: entity = GeoRideLockSwitchEntity(hass, tracker.tracker_id, georide_context.get_token, georide_context.get_tracker, data=tracker) hass.data[GEORIDE_DOMAIN]["devices"][tracker.tracker_id] = entity lock_switch_entities.append(entity) async_add_entities(lock_switch_entities) return True class GeoRideLockSwitchEntity(SwitchEntity): """Represent a tracked device.""" def __init__(self, hass, tracker_id, get_token_callback, get_tracker_callback, data): """Set up GeoRide entity.""" self._tracker_id = tracker_id self._data = data or {} self._get_token_callback = get_token_callback self._get_tracker_callback = get_tracker_callback self._name = data.tracker_name self._is_on = data.is_locked self.entity_id = ENTITY_ID_FORMAT.format("lock") +"." + str(tracker_id) self._state = {} self._hass = hass async def async_turn_on(self, **kwargs): """ lock the GeoRide tracker """ _LOGGER.info('async_turn_on %s', kwargs) token = await self._get_token_callback() success = await self._hass.async_add_executor_job(GeoRideApi.lock_tracker, token, self._tracker_id) if success: self._data.is_locked = True self._is_on = True async def async_turn_off(self, **kwargs): """ unlock the GeoRide tracker """ _LOGGER.info('async_turn_off %s', kwargs) token = await self._get_token_callback() success = await self._hass.async_add_executor_job(GeoRideApi.unlock_tracker, token, self._tracker_id) if success: self._data.is_locked = False self._is_on = False async def async_toggle(self, **kwargs): """ toggle lock the georide tracker """ _LOGGER.info('async_toggle %s', kwargs) token = await self._get_token_callback() result = await self._hass.async_add_executor_job(GeoRideApi.toogle_lock_tracker, token, self._tracker_id) self._data.is_locked = result self._is_on = result async def async_update(self): """ update the current tracker""" _LOGGER.info('update') self._data = await self._get_tracker_callback(self._tracker_id) self._name = self._data.tracker_name self._is_on = self._data.is_locked @property def unique_id(self): """Return the unique ID.""" return self._tracker_id @property def name(self): """ GeoRide switch name """ return self._name @property def is_on(self): """ GeoRide switch status """ return self._is_on @property def get_token_callback(self): """ GeoRide switch token callback method """ return self._get_token_callback @property def get_tracker_callback(self): """ GeoRide switch token callback method """ return self._get_tracker_callback @property def icon(self): """return the entity icon""" if self._is_on: return "mdi:lock" return "mdi:lock-open" @property def device_info(self): """Return the device info.""" return { "name": self.name, "identifiers": {(GEORIDE_DOMAIN, self._tracker_id)}, "manufacturer": "GeoRide" }