summaryrefslogtreecommitdiffstats
path: root/ipfs-api/examples
diff options
context:
space:
mode:
authorFerris Tseng <ferristseng@fastmail.fm>2017-10-09 19:52:37 -0400
committerFerris Tseng <ferristseng@fastmail.fm>2017-10-09 19:52:37 -0400
commitd4c8637104362d053caa85806b7fb4513c61b53d (patch)
tree0eef7d0d2fb429cc47e6d7e7c71c060d2811f919 /ipfs-api/examples
parentaf3c23b54fb04ba232d0e04642f570e1f5b4cf72 (diff)
add bootstrap example
Diffstat (limited to 'ipfs-api/examples')
-rw-r--r--ipfs-api/examples/bootstrap_default.rs49
-rw-r--r--ipfs-api/examples/get_stats.rs10
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);