Connection monitor settings in da integration tests

logos-co · Feb 18, 2025 · 26623ce · 26623ce
1 parent 4c24307
commit 26623ce
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 0 deletions.
diff --git a/nomos-services/data-availability/tests/Cargo.toml b/nomos-services/data-availability/tests/Cargo.toml
@@ -11,13 +11,15 @@ cryptarchia-consensus = { path = "../../../nomos-services/cryptarchia-consensus"
 cryptarchia-engine = { path = "../../../consensus/cryptarchia-engine", features = ["serde"] }
 nomos-ledger = { path = "../../../ledger/nomos-ledger", features = ["serde"] }
 cl = { path = "../../../nomos-core/cl" }
+fixed = "1"
 full-replication = { path = "../../../nomos-da/full-replication" }
 hex = "0.4.3"
 kzgrs-backend = { path = "../../../nomos-da/kzgrs-backend" }
 nomos-core = { path = "../../../nomos-core/chain-defs" }
 nomos-da-indexer = { path = "../indexer", features = ["rocksdb-backend"] }
 nomos-da-verifier = { path = "../verifier", features = ["rocksdb-backend", "libp2p"] }
 nomos-da-sampling = { path = "../sampling" }
+nomos-da-network-core = { path = "../../../nomos-da/network/core" }
 nomos-da-network-service = { path = "../network" }
 nomos-da-storage = { path = "../../../nomos-da/storage" }
 nomos-node = { path = "../../../nodes/nomos-node" }

diff --git a/nomos-services/data-availability/tests/src/common.rs b/nomos-services/data-availability/tests/src/common.rs
@@ -1,4 +1,5 @@
 use cryptarchia_consensus::LeaderConfig;
+use fixed::types::U57F7;
 // std
 use nomos_blend::membership::Node;
 use nomos_blend::message_blend::{
@@ -31,6 +32,7 @@ use nomos_da_indexer::storage::adapters::rocksdb::RocksAdapter as IndexerStorage
 use nomos_da_indexer::storage::adapters::rocksdb::RocksAdapterSettings as IndexerStorageSettings;
 use nomos_da_indexer::DataIndexerService;
 use nomos_da_indexer::IndexerSettings;
+use nomos_da_network_core::swarm::DAConnectionMonitorSettings;
 use nomos_da_network_service::backends::libp2p::validator::DaNetworkValidatorBackend;
 use nomos_da_network_service::NetworkConfig as DaNetworkConfig;
 use nomos_da_network_service::NetworkService as DaNetworkService;
@@ -255,6 +257,15 @@ pub fn new_node(
                     ),
                     addresses: da_network_settings.peer_addresses.into_iter().collect(),
                     listening_address: da_network_settings.listening_address,
+                    monitor_settings: DAConnectionMonitorSettings {
+                        max_dispersal_failures: 0,
+                        max_sampling_failures: 0,
+                        max_replication_failures: 0,
+                        malicious_threshold: 0,
+                        failure_time_window: Duration::ZERO,
+                        time_decay_factor: U57F7::ZERO,
+                    },
+                    redial_cooldown: Duration::ZERO,
                 },
             },
             cl_mempool: TxMempoolSettings {