Compare commits
4 Commits
0.9.0-snap
...
0.6.1
| Author | SHA1 | Date | |
|---|---|---|---|
| a83bae6d3e | |||
| b84a4cfd7f | |||
| 02e1656aab | |||
| 9b651f933e |
80
README.md
80
README.md
@@ -10,86 +10,6 @@ Official GeoRide website: https://georide.fr/
|
|||||||
## Description
|
## Description
|
||||||
This component add some sensor for GeoRide Tracker
|
This component add some sensor for GeoRide Tracker
|
||||||
|
|
||||||
### What's entity is available :
|
|
||||||
|
|
||||||
Get GeoRide position
|
|
||||||
Get GeoRide lock status
|
|
||||||
Change GeoRide lock status
|
|
||||||
Get stollen status
|
|
||||||
Get crashed status
|
|
||||||
Get is owner status
|
|
||||||
Get subsription status
|
|
||||||
Get odomoter to km an m (2 entities)
|
|
||||||
Internal battery (of georide 3) (not work on GR1)
|
|
||||||
External battery (of the bike) (not work on GR1)
|
|
||||||
Fixtime (last registered positition of the georide)
|
|
||||||
|
|
||||||
|
|
||||||
### What's events are available:
|
|
||||||
you can filter by data.device_id == XX (XX is your tracker id)
|
|
||||||
you can display your tracker name by by data.device_name
|
|
||||||
|
|
||||||
event;
|
|
||||||
|
|
||||||
georide_position_event
|
|
||||||
georide_lock_event
|
|
||||||
georide_device_event
|
|
||||||
georide_alarm_event
|
|
||||||
|
|
||||||
you can filter with data.type == 'alarm_vibration' to filter by vibration
|
|
||||||
here is the alarm type available: (listen the georide_alarm_event)
|
|
||||||
|
|
||||||
alarm_vibration
|
|
||||||
alarm_exitZone
|
|
||||||
alarm_crash
|
|
||||||
alarm_crashParking
|
|
||||||
alarm_deviceOffline
|
|
||||||
alarm_deviceOnline
|
|
||||||
alarm_powerCut
|
|
||||||
alarm_powerUncut
|
|
||||||
alarm_batteryWarning
|
|
||||||
alarm_temperatureWarning
|
|
||||||
alarm_magnetOn
|
|
||||||
alarm_magnetOff
|
|
||||||
alarm_sonorAlarmOn
|
|
||||||
|
|
||||||
|
|
||||||
## Question:
|
|
||||||
|
|
||||||
### How to have the odometer in Km ? (Deprecated, now you have an entity - thx @Inervo)
|
|
||||||
|
|
||||||
Simply add a sensor like this in configuration.yaml
|
|
||||||
(Replace XX by your tracker id)
|
|
||||||
|
|
||||||
```yaml
|
|
||||||
sensor:
|
|
||||||
- platform: template # Conversion georide de m en km
|
|
||||||
sensors:
|
|
||||||
odometer_XX_km:
|
|
||||||
friendly_name: "Odometter - Km"
|
|
||||||
value_template: "{{ states.sensor.odometer_XX.state | multiply(0.001) | round(3, 'flour') }}"
|
|
||||||
unit_of_measurement: 'Km'
|
|
||||||
```
|
|
||||||
|
|
||||||
### How to use the event:
|
|
||||||
|
|
||||||
Simply made a automation like this:
|
|
||||||
|
|
||||||
```yaml
|
|
||||||
alias: '[TEST] Send notification'
|
|
||||||
description: ''
|
|
||||||
trigger:
|
|
||||||
- platform: event
|
|
||||||
event_type: georide_lock_event
|
|
||||||
condition: []
|
|
||||||
action:
|
|
||||||
- service: notify.mobile_app_oneplus_a3003
|
|
||||||
data:
|
|
||||||
message: 'The device {{ data.device_name }} have recieved a lock event'
|
|
||||||
mode: single
|
|
||||||
|
|
||||||
```
|
|
||||||
|
|
||||||
|
|
||||||
## Options
|
## Options
|
||||||
|
|
||||||
|
|||||||
@@ -32,7 +32,7 @@ from homeassistant.helpers.update_coordinator import (
|
|||||||
)
|
)
|
||||||
|
|
||||||
|
|
||||||
from .device import Device, DeviceBeacon
|
from .device import Device
|
||||||
from .const import (
|
from .const import (
|
||||||
CONF_EMAIL,
|
CONF_EMAIL,
|
||||||
CONF_PASSWORD,
|
CONF_PASSWORD,
|
||||||
@@ -40,8 +40,7 @@ from .const import (
|
|||||||
TRACKER_ID,
|
TRACKER_ID,
|
||||||
TOKEN_SAFE_DAY,
|
TOKEN_SAFE_DAY,
|
||||||
MIN_UNTIL_REFRESH,
|
MIN_UNTIL_REFRESH,
|
||||||
DOMAIN,
|
DOMAIN
|
||||||
SIREN_ACTIVATION_DELAY
|
|
||||||
)
|
)
|
||||||
|
|
||||||
|
|
||||||
@@ -106,8 +105,6 @@ async def async_setup_entry(hass, entry):
|
|||||||
hass.config_entries.async_forward_entry_setup(entry, "sensor"))
|
hass.config_entries.async_forward_entry_setup(entry, "sensor"))
|
||||||
hass.async_create_task(
|
hass.async_create_task(
|
||||||
hass.config_entries.async_forward_entry_setup(entry, "binary_sensor"))
|
hass.config_entries.async_forward_entry_setup(entry, "binary_sensor"))
|
||||||
hass.async_create_task(
|
|
||||||
hass.config_entries.async_forward_entry_setup(entry, "siren"))
|
|
||||||
return True
|
return True
|
||||||
|
|
||||||
|
|
||||||
@@ -118,7 +115,6 @@ async def async_unload_entry(hass, entry):
|
|||||||
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")
|
await hass.config_entries.async_forward_entry_unload(entry, "sensor")
|
||||||
await hass.config_entries.async_forward_entry_unload(entry, "binary_sensor")
|
await hass.config_entries.async_forward_entry_unload(entry, "binary_sensor")
|
||||||
await hass.config_entries.async_forward_entry_unload(entry, "siren")
|
|
||||||
|
|
||||||
|
|
||||||
context = hass.data[DOMAIN]["context"]
|
context = hass.data[DOMAIN]["context"]
|
||||||
@@ -137,8 +133,6 @@ class GeoRideContext:
|
|||||||
self._email = email
|
self._email = email
|
||||||
self._password = password
|
self._password = password
|
||||||
self._georide_trackers_coordoned = []
|
self._georide_trackers_coordoned = []
|
||||||
self._georide_trackers_beacon_coordoned = []
|
|
||||||
self._georide_trackers_beacon = []
|
|
||||||
self._georide_trackers = []
|
self._georide_trackers = []
|
||||||
self._token = token
|
self._token = token
|
||||||
self._socket = None
|
self._socket = None
|
||||||
@@ -182,7 +176,7 @@ class GeoRideContext:
|
|||||||
socket.subscribe_device(self.on_device_callback)
|
socket.subscribe_device(self.on_device_callback)
|
||||||
socket.subscribe_position(self.on_position_callback)
|
socket.subscribe_position(self.on_position_callback)
|
||||||
socket.subscribe_alarm(self.on_alarm_callback)
|
socket.subscribe_alarm(self.on_alarm_callback)
|
||||||
socket.subscribe_refresh_tracker(self.on_refresh_tracker_callback)
|
|
||||||
self._socket = socket
|
self._socket = socket
|
||||||
|
|
||||||
socket.init()
|
socket.init()
|
||||||
@@ -190,7 +184,7 @@ class GeoRideContext:
|
|||||||
|
|
||||||
async def get_token(self):
|
async def get_token(self):
|
||||||
""" here we return the current valid tocken """
|
""" here we return the current valid tocken """
|
||||||
jwt_data = jwt.decode(self._token, options={"verify_signature": False})
|
jwt_data = jwt.decode(self._token, verify=False)
|
||||||
exp_timestamp = jwt_data['exp']
|
exp_timestamp = jwt_data['exp']
|
||||||
|
|
||||||
epoch = math.ceil(time.time())
|
epoch = math.ceil(time.time())
|
||||||
@@ -214,36 +208,17 @@ class GeoRideContext:
|
|||||||
return tracker
|
return tracker
|
||||||
return {}
|
return {}
|
||||||
|
|
||||||
async def get_tracker_beacon(self, beacon_id):
|
|
||||||
""" here we return last tracker_beacon by id"""
|
|
||||||
for tracker_beacon in self._georide_trackers_beacon:
|
|
||||||
if tracker_beacon.beacon_id == beacon_id:
|
|
||||||
return tracker_beacon
|
|
||||||
return {}
|
|
||||||
|
|
||||||
async def get_tracker_beacons_by_tracker_id(self, tracker_id):
|
|
||||||
""" here we return last tracker_beacon by id"""
|
|
||||||
filtered_beacon = []
|
|
||||||
for tracker_beacon in self._georide_trackers_beacon:
|
|
||||||
if tracker_beacon.linked_tracker_id == tracker_id:
|
|
||||||
filtered_beacon.append(tracker_beacon)
|
|
||||||
return filtered_beacon
|
|
||||||
|
|
||||||
async def refresh_trackers(self):
|
async def refresh_trackers(self):
|
||||||
""" here we return last tracker by id"""
|
""" here we return last tracker by id"""
|
||||||
_LOGGER.debug("Call refresh tracker")
|
_LOGGER.debug("Call refresh tracker")
|
||||||
epoch_min = math.floor(time.time()/60)
|
epoch_min = math.floor(time.time()/60)
|
||||||
|
#if (epoch_min % MIN_UNTIL_REFRESH) == 0:
|
||||||
if epoch_min != self._previous_refresh:
|
if epoch_min != self._previous_refresh:
|
||||||
self._previous_refresh = epoch_min
|
self._previous_refresh = epoch_min
|
||||||
await self.force_refresh_trackers()
|
await self.force_refresh_trackers()
|
||||||
for tracker in self._georide_trackers:
|
#else:
|
||||||
if tracker.is_siren_on:
|
# _LOGGER.debug("We wil dont refresh the tracker list")
|
||||||
if time.time() - SIREN_ACTIVATION_DELAY > tracker.siren_last_on_date:
|
|
||||||
tracker.is_siren_on = False
|
|
||||||
|
|
||||||
async def refresh_trackers_beacon(self):
|
|
||||||
""" here we return last tracker by id"""
|
|
||||||
_LOGGER.debug("Do nothing, updated by another way")
|
|
||||||
|
|
||||||
async def force_refresh_trackers(self):
|
async def force_refresh_trackers(self):
|
||||||
"""Used to refresh the tracker list"""
|
"""Used to refresh the tracker list"""
|
||||||
@@ -255,32 +230,9 @@ class GeoRideContext:
|
|||||||
for tracker in self._georide_trackers:
|
for tracker in self._georide_trackers:
|
||||||
if tracker.tracker_id == refreshed_tracker.tracker_id:
|
if tracker.tracker_id == refreshed_tracker.tracker_id:
|
||||||
tracker.update_all_data(refreshed_tracker)
|
tracker.update_all_data(refreshed_tracker)
|
||||||
if tracker.version > 2:
|
|
||||||
await self.force_refresh_trackers_beacon(tracker.tracker_id)
|
|
||||||
found = True
|
found = True
|
||||||
if not found:
|
if not found:
|
||||||
self._georide_trackers.append(refreshed_tracker)
|
self._georide_trackers.append(refreshed_tracker)
|
||||||
if refreshed_tracker.version > 2:
|
|
||||||
await self.force_refresh_trackers_beacon(refreshed_tracker.tracker_id)
|
|
||||||
if not self._thread_started:
|
|
||||||
_LOGGER.info("Start the thread")
|
|
||||||
# We refresh the tracker list each hours
|
|
||||||
self._thread_started = True
|
|
||||||
await self.connect_socket()
|
|
||||||
|
|
||||||
async def force_refresh_trackers_beacon(self, tracker_id):
|
|
||||||
"""Used to refresh the tracker list"""
|
|
||||||
_LOGGER.info("Tracker beacon refresh")
|
|
||||||
new_georide_tracker_beacons = await self._hass.async_add_executor_job(GeoRideApi.get_tracker_beacons,
|
|
||||||
await self.get_token(), tracker_id)
|
|
||||||
for new_georide_tracker_beacon in new_georide_tracker_beacons:
|
|
||||||
found = False
|
|
||||||
for tracker_beacon in self._georide_trackers_beacon:
|
|
||||||
if tracker_beacon.beacon_id == new_georide_tracker_beacon.beacon_id:
|
|
||||||
tracker_beacon.update_all_data(new_georide_tracker_beacon)
|
|
||||||
found = True
|
|
||||||
if not found:
|
|
||||||
self._georide_trackers_beacon.append(new_georide_tracker_beacon)
|
|
||||||
if not self._thread_started:
|
if not self._thread_started:
|
||||||
_LOGGER.info("Start the thread")
|
_LOGGER.info("Start the thread")
|
||||||
# We refresh the tracker list each hours
|
# We refresh the tracker list each hours
|
||||||
@@ -303,41 +255,17 @@ class GeoRideContext:
|
|||||||
update_method=self.refresh_trackers,
|
update_method=self.refresh_trackers,
|
||||||
update_interval=update_interval
|
update_interval=update_interval
|
||||||
)
|
)
|
||||||
|
self._georide_trackers_coordoned.append({
|
||||||
coordoned_tracker = {
|
"tracker_device": Device(tracker),
|
||||||
"tracker_device": Device(tracker),
|
"coordinator": coordinator
|
||||||
"coordinator": coordinator
|
})
|
||||||
}
|
|
||||||
if tracker.version > 2:
|
|
||||||
tracker_beacons = await self.get_tracker_beacons_by_tracker_id(tracker.tracker_id)
|
|
||||||
for tracker_beacon in tracker_beacons:
|
|
||||||
beacon_coordinator = DataUpdateCoordinator[Mapping[str, Any]](
|
|
||||||
hass,
|
|
||||||
_LOGGER,
|
|
||||||
name=tracker_beacon.name,
|
|
||||||
update_method=self.refresh_trackers_beacon,
|
|
||||||
update_interval=update_interval
|
|
||||||
)
|
|
||||||
coordoned_beacon = {
|
|
||||||
"tracker_beacon": DeviceBeacon(tracker_beacon),
|
|
||||||
"coordinator": beacon_coordinator
|
|
||||||
}
|
|
||||||
self._georide_trackers_beacon_coordoned.append(coordoned_beacon)
|
|
||||||
self._georide_trackers_coordoned.append(coordoned_tracker)
|
|
||||||
|
|
||||||
|
|
||||||
@property
|
def get_coordoned_trackers(self):
|
||||||
def georide_trackers_coordoned(self):
|
|
||||||
"""Return coordoned trackers"""
|
"""Return coordoned trackers"""
|
||||||
|
|
||||||
return self._georide_trackers_coordoned
|
return self._georide_trackers_coordoned
|
||||||
|
|
||||||
@property
|
|
||||||
def georide_trackers_beacon_coordoned(self):
|
|
||||||
"""Return coordoned trackers"""
|
|
||||||
|
|
||||||
return self._georide_trackers_beacon_coordoned
|
|
||||||
|
|
||||||
@property
|
@property
|
||||||
def socket(self):
|
def socket(self):
|
||||||
""" hold the GeoRide socket """
|
""" hold the GeoRide socket """
|
||||||
@@ -353,8 +281,7 @@ class GeoRideContext:
|
|||||||
"""on lock callback"""
|
"""on lock callback"""
|
||||||
_LOGGER.info("On lock received")
|
_LOGGER.info("On lock received")
|
||||||
for coordoned_tracker in self._georide_trackers_coordoned:
|
for coordoned_tracker in self._georide_trackers_coordoned:
|
||||||
tracker_device = coordoned_tracker['tracker_device']
|
tracker = coordoned_tracker['tracker_device'].tracker
|
||||||
tracker = tracker_device.tracker
|
|
||||||
coordinator = coordoned_tracker['coordinator']
|
coordinator = coordoned_tracker['coordinator']
|
||||||
if tracker.tracker_id == data['trackerId']:
|
if tracker.tracker_id == data['trackerId']:
|
||||||
tracker.locked_latitude = data['lockedLatitude']
|
tracker.locked_latitude = data['lockedLatitude']
|
||||||
@@ -362,101 +289,68 @@ class GeoRideContext:
|
|||||||
tracker.is_locked = data['isLocked']
|
tracker.is_locked = data['isLocked']
|
||||||
|
|
||||||
event_data = {
|
event_data = {
|
||||||
"device_id": tracker_device.unique_id,
|
"device_id": tracker.tracker_id,
|
||||||
"device_name": tracker_device.name,
|
"type": "on_lock",
|
||||||
}
|
}
|
||||||
self._hass.bus.async_fire(f"{DOMAIN}_lock_event", event_data)
|
self._hass.bus.async_fire(f"{DOMAIN}_event", event_data)
|
||||||
|
|
||||||
asyncio.run_coroutine_threadsafe(
|
asyncio.run_coroutine_threadsafe(
|
||||||
coordinator.async_request_refresh(), self._hass.loop
|
coordinator.async_request_refresh(), self._hass.loop
|
||||||
).result()
|
).result()
|
||||||
break
|
break
|
||||||
|
|
||||||
|
|
||||||
@callback
|
@callback
|
||||||
def on_device_callback(self, data):
|
def on_device_callback(self, data):
|
||||||
"""on device callback"""
|
"""on device callback"""
|
||||||
_LOGGER.info("On device received")
|
_LOGGER.info("On device received")
|
||||||
for coordoned_tracker in self._georide_trackers_coordoned:
|
for coordoned_tracker in self._georide_trackers_coordoned:
|
||||||
tracker_device = coordoned_tracker['tracker_device']
|
tracker = coordoned_tracker['tracker_device'].tracker
|
||||||
tracker = tracker_device.tracker
|
|
||||||
coordinator = coordoned_tracker['coordinator']
|
coordinator = coordoned_tracker['coordinator']
|
||||||
if tracker.tracker_id == data['trackerId']:
|
if tracker.tracker_id == data['trackerId']:
|
||||||
tracker.status = data['status']
|
tracker.status = data['status']
|
||||||
|
|
||||||
event_data = {
|
event_data = {
|
||||||
"device_id": tracker_device.unique_id,
|
"device_id": tracker.tracker_id,
|
||||||
"device_name": tracker_device.name,
|
"type": "on_device",
|
||||||
}
|
}
|
||||||
self._hass.bus.async_fire(f"{DOMAIN}_device_event", event_data)
|
self._hass.bus.async_fire(f"{DOMAIN}_event", event_data)
|
||||||
|
|
||||||
asyncio.run_coroutine_threadsafe(
|
asyncio.run_coroutine_threadsafe(
|
||||||
coordinator.async_request_refresh(), self._hass.loop
|
coordinator.async_request_refresh(), self._hass.loop
|
||||||
).result()
|
).result()
|
||||||
break
|
break
|
||||||
@callback
|
|
||||||
def on_refresh_tracker_callback(self):
|
|
||||||
"""on device callback"""
|
|
||||||
_LOGGER.info("On refresh tracker received")
|
|
||||||
self._previous_refresh = math.floor(time.time()/60)
|
|
||||||
self.force_refresh_trackers()
|
|
||||||
|
|
||||||
for coordoned_tracker in self._georide_trackers_coordoned:
|
|
||||||
tracker_device = coordoned_tracker['tracker_device']
|
|
||||||
tracker = tracker_device.tracker
|
|
||||||
coordinator = coordoned_tracker['coordinator']
|
|
||||||
event_data = {
|
|
||||||
"device_id": tracker_device.unique_id,
|
|
||||||
"device_name": tracker_device.name,
|
|
||||||
}
|
|
||||||
self._hass.bus.async_fire(f"{DOMAIN}_refresh_tracker_event", event_data)
|
|
||||||
asyncio.run_coroutine_threadsafe(
|
|
||||||
coordinator.async_request_refresh(), self._hass.loop
|
|
||||||
).result()
|
|
||||||
|
|
||||||
@callback
|
@callback
|
||||||
def on_alarm_callback(self, data):
|
def on_alarm_callback(self, data):
|
||||||
"""on device callback"""
|
"""on device callback"""
|
||||||
_LOGGER.info("On alarm received")
|
_LOGGER.info("On alarm received")
|
||||||
for coordoned_tracker in self._georide_trackers_coordoned:
|
for coordoned_tracker in self._georide_trackers_coordoned:
|
||||||
tracker_device = coordoned_tracker['tracker_device']
|
tracker = coordoned_tracker['tracker_device'].tracker
|
||||||
tracker = tracker_device.tracker
|
|
||||||
|
|
||||||
coordinator = coordoned_tracker['coordinator']
|
coordinator = coordoned_tracker['coordinator']
|
||||||
if tracker.tracker_id == data['trackerId']:
|
if tracker.tracker_id == data['trackerId']:
|
||||||
if data['name'] == 'vibration':
|
if data.name == 'vibration':
|
||||||
_LOGGER.info("Vibration detected")
|
_LOGGER.info("Vibration detected")
|
||||||
elif data['name'] == 'exitZone':
|
elif data.name == 'exitZone':
|
||||||
_LOGGER.info("Exit zone detected")
|
_LOGGER.info("Exit zone detected")
|
||||||
elif data['name'] == 'crash':
|
elif data.name == 'crash':
|
||||||
_LOGGER.info("Crash detected")
|
_LOGGER.info("Crash detected")
|
||||||
elif data['name'] == 'crashParking':
|
elif data.name == 'crashParking':
|
||||||
_LOGGER.info("Crash parking detected")
|
_LOGGER.info("Crash parking detected")
|
||||||
elif data['name'] == 'deviceOffline':
|
elif data.name == 'deviceOffline':
|
||||||
_LOGGER.info("Device offline detected")
|
_LOGGER.info("Device offline detected")
|
||||||
elif data['name'] == 'deviceOnline':
|
elif data.name == 'deviceOnline':
|
||||||
_LOGGER.info("Device online detected")
|
_LOGGER.info("Device online detected")
|
||||||
elif data['name'] == 'powerCut':
|
elif data.name == 'powerCut':
|
||||||
_LOGGER.info("powerCut detected")
|
_LOGGER.info("powerCut detected")
|
||||||
elif data['name'] == 'powerUncut':
|
|
||||||
_LOGGER.info("powerUncut detected")
|
|
||||||
elif data['name'] == 'batteryWarning':
|
|
||||||
_LOGGER.info("batteryWarning detected")
|
|
||||||
elif data['name'] == 'temperatureWarning':
|
|
||||||
_LOGGER.info("temperatureWarning detected")
|
|
||||||
elif data['name'] == 'magnetOn':
|
|
||||||
_LOGGER.info("magnetOn detected")
|
|
||||||
elif data['name'] == 'magnetOff':
|
|
||||||
_LOGGER.info("magnetOff detected")
|
|
||||||
elif data['name'] == 'sonorAlarmOn':
|
|
||||||
_LOGGER.info("sonorAlarmOn detected")
|
|
||||||
tracker.is_siren_on = True
|
|
||||||
else:
|
else:
|
||||||
_LOGGER.warning("Unmanaged alarm: %s", data["name"])
|
_LOGGER.warning("Unamanged alarm: %s", data.name)
|
||||||
|
|
||||||
event_data = {
|
event_data = {
|
||||||
"device_id": tracker_device.unique_id,
|
"device_id": tracker.tracker_id,
|
||||||
"device_name": tracker_device.name,
|
"type": f"alarm_{data.name}",
|
||||||
"type": f"alarm_{data['name']}"
|
|
||||||
}
|
}
|
||||||
self._hass.bus.async_fire(f"{DOMAIN}_alarm_event", event_data)
|
self._hass.bus.async_fire(f"{DOMAIN}_event", event_data)
|
||||||
asyncio.run_coroutine_threadsafe(
|
asyncio.run_coroutine_threadsafe(
|
||||||
coordinator.async_request_refresh(), self._hass.loop
|
coordinator.async_request_refresh(), self._hass.loop
|
||||||
).result()
|
).result()
|
||||||
@@ -477,10 +371,10 @@ class GeoRideContext:
|
|||||||
tracker.fixtime = data['fixtime']
|
tracker.fixtime = data['fixtime']
|
||||||
|
|
||||||
event_data = {
|
event_data = {
|
||||||
"device_id": tracker_device.unique_id,
|
"device_id": tracker.tracker_id,
|
||||||
"device_name": tracker_device.name,
|
"type": "position",
|
||||||
}
|
}
|
||||||
self._hass.bus.async_fire(f"{DOMAIN}_position_event", event_data)
|
self._hass.bus.async_fire(f"{DOMAIN}_event", event_data)
|
||||||
asyncio.run_coroutine_threadsafe(
|
asyncio.run_coroutine_threadsafe(
|
||||||
coordinator.async_request_refresh(), self._hass.loop
|
coordinator.async_request_refresh(), self._hass.loop
|
||||||
).result()
|
).result()
|
||||||
|
|||||||
@@ -5,7 +5,6 @@ import logging
|
|||||||
from typing import Any, Mapping
|
from typing import Any, Mapping
|
||||||
|
|
||||||
from homeassistant.core import callback
|
from homeassistant.core import callback
|
||||||
from homeassistant.helpers.entity import DeviceInfo, EntityCategory
|
|
||||||
from homeassistant.components.binary_sensor import BinarySensorEntity
|
from homeassistant.components.binary_sensor import BinarySensorEntity
|
||||||
from homeassistant.components.binary_sensor import ENTITY_ID_FORMAT
|
from homeassistant.components.binary_sensor import ENTITY_ID_FORMAT
|
||||||
from homeassistant.helpers.update_coordinator import (
|
from homeassistant.helpers.update_coordinator import (
|
||||||
@@ -15,14 +14,14 @@ from homeassistant.helpers.update_coordinator import (
|
|||||||
|
|
||||||
|
|
||||||
from .const import DOMAIN as GEORIDE_DOMAIN
|
from .const import DOMAIN as GEORIDE_DOMAIN
|
||||||
from .device import Device, DeviceBeacon
|
from .device import Device
|
||||||
|
|
||||||
_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"]
|
||||||
entities = []
|
entities = []
|
||||||
coordoned_trackers = georide_context.georide_trackers_coordoned
|
coordoned_trackers = georide_context.get_coordoned_trackers()
|
||||||
for coordoned_tracker in coordoned_trackers:
|
for coordoned_tracker in coordoned_trackers:
|
||||||
tracker_device = coordoned_tracker['tracker_device']
|
tracker_device = coordoned_tracker['tracker_device']
|
||||||
coordinator = coordoned_tracker['coordinator']
|
coordinator = coordoned_tracker['coordinator']
|
||||||
@@ -31,19 +30,9 @@ async def async_setup_entry(hass, config_entry, async_add_entities): # pylint: d
|
|||||||
entities.append(GeoRideCrashedBinarySensorEntity(coordinator, tracker_device))
|
entities.append(GeoRideCrashedBinarySensorEntity(coordinator, tracker_device))
|
||||||
entities.append(GeoRideOwnerBinarySensorEntity(coordinator, tracker_device))
|
entities.append(GeoRideOwnerBinarySensorEntity(coordinator, tracker_device))
|
||||||
entities.append(GeoRideActiveSubscriptionBinarySensorEntity(coordinator, tracker_device))
|
entities.append(GeoRideActiveSubscriptionBinarySensorEntity(coordinator, tracker_device))
|
||||||
entities.append(GeoRideNetworkBinarySensorEntity(coordinator, tracker_device))
|
|
||||||
entities.append(GeoRideMovingBinarySensorEntity(coordinator, tracker_device))
|
|
||||||
|
|
||||||
hass.data[GEORIDE_DOMAIN]["devices"][tracker_device.tracker.tracker_id] = coordinator
|
hass.data[GEORIDE_DOMAIN]["devices"][tracker_device.tracker.tracker_id] = coordinator
|
||||||
|
|
||||||
coordoned_beacons = georide_context.georide_trackers_beacon_coordoned
|
|
||||||
for coordoned_beacon in coordoned_beacons:
|
|
||||||
tracker_beacon = coordoned_beacon['tracker_beacon']
|
|
||||||
coordinator = coordoned_beacon['coordinator']
|
|
||||||
entities.append(GeoRideBeaconUpdatedBinarySensorEntity(coordinator, tracker_beacon))
|
|
||||||
hass.data[GEORIDE_DOMAIN]["devices"][tracker_beacon.beacon.beacon_id] = coordinator
|
|
||||||
|
|
||||||
|
|
||||||
async_add_entities(entities, True)
|
async_add_entities(entities, True)
|
||||||
|
|
||||||
return True
|
return True
|
||||||
@@ -66,26 +55,6 @@ class GeoRideBinarySensorEntity(CoordinatorEntity, BinarySensorEntity):
|
|||||||
"""Return the device info."""
|
"""Return the device info."""
|
||||||
return self._tracker_device.device_info
|
return self._tracker_device.device_info
|
||||||
|
|
||||||
class GeoRideBeaconBinarySensorEntity(CoordinatorEntity, BinarySensorEntity):
|
|
||||||
"""Represent a tracked device."""
|
|
||||||
def __init__(self, coordinator: DataUpdateCoordinator[Mapping[str, Any]],
|
|
||||||
tracker_device_beacon: DeviceBeacon):
|
|
||||||
"""Set up Georide entity."""
|
|
||||||
super().__init__(coordinator)
|
|
||||||
self._tracker_device_beacon = tracker_device_beacon
|
|
||||||
self._name = tracker_device_beacon.beacon.name
|
|
||||||
self.entity_id = f"{ENTITY_ID_FORMAT.format('binary_sensor')}.{tracker_device_beacon.beacon.beacon_id}"# pylint: disable=C0301
|
|
||||||
self._is_on = False
|
|
||||||
|
|
||||||
@property
|
|
||||||
def entity_category(self):
|
|
||||||
return None
|
|
||||||
|
|
||||||
@property
|
|
||||||
def device_info(self):
|
|
||||||
"""Return the device info."""
|
|
||||||
return self._tracker_device_beacon.device_info
|
|
||||||
|
|
||||||
class GeoRideStolenBinarySensorEntity(GeoRideBinarySensorEntity):
|
class GeoRideStolenBinarySensorEntity(GeoRideBinarySensorEntity):
|
||||||
"""Represent a tracked device."""
|
"""Represent a tracked device."""
|
||||||
def __init__(self, coordinator: DataUpdateCoordinator[Mapping[str, Any]],
|
def __init__(self, coordinator: DataUpdateCoordinator[Mapping[str, Any]],
|
||||||
@@ -99,11 +68,6 @@ class GeoRideStolenBinarySensorEntity(GeoRideBinarySensorEntity):
|
|||||||
"""Return the unique ID."""
|
"""Return the unique ID."""
|
||||||
return f"is_stolen_{self._tracker_device.tracker.tracker_id}"
|
return f"is_stolen_{self._tracker_device.tracker.tracker_id}"
|
||||||
|
|
||||||
@property
|
|
||||||
def device_class(self):
|
|
||||||
"""Return the device class."""
|
|
||||||
return "problem"
|
|
||||||
|
|
||||||
@property
|
@property
|
||||||
def is_on(self):
|
def is_on(self):
|
||||||
"""state value property"""
|
"""state value property"""
|
||||||
@@ -112,7 +76,7 @@ class GeoRideStolenBinarySensorEntity(GeoRideBinarySensorEntity):
|
|||||||
@property
|
@property
|
||||||
def name(self):
|
def name(self):
|
||||||
""" GeoRide odometer name """
|
""" GeoRide odometer name """
|
||||||
return f"{self._name} is not stolen"
|
return f"{self._name} is stolen"
|
||||||
|
|
||||||
|
|
||||||
class GeoRideCrashedBinarySensorEntity(GeoRideBinarySensorEntity):
|
class GeoRideCrashedBinarySensorEntity(GeoRideBinarySensorEntity):
|
||||||
@@ -129,11 +93,6 @@ class GeoRideCrashedBinarySensorEntity(GeoRideBinarySensorEntity):
|
|||||||
"""Return the unique ID."""
|
"""Return the unique ID."""
|
||||||
return f"is_crashed_{self._tracker_device.tracker.tracker_id}"
|
return f"is_crashed_{self._tracker_device.tracker.tracker_id}"
|
||||||
|
|
||||||
@property
|
|
||||||
def device_class(self):
|
|
||||||
"""Return the device class."""
|
|
||||||
return "problem"
|
|
||||||
|
|
||||||
@property
|
@property
|
||||||
def is_on(self):
|
def is_on(self):
|
||||||
"""state value property"""
|
"""state value property"""
|
||||||
@@ -142,7 +101,7 @@ class GeoRideCrashedBinarySensorEntity(GeoRideBinarySensorEntity):
|
|||||||
@property
|
@property
|
||||||
def name(self):
|
def name(self):
|
||||||
""" GeoRide odometer name """
|
""" GeoRide odometer name """
|
||||||
return f"{self._name} is not crashed"
|
return f"{self._name} is crashed"
|
||||||
|
|
||||||
class GeoRideActiveSubscriptionBinarySensorEntity(GeoRideBinarySensorEntity):
|
class GeoRideActiveSubscriptionBinarySensorEntity(GeoRideBinarySensorEntity):
|
||||||
"""Represent a tracked device."""
|
"""Represent a tracked device."""
|
||||||
@@ -153,10 +112,6 @@ class GeoRideActiveSubscriptionBinarySensorEntity(GeoRideBinarySensorEntity):
|
|||||||
super().__init__(coordinator, tracker_device)
|
super().__init__(coordinator, tracker_device)
|
||||||
self.entity_id = f"{ENTITY_ID_FORMAT.format('is_active_subscription_')}.{tracker_device.tracker.tracker_id}"# pylint: disable=C0301
|
self.entity_id = f"{ENTITY_ID_FORMAT.format('is_active_subscription_')}.{tracker_device.tracker.tracker_id}"# pylint: disable=C0301
|
||||||
|
|
||||||
@property
|
|
||||||
def entity_category(self):
|
|
||||||
return EntityCategory.DIAGNOSTIC
|
|
||||||
|
|
||||||
@property
|
@property
|
||||||
def unique_id(self):
|
def unique_id(self):
|
||||||
"""Return the unique ID."""
|
"""Return the unique ID."""
|
||||||
@@ -165,15 +120,9 @@ class GeoRideActiveSubscriptionBinarySensorEntity(GeoRideBinarySensorEntity):
|
|||||||
@property
|
@property
|
||||||
def is_on(self):
|
def is_on(self):
|
||||||
"""state value property"""
|
"""state value property"""
|
||||||
tracker = self._tracker_device.tracker
|
if self._tracker_device.tracker.subscription_id is not None:
|
||||||
if tracker.is_oldsubscription:
|
return True
|
||||||
if tracker.subscription_id is not None:
|
return False
|
||||||
return True
|
|
||||||
return False
|
|
||||||
else:
|
|
||||||
if tracker.subscription is not None and tracker.subscription.subscription_id is not None:
|
|
||||||
return True
|
|
||||||
return False
|
|
||||||
|
|
||||||
@property
|
@property
|
||||||
def name(self):
|
def name(self):
|
||||||
@@ -206,102 +155,3 @@ class GeoRideOwnerBinarySensorEntity(GeoRideBinarySensorEntity):
|
|||||||
""" GeoRide odometer name """
|
""" GeoRide odometer name """
|
||||||
return f"{self._name} is own tracker"
|
return f"{self._name} is own tracker"
|
||||||
|
|
||||||
class GeoRideNetworkBinarySensorEntity(GeoRideBinarySensorEntity):
|
|
||||||
"""Represent a tracked device."""
|
|
||||||
|
|
||||||
def __init__(self, coordinator: DataUpdateCoordinator[Mapping[str, Any]],
|
|
||||||
tracker_device: Device):
|
|
||||||
"""Set up Georide entity."""
|
|
||||||
super().__init__(coordinator, tracker_device)
|
|
||||||
self.entity_id = f"{ENTITY_ID_FORMAT.format('have_network')}.{tracker_device.tracker.tracker_id}"# pylint: disable=C0301
|
|
||||||
|
|
||||||
@property
|
|
||||||
def entity_category(self):
|
|
||||||
return EntityCategory.DIAGNOSTIC
|
|
||||||
|
|
||||||
@property
|
|
||||||
def unique_id(self):
|
|
||||||
"""Return the unique ID."""
|
|
||||||
return f"have_network_{self._tracker_device.tracker.tracker_id}"
|
|
||||||
|
|
||||||
@property
|
|
||||||
def device_class(self):
|
|
||||||
"""Return the device class."""
|
|
||||||
return "connectivity"
|
|
||||||
|
|
||||||
@property
|
|
||||||
def is_on(self):
|
|
||||||
"""state value property"""
|
|
||||||
if self._tracker_device.tracker.status == "online":
|
|
||||||
return True
|
|
||||||
return False
|
|
||||||
|
|
||||||
@property
|
|
||||||
def name(self):
|
|
||||||
""" GeoRide name """
|
|
||||||
return f"{self._name} have network"
|
|
||||||
|
|
||||||
class GeoRideMovingBinarySensorEntity(GeoRideBinarySensorEntity):
|
|
||||||
"""Represent a tracked device."""
|
|
||||||
|
|
||||||
def __init__(self, coordinator: DataUpdateCoordinator[Mapping[str, Any]],
|
|
||||||
tracker_device: Device):
|
|
||||||
"""Set up Georide entity."""
|
|
||||||
super().__init__(coordinator, tracker_device)
|
|
||||||
self.entity_id = f"{ENTITY_ID_FORMAT.format('moving')}.{tracker_device.tracker.tracker_id}"# pylint: disable=C0301
|
|
||||||
|
|
||||||
@property
|
|
||||||
def entity_category(self):
|
|
||||||
return EntityCategory.DIAGNOSTIC
|
|
||||||
|
|
||||||
@property
|
|
||||||
def unique_id(self):
|
|
||||||
"""Return the unique ID."""
|
|
||||||
return f"moving_{self._tracker_device.tracker.tracker_id}"
|
|
||||||
|
|
||||||
@property
|
|
||||||
def device_class(self):
|
|
||||||
"""Return the device class."""
|
|
||||||
return "moving"
|
|
||||||
|
|
||||||
@property
|
|
||||||
def is_on(self):
|
|
||||||
"""state value property"""
|
|
||||||
return self._tracker_device.tracker.moving
|
|
||||||
|
|
||||||
@property
|
|
||||||
def name(self):
|
|
||||||
""" GeoRide name """
|
|
||||||
return f"{self._name} is moving"
|
|
||||||
|
|
||||||
class GeoRideBeaconUpdatedBinarySensorEntity(GeoRideBeaconBinarySensorEntity):
|
|
||||||
"""Represent a tracked device."""
|
|
||||||
@property
|
|
||||||
def entity_category(self):
|
|
||||||
return EntityCategory.DIAGNOSTIC
|
|
||||||
|
|
||||||
def __init__(self, coordinator: DataUpdateCoordinator[Mapping[str, Any]],
|
|
||||||
tracker_beacon_device: DeviceBeacon):
|
|
||||||
"""Set up Georide entity."""
|
|
||||||
super().__init__(coordinator, tracker_beacon_device)
|
|
||||||
self.entity_id = f"{ENTITY_ID_FORMAT.format('update')}.{tracker_beacon_device.beacon.beacon_id}"# pylint: disable=C0301
|
|
||||||
|
|
||||||
@property
|
|
||||||
def unique_id(self):
|
|
||||||
"""Return the unique ID."""
|
|
||||||
return f"update_{self._tracker_device_beacon.beacon.beacon_id}"
|
|
||||||
|
|
||||||
@property
|
|
||||||
def device_class(self):
|
|
||||||
"""Return the device class."""
|
|
||||||
return "update"
|
|
||||||
|
|
||||||
@property
|
|
||||||
def is_on(self):
|
|
||||||
"""state value property"""
|
|
||||||
return not self._tracker_device_beacon.beacon.is_updated
|
|
||||||
|
|
||||||
@property
|
|
||||||
def name(self):
|
|
||||||
""" GeoRide name """
|
|
||||||
return f"{self._name} have an update"
|
|
||||||
@@ -10,6 +10,4 @@ TRACKER_ID = "trackerId"
|
|||||||
|
|
||||||
MIN_UNTIL_REFRESH = 10
|
MIN_UNTIL_REFRESH = 10
|
||||||
|
|
||||||
SIREN_ACTIVATION_DELAY = 30
|
|
||||||
|
|
||||||
TOKEN_SAFE_DAY = 432000 # five days
|
TOKEN_SAFE_DAY = 432000 # five days
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
"""Home Assistant representation of an GeoRide Tracker device."""
|
"""Home Assistant representation of an GeoRide Tracker device."""
|
||||||
from georideapilib.objects import GeoRideTracker, GeoRideTrackerBeacon
|
import georideapilib.objects as GeoRideTracker
|
||||||
from .const import DOMAIN as GEORIDE_DOMAIN
|
from .const import DOMAIN as GEORIDE_DOMAIN
|
||||||
|
|
||||||
|
|
||||||
@@ -28,15 +28,11 @@ class Device:
|
|||||||
@property
|
@property
|
||||||
def model_name(self) -> str:
|
def model_name(self) -> str:
|
||||||
"""Get the model name."""
|
"""Get the model name."""
|
||||||
name = None
|
name = "GeoRide 1"
|
||||||
if self._tracker.version == 1:
|
if self._tracker.is_old_tracker:
|
||||||
name = "GeoRide 1"
|
name = "Prototype / GeoRide 1"
|
||||||
elif self._tracker.version == 2:
|
elif self._tracker.is_second_gen:
|
||||||
name = "GeoRide 2"
|
name = "GeoRide 2 / GeoRide 3"
|
||||||
elif self._tracker.version == 3:
|
|
||||||
name = "GeoRide 3"
|
|
||||||
else:
|
|
||||||
name = "Prototype / Unknown"
|
|
||||||
return name
|
return name
|
||||||
|
|
||||||
@property
|
@property
|
||||||
@@ -44,7 +40,7 @@ class Device:
|
|||||||
"""Return the device info."""
|
"""Return the device info."""
|
||||||
return {
|
return {
|
||||||
"name": self.name,
|
"name": self.name,
|
||||||
"identifiers": self.unique_id,
|
"identifiers": {(GEORIDE_DOMAIN, self._tracker.tracker_id)},
|
||||||
"manufacturer": "GeoRide",
|
"manufacturer": "GeoRide",
|
||||||
"model": self.model_name,
|
"model": self.model_name,
|
||||||
"suggested_area": "Garage"
|
"suggested_area": "Garage"
|
||||||
@@ -58,53 +54,4 @@ class Device:
|
|||||||
|
|
||||||
def __str__(self) -> str:
|
def __str__(self) -> str:
|
||||||
"""Get string representation."""
|
"""Get string representation."""
|
||||||
return f"GeoRide Device: {self.name}::{self.model_name}::{self.unique_id}"
|
return f"GeoRide Device: {self.name}::{self.model_name}::self.unique_id"
|
||||||
|
|
||||||
class DeviceBeacon:
|
|
||||||
"""Home Assistant representation of a GeoRide Tracker device."""
|
|
||||||
|
|
||||||
def __init__(self, beacon):
|
|
||||||
"""Initialize GeoRideTracker device."""
|
|
||||||
self._beacon: GeoRideTrackerBeacon = beacon
|
|
||||||
|
|
||||||
@property
|
|
||||||
def beacon(self):
|
|
||||||
"""return the tracker beacon"""
|
|
||||||
return self._beacon
|
|
||||||
|
|
||||||
@property
|
|
||||||
def name(self) -> str:
|
|
||||||
"""Get the name."""
|
|
||||||
return self._beacon.name
|
|
||||||
|
|
||||||
@property
|
|
||||||
def manufacturer(self) -> str:
|
|
||||||
"""Get the manufacturer."""
|
|
||||||
return "GeoRide"
|
|
||||||
|
|
||||||
@property
|
|
||||||
def model_name(self) -> str:
|
|
||||||
"""Get the model name."""
|
|
||||||
name = "GeoRide Beacon"
|
|
||||||
return name
|
|
||||||
|
|
||||||
@property
|
|
||||||
def device_info(self):
|
|
||||||
"""Return the device info."""
|
|
||||||
return {
|
|
||||||
"name": self.name,
|
|
||||||
"identifiers": self.unique_id,
|
|
||||||
"manufacturer": "GeoRide",
|
|
||||||
"model": self.model_name,
|
|
||||||
"suggested_area": "Garage"
|
|
||||||
}
|
|
||||||
|
|
||||||
@property
|
|
||||||
def unique_id(self) -> str:
|
|
||||||
"""Get the unique id."""
|
|
||||||
|
|
||||||
return {(GEORIDE_DOMAIN, self._beacon.beacon_id)}
|
|
||||||
|
|
||||||
def __str__(self) -> str:
|
|
||||||
"""Get string representation."""
|
|
||||||
return f"GeoRide Device: {self.name}::{self.model_name}::{self.unique_id}"
|
|
||||||
|
|||||||
@@ -20,7 +20,7 @@ _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"]
|
||||||
coordoned_trackers = georide_context.georide_trackers_coordoned
|
coordoned_trackers = georide_context.get_coordoned_trackers()
|
||||||
|
|
||||||
entities = []
|
entities = []
|
||||||
for coordoned_tracker in coordoned_trackers:
|
for coordoned_tracker in coordoned_trackers:
|
||||||
@@ -47,10 +47,6 @@ class GeoRideTrackerEntity(CoordinatorEntity, TrackerEntity):
|
|||||||
self.entity_id = DOMAIN + ".{}".format(tracker_device.tracker.tracker_id)
|
self.entity_id = DOMAIN + ".{}".format(tracker_device.tracker.tracker_id)
|
||||||
self._hass = hass
|
self._hass = hass
|
||||||
|
|
||||||
@property
|
|
||||||
def entity_category(self):
|
|
||||||
return None
|
|
||||||
|
|
||||||
@property
|
@property
|
||||||
def unique_id(self):
|
def unique_id(self):
|
||||||
"""Return the unique ID."""
|
"""Return the unique ID."""
|
||||||
|
|||||||
@@ -3,13 +3,11 @@
|
|||||||
"name": "GeoRide",
|
"name": "GeoRide",
|
||||||
"config_flow": true,
|
"config_flow": true,
|
||||||
"documentation": "https://github.com/ptimatth/GeorideHA",
|
"documentation": "https://github.com/ptimatth/GeorideHA",
|
||||||
"issue_tracker": "https://github.com/ptimatth/GeorideHA/issues",
|
|
||||||
"iot_class": "cloud_polling",
|
|
||||||
"requirements": [
|
"requirements": [
|
||||||
"georideapilib>=0.8.2",
|
"georideapilib>=0.6.0",
|
||||||
"pyjwt==2.1.0"
|
"pyjwt>=1.7.1"
|
||||||
],
|
],
|
||||||
"dependencies": [],
|
"dependencies": [],
|
||||||
"codeowners": ["ptimatth"],
|
"codeowners": ["ptimatth"],
|
||||||
"version": "0.9.0"
|
"version": "0.6.1"
|
||||||
}
|
}
|
||||||
@@ -4,7 +4,6 @@ import logging
|
|||||||
from typing import Any, Mapping
|
from typing import Any, Mapping
|
||||||
|
|
||||||
from homeassistant.core import callback
|
from homeassistant.core import callback
|
||||||
from homeassistant.helpers.entity import DeviceInfo, EntityCategory
|
|
||||||
from homeassistant.components.sensor import SensorEntity
|
from homeassistant.components.sensor import SensorEntity
|
||||||
from homeassistant.components.sensor import ENTITY_ID_FORMAT
|
from homeassistant.components.sensor import ENTITY_ID_FORMAT
|
||||||
from homeassistant.helpers.update_coordinator import (
|
from homeassistant.helpers.update_coordinator import (
|
||||||
@@ -13,7 +12,7 @@ from homeassistant.helpers.update_coordinator import (
|
|||||||
)
|
)
|
||||||
|
|
||||||
from .const import DOMAIN as GEORIDE_DOMAIN
|
from .const import DOMAIN as GEORIDE_DOMAIN
|
||||||
from .device import Device, DeviceBeacon
|
from .device import Device
|
||||||
|
|
||||||
|
|
||||||
_LOGGER = logging.getLogger(__name__)
|
_LOGGER = logging.getLogger(__name__)
|
||||||
@@ -22,27 +21,15 @@ _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"]
|
||||||
coordoned_trackers = georide_context.georide_trackers_coordoned
|
coordoned_trackers = georide_context.get_coordoned_trackers()
|
||||||
|
|
||||||
entities = []
|
entities = []
|
||||||
for coordoned_tracker in coordoned_trackers:
|
for coordoned_tracker in coordoned_trackers:
|
||||||
tracker_device = coordoned_tracker['tracker_device']
|
tracker_device = coordoned_tracker['tracker_device']
|
||||||
coordinator = coordoned_tracker['coordinator']
|
coordinator = coordoned_tracker['coordinator']
|
||||||
|
entity = GeoRideOdometerSensorEntity(coordinator, tracker_device, hass)
|
||||||
hass.data[GEORIDE_DOMAIN]["devices"][tracker_device.tracker.tracker_id] = coordinator
|
hass.data[GEORIDE_DOMAIN]["devices"][tracker_device.tracker.tracker_id] = coordinator
|
||||||
entities.append(GeoRideOdometerSensorEntity(coordinator, tracker_device, hass))
|
entities.append(entity)
|
||||||
entities.append(GeoRideOdometerKmSensorEntity(coordinator, tracker_device, hass))
|
|
||||||
entities.append(GeoRideFixtimeSensorEntity(coordinator, tracker_device))
|
|
||||||
entities.append(GeoRideSpeedSensorEntity(coordinator, tracker_device))
|
|
||||||
if tracker_device.tracker.version > 2:
|
|
||||||
entities.append(GeoRideInternalBatterySensorEntity(coordinator, tracker_device))
|
|
||||||
entities.append(GeoRideExternalBatterySensorEntity(coordinator, tracker_device))
|
|
||||||
|
|
||||||
coordoned_beacons = georide_context.georide_trackers_beacon_coordoned
|
|
||||||
for coordoned_beacon in coordoned_beacons:
|
|
||||||
tracker_beacon = coordoned_beacon['tracker_beacon']
|
|
||||||
coordinator = coordoned_beacon['coordinator']
|
|
||||||
entities.append(GeoRideBeaconBatterySensorEntity(coordinator, tracker_beacon))
|
|
||||||
hass.data[GEORIDE_DOMAIN]["devices"][tracker_beacon.beacon.beacon_id] = coordinator
|
|
||||||
|
|
||||||
async_add_entities(entities)
|
async_add_entities(entities)
|
||||||
|
|
||||||
@@ -63,10 +50,6 @@ class GeoRideOdometerSensorEntity(CoordinatorEntity, SensorEntity):
|
|||||||
self._state = 0
|
self._state = 0
|
||||||
self._hass = hass
|
self._hass = hass
|
||||||
|
|
||||||
@property
|
|
||||||
def entity_category(self):
|
|
||||||
return None
|
|
||||||
|
|
||||||
@property
|
@property
|
||||||
def unique_id(self):
|
def unique_id(self):
|
||||||
"""Return the unique ID."""
|
"""Return the unique ID."""
|
||||||
@@ -75,8 +58,7 @@ class GeoRideOdometerSensorEntity(CoordinatorEntity, SensorEntity):
|
|||||||
@property
|
@property
|
||||||
def state(self):
|
def state(self):
|
||||||
"""state property"""
|
"""state property"""
|
||||||
odometer = self._tracker_device.tracker.odometer
|
return self._tracker_device.tracker.odometer
|
||||||
return odometer
|
|
||||||
|
|
||||||
@property
|
@property
|
||||||
def unit_of_measurement(self):
|
def unit_of_measurement(self):
|
||||||
@@ -94,305 +76,6 @@ class GeoRideOdometerSensorEntity(CoordinatorEntity, SensorEntity):
|
|||||||
return "mdi:counter"
|
return "mdi:counter"
|
||||||
|
|
||||||
@property
|
@property
|
||||||
def device_info(self) -> DeviceInfo:
|
def device_info(self):
|
||||||
"""Return the device info."""
|
|
||||||
return self._tracker_device.device_info
|
|
||||||
|
|
||||||
class GeoRideOdometerKmSensorEntity(CoordinatorEntity, SensorEntity):
|
|
||||||
"""Represent a tracked device."""
|
|
||||||
|
|
||||||
def __init__(self, coordinator: DataUpdateCoordinator[Mapping[str, Any]],
|
|
||||||
tracker_device:Device, hass):
|
|
||||||
"""Set up GeoRide entity."""
|
|
||||||
super().__init__(coordinator)
|
|
||||||
self._tracker_device = tracker_device
|
|
||||||
self._name = tracker_device.tracker.tracker_name
|
|
||||||
self._unit_of_measurement = "km"
|
|
||||||
self.entity_id = f"{ENTITY_ID_FORMAT.format('odometer_km')}.{tracker_device.tracker.tracker_id}"# pylint: disable=C0301
|
|
||||||
self._state = 0
|
|
||||||
self._hass = hass
|
|
||||||
|
|
||||||
@property
|
|
||||||
def unique_id(self):
|
|
||||||
"""Return the unique ID."""
|
|
||||||
return f"odometer_km_{self._tracker_device.tracker.tracker_id}"
|
|
||||||
|
|
||||||
@property
|
|
||||||
def state(self):
|
|
||||||
"""state property"""
|
|
||||||
odometer = self._tracker_device.tracker.odometer // 1000
|
|
||||||
return odometer
|
|
||||||
|
|
||||||
@property
|
|
||||||
def unit_of_measurement(self):
|
|
||||||
"""unit of mesurment property"""
|
|
||||||
return self._unit_of_measurement
|
|
||||||
|
|
||||||
@property
|
|
||||||
def name(self):
|
|
||||||
""" GeoRide odometer name """
|
|
||||||
return f"{self._name} odometer km"
|
|
||||||
|
|
||||||
@property
|
|
||||||
def icon(self):
|
|
||||||
"""icon getter"""
|
|
||||||
return "mdi:counter"
|
|
||||||
|
|
||||||
@property
|
|
||||||
def device_info(self) -> DeviceInfo:
|
|
||||||
"""Return the device info."""
|
|
||||||
return self._tracker_device.device_info
|
|
||||||
|
|
||||||
class GeoRideSpeedSensorEntity(CoordinatorEntity, SensorEntity):
|
|
||||||
"""Represent a tracked device."""
|
|
||||||
|
|
||||||
def __init__(self, coordinator: DataUpdateCoordinator[Mapping[str, Any]],
|
|
||||||
tracker_device:Device, hass):
|
|
||||||
"""Set up GeoRide entity."""
|
|
||||||
super().__init__(coordinator)
|
|
||||||
self._tracker_device = tracker_device
|
|
||||||
self._name = tracker_device.tracker.tracker_name
|
|
||||||
self._unit_of_measurement = "km/h"
|
|
||||||
self.entity_id = f"{ENTITY_ID_FORMAT.format('speed')}.{tracker_device.tracker.tracker_id}"# pylint: disable=C0301
|
|
||||||
self._state = 0
|
|
||||||
self._hass = hass
|
|
||||||
self._state_class = "measurement"
|
|
||||||
|
|
||||||
@property
|
|
||||||
def unique_id(self):
|
|
||||||
"""Return the unique ID."""
|
|
||||||
return f"speed_{self._tracker_device.tracker.tracker_id}"
|
|
||||||
|
|
||||||
@property
|
|
||||||
def state(self):
|
|
||||||
"""state property"""
|
|
||||||
return self._tracker_device.tracker.speed
|
|
||||||
|
|
||||||
@property
|
|
||||||
def state_class(self):
|
|
||||||
return self._state_class
|
|
||||||
|
|
||||||
@property
|
|
||||||
def unit_of_measurement(self):
|
|
||||||
"""unit of mesurment property"""
|
|
||||||
return self._unit_of_measurement
|
|
||||||
|
|
||||||
@property
|
|
||||||
def name(self):
|
|
||||||
""" GeoRide odometer name """
|
|
||||||
return f"{self._name} speed"
|
|
||||||
|
|
||||||
@property
|
|
||||||
def icon(self):
|
|
||||||
"""icon getter"""
|
|
||||||
return "mdi:speedometer"
|
|
||||||
|
|
||||||
@property
|
|
||||||
def device_info(self) -> DeviceInfo:
|
|
||||||
"""Return the device info."""
|
|
||||||
return self._tracker_device.device_info
|
|
||||||
|
|
||||||
class GeoRideInternalBatterySensorEntity(CoordinatorEntity, SensorEntity):
|
|
||||||
"""Represent a tracked device."""
|
|
||||||
entity_category = EntityCategory.DIAGNOSTIC
|
|
||||||
|
|
||||||
def __init__(self, coordinator: DataUpdateCoordinator[Mapping[str, Any]],
|
|
||||||
tracker_device:Device):
|
|
||||||
"""Set up GeoRide entity."""
|
|
||||||
super().__init__(coordinator)
|
|
||||||
self._tracker_device = tracker_device
|
|
||||||
self._name = tracker_device.tracker.tracker_name
|
|
||||||
self._unit_of_measurement = "V"
|
|
||||||
self.entity_id = f"{ENTITY_ID_FORMAT.format('internal_battery_voltage')}.{tracker_device.tracker.tracker_id}"# pylint: disable=C0301
|
|
||||||
self._state = 0
|
|
||||||
self._state_class = "measurement"
|
|
||||||
self._device_class = "voltage"
|
|
||||||
|
|
||||||
@property
|
|
||||||
def state_class(self):
|
|
||||||
return self._state_class
|
|
||||||
|
|
||||||
@property
|
|
||||||
def device_class(self):
|
|
||||||
return self._device_class
|
|
||||||
|
|
||||||
@property
|
|
||||||
def entity_category(self):
|
|
||||||
return EntityCategory.DIAGNOSTIC
|
|
||||||
|
|
||||||
@property
|
|
||||||
def unique_id(self):
|
|
||||||
"""Return the unique ID."""
|
|
||||||
return f"internal_battery_voltage_{self._tracker_device.tracker.tracker_id}"
|
|
||||||
|
|
||||||
@property
|
|
||||||
def state(self):
|
|
||||||
"""state property"""
|
|
||||||
return self._tracker_device.tracker.internal_battery_voltage
|
|
||||||
|
|
||||||
@property
|
|
||||||
def unit_of_measurement(self):
|
|
||||||
"""unit of mesurment property"""
|
|
||||||
return self._unit_of_measurement
|
|
||||||
|
|
||||||
@property
|
|
||||||
def name(self):
|
|
||||||
""" GeoRide internal_battery_voltage name """
|
|
||||||
return f"{self._name} internal_battery_voltage"
|
|
||||||
|
|
||||||
@property
|
|
||||||
def icon(self):
|
|
||||||
"""icon getter"""
|
|
||||||
return "mdi:battery"
|
|
||||||
|
|
||||||
@property
|
|
||||||
def device_info(self) -> DeviceInfo:
|
|
||||||
"""Return the device info."""
|
|
||||||
return self._tracker_device.device_info
|
|
||||||
|
|
||||||
class GeoRideExternalBatterySensorEntity(CoordinatorEntity, SensorEntity):
|
|
||||||
"""Represent a tracked device."""
|
|
||||||
|
|
||||||
def __init__(self, coordinator: DataUpdateCoordinator[Mapping[str, Any]],
|
|
||||||
tracker_device:Device):
|
|
||||||
"""Set up GeoRide entity."""
|
|
||||||
super().__init__(coordinator)
|
|
||||||
self._tracker_device = tracker_device
|
|
||||||
self._name = tracker_device.tracker.tracker_name
|
|
||||||
self._unit_of_measurement = "V"
|
|
||||||
self.entity_id = f"{ENTITY_ID_FORMAT.format('external_battery_voltage')}.{tracker_device.tracker.tracker_id}"# pylint: disable=C0301
|
|
||||||
self._state = 0
|
|
||||||
self._state_class = "measurement"
|
|
||||||
self._device_class = "voltage"
|
|
||||||
|
|
||||||
@property
|
|
||||||
def state_class(self):
|
|
||||||
return self._state_class
|
|
||||||
|
|
||||||
@property
|
|
||||||
def device_class(self):
|
|
||||||
return self._device_class
|
|
||||||
|
|
||||||
@property
|
|
||||||
def entity_category(self):
|
|
||||||
return EntityCategory.DIAGNOSTIC
|
|
||||||
|
|
||||||
@property
|
|
||||||
def unique_id(self):
|
|
||||||
"""Return the unique ID."""
|
|
||||||
return f"external_battery_voltage_{self._tracker_device.tracker.tracker_id}"
|
|
||||||
|
|
||||||
@property
|
|
||||||
def state(self):
|
|
||||||
"""state property"""
|
|
||||||
return self._tracker_device.tracker.external_battery_voltage
|
|
||||||
|
|
||||||
@property
|
|
||||||
def unit_of_measurement(self):
|
|
||||||
"""unit of mesurment property"""
|
|
||||||
return self._unit_of_measurement
|
|
||||||
|
|
||||||
@property
|
|
||||||
def name(self):
|
|
||||||
""" GeoRide internal_battery_voltage name """
|
|
||||||
return f"{self._name} external_battery_voltage"
|
|
||||||
|
|
||||||
@property
|
|
||||||
def icon(self):
|
|
||||||
"""icon getter"""
|
|
||||||
return "mdi:battery"
|
|
||||||
|
|
||||||
@property
|
|
||||||
def device_info(self) -> DeviceInfo:
|
|
||||||
"""Return the device info."""
|
|
||||||
return self._tracker_device.device_info
|
|
||||||
|
|
||||||
class GeoRideFixtimeSensorEntity(CoordinatorEntity, SensorEntity):
|
|
||||||
"""Represent a tracked device."""
|
|
||||||
|
|
||||||
def __init__(self, coordinator: DataUpdateCoordinator[Mapping[str, Any]],
|
|
||||||
tracker_device:Device):
|
|
||||||
"""Set up GeoRide entity."""
|
|
||||||
super().__init__(coordinator)
|
|
||||||
self._tracker_device = tracker_device
|
|
||||||
self._name = tracker_device.tracker.tracker_name
|
|
||||||
self.entity_id = f"{ENTITY_ID_FORMAT.format('fixtime')}.{tracker_device.tracker.tracker_id}"# pylint: disable=C0301
|
|
||||||
|
|
||||||
self._state = 0
|
|
||||||
self._device_class = "timestamp"
|
|
||||||
|
|
||||||
@property
|
|
||||||
def entity_category(self):
|
|
||||||
return EntityCategory.DIAGNOSTIC
|
|
||||||
|
|
||||||
@property
|
|
||||||
def unique_id(self):
|
|
||||||
"""Return the unique ID."""
|
|
||||||
return f"fixtime_{self._tracker_device.tracker.tracker_id}"
|
|
||||||
|
|
||||||
@property
|
|
||||||
def state(self):
|
|
||||||
"""state property"""
|
|
||||||
return self._tracker_device.tracker.fixtime
|
|
||||||
|
|
||||||
@property
|
|
||||||
def name(self):
|
|
||||||
""" GeoRide fixtime name """
|
|
||||||
return f"{self._name} last fixed position"
|
|
||||||
|
|
||||||
@property
|
|
||||||
def icon(self):
|
|
||||||
"""icon getter"""
|
|
||||||
return "mdi:map-clock"
|
|
||||||
|
|
||||||
@property
|
|
||||||
def device_info(self) -> DeviceInfo:
|
|
||||||
"""Return the device info."""
|
|
||||||
return self._tracker_device.device_info
|
|
||||||
|
|
||||||
class GeoRideBeaconBatterySensorEntity(CoordinatorEntity, SensorEntity):
|
|
||||||
"""Represent a tracked device."""
|
|
||||||
|
|
||||||
def __init__(self, coordinator: DataUpdateCoordinator[Mapping[str, Any]],
|
|
||||||
tracker_beacon: DeviceBeacon):
|
|
||||||
"""Set up GeoRide entity."""
|
|
||||||
super().__init__(coordinator)
|
|
||||||
self._tracker_device = tracker_beacon
|
|
||||||
self._name = tracker_beacon.beacon.name
|
|
||||||
self._unit_of_measurement = "%"
|
|
||||||
self.entity_id = f"{ENTITY_ID_FORMAT.format('battery_percent')}.{tracker_beacon.beacon.beacon_id}"# pylint: disable=C0301
|
|
||||||
self._state = 0
|
|
||||||
|
|
||||||
@property
|
|
||||||
def entity_category(self):
|
|
||||||
return EntityCategory.DIAGNOSTIC
|
|
||||||
|
|
||||||
@property
|
|
||||||
def unique_id(self):
|
|
||||||
"""Return the unique ID."""
|
|
||||||
return f"battery_percent_{self._tracker_device.beacon.beacon_id}"
|
|
||||||
|
|
||||||
@property
|
|
||||||
def state(self):
|
|
||||||
"""state property"""
|
|
||||||
return self._tracker_device.beacon.battery_level
|
|
||||||
|
|
||||||
@property
|
|
||||||
def unit_of_measurement(self):
|
|
||||||
"""unit of mesurment property"""
|
|
||||||
return self._unit_of_measurement
|
|
||||||
|
|
||||||
@property
|
|
||||||
def name(self):
|
|
||||||
""" GeoRide internal_battery_voltage name """
|
|
||||||
return f"{self._name} battery percent"
|
|
||||||
|
|
||||||
@property
|
|
||||||
def icon(self):
|
|
||||||
"""icon getter"""
|
|
||||||
return "mdi:battery"
|
|
||||||
|
|
||||||
@property
|
|
||||||
def device_info(self) -> DeviceInfo:
|
|
||||||
"""Return the device info."""
|
"""Return the device info."""
|
||||||
return self._tracker_device.device_info
|
return self._tracker_device.device_info
|
||||||
@@ -1,96 +0,0 @@
|
|||||||
""" device tracker for GeoRide object """
|
|
||||||
|
|
||||||
import logging
|
|
||||||
|
|
||||||
|
|
||||||
from typing import Any, Mapping
|
|
||||||
|
|
||||||
from homeassistant.components.siren import SirenEntity
|
|
||||||
|
|
||||||
from homeassistant.helpers.update_coordinator import (
|
|
||||||
CoordinatorEntity,
|
|
||||||
DataUpdateCoordinator,
|
|
||||||
)
|
|
||||||
|
|
||||||
import georideapilib.api as GeoRideApi
|
|
||||||
|
|
||||||
from .const import DOMAIN as GEORIDE_DOMAIN
|
|
||||||
from .device import Device
|
|
||||||
|
|
||||||
ENTITY_ID_FORMAT = 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"]
|
|
||||||
coordoned_trackers = georide_context.georide_trackers_coordoned
|
|
||||||
|
|
||||||
entities = []
|
|
||||||
for coordoned_tracker in coordoned_trackers:
|
|
||||||
tracker_device = coordoned_tracker['tracker_device']
|
|
||||||
coordinator = coordoned_tracker['coordinator']
|
|
||||||
hass.data[GEORIDE_DOMAIN]["devices"][tracker_device.tracker.tracker_id] = coordinator
|
|
||||||
if tracker_device.tracker.version > 2:
|
|
||||||
entities.append(GeoRideSirenEntity(coordinator, tracker_device, hass))
|
|
||||||
|
|
||||||
async_add_entities(entities)
|
|
||||||
|
|
||||||
return True
|
|
||||||
|
|
||||||
class GeoRideSirenEntity(CoordinatorEntity, SirenEntity):
|
|
||||||
"""Represent a tracked device."""
|
|
||||||
|
|
||||||
def __init__(self, coordinator: DataUpdateCoordinator[Mapping[str, Any]],
|
|
||||||
tracker_device:Device, hass):
|
|
||||||
"""Set up GeoRide entity."""
|
|
||||||
super().__init__(coordinator)
|
|
||||||
self._tracker_device = tracker_device
|
|
||||||
self._name = tracker_device.tracker.tracker_name
|
|
||||||
self.entity_id = f"{ENTITY_ID_FORMAT.format('eco_mode')}.{tracker_device.tracker.tracker_id}"# pylint: disable=C0301
|
|
||||||
self._hass = hass
|
|
||||||
|
|
||||||
@property
|
|
||||||
def entity_category(self):
|
|
||||||
return None
|
|
||||||
|
|
||||||
async def async_turn_on(self, **kwargs):
|
|
||||||
""" lock the GeoRide tracker """
|
|
||||||
_LOGGER.info('async_turn_on eco %s', kwargs)
|
|
||||||
georide_context = self._hass.data[GEORIDE_DOMAIN]["context"]
|
|
||||||
token = await georide_context.get_token()
|
|
||||||
success = await self._hass.async_add_executor_job(GeoRideApi.change_tracker_siren_state,
|
|
||||||
token, self._tracker_device.tracker.tracker_id, True)
|
|
||||||
if success:
|
|
||||||
self._tracker_device.tracker.is_siren_on = True
|
|
||||||
|
|
||||||
async def async_turn_off(self, **kwargs):
|
|
||||||
""" unlock the GeoRide tracker """
|
|
||||||
_LOGGER.info('async_turn_off eco %s', kwargs)
|
|
||||||
georide_context = self._hass.data[GEORIDE_DOMAIN]["context"]
|
|
||||||
token = await georide_context.get_token()
|
|
||||||
success = await self._hass.async_add_executor_job(GeoRideApi.change_tracker_siren_state,
|
|
||||||
token, self._tracker_device.tracker.tracker_id, False)
|
|
||||||
if success:
|
|
||||||
self._tracker_device.tracker.is_siren_on = False
|
|
||||||
|
|
||||||
@property
|
|
||||||
def unique_id(self):
|
|
||||||
"""Return the unique ID."""
|
|
||||||
return f"siren_{self._tracker_device.tracker.tracker_id}"
|
|
||||||
|
|
||||||
@property
|
|
||||||
def name(self):
|
|
||||||
""" GeoRide odometer name """
|
|
||||||
return f"{self._name} siren"
|
|
||||||
|
|
||||||
@property
|
|
||||||
def is_on(self):
|
|
||||||
""" GeoRide switch status """
|
|
||||||
return self._tracker_device.tracker.is_siren_on
|
|
||||||
|
|
||||||
@property
|
|
||||||
def device_info(self):
|
|
||||||
"""Return the device info."""
|
|
||||||
return self._tracker_device.device_info
|
|
||||||
@@ -24,18 +24,17 @@ _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"]
|
||||||
coordoned_trackers = georide_context.georide_trackers_coordoned
|
coordoned_trackers = georide_context.get_coordoned_trackers()
|
||||||
|
|
||||||
entities = []
|
lock_switch_entities = []
|
||||||
for coordoned_tracker in coordoned_trackers:
|
for coordoned_tracker in coordoned_trackers:
|
||||||
tracker_device = coordoned_tracker['tracker_device']
|
tracker_device = coordoned_tracker['tracker_device']
|
||||||
coordinator = coordoned_tracker['coordinator']
|
coordinator = coordoned_tracker['coordinator']
|
||||||
|
entity = GeoRideLockSwitchEntity(coordinator, tracker_device, hass)
|
||||||
hass.data[GEORIDE_DOMAIN]["devices"][tracker_device.tracker.tracker_id] = coordinator
|
hass.data[GEORIDE_DOMAIN]["devices"][tracker_device.tracker.tracker_id] = coordinator
|
||||||
entities.append(GeoRideLockSwitchEntity(coordinator, tracker_device, hass))
|
lock_switch_entities.append(entity)
|
||||||
if tracker_device.tracker.version > 2:
|
|
||||||
entities.append(GeoRideEcoModeSwitchEntity(coordinator, tracker_device, hass))
|
|
||||||
|
|
||||||
async_add_entities(entities)
|
async_add_entities(lock_switch_entities)
|
||||||
|
|
||||||
return True
|
return True
|
||||||
|
|
||||||
@@ -51,10 +50,6 @@ class GeoRideLockSwitchEntity(CoordinatorEntity, SwitchEntity):
|
|||||||
self.entity_id = f"{ENTITY_ID_FORMAT.format('lock')}.{tracker_device.tracker.tracker_id}"# pylint: disable=C0301
|
self.entity_id = f"{ENTITY_ID_FORMAT.format('lock')}.{tracker_device.tracker.tracker_id}"# pylint: disable=C0301
|
||||||
self._hass = hass
|
self._hass = hass
|
||||||
|
|
||||||
@property
|
|
||||||
def entity_category(self):
|
|
||||||
return None
|
|
||||||
|
|
||||||
async def async_turn_on(self, **kwargs):
|
async def async_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)
|
||||||
@@ -110,66 +105,3 @@ class GeoRideLockSwitchEntity(CoordinatorEntity, SwitchEntity):
|
|||||||
def device_info(self):
|
def device_info(self):
|
||||||
"""Return the device info."""
|
"""Return the device info."""
|
||||||
return self._tracker_device.device_info
|
return self._tracker_device.device_info
|
||||||
|
|
||||||
class GeoRideEcoModeSwitchEntity(CoordinatorEntity, SwitchEntity):
|
|
||||||
"""Represent a tracked device."""
|
|
||||||
|
|
||||||
def __init__(self, coordinator: DataUpdateCoordinator[Mapping[str, Any]],
|
|
||||||
tracker_device:Device, hass):
|
|
||||||
"""Set up GeoRide entity."""
|
|
||||||
super().__init__(coordinator)
|
|
||||||
self._tracker_device = tracker_device
|
|
||||||
self._name = tracker_device.tracker.tracker_name
|
|
||||||
self.entity_id = f"{ENTITY_ID_FORMAT.format('eco_mode')}.{tracker_device.tracker.tracker_id}"# pylint: disable=C0301
|
|
||||||
self._hass = hass
|
|
||||||
|
|
||||||
@property
|
|
||||||
def entity_category(self):
|
|
||||||
return None
|
|
||||||
|
|
||||||
async def async_turn_on(self, **kwargs):
|
|
||||||
""" lock the GeoRide tracker """
|
|
||||||
_LOGGER.info('async_turn_on eco %s', kwargs)
|
|
||||||
georide_context = self._hass.data[GEORIDE_DOMAIN]["context"]
|
|
||||||
token = await georide_context.get_token()
|
|
||||||
success = await self._hass.async_add_executor_job(GeoRideApi.change_tracker_eco_mode_state,
|
|
||||||
token, self._tracker_device.tracker.tracker_id, True)
|
|
||||||
if success:
|
|
||||||
self._tracker_device.tracker.is_in_eco = True
|
|
||||||
|
|
||||||
async def async_turn_off(self, **kwargs):
|
|
||||||
""" unlock the GeoRide tracker """
|
|
||||||
_LOGGER.info('async_turn_off eco %s', kwargs)
|
|
||||||
georide_context = self._hass.data[GEORIDE_DOMAIN]["context"]
|
|
||||||
token = await georide_context.get_token()
|
|
||||||
success = await self._hass.async_add_executor_job(GeoRideApi.change_tracker_eco_mode_state,
|
|
||||||
token, self._tracker_device.tracker.tracker_id, False)
|
|
||||||
if success:
|
|
||||||
self._tracker_device.tracker.is_in_eco = False
|
|
||||||
|
|
||||||
@property
|
|
||||||
def unique_id(self):
|
|
||||||
"""Return the unique ID."""
|
|
||||||
return f"eco_mode_{self._tracker_device.tracker.tracker_id}"
|
|
||||||
|
|
||||||
@property
|
|
||||||
def name(self):
|
|
||||||
""" GeoRide odometer name """
|
|
||||||
return f"{self._name} eco mode"
|
|
||||||
|
|
||||||
@property
|
|
||||||
def is_on(self):
|
|
||||||
""" GeoRide switch status """
|
|
||||||
return self._tracker_device.tracker.is_in_eco
|
|
||||||
|
|
||||||
@property
|
|
||||||
def icon(self):
|
|
||||||
"""return the entity icon"""
|
|
||||||
if self._tracker_device.tracker.is_in_eco:
|
|
||||||
return "mdi:battery-heart-variant"
|
|
||||||
return "mdi:battery"
|
|
||||||
|
|
||||||
@property
|
|
||||||
def device_info(self):
|
|
||||||
"""Return the device info."""
|
|
||||||
return self._tracker_device.device_info
|
|
||||||
Reference in New Issue
Block a user