mirror of
https://github.com/home-assistant/core.git
synced 2025-07-18 18:57:06 +00:00
Add support for multiple devices to Tado device tracker (#5810)
* Add support for multiple devices to Tado device tracker * Hound did not agree with my usage of spaces * Two blank lines were expected * Keep CONF_HOME_ID in the Tado file * Make home_id optional * Work with different API URLs depending on home_id being present * Remove CONF_HOME_ID from HA's const.py file * Missed removing CONF_HOME_ID from the import
This commit is contained in:
parent
5ecef6aaac
commit
0d76d72b9f
@ -13,28 +13,31 @@ import aiohttp
|
|||||||
import async_timeout
|
import async_timeout
|
||||||
|
|
||||||
import voluptuous as vol
|
import voluptuous as vol
|
||||||
|
import homeassistant.helpers.config_validation as cv
|
||||||
|
|
||||||
from homeassistant.const import CONF_USERNAME, CONF_PASSWORD
|
from homeassistant.const import CONF_USERNAME, CONF_PASSWORD
|
||||||
import homeassistant.helpers.config_validation as cv
|
|
||||||
from homeassistant.util import Throttle
|
from homeassistant.util import Throttle
|
||||||
from homeassistant.components.device_tracker import (
|
from homeassistant.components.device_tracker import (
|
||||||
DOMAIN, PLATFORM_SCHEMA, DeviceScanner)
|
DOMAIN, PLATFORM_SCHEMA, DeviceScanner)
|
||||||
from homeassistant.helpers.aiohttp_client import async_create_clientsession
|
from homeassistant.helpers.aiohttp_client import async_create_clientsession
|
||||||
|
|
||||||
|
# Configuration constant specific for tado
|
||||||
|
CONF_HOME_ID = 'home_id'
|
||||||
|
|
||||||
_LOGGER = logging.getLogger(__name__)
|
_LOGGER = logging.getLogger(__name__)
|
||||||
|
|
||||||
MIN_TIME_BETWEEN_SCANS = timedelta(seconds=30)
|
MIN_TIME_BETWEEN_SCANS = timedelta(seconds=30)
|
||||||
|
|
||||||
PLATFORM_SCHEMA = PLATFORM_SCHEMA.extend({
|
PLATFORM_SCHEMA = PLATFORM_SCHEMA.extend({
|
||||||
|
vol.Required(CONF_USERNAME): cv.string,
|
||||||
vol.Required(CONF_PASSWORD): cv.string,
|
vol.Required(CONF_PASSWORD): cv.string,
|
||||||
vol.Required(CONF_USERNAME): cv.string
|
vol.Optional(CONF_HOME_ID): cv.string
|
||||||
})
|
})
|
||||||
|
|
||||||
|
|
||||||
def get_scanner(hass, config):
|
def get_scanner(hass, config):
|
||||||
"""Return a Tado scanner."""
|
"""Return a Tado scanner."""
|
||||||
scanner = TadoDeviceScanner(hass, config[DOMAIN])
|
scanner = TadoDeviceScanner(hass, config[DOMAIN])
|
||||||
|
|
||||||
return scanner if scanner.success_init else None
|
return scanner if scanner.success_init else None
|
||||||
|
|
||||||
|
|
||||||
@ -50,8 +53,19 @@ class TadoDeviceScanner(DeviceScanner):
|
|||||||
|
|
||||||
self.username = config[CONF_USERNAME]
|
self.username = config[CONF_USERNAME]
|
||||||
self.password = config[CONF_PASSWORD]
|
self.password = config[CONF_PASSWORD]
|
||||||
self.tadoapiurl = 'https://my.tado.com/api/v2/me' \
|
|
||||||
'?username={}&password={}'
|
# The Tado device tracker can work with or without a home_id
|
||||||
|
self.home_id = config[CONF_HOME_ID] if CONF_HOME_ID in config else None
|
||||||
|
|
||||||
|
# If there's a home_id, we need a different API URL
|
||||||
|
if self.home_id is None:
|
||||||
|
self.tadoapiurl = 'https://my.tado.com/api/v2/me'
|
||||||
|
else:
|
||||||
|
self.tadoapiurl = 'https://my.tado.com/api/v2' \
|
||||||
|
'/homes/{home_id}/mobileDevices'
|
||||||
|
|
||||||
|
# The API URL always needs a username and password
|
||||||
|
self.tadoapiurl += '?username={username}&password={password}'
|
||||||
|
|
||||||
self.websession = async_create_clientsession(
|
self.websession = async_create_clientsession(
|
||||||
hass, cookie_jar=aiohttp.CookieJar(unsafe=True, loop=hass.loop))
|
hass, cookie_jar=aiohttp.CookieJar(unsafe=True, loop=hass.loop))
|
||||||
@ -62,7 +76,11 @@ class TadoDeviceScanner(DeviceScanner):
|
|||||||
@asyncio.coroutine
|
@asyncio.coroutine
|
||||||
def async_scan_devices(self):
|
def async_scan_devices(self):
|
||||||
"""Scan for devices and return a list containing found device ids."""
|
"""Scan for devices and return a list containing found device ids."""
|
||||||
yield from self._update_info()
|
info = self._update_info()
|
||||||
|
|
||||||
|
# Don't yield if we got None
|
||||||
|
if info is not None:
|
||||||
|
yield from info
|
||||||
|
|
||||||
return [device.mac for device in self.last_results]
|
return [device.mac for device in self.last_results]
|
||||||
|
|
||||||
@ -87,43 +105,54 @@ class TadoDeviceScanner(DeviceScanner):
|
|||||||
_LOGGER.debug("Requesting Tado")
|
_LOGGER.debug("Requesting Tado")
|
||||||
|
|
||||||
last_results = []
|
last_results = []
|
||||||
|
|
||||||
response = None
|
response = None
|
||||||
tadojson = None
|
tado_json = None
|
||||||
|
|
||||||
try:
|
try:
|
||||||
# get first token
|
|
||||||
with async_timeout.timeout(10, loop=self.hass.loop):
|
with async_timeout.timeout(10, loop=self.hass.loop):
|
||||||
url = self.tadoapiurl.format(self.username, self.password)
|
# Format the URL here, so we can log the template URL if
|
||||||
response = yield from self.websession.get(
|
# anything goes wrong without exposing username and password.
|
||||||
url
|
url = self.tadoapiurl.format(home_id=self.home_id,
|
||||||
)
|
username=self.username,
|
||||||
|
password=self.password)
|
||||||
|
|
||||||
|
# Go get 'em!
|
||||||
|
response = yield from self.websession.get(url)
|
||||||
|
|
||||||
# error on Tado webservice
|
# error on Tado webservice
|
||||||
if response.status != 200:
|
if response.status != 200:
|
||||||
_LOGGER.warning(
|
_LOGGER.warning(
|
||||||
"Error %d on %s.", response.status, self.tadoapiurl)
|
"Error %d on %s.", response.status, self.tadoapiurl)
|
||||||
self.token = None
|
|
||||||
return
|
return
|
||||||
|
|
||||||
tadojson = yield from response.json()
|
tado_json = yield from response.json()
|
||||||
|
|
||||||
except (asyncio.TimeoutError, aiohttp.errors.ClientError):
|
except (asyncio.TimeoutError, aiohttp.errors.ClientError):
|
||||||
_LOGGER.error("Can not load Tado data")
|
_LOGGER.error("Cannot load Tado data")
|
||||||
return False
|
return False
|
||||||
|
|
||||||
finally:
|
finally:
|
||||||
if response is not None:
|
if response is not None:
|
||||||
yield from response.release()
|
yield from response.release()
|
||||||
|
|
||||||
# Find devices that have geofencing enabled, and are currently at home
|
# Without a home_id, we fetched an URL where the mobile devices can be
|
||||||
for mobiledevice in tadojson['mobileDevices']:
|
# found under the mobileDevices key.
|
||||||
if 'location' in mobiledevice:
|
if 'mobileDevices' in tado_json:
|
||||||
if mobiledevice['location']['atHome']:
|
tado_json = tado_json['mobileDevices']
|
||||||
deviceid = mobiledevice['id']
|
|
||||||
devicename = mobiledevice['name']
|
# Find devices that have geofencing enabled, and are currently at home.
|
||||||
last_results.append(Device(deviceid, devicename))
|
for mobile_device in tado_json:
|
||||||
|
if 'location' in mobile_device:
|
||||||
|
if mobile_device['location']['atHome']:
|
||||||
|
device_id = mobile_device['id']
|
||||||
|
device_name = mobile_device['name']
|
||||||
|
last_results.append(Device(device_id, device_name))
|
||||||
|
|
||||||
self.last_results = last_results
|
self.last_results = last_results
|
||||||
|
|
||||||
_LOGGER.info("Tado presence query successful")
|
_LOGGER.info(
|
||||||
|
"Tado presence query successful, %d device(s) at home",
|
||||||
|
len(self.last_results)
|
||||||
|
)
|
||||||
|
|
||||||
return True
|
return True
|
||||||
|
Loading…
x
Reference in New Issue
Block a user