Struct HttpTransportClient

pub struct HttpTransportClient {
    pub client: Arc<Client>,
    /* private fields */
}

Basic HTTP transport client for blockchain interactions

This client provides a foundation for making JSON-RPC requests to blockchain nodes with built-in support for:

• Connection pooling and reuse
• Automatic endpoint rotation on failure
• Configurable retry policies

The client is thread-safe and can be shared across multiple tasks.

Fields

client: Arc<Client>

HTTP client for making requests, wrapped in Arc for thread-safety

Implementations

impl HttpTransportClient

pub async fn new( network: &Network, test_connection_payload: Option<String>, ) -> Result<Self, Error>

Creates a new HTTP transport client with automatic endpoint management

This constructor attempts to connect to available endpoints in order of their weight until a successful connection is established. It configures default timeout and retry policies suitable for blockchain interactions.

Arguments

• network - Network configuration containing RPC URLs, weights, and other details
• test_connection_payload - Optional JSON RPC payload to test the connection (default is net_version)

Returns

• Result<Self, anyhow::Error> - New client instance or connection error

Trait Implementations

impl BlockchainTransport for HttpTransportClient

fn get_current_url<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = String> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Retrieves the currently active RPC endpoint URL

This method is useful for monitoring which endpoint is currently in use, especially in scenarios with multiple failover URLs.

Returns

• String - The URL of the currently active endpoint

fn send_raw_request<'life0, 'life1, 'async_trait, P>( &'life0 self, method: &'life1 str, params: Option<P>, ) -> Pin<Box<dyn Future<Output = Result<Value, Error>> + Send + 'async_trait>>

where P: Into<Value> + Send + Clone + Serialize + 'async_trait, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Sends a JSON-RPC request to the blockchain node

This method handles the formatting of the JSON-RPC request, including:

• Adding required JSON-RPC 2.0 fields
• Generating unique request IDs
• Converting parameters to the correct format
• Handling authentication

Arguments

• method - The JSON-RPC method name to call
• params - Optional parameters for the method call

Returns

• Result<Value, anyhow::Error> - JSON response or error with context

Type Parameters

• P - Parameter type that can be serialized to JSON

fn set_retry_policy( &mut self, retry_policy: ExponentialBackoff, retry_strategy: Option<TransientErrorRetryStrategy>, ) -> Result<(), Error>

Updates the retry policy configuration

Arguments

• retry_policy - New retry policy to use for subsequent requests
• retry_strategy - Optional retry strategy to use for subsequent requests

Returns

• Result<(), anyhow::Error> - Success or error status

fn update_endpoint_manager_client( &mut self, client: ClientWithMiddleware, ) -> Result<(), Error>

Update endpoint manager with a new client

Arguments

• client - The new client to use for the endpoint manager

fn customize_request<'life0, 'life1, 'async_trait, P>( &'life0 self, method: &'life1 str, params: Option<P>, ) -> Pin<Box<dyn Future<Output = Value> + Send + 'async_trait>>

where P: Into<Value> + Send + Clone + Serialize + 'async_trait, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Customizes the request for specific blockchain requirements

impl Clone for HttpTransportClient

fn clone(&self) -> HttpTransportClient

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for HttpTransportClient

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl RotatingTransport for HttpTransportClient

fn try_connect<'life0, 'life1, 'async_trait>( &'life0 self, url: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Tests connectivity to a specific RPC endpoint

Performs a basic JSON-RPC request to verify the endpoint is responsive and correctly handling requests.

Arguments

• url - The URL to test

Returns

• Result<(), anyhow::Error> - Success or detailed error message

fn update_client<'life0, 'life1, 'async_trait>( &'life0 self, url: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Updates the active endpoint URL

This method is called when rotating to a new endpoint, typically after a failure of the current endpoint.

Arguments

• url - The new URL to use for subsequent requests

Returns

• Result<(), anyhow::Error> - Success or error status