Compare commits

...

21 Commits
0.1.0 ... 0.5.1

Author SHA1 Message Date
02e1656aab Merge branch 'develop' 2020-12-01 19:24:26 +01:00
4593c694d5 GeoRide wording update 2020-05-26 22:39:09 +02:00
9b651f933e Shipping v0.5.0 2020-05-23 15:07:27 +02:00
a8274f7fd1 Update to prepare new home assisntant version (0.111) 2020-05-23 15:01:52 +02:00
ef783db79b HotFix deveice_tracker.py du to HA Update 2020-03-28 23:59:38 +01:00
18de851e4d Merge pull request #2 from limeryls/fix_login
Fix setting login credentials using config_flow and fix mistakes in spelling
2020-03-28 17:04:19 +01:00
Kévin SIMON-QUESNEL
cbed2cebb3 Fix setting login credentials using config_flow and fix mistakes in spelling 2020-03-28 04:38:52 +01:00
e5bd90ae6f Shipping v0.4.1 2019-11-11 13:37:28 +01:00
a2e65694fc Increase interval to refresh each 10 minutes 2019-11-11 13:33:17 +01:00
66bd335a8e Add component to default HACS 2019-11-09 10:04:47 +01:00
14300c5278 Add polling off all tracker each hours 2019-11-09 09:11:56 +01:00
bc3da8f0e5 Shipping v0.4.0 2019-11-05 22:01:46 +01:00
ecf2a23c70 Fix socket thread launch after first time 2019-11-05 21:52:07 +01:00
991370fcec index on master: 7a80670 Add better polling 2019-11-03 19:15:58 +01:00
649c97b8bb Shipping v0.3.0 2019-11-02 21:49:31 +01:00
9ffc8de8a7 Add odometter sensor 2019-11-02 21:49:04 +01:00
9399c8e11a Add login failed treatment and renew token 2019-11-02 19:55:41 +01:00
b40c41e6b8 Shipping v0.2.0 2019-11-01 18:48:03 +01:00
3c9f42aa2b Support setup exception 2019-11-01 14:00:57 +01:00
cc45b02a3a Chandge switch from async to realtume update 2019-10-30 22:34:00 +01:00
750073b8f3 Add support of socket (georideapilib 0.4.0) 2019-10-30 21:56:22 +01:00
13 changed files with 437 additions and 184 deletions

View File

@@ -1,8 +1,32 @@
# Georide Home assistant # GeoRide Home assistant
![Logo Georide](georide-logo.png) ![Logo GeoRide](https://brands.home-assistant.io/georide/logo.png)
⚠️ this is not an official implementation ⚠️ This is not an official implementation
[![hacs_badge](https://img.shields.io/badge/HACS-Default-orange.svg?style=for-the-badge)](https://github.com/custom-components/hacs)
[![License: GPL v3](https://img.shields.io/badge/License-GPLv3-blue.svg?style=for-the-badge)](https://www.gnu.org/licenses/gpl-3.0)
Official georide website: https://georide.fr/ Official GeoRide website: https://georide.fr/
## Description
This component add some sensor for GeoRide Tracker
## Options
| Name | Type | Requirement | `default` Description
| ---- | ---- | ------- | -----------
| email | string | **Required** | GeoRide email
| password | string | **Required** | GeoRide password
## Installation
### Option 1
- Just folow the integration config steps.
### Option 2
- Add the folowing line in your configuration.yml
```yaml
georide:
email: <your-email>@exmple.com
password: <your-password>
```

View File

@@ -1,23 +0,0 @@
{
"config": {
"title": "GeoRide",
"step": {
"user": {
"title": "Set up GeoRide",
"description": "Are you sure you want to set up GeoRide ?",
"data": {
"email": "email",
"password": "password"
}
}
},
"abort": {
"one_instance_allowed": "Only a single instance is allowed.",
"no_credential": "You need to add your credentails."
},
"create_entry": {
"default": "\n\nLogin succes"
}
}
}

View File

@@ -3,13 +3,18 @@ from collections import defaultdict
import logging import logging
from datetime import timedelta from datetime import timedelta
import math
import time
import json
from threading import Thread
import voluptuous as vol import voluptuous as vol
import jwt
from aiohttp.web import json_response from aiohttp.web import json_response
from georideapilib.objects import GeorideAccount from georideapilib.objects import GeorideAccount as GeoRideAccount
import georideapilib.api as GeorideApi import georideapilib.api as GeoRideApi
from georideapilib.socket import GeorideSocket as GeoRideSocket
from homeassistant import config_entries from homeassistant import config_entries
from homeassistant.const import CONF_WEBHOOK_ID from homeassistant.const import CONF_WEBHOOK_ID
@@ -22,10 +27,13 @@ from homeassistant.setup import async_when_setup
from .const import ( from .const import (
CONF_EMAIL, CONF_EMAIL,
CONF_PASSWORD, CONF_PASSWORD,
TRACKER_ID CONF_TOKEN,
TRACKER_ID,
TOKEN_SAFE_DAY,
MIN_UNTIL_REFRESH,
DOMAIN
) )
DOMAIN = "georide"
_LOGGER = logging.getLogger(__name__) _LOGGER = logging.getLogger(__name__)
@@ -42,90 +50,94 @@ CONFIG_SCHEMA = vol.Schema(
async def async_setup(hass, config): async def async_setup(hass, config):
"""Setup Georide component.""" """Setup GeoRide component."""
hass.data[DOMAIN] = {"config": config[DOMAIN], "devices": {}, "unsub": None} hass.data[DOMAIN] = {"config": config[DOMAIN], "devices": {}, "unsub": None}
hass.async_create_task( hass.async_create_task(
hass.config_entries.flow.async_init( hass.config_entries.flow.async_init(
DOMAIN, context={"source": config_entries.SOURCE_IMPORT}, data={} DOMAIN,
context={
"source": config_entries.SOURCE_IMPORT
},
data={}
) )
) )
_LOGGER.info("Georide-setup ")
# Return boolean to indicate that initialization was successful. # Return boolean to indicate that initialization was successful.
return True return True
async def async_setup_entry(hass, entry): async def async_setup_entry(hass, entry):
"""Set up Georide entry.""" """Set up GeoRide entry."""
def georide_update(event):
"""Update tracker info"""
nonlocal hass
_LOGGER.info('Georide update event %s', event)
georide_context = hass.data[DOMAIN]["context"]
token = georide_context.async_get_token()
trackers = GeorideApi.get_trackers(token)
georide_context.georide_trackers = trackers
ha_event.async_track_time_interval(hass, georide_update, timedelta(seconds=30))
config = hass.data[DOMAIN]["config"] config = hass.data[DOMAIN]["config"]
email = config.get(CONF_EMAIL) or entry.data[CONF_EMAIL] email = config.get(CONF_EMAIL) or entry.data[CONF_EMAIL]
password = config.get(CONF_PASSWORD) or entry.data[CONF_PASSWORD] password = config.get(CONF_PASSWORD) or entry.data[CONF_PASSWORD]
token = config.get(CONF_TOKEN) or entry.data[CONF_TOKEN]
if email is None or password is None: context = GeoRideContext(
return False
account = GeorideApi.get_authorisation_token(email, password)
context = GeorideContext(
hass, hass,
email, email,
password, password,
account.auth_token token
) )
_LOGGER.info("Context-setup and start the thread")
_LOGGER.info("Thread started")
hass.data[DOMAIN]["context"] = context hass.data[DOMAIN]["context"] = context
# We add trackers to the context # We add trackers to the context
trackers = GeorideApi.get_trackers(account.auth_token) context.refresh_trackers()
context.georide_trackers = trackers
hass.async_create_task(hass.config_entries.async_forward_entry_setup(entry, "device_tracker"))
hass.async_create_task(hass.config_entries.async_forward_entry_setup(entry, "switch"))
hass.async_create_task(
hass.config_entries.async_forward_entry_setup(entry, "device_tracker"))
hass.async_create_task(
hass.config_entries.async_forward_entry_setup(entry, "switch"))
hass.async_create_task(
hass.config_entries.async_forward_entry_setup(entry, "sensor"))
return True return True
async def async_unload_entry(hass, entry): async def async_unload_entry(hass, entry):
"""Unload an Georide config entry.""" """Unload an GeoRide config entry."""
await hass.config_entries.async_forward_entry_unload(entry, "device_tracker") await hass.config_entries.async_forward_entry_unload(entry, "device_tracker")
await hass.config_entries.async_forward_entry_unload(entry, "switch") await hass.config_entries.async_forward_entry_unload(entry, "switch")
await hass.config_entries.async_forward_entry_unload(entry, "sensor")
context = hass.data[DOMAIN]["context"]
context.socket.disconnect()
hass.data[DOMAIN]["unsub"]() hass.data[DOMAIN]["unsub"]()
return True return True
def connect_socket(context):
"""subscribe to GeoRide socket"""
_LOGGER.info("GeoRide socket connexion")
socket = GeoRideSocket()
socket.subscribe_locked(context.on_lock_callback)
socket.subscribe_device(context.on_device_callback)
socket.subscribe_position(context.on_position_callback)
class GeorideContext: context.socket = socket
"""Hold the current Georide context."""
socket.init()
socket.connect(context.get_token())
class GeoRideContext:
"""Hold the current GeoRide context."""
def __init__(self, hass, email, password, token): def __init__(self, hass, email, password, token):
"""Initialize an Georide context.""" """Initialize an GeoRide context."""
self._hass = hass self._hass = hass
self._email = email self._email = email
self._password = password self._password = password
self._georide_trackers = defaultdict(set) self._georide_trackers = defaultdict(set)
self._token = token self._token = token
self._pending_msg = [] self._socket = None
self._thread_started = False
self._previous_refresh = math.floor(time.time()/60)
@property @property
def hass(self): def hass(self):
""" hass """ """ hass """
@@ -148,29 +160,98 @@ class GeorideContext:
@property @property
def georide_trackers(self): def georide_trackers(self):
""" georide tracker list """ """ GeoRide tracker list """
return self._georide_trackers return self._georide_trackers
@georide_trackers.setter @georide_trackers.setter
def georide_trackers(self, trackers): def georide_trackers(self, trackers):
""" georide tracker list """ """ GeoRide tracker list """
self._georide_trackers = trackers self._georide_trackers = trackers
@callback def get_token(self):
def async_get_token(self): """ here we return the current valid tocken """
""" here we return the current valid tocken, TODO: add here token expiration control""" jwt_data = jwt.decode(self._token, verify=False)
exp_timestamp = jwt_data['exp']
epoch = math.ceil(time.time())
if (exp_timestamp - TOKEN_SAFE_DAY) < epoch:
_LOGGER.info("Time reached, renew token")
account = GeoRideApi.get_authorisation_token(self._email, self._password)
config = self._hass.data[DOMAIN]["config"]
config[CONF_TOKEN] = account.auth_token
self._token = account.auth_token
_LOGGER.info("Token exp data: %s", exp_timestamp)
return self._token return self._token
@callback def get_tracker(self, tracker_id):
def async_get_tracker(self, tracker_id): """ here we return last tracker by id"""
""" here we return the current valid tocken, TODO: add here token expiration control""" epoch_min = math.floor(time.time()/60)
if (epoch_min % MIN_UNTIL_REFRESH) == 0:
if epoch_min != self._previous_refresh:
self._previous_refresh = epoch_min
self.refresh_trackers()
if not self._thread_started:
_LOGGER.info("Start the thread")
self._hass.async_add_executor_job(connect_socket, self)
# We refresh the tracker list each hours
self._thread_started = True
for tracker in self._georide_trackers: for tracker in self._georide_trackers:
if tracker.tracker_id == tracker_id: if tracker.tracker_id == tracker_id:
return tracker return tracker
return None return None
def refresh_trackers(self):
"""Used to refresh the tracker list"""
_LOGGER.info("Tracker list refresh")
self._georide_trackers = GeoRideApi.get_trackers(self.get_token())
@property
def socket(self):
""" hold the GeoRide socket """
return self._socket
@socket.setter
def socket(self, socket):
"""set the GeoRide socket"""
self._socket = socket
@callback @callback
def async_see(self, **data): def on_lock_callback(self, data):
"""Send a see message to the device tracker.""" """on lock callback"""
_LOGGER.info("sync_see") _LOGGER.info("On lock received")
self._pending_msg.append(data) for tracker in self._georide_trackers:
if tracker.tracker_id == data['trackerId']:
tracker.locked_latitude = data['lockedLatitude']
tracker.locked_longitude = data['lockedLongitude']
tracker.is_locked = data['isLocked']
return
@callback
def on_device_callback(self, data):
"""on device callback"""
_LOGGER.info("On device received")
for tracker in self._georide_trackers:
if tracker.tracker_id == data['trackerId']:
tracker.status = data['status']
return
@callback
def on_position_callback(self, data):
"""on position callback"""
_LOGGER.info("On position received")
for tracker in self._georide_trackers:
if tracker.tracker_id == data['trackerId']:
tracker.latitude = data['latitude']
tracker.longitude = data['longitude']
tracker.moving = data['moving']
tracker.speed = data['speed']
tracker.fixtime = data['fixtime']
return

View File

@@ -3,58 +3,70 @@
import logging import logging
from homeassistant import config_entries from homeassistant import config_entries
import voluptuous as vol import voluptuous as vol
import georideapilib.api as GeoRideApi
import georideapilib.exception as GeoRideException
from .const import CONF_EMAIL, CONF_PASSWORD from .const import CONF_EMAIL, CONF_PASSWORD, CONF_TOKEN
_LOGGER = logging.getLogger(__name__) _LOGGER = logging.getLogger(__name__)
@config_entries.HANDLERS.register("georide") @config_entries.HANDLERS.register("georide")
class GeorideConfigFlow(config_entries.ConfigFlow): class GeoRideConfigFlow(config_entries.ConfigFlow):
"""Georide config flow """ """GeoRide config flow """
async def async_step_user(self, user_input=None): async def async_step_user(self, user_input=None): #pylint: disable=W0613
""" handle info to help to configure georide """ """ handle info to help to configure GeoRide """
if self._async_current_entries(): if self._async_current_entries():
return self.async_abort(reason="one_instance_allowed") return self.async_abort(reason="one_instance_allowed")
if user_input is None: return self.async_show_form(step_id='georide_login', data_schema=vol.Schema({
return self.async_show_form(step_id='user', data_schema=vol.Schema({
vol.Required(CONF_EMAIL): vol.All(str, vol.Length(min=3)), vol.Required(CONF_EMAIL): vol.All(str, vol.Length(min=3)),
vol.Required(CONF_PASSWORD): vol.All(str) vol.Required(CONF_PASSWORD): vol.All(str)
})) }))
return self.async_create_entry( async def async_step_import(self, user_input=None): #pylint: disable=W0613
title=user_input[CONF_EMAIL],
data={
CONF_EMAIL: user_input[CONF_EMAIL],
CONF_PASSWORD: user_input[CONF_PASSWORD]
}
)
async def async_step_import(self, user_input):
"""Import a config flow from configuration.""" """Import a config flow from configuration."""
_LOGGER.info("user email: %", str(user_input))
if self._async_current_entries(): if self._async_current_entries():
return self.async_abort(reason="one_instance_allowed") return self.async_abort(reason="one_instance_allowed")
if user_input is None: return self.async_show_form(step_id='georide_login', data_schema=vol.Schema({
return self.async_show_form(step_id='user', data_schema=vol.Schema({
vol.Required(CONF_EMAIL): vol.All(str, vol.Length(min=3)), vol.Required(CONF_EMAIL): vol.All(str, vol.Length(min=3)),
vol.Required(CONF_PASSWORD): vol.All(str) vol.Required(CONF_PASSWORD): vol.All(str)
})) }))
return self.async_create_entry(
title=user_input,
data={ async def async_step_georide_login(self, user_input):
CONF_EMAIL: user_input[CONF_EMAIL], """ try to seupt GeoRide Account """
CONF_PASSWORD: user_input[CONF_PASSWORD]
} schema = vol.Schema({
) vol.Required(CONF_EMAIL): vol.All(str, vol.Length(min=3)),
vol.Required(CONF_PASSWORD): vol.All(str)
})
if user_input is None:
return self.async_show_form(step_id='georide_login', data_schema=schema)
email = user_input[CONF_EMAIL]
password = user_input[CONF_PASSWORD]
try:
account = GeoRideApi.get_authorisation_token(email, password)
data = {
CONF_EMAIL: email,
CONF_PASSWORD: password,
CONF_TOKEN: account.auth_token
}
return self.async_create_entry(title=email, data=data)
except (GeoRideException.SeverException, GeoRideException.LoginException):
_LOGGER.error("Invalid credentials provided, config not created")
errors = {"base": "faulty_credentials"}
return self.async_show_form(step_id="georide_login", data_schema=schema, errors=errors)
except:
_LOGGER.error("Unknown error")
errors = {"base": "unkonwn"}
return self.async_show_form(step_id="georide_login", data_schema=schema, errors=errors)

View File

@@ -1,4 +1,5 @@
""" Georide const file """ """ GeoRide const file """
DOMAIN = "georide"
CONF_EMAIL = "email" CONF_EMAIL = "email"
CONF_PASSWORD = "password" CONF_PASSWORD = "password"
@@ -6,3 +7,7 @@ CONF_PASSWORD = "password"
CONF_TOKEN = "token" CONF_TOKEN = "token"
TRACKER_ID = "trackerId" TRACKER_ID = "trackerId"
MIN_UNTIL_REFRESH = 10
TOKEN_SAFE_DAY = 432000 # five days

View File

@@ -1,14 +1,13 @@
""" device tracker for Georide object """ """ device tracker for GeoRide object """
import logging import logging
from homeassistant.core import callback from homeassistant.components.device_tracker.const import DOMAIN, SOURCE_TYPE_GPS
from homeassistant.components.device_tracker.const import ENTITY_ID_FORMAT, SOURCE_TYPE_GPS
from homeassistant.components.device_tracker.config_entry import TrackerEntity from homeassistant.components.device_tracker.config_entry import TrackerEntity
import georideapilib.api as GeorideApi import georideapilib.api as GeoRideApi
from . import DOMAIN as GEORIDE_DOMAIN from .const import DOMAIN as GEORIDE_DOMAIN
_LOGGER = logging.getLogger(__name__) _LOGGER = logging.getLogger(__name__)
@@ -18,19 +17,19 @@ async def async_setup_entry(hass, config_entry, async_add_entities): # pylint: d
georide_context = hass.data[GEORIDE_DOMAIN]["context"] georide_context = hass.data[GEORIDE_DOMAIN]["context"]
if georide_context.token is None: if georide_context.get_token() is None:
return False return False
_LOGGER.info('Current georide token: %s', georide_context.async_get_token()) _LOGGER.debug('Current GeoRide token: %s', georide_context.get_token())
trackers = GeorideApi.get_trackers(georide_context.async_get_token()) trackers = GeoRideApi.get_trackers(georide_context.get_token())
tracker_entities = [] tracker_entities = []
for tracker in trackers: for tracker in trackers:
entity = GeorideTrackerEntity(tracker.tracker_id, georide_context.async_get_token, entity = GeoRideTrackerEntity(tracker.tracker_id, georide_context.get_token,
georide_context.async_get_tracker, tracker) georide_context.get_tracker, tracker)
hass.data[GEORIDE_DOMAIN]["devices"][tracker.tracker_id] = entity hass.data[GEORIDE_DOMAIN]["devices"][tracker.tracker_id] = entity
@@ -41,17 +40,17 @@ async def async_setup_entry(hass, config_entry, async_add_entities): # pylint: d
return True return True
class GeorideTrackerEntity(TrackerEntity): class GeoRideTrackerEntity(TrackerEntity):
"""Represent a tracked device.""" """Represent a tracked device."""
def __init__(self, tracker_id, get_token_callback, get_tracker_callback, tracker): def __init__(self, tracker_id, get_token_callback, get_tracker_callback, tracker):
"""Set up Georide entity.""" """Set up GeoRide entity."""
self._tracker_id = tracker_id self._tracker_id = tracker_id
self._get_token_callback = get_token_callback self._get_token_callback = get_token_callback
self._get_tracker_callback = get_tracker_callback self._get_tracker_callback = get_tracker_callback
self._name = tracker.tracker_name self._name = tracker.tracker_name
self._data = tracker or {} self._data = tracker or {}
self.entity_id = ENTITY_ID_FORMAT.format(tracker_id) self.entity_id = DOMAIN + ".{}".format(tracker_id)
@property @property
def unique_id(self): def unique_id(self):
@@ -89,6 +88,7 @@ class GeorideTrackerEntity(TrackerEntity):
@property @property
def icon(self): def icon(self):
"""return the entity icon"""
return "mdi:map-marker" return "mdi:map-marker"
@@ -118,10 +118,9 @@ class GeorideTrackerEntity(TrackerEntity):
"""No polling needed.""" """No polling needed."""
return True return True
async def async_update(self): def update(self):
""" update the current tracker""" """ update the current tracker"""
_LOGGER.info('async_update ') _LOGGER.info('update')
self._data = self._get_tracker_callback(self._tracker_id) self._data = self._get_tracker_callback(self._tracker_id)
self._name = self._data.tracker_name self._name = self._data.tracker_name
return

View File

@@ -1,11 +1,12 @@
{ {
"domain": "georide", "domain": "georide",
"name": "Georide", "name": "GeoRide",
"config_flow": true, "config_flow": true,
"documentation": "https://git.tontontux.fr/mduval/GeorideHA", "documentation": "https://github.com/ptimatth/GeorideHA",
"requirements": [ "requirements": [
"georideapilib>=0.2.0" "georideapilib>=0.4.4",
"pyjwt>=1.7.1"
], ],
"dependencies": [], "dependencies": [],
"codeowners": ["@ptimatth"] "codeowners": ["ptimatth"]
} }

View File

@@ -0,0 +1,102 @@
""" odometter sensor 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"]
if georide_context.get_token() is None:
return False
trackers = GeoRideApi.get_trackers(georide_context.get_token())
odometer_switch_entities = []
for tracker in trackers:
entity = GeoRideOdometerSensorEntity(tracker.tracker_id, georide_context.get_token,
georide_context.get_tracker, data=tracker)
hass.data[GEORIDE_DOMAIN]["devices"][tracker.tracker_id] = entity
odometer_switch_entities.append(entity)
async_add_entities(odometer_switch_entities)
return True
class GeoRideOdometerSensorEntity(SwitchEntity):
"""Represent a tracked device."""
def __init__(self, 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._unit_of_measurement = "m"
self.entity_id = ENTITY_ID_FORMAT.format("odometer") + "." + str(tracker_id)
self._state = 0
def update(self):
""" update the current tracker"""
_LOGGER.info('update')
self._data = self._get_tracker_callback(self._tracker_id)
self._name = self._data.tracker_name
self._state = self._data.odometer
@property
def unique_id(self):
"""Return the unique ID."""
return self._tracker_id
@property
def name(self):
""" GeoRide odometer name """
return self._name
@property
def state(self):
return self._state
@property
def unit_of_measurement(self):
return self._unit_of_measurement
@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 "mdi:counter"
@property
def device_info(self):
"""Return the device info."""
return {
"name": self.name,
"identifiers": {(GEORIDE_DOMAIN, self._tracker_id)},
"manufacturer": "GeoRide"
}

View File

@@ -2,19 +2,21 @@
"config": { "config": {
"title": "GeoRide", "title": "GeoRide",
"step": { "step": {
"user": { "georide_login": {
"title": "Set up GeoRide", "title": "Set up GeoRide",
"description": "Are you sure you want to set up GeoRide ?", "description": "Sign-in to GeoRide",
"data": { "data": {
"email": "email", "email": "email",
"password": "password" "password": "password"
} }
} }
}, },
"error": {
"faulty_credentials": "Authorization failed",
"unknown": "Unknown error"
},
"abort": { "abort": {
"one_instance_allowed": "Only a single instance is allowed.", "one_instance_allowed": "Only a single instance is allowed."
"no_credential": "You need to add your credentails."
}, },
"create_entry": { "create_entry": {
"default": "\n\nLogin succes" "default": "\n\nLogin succes"

View File

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

View File

@@ -0,0 +1,25 @@
{
"config": {
"title": "GeoRide",
"step": {
"georide_login": {
"title": "Set up GeoRide",
"description": "Sign-in to GeoRide",
"data": {
"email": "email",
"password": "password"
}
}
},
"error": {
"faulty_credentials": "Authorization failed",
"unknown": "Unknown error"
},
"abort": {
"one_instance_allowed": "Only one instance is allowed."
},
"create_entry": {
"default": "\n\nLogin success"
}
}
}

View File

@@ -0,0 +1,25 @@
{
"config": {
"title": "GeoRide",
"step": {
"georide_login": {
"title": "Configuration de GeoRide",
"description": "T'es un motard ! V",
"data": {
"email": "email",
"password": "password"
}
}
},
"error": {
"faulty_credentials": "Connexion \u00e9chou\u00e9e",
"unkonwn": "Erreur inconnue"
},
"abort": {
"one_instance_allowed": "Seulement une instance est autoris\u00e9e"
},
"create_entry": {
"default": "\n\nConnexion r\u00e9ussie !"
}
}
}

View File

@@ -1,7 +1,8 @@
{ {
"name": "Georide integration", "name": "GeoRide integration",
"content_in_root": false, "content_in_root": false,
"render_readme": true, "render_readme": true,
"domains": ["devices_tracker", "sensor"], "domains": ["devices_tracker", "sensor"],
"country": ["FR"] "country": ["FR"],
"homeassistant": "0.110.0"
} }