Add/update cache-related logging

Author: bouwew

plugwise_usb/nodes/circle.py

@@ -269,6 +269,7 @@ async def _calibration_update_state(
             self._set_cache(CACHE_CALIBRATION_GAIN_B, gain_b)
             self._set_cache(CACHE_CALIBRATION_NOISE, off_noise)
             self._set_cache(CACHE_CALIBRATION_TOT, off_tot)
+            _LOGGER.debug("Saving calibration update to cache for %s", self._mac_in_str)
             await self.save_cache()
         return True
 
@@ -563,6 +564,7 @@ async def energy_log_update(self, address: int | None) -> bool:
 
         self._energy_counters.update()
         if energy_record_update:
+            _LOGGER.debug("Saving energy record update to cache for %s", self._mac_in_str)
             await self.save_cache()
 
         return True
@@ -782,6 +784,7 @@ async def _relay_update_state(
             await self.publish_feature_update_to_subscribers(
                 NodeFeature.RELAY, self._relay_state
             )
+            _LOGGER.debug("Saving relay state update to cache for %s", self._mac_in_str)
             await self.save_cache()
 
     async def _relay_update_lock(self, state: bool) -> None:
@@ -801,6 +804,7 @@ async def _relay_update_lock(self, state: bool) -> None:
             await self.publish_feature_update_to_subscribers(
                 NodeFeature.RELAY_LOCK, self._relay_lock
             )
+            _LOGGER.debug("Saving relay lock state update to cachefor %s", self._mac_in_str)
             await self.save_cache()
 
     async def clock_synchronize(self) -> bool:
@@ -1147,6 +1151,7 @@ async def _relay_init_update_state(self, state: bool) -> None:
             await self.publish_feature_update_to_subscribers(
                 NodeFeature.RELAY_INIT, self._relay_config
             )
+            _LOGGER.debug("Saving relay_init state update to cachefor %s", self._mac_in_str)
             await self.save_cache()
 
     @raise_calibration_missing
@@ -1287,7 +1292,7 @@ async def energy_reset_request(self) -> None:
             NO_PRODUCTION_INTERVAL,
         )
         if (response := await request.send()) is None:
-            raise NodeError("No response for CircleMeasureIntervalRequest.")
+            raise NodeError("No response for CircleMeasureIntervalRequest")
 
         if response.response_type != NodeResponseType.POWER_LOG_INTERVAL_ACCEPTED:
             raise MessageError(
@@ -1298,7 +1303,10 @@ async def energy_reset_request(self) -> None:
         # Clear the cached energy_collection
         if self._cache_enabled:
             self._set_cache(CACHE_ENERGY_COLLECTION, "")
-            _LOGGER.warning("Energy-collection cache cleared successfully")
+            _LOGGER.warning(
+                "Energy-collection cache cleared successfully, updating cache for %s",
+                self._mac_in_str,
+            )
             await self.save_cache()
 
         # Clear PulseCollection._logs
@@ -1307,6 +1315,12 @@ async def energy_reset_request(self) -> None:
 
         # Request a NodeInfo update
         if await self.node_info_update() is None:
-            _LOGGER.warning("Node info update failed after energy-reset")
+            _LOGGER.warning(
+                "Node info update failed after energy-reset for %s",
+                self._mac_in_str,
+            )
         else:
-            _LOGGER.warning("Node info update after energy-reset successful")
+            _LOGGER.warning(
+                "Node info update after energy-reset successful for %s",
+                self._mac_in_str,
+            )

plugwise_usb/nodes/node.py

@@ -577,6 +577,7 @@ async def update_node_details(
             self._node_info.timestamp = timestamp
             self._set_cache(CACHE_NODE_INFO_TIMESTAMP, timestamp)
 
+        _LOGGER.debug("Saving Node calibration update to cache for %s" self.mac)
         await self.save_cache()
         if timestamp is not None and timestamp > datetime.now(tz=UTC) - timedelta(
             minutes=5
@@ -654,6 +655,7 @@ async def unload(self) -> None:
             return
         if self._cache_save_task is not None and not self._cache_save_task.done():
             await self._cache_save_task
+        _LOGGER.debug("Writing cache to disk while unloading for %s" self.mac)
         await self.save_cache(trigger_only=False, full_write=True)
 
     def _get_cache(self, setting: str) -> str | None: