Implement K-DHT for spartan-farmer

.gitignore

@@ -1,2 +1,5 @@
+.gitignore
 /.idea
 /target
+**/rustfmt.toml
+.vscode/

crates/spartan-farmer/Cargo.toml

@@ -30,7 +30,7 @@ serde_json = "1.0.64"
 schnorrkel = "0.10.1"
 spartan-codec = "0.1.0"
 thiserror = "1.0.24"
-tokio = "1.11.0"
+tokio = { version = "1.11.0", features = [ "macros" ] }
 
 [dependencies.jsonrpsee]
 features = ["client"]
@@ -48,6 +48,11 @@ version = "0.17.0"
 features = ["derive"]
 version = "1.0.125"
 
+[dependencies.libp2p]
+version = "0.39.1"
+features = [ "noise", "mplex", "kad", "tcp-tokio" ]
+default-features = false
+
 [dependencies.subspace-core-primitives]
 version = "0.1.0"
 path = "../subspace-core-primitives"

crates/spartan-farmer/src/commands.rs

@@ -1,3 +1,4 @@
+mod dht;
 mod farm;
 mod plot;
 

crates/spartan-farmer/src/commands/dht.rs

@@ -0,0 +1,40 @@
+// Stuff for Kademlia
+use libp2p::kad::{record::store::MemoryStore, Kademlia, KademliaEvent, QueryId, QueryResult};
+
+// Stuff for defining composed behaviour
+use libp2p::NetworkBehaviour;
+
+// Stuff needed to create the swarm
+use libp2p::core::{upgrade, Transport};
+use libp2p::identity;
+use libp2p::mplex;
+use libp2p::noise::{Keypair, NoiseConfig, X25519Spec};
+use libp2p::swarm::{SwarmBuilder, SwarmEvent};
+use libp2p::tcp::TokioTcpConfig;
+use libp2p::{Multiaddr, PeerId, Swarm};
+
+// Stuff needed to set up channels between Client API task and EventLoop task.
+use futures::channel::{
+    mpsc::{channel, Receiver, Sender},
+    oneshot,
+};
+use futures::prelude::*;
+use futures::StreamExt;
+
+use log::info;
+
+type OneshotError = Box<dyn std::error::Error + Send>;
+type OneshotType = Result<(), OneshotError>;
+
+// The Client API which the end-user is supposed to interact with.
+pub mod client;
+// Core libp2p activities like defining network behaviour and events, bootstrap-ing,
+// creating of swarm and such...
+mod core;
+// EventLoop which actually processes libp2p SwarmEvents. The Client API interacts with the
+// EventLoop to transfer and receieve data.
+mod eventloop;
+
+// DHT related tests.
+#[cfg(test)]
+mod test;