summaryrefslogtreecommitdiffstats
path: root/src/main.rs
diff options
context:
space:
mode:
Diffstat (limited to 'src/main.rs')
-rw-r--r--src/main.rs23
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!()
},