feat(node/web): expose best chain user commands rpc

Author: binier

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

@@ -4,6 +4,7 @@ pub use sender::RpcSender;
 pub mod state;
 pub mod stats;
 pub mod transaction_pool;
+pub mod transition_frontier;
 
 use node::rpc::{
     RpcBestChainResponse, RpcBlockProducerStatsGetResponse, RpcConsensusConstantsGetResponse,

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

@@ -11,6 +11,7 @@ use node::rpc::*;
 use super::state::State;
 use super::stats::Stats;
 use super::transaction_pool::TransactionPool;
+use super::transition_frontier::TransitionFrontier;
 use super::NodeRpcRequest;
 
 #[derive(Clone)]
@@ -81,6 +82,10 @@ impl RpcSender {
     pub fn transaction_pool(&self) -> TransactionPool {
         TransactionPool::new(self.clone())
     }
+
+    pub fn transition_frontier(&self) -> TransitionFrontier {
+        TransitionFrontier::new(self.clone())
+    }
 }
 
 #[cfg(target_family = "wasm")]

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

@@ -0,0 +1,56 @@
+#[cfg(target_family = "wasm")]
+use gloo_utils::format::JsValueSerdeExt;
+use node::rpc::*;
+#[cfg(target_family = "wasm")]
+use wasm_bindgen::prelude::*;
+
+use super::RpcSender;
+
+#[derive(Clone)]
+#[cfg_attr(target_family = "wasm", wasm_bindgen)]
+pub struct TransitionFrontier {
+    #[allow(unused)]
+    sender: RpcSender,
+}
+
+#[derive(Clone)]
+#[cfg_attr(target_family = "wasm", wasm_bindgen)]
+pub struct TransitionFrontierBestChain {
+    #[allow(unused)]
+    sender: RpcSender,
+}
+
+impl TransitionFrontier {
+    pub fn new(sender: RpcSender) -> Self {
+        Self { sender }
+    }
+
+    pub fn best_chain(&self) -> TransitionFrontierBestChain {
+        TransitionFrontierBestChain {
+            sender: self.sender.clone(),
+        }
+    }
+}
+
+impl TransitionFrontierBestChain {
+    async fn _user_commands(&self) -> Option<RpcTransitionFrontierUserCommandsResponse> {
+        self.sender
+            .oneshot_request(RpcRequest::TransitionFrontierUserCommandsGet)
+            .await
+    }
+}
+
+#[cfg(not(target_family = "wasm"))]
+impl TransitionFrontierBestChain {
+    pub async fn user_commands(&self) -> Option<RpcTransitionFrontierUserCommandsResponse> {
+        self._user_commands().await
+    }
+}
+
+#[cfg(target_family = "wasm")]
+#[cfg_attr(target_family = "wasm", wasm_bindgen)]
+impl TransitionFrontierBestChain {
+    pub async fn user_commands(&self) -> JsValue {
+        JsValue::from_serde(&self._user_commands().await).unwrap_or_default()
+    }
+}

node/native/src/http_server.rs

@@ -515,14 +515,13 @@ pub async fn run(port: u16, rpc_sender: RpcSender) {
 
             async move {
                 rpc_sender_clone
-                    .oneshot_request(RpcRequest::TransitionFrontierUserCommandsGet)
+                    .transition_frontier()
+                    .best_chain()
+                    .user_commands()
                     .await
-                    .map_or_else(
-                        dropped_channel_response,
-                        |reply: node::rpc::RpcTransitionFrontierUserCommandsResponse| {
-                            with_json_reply(&reply, StatusCode::OK)
-                        },
-                    )
+                    .map_or_else(dropped_channel_response, |reply| {
+                        with_json_reply(&reply, StatusCode::OK)
+                    })
             }
         });