black2.

Author: janiversen

pymodbus/client/tcp.py

@@ -101,7 +101,7 @@ async def _connect(self):
         """Connect."""
         _logger.debug("Connecting.")
         try:
-            if self.params.host.startswith("unit:"):
+            if self.params.host.startswith("unix:"):
                 transport, protocol = await asyncio.wait_for(
                     self.loop.create_unit_connection(
                         self._create_protocol, path=self.params.host[5:]

test/test_unix_socket.py

@@ -5,7 +5,7 @@
 import pytest_asyncio
 
 from pymodbus import pymodbus_apply_logging_config
-# from pymodbus.client import AsyncModbusTcpClient
+from pymodbus.client import AsyncModbusTcpClient
 from pymodbus.datastore import (
     ModbusSequentialDataBlock,
     ModbusServerContext,
@@ -44,9 +44,6 @@ async def _helper_server():
 # async def run_client(test_comm, test_type, args=Commandline.copy()):
 #     """Help run async client."""
 #
-#     args.comm = test_comm
-#     if test_comm == "serial":
-#         args.port = f"socket://127.0.0.1:{args.port}"
 #     test_client = setup_async_client(args=args)
 #     if not test_type:
 #         await run_async_client(test_client)
@@ -62,9 +59,10 @@ async def test_unix_server(_mock_run_server):
 
 async def test_unix_async_client(_mock_run_server):
     """Run async client with unit domain socket."""
-    # client = AsyncModbusTcpClient(
-    #     HOST,
-    #     framer=ModbusSocketFramer,
-    # )
-
     await asyncio.sleep(0.1)
+    client = AsyncModbusTcpClient(
+        HOST,
+        framer=ModbusSocketFramer,
+    )
+    await client.connect()
+    assert client.connected