Sort and prune the records loaded from cache

Author: bouwew

plugwise_usb/nodes/circle.py

@@ -26,6 +26,7 @@
 from ..constants import (
     DAY_IN_HOURS,
     DEFAULT_CONS_INTERVAL,
+    MAX_LOG_HOURS,
     MAX_TIME_DRIFT,
     MINIMAL_POWER_UPDATE,
     NO_PRODUCTION_INTERVAL,
@@ -635,6 +636,20 @@ async def _energy_log_records_load_from_cache(self) -> bool:
                         restored_logs[address] = []
                     restored_logs[address].append(slot)
 
+        # Sort and prune the records loaded from cache
+        sorted_logs: dict[int, dict[int, PulseLogRecord]] = {}
+        skip_before = datetime.now(tz=UTC) - timedelta(hours=MAX_LOG_HOURS)
+        sorted_address = sorted(restored_logs.keys(), reverse=True)
+        for address in sorted_address:
+            sorted_slots = sorted(restored_logs[address].keys(), reverse=True)
+            for slot in sorted_slots:
+                if restored_logs[address][slot].timestamp > skip_before:
+                    if sorted_log.get(address) is None:
+                        sorted_log[address] = {}
+                    sorted_log[address][slot] = restored_logs[address][slot]
+        
+        restored_logs = sorted_logs
+
         self._energy_counters.update()
 
         # Create task to retrieve remaining (missing) logs