Struct PeerFetcher 

pub struct PeerFetcher { /* private fields */ }

A CoinStateFetcher backed by a live wallet-protocol Peer.

The peer sits behind an RwLock<Option<_>> so swap_peer can replace it on reconnect while in-flight readers keep working against the peer they cloned.

Implementations

impl PeerFetcher

pub fn new( peer: Peer, genesis_challenge: Bytes32, request_timeout: Duration, ) -> Self

Builds a fetcher over peer, using genesis_challenge as the height-0 header_hash and bounding every request with request_timeout.

pub async fn swap_peer(&self, peer: Peer)

Replaces the underlying peer (used by reconnect).

pub async fn send_transaction( &self, bundle: SpendBundle, ) -> Result<u8, ChiaPeerError>

Submits bundle to the network, returning the ack status byte (1 = success/pending).

pub async fn remove_coin_subscriptions( &self, coin_ids: Vec<Bytes32>, ) -> Result<(), ChiaPeerError>

Removes the server-side subscription to coin_ids (wraps remove_coin_subscriptions).

Trait Implementations

impl Clone for PeerFetcher

fn clone(&self) -> PeerFetcher

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl CoinStateFetcher for PeerFetcher

fn coin_states<'life0, 'async_trait>( &'life0 self, coin_ids: Vec<Bytes32>, subscribe: bool, ) -> Pin<Box<dyn Future<Output = Result<Vec<CoinState>, ChiaPeerError>> + Send + 'async_trait>>

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

Reads the current state of coin_ids. An empty result is a PROVABLE absence.

fn puzzle_states<'life0, 'async_trait>( &'life0 self, puzzle_hashes: Vec<Bytes32>, filters: CoinStateFilters, subscribe: bool, ) -> Pin<Box<dyn Future<Output = Result<Vec<CoinState>, ChiaPeerError>> + Send + 'async_trait>>

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

Reads every coin paying to puzzle_hashes (paging through the peer’s is_finished protocol until complete), applying filters.

fn children<'life0, 'async_trait>( &'life0 self, coin_id: Bytes32, ) -> Pin<Box<dyn Future<Output = Result<Vec<CoinState>, ChiaPeerError>> + Send + 'async_trait>>

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

Reads the direct children created by spending coin_id.

fn puzzle_and_solution<'life0, 'async_trait>( &'life0 self, coin_id: Bytes32, height: u32, ) -> Pin<Box<dyn Future<Output = Result<(Program, Program), ChiaPeerError>> + Send + 'async_trait>>

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

Reads the puzzle reveal + solution of the coin spent at height.