style: isort fix ording of imports

This commit is contained in:
Luca Vivona
2025-06-20 16:01:11 -04:00
parent d03ca45bd8
commit 811c217ee6
6 changed files with 30 additions and 33 deletions

View File

@ -1,3 +1,7 @@
"""
Common Objects for Kademlia DHT implementation.
"""
from libp2p.custom_types import ( from libp2p.custom_types import (
TProtocol, TProtocol,
) )

View File

@ -31,6 +31,11 @@ from libp2p.tools.async_service import (
Service, Service,
) )
from .common import (
ALPHA,
PROTOCOL_ID,
QUERY_TIMEOUT,
)
from .pb.kademlia_pb2 import ( from .pb.kademlia_pb2 import (
Message, Message,
) )
@ -46,11 +51,6 @@ from .routing_table import (
from .value_store import ( from .value_store import (
ValueStore, ValueStore,
) )
from .common import (
PROTOCOL_ID,
ALPHA,
QUERY_TIMEOUT
)
logger = logging.getLogger("kademlia-example.kad_dht") logger = logging.getLogger("kademlia-example.kad_dht")
# logger = logging.getLogger("libp2p.kademlia") # logger = logging.getLogger("libp2p.kademlia")

View File

@ -22,17 +22,16 @@ from libp2p.peer.peerinfo import (
PeerInfo, PeerInfo,
) )
from .common import (
ALPHA,
PROTOCOL_ID,
)
from .pb.kademlia_pb2 import ( from .pb.kademlia_pb2 import (
Message, Message,
) )
from .routing_table import ( from .routing_table import (
RoutingTable, RoutingTable,
) )
from .common import (
PROTOCOL_ID,
ALPHA
)
from .utils import ( from .utils import (
sort_peer_ids_by_distance, sort_peer_ids_by_distance,
) )

View File

@ -29,16 +29,15 @@ from libp2p.peer.peerinfo import (
PeerInfo, PeerInfo,
) )
from .common import (
ALPHA,
PROTOCOL_ID,
QUERY_TIMEOUT,
)
from .pb.kademlia_pb2 import ( from .pb.kademlia_pb2 import (
Message, Message,
) )
from .common import (
PROTOCOL_ID,
ALPHA,
QUERY_TIMEOUT
)
# logger = logging.getLogger("libp2p.kademlia.provider_store") # logger = logging.getLogger("libp2p.kademlia.provider_store")
logger = logging.getLogger("kademlia-example.provider_store") logger = logging.getLogger("kademlia-example.provider_store")

View File

@ -2,21 +2,16 @@
Kademlia DHT routing table implementation. Kademlia DHT routing table implementation.
""" """
from collections import ( from collections import OrderedDict
OrderedDict,
)
import logging import logging
import time import time
import trio import trio
from libp2p.abc import ( from libp2p.abc import IHost
IHost, from libp2p.kad_dht.utils import (
xor_distance,
) )
from libp2p.custom_types import (
TProtocol,
)
from libp2p.kad_dht.utils import xor_distance
from libp2p.peer.id import ( from libp2p.peer.id import (
ID, ID,
) )
@ -24,9 +19,10 @@ from libp2p.peer.peerinfo import (
PeerInfo, PeerInfo,
) )
from .pb.kademlia_pb2 import ( from .common import (
Message, PROTOCOL_ID,
) )
from .pb.kademlia_pb2 import Message
# logger = logging.getLogger("libp2p.kademlia.routing_table") # logger = logging.getLogger("libp2p.kademlia.routing_table")
logger = logging.getLogger("kademlia-example.routing_table") logger = logging.getLogger("kademlia-example.routing_table")
@ -243,7 +239,7 @@ class KBucket:
raise ValueError(f"Peer {peer_id} not in bucket") raise ValueError(f"Peer {peer_id} not in bucket")
# Default protocol ID for Kademlia DHT # Default protocol ID for Kademlia DHT
protocol_id = TProtocol("/ipfs/kad/1.0.0") protocol_id = PROTOCOL_ID
try: try:
# Open a stream to the peer with the DHT protocol # Open a stream to the peer with the DHT protocol

View File

@ -19,15 +19,14 @@ from libp2p.peer.id import (
ID, ID,
) )
from .common import (
DEFAULT_TTL,
PROTOCOL_ID,
)
from .pb.kademlia_pb2 import ( from .pb.kademlia_pb2 import (
Message, Message,
) )
from .common import (
PROTOCOL_ID,
DEFAULT_TTL
)
# logger = logging.getLogger("libp2p.kademlia.value_store") # logger = logging.getLogger("libp2p.kademlia.value_store")
logger = logging.getLogger("kademlia-example.value_store") logger = logging.getLogger("kademlia-example.value_store")