Improve logic and summing covering the log_interval resets

Author: bouwew

plugwise_usb/nodes/helpers/pulses.py

@@ -174,7 +174,7 @@ def collected_pulses(
                 return (None, None)
 
         if (
-            log_pulses := self._collect_pulses_from_logs(from_timestamp, is_consumption)
+            log_pulses, reset := self._collect_pulses_from_logs(from_timestamp, is_consumption)
         ) is None:
             _LOGGER.debug("collected_pulses | %s | log_pulses:None", self._mac)
             return (None, None)
@@ -188,18 +188,24 @@ def collected_pulses(
             delta_cons_pulses = self._pulses_consumption - self._prev_pulses_consumption
             pulses = self._prev_pulses_consumption + delta_cons_pulses
             self._prev_pulses_consumption = pulses
-            if self._pulsecounter_reset:
-                pulses = self._pulses_consumption
+            if reset:
+                pulses = delta_cons_pulses
                 self._prev_pulses_consumption = 0
+            if self._pulsecounter_reset:
+                pulses = self._pulses_consumption + self._prev_pulses_consumption
+                self._prev_pulses_consumption = pulses
 
         if not is_consumption and self._pulses_production is not None:
             timestamp = self._pulses_timestamp
             delta_prod_pulses = self._pulses_production - self._prev_pulses_production
             pulses = self._prev_pulses_production + delta_prod_pulses
             self._prev_pulses_production = pulses
-            if self._pulsecounter_reset:
-                pulses = self._pulses_production
+            if reset:
+                pulses = delta_prod_pulses
                 self._prev_pulses_production = 0
+            if self._pulsecounter_reset:
+                pulses = self._prev_pulses_production + self._prev_pulses_production
+                self._prev_pulses_production = pulses
 
         if pulses is None:
             _LOGGER.debug(
@@ -222,8 +228,11 @@ def collected_pulses(
 
     def _collect_pulses_from_logs(
         self, from_timestamp: datetime, is_consumption: bool
-    ) -> int | None:
-        """Collect all pulses from logs."""
+    ) -> tuple[int, bool] | None:
+        """Collect all pulses from logs.
+        
+        And return True when the from_timestamp rolls over to the next log_interval.
+        """
         if self._logs is None:
             _LOGGER.debug("_collect_pulses_from_logs | %s | self._logs=None", self._mac)
             return None
@@ -236,7 +245,7 @@ def _collect_pulses_from_logs(
                 )
                 return None
             if from_timestamp > self._last_log_consumption_timestamp:
-                return 0
+                return (0, True)
         else:
             if self._last_log_production_timestamp is None:
                 _LOGGER.debug(
@@ -245,7 +254,7 @@ def _collect_pulses_from_logs(
                 )
                 return None
             if from_timestamp > self._last_log_production_timestamp:
-                return 0
+                return (0, True)
 
         missing_logs = self._logs_missing(from_timestamp)
         if missing_logs is None or missing_logs:
@@ -265,7 +274,7 @@ def _collect_pulses_from_logs(
                 ):
                     log_pulses += slot_item.pulses
 
-        return log_pulses
+        return (log_pulses, False)
 
     def update_pulse_counter(
         self, pulses_consumed: int, pulses_produced: int, timestamp: datetime