feat: implement autorelay

Cargo.toml

@@ -59,12 +59,12 @@ indexeddb = ["dep:idb", "serde"]
 redb = ["dep:redb", "dep:cbor4ii", "serde"]
 sqlite = ["dep:sqlx", "dep:cbor4ii", "serde"]
 
-webrtc =["dep:libp2p-webrtc", "dep:libp2p-webrtc-websys"]
+webrtc = ["dep:libp2p-webrtc", "dep:libp2p-webrtc-websys"]
 websocket = ["libp2p/websocket", "rcgen", "dep:pem", "libp2p/websocket-websys"]
 webtransport = ["libp2p/webtransport-websys"]
 
 [workspace]
-members = ["examples/browser-webrtc", "examples/custom-behaviour-and-context", "examples/custom-transport", "examples/distributed-key-value-store", "examples/file-sharing-request-response", "examples/file-sharing-stream", "examples/floodsub", "examples/gossipsub", "examples/ipfs-kad", "examples/peer-store", "examples/relay", "examples/rendezvous", "examples/stream", "examples/upnp"]
+members = ["examples/autorelay", "examples/browser-webrtc", "examples/custom-behaviour-and-context", "examples/custom-transport", "examples/distributed-key-value-store", "examples/file-sharing-request-response", "examples/file-sharing-stream", "examples/floodsub", "examples/gossipsub", "examples/ipfs-kad", "examples/peer-store", "examples/relay", "examples/rendezvous", "examples/stream", "examples/upnp"]
 
 [workspace.dependencies]
 async-rt = "0.1.8"
@@ -170,7 +170,7 @@ getrandom = { workspace = true, features = ["js"] }
 getrandom_03 = { workspace = true, features = ["wasm_js"] }
 idb = { workspace = true, optional = true }
 js-sys = { workspace = true, optional = true }
-libp2p = { features = ["macros", "serde", "wasm-bindgen"], workspace = true }
+libp2p = { features = ["macros", "serde"], workspace = true }
 libp2p-webrtc-websys = { workspace = true, optional = true }
 parking_lot = { workspace = true, optional = true }
 send_wrapper = { workspace = true, features = ["futures"] }
@@ -180,4 +180,4 @@ tokio = { default-features = false, features = ["sync", "macros"], workspace = t
 url = { workspace = true, optional = true }
 wasm-bindgen.workspace = true
 wasm-bindgen-futures.workspace = true
-web-sys = { workspace = true, optional = true }
+web-sys = { workspace = true, optional = true }

examples/autorelay/Cargo.toml

@@ -0,0 +1,11 @@
+[package]
+name = "autorelay"
+version = "0.1.0"
+edition = "2024"
+
+[dependencies]
+tokio.workspace = true
+futures.workspace = true
+connexa = { path = "../../", default-features = false, features = ["ed25519", "rsa", "tcp", "quic", "yamux", "noise", "relay", "ping", "identify", "testing", "kad", "dns"] }
+clap = { version = "4.5.39", features = ["derive"] }
+tracing-subscriber = { version = "0.3.19", features = ["env-filter"] }

examples/autorelay/src/main.rs

@@ -0,0 +1,55 @@
+use connexa::prelude::{DefaultConnexaBuilder, Multiaddr, PeerId};
+
+pub const BOOTSTRAP_NODES: &[(&str, &str)] = &[
+    (
+        "/ip4/104.131.131.82/tcp/4001",
+        "QmaCpDMGvV2BGHeYERUEnRQAwe3N8SzbUtfsmvsqQLuvuJ",
+    ),
+    (
+        "/dnsaddr/bootstrap.libp2p.io",
+        "QmNnooDu7bfjPFoTZYxMNLWUQJyrVwtbZg5gBMjTezGAJN",
+    ),
+    (
+        "/dnsaddr/bootstrap.libp2p.io",
+        "QmQCU2EcMqAqQPR2i9bChDtGNJchTbq5TbXJJ16u19uLTa",
+    ),
+    (
+        "/dnsaddr/bootstrap.libp2p.io",
+        "QmbLHAnMoJPWSCR5Zhtx6BHJX9KiKNN6tpvbUcqanj75Nb",
+    ),
+    (
+        "/dnsaddr/bootstrap.libp2p.io",
+        "QmcZf59bWwK5XFi76CZX8cbJ4BhTzzA3gU1ZjYZcYW3dwt",
+    ),
+];
+
+#[tokio::main]
+async fn main() -> std::io::Result<()> {
+    let connexa = DefaultConnexaBuilder::new_identity()
+        .enable_tcp()
+        .enable_quic()
+        .enable_dns()
+        .with_relay()
+        .with_autorelay()
+        .with_ping()
+        .with_identify()
+        .with_kademlia()
+        .build()
+        .await?;
+
+    for (addr, peer_id) in BOOTSTRAP_NODES {
+        let peer_id: PeerId = peer_id.parse().expect("valid peer id");
+        let addr: Multiaddr = addr.parse().expect("valid addr");
+        connexa.dht().add_address(peer_id, addr).await?;
+    }
+
+    tokio::time::sleep(std::time::Duration::from_secs(10)).await;
+
+    let external_addrs = connexa.swarm().external_addresses().await?;
+
+    for addr in external_addrs {
+        println!("- {}", addr);
+    }
+
+    Ok(())
+}

examples/upnp/src/main.rs

@@ -21,6 +21,7 @@ async fn main() -> std::io::Result<()> {
                 UpnpEvent::NonRoutableGateway => println!("Gateway is not routable"),
             },
             _ => {}
+            _ => {}
         })
         .build()
         .await?;

src/behaviour.rs

@@ -1,3 +1,5 @@
+#[cfg(feature = "relay")]
+pub mod autorelay;
 pub mod dummy;
 pub mod peer_store;
 #[cfg(feature = "request-response")]
@@ -56,6 +58,9 @@ where
     #[cfg(feature = "relay")]
     pub relay_client: Toggle<RelayClient>,
 
+    #[cfg(feature = "relay")]
+    pub autorelay: Toggle<autorelay::Behaviour>,
+
     #[cfg(not(target_arch = "wasm32"))]
     #[cfg(feature = "upnp")]
     pub upnp: Toggle<libp2p::upnp::tokio::Behaviour>,
@@ -270,6 +275,15 @@ where
             }
             false => (None, None.into()),
         };
+        #[cfg(feature = "relay")]
+        let autorelay = protocols
+            .autorelay
+            .then(|| {
+                let config_fn = config.autorelay_config;
+                let config = config_fn(autorelay::Config::default());
+                autorelay::Behaviour::new_with_config(config)
+            })
+            .into();
 
         #[cfg(not(feature = "relay"))]
         let transport = None::<()>;
@@ -361,6 +375,8 @@ where
             relay,
             #[cfg(feature = "relay")]
             relay_client,
+            #[cfg(feature = "relay")]
+            autorelay,
             #[cfg(feature = "stream")]
             stream,
             #[cfg(not(target_arch = "wasm32"))]