Add nice warnings for re-try mechanisms

Author: JasoonS

examples/wallet/src/main.rs

@@ -1,6 +1,6 @@
 // Example of getting all transactions and erc20 transfers of a multi-address wallet on arbitrum
 
-use std::sync::Arc;
+use std::{num::NonZero, sync::Arc};
 
 use hypersync_client::{
     format::Hex, net_types::Query, Client, ClientConfig, Decoder, StreamConfig,
@@ -18,6 +18,7 @@ async fn main() {
 
     let client = Client::new(ClientConfig {
         url: Some("https://eth.hypersync.xyz".parse().unwrap()),
+        http_req_timeout_millis: NonZero::new(500),
         ..Default::default()
     })
     .unwrap();

hypersync-client/src/lib.rs

@@ -301,12 +301,14 @@ impl Client {
 
         let mut err = anyhow!("");
 
-        for _ in 0..self.max_num_retries + 1 {
+        for i in 0..self.max_num_retries + 1 {
             match self.get_chain_id_impl().await {
                 Ok(res) => return Ok(res),
                 Err(e) => {
-                    log::error!(
-                        "failed to get chain_id from server, retrying... The error was: {:?}",
+                    log::warn!(
+                        "An exception occured getting chain_id from server. Retrying request ({}/{}). The error was: {:?}",
+                        i - 1 ,
+                        self.max_num_retries,
                         e
                     );
                     err = err.context(format!("{:?}", e));
@@ -333,12 +335,14 @@ impl Client {
 
         let mut err = anyhow!("");
 
-        for _ in 0..self.max_num_retries + 1 {
+        for i in 0..self.max_num_retries + 1 {
             match self.get_height_impl(None).await {
                 Ok(res) => return Ok(res),
                 Err(e) => {
-                    log::error!(
-                        "failed to get height from server, retrying... The error was: {:?}",
+                    log::warn!(
+                        "An exception occured getting height from server. Retrying request ({}/{}). The error was: {:?}",
+                        i,
+                        self.max_num_retries,
                         e
                     );
                     err = err.context(format!("{:?}", e));
@@ -425,12 +429,14 @@ impl Client {
 
         let mut err = anyhow!("");
 
-        for _ in 0..self.max_num_retries + 1 {
+        for i in 0..self.max_num_retries + 1 {
             match self.get_arrow_impl(query).await {
                 Ok(res) => return Ok(res),
                 Err(e) => {
-                    log::error!(
-                        "failed to get arrow data from server, retrying... The error was: {:?}",
+                    log::warn!(
+                        "An exception occured getting arrow data from server. Retrying request ({}/{}). The error was: {:?}",
+                        i - 1 ,
+                        self.max_num_retries,
                         e
                     );
                     err = err.context(format!("{:?}", e));