Merge branch 'main' into lowhung/395-bootstrap-orchestration

# Conflicts:
#	common/Cargo.toml

Author: lowhung

Cargo.lock

@@ -35,6 +35,7 @@ members = [
     "processes/replayer",           # All-inclusive process to replay messages
     "processes/golden_tests",       # All-inclusive golden tests process
     "processes/tx_submitter_cli",   # CLI wrapper for TX submitter
+    "processes/indexer",            # Minimal example indexer
 ]
 resolver = "2"
 

Cargo.toml

@@ -29,6 +29,7 @@ regex = "1"
 serde = { workspace = true, features = ["rc"] }
 serde_json = { workspace = true }
 serde_with = { workspace = true, features = ["base64"] }
+tempfile = "3"
 tokio = { workspace = true }
 tracing = { workspace = true }
 futures = "0.3.31"

common/Cargo.toml

@@ -0,0 +1,6 @@
+use crate::{BlockHash, Slot};
+
+#[derive(Debug, Clone, serde::Serialize, serde::Deserialize)]
+pub enum ChainSyncCommand {
+    FindIntersect { slot: Slot, hash: BlockHash },
+}

common/src/commands/chain_sync.rs

@@ -1 +1,2 @@
+pub mod chain_sync;
 pub mod transactions;

common/src/commands/mod.rs

@@ -3,6 +3,7 @@
 // We don't use these messages in the acropolis_common crate itself
 #![allow(dead_code)]
 
+use crate::commands::chain_sync::ChainSyncCommand;
 use crate::commands::transactions::{TransactionsCommand, TransactionsCommandResponse};
 use crate::genesis_values::GenesisValues;
 use crate::ledger_state::SPOState;
@@ -453,6 +454,7 @@ pub enum StateQueryResponse {
 #[derive(Debug, Clone, serde::Serialize, serde::Deserialize)]
 pub enum Command {
     Transactions(TransactionsCommand),
+    ChainSync(ChainSyncCommand),
 }
 
 #[derive(Debug, Clone, serde::Serialize, serde::Deserialize)]

common/src/messages.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/queries/assets.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)]

common/src/types.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,