Merge pull request input-output-hk#1680 from input-output-hk/jpraynau…

…d/1590-chainsync-pallas

Implement `chainsync` `ChainReader` with `pallas`

CHANGELOG.md

@@ -19,6 +19,8 @@ As a minor extension, we have adopted a slightly different versioning convention
 
 - Update website and explorer user interface to use the new mithril logo.
 
+- Implement a Chain Reader which retrieves blocks from the Cardano chain with Pallas through the `chainsync` mini-protocol.
+
 - Crates versions:
 
 |  Crate  |  Version  |

mithril-common/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "mithril-common"
-version = "0.4.7"
+version = "0.4.8"
 description = "Common types, interfaces, and utilities for Mithril nodes."
 authors = { workspace = true }
 edition = { workspace = true }

mithril-common/src/chain_reader/entity.rs

@@ -0,0 +1,18 @@
+use crate::{cardano_block_scanner::ScannedBlock, entities::ChainPoint};
+
+/// The action that indicates what to do next when scanning the chain
+#[derive(Debug, Clone, PartialEq)]
+pub enum ChainBlockNextAction {
+    /// RollForward event (we are still on the correct fork)
+    RollForward {
+        /// The next point in the chain to read
+        next_point: ChainPoint,
+        /// The parsed chain block
+        parsed_block: ScannedBlock,
+    },
+    /// RollBackward event (we are on an incorrect fork, we need to get back a point to roll forward again)
+    RollBackward {
+        /// The rollback point in the chain to read (as a new valid point to read from on the main chain, which has already been seen)
+        rollback_point: ChainPoint,
+    },
+}

mithril-common/src/chain_reader/fake_chain_reader.rs

@@ -0,0 +1,73 @@
+use async_trait::async_trait;
+use std::{collections::VecDeque, sync::Mutex};
+
+use crate::{entities::ChainPoint, StdResult};
+
+use super::{ChainBlockNextAction, ChainBlockReader};
+
+/// [FakeChainReader] is a fake implementation of [ChainBlockReader] for testing purposes.
+pub struct FakeChainReader {
+    chain_point_next_actions: Mutex<VecDeque<ChainBlockNextAction>>,
+}
+
+impl FakeChainReader {
+    /// Creates a new [FakeChainReader] instance.
+    pub fn new(chain_point_next_actions: Vec<ChainBlockNextAction>) -> Self {
+        Self {
+            chain_point_next_actions: Mutex::new(chain_point_next_actions.into()),
+        }
+    }
+}
+
+#[async_trait]
+impl ChainBlockReader for FakeChainReader {
+    async fn set_chain_point(&mut self, _point: &ChainPoint) -> StdResult<()> {
+        Ok(())
+    }
+
+    async fn get_next_chain_block(&mut self) -> StdResult<Option<ChainBlockNextAction>> {
+        Ok(self.chain_point_next_actions.lock().unwrap().pop_front())
+    }
+}
+
+#[cfg(test)]
+mod tests {
+    use crate::cardano_block_scanner::ScannedBlock;
+
+    use super::*;
+
+    fn build_chain_point(id: u64) -> ChainPoint {
+        ChainPoint {
+            slot_number: id,
+            block_number: id,
+            block_hash: format!("point-hash-{id}"),
+        }
+    }
+
+    #[tokio::test]
+    async fn test_get_next_chain_block() {
+        let expected_chain_point_next_actions = vec![
+            ChainBlockNextAction::RollForward {
+                next_point: build_chain_point(1),
+                parsed_block: ScannedBlock::new("hash-1", 1, 10, 20, Vec::<&str>::new()),
+            },
+            ChainBlockNextAction::RollForward {
+                next_point: build_chain_point(2),
+                parsed_block: ScannedBlock::new("hash-2", 2, 11, 21, Vec::<&str>::new()),
+            },
+            ChainBlockNextAction::RollBackward {
+                rollback_point: build_chain_point(1),
+            },
+        ];
+
+        let mut chain_reader = FakeChainReader::new(expected_chain_point_next_actions.clone());
+
+        let mut chain_point_next_actions = vec![];
+        while let Some(chain_block_next_action) = chain_reader.get_next_chain_block().await.unwrap()
+        {
+            chain_point_next_actions.push(chain_block_next_action);
+        }
+
+        assert_eq!(expected_chain_point_next_actions, chain_point_next_actions);
+    }
+}

mithril-common/src/chain_reader/interface.rs

@@ -0,0 +1,18 @@
+use async_trait::async_trait;
+
+use crate::{entities::ChainPoint, StdResult};
+
+use super::ChainBlockNextAction;
+
+/// The trait that reads events to either:
+/// - read next block on the chain
+/// - rollback to another point in case of rollback
+/// - do nothing when tip of the chain is reached
+#[async_trait]
+pub trait ChainBlockReader {
+    /// Sets the chain point
+    async fn set_chain_point(&mut self, point: &ChainPoint) -> StdResult<()>;
+
+    /// Get the next chain block
+    async fn get_next_chain_block(&mut self) -> StdResult<Option<ChainBlockNextAction>>;
+}

mithril-common/src/chain_reader/mod.rs

@@ -0,0 +1,11 @@
+//! Tools to read chain blocks sequentially
+
+mod entity;
+mod fake_chain_reader;
+mod interface;
+mod pallas_chain_reader;
+
+pub use entity::*;
+pub use fake_chain_reader::*;
+pub use interface::*;
+pub use pallas_chain_reader::*;