feat(node/web): expose ledger accounts rpc

Author: binier

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

@@ -0,0 +1,71 @@
+#[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 Ledger {
+    #[allow(unused)]
+    sender: RpcSender,
+}
+
+#[derive(Clone)]
+#[cfg_attr(target_family = "wasm", wasm_bindgen)]
+pub struct LedgerSelected {
+    #[allow(unused)]
+    sender: RpcSender,
+}
+
+#[derive(Clone)]
+#[cfg_attr(target_family = "wasm", wasm_bindgen)]
+pub struct LedgerAccounts {
+    #[allow(unused)]
+    sender: RpcSender,
+}
+
+impl Ledger {
+    pub fn new(sender: RpcSender) -> Self {
+        Self { sender }
+    }
+
+    pub fn latest(&self) -> LedgerSelected {
+        LedgerSelected {
+            sender: self.sender.clone(),
+        }
+    }
+}
+
+impl LedgerSelected {
+    pub fn accounts(&self) -> LedgerAccounts {
+        LedgerAccounts {
+            sender: self.sender.clone(),
+        }
+    }
+}
+
+impl LedgerAccounts {
+    async fn _all(&self) -> Option<RpcLedgerSlimAccountsResponse> {
+        self.sender
+            .oneshot_request(RpcRequest::LedgerAccountsGet(AccountQuery::All))
+            .await
+    }
+}
+
+#[cfg(not(target_family = "wasm"))]
+impl LedgerAccounts {
+    pub async fn all(&self) -> Option<RpcLedgerSlimAccountsResponse> {
+        self._all().await
+    }
+}
+
+#[cfg(target_family = "wasm")]
+#[cfg_attr(target_family = "wasm", wasm_bindgen)]
+impl LedgerAccounts {
+    pub async fn all(&self) -> JsValue {
+        JsValue::from_serde(&self._all().await).unwrap_or_default()
+    }
+}

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

@@ -1,6 +1,7 @@
 mod sender;
 pub use sender::RpcSender;
 
+pub mod ledger;
 pub mod state;
 pub mod stats;
 pub mod transaction_pool;

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::ledger::Ledger;
 use super::state::State;
 use super::stats::Stats;
 use super::transaction_pool::TransactionPool;
@@ -86,6 +87,10 @@ impl RpcSender {
     pub fn transition_frontier(&self) -> TransitionFrontier {
         TransitionFrontier::new(self.clone())
     }
+
+    pub fn ledger(&self) -> Ledger {
+        Ledger::new(self.clone())
+    }
 }
 
 #[cfg(target_family = "wasm")]

node/native/src/http_server.rs

@@ -468,7 +468,10 @@ pub async fn run(port: u16, rpc_sender: RpcSender) {
 
         async move {
             rpc_sender_clone
-                .oneshot_request(RpcRequest::LedgerAccountsGet(AccountQuery::All))
+                .ledger()
+                .latest()
+                .accounts()
+                .all()
                 .await
                 .map_or_else(
                     dropped_channel_response,