Struct RpcOperations

pub struct RpcOperations<R: HttpRequestor + 'static + Clone> { /* private fields */ }

Implementation of HoprRpcOperations and HoprIndexerRpcOperations trait via alloy

Implementations

impl<R: HttpRequestor + 'static + Clone> RpcOperations<R>

pub fn new( rpc_client: RpcClient, requestor: R, chain_key: &ChainKeypair, cfg: RpcOperationsConfig, use_dummy_nr: Option<bool>, ) -> Result<Self>

Trait Implementations

impl<R: Clone + HttpRequestor + 'static + Clone> Clone for RpcOperations<R>

fn clone(&self) -> RpcOperations<R>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<R: Debug + HttpRequestor + 'static + Clone> Debug for RpcOperations<R>

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

Formats the value using the given formatter.

impl<R: HttpRequestor + 'static + Clone> HoprIndexerRpcOperations for RpcOperations<R>

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

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

Retrieves the latest block number.

fn get_hopr_allowance<'life0, 'async_trait>( &'life0 self, owner: Address, spender: Address, ) -> Pin<Box<dyn Future<Output = Result<HoprBalance>> + Send + 'async_trait>>

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

Queries the HOPR token allowance between owner and spender addresses.

fn get_xdai_balance<'life0, 'async_trait>( &'life0 self, address: Address, ) -> Pin<Box<dyn Future<Output = Result<XDaiBalance>> + Send + 'async_trait>>

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

Queries the xDAI (native token) balance for a specific address.

fn get_hopr_balance<'life0, 'async_trait>( &'life0 self, address: Address, ) -> Pin<Box<dyn Future<Output = Result<HoprBalance>> + Send + 'async_trait>>

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

Queries the HOPR token balance for a specific address.

fn try_stream_logs<'a>( &'a self, start_block_number: u64, filters: FilterSet, is_synced: bool, ) -> Result<Pin<Box<dyn Stream<Item = BlockWithLogs> + Send + 'a>>>

Streams blockchain logs using selective filtering based on synchronization state.

impl<R: HttpRequestor + 'static + Clone> HoprRpcOperations for RpcOperations<R>

fn get_timestamp<'life0, 'async_trait>( &'life0 self, block_number: u64, ) -> Pin<Box<dyn Future<Output = Result<Option<u64>>> + Send + 'async_trait>>

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

Retrieves the timestamp from the given block number.

fn get_xdai_balance<'life0, 'async_trait>( &'life0 self, address: Address, ) -> Pin<Box<dyn Future<Output = Result<XDaiBalance>> + Send + 'async_trait>>

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

Retrieves on-chain xdai balance of the given address.

fn get_hopr_balance<'life0, 'async_trait>( &'life0 self, address: Address, ) -> Pin<Box<dyn Future<Output = Result<HoprBalance>> + Send + 'async_trait>>

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

Retrieves on-chain wxHOPR token balance of the given address.

fn get_hopr_allowance<'life0, 'async_trait>( &'life0 self, owner: Address, spender: Address, ) -> Pin<Box<dyn Future<Output = Result<HoprBalance>> + Send + 'async_trait>>

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

Retrieves the wxHOPR token allowance for the given owner and spender.

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

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

Retrieves the minimum incoming ticket winning probability by directly calling the network’s winning probability oracle.

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

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

Retrieves the minimum ticket prices by directly calling the network’s ticket price oracle.

fn get_eligibility_status<'life0, 'async_trait>( &'life0 self, address: Address, ) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>

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

Retrieves the node’s eligibility status

fn get_node_management_module_target_info<'life0, 'async_trait>( &'life0 self, target: Address, ) -> Pin<Box<dyn Future<Output = Result<Option<U256>>> + Send + 'async_trait>>

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

Retrieves information of the given node module’s target.

fn get_safe_from_node_safe_registry<'life0, 'async_trait>( &'life0 self, node_address: Address, ) -> Pin<Box<dyn Future<Output = Result<Address>> + Send + 'async_trait>>

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

Retrieves the safe address of the given node address from the registry.

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

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

Retrieves the target address of the node module.

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

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

Retrieves the notice period of channel closure from the Channels contract.

fn check_node_safe_module_status<'life0, 'async_trait>( &'life0 self, node_address: Address, ) -> Pin<Box<dyn Future<Output = Result<NodeSafeModuleStatus>> + Send + 'async_trait>>

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

Retrieves the on-chain status of node, safe, and module.

fn send_transaction<'life0, 'async_trait>( &'life0 self, tx: TransactionRequest, ) -> Pin<Box<dyn Future<Output = Result<PendingTransaction>> + Send + 'async_trait>>

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

Sends transaction to the RPC provider.