reduce changes

clients/stellar-relay-lib/Cargo.toml

@@ -16,7 +16,6 @@ wallet = { path = "../wallet", features = ["testing-utils"] }
 console-subscriber = { version = "0.3.0" }
 
 [dependencies]
-
 hex = "0.4.3"
 tracing = { version = "0.1", features = ["log"] }
 

clients/stellar-relay-lib/src/overlay.rs

@@ -93,7 +93,6 @@ impl StellarOverlayConnection {
 
 impl Drop for StellarOverlayConnection {
 	fn drop(&mut self) {
-		debug!("drop(): shutting down StellarOverlayConnection");
 		self.stop();
 	}
 }

clients/vault/src/cancellation.rs

@@ -204,7 +204,6 @@ impl<P: IssuePallet + ReplacePallet + UtilFuncs + SecurityPallet + Clone> Cancel
 		mut self,
 		mut event_listener: Receiver<Event>,
 	) -> Result<(), RuntimeError> {
-		tracing::info!("handle_cancellation(): started");
 		let mut list_state = ListState::Invalid;
 		let mut active_requests: Vec<ActiveRequest> = vec![];
 

clients/vault/src/oracle/agent.rs

@@ -13,7 +13,7 @@ use stellar_relay_lib::{
 
 use crate::{
 	oracle::{
-		collector::ScpMessageCollector, errors::Error, get_random_secret_key,
+		collector::ScpMessageCollector, errors::Error,
 		types::StellarMessageSender, AddTxSet, Proof,
 	},
 	ArcRwLock,
@@ -176,7 +176,7 @@ pub async fn start_oracle_agent(
 ) -> ArcRwLock<OracleAgent> {
 	let oracle_agent = Arc::new(RwLock::new(OracleAgent::new(&cfg, shutdown_sender.clone())));
 
-	let secret = get_random_secret_key();
+	let secret = crate::oracle::get_random_secret_key();
 
 	tokio::spawn(listen_for_stellar_messages(cfg, oracle_agent.clone(), secret, shutdown_sender));
 

clients/vault/src/oracle/collector/collector.rs

@@ -69,6 +69,7 @@ impl ScpMessageCollector {
 			stellar_history_archive_urls,
 		}
 	}
+
 	pub fn envelopes_map_len(&self) -> usize {
 		self.envelopes_map.read().len()
 	}
@@ -120,7 +121,7 @@ impl ScpMessageCollector {
 		self.txset_and_slot_map.read().get_txset_hash_by_slot(slot).cloned()
 	}
 
-	pub fn last_slot_index(&self) -> u64 {
+	pub(crate) fn last_slot_index(&self) -> u64 {
 		self.last_slot_index
 	}
 }

clients/vault/src/oracle/collector/handler.rs

@@ -25,7 +25,7 @@ impl ScpMessageCollector {
 
 		// we are only interested with `ScpStExternalize`. Other messages are ignored.
 		if let ScpStatementPledges::ScpStExternalize(stmt) = &env.statement.pledges {
-			tracing::debug!(
+			tracing::trace!(
 				"Handling Incoming ScpEnvelopes for slot {slot}: SCPStExternalize found: {}",
 				to_base64_xdr_string(stmt)
 			);

clients/vault/src/replace.rs

@@ -28,7 +28,6 @@ pub async fn listen_for_accept_replace(
 	payment_margin: Duration,
 	oracle_agent: ArcRwLock<OracleAgent>,
 ) -> Result<(), ServiceError<Error>> {
-	tracing::info!("listen_for_accept_replace(): started");
 	let parachain_rpc = &parachain_rpc;
 	let vault_id_manager = &vault_id_manager;
 	let shutdown_tx = &shutdown_tx;

clients/wallet/src/horizon/horizon.rs

@@ -320,7 +320,6 @@ where
 	U: Clone + IsEmptyExt,
 	Filter: FilterWith<T, U> + Clone,
 {
-	tracing::info!("listen_for_new_transactions(): started");
 	let horizon_client = reqwest::Client::new();
 	let mut fetcher =
 		HorizonFetcher::new(horizon_client, vault_account_public_key, is_public_network);