diff --git a/libp2p/kad_dht/common.py b/libp2p/kad_dht/common.py index ccabb002..8b82ea97 100644 --- a/libp2p/kad_dht/common.py +++ b/libp2p/kad_dht/common.py @@ -7,4 +7,4 @@ ALPHA = 3 # Concurrency parameter PROTOCOL_ID = TProtocol("/ipfs/kad/1.0.0") QUERY_TIMEOUT = 10 -TTL = DEFAULT_TTL = 24 * 60 * 60 # 24 hours in seconds \ No newline at end of file +TTL = DEFAULT_TTL = 24 * 60 * 60 # 24 hours in seconds diff --git a/libp2p/kad_dht/kad_dht.py b/libp2p/kad_dht/kad_dht.py index 8a917bda..f82c0063 100644 --- a/libp2p/kad_dht/kad_dht.py +++ b/libp2p/kad_dht/kad_dht.py @@ -18,9 +18,6 @@ import varint from libp2p.abc import ( IHost, ) -from libp2p.custom_types import ( - TProtocol, -) from libp2p.network.stream.net_stream import ( INetStream, ) @@ -60,6 +57,7 @@ logger = logging.getLogger("kademlia-example.kad_dht") # Default parameters ROUTING_TABLE_REFRESH_INTERVAL = 60 # 1 min in seconds for testing + class DHTMode(Enum): """DHT operation modes.""" diff --git a/libp2p/kad_dht/value_store.py b/libp2p/kad_dht/value_store.py index c133fd00..488735e6 100644 --- a/libp2p/kad_dht/value_store.py +++ b/libp2p/kad_dht/value_store.py @@ -31,6 +31,7 @@ from .common import ( # logger = logging.getLogger("libp2p.kademlia.value_store") logger = logging.getLogger("kademlia-example.value_store") + class ValueStore: """ Store for key-value pairs in a Kademlia DHT.