Compare commits
8 Commits
0.9.0-snap
...
0.9.0-snap
| Author | SHA1 | Date | |
|---|---|---|---|
| 3000d5588b | |||
| a3c84c63fd | |||
| a37cca7902 | |||
| 32db0ec42e | |||
| 1250dda047 | |||
| 759fe2d257 | |||
| 9e2e6e8d53 | |||
| 4dc091525e |
@@ -220,12 +220,13 @@ class GeoRideContext:
|
|||||||
return tracker_beacon
|
return tracker_beacon
|
||||||
return {}
|
return {}
|
||||||
|
|
||||||
async def get_tracker_beacon_by_tracker_id(self, tracker_id):
|
async def get_tracker_beacons_by_tracker_id(self, tracker_id):
|
||||||
""" here we return last tracker_beacon by id"""
|
""" here we return last tracker_beacon by id"""
|
||||||
|
filtered_beacon = []
|
||||||
for tracker_beacon in self._georide_trackers_beacon:
|
for tracker_beacon in self._georide_trackers_beacon:
|
||||||
if tracker_beacon.linked_tracker_id == tracker_id:
|
if tracker_beacon.linked_tracker_id == tracker_id:
|
||||||
return tracker_beacon
|
filtered_beacon.append(tracker_beacon)
|
||||||
return {}
|
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"""
|
||||||
@@ -250,13 +251,12 @@ class GeoRideContext:
|
|||||||
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:
|
if tracker.version > 2:
|
||||||
await force_refresh_trackers_beacon(tracker.tracker_id)
|
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:
|
if refreshed_tracker.version > 2:
|
||||||
await force_refresh_trackers_beacon(tracker.tracker_id)
|
await self.force_refresh_trackers_beacon(refreshed_tracker.tracker_id)
|
||||||
|
|
||||||
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
|
||||||
@@ -266,15 +266,17 @@ class GeoRideContext:
|
|||||||
async def force_refresh_trackers_beacon(self, tracker_id):
|
async def force_refresh_trackers_beacon(self, tracker_id):
|
||||||
"""Used to refresh the tracker list"""
|
"""Used to refresh the tracker list"""
|
||||||
_LOGGER.info("Tracker beacon refresh")
|
_LOGGER.info("Tracker beacon refresh")
|
||||||
new_georide_tracker_beacon = await self._hass.async_add_executor_job(GeoRideApi.get_tracker_beacon,
|
new_georide_tracker_beacons = await self._hass.async_add_executor_job(GeoRideApi.get_tracker_beacon,
|
||||||
await self.get_token(), tracker_id)
|
await self.get_token(), tracker_id)
|
||||||
found = False
|
|
||||||
for tracker_beacon in self._georide_trackers_beacon:
|
for new_georide_tracker_beacon in new_georide_tracker_beacons:
|
||||||
if tracker_beacon.tracker_id == new_georide_tracker_beacon.beacon_id:
|
found = False
|
||||||
tracker_beacon.update_all_data(new_georide_tracker_beacon)
|
for tracker_beacon in self._georide_trackers_beacon:
|
||||||
found = True
|
if tracker_beacon.tracker_id == new_georide_tracker_beacon.beacon_id:
|
||||||
if not found:
|
tracker_beacon.update_all_data(new_georide_tracker_beacon)
|
||||||
self._georide_trackers_beacon.append(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
|
||||||
@@ -301,17 +303,18 @@ class GeoRideContext:
|
|||||||
"coordinator": coordinator
|
"coordinator": coordinator
|
||||||
}
|
}
|
||||||
if tracker.version > 2:
|
if tracker.version > 2:
|
||||||
tracker_beacon = await get_tracker_beacon_by_tracker_id(tracker.tracker_id)
|
tracker_beacons = await self.get_tracker_beacon_by_tracker_id(tracker.tracker_id)
|
||||||
beacon_coordinator = DataUpdateCoordinator[Mapping[str, Any]](
|
for tracker_beacon in tracker_beacons
|
||||||
hass,
|
beacon_coordinator = DataUpdateCoordinator[Mapping[str, Any]](
|
||||||
_LOGGER,
|
hass,
|
||||||
name=tracker_beacon.name
|
_LOGGER,
|
||||||
)
|
name= tracker_beacon.name
|
||||||
coordoned_beacon = {
|
)
|
||||||
"beacon_device": DeviceBeacon(tracker_beacon),
|
coordoned_beacon = {
|
||||||
"coordinator": coordinator
|
"beacon_device": DeviceBeacon(tracker_beacon),
|
||||||
}
|
"coordinator": coordinator
|
||||||
self._georide_trackers_beacon_coordoned(coordoned_beacon)
|
}
|
||||||
|
self._georide_trackers_beacon_coordoned.append(coordoned_beacon)
|
||||||
self._georide_trackers_coordoned.append(coordoned_tracker)
|
self._georide_trackers_coordoned.append(coordoned_tracker)
|
||||||
|
|
||||||
|
|
||||||
@@ -320,7 +323,7 @@ class GeoRideContext:
|
|||||||
"""Return coordoned trackers"""
|
"""Return coordoned trackers"""
|
||||||
|
|
||||||
return self._georide_trackers_coordoned
|
return self._georide_trackers_coordoned
|
||||||
|
|
||||||
@property
|
@property
|
||||||
def georide_trackers_beacon_coordoned(self):
|
def georide_trackers_beacon_coordoned(self):
|
||||||
"""Return coordoned trackers"""
|
"""Return coordoned trackers"""
|
||||||
|
|||||||
@@ -6,7 +6,7 @@
|
|||||||
"issue_tracker": "https://github.com/ptimatth/GeorideHA/issues",
|
"issue_tracker": "https://github.com/ptimatth/GeorideHA/issues",
|
||||||
"iot_class": "cloud_polling",
|
"iot_class": "cloud_polling",
|
||||||
"requirements": [
|
"requirements": [
|
||||||
"georideapilib==0.8.1",
|
"georideapilib>=0.8.2",
|
||||||
"pyjwt==2.1.0"
|
"pyjwt==2.1.0"
|
||||||
],
|
],
|
||||||
"dependencies": [],
|
"dependencies": [],
|
||||||
|
|||||||
@@ -111,11 +111,7 @@ class GeoRideOdometerKmSensorEntity(CoordinatorEntity, SensorEntity):
|
|||||||
|
|
||||||
self._state = 0
|
self._state = 0
|
||||||
self._hass = hass
|
self._hass = hass
|
||||||
|
|
||||||
@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."""
|
||||||
|
|||||||
Reference in New Issue
Block a user