Add missing save_cache()

Author: bouwew

plugwise_usb/nodes/circle.py

@@ -591,6 +591,7 @@ async def _energy_log_records_save_to_cache(self) -> None:
                 cached_logs += f"-{log.timestamp.hour}-{log.timestamp.minute}"
                 cached_logs += f"-{log.timestamp.second}:{log.pulses}"
         self._set_cache(CACHE_ENERGY_COLLECTION, cached_logs)
+        await self.save_cache()
 
     async def _energy_log_record_update_state(
         self,
@@ -606,6 +607,7 @@ async def _energy_log_record_update_state(
         )
         if not self._cache_enabled:
             return False
+
         log_cache_record = f"{address}:{slot}:{timestamp.year}"
         log_cache_record += f"-{timestamp.month}-{timestamp.day}"
         log_cache_record += f"-{timestamp.hour}-{timestamp.minute}"
@@ -621,12 +623,16 @@ async def _energy_log_record_update_state(
                 self._set_cache(
                     CACHE_ENERGY_COLLECTION, cached_logs + "|" + log_cache_record
                 )
+                await self.save_cache()
                 return True
+
             return False
+
         _LOGGER.debug(
             "No existing energy collection log cached for %s", self._mac_in_str
         )
         self._set_cache(CACHE_ENERGY_COLLECTION, log_cache_record)
+        await self.save_cache()
         return True
 
     @raise_not_loaded

plugwise_usb/nodes/node.py

@@ -690,6 +690,7 @@ def _set_cache(self, setting: str, value: Any) -> None:
         """Store setting with value in cache memory."""
         if not self._cache_enabled:
             return
+
         if isinstance(value, datetime):
             self._node_cache.update_state(
                 setting,
@@ -707,9 +708,11 @@ async def save_cache(
         """Save cached data to cache file when cache is enabled."""
         if not self._cache_enabled or not self._loaded or not self._initialized:
             return
+
         _LOGGER.debug("Save cache file for node %s", self.mac)
         if self._cache_save_task is not None and not self._cache_save_task.done():
             await self._cache_save_task
+
         if trigger_only:
             self._cache_save_task = create_task(self._node_cache.save_cache())
         else:

plugwise_usb/nodes/sed.py

@@ -550,6 +550,7 @@ async def _awake_response(self, response: PlugwiseResponse) -> bool:
                 tasks.append(self.update_ping_at_awake())
 
         await gather(*tasks)
+        await self.save_cache()
         return True
 
     async def update_ping_at_awake(self) -> None:
@@ -560,6 +561,7 @@ def _detect_maintenance_interval(self, timestamp: datetime) -> None:
         """Detect current maintenance interval."""
         if self._last_awake[NodeAwakeResponseType.MAINTENANCE] == timestamp:
             return
+
         new_interval_in_sec = (
             timestamp - self._last_awake[NodeAwakeResponseType.MAINTENANCE]
         ).seconds
@@ -594,6 +596,8 @@ def _detect_maintenance_interval(self, timestamp: datetime) -> None:
             self._set_cache(
                 CACHE_MAINTENANCE_INTERVAL, SED_DEFAULT_MAINTENANCE_INTERVAL
             )
+
+        await self.save_cache()
         self._maintenance_interval_restored_from_cache = True
 
     async def _reset_awake(self, last_alive: datetime) -> None: