diff options
Diffstat (limited to 'ipfs-api/examples')
-rw-r--r-- | ipfs-api/examples/bootstrap_default.rs | 49 | ||||
-rw-r--r-- | ipfs-api/examples/get_stats.rs | 10 |
2 files changed, 57 insertions, 2 deletions
diff --git a/ipfs-api/examples/bootstrap_default.rs b/ipfs-api/examples/bootstrap_default.rs new file mode 100644 index 0000000..e88b71a --- /dev/null +++ b/ipfs-api/examples/bootstrap_default.rs @@ -0,0 +1,49 @@ +extern crate ipfs_api; +extern crate tokio_core; + +use ipfs_api::IpfsClient; +use tokio_core::reactor::Core; + + +// Lists clients in bootstrap list, then adds the default list, then removes +// them, and readds them. +// +fn main() { + if let Ok(mut core) = Core::new() { + println!("connecting to localhost:5001..."); + + let client = + IpfsClient::new(&core.handle(), "localhost", 5001).expect("expected a valid url"); + let bootstrap = client.bootstrap_list().expect("expected a valid request"); + let bootstrap = core.run(bootstrap).expect("expected a valid response"); + + println!("current bootstrap peers:"); + for peer in bootstrap.peers { + println!(" {}", peer); + } + + println!(""); + println!("dropping all bootstrap peers..."); + + let drop = client.bootstrap_rm_all().expect("expected a valid request"); + let drop = core.run(drop).expect("expected a valid response"); + + println!("dropped:"); + for peer in drop.peers { + println!(" {}", peer); + } + + println!(""); + println!("adding default peers..."); + + let add = client.bootstrap_add_default().expect("expected a valid request"); + let add = core.run(add).expect("expected a valid response"); + + println!("added:"); + for peer in add.peers { + println!(" {}", peer); + } + } else { + println!("failed to create event loop"); + } +} diff --git a/ipfs-api/examples/get_stats.rs b/ipfs-api/examples/get_stats.rs index 97c1b6a..b7bd293 100644 --- a/ipfs-api/examples/get_stats.rs +++ b/ipfs-api/examples/get_stats.rs @@ -28,8 +28,14 @@ fn main() { println!(" data recv: {}", bitswap_stats.data_received); println!(" blocks sent: {}", bitswap_stats.blocks_sent); println!(" data sent: {}", bitswap_stats.data_sent); - println!(" peers: {}", bitswap_stats.peers.join("\n ")); - println!(" wantlist: {}", bitswap_stats.wantlist.join("\n ")); + println!( + " peers: {}", + bitswap_stats.peers.join("\n ") + ); + println!( + " wantlist: {}", + bitswap_stats.wantlist.join("\n ") + ); println!(""); println!("bandwidth stats:"); println!(" total in: {}", bw_stats.total_in); |