py<->rust PING INTEROP successfull

Author: lla-dane

docs/conf.py

@@ -290,7 +290,7 @@
 ]
 
 # Prevent autodoc from trying to import module from tests.factories
-autodoc_mock_imports = ["tests.factories"]
+autodoc_mock_imports = ["tests.factories", "redis"]
 
 # Documents to append as an appendix to all manuals.
 # texinfo_appendices = []

docs/index.rst

@@ -18,6 +18,7 @@ The Python implementation of the libp2p networking stack
 
     Examples <examples>
     API <libp2p>
+    Interop <interop>
 
 .. toctree::
     :maxdepth: 1

docs/interop.rst

@@ -0,0 +1,29 @@
+interop package
+===============
+
+Submodules
+----------
+
+interop.arch module
+-------------------
+
+.. automodule:: interop.arch
+   :members:
+   :show-inheritance:
+   :undoc-members:
+
+interop.lib module
+------------------
+
+.. automodule:: interop.lib
+   :members:
+   :show-inheritance:
+   :undoc-members:
+
+Module contents
+---------------
+
+.. automodule:: interop
+   :members:
+   :show-inheritance:
+   :undoc-members:

examples/ping/ping.py

@@ -1,4 +1,5 @@
 import argparse
+import logging
 
 import multiaddr
 import trio
@@ -55,8 +56,8 @@ async def send_ping(stream: INetStream) -> None:
 
 
 async def run(port: int, destination: str) -> None:
-    listen_addr = multiaddr.Multiaddr(f"/ip4/0.0.0.0/tcp/{port}")
-    host = new_host(listen_addrs=[listen_addr])
+    listen_addr = multiaddr.Multiaddr(f"/ip4/127.0.0.1/tcp/{port}")
+    host = new_host()
 
     async with host.run(listen_addrs=[listen_addr]), trio.open_nursery() as nursery:
         if not destination:
@@ -103,8 +104,20 @@ def main() -> None:
         type=str,
         help=f"destination multiaddr string, e.g. {example_maddr}",
     )
+    parser.add_argument(
+        "-v", "--verbose", action="store_true", help="enable verbose logging"
+    )
+
     args = parser.parse_args()
 
+    if args.verbose:
+        # Enable even more detailed logging
+        logging.getLogger("libp2p").setLevel(logging.DEBUG)
+        logging.getLogger("libp2p.network").setLevel(logging.DEBUG)
+        logging.getLogger("libp2p.transport").setLevel(logging.DEBUG)
+        logging.getLogger("libp2p.security").setLevel(logging.DEBUG)
+        logging.getLogger("libp2p.stream_muxer").setLevel(logging.DEBUG)
+
     try:
         trio.run(run, *(args.port, args.destination))
     except KeyboardInterrupt:

libp2p/stream_muxer/yamux/yamux.py

@@ -31,6 +31,7 @@ dependencies = [
     "trio-typing>=0.0.4",
     "trio>=0.26.0",
     "fastecdsa==2.3.2; sys_platform != 'win32'",
+    "cryptography>=42.0.0; sys_platform == 'win32'",    # Alternative for Windows
     "zeroconf (>=0.147.0,<0.148.0)",
 ]
 classifiers = [
@@ -79,6 +80,7 @@ dev = [
     "factory-boy>=2.12.0,<3.0.0",
     "ruff>=0.11.10",
     "pyrefly (>=0.17.1,<0.18.0)",
+    "pytest-timeout"
 ]
 docs = [
     "sphinx>=6.0.0",
@@ -93,6 +95,7 @@ test = [
     "pytest-xdist>=2.4.0",
     "pytest-trio>=0.5.2",
     "factory-boy>=2.12.0,<3.0.0",
+    "pytest-timeout",
 ]
 
 [tool.setuptools]

pyproject.toml

@@ -51,6 +51,11 @@ async def read(self, n: int | None = None) -> bytes:
             data = await self.receive_stream.receive_some(n)
             logging.debug(f"Read {len(data)} bytes")
             return data
+        # Raise IncompleteReadError on timeout to simulate connection closed
+        logging.debug("Read timed out after 2 seconds, raising IncompleteReadError")
+        from libp2p.io.exceptions import IncompleteReadError
+
+        raise IncompleteReadError({"requested_count": n, "received_count": 0})
 
     async def close(self) -> None:
         logging.debug("Closing stream")

tests/core/stream_muxer/test_yamux.py

@@ -63,13 +63,14 @@ deps=
     wheel
     build[virtualenv]
 allowlist_externals=
-    bash.exe
+    cmd.exe
 commands=
     python --version
     python -m pip install --upgrade pip
-    bash.exe -c "rm -rf build dist"
+    cmd.exe /c "if exist build rd /s /q build"
+    cmd.exe /c "if exist dist rd /s /q dist"
     python -m build
-    bash.exe -c 'python -m pip install --upgrade "$(ls dist/libp2p-*-py3-none-any.whl)" --progress-bar off'
+    cmd.exe /c "for %i in (dist\libp2p-*-py3-none-any.whl) do python -m pip install --upgrade "%i" --progress-bar off"
     python -c "import libp2p"
 skip_install=true