mirror of
https://github.com/pezkuwichain/pezkuwi-subxt.git
synced 2026-06-09 20:11:09 +00:00
Minor refactor (#3386)
* minro refactor * Update node/core/runtime-api/src/lib.rs Co-authored-by: Keith Yeung <kungfukeith11@gmail.com> * Update node/core/runtime-api/src/lib.rs Co-authored-by: Bastian Köcher <bkchr@users.noreply.github.com> Co-authored-by: Keith Yeung <kungfukeith11@gmail.com> Co-authored-by: Bastian Köcher <bkchr@users.noreply.github.com>
This commit is contained in:
committed by
GitHub
parent
d97d083d59
commit
0b10a24cd2
@@ -302,33 +302,15 @@ where
|
||||
let _timer = metrics.time_make_runtime_api_request();
|
||||
|
||||
macro_rules! query {
|
||||
($req_variant:ident, $api_name:ident (), $sender:expr) => {{
|
||||
($req_variant:ident, $api_name:ident ($($param:expr),*), $sender:expr) => {{
|
||||
let sender = $sender;
|
||||
let api = client.runtime_api();
|
||||
let res = api.$api_name(&BlockId::Hash(relay_parent))
|
||||
let res = api.$api_name(&BlockId::Hash(relay_parent) $(, $param.clone() )*)
|
||||
.map_err(|e| RuntimeApiError::from(format!("{:?}", e)));
|
||||
metrics.on_request(res.is_ok());
|
||||
let _ = sender.send(res.clone());
|
||||
|
||||
if let Ok(res) = res {
|
||||
Some(RequestResult::$req_variant(relay_parent, res.clone()))
|
||||
} else {
|
||||
None
|
||||
}
|
||||
}};
|
||||
($req_variant:ident, $api_name:ident ($($param:expr),+), $sender:expr) => {{
|
||||
let sender = $sender;
|
||||
let api = client.runtime_api();
|
||||
let res = api.$api_name(&BlockId::Hash(relay_parent), $($param.clone()),*)
|
||||
.map_err(|e| RuntimeApiError::from(format!("{:?}", e)));
|
||||
metrics.on_request(res.is_ok());
|
||||
let _ = sender.send(res.clone());
|
||||
|
||||
if let Ok(res) = res {
|
||||
Some(RequestResult::$req_variant(relay_parent, $($param),+, res.clone()))
|
||||
} else {
|
||||
None
|
||||
}
|
||||
res.ok().map(|res| RequestResult::$req_variant(relay_parent, $( $param, )* res))
|
||||
}}
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user