diff --git a/clients/stellar-relay-lib/Cargo.toml b/clients/stellar-relay-lib/Cargo.toml index c483b22c9..f223d30cb 100644 --- a/clients/stellar-relay-lib/Cargo.toml +++ b/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"] } diff --git a/clients/stellar-relay-lib/src/overlay.rs b/clients/stellar-relay-lib/src/overlay.rs index d011bf716..989d9c16d 100644 --- a/clients/stellar-relay-lib/src/overlay.rs +++ b/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(); } } diff --git a/clients/vault/src/cancellation.rs b/clients/vault/src/cancellation.rs index 64f829226..246922b81 100644 --- a/clients/vault/src/cancellation.rs +++ b/clients/vault/src/cancellation.rs @@ -204,7 +204,6 @@ impl Cancel mut self, mut event_listener: Receiver, ) -> Result<(), RuntimeError> { - tracing::info!("handle_cancellation(): started"); let mut list_state = ListState::Invalid; let mut active_requests: Vec = vec![]; diff --git a/clients/vault/src/oracle/agent.rs b/clients/vault/src/oracle/agent.rs index d65dc30a3..58fbfc5ec 100644 --- a/clients/vault/src/oracle/agent.rs +++ b/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 { 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)); diff --git a/clients/vault/src/oracle/collector/collector.rs b/clients/vault/src/oracle/collector/collector.rs index 507554125..b8b57bb66 100644 --- a/clients/vault/src/oracle/collector/collector.rs +++ b/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 } } diff --git a/clients/vault/src/oracle/collector/handler.rs b/clients/vault/src/oracle/collector/handler.rs index 61fd6be03..4225b59e1 100644 --- a/clients/vault/src/oracle/collector/handler.rs +++ b/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) ); diff --git a/clients/vault/src/replace.rs b/clients/vault/src/replace.rs index 4dced56cc..3dc96703a 100644 --- a/clients/vault/src/replace.rs +++ b/clients/vault/src/replace.rs @@ -28,7 +28,6 @@ pub async fn listen_for_accept_replace( payment_margin: Duration, oracle_agent: ArcRwLock, ) -> Result<(), ServiceError> { - tracing::info!("listen_for_accept_replace(): started"); let parachain_rpc = ¶chain_rpc; let vault_id_manager = &vault_id_manager; let shutdown_tx = &shutdown_tx; diff --git a/clients/wallet/src/horizon/horizon.rs b/clients/wallet/src/horizon/horizon.rs index f2adf2719..5e54de558 100644 --- a/clients/wallet/src/horizon/horizon.rs +++ b/clients/wallet/src/horizon/horizon.rs @@ -320,7 +320,6 @@ where U: Clone + IsEmptyExt, Filter: FilterWith + 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);