rename typing.py to custom_types.py for clarity

examples/chat/chat.py

@@ -7,15 +7,15 @@
 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

examples/echo/echo.py

@@ -9,15 +9,15 @@
 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")
 

examples/ping/ping.py

@@ -6,15 +6,15 @@
 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

libp2p/__init__.py

@@ -6,6 +6,9 @@
 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.upgrader import (
     TransportUpgrader,
 )
-from libp2p.typing import (
-    TProtocol,
-)
 
 
 def generate_new_rsa_identity() -> KeyPair:

libp2p/host/basic_host.py

@@ -16,6 +16,10 @@
     PrivateKey,
     PublicKey,
 )
+from libp2p.custom_types import (
+    StreamHandlerFn,
+    TProtocol,
+)
 from libp2p.host.defaults import (
     get_default_protocols,
 )
@@ -53,10 +57,6 @@
 from libp2p.tools.async_service import (
     background_trio_service,
 )
-from libp2p.typing import (
-    StreamHandlerFn,
-    TProtocol,
-)
 
 from .host_interface import (
     IHost,

libp2p/host/defaults.py

@@ -18,7 +18,7 @@
 from libp2p.identity.identify.protocol import ID as IdentifyID
 
 if TYPE_CHECKING:
-    from libp2p.typing import (
+    from libp2p.custom_types import (
         StreamHandlerFn,
         TProtocol,
     )

libp2p/host/host_interface.py

@@ -16,6 +16,10 @@
     PrivateKey,
     PublicKey,
 )
+from libp2p.custom_types import (
+    StreamHandlerFn,
+    TProtocol,
+)
 from libp2p.network.network_interface import (
     INetworkService,
 )
@@ -28,10 +32,6 @@
 from libp2p.peer.peerinfo import (
     PeerInfo,
 )
-from libp2p.typing import (
-    StreamHandlerFn,
-    TProtocol,
-)
 
 
 class IHost(ABC):

libp2p/host/ping.py

@@ -4,6 +4,9 @@
 
 import trio
 
+from libp2p.custom_types import (
+    TProtocol,
+)
 from libp2p.host.host_interface import (
     IHost,
 )
@@ -16,9 +19,6 @@
     INetStream,
 )
 from libp2p.peer.id import ID as PeerID
-from libp2p.typing import (
-    TProtocol,
-)
 
 ID = TProtocol("/ipfs/ping/1.0.0")
 PING_LENGTH = 32

libp2p/identity/identify/protocol.py

@@ -4,6 +4,10 @@
     Multiaddr,
 )
 
+from libp2p.custom_types import (
+    StreamHandlerFn,
+    TProtocol,
+)
 from libp2p.host.host_interface import (
     IHost,
 )
@@ -13,10 +17,6 @@
 from libp2p.network.stream.net_stream_interface import (
     INetStream,
 )
-from libp2p.typing import (
-    StreamHandlerFn,
-    TProtocol,
-)
 
 from .pb.identify_pb2 import (
     Identify,

libp2p/network/network_interface.py

@@ -13,6 +13,9 @@
     Multiaddr,
 )
 
+from libp2p.custom_types import (
+    StreamHandlerFn,
+)
 from libp2p.network.connection.net_connection_interface import (
     INetConn,
 )
@@ -28,9 +31,6 @@
 from libp2p.transport.listener_interface import (
     IListener,
 )
-from libp2p.typing import (
-    StreamHandlerFn,
-)
 
 from .stream.net_stream_interface import (
     INetStream,

libp2p/network/stream/net_stream.py

@@ -2,6 +2,9 @@
     Optional,
 )
 
+from libp2p.custom_types import (
+    TProtocol,
+)
 from libp2p.stream_muxer.abc import (
     IMuxedStream,
 )
@@ -10,9 +13,6 @@
     MuxedStreamEOF,
     MuxedStreamReset,
 )
-from libp2p.typing import (
-    TProtocol,
-)
 
 from .exceptions import (
     StreamClosed,

libp2p/network/stream/net_stream_interface.py

@@ -2,15 +2,15 @@
     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):

libp2p/network/swarm.py

@@ -8,6 +8,9 @@
 )
 import trio
 
+from libp2p.custom_types import (
+    StreamHandlerFn,
+)
 from libp2p.io.abc import (
     ReadWriteCloser,
 )
@@ -43,9 +46,6 @@
 from libp2p.transport.upgrader import (
     TransportUpgrader,
 )
-from libp2p.typing import (
-    StreamHandlerFn,
-)
 
 from ..exceptions import (
     MultiError,

libp2p/protocol_muxer/multiselect.py

@@ -1,4 +1,4 @@
-from libp2p.typing import (
+from libp2p.custom_types import (
     StreamHandlerFn,
     TProtocol,
 )

libp2p/protocol_muxer/multiselect_client.py

@@ -2,7 +2,7 @@
     Sequence,
 )
 
-from libp2p.typing import (
+from libp2p.custom_types import (
     TProtocol,
 )
 

libp2p/protocol_muxer/multiselect_client_interface.py

@@ -6,12 +6,12 @@
     Sequence,
 )
 
+from libp2p.custom_types import (
+    TProtocol,
+)
 from libp2p.protocol_muxer.multiselect_communicator_interface import (
     IMultiselectCommunicator,
 )
-from libp2p.typing import (
-    TProtocol,
-)
 
 
 class IMultiselectClient(ABC):

libp2p/protocol_muxer/multiselect_muxer_interface.py

@@ -3,7 +3,7 @@
     abstractmethod,
 )
 
-from libp2p.typing import (
+from libp2p.custom_types import (
     StreamHandlerFn,
     TProtocol,
 )

libp2p/pubsub/abc.py

@@ -11,15 +11,15 @@
     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,

libp2p/pubsub/floodsub.py

@@ -6,15 +6,15 @@
 
 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,
 )

libp2p/pubsub/gossipsub.py

@@ -17,6 +17,9 @@
 
 import trio
 
+from libp2p.custom_types import (
+    TProtocol,
+)
 from libp2p.network.stream.exceptions import (
     StreamClosed,
 )
@@ -29,9 +32,6 @@
 from libp2p.tools.async_service import (
     Service,
 )
-from libp2p.typing import (
-    TProtocol,
-)
 from libp2p.utils import (
     encode_varint_prefixed,
 )

libp2p/pubsub/pubsub.py

@@ -26,6 +26,9 @@
 from libp2p.crypto.keys import (
     PrivateKey,
 )
+from libp2p.custom_types import (
+    TProtocol,
+)
 from libp2p.exceptions import (
     ParseError,
     ValidationError,
@@ -53,9 +56,6 @@
 from libp2p.tools.async_service import (
     Service,
 )
-from libp2p.typing import (
-    TProtocol,
-)
 from libp2p.utils import (
     encode_varint_prefixed,
     read_varint_prefixed_bytes,

libp2p/security/insecure/transport.py

@@ -11,6 +11,9 @@
 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.secure_conn_interface import (
     ISecureConn,
 )
-from libp2p.typing import (
-    TProtocol,
-)
 
 from .pb import (
     plaintext_pb2,