fix(stream): Partial fix for stream service compilation errors (WIP)

- Fixed variable shadowing: renamed transaction decode variable
- Fixed axum serve: added into_make_service()
- Stream feature still has compilation errors - needs more work
- Graph features (wallet hop, DeFi filter) are working correctly

Author: 0xrinegade

Cargo.lock

@@ -91,7 +91,7 @@ pub async fn start_server(
     tracing::info!("Stream server listening on {}", addr);
 
     let listener = tokio::net::TcpListener::bind(addr).await?;
-    axum::serve(listener, app).await?;
+    axum::serve(listener, app.into_make_service()).await?;
 
     Ok(())
 }

src/services/stream_server.rs

@@ -287,17 +287,17 @@ impl StreamService {
         // Get recent block with transactions
         if let Ok(block) = client.get_block(slot) {
             for tx_with_meta in block.transactions.iter().take(10) {
-                if let Some(tx) = &tx_with_meta.transaction.decode() {
+                if let Some(transaction) = &tx_with_meta.transaction.decode() {
                     if let Some(meta) = &tx_with_meta.meta {
-                        let signature = tx.signatures[0].to_string();
+                        let signature = transaction.signatures[0].to_string();
 
                         let event = SolanaEvent::Transaction {
                             signature: signature.clone(),
                             slot,
                             timestamp: block.block_time.unwrap_or(0) as u64,
                             success: meta.status.is_ok(),
                             fee: meta.fee,
-                            signer: tx.message.account_keys[0].to_string(),
+                            signer: transaction.message.account_keys[0].to_string(),
                         };
 
                         stats.lock().unwrap().events_processed += 1;