#![warn(missing_docs)]
pub mod client_ext;
pub use self::client_ext::{BlockOrigin, ClientBlockImportExt, ClientExt};
pub use sc_client_api::{execution_extensions::ExecutionExtensions, BadBlocks, ForkBlocks};
pub use sc_client_db::{self, Backend, BlocksPruning};
pub use sc_executor::{self, WasmExecutionMethod, WasmExecutor};
pub use sc_service::{client, RpcHandlers};
pub use sp_consensus;
pub use sp_keyring::{Ed25519Keyring, Sr25519Keyring};
pub use sp_keystore::{Keystore, KeystorePtr};
pub use sp_runtime::{Storage, StorageChild};
use futures::{future::Future, stream::StreamExt};
use sc_client_api::BlockchainEvents;
use sc_service::client::{ClientConfig, LocalCallExecutor};
use serde::Deserialize;
use sp_core::{storage::ChildInfo, testing::TaskExecutor};
use sp_runtime::{
codec::Encode,
traits::{Block as BlockT, Header},
OpaqueExtrinsic,
};
use std::{
collections::{HashMap, HashSet},
pin::Pin,
sync::Arc,
};
pub trait GenesisInit: Default {
fn genesis_storage(&self) -> Storage;
}
impl GenesisInit for () {
fn genesis_storage(&self) -> Storage {
Default::default()
}
}
pub struct TestClientBuilder<Block: BlockT, ExecutorDispatch, Backend: 'static, G: GenesisInit> {
genesis_init: G,
child_storage_extension: HashMap<Vec<u8>, StorageChild>,
backend: Arc<Backend>,
_executor: std::marker::PhantomData<ExecutorDispatch>,
fork_blocks: ForkBlocks<Block>,
bad_blocks: BadBlocks<Block>,
enable_offchain_indexing_api: bool,
enable_import_proof_recording: bool,
no_genesis: bool,
}
impl<Block: BlockT, ExecutorDispatch, G: GenesisInit> Default
for TestClientBuilder<Block, ExecutorDispatch, Backend<Block>, G>
{
fn default() -> Self {
Self::with_default_backend()
}
}
impl<Block: BlockT, ExecutorDispatch, G: GenesisInit>
TestClientBuilder<Block, ExecutorDispatch, Backend<Block>, G>
{
pub fn with_default_backend() -> Self {
let backend = Arc::new(Backend::new_test(std::u32::MAX, std::u64::MAX));
Self::with_backend(backend)
}
pub fn with_pruning_window(blocks_pruning: u32) -> Self {
let backend = Arc::new(Backend::new_test(blocks_pruning, 0));
Self::with_backend(backend)
}
pub fn with_tx_storage(blocks_pruning: u32) -> Self {
let backend =
Arc::new(Backend::new_test_with_tx_storage(BlocksPruning::Some(blocks_pruning), 0));
Self::with_backend(backend)
}
}
impl<Block: BlockT, ExecutorDispatch, Backend, G: GenesisInit>
TestClientBuilder<Block, ExecutorDispatch, Backend, G>
{
pub fn with_backend(backend: Arc<Backend>) -> Self {
TestClientBuilder {
backend,
child_storage_extension: Default::default(),
genesis_init: Default::default(),
_executor: Default::default(),
fork_blocks: None,
bad_blocks: None,
enable_offchain_indexing_api: false,
no_genesis: false,
enable_import_proof_recording: false,
}
}
pub fn genesis_init_mut(&mut self) -> &mut G {
&mut self.genesis_init
}
pub fn backend(&self) -> Arc<Backend> {
self.backend.clone()
}
pub fn add_child_storage(
mut self,
child_info: &ChildInfo,
key: impl AsRef<[u8]>,
value: impl AsRef<[u8]>,
) -> Self {
let storage_key = child_info.storage_key();
let entry = self.child_storage_extension.entry(storage_key.to_vec()).or_insert_with(|| {
StorageChild { data: Default::default(), child_info: child_info.clone() }
});
entry.data.insert(key.as_ref().to_vec(), value.as_ref().to_vec());
self
}
pub fn set_block_rules(
mut self,
fork_blocks: ForkBlocks<Block>,
bad_blocks: BadBlocks<Block>,
) -> Self {
self.fork_blocks = fork_blocks;
self.bad_blocks = bad_blocks;
self
}
pub fn enable_offchain_indexing_api(mut self) -> Self {
self.enable_offchain_indexing_api = true;
self
}
pub fn enable_import_proof_recording(mut self) -> Self {
self.enable_import_proof_recording = true;
self
}
pub fn set_no_genesis(mut self) -> Self {
self.no_genesis = true;
self
}
pub fn build_with_executor<RuntimeApi>(
self,
executor: ExecutorDispatch,
) -> (
client::Client<Backend, ExecutorDispatch, Block, RuntimeApi>,
sc_consensus::LongestChain<Backend, Block>,
)
where
ExecutorDispatch:
sc_client_api::CallExecutor<Block> + sc_executor::RuntimeVersionOf + Clone + 'static,
Backend: sc_client_api::backend::Backend<Block>,
<Backend as sc_client_api::backend::Backend<Block>>::OffchainStorage: 'static,
{
let storage = {
let mut storage = self.genesis_init.genesis_storage();
for (key, child_content) in self.child_storage_extension {
storage.children_default.insert(
key,
StorageChild {
data: child_content.data.into_iter().collect(),
child_info: child_content.child_info,
},
);
}
storage
};
let client_config = ClientConfig {
enable_import_proof_recording: self.enable_import_proof_recording,
offchain_indexing_api: self.enable_offchain_indexing_api,
no_genesis: self.no_genesis,
..Default::default()
};
let genesis_block_builder = sc_service::GenesisBlockBuilder::new(
&storage,
!client_config.no_genesis,
self.backend.clone(),
executor.clone(),
)
.expect("Creates genesis block builder");
let spawn_handle = Box::new(TaskExecutor::new());
let client = client::Client::new(
self.backend.clone(),
executor,
spawn_handle,
genesis_block_builder,
self.fork_blocks,
self.bad_blocks,
None,
None,
client_config,
)
.expect("Creates new client");
let longest_chain = sc_consensus::LongestChain::new(self.backend);
(client, longest_chain)
}
}
impl<Block: BlockT, H, Backend, G: GenesisInit>
TestClientBuilder<Block, client::LocalCallExecutor<Block, Backend, WasmExecutor<H>>, Backend, G>
{
pub fn build_with_native_executor<RuntimeApi, I>(
self,
executor: I,
) -> (
client::Client<
Backend,
client::LocalCallExecutor<Block, Backend, WasmExecutor<H>>,
Block,
RuntimeApi,
>,
sc_consensus::LongestChain<Backend, Block>,
)
where
I: Into<Option<WasmExecutor<H>>>,
Backend: sc_client_api::backend::Backend<Block> + 'static,
H: sc_executor::HostFunctions,
{
let executor = executor.into().unwrap_or_else(|| WasmExecutor::<H>::builder().build());
let executor = LocalCallExecutor::new(
self.backend.clone(),
executor.clone(),
Default::default(),
ExecutionExtensions::new(None, Arc::new(executor)),
)
.expect("Creates LocalCallExecutor");
self.build_with_executor(executor)
}
}
pub struct RpcTransactionOutput {
pub result: String,
pub receiver: tokio::sync::mpsc::Receiver<String>,
}
impl std::fmt::Debug for RpcTransactionOutput {
fn fmt(&self, f: &mut std::fmt::Formatter) -> std::fmt::Result {
write!(f, "RpcTransactionOutput {{ result: {:?}, receiver }}", self.result)
}
}
#[derive(Deserialize, Debug)]
pub struct RpcTransactionError {
pub code: i64,
pub message: String,
pub data: Option<serde_json::Value>,
}
impl std::fmt::Display for RpcTransactionError {
fn fmt(&self, f: &mut std::fmt::Formatter) -> std::fmt::Result {
std::fmt::Debug::fmt(self, f)
}
}
#[async_trait::async_trait]
pub trait RpcHandlersExt {
async fn send_transaction(
&self,
extrinsic: OpaqueExtrinsic,
) -> Result<RpcTransactionOutput, RpcTransactionError>;
}
#[async_trait::async_trait]
impl RpcHandlersExt for RpcHandlers {
async fn send_transaction(
&self,
extrinsic: OpaqueExtrinsic,
) -> Result<RpcTransactionOutput, RpcTransactionError> {
let (result, rx) = self
.rpc_query(&format!(
r#"{{
"jsonrpc": "2.0",
"method": "author_submitExtrinsic",
"params": ["0x{}"],
"id": 0
}}"#,
array_bytes::bytes2hex("", &extrinsic.encode())
))
.await
.expect("valid JSON-RPC request object; qed");
parse_rpc_result(result, rx)
}
}
pub(crate) fn parse_rpc_result(
result: String,
receiver: tokio::sync::mpsc::Receiver<String>,
) -> Result<RpcTransactionOutput, RpcTransactionError> {
let json: serde_json::Value =
serde_json::from_str(&result).expect("the result can only be a JSONRPC string; qed");
let error = json.as_object().expect("JSON result is always an object; qed").get("error");
if let Some(error) = error {
return Err(serde_json::from_value(error.clone())
.expect("the JSONRPC result's error is always valid; qed"))
}
Ok(RpcTransactionOutput { result, receiver })
}
pub trait BlockchainEventsExt<C, B>
where
C: BlockchainEvents<B>,
B: BlockT,
{
fn wait_for_blocks(&self, count: usize) -> Pin<Box<dyn Future<Output = ()> + Send>>;
}
impl<C, B> BlockchainEventsExt<C, B> for C
where
C: BlockchainEvents<B>,
B: BlockT,
{
fn wait_for_blocks(&self, count: usize) -> Pin<Box<dyn Future<Output = ()> + Send>> {
assert!(count > 0, "'count' argument must be greater than 0");
let mut import_notification_stream = self.import_notification_stream();
let mut blocks = HashSet::new();
Box::pin(async move {
while let Some(notification) = import_notification_stream.next().await {
if notification.is_new_best {
blocks.insert(*notification.header.number());
if blocks.len() == count {
break
}
}
}
})
}
}
#[cfg(test)]
mod tests {
#[test]
fn parses_error_properly() {
let (_, rx) = tokio::sync::mpsc::channel(1);
assert!(super::parse_rpc_result(
r#"{
"jsonrpc": "2.0",
"result": 19,
"id": 1
}"#
.to_string(),
rx
)
.is_ok());
let (_, rx) = tokio::sync::mpsc::channel(1);
let error = super::parse_rpc_result(
r#"{
"jsonrpc": "2.0",
"error": {
"code": -32601,
"message": "Method not found"
},
"id": 1
}"#
.to_string(),
rx,
)
.unwrap_err();
assert_eq!(error.code, -32601);
assert_eq!(error.message, "Method not found");
assert!(error.data.is_none());
let (_, rx) = tokio::sync::mpsc::channel(1);
let error = super::parse_rpc_result(
r#"{
"jsonrpc": "2.0",
"error": {
"code": -32601,
"message": "Method not found",
"data": 42
},
"id": 1
}"#
.to_string(),
rx,
)
.unwrap_err();
assert_eq!(error.code, -32601);
assert_eq!(error.message, "Method not found");
assert!(error.data.is_some());
}
}