Solana Block Streams — Shred, Geyser & Sandwich Detector

use yellowstone_grpc_client::GeyserGrpcClient;

#[tokio::main]
async fn main() -> anyhow::Result<()> {
    let mut client = GeyserGrpcClient::connect(
        "https://geyser.blockrazor.io",
        Some("YOUR_AUTH_TOKEN"),
        None,
    )
    .await?;

    // Subscribe to slot updates
    let (mut subscribe_tx, mut stream) = client.subscribe().await?;

    // Send subscription request for slots and transactions
    use yellowstone_grpc_proto::prelude::*;
    subscribe_tx
        .send(SubscribeRequest {
            slots: std::collections::HashMap::from([(
                "slots".to_string(),
                SubscribeRequestFilterSlots {},
            )]),
            ..Default::default()
        })
        .await?;

    // Process incoming stream events
    while let Some(message) = stream.next().await {
        match message {
            Ok(msg) => println!("Geyser event: {:?}", msg.update_oneof),
            Err(e) => eprintln!("Stream error: {}", e),
        }
    }

    Ok(())
}