ChristianKuehnel
316eb59de2
* first working version of BMW connected drive sensor * extended coveragerc * fixed blank line * fixed pylint * major refactoring after major refactoring in bimmer_connected * Update are now triggered from BMWConnectedDriveVehicle. * removed polling from sensor and device_tracker * backend URL is not detected automatically based on current country * vehicles are discovered automatically * updates are async now resolves: * https://github.com/ChristianKuehnel/bimmer_connected/issues/3 * https://github.com/ChristianKuehnel/bimmer_connected/issues/5 * improved exception handing * fixed static analysis findings * fixed review comments from @MartinHjelmare * improved startup, data is updated right after sensors were created. * fixed pylint issue * updated to latest release of the bimmer_connected library * updated requirements-all.txt * fixed comments from @MartinHjelmare * calling self.update from async_add_job * removed unused attribute "account"
106 lines
3.1 KiB
Python
106 lines
3.1 KiB
Python
"""
|
|
Reads vehicle status from BMW connected drive portal.
|
|
|
|
For more details about this platform, please refer to the documentation at
|
|
https://home-assistant.io/components/bmw_connected_drive/
|
|
"""
|
|
import logging
|
|
import datetime
|
|
|
|
import voluptuous as vol
|
|
from homeassistant.helpers import discovery
|
|
from homeassistant.helpers.event import track_utc_time_change
|
|
|
|
import homeassistant.helpers.config_validation as cv
|
|
from homeassistant.const import (
|
|
CONF_USERNAME, CONF_PASSWORD
|
|
)
|
|
|
|
REQUIREMENTS = ['bimmer_connected==0.3.0']
|
|
|
|
_LOGGER = logging.getLogger(__name__)
|
|
|
|
DOMAIN = 'bmw_connected_drive'
|
|
CONF_VALUES = 'values'
|
|
CONF_COUNTRY = 'country'
|
|
|
|
ACCOUNT_SCHEMA = vol.Schema({
|
|
vol.Required(CONF_USERNAME): cv.string,
|
|
vol.Required(CONF_PASSWORD): cv.string,
|
|
vol.Required(CONF_COUNTRY): cv.string,
|
|
})
|
|
|
|
CONFIG_SCHEMA = vol.Schema({
|
|
DOMAIN: {
|
|
cv.string: ACCOUNT_SCHEMA
|
|
},
|
|
}, extra=vol.ALLOW_EXTRA)
|
|
|
|
|
|
BMW_COMPONENTS = ['device_tracker', 'sensor']
|
|
UPDATE_INTERVAL = 5 # in minutes
|
|
|
|
|
|
def setup(hass, config):
|
|
"""Set up the BMW connected drive components."""
|
|
accounts = []
|
|
for name, account_config in config[DOMAIN].items():
|
|
username = account_config[CONF_USERNAME]
|
|
password = account_config[CONF_PASSWORD]
|
|
country = account_config[CONF_COUNTRY]
|
|
_LOGGER.debug('Adding new account %s', name)
|
|
bimmer = BMWConnectedDriveAccount(username, password, country, name)
|
|
accounts.append(bimmer)
|
|
|
|
# update every UPDATE_INTERVAL minutes, starting now
|
|
# this should even out the load on the servers
|
|
|
|
now = datetime.datetime.now()
|
|
track_utc_time_change(
|
|
hass, bimmer.update,
|
|
minute=range(now.minute % UPDATE_INTERVAL, 60, UPDATE_INTERVAL),
|
|
second=now.second)
|
|
|
|
hass.data[DOMAIN] = accounts
|
|
|
|
for account in accounts:
|
|
account.update()
|
|
|
|
for component in BMW_COMPONENTS:
|
|
discovery.load_platform(hass, component, DOMAIN, {}, config)
|
|
|
|
return True
|
|
|
|
|
|
class BMWConnectedDriveAccount(object):
|
|
"""Representation of a BMW vehicle."""
|
|
|
|
def __init__(self, username: str, password: str, country: str,
|
|
name: str) -> None:
|
|
"""Constructor."""
|
|
from bimmer_connected.account import ConnectedDriveAccount
|
|
|
|
self.account = ConnectedDriveAccount(username, password, country)
|
|
self.name = name
|
|
self._update_listeners = []
|
|
|
|
def update(self, *_):
|
|
"""Update the state of all vehicles.
|
|
|
|
Notify all listeners about the update.
|
|
"""
|
|
_LOGGER.debug('Updating vehicle state for account %s, '
|
|
'notifying %d listeners',
|
|
self.name, len(self._update_listeners))
|
|
try:
|
|
self.account.update_vehicle_states()
|
|
for listener in self._update_listeners:
|
|
listener()
|
|
except IOError as exception:
|
|
_LOGGER.error('Error updating the vehicle state.')
|
|
_LOGGER.exception(exception)
|
|
|
|
def add_update_listener(self, listener):
|
|
"""Add a listener for update notifications."""
|
|
self._update_listeners.append(listener)
|