feat: add relay capabilities to rust server (#12)

Author: maschad

rust-server/Cargo.lock

@@ -11,10 +11,23 @@ clap = { version = "4.1.11", features = ["derive"] }
 env_logger = "0.10.0"
 futures = "0.3.27"
 futures-timer = "3.0.2"
-libp2p = {git = "https://github.com/vnermolaev/rust-libp2p.git", branch = "deprecate/gossipsub-close-event", version="0.51.2", features = ["identify", "ping", "tokio", "gossipsub", "webrtc", "macros", "kad", "rsa", "ed25519"]}
-libp2p-webrtc = {git = "https://github.com/vnermolaev/rust-libp2p.git", branch = "deprecate/gossipsub-close-event", version="0.4.0-alpha.4", features = ["tokio"] }
+libp2p = { git = "https://github.com/vnermolaev/rust-libp2p.git", branch = "deprecate/gossipsub-close-event", version = "0.51.2", features = [
+	"identify",
+	"ping",
+	"tokio",
+	"gossipsub",
+	"webrtc",
+	"macros",
+	"relay",
+	"kad",
+	"rsa",
+	"ed25519",
+] }
+libp2p-webrtc = { git = "https://github.com/vnermolaev/rust-libp2p.git", branch = "deprecate/gossipsub-close-event", version = "0.4.0-alpha.4", features = [
+	"tokio",
+] }
 log = "0.4.17"
 rand = "0.8.5"
-tokio = { version= "1.26.0", features=["full"] }
+tokio = { version = "1.26.0", features = ["full"] }
 tokio-util = { version = "0.7", features = ["full"] }
 webrtc = { version = "0.6.0", optional = true }

rust-server/Cargo.toml

@@ -5,7 +5,7 @@ use libp2p::{
     core::muxing::StreamMuxerBox,
     gossipsub, identify, identity,
     multiaddr::Protocol,
-    ping,
+    ping, relay,
     swarm::{keep_alive, NetworkBehaviour, Swarm, SwarmBuilder, SwarmEvent},
     Multiaddr, PeerId, Transport,
 };
@@ -59,6 +59,9 @@ async fn main() -> Result<()> {
                 SwarmEvent::ConnectionClosed { peer_id, cause, .. } => {
                     warn!("Connection to {peer_id} closed: {cause:?}");
                 }
+                SwarmEvent::Behaviour(BehaviourEvent::Relay(e)) => {
+                    info!("{:?}", e);
+                }
                 SwarmEvent::Behaviour(BehaviourEvent::Gossipsub(
                     libp2p::gossipsub::Event::Message {
                         message_id: _,
@@ -104,6 +107,7 @@ struct Behaviour {
     // kademlia: Kademlia<MemoryStore>,
     keep_alive: keep_alive::Behaviour,
     ping: ping::Behaviour,
+    relay: relay::Behaviour,
 }
 
 fn create_swarm() -> Result<Swarm<Behaviour>> {
@@ -160,6 +164,7 @@ fn create_swarm() -> Result<Swarm<Behaviour>> {
         identify: identify_config,
         keep_alive: keep_alive::Behaviour::default(),
         ping: ping::Behaviour::default(),
+        relay: relay::Behaviour::new(local_peer_id, Default::default()),
     };
     Ok(SwarmBuilder::with_tokio_executor(transport, behaviour, local_peer_id).build())
 }