add retry lag

apps/fortuna/src/keeper.rs

@@ -687,7 +687,7 @@ pub async fn process_backlog(
 }
 
 
-/// tracks the balance of the given address for each chain in the given config periodically
+/// tracks the balance of the given address on the given chain periodically
 pub async fn track_balance(
     chain_id: String,
     chain_config: EthereumConfig,
@@ -697,14 +697,20 @@ pub async fn track_balance(
     loop {
         let provider = match Provider::<Http>::try_from(&chain_config.geth_rpc_addr) {
             Ok(r) => r,
-            Err(_e) => continue,
+            Err(_e) => {
+                time::sleep(RETRY_INTERVAL).await;
+                continue;
+            }
         };
 
         let balance = match provider.get_balance(address, None).await {
             // This conversion to u128 is fine as the total balance will never cross the limits
             // of u128 practically.
             Ok(r) => r.as_u128(),
-            Err(_e) => continue,
+            Err(_e) => {
+                time::sleep(RETRY_INTERVAL).await;
+                continue;
+            }
         };
         // The f64 conversion is made to be able to serve metrics within the constraints of Prometheus.
         // The balance is in wei, so we need to divide by 1e18 to convert it to eth.
@@ -722,7 +728,7 @@ pub async fn track_balance(
     }
 }
 
-/// tracks the collected fees and the hashchain data of the given provider address for each chain in the given config periodically
+/// tracks the collected fees and the hashchain data of the given provider address on the given chain periodically
 pub async fn track_provider(
     chain_id: String,
     chain_config: EthereumConfig,
@@ -732,19 +738,22 @@ pub async fn track_provider(
     loop {
         let contract = match PythContract::from_config(&chain_config) {
             Ok(r) => r,
-            Err(_e) => continue,
+            Err(_e) => {
+                time::sleep(RETRY_INTERVAL).await;
+                continue;
+            }
         };
 
         let provider_info = match contract.get_provider_info(provider_address).call().await {
             Ok(info) => info,
             Err(_e) => {
-                time::sleep(Duration::from_secs(5)).await;
+                time::sleep(RETRY_INTERVAL).await;
                 continue;
             }
         };
 
         // The f64 conversion is made to be able to serve metrics with the constraints of Prometheus.
-        // The fee is in wei, so we need to divide by 1e18 to convert it to eth.
+        // The fee is in wei, so we divide by 1e18 to convert it to eth.
         let collected_fee = provider_info.accrued_fees_in_wei as f64 / 1e18;
 
         let current_sequence_number = provider_info.sequence_number;