Merge branch 'main' into feat/analytics/nft-native-endpoints

bin/inx-chronicle/src/api/stardust/analytics/responses.rs

@@ -61,3 +61,54 @@ pub struct OutputDiffAnalyticsResponse {
 }
 
 impl_success_response!(OutputDiffAnalyticsResponse);
+
+#[derive(Clone, Debug, Serialize, Deserialize)]
+#[serde(rename_all = "camelCase")]
+pub struct RichestAddressesResponse {
+ pub top: Vec<AddressStatDto>,
+ pub ledger_index: u32,
+}
+
+impl_success_response!(RichestAddressesResponse);
+
+#[derive(Clone, Debug, Serialize, Deserialize)]
+pub struct AddressStatDto {
+ pub address: AddressDto,
+ pub balance: String,
+}
+
+impl From<AddressStat> for AddressStatDto {
+ fn from(s: AddressStat) -> Self {
+ Self {
+ address: AddressDto::from(&bee_block_stardust::address::Address::from(s.address)),
+ balance: s.balance,
+ }
+ }
+}
+
+#[derive(Clone, Debug, Serialize, Deserialize)]
+#[serde(rename_all = "camelCase")]
+pub struct TokenDistributionResponse {
+ pub distribution: Vec<DistributionStatDto>,
+ pub ledger_index: u32,
+}
+
+impl_success_response!(TokenDistributionResponse);
+
+#[derive(Clone, Debug, Serialize, Deserialize)]
+#[serde(rename_all = "camelCase")]
+pub struct DistributionStatDto {
+ pub range: Range<u64>,
+ pub address_count: String,
+ pub total_balance: String,
+}
+
+impl From<DistributionStat> for DistributionStatDto {
+ fn from(s: DistributionStat) -> Self {
+ Self {
+ range: 10_u64.pow(s.index)..10_u64.pow(s.index + 1),
+ address_count: s.address_count.to_string(),
+ total_balance: s.total_balance,
+ }
+ }
+}

bin/inx-chronicle/src/api/stardust/analytics/routes.rs

@@ -18,7 +18,7 @@ use super::{
  extractors::{LedgerIndex, MilestoneRange, RichestAddressesQuery},
  responses::{
  AddressAnalyticsResponse, BlockAnalyticsResponse, OutputAnalyticsResponse, OutputDiffAnalyticsResponse,
- StorageDepositAnalyticsResponse,
+ RichestAddressesResponse, StorageDepositAnalyticsResponse, TokenDistributionResponse,
  },
 };
 use crate::api::{ApiError, ApiResult};
@@ -165,3 +165,33 @@ async fn foundry_output_analytics(
  burned_count: res.burned_count.to_string(),
  })
 }
+
+async fn richest_addresses(
+ database: Extension<MongoDb>,
+ RichestAddressesQuery { top, ledger_index }: RichestAddressesQuery,
+) -> ApiResult<RichestAddressesResponse> {
+ let res = database
+ .get_richest_addresses(ledger_index, top)
+ .await?
+ .ok_or(ApiError::NoResults)?;
+
+ Ok(RichestAddressesResponse {
+ top: res.top.into_iter().map(Into::into).collect(),
+ ledger_index: res.ledger_index.0,
+ })
+}
+
+async fn token_distribution(
+ database: Extension<MongoDb>,
+ LedgerIndex { ledger_index }: LedgerIndex,
+) -> ApiResult<TokenDistributionResponse> {
+ let res = database
+ .get_token_distribution(ledger_index)
+ .await?
+ .ok_or(ApiError::NoResults)?;
+
+ Ok(TokenDistributionResponse {
+ distribution: res.distribution.into_iter().map(Into::into).collect(),
+ ledger_index: res.ledger_index.0,
+ })
+}