diff options
Diffstat (limited to 'src/main.rs')
-rw-r--r-- | src/main.rs | 23 |
1 files changed, 23 insertions, 0 deletions
diff --git a/src/main.rs b/src/main.rs index 3db85d5..1b97f6d 100644 --- a/src/main.rs +++ b/src/main.rs @@ -1,6 +1,7 @@ use std::path::PathBuf; use std::str::FromStr; +use anyhow::anyhow; use anyhow::Result; use daglib::DagBackend; use rand_os::OsRng; @@ -104,6 +105,28 @@ async fn main() -> Result<()> { Ok(()) }, + ("get", Some(mtch)) => { + let head = mtch + .value_of("head") + .map(cid::Cid::from_str) + .transpose()? + .map(crate::backend::Id::from) + .unwrap(); // Safe by clap + + let (id, node) = backend + .get(head.clone()) + .await? + .ok_or_else(|| anyhow!("Not found: {:?}", head))?; + + let payload = backend.ipfs().fetch(node.payload_id(), backend.ipfs().peers()).await?; + let payload = payload.decode::<libipld::cbor::DagCborCodec, crate::backend::Payload>()?; + + println!("id = {:?}", id); + println!("node = {:?}", node); + println!("payload = {:?}", payload); + Ok(()) + }, + (other, _) => { unimplemented!() }, |