Remove loop from return of Modbus<Something>Client

TODO_pylint

@@ -62,7 +62,6 @@ try-except-raise
 unexpected-keyword-arg
 unnecessary-comprehension
 unnecessary-lambda
-unpacking-non-sequence
 unspecified-encoding
 unused-argument
 unused-import

examples/client_async.py

@@ -48,7 +48,7 @@ def setup_async_client(loop):
     _logger.info("### Create client object")
 
     if args.comm == "tcp":
-        loop, client = AsyncModbusTCPClient(  # pylint: disable=unpacking-non-sequence
+        client = AsyncModbusTCPClient(
             host="127.0.0.1",  # define tcp address where to connect to.
             port=args.port,  # on which port
             framer=ModbusSocketFramer,  # how to interpret the messages
@@ -60,7 +60,7 @@ def setup_async_client(loop):
             loop=loop,
         )
     elif args.comm == "udp":
-        loop, client = AsyncModbusUDPClient(  # pylint: disable=unpacking-non-sequence
+        client = AsyncModbusUDPClient(
             host="localhost",  # define tcp address where to connect to.
             port=args.port,  # on which port
             framer=args.framer,  # how to interpret the messages
@@ -72,7 +72,7 @@ def setup_async_client(loop):
             loop=loop,
         )
     elif args.comm == "serial":
-        loop, client = AsyncModbusSerialClient(  # pylint: disable=unpacking-non-sequence
+        client = AsyncModbusSerialClient(
             port=args.port,  # serial port
             framer=args.framer,  # how to interpret the messages
             stopbits=1,  # The number of stop bits to use
@@ -85,7 +85,7 @@ def setup_async_client(loop):
             loop=loop,
         )
     elif args.comm == "tls":
-        loop, client = AsyncModbusTLSClient(  # pylint: disable=unpacking-non-sequence
+        client = AsyncModbusTLSClient(
             host="localhost",  # define tcp address where to connect to.
             port=args.port,  # on which port
             sslctx=None,  # ssl control

examples/contrib/asynchronous_asyncio_modbus_tls_client.py

@@ -9,6 +9,7 @@
 # import necessary libraries
 # -------------------------------------------------------------------------- #
 import ssl
+import asyncio
 
 from pymodbus.client.asynchronous.tls import AsyncModbusTLSClient
 
@@ -37,10 +38,11 @@ async def start_async_test(client):
     # ----------------------------------------------------------------------- #
     # pass SSLContext which is the context here to ModbusTcpClient()
     # ----------------------------------------------------------------------- #
-    loop, new_client = AsyncModbusTLSClient(  # pylint: disable=unpacking-non-sequence
+    new_client = AsyncModbusTLSClient(  # pylint: disable=unpacking-non-sequence
         "test.host.com",
         8020,
         sslctx=sslctx,
     )
+    loop = asyncio.get_running_loop()
     loop.run_until_complete(start_async_test(new_client.protocol))
     loop.close()

pymodbus/client/asynchronous/async_io/__init__.py

@@ -18,6 +18,7 @@
     ModbusTlsFramer,
 )
 
+
 _logger = logging.getLogger(__name__)
 
 DGRAM_TYPE = socket.SOCK_DGRAM
@@ -236,7 +237,7 @@ def __init__(self, protocol_class=None, framer=None, **kwargs):
 
         :param protocol_class: Protocol used to talk to modbus device.
         """
-        # If there are no loop running a runtime error will be raised
+        # get current loop, if there are no loop a RuntimeError will be raised
         self.loop = asyncio.get_running_loop()
         #: Protocol used to talk to modbus device.
         self.protocol_class = protocol_class or ModbusClientProtocol
@@ -347,17 +348,15 @@ def __init__(self, host=None, port=502, protocol_class=None, framer=None, **kwar
         :param port: Port to connect
         :param protocol_class: Protocol used to talk to modbus device.
         """
-        # If there are no loop running a runtime error will be raised
+        # get current loop, if there are no loop a RuntimeError will be raised
         self.loop = asyncio.get_running_loop()
         #: Protocol used to talk to modbus device.
         self.protocol_class = protocol_class or ModbusClientProtocol
         #: Current protocol instance.
         self.protocol = None
         self.framer = framer if framer else ModbusSocketFramer
-
         self.host = host
         self.port = port
-
         self.connected = False
         self._proto_args = kwargs
 
@@ -422,7 +421,7 @@ def __init__(self, protocol_class=None, framer=None, **kwargs):
 
         :param protocol_class: Protocol used to talk to modbus device.
         """
-        # If there are no loop running a runtime error will be raised
+        # get current loop, if there are no loop a RuntimeError will be raised
         self.loop = asyncio.get_running_loop()
         self.framer = framer if framer else ModbusTlsFramer
         self.server_hostname = None
@@ -493,7 +492,7 @@ def __init__(self, protocol_class=None, framer=None, **kwargs):
 
         :param protocol_class: Protocol used to talk to modbus device.
         """
-        # If there are no loop running a runtime error will be raised
+        # get current loop, if there are no loop a RuntimeError will be raised
         self.loop = asyncio.get_running_loop()
         #: Protocol used to talk to modbus device.
         self.protocol_class = protocol_class or ModbusUdpClientProtocol
@@ -612,7 +611,7 @@ def __init__(self, host=None, port=502, protocol_class=None, framer=None, **kwar
         :param port: Port to connect
         :param protocol_class: Protocol used to talk to modbus device.
         """
-        # If there are no loop running a runtime error will be raised
+        # get current loop, if there are no loop a RuntimeError will be raised
         self.loop = asyncio.get_running_loop()
         #: Protocol used to talk to modbus device.
         self.protocol_class = protocol_class or ModbusUdpClientProtocol
@@ -711,7 +710,7 @@ def __init__(
         :param protocol_class: Protocol used to talk to modbus device.
         :param framer: Framer to use
         """
-        # If there are no loop running a runtime error will be raised
+        # get current loop, if there are no loop a RuntimeError will be raised
         self.loop = asyncio.get_running_loop()
         #: Protocol used to talk to modbus device.
         self.protocol_class = protocol_class or ModbusRtuFramer

pymodbus/client/asynchronous/factory/serial.py

@@ -34,4 +34,4 @@ def async_io_factory(port=None, framer=None, **kwargs):
         future = asyncio.run_coroutine_threadsafe(coro(), loop=loop)
         future.result()
 
-    return loop, client
+    return client

pymodbus/client/asynchronous/factory/tcp.py

@@ -37,4 +37,4 @@ def async_io_factory(host="127.0.0.1", port=Defaults.Port, **kwargs):
         future = asyncio.run_coroutine_threadsafe(cor, loop=loop)
         client = future.result()
 
-    return loop, client
+    return client

pymodbus/client/asynchronous/factory/tls.py

@@ -40,7 +40,7 @@ def async_io_factory(
         )
         client = loop.run_until_complete(asyncio.gather(cor))[0]
     elif loop is asyncio.get_event_loop():
-        return loop, init_tls_client(
+        return init_tls_client(
             proto_cls, host, port, sslctx, server_hostname, framer, **kwargs
         )
     else:
@@ -50,4 +50,4 @@ def async_io_factory(
         future = asyncio.run_coroutine_threadsafe(cor, loop=loop)
         client = future.result()
 
-    return loop, client
+    return client

pymodbus/client/asynchronous/factory/udp.py

@@ -28,10 +28,10 @@ def async_io_factory(host="127.0.0.1", port=Defaults.Port, **kwargs):
         cor = init_udp_client(proto_cls, host, port)
         client = loop.run_until_complete(asyncio.gather(cor))[0]
     elif loop is asyncio.get_event_loop():
-        return loop, init_udp_client(proto_cls, host, port)
+        return init_udp_client(proto_cls, host, port)
 
     cor = init_udp_client(proto_cls, host, port)
     client = asyncio.run_coroutine_threadsafe(cor, loop=loop)
     client = client.result()
 
-    return loop, client
+    return client

pymodbus/client/asynchronous/serial.py

@@ -1,13 +1,14 @@
 """SERIAL communication."""
 import logging
 
+from pymodbus.client.asynchronous.async_io import AsyncioModbusSerialClient as serialClient
 from pymodbus.client.asynchronous.factory.serial import async_io_factory
 from pymodbus.factory import ClientDecoder
 
 _logger = logging.getLogger(__name__)
 
 
-class AsyncModbusSerialClient:  # pylint: disable=too-few-public-methods
+class AsyncModbusSerialClient(serialClient):
     """Actual Async Serial Client to be used.
 
     To use do::

pymodbus/client/asynchronous/tcp.py

@@ -1,13 +1,14 @@
 """TCP communication."""
 import logging
 
+from pymodbus.client.asynchronous.async_io import ReconnectingAsyncioModbusTcpClient as tcpClient
 from pymodbus.client.asynchronous.factory.tcp import async_io_factory
 from pymodbus.constants import Defaults
 
 _logger = logging.getLogger(__name__)
 
 
-class AsyncModbusTCPClient:  # pylint: disable=too-few-public-methods
+class AsyncModbusTCPClient(tcpClient):
     """Actual Async Serial Client to be used.
 
     To use do::

pymodbus/client/asynchronous/tls.py

@@ -1,6 +1,7 @@
 """TLS communication."""
 import logging
 
+from pymodbus.client.asynchronous.async_io import ReconnectingAsyncioModbusTlsClient as TlsClient
 from pymodbus.client.asynchronous.factory.tls import async_io_factory
 from pymodbus.constants import Defaults
 from pymodbus.factory import ClientDecoder
@@ -9,7 +10,7 @@
 _logger = logging.getLogger(__name__)
 
 
-class AsyncModbusTLSClient:  # pylint: disable=too-few-public-methods
+class AsyncModbusTLSClient(TlsClient):
     """Actual Async TLS Client to be used.
 
     To use do::

pymodbus/client/asynchronous/udp.py

@@ -1,13 +1,14 @@
 """UDP communication."""
 import logging
 
+from pymodbus.client.asynchronous.async_io import ReconnectingAsyncioModbusUdpClient as udpClient
 from pymodbus.client.asynchronous.factory.udp import async_io_factory
 from pymodbus.constants import Defaults
 
 _logger = logging.getLogger(__name__)
 
 
-class AsyncModbusUDPClient:  # pylint: disable=too-few-public-methods
+class AsyncModbusUDPClient(udpClient):
     """Actual Async UDP Client to be used.
 
     To use do::

test/test_client_async.py

@@ -62,7 +62,7 @@ def test_tcp_asyncio_client(
 
     def test_tls_asyncio_client(self):
         """Test the TLS AsyncIO client."""
-        _, client = AsyncModbusTLSClient()  # pylint: disable=unpacking-non-sequence
+        client = AsyncModbusTLSClient()
         assert isinstance(client, ReconnectingAsyncioModbusTlsClient)  # nosec
         assert isinstance(client.framer, ModbusTlsFramer)  # nosec
         assert isinstance(client.sslctx, ssl.SSLContext)  # nosec
@@ -107,10 +107,7 @@ async def test_serial_asyncio_client(
         """Test that AsyncModbusSerialClient instantiates AsyncioModbusSerialClient for asyncio scheduler."""
         loop = asyncio.get_event_loop()
         loop.is_running.side_effect = lambda: False
-        (  # pylint: disable=unpacking-non-sequence
-            loop,
-            client,
-        ) = AsyncModbusSerialClient(
+        client = AsyncModbusSerialClient(
             framer=framer,
             port=pytest.SERIAL_PORT,
             loop=loop,

test/test_client_async2.py

@@ -50,7 +50,7 @@ class TestAsynchronousClient:
     # -----------------------------------------------------------------------#
     def test_tls_asyncio_client(self):
         """Test the TLS AsyncIO client."""
-        _, client = AsyncModbusTLSClient()  # pylint: disable=unpacking-non-sequence
+        client = AsyncModbusTLSClient()
         assert isinstance(client, ReconnectingAsyncioModbusTlsClient)  # nosec
         assert isinstance(client.framer, ModbusTlsFramer)  # nosec
         assert isinstance(client.sslctx, ssl.SSLContext)  # nosec
@@ -94,10 +94,7 @@ async def test_serial_asyncio_client(
         """Test that AsyncModbusSerialClient instantiates AsyncioModbusSerialClient for asyncio scheduler."""
         loop = asyncio.get_event_loop()
         loop.is_running.side_effect = lambda: False
-        (  # pylint: disable=unpacking-non-sequence
-            loop,
-            client,
-        ) = AsyncModbusSerialClient(
+        client = AsyncModbusSerialClient(
             framer=framer,
             port=pytest.SERIAL_PORT,
             loop=loop,

test/test_client_async_asyncio.py

@@ -93,9 +93,7 @@ async def test_factory_initialization_state(self):
 
     async def test_initialization_tcp_in_loop(self):
         """Test initialization tcp in loop."""
-        _, client = AsyncModbusTCPClient(  # pylint: disable=unpacking-non-sequence
-            port=5020,
-        )
+        client = AsyncModbusTCPClient(port=5020)
         client = await client
 
         assert not client.connected  # nosec
@@ -104,7 +102,7 @@ async def test_initialization_tcp_in_loop(self):
 
     async def test_initialization_udp_in_loop(self):
         """Test initialization udp in loop."""
-        _, client = AsyncModbusUDPClient()  # pylint: disable=unpacking-non-sequence
+        client = AsyncModbusUDPClient()
         client = await client
 
         assert client.connected  # nosec
@@ -113,7 +111,7 @@ async def test_initialization_udp_in_loop(self):
 
     async def test_initialization_tls_in_loop(self):
         """Test initialization tls in loop."""
-        _, client = AsyncModbusTLSClient()  # pylint: disable=unpacking-non-sequence
+        client = AsyncModbusTLSClient()
         client = await client
 
         assert not client.connected  # nosec
@@ -123,7 +121,7 @@ async def test_initialization_tls_in_loop(self):
     @pytest.mark.skip("To fix")
     def test_initialization_serial_in_loop(self):
         """Test initialization serial in loop."""
-        _, client = AsyncModbusSerialClient(  # pylint: disable=unpacking-non-sequence
+        client = AsyncModbusSerialClient(
             port="/tmp/ptyp0", baudrate=9600, framer=ModbusRtuFramer  # nosec
         )
         assert client.port == "/tmp/ptyp0"  # nosec