Skip to content
This repository has been archived by the owner on Nov 15, 2023. It is now read-only.

Introduce RPC Worker #1462

Merged
merged 19 commits into from
Aug 1, 2022
Merged

Introduce RPC Worker #1462

Show file tree
Hide file tree
Changes from 16 commits
Commits
Show all changes
19 commits
Select commit Hold shift + click to select a range
bed82c8
Extract json-rpc-client and introduce worker
skunert Jul 11, 2022
83e1c26
Initial rpc worker
skunert Jul 19, 2022
102da75
Merge branch 'master' into json-rpc-worker
skunert Jul 19, 2022
09c461d
Add error handling
skunert Jul 20, 2022
b0e96bb
Use bounded channels for listeners
skunert Jul 20, 2022
9e61adc
Merge branch 'master' into json-rpc-worker
skunert Jul 20, 2022
d398320
Improve naming and clean up
skunert Jul 20, 2022
de5d7d1
Use tracing channels
skunert Jul 21, 2022
4bb26be
Improve code readability
skunert Jul 21, 2022
fc24b87
Decrease channel size limit
skunert Jul 21, 2022
b65b56c
Remove unused dependency
skunert Jul 21, 2022
1398b7d
Fix docs
skunert Jul 21, 2022
c7601f0
RPC -> Rpc
skunert Jul 27, 2022
23f6e0d
Start worker in initialization method
skunert Jul 27, 2022
73c69fd
Print error in case a distribution channel is full
skunert Jul 27, 2022
9953820
Fix docs
skunert Jul 27, 2022
3cc5397
Make `RpcStreamWorker` private
skunert Jul 28, 2022
7366381
Use tokio channels and add TODO item
skunert Jul 29, 2022
512f1b4
Remove `Option` from `to_worker_channel`
skunert Aug 1, 2022
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions Cargo.lock
View file
Open in desktop

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

8 changes: 5 additions & 3 deletions client/relay-chain-interface/src/lib.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,7 @@ use sc_client_api::StorageProof;
use futures::Stream;

use async_trait::async_trait;
use jsonrpsee_core::Error as JsonRPSeeError;
use jsonrpsee_core::Error as JsonRpcError;
use parity_scale_codec::Error as CodecError;
use sp_api::ApiError;
use sp_state_machine::StorageValue;
Expand All @@ -51,9 +51,11 @@ pub enum RelayChainError {
#[error("State machine error occured: {0}")]
StateMachineError(Box<dyn sp_state_machine::Error>),
#[error("Unable to call RPC method '{0}' due to error: {1}")]
RPCCallError(String, JsonRPSeeError),
RpcCallError(String, JsonRpcError),
#[error("RPC Error: '{0}'")]
JsonRPCError(#[from] JsonRPSeeError),
JsonRpcError(#[from] JsonRpcError),
#[error("Unable to reach RpcStreamWorker: {0}")]
WorkerCommunicationError(String),
#[error("Scale codec deserialization error: {0}")]
DeserializationError(CodecError),
#[error("Scale codec deserialization error: {0}")]
Expand Down
1 change: 1 addition & 0 deletions client/relay-chain-rpc-interface/Cargo.toml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@ sp-api = { git = "https://github.com/paritytech/substrate", branch = "master" }
sp-runtime = { git = "https://github.com/paritytech/substrate", branch = "master" }
sp-state-machine = { git = "https://github.com/paritytech/substrate", branch = "master" }
sc-client-api = { git = "https://github.com/paritytech/substrate", branch = "master" }
sc-utils = { git = "https://github.com/paritytech/substrate", branch = "master" }
sp-storage = { git = "https://github.com/paritytech/substrate", branch = "master" }
sc-rpc-api = { git = "https://github.com/paritytech/substrate", branch = "master" }

Expand Down
Loading