fix multi transport support on one devceice

Author: HotNoob

classes/transports/modbus_base.py

@@ -12,9 +12,20 @@
 from typing import TYPE_CHECKING
 if TYPE_CHECKING:
     from configparser import SectionProxy
+    try:
+        from pymodbus.client.sync import BaseModbusClient
+    except ImportError:
+        from pymodbus.client import BaseModbusClient
+
 
 class modbus_base(transport_base):
 
+
+    #this is specifically static
+    clients : dict[str, BaseModbusClient] = []
+    ''' str is identifier, dict of clients when multiple transports use the same ports '''
+
+    #non-static here for reference, type hinting, python bs ect... 
     modbus_delay_increament : float = 0.05 
     ''' delay adjustment every error. todo: add a setting for this '''
 

classes/transports/modbus_rtu.py

@@ -54,6 +54,12 @@ def __init__(self, settings : SectionProxy, protocolSettings : protocol_settings
         # Get the signature of the __init__ method
         init_signature = inspect.signature(ModbusSerialClient.__init__)
 
+        client_str = self.port+"("+self.baudrate+")"
+
+        if client_str in modbus_base.clients:
+            self.client = modbus_base.clients[client_str]
+            return
+        
         if 'method' in init_signature.parameters:
             self.client = ModbusSerialClient(method='rtu', port=self.port, 
                                         baudrate=int(self.baudrate), 
@@ -64,6 +70,9 @@ def __init__(self, settings : SectionProxy, protocolSettings : protocol_settings
                             baudrate=int(self.baudrate), 
                             stopbits=1, parity='N', bytesize=8, timeout=2
                             )
+            
+        #add to clients
+        self.clients[client_str] = self.client
 
     def read_registers(self, start, count=1, registry_type : Registry_Type = Registry_Type.INPUT, **kwargs):
 

classes/transports/modbus_tcp.py

@@ -33,7 +33,17 @@ def __init__(self, settings : SectionProxy, protocolSettings : protocol_settings
         if 'slave' in inspect.signature(ModbusTcpClient.read_holding_registers).parameters:
             self.pymodbus_slave_arg = 'slave'
 
+        client_str = self.host+"("+self.port+")"
+        #check if client is already initialied
+        if client_str in modbus_base.clients:
+            self.client = modbus_base.clients[client_str]
+            return
+
         self.client = ModbusTcpClient(host=self.host, port=self.port, timeout=7, retries=3)
+
+        #add to clients
+        self.clients[client_str] = self.client
+        
         super().__init__(settings, protocolSettings=protocolSettings)
 
     def read_registers(self, start, count=1, registry_type : Registry_Type = Registry_Type.INPUT, **kwargs):