tsarevvv/rust-ipfs
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

example(fetch_and_cat): add argument: peer to connect to

Browse Source
This commit is contained in:
Joonas Koivunen 2020-08-26 17:50:48 +03:00
parent bdf256cc44
commit 4af69120d4
1 changed files with 18 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
examples/fetch_and_cat.rs
View File

@ -24,11 +24,13 @@ async fn main() {
exit(1);
}
None => {
eprintln!("Usage: fetch_and_cat <IPFS_PATH | CID>");
eprintln!("Usage: fetch_and_cat <IPFS_PATH | CID> [MULTIADDR]");
eprintln!(
"Example will accept connections and print all bytes of the unixfs file to \
stdout."
);
eprintln!("If second argument is present, it is expected to be a Multiaddr with \
peer_id. The given multiaddr will be connected to instead of waiting an incoming connection.");
exit(0);
}
};
@ -41,22 +43,30 @@ async fn main() {
exit(1);
}
let target = env::args()
.nth(2)
.map(|s| s.parse::<MultiaddrWithPeerId>().unwrap());
// Start daemon and initialize repo
let (ipfs, fut): (Ipfs<TestTypes>, _) =
UninitializedIpfs::default().await.start().await.unwrap();
tokio::task::spawn(fut);
let (_, addresses) = ipfs.identity().await.unwrap();
assert!(!addresses.is_empty(), "Zero listening addresses");
if let Some(target) = target {
ipfs.connect(target).await.unwrap();
} else {
let (_, addresses) = ipfs.identity().await.unwrap();
assert!(!addresses.is_empty(), "Zero listening addresses");
eprintln!("Please connect an ipfs node having {} to:\n", path);
eprintln!("Please connect an ipfs node having {} to:\n", path);
for address in addresses {
eprintln!(" - {}", address);
for address in addresses {
eprintln!(" - {}", address);
}
eprintln!();
}
eprintln!();
let stream = ipfs.cat_unixfs(path, None).await.unwrap_or_else(|e| {
eprintln!("Error: {}", e);
exit(1);