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(())
}

// npm i @triton-one/yellowstone-grpc
import Client, { CommitmentLevel } from "@triton-one/yellowstone-grpc";

const client = new Client("https://grpc.raze.bot:443", "sk_your_api_key", undefined);

const stream = await client.subscribe();
stream.on("data", (update) => console.log(update));

stream.write({
  accounts: {},
  slots: {},
  transactions: {
    all: { vote: false, failed: false, accountInclude: [], accountExclude: [], accountRequired: [] },
  },
  transactionsStatus: {},
  blocks: {},
  blocksMeta: {},
  entry: {},
  commitment: CommitmentLevel.PROCESSED,
  accountsDataSlice: [],
});

grpcurl \
  -H 'x-token: sk_your_api_key' \
  -d '{"transactions":{"all":{"vote":false,"failed":false}},"commitment":"PROCESSED"}' \
  grpc.raze.bot:443 geyser.Geyser/Subscribe