pretty print json_strings coming back from jetstream

likeandscribe · Nov 14, 2024 · 6fbe9f9 · 6fbe9f9
1 parent 374ec88
commit 6fbe9f9
Show file tree

Hide file tree

Showing 3 changed files with 188 additions and 2 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/packages-rs/drainpipe/Cargo.toml b/packages-rs/drainpipe/Cargo.toml
@@ -4,7 +4,10 @@ version = "0.2.0"
 edition = "2021"
 
 [dependencies]
+chrono = { version = "0.4.38", features = ["serde"] }
 futures-util = "0.3"
+serde = "1.0.203"
+serde_json = { version = "1.0" }
 tokio = { version = "1.38.0", features = ["full"] }
 tokio-metrics = "0.3.1"
 tokio-tungstenite = { version = "0.23.0", features = ["native-tls"] }
diff --git a/packages-rs/drainpipe/src/main.rs b/packages-rs/drainpipe/src/main.rs
@@ -40,8 +40,9 @@ async fn main() -> Result<(), Box<dyn Error>> {
 
         while let Some(msg) = stream.next().await {
             match msg {
-                Ok(Message::Text(text)) => {
-                    println!("{}", text);
+                Ok(Message::Text(json_string)) => {
+                    let json: serde_json::Value = serde_json::from_str(&json_string).unwrap();
+                    println!("{}", serde_json::to_string_pretty(&json).unwrap());
                 }
                 Err(e) => {
                     eprintln!("Error: {}", e);