enhancement: forc index status formatting update (#1365)

forc index status formatting update
FuelLabs · Sep 20, 2023 · 14b307c · 14b307c
1 parent 887ab38
commit 14b307c
Show file tree

Hide file tree

Showing 3 changed files with 34 additions and 6 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/plugins/forc-index/Cargo.toml b/plugins/forc-index/Cargo.toml
@@ -23,6 +23,7 @@ fuel-indexer-lib = { workspace = true }
 fuel-tx = { features = ["builder"], workspace = true }
 fuels = { default-features = false, workspace = true }
 hex = "0.4.3"
+humantime = "2.1.0"
 hyper-rustls = { version = "0.23", features = ["http2"] }
 indicatif = "0.17"
 owo-colors = "1.3.0"

diff --git a/plugins/forc-index/src/ops/forc_index_status.rs b/plugins/forc-index/src/ops/forc_index_status.rs
@@ -29,15 +29,34 @@ pub async fn status(
                 return Ok(());
             }
 
-            let res_json = res
+            let result = res
                 .json::<Map<String, Value>>()
                 .await
                 .expect("Failed to read JSON response.");
 
-            info!(
-                "\n✅ Sucessfully fetched service health:\n\n{}",
-                to_string_pretty(&res_json).unwrap()
-            );
+            info!("\n✅ Successfully fetched service health:\n");
+
+            let client_status = result
+                .get("client_status")
+                .and_then(|x| x.as_str())
+                .unwrap_or("missing");
+            let database_status = result
+                .get("database_status")
+                .and_then(|x| x.as_str())
+                .unwrap_or("missing");
+            let uptime = result
+                .get("uptime")
+                .and_then(|x| x.as_str())
+                .and_then(|x| x.to_string().parse::<u64>().ok())
+                .map(|x| {
+                    humantime::format_duration(std::time::Duration::from_secs(x))
+                        .to_string()
+                })
+                .unwrap_or("missing".to_string());
+
+            info!("client status: {client_status}");
+            info!("database status: {database_status}");
+            info!("uptime: {uptime}\n");
         }
         Err(e) => {
             error!("\n❌ Could not connect to indexer service:\n'{e}'");
@@ -70,6 +89,7 @@ pub async fn status(
                 .await
                 .expect("Failed to read JSON response.");
 
+            info!("indexers:");
             print_indexers(result);
         }
         Err(e) => {
@@ -121,7 +141,7 @@ fn print_indexers(indexers: Vec<RegisteredIndexer>) {
             };
             println!("{}  {} {}", ng2, ig1, indexer.identifier);
             println!("{}  {}  • id: {}", ng2, ig2, indexer.id);
-            println!("{}  {}  • created_at: {}", ng2, ig2, indexer.created_at);
+            println!("{}  {}  • created at: {}", ng2, ig2, indexer.created_at);
             println!("{}  {}  • pubkey: {:?}", ng2, ig2, indexer.pubkey);
         }
         if !is_last_namespace {