Call on_reconnect_callback. (#1959)

Author: janiversen

pymodbus/client/base.py

@@ -346,6 +346,7 @@ def __init__(  # pylint: disable=too-many-arguments
                 parity=kwargs.get("parity", None),
                 stopbits=kwargs.get("stopbits", None),
                 handle_local_echo=kwargs.get("handle_local_echo", False),
+                on_reconnect_callback = on_reconnect_callback,
             ),
             False,
         )
@@ -355,7 +356,6 @@ def __init__(  # pylint: disable=too-many-arguments
         self.params.close_comm_on_error = bool(close_comm_on_error)
         self.params.strict = bool(strict)
         self.params.broadcast_enable = bool(broadcast_enable)
-        self.on_reconnect_callback = on_reconnect_callback
         self.retry_on_empty: int = 0
         self.no_resend_on_retry = no_resend_on_retry
         self.slaves: list[int] = []

pymodbus/transport/transport.py

@@ -85,6 +85,7 @@ class CommParams:
     port: int = 0
     source_address: tuple[str, int] | None = None
     handle_local_echo: bool = False
+    on_reconnect_callback: Callable[[], None] | None = None
 
     # tls
     sslctx: ssl.SSLContext | None = None
@@ -467,6 +468,8 @@ async def do_reconnect(self) -> None:
                     self.reconnect_delay_current * 1000,
                 )
                 await asyncio.sleep(self.reconnect_delay_current)
+                if self.comm_params.on_reconnect_callback:
+                    self.comm_params.on_reconnect_callback()
                 if await self.transport_connect():
                     break
                 self.reconnect_delay_current = min(