feat(node/web): expose block producer stats rpc

Author: binier

node/common/src/service/rpc/mod.rs

@@ -1,6 +1,8 @@
 mod sender;
 pub use sender::RpcSender;
 
+pub mod stats;
+
 use node::rpc::{
     RpcBlockProducerStatsGetResponse, RpcDiscoveryBoostrapStatsResponse,
     RpcDiscoveryRoutingTableResponse, RpcHealthCheckResponse, RpcLedgerAccountsResponse,

node/common/src/service/rpc/sender.rs

@@ -8,6 +8,7 @@ use node::core::channels::{mpsc, oneshot};
 use node::p2p::connection::outgoing::P2pConnectionOutgoingInitOpts;
 use node::rpc::*;
 
+use super::stats::Stats;
 use super::NodeRpcRequest;
 
 #[derive(Clone)]
@@ -65,6 +66,13 @@ impl RpcSender {
     }
 }
 
+#[cfg_attr(target_family = "wasm", wasm_bindgen)]
+impl RpcSender {
+    pub fn stats(&self) -> Stats {
+        Stats::new(self.clone())
+    }
+}
+
 #[cfg(target_family = "wasm")]
 #[cfg_attr(target_family = "wasm", wasm_bindgen)]
 impl RpcSender {

node/common/src/service/rpc/stats.rs

@@ -0,0 +1,34 @@
+#[cfg(target_family = "wasm")]
+use gloo_utils::format::JsValueSerdeExt;
+#[cfg(target_family = "wasm")]
+use node::rpc::{RpcBlockProducerStatsGetResponse, RpcRequest};
+#[cfg(target_family = "wasm")]
+use wasm_bindgen::prelude::*;
+
+use super::RpcSender;
+
+#[derive(Clone)]
+#[cfg_attr(target_family = "wasm", wasm_bindgen)]
+pub struct Stats {
+    #[allow(unused)]
+    sender: RpcSender,
+}
+
+impl Stats {
+    pub fn new(sender: RpcSender) -> Self {
+        Self { sender }
+    }
+}
+
+#[cfg(target_family = "wasm")]
+#[cfg_attr(target_family = "wasm", wasm_bindgen)]
+impl Stats {
+    pub async fn block_producer(&self) -> JsValue {
+        let res = self
+            .sender
+            .oneshot_request::<RpcBlockProducerStatsGetResponse>(RpcRequest::BlockProducerStatsGet)
+            .await
+            .flatten();
+        JsValue::from_serde(&res).unwrap_or_default()
+    }
+}