From 503ff86b5d8861cdc2c1bbcf2902127abde71693 Mon Sep 17 00:00:00 2001
From: scx1332 <sieciech.czajka@golem.network>
Date: Thu, 8 Feb 2024 19:48:28 +0100
Subject: [PATCH] Working on problem resolution

---
 crates/erc20_rpc_pool/src/rpc_pool/pool.rs | 30 +++++++++++++++++++++-
 1 file changed, 29 insertions(+), 1 deletion(-)

diff --git a/crates/erc20_rpc_pool/src/rpc_pool/pool.rs b/crates/erc20_rpc_pool/src/rpc_pool/pool.rs
index b4b02b7c..c959bf3a 100644
--- a/crates/erc20_rpc_pool/src/rpc_pool/pool.rs
+++ b/crates/erc20_rpc_pool/src/rpc_pool/pool.rs
@@ -119,6 +119,8 @@ pub struct Web3RpcPool {
     pub external_dns_sources: Vec<Web3ExternalDnsSource>,
     pub last_external_check: Arc<Mutex<Option<std::time::Instant>>>,
     pub check_external_sources_interval: Duration,
+
+    pub last_verify_endpoints_spawn: Arc<Mutex<Option<std::time::Instant>>>,
 }
 
 pub async fn resolve_txt_record_to_string_array(record: &str) -> std::io::Result<Vec<String>> {
@@ -192,6 +194,7 @@ impl Web3RpcPool {
             external_dns_sources: dns_sources,
             last_external_check: Arc::new(Mutex::new(None)),
             check_external_sources_interval: external_sources_interval_check,
+            last_verify_endpoints_spawn: Arc::new(Mutex::new(None)),
         });
         if !s.external_json_sources.is_empty() || !s.external_dns_sources.is_empty() {
             tokio::spawn(s.clone().resolve_external_addresses());
@@ -495,10 +498,35 @@ impl Web3RpcPool {
             //todo change type system to allow that call
 
             let self_cloned = self.clone();
-            tokio::spawn(self_cloned.verify_unverified_endpoints());
+
+            let spawn_endpoints = if let Some(last_verify_endpoints_spawn) = self_cloned
+                .last_verify_endpoints_spawn
+                .try_lock_for(Duration::from_secs(5))
+                .unwrap()
+                .as_ref()
+            {
+                if last_verify_endpoints_spawn.elapsed() < Duration::from_secs(10) {
+                    false
+                } else {
+                    true
+                }
+            } else {
+                true
+            };
+
+            if spawn_endpoints {
+                self_cloned
+                    .last_verify_endpoints_spawn
+                    .try_lock_for(Duration::from_secs(5))
+                    .unwrap()
+                    .replace(std::time::Instant::now());
+                tokio::spawn(self_cloned.verify_unverified_endpoints());
+            }
+
             allowed_endpoints
         } else {
             let self_cloned = self.clone();
+            log::error!("Spawn tasks");
             let verify_task = tokio::spawn(self_cloned.verify_unverified_endpoints());
 
             loop {