Struct NodeTestContext

pub struct NodeTestContext<Node, AddOns>
where
    Node: FullNodeComponents,
    AddOns: RethRpcAddOns<Node>,
{
    pub inner: FullNode<Node, AddOns>,
    pub payload: PayloadTestContext<<Node::Types as NodeTypes>::Payload>,
    pub network: NetworkTestContext<Node::Network>,
    pub rpc: RpcTestContext<Node, AddOns::EthApi>,
    pub canonical_stream: CanonStateNotificationStream<PrimitivesTy<Node::Types>>,
}

An helper struct to handle node actions

Fields

inner: FullNode<Node, AddOns>

The core structure representing the full node.

payload: PayloadTestContext<<Node::Types as NodeTypes>::Payload>

Context for testing payload-related features.

network: NetworkTestContext<Node::Network>

Context for testing network functionalities.

rpc: RpcTestContext<Node, AddOns::EthApi>

Context for testing RPC features.

canonical_stream: CanonStateNotificationStream<PrimitivesTy<Node::Types>>

Canonical state events.

Implementations

impl<Node, Payload, AddOns> NodeTestContext<Node, AddOns>

where Payload: PayloadTypes, Node: FullNodeComponents, Node::Types: NodeTypes<ChainSpec: EthereumHardforks, Payload = Payload>, Node::Network: PeersHandleProvider, AddOns: RethRpcAddOns<Node>,

pub async fn new( node: FullNode<Node, AddOns>, attributes_generator: impl Fn(u64) -> Payload::PayloadBuilderAttributes + Send + Sync + 'static, ) -> Result<Self>

Creates a new test node

pub async fn connect(&mut self, node: &mut Self)

Establish a connection to the node

pub async fn advance( &mut self, length: u64, tx_generator: impl Fn(u64) -> Pin<Box<dyn Future<Output = Bytes>>>, ) -> Result<Vec<Payload::BuiltPayload>>

where AddOns::EthApi: EthApiSpec<Provider: BlockReader<Block = BlockTy<Node::Types>>> + FullEthApi + TraceExt,

Advances the chain length blocks.

Returns the added chain as a Vec of block hashes.

pub async fn new_payload(&mut self) -> Result<Payload::BuiltPayload>

Creates a new payload from given attributes generator expects a payload attribute event and waits until the payload is built.

It triggers the resolve payload via engine api and expects the built payload event.

pub async fn build_and_submit_payload( &mut self, ) -> Result<Payload::BuiltPayload>

Triggers payload building job and submits it to the engine.

pub async fn advance_block(&mut self) -> Result<Payload::BuiltPayload>

Advances the node forward one block

pub async fn wait_block( &self, number: BlockNumber, expected_block_hash: BlockHash, wait_finish_checkpoint: bool, ) -> Result<()>

Waits for block to be available on node.

pub async fn wait_unwind(&self, number: BlockNumber) -> Result<()>

Waits for the node to unwind to the given block number

pub async fn assert_new_block( &mut self, tip_tx_hash: B256, block_hash: B256, block_number: BlockNumber, ) -> Result<()>

Asserts that a new block has been added to the blockchain and the tx has been included in the block.

Does NOT work for pipeline since there’s no stream notification!

pub fn block_hash(&self, number: u64) -> BlockHash

Gets block hash by number.

pub async fn sync_to(&self, block: BlockHash) -> Result<()>

Sends FCU and waits for the node to sync to the given block.

pub async fn update_forkchoice( &self, current_head: B256, new_head: B256, ) -> Result<()>

Sends a forkchoice update message to the engine.

pub async fn update_optimistic_forkchoice(&self, hash: B256) -> Result<()>

Sends forkchoice update to the engine api with a zero finalized hash

pub async fn submit_payload( &self, payload: Payload::BuiltPayload, ) -> Result<B256>

Submits a payload to the engine.

pub fn rpc_url(&self) -> Url

Returns the RPC URL.

pub fn rpc_client(&self) -> Option<HttpClient>

Returns an RPC client.

pub fn auth_server_handle(&self) -> AuthServerHandle

Returns an Engine API client.

Layout

Note: Unable to compute type layout, possibly due to this type having generic parameters. Layout can only be computed for concrete, fully-instantiated types.