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

Author: dkijania

Cargo.lock

@@ -1,18 +1,20 @@
+use assert_fs::fixture::PathChild;
 use crate::common::get_available_port;
 use crate::common::snapshot::SnapshotServiceStarter;
 use assert_fs::TempDir;
-use mainnet_lib::{JsonBasedBdSyncError, JsonBasedDbSync};
+use mainnet_lib::{DbSyncError, InMemoryDbSync};
 use snapshot_trigger_service::client::SnapshotResult;
 use snapshot_trigger_service::config::{
     ConfigurationBuilder, JobParameters, NetworkType, VotingToolsParams,
 };
 
 pub fn do_snapshot(
-    db_sync_instance: &JsonBasedDbSync,
+    db_sync_instance: &InMemoryDbSync,
     job_parameters: JobParameters,
     testing_directory: &TempDir,
 ) -> Result<SnapshotResult, Error> {
-    db_sync_instance.persist()?;
+    let mock_json_file  = testing_directory.child("database.json");
+    db_sync_instance.persist(mock_json_file.path())?;
 
     let params = VotingToolsParams {
         bin: Some("snapshot_tool".to_string()),
@@ -25,7 +27,7 @@ pub fn do_snapshot(
         additional_params: Some(vec![
             "dry-run".to_string(),
             "--mock-json-file".to_string(),
-            db_sync_instance.db_path().to_str().unwrap().to_string(),
+            mock_json_file.path().to_str().unwrap().to_string(),
         ]),
     };
 
@@ -44,7 +46,7 @@ pub fn do_snapshot(
 #[derive(thiserror::Error, Debug)]
 pub enum Error {
     #[error(transparent)]
-    DbSync(#[from] JsonBasedBdSyncError),
+    DbSync(#[from] DbSyncError),
     #[error(transparent)]
     SnapshotIntegration(#[from] crate::common::snapshot::Error),
     #[error(transparent)]

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

@@ -35,7 +35,7 @@ pub fn cip_36_support() {
         .with(bob.as_representative())
         .with(clarice.as_representative())
         .with(dave.as_delegator(vec![(&bob, 1u8), (&clarice, 1u8)]))
-        .as_json(&testing_directory);
+        .build();
 
     let snapshot_result = mock::do_snapshot(&db_sync, job_param, &testing_directory).unwrap();
 

src/vit-testing/integration-tests/src/component/backend/cip_36_support.rs

@@ -28,7 +28,7 @@ pub fn mixed_registration_transactions() {
         .with(david.as_representative())
         .with(edgar.as_representative())
         .with(fred.as_representative())
-        .as_json(&testing_directory);
+        .build();
 
     let voters_hir = mock::do_snapshot(&db_sync, JobParameters::fund("fund9"), &testing_directory)
         .unwrap()

src/vit-testing/integration-tests/src/component/snapshot/local.rs

@@ -35,7 +35,7 @@ pub fn voters_with_at_least_one_vote() {
         .with(alice_wallet.as_direct_voter())
         .with(bob_wallet.as_direct_voter())
         .with(clarice_wallet.as_direct_voter())
-        .as_json(&testing_directory);
+        .build();
 
     let snapshot = mock::do_snapshot(&db_sync, JobParameters::fund("fund9"), &testing_directory)
         .unwrap()

src/vit-testing/integration-tests/src/e2e/local/active_voters_rewards.rs

@@ -26,7 +26,7 @@ pub fn cip36_mixed_delegation() {
         .with(alice.as_direct_voter())
         .with(bob.as_delegator(vec![(&david, 1)]))
         .with(clarice.as_delegator(vec![(&david, 1), (&edgar, 1)]))
-        .as_json(&testing_directory);
+        .build();
 
     let voter_hir = mock::do_snapshot(&db_sync, JobParameters::fund("fund9"), &testing_directory)
         .unwrap()
@@ -74,7 +74,7 @@ pub fn voting_power_cap_for_reps() {
         .with(alice.as_delegator(vec![(&david, 1)]))
         .with(bob.as_delegator(vec![(&edgar, 1)]))
         .with(clarice.as_delegator(vec![(&fred, 1)]))
-        .as_json(&testing_directory);
+        .build();
 
     let reps_circle_size = reps.len();
 
@@ -106,7 +106,7 @@ pub fn voting_power_cap_for_direct() {
         .with(alice.as_direct_voter())
         .with(bob.as_direct_voter())
         .with(clarice.as_direct_voter())
-        .as_json(&testing_directory);
+        .build();
 
     let voter_hir = mock::do_snapshot(&db_sync, JobParameters::fund("fund9"), &testing_directory)
         .unwrap()
@@ -138,7 +138,7 @@ pub fn voting_power_cap_for_mix() {
         .with(alice.as_direct_voter())
         .with(bob.as_direct_voter())
         .with(clarice.as_delegator(vec![(&david, 1)]))
-        .as_json(&testing_directory);
+        .build();
 
     let voter_hir = mock::do_snapshot(&db_sync, JobParameters::fund("fund9"), &testing_directory)
         .unwrap()

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

@@ -38,7 +38,7 @@ pub fn cip36_and_voting_group_merge() {
         .with(alice.as_direct_voter())
         .with(bob.as_delegator(vec![(&david, 1)]))
         .with(clarice.as_delegator(vec![(&david, 1), (&edgar, 1)]))
-        .as_json(&testing_directory);
+        .build();
 
     let voter_hir = mock::do_snapshot(&db_sync, JobParameters::fund("fund9"), &testing_directory)
         .unwrap()

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

@@ -25,7 +25,7 @@ pub fn put_raw_snapshot() {
         .with(alice_wallet.as_direct_voter())
         .with(bob_wallet.as_direct_voter())
         .with(clarice_wallet.as_direct_voter())
-        .as_json(&testing_directory);
+        .build();
 
     let job_params = JobParameters::fund("fund9");
     let snapshot_result =

src/vit-testing/integration-tests/src/integration/from_snapshot_to_vit_servicing_station.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;
@@ -34,7 +34,7 @@ pub fn cip36_mixed_delegation_should_appear_in_block0() {
         .with(alice.as_direct_voter())
         .with(bob.as_delegator(vec![(&david_representative, 1)]))
         .with(clarice.as_delegator(vec![(&edgar_representative, 1), (&edgar_representative, 1)]))
-        .as_json(&testing_directory);
+        .build();
 
     let snapshot_result =
         mock::do_snapshot(&db_sync, JobParameters::fund("fund9"), &testing_directory).unwrap();

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

@@ -4,19 +4,29 @@ use cardano_serialization_lib::crypto::{BlockHash, Ed25519Signature, KESSignatur
 use cardano_serialization_lib::utils::BigNum;
 use crate::Settings;
 
+
 pub struct Block0{
     pub block: Block,
     pub settings: Settings
 }
 
 
+impl Default for Block0 {
+    fn default() -> Self {
+        Self {
+            block: BlockBuilder::next_block(None,vec![]),
+            settings: Default::default()
+        }
+    }
+}
+
 pub struct BlockBuilder;
 
 impl BlockBuilder {
 
     pub fn next_block(prev: Option<&Block>, transactions: Vec<Transaction>) -> Block {
         let header_body = Self::block_header(
-            prev.map(|b| b.header().header_body().block_number()).unwrap_or(0),
+            prev.map(|b| b.header().header_body().block_number()).unwrap_or(1),
             prev.map(|b| b.header().header_body().block_body_hash())
         );
 
@@ -51,14 +61,14 @@ impl BlockBuilder {
         let issuer_vkey = PrivateKey::generate_ed25519extended().unwrap().to_public();
 
         HeaderBody::new_headerbody(block_number,
-                                   &BigNum::zero(),
+                                   &BigNum::from(block_number),
                                    prev_hash,
                                    &Vkey::new(&issuer_vkey),
-                                   &VRFVKey::from_hex(&issuer_vkey.to_hex()).unwrap(),
-                                   &VRFCert::from_hex(&issuer_vkey.to_hex()).unwrap(),
+                                   &VRFVKey::from_bytes(Self::generate_random_bytes_of_len(32)).unwrap(),
+                                   &VRFCert::new(Self::generate_random_bytes_of_len(32),Self::generate_random_bytes_of_len(VRFCert::PROOF_LEN)).unwrap(),
                                    0,
-                                   &BlockHash::from_hex(&issuer_vkey.to_hex()).unwrap(),
-                                   &OperationalCert::new(&KESVKey::from_hex(&issuer_vkey.to_hex()).unwrap(),0,0,&Ed25519Signature::from_hex(&issuer_vkey.to_hex()).unwrap()), &ProtocolVersion::new(0,1))
+                                   &BlockHash::from_bytes(Self::generate_random_bytes_of_len(32)).unwrap(),
+                                   &OperationalCert::new(&KESVKey::from_bytes(Self::generate_random_bytes_of_len(32)).unwrap(),0,0,&Ed25519Signature::from_bytes(Self::generate_random_bytes_of_len(64)).unwrap()), &ProtocolVersion::new(0,1))
 
     }
 }