chore: update example

examples/block_exchange.rs

@@ -23,9 +23,7 @@ async fn main() -> anyhow::Result<()> {
 
     let addrs = node_a.listening_addresses().await?;
 
-    for addr in addrs {
-        node_b.add_peer((peer_id, addr)).await?;
-    }
+    node_b.add_peer((peer_id, addrs)).await?;
 
     let block_a = ipld!({
         "name": "alice",

examples/custom_behaviour.rs

@@ -9,7 +9,7 @@ async fn main() -> anyhow::Result<()> {
     // Initialize the repo and start a daemon
     let ipfs: Ipfs = UninitializedIpfs::new()
         .with_custom_behaviour(ext_behaviour::Behaviour)
-        .add_listening_addr("/ip4/0.0.0.0/tcp/0".parse()?)
+        .add_listening_addr("/ip4/127.0.0.1/tcp/0".parse()?)
         .start()
         .await?;
 

examples/echo-stream.rs

@@ -29,7 +29,7 @@ async fn main() -> anyhow::Result<()> {
     // Initialize the repo and start a daemon
     let ipfs = UninitializedIpfs::new()
         .set_keypair(&keypair)
-        .add_listening_addr("/ip4/0.0.0.0/tcp/0".parse()?)
+        .add_listening_addr("/ip4/127.0.0.1/tcp/0".parse()?)
         .with_streams()
         .start()
         .await?;

examples/pubsub.rs

@@ -1,6 +1,5 @@
 use clap::Parser;
 use futures::FutureExt;
-use ipld_core::ipld;
 use libp2p::futures::StreamExt;
 use libp2p::Multiaddr;
 use rust_ipfs::p2p::MultiaddrExt;
@@ -278,10 +277,10 @@ async fn main() -> anyhow::Result<()> {
 
 //Note: This is temporary as a similar implementation will be used internally in the future
 async fn topic_discovery(ipfs: Ipfs, topic: String) -> anyhow::Result<()> {
-    let cid = ipfs.put_dag(ipld!(topic)).await?;
-    ipfs.provide(cid).await?;
+    let topic_bytes = topic.as_bytes().to_vec();
+    ipfs.dht_provide(topic_bytes.clone()).await?;
     loop {
-        let mut stream = ipfs.get_providers(cid).await?.boxed();
+        let mut stream = ipfs.dht_get_providers(topic_bytes.clone()).await?.boxed();
         while let Some(_providers) = stream.next().await {}
         tokio::time::sleep(Duration::from_millis(50)).await;
     }

examples/wasm-example/src/lib.rs

@@ -32,11 +32,7 @@ pub async fn run() -> Result<(), JsError> {
 
     let addrs = node_a.listening_addresses().await.unwrap();
 
-    for addr in addrs {
-        node_b.add_peer((peer_id, addr)).await.unwrap();
-    }
-
-    node_b.connect(peer_id).await.unwrap();
+    node_b.add_peer((peer_id, addrs)).await.unwrap();
 
     let block_a = ipld!({
         "name": "alice",