gRPC (Yellowstone)

// cargo add yellowstone-grpc-client yellowstone-grpc-proto futures tokio
use yellowstone_grpc_client::GeyserGrpcClient;
use yellowstone_grpc_proto::geyser::{
    SubscribeRequest, SubscribeRequestFilterTransactions, CommitmentLevel,
};
use std::collections::HashMap;
use futures::{SinkExt, StreamExt};

#[tokio::main]
async fn main() -> anyhow::Result<()> {
    let mut client = GeyserGrpcClient::build_from_shared("https://grpc.raze.bot:443")?
        .x_token(Some("sk_your_api_key"))?
        .tls_config(Default::default())?
        .connect()
        .await?;

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

    let req = SubscribeRequest {
        transactions: txs,
        commitment: Some(CommitmentLevel::Processed as i32),
        ..Default::default()
    };

    let (mut sink, mut stream) = client.subscribe().await?;
    sink.send(req).await?;
    while let Some(update) = stream.next().await {
        println!("{:?}", update?);
    }
    Ok(())
}