mirror of
https://github.com/pezkuwichain/pezkuwi-subxt.git
synced 2026-07-12 14:35:42 +00:00
Zeke Mostov
b048be06fe
* WIP * Dry run cmd working * Monitor cmd works * Configure balance with parameter type * Comments * cleannnn * Add balancing to PhragMMS * Move OffchainRanomBalancing to common * DRY mine_unchecked over config.solver * FMT * Apply suggestions from code review Co-authored-by: Kian Paimani <5588131+kianenigma@users.noreply.github.com> * Improve docs for any_runtime_unit! * Some cleanup * fmt * Correct capitilaztion * Improve version mismatch log * Revert "Improve version mismatch log" This reverts commit 57570403f654f1efa4307956cda2de6f0c64f70a. * Apply suggestions from code review Co-authored-by: Kian Paimani <5588131+kianenigma@users.noreply.github.com> * Remove Balancing struct and use Balancing Parameter type instead * update Substrate Co-authored-by: Kian Paimani <5588131+kianenigma@users.noreply.github.com> Co-authored-by: parity-processbot <>
92 lines
2.8 KiB
Rust
92 lines
2.8 KiB
Rust
// Copyright 2021 Parity Technologies (UK) Ltd.
|
|
// This file is part of Polkadot.
|
|
|
|
// Polkadot is free software: you can redistribute it and/or modify
|
|
// it under the terms of the GNU General Public License as published by
|
|
// the Free Software Foundation, either version 3 of the License, or
|
|
// (at your option) any later version.
|
|
|
|
// Polkadot is distributed in the hope that it will be useful,
|
|
// but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
// GNU General Public License for more details.
|
|
|
|
// You should have received a copy of the GNU General Public License
|
|
// along with Polkadot. If not, see <http://www.gnu.org/licenses/>.
|
|
|
|
//! Helper method for RPC.
|
|
|
|
use super::*;
|
|
use jsonrpsee_ws_client::types::traits::Client;
|
|
pub(crate) use jsonrpsee_ws_client::types::v2::params::JsonRpcParams;
|
|
|
|
#[derive(frame_support::DebugNoBound, thiserror::Error)]
|
|
pub(crate) enum RpcHelperError {
|
|
JsonRpsee(#[from] jsonrpsee_ws_client::types::Error),
|
|
Codec(#[from] codec::Error),
|
|
}
|
|
|
|
impl std::fmt::Display for RpcHelperError {
|
|
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
|
|
<RpcHelperError as std::fmt::Debug>::fmt(self, f)
|
|
}
|
|
}
|
|
|
|
#[macro_export]
|
|
macro_rules! params {
|
|
($($param:expr),*) => {
|
|
{
|
|
let mut __params = vec![];
|
|
$(
|
|
__params.push(serde_json::to_value($param).expect("json serialization infallible; qed."));
|
|
)*
|
|
$crate::rpc_helpers::JsonRpcParams::Array(__params)
|
|
}
|
|
};
|
|
() => {
|
|
$crate::rpc::JsonRpcParams::NoParams,
|
|
}
|
|
}
|
|
|
|
/// Make the rpc request, returning `Ret`.
|
|
pub(crate) async fn rpc<'a, Ret: serde::de::DeserializeOwned>(
|
|
client: &WsClient,
|
|
method: &'a str,
|
|
params: JsonRpcParams<'a>,
|
|
) -> Result<Ret, RpcHelperError> {
|
|
client
|
|
.request::<Ret>(method, params)
|
|
.await
|
|
.map_err::<RpcHelperError, _>(Into::into)
|
|
}
|
|
|
|
/// Make the rpc request, decode the outcome into `Dec`. Don't use for storage, it will fail for
|
|
/// non-existent storage items.
|
|
pub(crate) async fn rpc_decode<'a, Dec: codec::Decode>(
|
|
client: &WsClient,
|
|
method: &'a str,
|
|
params: JsonRpcParams<'a>,
|
|
) -> Result<Dec, RpcHelperError> {
|
|
let bytes = rpc::<sp_core::Bytes>(client, method, params)
|
|
.await
|
|
.map_err::<RpcHelperError, _>(Into::into)?;
|
|
<Dec as codec::Decode>::decode(&mut &*bytes.0).map_err::<RpcHelperError, _>(Into::into)
|
|
}
|
|
|
|
/// Get the storage item.
|
|
pub(crate) async fn get_storage<'a, T: codec::Decode>(
|
|
client: &WsClient,
|
|
params: JsonRpcParams<'a>,
|
|
) -> Result<Option<T>, RpcHelperError> {
|
|
let maybe_bytes = rpc::<Option<sp_core::Bytes>>(client, "state_getStorage", params)
|
|
.await
|
|
.map_err::<RpcHelperError, _>(Into::into)?;
|
|
if let Some(bytes) = maybe_bytes {
|
|
let decoded = <T as codec::Decode>::decode(&mut &*bytes.0)
|
|
.map_err::<RpcHelperError, _>(Into::into)?;
|
|
Ok(Some(decoded))
|
|
} else {
|
|
Ok(None)
|
|
}
|
|
}
|