Struct EnhancedWebsocket

pub struct EnhancedWebsocket { /* private fields */ }

A client for subscribing to transaction or account updates from a Helius (Geyser) enhanced websocket server.

Forked from Solana’s [PubsubClient].

Implementations

impl EnhancedWebsocket

pub async fn new( url: &str, ping_interval_secs: Option<u64>, pong_timeout_secs: Option<u64>, ) -> Result<Self>

Expects enhanced websocket endpoint: wss://atlas-mainnet.helius-rpc.com?api-key=<API_KEY>

pub async fn shutdown(self) -> Result<()>

pub async fn set_node_version(&self, version: Version) -> Result<()>

pub async fn transaction_subscribe( &self, config: RpcTransactionsConfig, ) -> Result<(BoxStream<'_, TransactionNotification>, Box<dyn FnOnce() -> BoxFuture<'static, ()> + Send>)>

Stream transactions with numerous configurations and filters to choose from.

Example

use helius::Helius;
use helius::error::Result;
use helius::types::{Cluster, RpcTransactionsConfig, TransactionSubscribeFilter, TransactionSubscribeOptions};
use solana_sdk::pubkey;
use tokio_stream::StreamExt;

#[tokio::main]
async fn main() -> Result<()> {
  let helius = Helius::new("your_api_key", Cluster::MainnetBeta).expect("Failed to create a Helius client");
  // you may monitor transactions for any pubkey, this is just an example.
  let key = pubkey!("BtsmiEEvnSuUnKxqXj2PZRYpPJAc7C34mGz8gtJ1DAaH");
  let config = RpcTransactionsConfig {
    filter: TransactionSubscribeFilter::standard(&key),
    options: TransactionSubscribeOptions::default(),
  };
  if let Some(ws) = helius.ws() {
    let (mut stream, _unsub) = ws.transaction_subscribe(config).await?;
    while let Some(event) = stream.next().await {
      println!("{:#?}", event);
    }
  }
  Ok(())
}

pub async fn account_subscribe( &self, pubkey: &Pubkey, config: Option<RpcAccountInfoConfig>, ) -> Result<(BoxStream<'_, RpcResponse<UiAccount>>, Box<dyn FnOnce() -> BoxFuture<'static, ()> + Send>)>

Stream accounts with numerous configurations and filters to choose from.

Example

use helius::Helius;
use helius::error::Result;
use helius::types::{Cluster, RpcTransactionsConfig, TransactionSubscribeFilter, TransactionSubscribeOptions};
use solana_sdk::pubkey;
use tokio_stream::StreamExt;

#[tokio::main]
async fn main() -> Result<()> {
  let helius = Helius::new("your_api_key", Cluster::MainnetBeta).expect("Failed to create a Helius client");
  // you may monitor updates for any account pubkey, this is just an example.
  let key = pubkey!("BtsmiEEvnSuUnKxqXj2PZRYpPJAc7C34mGz8gtJ1DAaH");
  if let Some(ws) = helius.ws() {
    let (mut stream, _unsub) = ws.account_subscribe(&key, None).await?;
    while let Some(event) = stream.next().await {
      println!("{:#?}", event);
    }
  }
  Ok(())
}