feat: log out endpoint in case of failed connection attempt

Author: pedrohba1

crates/tap-agent/src/agent/sender_account.rs

@@ -608,9 +608,12 @@ impl Actor for SenderAccount {
             .expect("Failed to create an endpoint for the sender aggregator")
             .connect_timeout(config.rav_request_timeout);
 
-        let sender_aggregator = TapAggregatorClient::connect(endpoint)
+            let sender_aggregator = TapAggregatorClient::connect(endpoint.clone())
             .await
-            .expect("Failed to connect to the TapAggregator endpoint")
+            .expect(&format!(
+                "Failed to connect to the TapAggregator endpoint '{}'",
+                endpoint.uri()
+            ))
             .send_compressed(tonic::codec::CompressionEncoding::Zstd);
 
         let state = State {
@@ -1040,9 +1043,7 @@ impl SenderAccount {
 #[cfg(test)]
 pub mod tests {
     use std::{
-        collections::{HashMap, HashSet},
-        sync::{atomic::AtomicU32, Arc},
-        time::{Duration, SystemTime, UNIX_EPOCH},
+        collections::{HashMap, HashSet},  sync::{atomic::AtomicU32, Arc}, time::{Duration, SystemTime, UNIX_EPOCH}
     };
 
     use indexer_monitor::{DeploymentDetails, EscrowAccounts, SubgraphClient};
@@ -1123,7 +1124,7 @@ pub mod tests {
             }
         }
     }
-
+    
     pub static PREFIX_ID: AtomicU32 = AtomicU32::new(0);
     const DUMMY_URL: &str = "http://localhost:1234";
     const TRIGGER_VALUE: u128 = 500;

crates/tap-agent/src/agent/sender_accounts_manager.rs

@@ -655,6 +655,8 @@ mod tests {
         }))
     }
 
+
+    const DUMMY_ADDR: &str = "http://localhost:1234";
     async fn create_sender_accounts_manager(
         pgpool: PgPool,
     ) -> (
@@ -683,8 +685,8 @@ mod tests {
             escrow_subgraph,
             network_subgraph,
             sender_aggregator_endpoints: HashMap::from([
-                (SENDER.1, Url::parse("http://localhost:8000").unwrap()),
-                (SENDER_2.1, Url::parse("http://localhost:8000").unwrap()),
+                (SENDER.1, Url::parse(DUMMY_ADDR).unwrap()),
+                (SENDER_2.1, Url::parse(DUMMY_ADDR).unwrap()),
             ]),
             prefix: Some(prefix.clone()),
         };
@@ -704,6 +706,7 @@ mod tests {
         join_handle.await.unwrap();
     }
 
+    const SENDER_DUMMY_ADDR: &str = "http://localhost:1234";
     async fn create_state(pgpool: PgPool) -> (String, State) {
         let config = get_config();
         let senders_to_signers = vec![(SENDER.1, vec![SIGNER.1])].into_iter().collect();
@@ -727,8 +730,8 @@ mod tests {
                 escrow_subgraph: get_subgraph_client().await,
                 network_subgraph: get_subgraph_client().await,
                 sender_aggregator_endpoints: HashMap::from([
-                    (SENDER.1, Url::parse("http://localhost:8000").unwrap()),
-                    (SENDER_2.1, Url::parse("http://localhost:8000").unwrap()),
+                    (SENDER.1, Url::parse(SENDER_DUMMY_ADDR).unwrap()),
+                    (SENDER_2.1, Url::parse(SENDER_DUMMY_ADDR).unwrap()),
                 ]),
                 prefix: Some(prefix),
             },

crates/tap-agent/src/agent/sender_allocation.rs

@@ -953,10 +953,13 @@ pub mod tests {
             .unwrap()
             .connect_timeout(Duration::default());
 
-      
-        let sender_aggregator = TapAggregatorClient::connect(endpoint)
+
+            let sender_aggregator = TapAggregatorClient::connect(endpoint.clone())
             .await
-            .expect("Failed to connect to the TapAggregator endpoint")
+            .expect(&format!(
+                "Failed to connect to the TapAggregator endpoint '{}'",
+                endpoint.uri()
+            ))
      .send_compressed(tonic::codec::CompressionEncoding::Zstd);
 
         SenderAllocationArgs {
@@ -1373,7 +1376,7 @@ pub mod tests {
         // check if the actor is actually stopped
         assert_eq!(sender_allocation.get_status(), ActorStatus::Stopped);
     }
-
+ 
     #[sqlx::test(migrations = "../../migrations")]
     async fn should_return_unaggregated_fees_without_rav(pgpool: PgPool) {
         let (mock_escrow_subgraph_server, _mock_ecrow_subgraph) = mock_escrow_subgraph().await;