rusk: Expose /stats/account_count endpoint for public account count

Author: HDauven

node/src/archive/sqlite.rs

@@ -234,11 +234,9 @@ impl Archive {
         Ok(last_account_id)
     }
 
-    /// Count finalized transfer transactions for the transfer contract, split by topic.
-    /// Returns (moonlight_count, phoenix_count).
-    pub async fn fetch_tx_count(
-        &self,
-    ) -> Result<(u64, u64)> {
+    /// Count finalized transfer transactions for the transfer contract, split
+    /// by topic. Returns (moonlight_count, phoenix_count).
+    pub async fn fetch_tx_count(&self) -> Result<(u64, u64)> {
         let mut conn = self.sqlite_archive.acquire().await?;
 
         let transfer_src = dusk_core::transfer::TRANSFER_CONTRACT.to_string();

rusk/CHANGELOG.md

@@ -14,6 +14,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 - Add `status` to GQL block fields
 - Add activaction height for host queries
 - Add blob config section
+- add `/stats/account_count` endpoint [#3625]
 - add `/stats/tx_count` endpoint [#3625]
 
 ### Changed

rusk/src/lib/http/chain.rs

@@ -68,6 +68,7 @@ impl HandleRequest for RuskNode {
             ("blocks", _, "gas-price") => true,
             ("blobs", Some(_), "commitment") => true,
             ("blobs", Some(_), "hash") => true,
+            ("stats", _, "account_count") => true,
             ("stats", _, "tx_count") => true,
 
             _ => false,
@@ -122,6 +123,7 @@ impl HandleRequest for RuskNode {
                 self.blob_by_hash(&hash, request.is_json()).await
             }
 
+            ("stats", _, "account_count") => self.get_account_count().await,
             ("stats", _, "tx_count") => self.get_tx_count().await,
 
             _ => anyhow::bail!("Unsupported"),
@@ -390,7 +392,29 @@ impl RuskNode {
         })))
     }
 
-    /// Returns the total number of finalized transactions observed in the 
+    /// Returns the total number of active public accounts recorded in the
+    /// archive node. The response is a JSON object:
+    /// ```json
+    /// { "public_accounts": 12345 }
+    /// ```
+    ///
+    /// # Errors
+    /// Returns an error if the archive feature is not enabled.
+    async fn get_account_count(&self) -> anyhow::Result<ResponseData> {
+        #[cfg(feature = "archive")]
+        {
+            let count = self.archive().fetch_active_accounts().await?;
+            let body = serde_json::json!({ "public_accounts": count });
+            Ok(ResponseData::new(body))
+        }
+
+        #[cfg(not(feature = "archive"))]
+        {
+            anyhow::bail!("The archive feature is required for this endpoint.");
+        }
+    }
+
+    /// Returns the total number of finalized transactions observed in the
     /// archive, split into `public`, `shielded` and `total. The response is
     /// a JSON object:
     /// ```json