Merge pull request #368 from input-output-hk/whankinsiv/address-extended-endpoint

feat: addresses extended endpoint

Author: whankinsiv

common/src/queries/assets.rs

@@ -1,7 +1,7 @@
 use crate::queries::errors::QueryError;
 use crate::{
-    AssetAddressEntry, AssetInfoRecord, AssetMintRecord, AssetName, PolicyAsset, PolicyId,
-    TxIdentifier,
+    AssetAddressEntry, AssetInfoRecord, AssetMetadata, AssetMintRecord, AssetName, NativeAssets,
+    PolicyAsset, PolicyId, TxIdentifier,
 };
 
 pub const DEFAULT_ASSETS_QUERY_TOPIC: (&str, &str) =
@@ -27,6 +27,7 @@ pub enum AssetsStateQuery {
     GetPolicyIdAssets { policy: PolicyId },
     GetAssetAddresses { policy: PolicyId, name: AssetName },
     GetAssetTransactions { policy: PolicyId, name: AssetName },
+    GetAssetsMetadata { assets: NativeAssets },
 }
 
 #[derive(Debug, Clone, serde::Serialize, serde::Deserialize)]
@@ -37,5 +38,6 @@ pub enum AssetsStateQueryResponse {
     AssetAddresses(AssetAddresses),
     AssetTransactions(AssetTransactions),
     PolicyIdAssets(PolicyAssets),
+    AssetsMetadata(Vec<AssetMetadata>),
     Error(QueryError),
 }

common/src/types.rs

@@ -2121,8 +2121,15 @@ pub struct TxCertificateWithPos {
 pub struct AssetInfoRecord {
     pub initial_mint_tx: TxIdentifier,
     pub mint_or_burn_count: u64,
-    pub onchain_metadata: Option<Vec<u8>>,
-    pub metadata_standard: Option<AssetMetadataStandard>,
+    pub metadata: AssetMetadata,
+}
+
+#[derive(Debug, Default, Clone, serde::Serialize, serde::Deserialize)]
+pub struct AssetMetadata {
+    pub cip25_metadata: Option<Vec<u8>>,
+    pub cip25_version: Option<AssetMetadataStandard>,
+    pub cip68_metadata: Option<Vec<u8>>,
+    pub cip68_version: Option<AssetMetadataStandard>,
 }
 
 #[derive(Debug, Clone, PartialEq, Eq, Hash, serde::Serialize, serde::Deserialize)]

modules/assets_state/src/assets_state.rs

@@ -443,6 +443,18 @@ impl AssetsState {
                             )),
                         }
                     }
+                    AssetsStateQuery::GetAssetsMetadata { assets } => {
+                        let reg = registry.lock().await;
+                        match state.get_assets_metadata(assets, &reg) {
+                            Ok(Some(assets)) => AssetsStateQueryResponse::AssetsMetadata(assets),
+                            Ok(None) => AssetsStateQueryResponse::Error(QueryError::not_found(
+                                "One or more assets not found in registry".to_string(),
+                            )),
+                            Err(e) => AssetsStateQueryResponse::Error(QueryError::internal_error(
+                                e.to_string(),
+                            )),
+                        }
+                    }
                 };
                 Arc::new(Message::StateQueryResponse(StateQueryResponse::Assets(
                     response,