jsonrpsee integration (paritytech#8783)

* Add tokio * No need to map CallError to CallError * jsonrpsee proc macros (paritytech#9673) * port error types to `JsonRpseeError` * migrate chain module to proc macro api * make it compile with proc macros * update branch * update branch * update to jsonrpsee master * port system rpc * port state rpc * port childstate & offchain * frame system rpc * frame transaction payment * bring back CORS hack to work with polkadot UI * port babe rpc * port manual seal rpc * port frame mmr rpc * port frame contracts rpc * port finality grandpa rpc * port sync state rpc * resolve a few TODO + no jsonrpc deps * Update bin/node/rpc-client/src/main.rs * Update bin/node/rpc-client/src/main.rs * Update bin/node/rpc-client/src/main.rs * Update bin/node/rpc-client/src/main.rs * Port over system_ rpc tests * Make it compile * Use prost 0.8 * Use prost 0.8 * Make it compile * Ignore more failing tests * Comment out WIP tests * fix nit in frame system api * Update lockfile * No more juggling tokio versions * No more wait_for_stop ? * Remove browser-testing * Arguments must be arrays * Use same argument names * Resolve todo: no wait_for_stop for WS server Add todo: is parse_rpc_result used? Cleanup imports * fmt * log * One test passes * update jsonrpsee * update jsonrpsee * cleanup rpc-servers crate * jsonrpsee: add host and origin filtering (paritytech#9787) * add access control in the jsonrpsee servers * use master * fix nits * rpc runtime_version safe * fix nits * fix grumbles * remove unused files * resolve some todos * jsonrpsee more cleanup (paritytech#9803) * more cleanup * resolve TODOs * fix some unwraps * remove type hints * update jsonrpsee * downgrade zeroize * pin jsonrpsee rev * remove unwrap nit * Comment out more tests that aren't ported * Comment out more tests * Fix tests after merge * Subscription test * Invalid nonce test * Pending exts * WIP removeExtrinsic test * Test remove_extrinsic * Make state test: should_return_storage work * Uncomment/fix the other non-subscription related state tests * test: author_insertKey * test: author_rotateKeys * Get rest of state tests passing * asyncify a little more * Add todo to note #msg change * Crashing test for has_session_keys * Fix error conversion to avoid stack overflows Port author_hasSessionKeys test fmt * test author_hasKey * Add two missing tests Add a check on the return type Add todos for James's concerns * RPC tests for state, author and system (paritytech#9859) * Fix test runner * Impl Default for SubscriptionTaskExecutor * Keep the minimul amount of code needed to compile tests * Re-instate `RpcSession` (for now) * cleanup * Port over RPC tests * Add tokio * No need to map CallError to CallError * Port over system_ rpc tests * Make it compile * Use prost 0.8 * Use prost 0.8 * Make it compile * Ignore more failing tests * Comment out WIP tests * Update lockfile * No more juggling tokio versions * No more wait_for_stop ? * Remove browser-testing * Arguments must be arrays * Use same argument names * Resolve todo: no wait_for_stop for WS server Add todo: is parse_rpc_result used? Cleanup imports * fmt * log * One test passes * Comment out more tests that aren't ported * Comment out more tests * Fix tests after merge * Subscription test * Invalid nonce test * Pending exts * WIP removeExtrinsic test * Test remove_extrinsic * Make state test: should_return_storage work * Uncomment/fix the other non-subscription related state tests * test: author_insertKey * test: author_rotateKeys * Get rest of state tests passing * asyncify a little more * Add todo to note #msg change * Crashing test for has_session_keys * Fix error conversion to avoid stack overflows Port author_hasSessionKeys test fmt * test author_hasKey * Add two missing tests Add a check on the return type Add todos for James's concerns * offchain rpc tests * Address todos * fmt Co-authored-by: James Wilson <[email protected]> * fix drop in state test * update jsonrpsee * fix ignored system test * fix chain tests * remove some boiler plate * Port BEEFY RPC (paritytech#9883) * Merge master * Port beefy RPC (ty @niklas!) * trivial changes left over from merge * Remove unused code * Update jsonrpsee * fix build * make tests compile again * beefy update jsonrpsee * fix: respect rpc methods policy * update cargo.lock * update jsonrpsee * update jsonrpsee * downgrade error logs * update jsonrpsee * Fix typo * remove unused file * Better name * Port Babe RPC tests * Put docs back * Resolve todo * Port tests for System RPCs * Resolve todo * fix build * Updated jsonrpsee to current master * fix: port finality grandpa rpc tests * Move .into() outside of the match * more review grumbles * jsonrpsee: add `rpc handlers` back (paritytech#10245) * add back RpcHandlers * cargo fmt * fix docs * fix grumble: remove needless alloc * resolve TODO * fmt * Fix typo * grumble: Use constants based on BASE_ERROR * grumble: DRY whitelisted listening addresses grumble: s/JSONRPC/JSON-RPC/ * cleanup * grumbles: Making readers aware of the possibility of gaps * review grumbles * grumbles * remove notes from niklasad1 * Update `jsonrpsee` * fix: jsonrpsee features * jsonrpsee: fallback to random port in case the specified port failed (paritytech#10304) * jsonrpsee: fallback to random port * better comment * Update client/rpc-servers/src/lib.rs Co-authored-by: Maciej Hirsz <[email protected]> * Update client/rpc-servers/src/lib.rs Co-authored-by: Maciej Hirsz <[email protected]> * address grumbles * cargo fmt * addrs already slice Co-authored-by: Maciej Hirsz <[email protected]> * Update jsonrpsee to 092081a0a2b8904c6ebd2cd99e16c7bc13ffc3ae * lockfile * update jsonrpsee * fix warning * Don't fetch jsonrpsee from crates * make tests compile again * fix rpc tests * remove unused deps * update tokio * fix rpc tests again * fix: test runner `HttpServerBuilder::builder` fails unless it's called within tokio runtime * cargo fmt * grumbles: fix subscription aliases * make clippy happy * update remaining subscriptions alias * cleanup * cleanup * fix chain subscription: less boiler plate (paritytech#10285) * fix chain subscription: less boiler plate * fix bad merge * cargo fmt * Switch to jsonrpsee 0.5 * fix build * add missing features * fix nit: remove needless Box::pin * Integrate jsonrpsee metrics (paritytech#10395) * draft metrics impl * Use latest api * Add missing file * Http server metrics * cleanup * bump jsonrpsee * Remove `ServerMetrics` and use a single middleware for both connection counting (aka sessions) and call metrics. * fix build * remove needless Arc::clone * Update to jsonrpsee 0.6 * lolz * fix metrics * Revert "lolz" This reverts commit eed6c6a. * fix: in-memory rpc support subscriptions * commit Cargo.lock * Update tests to 0.7 * fix TODOs * ws server: generate subscriptionIDs as Strings Some libraries seems to expect the subscription IDs to be Strings, let's not break this in this PR. * Increase timeout * Port over tests * cleanup * Using error codes from the spec * fix clippy * cargo fmt * update jsonrpsee * fix nits * fix: rpc_query * enable custom subid gen through spawn_tasks * remove unsed deps * unify tokio deps * Revert "enable custom subid gen through spawn_tasks" This reverts commit 5c5eb70. * fix bad merge of `test-utils` * fix more nits * downgrade wasm-instrument to 0.1.0 * [jsonrpsee]: enable custom RPC subscription ID generatation (paritytech#10731) * enable custom subid gen through spawn_tasks * fix nits * Update client/service/src/builder.rs Co-authored-by: David <[email protected]> * add Poc; needs jsonrpsee pr * update jsonrpsee * add re-exports * add docs Co-authored-by: David <[email protected]> * cargo fmt * fmt * port RPC-API dev * Remove unused file * fix nit: remove async trait * fix doc links * fix merge nit: remove jsonrpc deps * kill namespace on rpc apis * companion for jsonrpsee v0.10 (paritytech#11158) * companion for jsonrpsee v0.10 * update versions v0.10.0 * add some fixes * spelling * fix spaces Co-authored-by: Niklas Adolfsson <[email protected]> * send error before subs are closed * fix unsubscribe method names: chain * fix tests * jsonrpc server: print binded local address * grumbles: kill SubscriptionTaskExecutor * Update client/sync-state-rpc/src/lib.rs Co-authored-by: Bastian Köcher <[email protected]> * Update client/rpc/src/chain/chain_full.rs Co-authored-by: Bastian Köcher <[email protected]> * Update client/rpc/src/chain/chain_full.rs Co-authored-by: Bastian Köcher <[email protected]> * sync-state-rpc: kill anyhow * no more anyhow * remove todo * jsonrpsee: fix bad params in subscriptions. (paritytech#11251) * update jsonrpsee * fix error responses * revert error codes * dont do weird stuff in drop impl * rpc servers: remove needless clone * Remove silly constants * chore: update jsonrpsee v0.12 * commit Cargo.lock * deps: downgrade git2 * feat: CLI flag max subscriptions per connection * metrics: use old logging format * fix: read WS address from substrate output (paritytech#11379) Co-authored-by: Niklas Adolfsson <[email protected]> Co-authored-by: James Wilson <[email protected]> Co-authored-by: Maciej Hirsz <[email protected]> Co-authored-by: Maciej Hirsz <[email protected]> Co-authored-by: Bastian Köcher <[email protected]>
sensoriumxr · Jun 22, 2022 · b1340e1 · b1340e1
1 parent d5a9d7a
commit b1340e1
Show file tree

Hide file tree

Showing 93 changed files with 3,781 additions and 5,062 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/bin/node-template/node/Cargo.toml b/bin/node-template/node/Cargo.toml
@@ -42,7 +42,7 @@ frame-system = { version = "4.0.0-dev", path = "../../../frame/system" }
 pallet-transaction-payment = { version = "4.0.0-dev", default-features = false, path = "../../../frame/transaction-payment" }
 
 # These dependencies are used for the node template's RPCs
-jsonrpc-core = "18.0.0"
+jsonrpsee = { version = "0.12.0", features = ["server"] }
 sc-rpc = { version = "4.0.0-dev", path = "../../../client/rpc" }
 sp-api = { version = "4.0.0-dev", path = "../../../primitives/api" }
 sc-rpc-api = { version = "0.10.0-dev", path = "../../../client/rpc-api" }

diff --git a/bin/node-template/node/src/rpc.rs b/bin/node-template/node/src/rpc.rs
@@ -7,13 +7,15 @@
 
 use std::sync::Arc;
 
+use jsonrpsee::RpcModule;
 use node_template_runtime::{opaque::Block, AccountId, Balance, Index};
-pub use sc_rpc_api::DenyUnsafe;
 use sc_transaction_pool_api::TransactionPool;
 use sp_api::ProvideRuntimeApi;
 use sp_block_builder::BlockBuilder;
 use sp_blockchain::{Error as BlockChainError, HeaderBackend, HeaderMetadata};
 
+pub use sc_rpc_api::DenyUnsafe;
+
 /// Full client dependencies.
 pub struct FullDeps<C, P> {
  /// The client instance to use.
@@ -25,7 +27,9 @@ pub struct FullDeps<C, P> {
 }
 
 /// Instantiate all full RPC extensions.
-pub fn create_full<C, P>(deps: FullDeps<C, P>) -> jsonrpc_core::IoHandler<sc_rpc::Metadata>
+pub fn create_full<C, P>(
+ deps: FullDeps<C, P>,
+) -> Result<RpcModule<()>, Box<dyn std::error::Error + Send + Sync>>
 where
  C: ProvideRuntimeApi<Block>,
  C: HeaderBackend<Block> + HeaderMetadata<Block, Error = BlockChainError> + 'static,
@@ -35,20 +39,19 @@ where
  C::Api: BlockBuilder<Block>,
  P: TransactionPool + 'static,
 {
- use pallet_transaction_payment_rpc::{TransactionPayment, TransactionPaymentApi};
- use substrate_frame_rpc_system::{FullSystem, SystemApi};
+ use pallet_transaction_payment_rpc::{TransactionPaymentApiServer, TransactionPaymentRpc};
+ use substrate_frame_rpc_system::{SystemApiServer, SystemRpc};
 
- let mut io = jsonrpc_core::IoHandler::default();
+ let mut module = RpcModule::new(());
  let FullDeps { client, pool, deny_unsafe } = deps;
 
- io.extend_with(SystemApi::to_delegate(FullSystem::new(client.clone(), pool, deny_unsafe)));
-
- io.extend_with(TransactionPaymentApi::to_delegate(TransactionPayment::new(client)));
+ module.merge(SystemRpc::new(client.clone(), pool.clone(), deny_unsafe).into_rpc())?;
+ module.merge(TransactionPaymentRpc::new(client).into_rpc())?;
 
  // Extend this RPC with a custom API by using the following syntax.
  // `YourRpcStruct` should have a reference to a client, which is needed
  // to call into the runtime.
- // `io.extend_with(YourRpcTrait::to_delegate(YourRpcStruct::new(ReferenceToClient, ...)));`
+ // `module.merge(YourRpcTrait::into_rpc(YourRpcStruct::new(ReferenceToClient, ...)))?;`
 
- io
+ Ok(module)
 }
diff --git a/bin/node-template/node/src/service.rs b/bin/node-template/node/src/service.rs
@@ -228,8 +228,7 @@ pub fn new_full(mut config: Configuration) -> Result<TaskManager, ServiceError>
  Box::new(move |deny_unsafe, _| {
  let deps =
  crate::rpc::FullDeps { client: client.clone(), pool: pool.clone(), deny_unsafe };
-
- Ok(crate::rpc::create_full(deps))
+ crate::rpc::create_full(deps).map_err(Into::into)
  })
  };
 
@@ -239,7 +238,7 @@ pub fn new_full(mut config: Configuration) -> Result<TaskManager, ServiceError>
  keystore: keystore_container.sync_keystore(),
  task_manager: &mut task_manager,
  transaction_pool: transaction_pool.clone(),
- rpc_extensions_builder,
+ rpc_builder: rpc_extensions_builder,
  backend,
  system_rpc_tx,
  config,

diff --git a/bin/node/cli/Cargo.toml b/bin/node/cli/Cargo.toml
@@ -37,6 +37,7 @@ crate-type = ["cdylib", "rlib"]
 clap = { version = "3.1.6", features = ["derive"], optional = true }
 codec = { package = "parity-scale-codec", version = "3.0.0" }
 serde = { version = "1.0.136", features = ["derive"] }
+jsonrpsee = { version = "0.12.0", features = ["server"] }
 futures = "0.3.21"
 hex-literal = "0.3.4"
 log = "0.4.16"

diff --git a/bin/node/cli/benches/block_production.rs b/bin/node/cli/benches/block_production.rs
@@ -92,6 +92,10 @@ fn new_node(tokio_handle: Handle) -> node_cli::service::NewFullBase {
  rpc_cors: None,
  rpc_methods: Default::default(),
  rpc_max_payload: None,
+ rpc_max_request_size: None,
+ rpc_max_response_size: None,
+ rpc_id_provider: None,
+ rpc_max_subs_per_conn: None,
  ws_max_out_buffer_capacity: None,
  prometheus_config: None,
  telemetry_endpoints: None,

diff --git a/bin/node/cli/benches/transaction_pool.rs b/bin/node/cli/benches/transaction_pool.rs
@@ -84,6 +84,10 @@ fn new_node(tokio_handle: Handle) -> node_cli::service::NewFullBase {
  rpc_cors: None,
  rpc_methods: Default::default(),
  rpc_max_payload: None,
+ rpc_max_request_size: None,
+ rpc_max_response_size: None,
+ rpc_id_provider: None,
+ rpc_max_subs_per_conn: None,
  ws_max_out_buffer_capacity: None,
  prometheus_config: None,
  telemetry_endpoints: None,

diff --git a/bin/node/cli/src/service.rs b/bin/node/cli/src/service.rs
@@ -134,7 +134,7 @@ pub fn new_partial(
  impl Fn(
  node_rpc::DenyUnsafe,
  sc_rpc::SubscriptionTaskExecutor,
- ) -> Result<node_rpc::IoHandler, sc_service::Error>,
+ ) -> Result<jsonrpsee::RpcModule<()>, sc_service::Error>,
  (
  sc_consensus_babe::BabeBlockImport<Block, FullClient, FullGrandpaBlockImport>,
  grandpa::LinkHalf<Block, FullClient, FullSelectChain>,
@@ -236,7 +236,7 @@ pub fn new_partial(
  let justification_stream = grandpa_link.justification_stream();
  let shared_authority_set = grandpa_link.shared_authority_set().clone();
  let shared_voter_state = grandpa::SharedVoterState::empty();
- let rpc_setup = shared_voter_state.clone();
+ let shared_voter_state2 = shared_voter_state.clone();
 
  let finality_proof_provider = grandpa::FinalityProofProvider::new_for_service(
  backend.clone(),
@@ -277,7 +277,7 @@ pub fn new_partial(
  node_rpc::create_full(deps, rpc_backend.clone()).map_err(Into::into)
  };
 
- (rpc_extensions_builder, rpc_setup)
+ (rpc_extensions_builder, shared_voter_state2)
  };
 
  Ok(sc_service::PartialComponents {
@@ -332,7 +332,7 @@ pub fn new_full_base(
  keystore_container,
  select_chain,
  transaction_pool,
- other: (rpc_extensions_builder, import_setup, rpc_setup, mut telemetry),
+ other: (rpc_builder, import_setup, rpc_setup, mut telemetry),
  } = new_partial(&config)?;
 
  let shared_voter_state = rpc_setup;
@@ -386,7 +386,7 @@ pub fn new_full_base(
  client: client.clone(),
  keystore: keystore_container.sync_keystore(),
  network: network.clone(),
- rpc_extensions_builder: Box::new(rpc_extensions_builder),
+ rpc_builder: Box::new(rpc_builder),
  transaction_pool: transaction_pool.clone(),
  task_manager: &mut task_manager,
  system_rpc_tx,

diff --git a/bin/node/cli/tests/common.rs b/bin/node/cli/tests/common.rs
@@ -26,15 +26,14 @@ use nix::{
 use node_primitives::Block;
 use remote_externalities::rpc_api;
 use std::{
+ io::{BufRead, BufReader, Read},
  ops::{Deref, DerefMut},
  path::Path,
- process::{Child, Command, ExitStatus},
+ process::{self, Child, Command, ExitStatus},
  time::Duration,
 };
 use tokio::time::timeout;
 
-static LOCALHOST_WS: &str = "ws://127.0.0.1:9944/";
-
 /// Wait for the given `child` the given number of `secs`.
 ///
 /// Returns the `Some(exit status)` or `None` if the process did not finish in the given time.
@@ -63,8 +62,9 @@ pub fn wait_for(child: &mut Child, secs: u64) -> Result<ExitStatus, ()> {
 pub async fn wait_n_finalized_blocks(
  n: usize,
  timeout_secs: u64,
+ url: &str,
 ) -> Result<(), tokio::time::error::Elapsed> {
- timeout(Duration::from_secs(timeout_secs), wait_n_finalized_blocks_from(n, LOCALHOST_WS)).await
+ timeout(Duration::from_secs(timeout_secs), wait_n_finalized_blocks_from(n, url)).await
 }
 
 /// Wait for at least n blocks to be finalized from a specified node
@@ -85,12 +85,23 @@ pub async fn wait_n_finalized_blocks_from(n: usize, url: &str) {
 
 /// Run the node for a while (3 blocks)
 pub async fn run_node_for_a_while(base_path: &Path, args: &[&str]) {
- let mut cmd = Command::new(cargo_bin("substrate"));
+ let mut cmd = Command::new(cargo_bin("substrate"))
+ .stdout(process::Stdio::piped())
+ .stderr(process::Stdio::piped())
+ .args(args)
+ .arg("-d")
+ .arg(base_path)
+ .spawn()
+ .unwrap();
 
- let mut child = KillChildOnDrop(cmd.args(args).arg("-d").arg(base_path).spawn().unwrap());
+ let stderr = cmd.stderr.take().unwrap();
+
+ let mut child = KillChildOnDrop(cmd);
+
+ let (ws_url, _) = find_ws_url_from_output(stderr);
 
  // Let it produce some blocks.
- let _ = wait_n_finalized_blocks(3, 30).await;
+ let _ = wait_n_finalized_blocks(3, 30, &ws_url).await;
 
  assert!(child.try_wait().unwrap().is_none(), "the process should still be running");
 
@@ -134,3 +145,30 @@ impl DerefMut for KillChildOnDrop {
  &mut self.0
  }
 }
+
+/// Read the WS address from the output.
+///
+/// This is hack to get the actual binded sockaddr because
+/// substrate assigns a random port if the specified port was already binded.
+pub fn find_ws_url_from_output(read: impl Read + Send) -> (String, String) {
+ let mut data = String::new();
+
+ let ws_url = BufReader::new(read)
+ .lines()
+ .find_map(|line| {
+ let line =
+ line.expect("failed to obtain next line from stdout for WS address discovery");
+ data.push_str(&line);
+
+ // does the line contain our port (we expect this specific output from substrate).
+ let sock_addr = match line.split_once("Running JSON-RPC WS server: addr=") {
+ None => return None,
+ Some((_, after)) => after.split_once(",").unwrap().0,
+ };
+
+ Some(format!("ws://{}", sock_addr))
+ })
+ .expect("We should get a WebSocket address");
+
+ (ws_url, data)
+}
diff --git a/bin/node/cli/tests/running_the_node_and_interrupt.rs b/bin/node/cli/tests/running_the_node_and_interrupt.rs
@@ -25,7 +25,7 @@ use nix::{
  },
  unistd::Pid,
 };
-use std::process::{Child, Command};
+use std::process::{self, Child, Command};
 use tempfile::tempdir;
 
 pub mod common;
@@ -36,6 +36,8 @@ async fn running_the_node_works_and_can_be_interrupted() {
  let base_path = tempdir().expect("could not create a temp dir");
  let mut cmd = common::KillChildOnDrop(
  Command::new(cargo_bin("substrate"))
+ .stdout(process::Stdio::piped())
+ .stderr(process::Stdio::piped())
  .args(&["--dev", "-d"])
  .arg(base_path.path())
  .arg("--db=paritydb")
@@ -44,7 +46,13 @@ async fn running_the_node_works_and_can_be_interrupted() {
  .unwrap(),
  );
 
- common::wait_n_finalized_blocks(3, 30).await.unwrap();
+ let stderr = cmd.stderr.take().unwrap();
+
+ let (ws_url, _) = common::find_ws_url_from_output(stderr);
+
+ common::wait_n_finalized_blocks(3, 30, &ws_url)
+ .await
+ .expect("Blocks are produced in time");
  assert!(cmd.try_wait().unwrap().is_none(), "the process should still be running");
  kill(Pid::from_raw(cmd.id().try_into().unwrap()), signal).unwrap();
  assert_eq!(
@@ -69,6 +77,8 @@ async fn running_the_node_works_and_can_be_interrupted() {
 async fn running_two_nodes_with_the_same_ws_port_should_work() {
  fn start_node() -> Child {
  Command::new(cargo_bin("substrate"))
+ .stdout(process::Stdio::piped())
+ .stderr(process::Stdio::piped())
  .args(&["--dev", "--tmp", "--ws-port=45789", "--no-hardware-benchmarks"])
  .spawn()
  .unwrap()
@@ -77,7 +87,10 @@ async fn running_two_nodes_with_the_same_ws_port_should_work() {
  let mut first_node = common::KillChildOnDrop(start_node());
  let mut second_node = common::KillChildOnDrop(start_node());
 
- let _ = common::wait_n_finalized_blocks(3, 30).await;
+ let stderr = first_node.stderr.take().unwrap();
+ let (ws_url, _) = common::find_ws_url_from_output(stderr);
+
+ common::wait_n_finalized_blocks(3, 30, &ws_url).await.unwrap();
 
  assert!(first_node.try_wait().unwrap().is_none(), "The first node should still be running");
  assert!(second_node.try_wait().unwrap().is_none(), "The second node should still be running");

diff --git a/bin/node/cli/tests/temp_base_path_works.rs b/bin/node/cli/tests/temp_base_path_works.rs
@@ -43,19 +43,21 @@ async fn temp_base_path_works() {
  .unwrap(),
  );
 
+ let mut stderr = child.stderr.take().unwrap();
+ let (ws_url, mut data) = common::find_ws_url_from_output(&mut stderr);
+
  // Let it produce some blocks.
- common::wait_n_finalized_blocks(3, 30).await.unwrap();
+ common::wait_n_finalized_blocks(3, 30, &ws_url).await.unwrap();
  assert!(child.try_wait().unwrap().is_none(), "the process should still be running");
 
  // Stop the process
  kill(Pid::from_raw(child.id().try_into().unwrap()), SIGINT).unwrap();
  assert!(common::wait_for(&mut child, 40).map(|x| x.success()).unwrap_or_default());
 
  // Ensure the database has been deleted
- let mut stderr = String::new();
- child.stderr.as_mut().unwrap().read_to_string(&mut stderr).unwrap();
+ stderr.read_to_string(&mut data).unwrap();
  let re = Regex::new(r"Database: .+ at (\S+)").unwrap();
- let db_path = PathBuf::from(re.captures(stderr.as_str()).unwrap().get(1).unwrap().as_str());
+ let db_path = PathBuf::from(re.captures(data.as_str()).unwrap().get(1).unwrap().as_str());
 
  assert!(!db_path.exists());
 }
diff --git a/bin/node/rpc/Cargo.toml b/bin/node/rpc/Cargo.toml
@@ -11,7 +11,7 @@ repository = "https:/paritytech/substrate/"
 targets = ["x86_64-unknown-linux-gnu"]
 
 [dependencies]
-jsonrpc-core = "18.0.0"
+jsonrpsee = { version = "0.12.0", features = ["server"] }
 node-primitives = { version = "2.0.0", path = "../primitives" }
 pallet-contracts-rpc = { version = "4.0.0-dev", path = "../../../frame/contracts/rpc/" }
 pallet-mmr-rpc = { version = "3.0.0", path = "../../../frame/merkle-mountain-range/rpc/" }