Skip to content

Commit 811c217

Browse files
committed
style: isort fix ording of imports
1 parent d03ca45 commit 811c217

File tree

6 files changed

+30
-33
lines changed

6 files changed

+30
-33
lines changed

libp2p/kad_dht/common.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,7 @@
1+
"""
2+
Common Objects for Kademlia DHT implementation.
3+
"""
4+
15
from libp2p.custom_types import (
26
TProtocol,
37
)

libp2p/kad_dht/kad_dht.py

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -31,6 +31,11 @@
3131
Service,
3232
)
3333

34+
from .common import (
35+
ALPHA,
36+
PROTOCOL_ID,
37+
QUERY_TIMEOUT,
38+
)
3439
from .pb.kademlia_pb2 import (
3540
Message,
3641
)
@@ -46,11 +51,6 @@
4651
from .value_store import (
4752
ValueStore,
4853
)
49-
from .common import (
50-
PROTOCOL_ID,
51-
ALPHA,
52-
QUERY_TIMEOUT
53-
)
5454

5555
logger = logging.getLogger("kademlia-example.kad_dht")
5656
# logger = logging.getLogger("libp2p.kademlia")

libp2p/kad_dht/peer_routing.py

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -22,17 +22,16 @@
2222
PeerInfo,
2323
)
2424

25-
25+
from .common import (
26+
ALPHA,
27+
PROTOCOL_ID,
28+
)
2629
from .pb.kademlia_pb2 import (
2730
Message,
2831
)
2932
from .routing_table import (
3033
RoutingTable,
3134
)
32-
from .common import (
33-
PROTOCOL_ID,
34-
ALPHA
35-
)
3635
from .utils import (
3736
sort_peer_ids_by_distance,
3837
)

libp2p/kad_dht/provider_store.py

Lines changed: 5 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -29,14 +29,13 @@
2929
PeerInfo,
3030
)
3131

32-
from .pb.kademlia_pb2 import (
33-
Message,
34-
)
35-
3632
from .common import (
37-
PROTOCOL_ID,
3833
ALPHA,
39-
QUERY_TIMEOUT
34+
PROTOCOL_ID,
35+
QUERY_TIMEOUT,
36+
)
37+
from .pb.kademlia_pb2 import (
38+
Message,
4039
)
4140

4241
# logger = logging.getLogger("libp2p.kademlia.provider_store")

libp2p/kad_dht/routing_table.py

Lines changed: 8 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -2,31 +2,27 @@
22
Kademlia DHT routing table implementation.
33
"""
44

5-
from collections import (
6-
OrderedDict,
7-
)
5+
from collections import OrderedDict
86
import logging
97
import time
108

119
import trio
1210

13-
from libp2p.abc import (
14-
IHost,
15-
)
16-
from libp2p.custom_types import (
17-
TProtocol,
11+
from libp2p.abc import IHost
12+
from libp2p.kad_dht.utils import (
13+
xor_distance,
1814
)
19-
from libp2p.kad_dht.utils import xor_distance
2015
from libp2p.peer.id import (
2116
ID,
2217
)
2318
from libp2p.peer.peerinfo import (
2419
PeerInfo,
2520
)
2621

27-
from .pb.kademlia_pb2 import (
28-
Message,
22+
from .common import (
23+
PROTOCOL_ID,
2924
)
25+
from .pb.kademlia_pb2 import Message
3026

3127
# logger = logging.getLogger("libp2p.kademlia.routing_table")
3228
logger = logging.getLogger("kademlia-example.routing_table")
@@ -243,7 +239,7 @@ async def _ping_peer(self, peer_id: ID) -> bool:
243239
raise ValueError(f"Peer {peer_id} not in bucket")
244240

245241
# Default protocol ID for Kademlia DHT
246-
protocol_id = TProtocol("/ipfs/kad/1.0.0")
242+
protocol_id = PROTOCOL_ID
247243

248244
try:
249245
# Open a stream to the peer with the DHT protocol

libp2p/kad_dht/value_store.py

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -19,13 +19,12 @@
1919
ID,
2020
)
2121

22-
from .pb.kademlia_pb2 import (
23-
Message,
24-
)
25-
2622
from .common import (
23+
DEFAULT_TTL,
2724
PROTOCOL_ID,
28-
DEFAULT_TTL
25+
)
26+
from .pb.kademlia_pb2 import (
27+
Message,
2928
)
3029

3130
# logger = logging.getLogger("libp2p.kademlia.value_store")

0 commit comments

Comments
 (0)