From e7a9ee78a836f6d4379be03ebc4083b42b321653 Mon Sep 17 00:00:00 2001
From: pacrob <5199899+pacrob@users.noreply.github.com>
Date: Sun, 2 Feb 2025 07:04:36 -0700
Subject: [PATCH] rename typing.py to custom_types.py for clarity

---
 docs/libp2p.rst                                       | 6 +++---
 examples/chat/chat.py                                 | 6 +++---
 examples/echo/echo.py                                 | 6 +++---
 examples/ping/ping.py                                 | 6 +++---
 libp2p/__init__.py                                    | 6 +++---
 libp2p/{typing.py => custom_types.py}                 | 0
 libp2p/host/basic_host.py                             | 8 ++++----
 libp2p/host/defaults.py                               | 2 +-
 libp2p/host/host_interface.py                         | 8 ++++----
 libp2p/host/ping.py                                   | 6 +++---
 libp2p/identity/identify/protocol.py                  | 8 ++++----
 libp2p/network/network_interface.py                   | 6 +++---
 libp2p/network/stream/net_stream.py                   | 6 +++---
 libp2p/network/stream/net_stream_interface.py         | 6 +++---
 libp2p/network/swarm.py                               | 6 +++---
 libp2p/protocol_muxer/multiselect.py                  | 2 +-
 libp2p/protocol_muxer/multiselect_client.py           | 2 +-
 libp2p/protocol_muxer/multiselect_client_interface.py | 6 +++---
 libp2p/protocol_muxer/multiselect_muxer_interface.py  | 2 +-
 libp2p/pubsub/abc.py                                  | 6 +++---
 libp2p/pubsub/floodsub.py                             | 6 +++---
 libp2p/pubsub/gossipsub.py                            | 6 +++---
 libp2p/pubsub/pubsub.py                               | 6 +++---
 libp2p/security/insecure/transport.py                 | 6 +++---
 libp2p/security/noise/transport.py                    | 6 +++---
 libp2p/security/secio/transport.py                    | 6 +++---
 libp2p/security/security_multistream.py               | 6 +++---
 libp2p/stream_muxer/mplex/mplex.py                    | 6 +++---
 libp2p/stream_muxer/muxer_multistream.py              | 6 +++---
 libp2p/tools/factories.py                             | 6 +++---
 libp2p/transport/typing.py                            | 6 +++---
 newsfragments/500.internal.rst                        | 1 +
 tests/core/test_libp2p/test_libp2p.py                 | 6 +++---
 tests/interop/test_echo.py                            | 6 +++---
 tests/utils/interop/daemon.py                         | 6 +++---
 35 files changed, 95 insertions(+), 94 deletions(-)
 rename libp2p/{typing.py => custom_types.py} (100%)
 create mode 100644 newsfragments/500.internal.rst

diff --git a/docs/libp2p.rst b/docs/libp2p.rst
index 8aa68d46..c3153546 100644
--- a/docs/libp2p.rst
+++ b/docs/libp2p.rst
@@ -32,10 +32,10 @@ libp2p.exceptions module
    :undoc-members:
    :show-inheritance:
 
-libp2p.typing module
---------------------
+libp2p.custom_types module
+--------------------------
 
-.. automodule:: libp2p.typing
+.. automodule:: libp2p.custom_types
    :members:
    :undoc-members:
    :show-inheritance:
diff --git a/examples/chat/chat.py b/examples/chat/chat.py
index 2b390a54..048d1e3d 100755
--- a/examples/chat/chat.py
+++ b/examples/chat/chat.py
@@ -7,15 +7,15 @@ import trio
 from libp2p import (
     new_host,
 )
+from libp2p.custom_types import (
+    TProtocol,
+)
 from libp2p.network.stream.net_stream_interface import (
     INetStream,
 )
 from libp2p.peer.peerinfo import (
     info_from_p2p_addr,
 )
-from libp2p.typing import (
-    TProtocol,
-)
 
 PROTOCOL_ID = TProtocol("/chat/1.0.0")
 MAX_READ_LEN = 2**32 - 1
diff --git a/examples/echo/echo.py b/examples/echo/echo.py
index 24be3b16..331a8309 100644
--- a/examples/echo/echo.py
+++ b/examples/echo/echo.py
@@ -9,15 +9,15 @@ from libp2p import (
 from libp2p.crypto.secp256k1 import (
     create_new_key_pair,
 )
+from libp2p.custom_types import (
+    TProtocol,
+)
 from libp2p.network.stream.net_stream_interface import (
     INetStream,
 )
 from libp2p.peer.peerinfo import (
     info_from_p2p_addr,
 )
-from libp2p.typing import (
-    TProtocol,
-)
 
 PROTOCOL_ID = TProtocol("/echo/1.0.0")
 
diff --git a/examples/ping/ping.py b/examples/ping/ping.py
index 778deba0..a6690dbd 100644
--- a/examples/ping/ping.py
+++ b/examples/ping/ping.py
@@ -6,15 +6,15 @@ import trio
 from libp2p import (
     new_host,
 )
+from libp2p.custom_types import (
+    TProtocol,
+)
 from libp2p.network.stream.net_stream_interface import (
     INetStream,
 )
 from libp2p.peer.peerinfo import (
     info_from_p2p_addr,
 )
-from libp2p.typing import (
-    TProtocol,
-)
 
 PING_PROTOCOL_ID = TProtocol("/ipfs/ping/1.0.0")
 PING_LENGTH = 32
diff --git a/libp2p/__init__.py b/libp2p/__init__.py
index 73912d4f..0bd528ba 100644
--- a/libp2p/__init__.py
+++ b/libp2p/__init__.py
@@ -6,6 +6,9 @@ from libp2p.crypto.keys import (
 from libp2p.crypto.rsa import (
     create_new_key_pair,
 )
+from libp2p.custom_types import (
+    TProtocol,
+)
 from libp2p.host.basic_host import (
     BasicHost,
 )
@@ -52,9 +55,6 @@ from libp2p.transport.typing import (
 from libp2p.transport.upgrader import (
     TransportUpgrader,
 )
-from libp2p.typing import (
-    TProtocol,
-)
 
 
 def generate_new_rsa_identity() -> KeyPair:
diff --git a/libp2p/typing.py b/libp2p/custom_types.py
similarity index 100%
rename from libp2p/typing.py
rename to libp2p/custom_types.py
diff --git a/libp2p/host/basic_host.py b/libp2p/host/basic_host.py
index d513e106..fff4124c 100644
--- a/libp2p/host/basic_host.py
+++ b/libp2p/host/basic_host.py
@@ -16,6 +16,10 @@ from libp2p.crypto.keys import (
     PrivateKey,
     PublicKey,
 )
+from libp2p.custom_types import (
+    StreamHandlerFn,
+    TProtocol,
+)
 from libp2p.host.defaults import (
     get_default_protocols,
 )
@@ -53,10 +57,6 @@ from libp2p.protocol_muxer.multiselect_communicator import (
 from libp2p.tools.async_service import (
     background_trio_service,
 )
-from libp2p.typing import (
-    StreamHandlerFn,
-    TProtocol,
-)
 
 from .host_interface import (
     IHost,
diff --git a/libp2p/host/defaults.py b/libp2p/host/defaults.py
index cfc95e76..624c71f8 100644
--- a/libp2p/host/defaults.py
+++ b/libp2p/host/defaults.py
@@ -18,7 +18,7 @@ from libp2p.identity.identify.protocol import (
 from libp2p.identity.identify.protocol import ID as IdentifyID
 
 if TYPE_CHECKING:
-    from libp2p.typing import (
+    from libp2p.custom_types import (
         StreamHandlerFn,
         TProtocol,
     )
diff --git a/libp2p/host/host_interface.py b/libp2p/host/host_interface.py
index e0258551..00b83303 100644
--- a/libp2p/host/host_interface.py
+++ b/libp2p/host/host_interface.py
@@ -16,6 +16,10 @@ from libp2p.crypto.keys import (
     PrivateKey,
     PublicKey,
 )
+from libp2p.custom_types import (
+    StreamHandlerFn,
+    TProtocol,
+)
 from libp2p.network.network_interface import (
     INetworkService,
 )
@@ -28,10 +32,6 @@ from libp2p.peer.id import (
 from libp2p.peer.peerinfo import (
     PeerInfo,
 )
-from libp2p.typing import (
-    StreamHandlerFn,
-    TProtocol,
-)
 
 
 class IHost(ABC):
diff --git a/libp2p/host/ping.py b/libp2p/host/ping.py
index 330d71c4..e1906146 100644
--- a/libp2p/host/ping.py
+++ b/libp2p/host/ping.py
@@ -4,6 +4,9 @@ import time
 
 import trio
 
+from libp2p.custom_types import (
+    TProtocol,
+)
 from libp2p.host.host_interface import (
     IHost,
 )
@@ -16,9 +19,6 @@ from libp2p.network.stream.net_stream_interface import (
     INetStream,
 )
 from libp2p.peer.id import ID as PeerID
-from libp2p.typing import (
-    TProtocol,
-)
 
 ID = TProtocol("/ipfs/ping/1.0.0")
 PING_LENGTH = 32
diff --git a/libp2p/identity/identify/protocol.py b/libp2p/identity/identify/protocol.py
index db203e7e..3bf6ae1f 100644
--- a/libp2p/identity/identify/protocol.py
+++ b/libp2p/identity/identify/protocol.py
@@ -4,6 +4,10 @@ from multiaddr import (
     Multiaddr,
 )
 
+from libp2p.custom_types import (
+    StreamHandlerFn,
+    TProtocol,
+)
 from libp2p.host.host_interface import (
     IHost,
 )
@@ -13,10 +17,6 @@ from libp2p.network.stream.exceptions import (
 from libp2p.network.stream.net_stream_interface import (
     INetStream,
 )
-from libp2p.typing import (
-    StreamHandlerFn,
-    TProtocol,
-)
 
 from .pb.identify_pb2 import (
     Identify,
diff --git a/libp2p/network/network_interface.py b/libp2p/network/network_interface.py
index 08bbbbd4..6f97f71a 100644
--- a/libp2p/network/network_interface.py
+++ b/libp2p/network/network_interface.py
@@ -13,6 +13,9 @@ from multiaddr import (
     Multiaddr,
 )
 
+from libp2p.custom_types import (
+    StreamHandlerFn,
+)
 from libp2p.network.connection.net_connection_interface import (
     INetConn,
 )
@@ -28,9 +31,6 @@ from libp2p.tools.async_service import (
 from libp2p.transport.listener_interface import (
     IListener,
 )
-from libp2p.typing import (
-    StreamHandlerFn,
-)
 
 from .stream.net_stream_interface import (
     INetStream,
diff --git a/libp2p/network/stream/net_stream.py b/libp2p/network/stream/net_stream.py
index 8b99cca0..90d4c55c 100644
--- a/libp2p/network/stream/net_stream.py
+++ b/libp2p/network/stream/net_stream.py
@@ -2,6 +2,9 @@ from typing import (
     Optional,
 )
 
+from libp2p.custom_types import (
+    TProtocol,
+)
 from libp2p.stream_muxer.abc import (
     IMuxedStream,
 )
@@ -10,9 +13,6 @@ from libp2p.stream_muxer.exceptions import (
     MuxedStreamEOF,
     MuxedStreamReset,
 )
-from libp2p.typing import (
-    TProtocol,
-)
 
 from .exceptions import (
     StreamClosed,
diff --git a/libp2p/network/stream/net_stream_interface.py b/libp2p/network/stream/net_stream_interface.py
index 4662cbee..ceaede3a 100644
--- a/libp2p/network/stream/net_stream_interface.py
+++ b/libp2p/network/stream/net_stream_interface.py
@@ -2,15 +2,15 @@ from abc import (
     abstractmethod,
 )
 
+from libp2p.custom_types import (
+    TProtocol,
+)
 from libp2p.io.abc import (
     ReadWriteCloser,
 )
 from libp2p.stream_muxer.abc import (
     IMuxedConn,
 )
-from libp2p.typing import (
-    TProtocol,
-)
 
 
 class INetStream(ReadWriteCloser):
diff --git a/libp2p/network/swarm.py b/libp2p/network/swarm.py
index 0e925827..647a073a 100644
--- a/libp2p/network/swarm.py
+++ b/libp2p/network/swarm.py
@@ -8,6 +8,9 @@ from multiaddr import (
 )
 import trio
 
+from libp2p.custom_types import (
+    StreamHandlerFn,
+)
 from libp2p.io.abc import (
     ReadWriteCloser,
 )
@@ -43,9 +46,6 @@ from libp2p.transport.transport_interface import (
 from libp2p.transport.upgrader import (
     TransportUpgrader,
 )
-from libp2p.typing import (
-    StreamHandlerFn,
-)
 
 from ..exceptions import (
     MultiError,
diff --git a/libp2p/protocol_muxer/multiselect.py b/libp2p/protocol_muxer/multiselect.py
index a582ff27..69ea2754 100644
--- a/libp2p/protocol_muxer/multiselect.py
+++ b/libp2p/protocol_muxer/multiselect.py
@@ -1,4 +1,4 @@
-from libp2p.typing import (
+from libp2p.custom_types import (
     StreamHandlerFn,
     TProtocol,
 )
diff --git a/libp2p/protocol_muxer/multiselect_client.py b/libp2p/protocol_muxer/multiselect_client.py
index d4ce7d38..d8806521 100644
--- a/libp2p/protocol_muxer/multiselect_client.py
+++ b/libp2p/protocol_muxer/multiselect_client.py
@@ -2,7 +2,7 @@ from collections.abc import (
     Sequence,
 )
 
-from libp2p.typing import (
+from libp2p.custom_types import (
     TProtocol,
 )
 
diff --git a/libp2p/protocol_muxer/multiselect_client_interface.py b/libp2p/protocol_muxer/multiselect_client_interface.py
index b539ea82..180aa4f6 100644
--- a/libp2p/protocol_muxer/multiselect_client_interface.py
+++ b/libp2p/protocol_muxer/multiselect_client_interface.py
@@ -6,12 +6,12 @@ from collections.abc import (
     Sequence,
 )
 
+from libp2p.custom_types import (
+    TProtocol,
+)
 from libp2p.protocol_muxer.multiselect_communicator_interface import (
     IMultiselectCommunicator,
 )
-from libp2p.typing import (
-    TProtocol,
-)
 
 
 class IMultiselectClient(ABC):
diff --git a/libp2p/protocol_muxer/multiselect_muxer_interface.py b/libp2p/protocol_muxer/multiselect_muxer_interface.py
index e3a952dc..f0ecf063 100644
--- a/libp2p/protocol_muxer/multiselect_muxer_interface.py
+++ b/libp2p/protocol_muxer/multiselect_muxer_interface.py
@@ -3,7 +3,7 @@ from abc import (
     abstractmethod,
 )
 
-from libp2p.typing import (
+from libp2p.custom_types import (
     StreamHandlerFn,
     TProtocol,
 )
diff --git a/libp2p/pubsub/abc.py b/libp2p/pubsub/abc.py
index 3ca4874c..8d6ba44b 100644
--- a/libp2p/pubsub/abc.py
+++ b/libp2p/pubsub/abc.py
@@ -11,15 +11,15 @@ from typing import (
     AsyncContextManager,
 )
 
+from libp2p.custom_types import (
+    TProtocol,
+)
 from libp2p.peer.id import (
     ID,
 )
 from libp2p.tools.async_service import (
     ServiceAPI,
 )
-from libp2p.typing import (
-    TProtocol,
-)
 
 from .pb import (
     rpc_pb2,
diff --git a/libp2p/pubsub/floodsub.py b/libp2p/pubsub/floodsub.py
index 5b805550..d99be87b 100644
--- a/libp2p/pubsub/floodsub.py
+++ b/libp2p/pubsub/floodsub.py
@@ -6,15 +6,15 @@ import logging
 
 import trio
 
+from libp2p.custom_types import (
+    TProtocol,
+)
 from libp2p.network.stream.exceptions import (
     StreamClosed,
 )
 from libp2p.peer.id import (
     ID,
 )
-from libp2p.typing import (
-    TProtocol,
-)
 from libp2p.utils import (
     encode_varint_prefixed,
 )
diff --git a/libp2p/pubsub/gossipsub.py b/libp2p/pubsub/gossipsub.py
index de7a36b0..f23040f6 100644
--- a/libp2p/pubsub/gossipsub.py
+++ b/libp2p/pubsub/gossipsub.py
@@ -17,6 +17,9 @@ from typing import (
 
 import trio
 
+from libp2p.custom_types import (
+    TProtocol,
+)
 from libp2p.network.stream.exceptions import (
     StreamClosed,
 )
@@ -29,9 +32,6 @@ from libp2p.pubsub import (
 from libp2p.tools.async_service import (
     Service,
 )
-from libp2p.typing import (
-    TProtocol,
-)
 from libp2p.utils import (
     encode_varint_prefixed,
 )
diff --git a/libp2p/pubsub/pubsub.py b/libp2p/pubsub/pubsub.py
index 4ce7b586..1b1fe19f 100644
--- a/libp2p/pubsub/pubsub.py
+++ b/libp2p/pubsub/pubsub.py
@@ -26,6 +26,9 @@ import trio
 from libp2p.crypto.keys import (
     PrivateKey,
 )
+from libp2p.custom_types import (
+    TProtocol,
+)
 from libp2p.exceptions import (
     ParseError,
     ValidationError,
@@ -53,9 +56,6 @@ from libp2p.peer.id import (
 from libp2p.tools.async_service import (
     Service,
 )
-from libp2p.typing import (
-    TProtocol,
-)
 from libp2p.utils import (
     encode_varint_prefixed,
     read_varint_prefixed_bytes,
diff --git a/libp2p/security/insecure/transport.py b/libp2p/security/insecure/transport.py
index a2380a33..a60b3a61 100644
--- a/libp2p/security/insecure/transport.py
+++ b/libp2p/security/insecure/transport.py
@@ -11,6 +11,9 @@ from libp2p.crypto.pb import (
 from libp2p.crypto.serialization import (
     deserialize_public_key,
 )
+from libp2p.custom_types import (
+    TProtocol,
+)
 from libp2p.io.abc import (
     ReadWriteCloser,
 )
@@ -38,9 +41,6 @@ from libp2p.security.exceptions import (
 from libp2p.security.secure_conn_interface import (
     ISecureConn,
 )
-from libp2p.typing import (
-    TProtocol,
-)
 
 from .pb import (
     plaintext_pb2,
diff --git a/libp2p/security/noise/transport.py b/libp2p/security/noise/transport.py
index ffe927ca..d335d438 100644
--- a/libp2p/security/noise/transport.py
+++ b/libp2p/security/noise/transport.py
@@ -2,6 +2,9 @@ from libp2p.crypto.keys import (
     KeyPair,
     PrivateKey,
 )
+from libp2p.custom_types import (
+    TProtocol,
+)
 from libp2p.network.connection.raw_connection_interface import (
     IRawConnection,
 )
@@ -14,9 +17,6 @@ from libp2p.security.secure_conn_interface import (
 from libp2p.security.secure_transport_interface import (
     ISecureTransport,
 )
-from libp2p.typing import (
-    TProtocol,
-)
 
 from .patterns import (
     IPattern,
diff --git a/libp2p/security/secio/transport.py b/libp2p/security/secio/transport.py
index 32cefc27..ac328698 100644
--- a/libp2p/security/secio/transport.py
+++ b/libp2p/security/secio/transport.py
@@ -34,6 +34,9 @@ from libp2p.crypto.keys import (
 from libp2p.crypto.serialization import (
     deserialize_public_key,
 )
+from libp2p.custom_types import (
+    TProtocol,
+)
 from libp2p.io.abc import (
     EncryptedMsgReadWriter,
 )
@@ -57,9 +60,6 @@ from libp2p.security.secure_conn_interface import (
 from libp2p.security.secure_session import (
     SecureSession,
 )
-from libp2p.typing import (
-    TProtocol,
-)
 
 from .exceptions import (
     IncompatibleChoices,
diff --git a/libp2p/security/security_multistream.py b/libp2p/security/security_multistream.py
index 046846ca..3f708b99 100644
--- a/libp2p/security/security_multistream.py
+++ b/libp2p/security/security_multistream.py
@@ -5,6 +5,9 @@ from collections import (
     OrderedDict,
 )
 
+from libp2p.custom_types import (
+    TProtocol,
+)
 from libp2p.network.connection.raw_connection_interface import (
     IRawConnection,
 )
@@ -29,9 +32,6 @@ from libp2p.security.secure_transport_interface import (
 from libp2p.transport.typing import (
     TSecurityOptions,
 )
-from libp2p.typing import (
-    TProtocol,
-)
 
 """
 Represents a secured connection object, which includes a connection and details about
diff --git a/libp2p/stream_muxer/mplex/mplex.py b/libp2p/stream_muxer/mplex/mplex.py
index d675ce09..b63b0dc7 100644
--- a/libp2p/stream_muxer/mplex/mplex.py
+++ b/libp2p/stream_muxer/mplex/mplex.py
@@ -5,6 +5,9 @@ from typing import (
 
 import trio
 
+from libp2p.custom_types import (
+    TProtocol,
+)
 from libp2p.exceptions import (
     ParseError,
 )
@@ -24,9 +27,6 @@ from libp2p.stream_muxer.abc import (
     IMuxedConn,
     IMuxedStream,
 )
-from libp2p.typing import (
-    TProtocol,
-)
 from libp2p.utils import (
     decode_uvarint_from_stream,
     encode_uvarint,
diff --git a/libp2p/stream_muxer/muxer_multistream.py b/libp2p/stream_muxer/muxer_multistream.py
index 5cadc568..13e7e301 100644
--- a/libp2p/stream_muxer/muxer_multistream.py
+++ b/libp2p/stream_muxer/muxer_multistream.py
@@ -2,6 +2,9 @@ from collections import (
     OrderedDict,
 )
 
+from libp2p.custom_types import (
+    TProtocol,
+)
 from libp2p.network.connection.raw_connection_interface import (
     IRawConnection,
 )
@@ -24,9 +27,6 @@ from libp2p.transport.typing import (
     TMuxerClass,
     TMuxerOptions,
 )
-from libp2p.typing import (
-    TProtocol,
-)
 
 from .abc import (
     IMuxedConn,
diff --git a/libp2p/tools/factories.py b/libp2p/tools/factories.py
index bdf055c6..795870a8 100644
--- a/libp2p/tools/factories.py
+++ b/libp2p/tools/factories.py
@@ -28,6 +28,9 @@ from libp2p.crypto.keys import (
     PrivateKey,
 )
 from libp2p.crypto.secp256k1 import create_new_key_pair as create_secp256k1_key_pair
+from libp2p.custom_types import (
+    TProtocol,
+)
 from libp2p.host.basic_host import (
     BasicHost,
 )
@@ -121,9 +124,6 @@ from libp2p.transport.typing import (
 from libp2p.transport.upgrader import (
     TransportUpgrader,
 )
-from libp2p.typing import (
-    TProtocol,
-)
 
 from .constants import (
     FLOODSUB_PROTOCOL_ID,
diff --git a/libp2p/transport/typing.py b/libp2p/transport/typing.py
index c6ed7427..71d8c256 100644
--- a/libp2p/transport/typing.py
+++ b/libp2p/transport/typing.py
@@ -6,6 +6,9 @@ from typing import (
     Callable,
 )
 
+from libp2p.custom_types import (
+    TProtocol,
+)
 from libp2p.io.abc import (
     ReadWriteCloser,
 )
@@ -15,9 +18,6 @@ from libp2p.security.secure_transport_interface import (
 from libp2p.stream_muxer.abc import (
     IMuxedConn,
 )
-from libp2p.typing import (
-    TProtocol,
-)
 
 THandler = Callable[[ReadWriteCloser], Awaitable[None]]
 TSecurityOptions = Mapping[TProtocol, ISecureTransport]
diff --git a/newsfragments/500.internal.rst b/newsfragments/500.internal.rst
new file mode 100644
index 00000000..da8204d3
--- /dev/null
+++ b/newsfragments/500.internal.rst
@@ -0,0 +1 @@
+Rename ``typing.py`` to ``custom_types.py`` for clarity.
diff --git a/tests/core/test_libp2p/test_libp2p.py b/tests/core/test_libp2p/test_libp2p.py
index 235cd119..0025f878 100644
--- a/tests/core/test_libp2p/test_libp2p.py
+++ b/tests/core/test_libp2p/test_libp2p.py
@@ -1,6 +1,9 @@
 import pytest
 import multiaddr
 
+from libp2p.custom_types import (
+    TProtocol,
+)
 from libp2p.network.stream.exceptions import (
     StreamError,
 )
@@ -14,9 +17,6 @@ from libp2p.tools.utils import (
     connect,
     create_echo_stream_handler,
 )
-from libp2p.typing import (
-    TProtocol,
-)
 
 PROTOCOL_ID_0 = TProtocol("/echo/0")
 PROTOCOL_ID_1 = TProtocol("/echo/1")
diff --git a/tests/interop/test_echo.py b/tests/interop/test_echo.py
index 7fe09426..d630dc5f 100644
--- a/tests/interop/test_echo.py
+++ b/tests/interop/test_echo.py
@@ -9,6 +9,9 @@ from p2pclient.utils import (
 )
 import trio
 
+from libp2p.custom_types import (
+    TProtocol,
+)
 from libp2p.peer.peerinfo import (
     PeerInfo,
     info_from_p2p_addr,
@@ -16,9 +19,6 @@ from libp2p.peer.peerinfo import (
 from libp2p.tools.factories import (
     HostFactory,
 )
-from libp2p.typing import (
-    TProtocol,
-)
 from tests.utils.interop.envs import (
     GO_BIN_PATH,
 )
diff --git a/tests/utils/interop/daemon.py b/tests/utils/interop/daemon.py
index 77108065..e55aba9f 100644
--- a/tests/utils/interop/daemon.py
+++ b/tests/utils/interop/daemon.py
@@ -14,6 +14,9 @@ from p2pclient import (
 )
 import trio
 
+from libp2p.custom_types import (
+    TProtocol,
+)
 from libp2p.peer.id import (
     ID,
 )
@@ -23,9 +26,6 @@ from libp2p.peer.peerinfo import (
 )
 from libp2p.security.noise.transport import PROTOCOL_ID as NOISE_PROTOCOL_ID
 from libp2p.security.secio.transport import ID as SECIO_PROTOCOL_ID
-from libp2p.typing import (
-    TProtocol,
-)
 
 from .constants import (
     LOCALHOST_IP,