BlockRazor Block Stream: Low-Latency Block Data Feed

use yellowstone_grpc_client::GeyserGrpcClient;
use yellowstone_grpc_proto::prelude::*;
use std::collections::HashMap;

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

    let mut transactions = HashMap::new();
    transactions.insert(
        "client_id".to_string(),
        SubscribeRequestFilterTransactions {
            vote: Some(false),
            failed: Some(false),
            ..Default::default()
        },
    );

    let request = SubscribeRequest {
        transactions,
        ..Default::default()
    };

    let (_, mut stream) = client.subscribe_with_request(Some(request)).await?;

    while let Some(msg) = stream.next().await {
        match msg {
            Ok(update) => println!("Block update: {:?}", update),
            Err(e) => eprintln!("Stream error: {}", e),
        }
    }

    Ok(())
}