rusk: RUES - move on/account/status to chain service

Author: herr-seppia

rusk/src/lib/http/chain.rs

@@ -10,6 +10,8 @@ pub mod graphql;
 use std::collections::HashMap;
 use std::sync::Arc;
 
+use dusk_bytes::DeserializableSlice;
+use dusk_core::signatures::bls::PublicKey as BlsPublicKey;
 use dusk_core::transfer::data::{BlobData, BlobSidecar};
 use dusk_core::transfer::Transaction as ProtocolTransaction;
 use dusk_vm::execute;
@@ -62,6 +64,7 @@ impl HandleRequest for RuskNode {
             ("network", _, "peers") => true,
             ("network", _, "peers_location") => true,
             ("node", _, "info") => true,
+            ("account", Some(_), "status") => true,
             ("blocks", _, "gas-price") => true,
             ("blobs", Some(_), "commitment") => true,
             ("blobs", Some(_), "hash") => true,
@@ -93,6 +96,7 @@ impl HandleRequest for RuskNode {
 
             ("network", _, "peers_location") => self.peers_location().await,
             ("node", _, "info") => self.get_info().await,
+            ("account", Some(pk), "status") => self.get_account(pk).await,
             ("blocks", _, "gas-price") => {
                 let max_transactions = request
                     .data
@@ -333,6 +337,26 @@ impl RuskNode {
         };
         Ok(response)
     }
+
+    async fn get_account(&self, pk: &str) -> anyhow::Result<ResponseData> {
+        let pk = bs58::decode(pk)
+            .into_vec()
+            .map_err(|_| anyhow::anyhow!("Invalid bs58 account"))?;
+        let pk = BlsPublicKey::from_slice(&pk)
+            .map_err(|_| anyhow::anyhow!("Invalid bls account"))?;
+
+        let vm = self.inner().vm_handler();
+
+        let account = vm
+            .read()
+            .await
+            .account(&pk)
+            .map_err(|e| anyhow::anyhow!("Cannot query the state {e:?}"))?;
+        Ok(ResponseData::new(json!({
+            "balance": account.balance,
+            "nonce": account.nonce,
+        })))
+    }
 }
 
 async fn load_tip<DB: database::DB>(

rusk/src/lib/http/rusk.rs

@@ -7,16 +7,14 @@
 use super::*;
 
 use anyhow::anyhow;
-use dusk_bytes::{DeserializableSlice, Serializable};
+use dusk_bytes::Serializable;
 use dusk_core::abi::ContractId;
-use dusk_core::signatures::bls::PublicKey as BlsPublicKey;
 use dusk_core::stake::{StakeFundOwner, STAKE_CONTRACT};
 use dusk_core::transfer::TRANSFER_CONTRACT;
 use dusk_data_driver::ConvertibleContract;
 use event::RequestData;
 use rusk_profile::CRS_17_HASH;
 use serde::Serialize;
-use serde_json::json;
 use std::sync::mpsc;
 use std::thread;
 
@@ -32,7 +30,6 @@ impl HandleRequest for Rusk {
             ("contracts", Some(_), _) => true,
             ("driver", Some(_), _) => true,
             ("node", _, "provisioners") => true,
-            ("account", Some(_), "status") => true,
             ("node", _, "crs") => true,
             _ => false,
         }
@@ -57,7 +54,6 @@ impl HandleRequest for Rusk {
             }
             ("node", _, "provisioners") => self.get_provisioners(),
 
-            ("account", Some(pk), "status") => self.get_account(pk),
             ("node", _, "crs") => self.get_crs(),
             _ => Err(anyhow::anyhow!("Unsupported")),
         }
@@ -228,24 +224,6 @@ impl Rusk {
         Ok(ResponseData::new(serde_json::to_value(prov)?))
     }
 
-    fn get_account(&self, pk: &str) -> anyhow::Result<ResponseData> {
-        let pk = bs58::decode(pk)
-            .into_vec()
-            .map_err(|_| anyhow::anyhow!("Invalid bs58 account"))?;
-        let pk = BlsPublicKey::from_slice(&pk)
-            .map_err(|_| anyhow::anyhow!("Invalid bls account"))?;
-        let account = self
-            .account(&pk)
-            .map(|account| {
-                json!({
-                    "balance": account.balance,
-                    "nonce": account.nonce,
-                })
-            })
-            .map_err(|e| anyhow::anyhow!("Cannot query the state {e:?}"))?;
-        Ok(ResponseData::new(account))
-    }
-
     fn get_crs(&self) -> anyhow::Result<ResponseData> {
         let crs = rusk_profile::get_common_reference_string()?;
         Ok(ResponseData::new(crs).with_header("crs-hash", CRS_17_HASH))