Struct DomainNode

pub struct DomainNode<Runtime, RuntimeApi>
where
    Runtime: DomainRuntime,
    RuntimeApi: ConstructRuntimeApi<Block, FullClient<Block, RuntimeApi>> + Send + Sync + 'static,
    RuntimeApi::RuntimeApi: ApiExt<Block> + Metadata<Block> + BlockBuilder<Block> + OffchainWorkerApi<Block> + SessionKeys<Block> + DomainCoreApi<Block> + MessengerApi<Block, NumberFor<Block>, <Block as BlockT>::Hash> + TaggedTransactionQueue<Block> + AccountNonceApi<Block, Runtime::AccountId, Nonce> + TransactionPaymentRuntimeApi<Block, Balance> + RelayerApi<Block, NumberFor<Block>, NumberFor<Block>, <Block as BlockT>::Hash>,
{
    pub domain_id: DomainId,
    pub key: Runtime::Keyring,
    pub task_manager: TaskManager,
    pub client: Arc<FullClient<Block, RuntimeApi>>,
    pub backend: Arc<Backend>,
    pub code_executor: Arc<RuntimeExecutor>,
    pub network_service: Arc<dyn NetworkService>,
    pub sync_service: Arc<SyncingService<Block>>,
    pub addr: MultiaddrWithPeerId,
    pub rpc_handlers: RpcHandlers,
    pub operator: DomainOperator<RuntimeApi>,
    pub tx_pool_sink: TracingUnboundedSender<ChainMsg>,
}

A generic domain node instance used for testing.

Fields

domain_id: DomainId

The domain id

key: Runtime::Keyring

The node’s account key

task_manager: TaskManager

TaskManager’s instance.

client: Arc<FullClient<Block, RuntimeApi>>

Client’s instance.

backend: Arc<Backend>

Client backend.

code_executor: Arc<RuntimeExecutor>

Code executor.

network_service: Arc<dyn NetworkService>

Network service.

sync_service: Arc<SyncingService<Block>>

Sync service.

addr: MultiaddrWithPeerId

The MultiaddrWithPeerId to this node. This is useful if you want to pass it as “boot node” to other nodes.

rpc_handlers: RpcHandlers

RPCHandlers to make RPC queries.

operator: DomainOperator<RuntimeApi>

Domain oeprator.

tx_pool_sink: TracingUnboundedSender<ChainMsg>

Sink to the node’s tx pool

Implementations

impl<Runtime, RuntimeApi> DomainNode<Runtime, RuntimeApi>

where Runtime: Config<Hash = H256> + Config + DomainRuntime + Send + Sync, Runtime::RuntimeCall: Dispatchable<Info = DispatchInfo, PostInfo = PostDispatchInfo> + Send + Sync, <<Runtime as Config>::OnChargeTransaction as OnChargeTransaction<Runtime>>::Balance: Send + Sync + From<u64> + FixedPointOperand, u64: From<BlockNumberFor<Runtime>>, RuntimeApi: ConstructRuntimeApi<Block, FullClient<Block, RuntimeApi>> + Send + Sync + 'static, RuntimeApi::RuntimeApi: ApiExt<Block> + Metadata<Block> + BlockBuilder<Block> + OffchainWorkerApi<Block> + SessionKeys<Block> + DomainCoreApi<Block> + TaggedTransactionQueue<Block> + AccountNonceApi<Block, <Runtime as DomainRuntime>::AccountId, Nonce> + TransactionPaymentRuntimeApi<Block, Balance> + MessengerApi<Block, NumberFor<Block>, <Block as BlockT>::Hash> + RelayerApi<Block, NumberFor<Block>, NumberFor<Block>, <Block as BlockT>::Hash> + OnchainStateApi<Block, <Runtime as DomainRuntime>::AccountId, Balance>,

pub fn wait_for_blocks(&self, count: usize) -> impl Future<Output = ()>

Wait for count blocks to be imported in the node and then exit. This function will not return if no blocks are ever created, thus you should restrict the maximum amount of time of the test execution.

pub fn account_nonce(&self) -> u32

Get the nonce of the node account

pub async fn send_system_remark(&mut self)

Sends an system.remark extrinsic to the pool.

pub async fn construct_and_send_extrinsic( &mut self, function: impl Into<<Runtime as Config>::RuntimeCall>, ) -> Result<RpcTransactionOutput, RpcTransactionError>

Construct an extrinsic with the current nonce of the node account and send it to this node.

pub async fn construct_and_send_extrinsic_with( &self, nonce: u32, tip: <<Runtime as Config>::OnChargeTransaction as OnChargeTransaction<Runtime>>::Balance, function: impl Into<<Runtime as Config>::RuntimeCall>, ) -> Result<RpcTransactionOutput, RpcTransactionError>

Construct an extrinsic with the given nonce and tip for the node account and send it to this node.

pub fn construct_extrinsic( &mut self, nonce: u32, function: impl Into<<Runtime as Config>::RuntimeCall>, ) -> UncheckedExtrinsic<<Runtime as DomainRuntime>::Address, <Runtime as Config>::RuntimeCall, <Runtime as DomainRuntime>::Signature, (CheckNonZeroSender<Runtime>, CheckSpecVersion<Runtime>, CheckTxVersion<Runtime>, CheckGenesis<Runtime>, CheckMortality<Runtime>, CheckNonce<Runtime>, CheckWeight<Runtime>, ChargeTransactionPayment<Runtime>)>

Construct an extrinsic.

pub fn construct_extrinsic_with_tip( &mut self, nonce: u32, tip: <<Runtime as Config>::OnChargeTransaction as OnChargeTransaction<Runtime>>::Balance, function: impl Into<<Runtime as Config>::RuntimeCall>, ) -> UncheckedExtrinsic<<Runtime as DomainRuntime>::Address, <Runtime as Config>::RuntimeCall, <Runtime as DomainRuntime>::Signature, (CheckNonZeroSender<Runtime>, CheckSpecVersion<Runtime>, CheckTxVersion<Runtime>, CheckGenesis<Runtime>, CheckMortality<Runtime>, CheckNonce<Runtime>, CheckWeight<Runtime>, ChargeTransactionPayment<Runtime>)>

Construct an extrinsic with the given transaction tip.

pub async fn send_extrinsic( &self, extrinsic: impl Into<OpaqueExtrinsic>, ) -> Result<RpcTransactionOutput, RpcTransactionError>

Send an extrinsic to this node.

pub fn free_balance( &self, account_id: <Runtime as DomainRuntime>::AccountId, ) -> Balance

Get the free balance of the given account

pub fn get_open_channel_for_chain(&self, chain_id: ChainId) -> Option<ChannelId>

Returns the open XDM channel for given chain

pub fn construct_unsigned_extrinsic( &self, function: impl Into<<Runtime as Config>::RuntimeCall>, ) -> UncheckedExtrinsic<<Runtime as DomainRuntime>::Address, <Runtime as Config>::RuntimeCall, <Runtime as DomainRuntime>::Signature, (CheckNonZeroSender<Runtime>, CheckSpecVersion<Runtime>, CheckTxVersion<Runtime>, CheckGenesis<Runtime>, CheckMortality<Runtime>, CheckNonce<Runtime>, CheckWeight<Runtime>, ChargeTransactionPayment<Runtime>)>

where Runtime: Config<Hash = H256> + Config + Send + Sync, Runtime::RuntimeCall: Dispatchable<Info = DispatchInfo, PostInfo = PostDispatchInfo> + Send + Sync, <<Runtime as Config>::OnChargeTransaction as OnChargeTransaction<Runtime>>::Balance: Send + Sync + From<u64> + FixedPointOperand,

Construct an unsigned extrinsic that can be applied to the test runtime.