added InMemory Cardano node and Db Sync. Added fake leadership and update processes to simulate node updated to db sync

Author: dkijania

src/vit-testing/integration-tests/src/common/snapshot/mock.rs

@@ -1,3 +1,4 @@
+use assert_fs::fixture::PathChild;
 use crate::common::get_available_port;
 use crate::common::snapshot::SnapshotServiceStarter;
 use assert_fs::fixture::PathChild;

src/vit-testing/integration-tests/src/integration/from_snapshot_to_vitup.rs

@@ -1,5 +1,5 @@
 use crate::common::snapshot::mock;
-use crate::common::{CardanoWallet, RepsVoterAssignerSource, SnapshotFilter};
+use crate::common::{CardanoWallet, SnapshotFilter, RepsVoterAssignerSource};
 use assert_fs::TempDir;
 use chain_impl_mockchain::certificate::VotePlan;
 use fraction::Fraction;

src/vit-testing/mainnet-lib/src/db_sync/in_memory.rs

@@ -13,7 +13,14 @@ use std::fs::File;
 use std::io::Write;
 use std::path::Path;
 use std::sync::{Arc, RwLock};
+use cardano_serialization_lib::{Block, Transaction, TransactionWitnessSet};
+use cardano_serialization_lib::utils::BigNum;
+use futures::executor::block_on;
+use futures_util::StreamExt;
+use serde::{Deserialize,Serialize};
+use pharos::{Channel,Observable};
 use tokio::task::JoinHandle;
+use crate::InMemoryNode;
 
 pub type BlockNo = u32;
 pub type Address = String;
@@ -24,7 +31,14 @@ pub struct SharedInMemoryDbSync {
     pub(crate) update_thread: JoinHandle<()>,
     // Allowing for now since there is no usage yet in explorer service
     #[allow(dead_code)]
-    pub(crate) db_sync: Arc<RwLock<InMemoryDbSync>>,
+
+/// thread safe `InMemoryDbSync`. It has inner struct db_sync with rw lock guard and handle to update
+/// thread which listen to `InMemoryNode` mock block updates
+pub struct SharedInMemoryDbSync{
+    pub(crate) update_thread: JoinHandle<()>,
+    // Allowing for now since there is no usage yet in explorer service
+    #[allow(dead_code)]
+    pub(crate) db_sync: Arc<RwLock<InMemoryDbSync>>
 }
 
 impl Drop for SharedInMemoryDbSync {
@@ -33,6 +47,7 @@ impl Drop for SharedInMemoryDbSync {
     }
 }
 
+
 /// Mock of real cardano db sync. At this moment we only stores transactions metadata
 /// as the only purpose of existance for this struct is to provide catalyst voting registrations
 /// Struct can be persisted and restored from json file using `serde_json`.
@@ -41,8 +56,9 @@ pub struct InMemoryDbSync {
     pub(crate) transactions: HashMap<BlockNo, Vec<Transaction>>,
     pub(crate) blocks: Vec<Block>,
     stakes: HashMap<Address, BigNum>,
-    settings: Settings,
+    settings: Settings
 }
+
 impl Debug for InMemoryDbSync {
     fn fmt(&self, f: &mut Formatter<'_>) -> std::fmt::Result {
         write!(f, "{:?}", self.settings)
@@ -73,18 +89,18 @@ impl InMemoryDbSync {
         let shared_db_sync = Arc::new(RwLock::new(self));
         let db_sync = shared_db_sync.clone();
 
-        let handle = tokio::spawn(async move {
-            loop {
+        let handle = tokio::spawn( async move {
+             loop {
                 let block = observer.next().await;
                 if let Some(block) = block {
                     db_sync.write().unwrap().on_block_propagation(&block);
                 }
             }
         });
 
-        SharedInMemoryDbSync {
+        SharedInMemoryDbSync{
             update_thread: handle,
-            db_sync: shared_db_sync,
+            db_sync: shared_db_sync
         }
     }
 

src/vit-testing/mainnet-lib/src/wallet/registration.rs

@@ -156,6 +156,7 @@ impl<'a> RegistrationTransactionBuilder<'a> {
     }
 }
 
+/// Metadata conversion error
 /// Metadata conversion error
 #[derive(thiserror::Error, Debug)]
 pub enum JsonConversionError {