normalize variable timing read intervals

Author: HotNoob

classes/protocol_settings.py

@@ -764,7 +764,7 @@ def process_row(row):
 
             return registry_map
 
-    def calculate_registry_ranges(self, map : list[registry_map_entry], max_register : int, init : bool = False) -> list[tuple]:
+    def calculate_registry_ranges(self, map : list[registry_map_entry], max_register : int, init : bool = False, timestamp: int = 0) -> list[tuple]:
 
         ''' read optimization; calculate which ranges to read'''
         max_batch_size = 45 #see manual; says max batch is 45
@@ -778,7 +778,10 @@ def calculate_registry_ranges(self, map : list[registry_map_entry], max_register
         start = -max_batch_size
         ranges : list[tuple] = []
 
-        timestamp_ms = int(time.time() * 1000)
+        if timestamp > 0:
+            timestamp_ms = timestamp*1000
+        else:
+            timestamp_ms = int(time.time() * 1000)
 
         while (start := start+max_batch_size) <= max_register:
 

classes/transports/modbus_base.py

@@ -175,7 +175,9 @@ def read_data(self) -> dict[str, str]:
                 continue
 
             #calculate ranges dynamically -- for variable read timing
-            ranges = self.protocolSettings.calculate_registry_ranges(self.protocolSettings.registry_map[registry_type], self.protocolSettings.registry_map_size[registry_type])
+            ranges = self.protocolSettings.calculate_registry_ranges(self.protocolSettings.registry_map[registry_type],
+                                                                     self.protocolSettings.registry_map_size[registry_type],
+                                                                     timestamp=self.last_read_time)
 
             registry = self.read_modbus_registers(ranges=ranges, registry_type=registry_type)
             new_info = self.protocolSettings.process_registery(registry, self.protocolSettings.get_registry_map(registry_type))