Struct test_runner::Node

pub struct Node<T: ChainInfo> { /* fields omitted */ }

This holds a reference to a running node on another thread, the node process is dropped when this struct is dropped also holds logs from the process.

Implementations

impl<T> Node<T> where
    T: ChainInfo,
    <<T::Block as BlockT>::Header as Header>::Number: From<u32>, 

pub fn new(
    rpc_handler: Arc<MetaIoHandler<Metadata, RpcMiddleware>>,
    task_manager: TaskManager,
    client: Arc<TFullClient<T::Block, T::RuntimeApi, T::Executor>>,
    pool: Arc<dyn TransactionPool<Block = <T as ChainInfo>::Block, Hash = <<T as ChainInfo>::Block as BlockT>::Hash, Error = Error, InPoolTransaction = Transaction<<<T as ChainInfo>::Block as BlockT>::Hash, <<T as ChainInfo>::Block as BlockT>::Extrinsic>>>,
    command_sink: Sender<EngineCommand<<T::Block as BlockT>::Hash>>,
    backend: Arc<TFullBackend<T::Block>>
) -> Self

Creates a new node.

pub fn rpc_handler(&self) -> Arc<MetaIoHandler<Metadata, RpcMiddleware>>

Returns a reference to the rpc handlers, use this to send rpc requests. eg

	let request = r#"{"jsonrpc":"2.0","method":"engine_createBlock","params": [true, true],"id":1}"#;
		let response = node.rpc_handler()
		.handle_request_sync(request, Default::default());

pub fn client(&self) -> Arc<TFullClient<T::Block, T::RuntimeApi, T::Executor>>

Return a reference to the Client

pub fn pool(
    &self
) -> Arc<dyn TransactionPool<Block = <T as ChainInfo>::Block, Hash = <<T as ChainInfo>::Block as BlockT>::Hash, Error = Error, InPoolTransaction = Transaction<<<T as ChainInfo>::Block as BlockT>::Hash, <<T as ChainInfo>::Block as BlockT>::Extrinsic>>>

Return a reference to the pool.

pub fn with_state<R>(&self, closure: impl FnOnce() -> R) -> R where
    <TFullCallExecutor<T::Block, T::Executor> as CallExecutor<T::Block>>::Error: Debug, 

Executes closure in an externalities provided environment.

pub async fn submit_extrinsic(
    &self,
    call: impl Into<<T::Runtime as Config>::Call>,
    signer: Option<<T::Runtime as Config>::AccountId>
) -> Result<<T::Block as BlockT>::Hash, Error> where
    <T::Block as BlockT>::Extrinsic: From<UncheckedExtrinsic<MultiAddress<<T::Runtime as Config>::AccountId, <T::Runtime as Config>::Index>, <T::Runtime as Config>::Call, MultiSignature, T::SignedExtras>>, 

submit some extrinsic to the node. if signer is None, will submit unsigned_extrinsic.

pub fn events(
    &self
) -> Vec<EventRecord<<T::Runtime as Config>::Event, <T::Runtime as Config>::Hash>>

Get the events of the most recently produced block

pub async fn seal_blocks(&self, num: usize)

Instructs manual seal to seal new, possibly empty blocks.

pub fn revert_blocks(&self, count: NumberFor<T::Block>)

Revert count number of blocks from the chain.

pub async fn until_shutdown(self)

so you’ve decided to run the test runner as a binary, use this to shutdown gracefully.

Trait Implementations

impl<T: ChainInfo> Drop for Node<T>

fn drop(&mut self)

Executes the destructor for this type.