JSON client setup and chain CLI commands

blockchain/blocks/src/tipset.rs

@@ -270,7 +270,7 @@ pub mod tipset_json {
     use serde::{de, Deserialize, Deserializer, Serialize, Serializer};
 
     /// Wrapper for serializing and deserializing a SignedMessage from JSON.
-    #[derive(Deserialize, Serialize)]
+    #[derive(Deserialize, Serialize, Debug)]
     #[serde(transparent)]
     pub struct TipsetJson(#[serde(with = "self")] pub Tipset);
 

forest/Cargo.toml

@@ -18,7 +18,7 @@ pretty_env_logger = "0.4.0"
 ctrlc = "3.1.4"
 chain_sync = { path = "../blockchain/chain_sync" }
 state_manager = { path = "../blockchain/state_manager" }
-cid = { package = "forest_cid", path = "../ipld/cid" }
+cid = { package = "forest_cid", path = "../ipld/cid", features = ["json"] }
 forest_car = { path = "../ipld/car" }
 blocks = { package = "forest_blocks", path = "../blockchain/blocks" }
 ipld_blockstore = { path = "../ipld/blockstore", features = ["rocksdb"] }
@@ -27,6 +27,7 @@ structopt = { version = "0.3" }
 beacon = { path = "../blockchain/beacon" }
 hex = "0.4.2"
 rpc = { path = "../node/rpc" }
+rpc_client = {package = "rpc-client", path = "../node/rpc-client" }
 fil_types = { path = "../types" }
 serde_json = "1.0"
 blake2b_simd = "0.5.9"

forest/src/cli/chain_cmd.rs

@@ -0,0 +1,81 @@
+// Copyright 2020 ChainSafe Systems
+// SPDX-License-Identifier: Apache-2.0, MIT
+
+use cid::Cid;
+use rpc_client::{block, genesis, head, messages, new_client, read_obj};
+use structopt::StructOpt;
+
+#[derive(Debug, StructOpt)]
+pub enum ChainCommands {
+    /// Retrieves and prints out the block specified by the given CID
+    #[structopt(about = "<Cid> Retrieve a block and print its details")]
+    Block {
+        #[structopt(help = "Input a valid CID")]
+        cid: String,
+    },
+
+    /// Prints out the genesis tipset
+    #[structopt(about = "Prints genesis tipset", help = "Prints genesis tipset")]
+    Genesis,
+
+    /// Prints out the canonical head of the chain
+    #[structopt(about = "Print chain head", help = "Print chain head")]
+    Head,
+
+    /// Reads and prints out a message referenced by the specified CID from the
+    /// chain blockstore
+    #[structopt(about = "<CID> Retrieves and prints messages by CIDs")]
+    Message {
+        #[structopt(help = "Input a valid CID")]
+        cid: String,
+    },
+
+    /// Reads and prints out ipld nodes referenced by the specified CID from chain
+    /// blockstore and returns raw bytes
+    #[structopt(about = "<CID> Read the raw bytes of an object")]
+    ReadObj {
+        #[structopt(help = "Input a valid CID")]
+        cid: String,
+    },
+}
+
+impl ChainCommands {
+    pub async fn run(&self) {
+        // TODO handle cli config
+        match self {
+            Self::Block { cid } => {
+                let cid: Cid = cid.parse().unwrap();
+                let mut client = new_client();
+
+                let blk = block(client, cid).await;
+                println!("{}", serde_json::to_string_pretty(&blk).unwrap());
+            }
+            Self::Genesis => {
+                let mut client = new_client();
+
+                let gen = genesis(client).await;
+                println!("{}", serde_json::to_string_pretty(&gen).unwrap());
+            }
+            Self::Head => {
+                let mut client = new_client();
+
+                let head = head(client).await;
+                println!("{}", serde_json::to_string_pretty(&head).unwrap());
+            }
+            Self::Message { cid } => {
+                let cid: Cid = cid.parse().unwrap();
+                let mut client = new_client();
+
+                let msg = messages(client, cid).await;
+                println!("{}", serde_json::to_string_pretty(&msg).unwrap());
+            }
+            Self::ReadObj { cid } => {
+                let cid: Cid = cid.parse().unwrap();
+                let mut client = new_client();
+
+                let obj = read_obj(client, cid).await;
+                println!("{}", serde_json::to_string_pretty(&obj).unwrap());
+            }
+        }
+    }
+}