Struct lumina_node::test_utils::MockP2pHandle

pub struct MockP2pHandle { /* private fields */ }

Available on crate feature test-utils only.

A handle to the mocked P2p component.

Implementations

impl MockP2pHandle

pub fn announce_peer_connected(&self)

Simulate a new connected peer.

pub fn announce_trusted_peer_connected(&self)

Simulate a new connected trusted peer.

pub fn announce_all_peers_disconnected(&self)

Simulate a disconnect from all peers.

pub fn announce_new_head(&self, header: ExtendedHeader)

Simulate a new header announced in the network.

pub async fn expect_no_cmd(&mut self)

Assert that no command was sent to the P2p worker.

pub async fn expect_header_request_cmd( &mut self, ) -> (HeaderRequest, Sender<Result<Vec<ExtendedHeader>, P2pError>>)

Assert that a header request was sent to the P2p worker and obtain a response channel.

pub async fn expect_header_request_for_height_cmd( &mut self, ) -> (u64, u64, Sender<Result<Vec<ExtendedHeader>, P2pError>>)

Assert that a header request for height was sent to the P2p worker and obtain a response channel.

pub async fn expect_header_request_for_hash_cmd( &mut self, ) -> (Hash, Sender<Result<Vec<ExtendedHeader>, P2pError>>)

Assert that a header request for hash was sent to the P2p worker and obtain a response channel.

pub async fn expect_init_header_sub(&mut self) -> ExtendedHeader

Assert that a header-sub initialization command was sent to the P2p worker.

pub async fn expect_get_shwap_cid( &mut self, ) -> (Cid, Sender<Result<Vec<u8>, P2pError>>)

Assert that a CID request was sent to the P2p worker and obtain a response channel.