Typed streaming

Cargo.toml

@@ -7,7 +7,7 @@ edition = "2024"
 anyhow = "1.0.104"
 futures-util = "0.3.33"
 rt = "0.19.1"
-serde = { version = "1.0.229", features = ["serde_derive"] }
+serde = { version = "1.0.229", features = ["derive", "serde_derive"] }
 serde_json = "1.0.151"
 solana-sdk = "4.1.0"
 tokio = { version = "1.53.1", features = ["macros", "rt-multi-thread"] }

src/launch.rs

@@ -0,0 +1,21 @@
+use serde::Deserialize;
+
+#[derive(Debug, Deserialize)]
+pub struct NewToken {
+    pub mint: String,
+    pub name: String,
+    pub symbol: String,
+    pub uri: String,
+
+    #[serde(rename = "marketCapSol")]
+    pub market_cap_sol: f64,
+
+    #[serde(rename = "solAmount")]
+    pub sol_amount: f64,
+
+    #[serde(rename = "traderPublicKey")]
+    pub trader_public_key: String,
+
+    #[serde(rename = "txType")]
+    pub tx_type: String,
+}

src/main.rs

@@ -1,4 +1,5 @@
 pub mod executor;
+pub mod launch;
 
 use futures_util::{SinkExt, StreamExt};
 use serde_json::json;
@@ -17,7 +18,6 @@ async fn main() -> anyhow::Result<()> {
         let msg = msg?;
         if let tokio_tungstenite::tungstenite::Message::Text(text) = msg {
             let token: serde_json::Value = serde_json::from_str(&text)?;
-            // println!("{} ({})", token.name, token.symbol);
             println!("{:?}", token);
         }
     }