Merge pull request #141 from YorkshireIoT/140-refresh-sensor-values-o…

…n-startup

140 refresh sensor values on integration startup

custom_components/google_fit/__init__.py

@@ -49,6 +49,10 @@ async def async_setup_entry(hass: HomeAssistant, entry: ConfigEntry) -> bool:
     await hass.config_entries.async_forward_entry_setup(entry, PLATFORM)
     entry.async_on_unload(entry.add_update_listener(update_listener))
 
+    # Attempt to retrieve values immediately, not waiting for first
+    # time interval to pass
+    await coordinator.async_config_entry_first_refresh()
+
     return True
 
 

custom_components/google_fit/coordinator.py

@@ -16,7 +16,6 @@
 
 from .api import AsyncConfigEntryAuth, GoogleFitParse
 from .api_types import (
-    FitService,
     FitnessData,
     FitnessObject,
     FitnessDataPoint,
@@ -97,12 +96,15 @@ def _get_interval(self, interval_period: int = 0) -> str:
         now = int(datetime.today().timestamp() * NANOSECONDS_SECONDS_CONVERSION)
         return f"{start}-{now}"
 
-    async def _async_update_data(self) -> FitService | None:
+    async def _async_update_data(self) -> FitnessData | None:
         """Update data via library."""
         LOGGER.debug(
             "Fetching data for account %s",
             self._auth.oauth_session.config_entry.unique_id,
         )
+
+        # Start by initialising data to None
+        self.fitness_data = None
         try:
             async with async_timeout.timeout(30):
                 service = await self._auth.get_resource(self.hass)
@@ -175,8 +177,8 @@ def _get_session(activity_id: int) -> FitnessSessionResponse:
                             f"Unknown sensor type for {entity.data_key}. Got: {type(entity)}"
                         )
 
+                # Update globally stored data with fetched and parsed data
                 self.fitness_data = parser.fit_data
-
         except HttpError as err:
             if 400 <= err.status_code < 500:
                 raise ConfigEntryAuthFailed(
@@ -185,3 +187,5 @@ def _get_session(activity_id: int) -> FitnessSessionResponse:
             raise err
         except Exception as err:
             raise UpdateFailed(f"Error communicating with API: {err}") from err
+
+        return self.fitness_data