Merge branch 'main' into sg/chain-sync-tweaks

Author: SupernaviX

Cargo.lock

@@ -3,6 +3,7 @@
 [workspace]
 members = [
     # Global message and common definitions
+    "cardano",
     "codec",
     "common",
 
@@ -52,6 +53,7 @@ config = "0.15.11"
 dashmap = "6.1.0"
 hex = "0.4"
 imbl = { version = "5.0.0", features = ["serde"] }
+minicbor = { version = "0.25.1", features = ["alloc", "std", "derive"] }
 opentelemetry = { version = "0.30.0", features = ["trace"] }
 opentelemetry-otlp = { version = "0.30.0", features = ["grpc-tonic", "trace", "tls"] }
 opentelemetry_sdk = { version = "0.30.0", features = ["rt-tokio"] }

Cargo.toml

@@ -26,28 +26,23 @@ to communicate between micro-services.
 
 ```mermaid
 graph TB
-
   subgraph Process A
     Module1(Module 1)
     Module2(Module 2)
     Caryatid1(Caryatid Framework)
-
     Module1 <--> Caryatid1
     Module2 <--> Caryatid1
   end
 
   subgraph Process B
     Module3(Module 3)
-
     Caryatid2(Caryatid Framework)
-
     Module3 <--> Caryatid2
 
   end
 
   RabbitMQ([RabbitMQ Message Bus])
-  style RabbitMQ fill:#eff
-
+  style RabbitMQ fill: #eff
   Caryatid1 <--> RabbitMQ
   Caryatid2 <--> RabbitMQ
 ```
@@ -61,6 +56,9 @@ graph TB
   Fetches a chain snapshot from Mithril and replays all the blocks in it
 - [Genesis Bootstrapper](modules/genesis_bootstrapper) - reads the Genesis
   file for a chain and generates initial UTXOs
+- [Snapshot Bootstrapper](modules/snapshot_bootstrapper) - downloads ledger state snapshot files for configured epochs,
+  streams and parses the CBOR data (UTXOs, pools, accounts, DReps, proposals), and publishes completion messages to
+  signal snapshot readiness to other modules.
 - [Block Unpacker](modules/block_unpacker) - unpacks received blocks
   into individual transactions
 - [Tx Unpacker](modules/tx_unpacker) - parses transactions and generates UTXO
@@ -69,7 +67,8 @@ graph TB
 - [SPO State](modules/spo_state) - matches SPO registrations and retirements
 - [DRep State](modules/drep_state) - tracks DRep registrations
 - [Governance State](modules/governance_state) - tracks Governance Actions and voting
-- [Stake Delta Filter](modules/stake_delta_filter) - filters out stake address changes and handles stake pointer references
+- [Stake Delta Filter](modules/stake_delta_filter) - filters out stake address changes and handles stake pointer
+  references
 - [Epochs State](modules/epochs_state) - track fees blocks minted and epochs history
 - [Accounts State](modules/accounts_state) - stake and reward accounts tracker
 - [Assets State](modules/assets_state) - tracks native asset supply, metadata, transactions, and addresses

README.md

@@ -0,0 +1,8 @@
+[package]
+name = "acropolis_cardano"
+version = "0.1.0"
+edition = "2024"
+
+[dependencies]
+acropolis_common = { version = "0.3.0", path = "../common" }
+anyhow.workspace = true

cardano/Cargo.toml

@@ -0,0 +1 @@
+pub mod transaction;

cardano/src/lib.rs

@@ -0,0 +1,31 @@
+use acropolis_common::{Lovelace, protocol_params::ProtocolParams};
+use anyhow::{Error, anyhow};
+
+pub fn calculate_transaction_fee(
+    recorded_fee: &Option<Lovelace>,
+    inputs: &[Lovelace],
+    outputs: &[Lovelace],
+) -> Lovelace {
+    match recorded_fee {
+        Some(fee) => *fee,
+        None => inputs.iter().sum::<Lovelace>() - outputs.iter().sum::<Lovelace>(),
+    }
+}
+
+pub fn calculate_deposit(
+    pool_update_count: u64,
+    stake_cert_count: u64,
+    params: &ProtocolParams,
+) -> Result<Lovelace, Error> {
+    match &params.shelley {
+        Some(shelley) => Ok(stake_cert_count * shelley.protocol_params.key_deposit
+            + pool_update_count * shelley.protocol_params.pool_deposit),
+        None => {
+            if pool_update_count > 0 || stake_cert_count > 0 {
+                Err(anyhow!("No Shelley params, but deposits present"))
+            } else {
+                Ok(0)
+            }
+        }
+    }
+}