the great peer connection rewrite

Cargo.toml

@@ -5,10 +5,12 @@ edition = "2021"
 
 [dependencies]
 anyhow = "1.0.92"
+async-channel = "2.3.1"
 async-trait = "0.1.83"
 chia = "0.15.0"
 chia-wallet-sdk = { version = "0.17.0", features = ["rustls"] }
 clap = { version = "4.5.20", features = ["derive"] }
+dashmap = "6.1.0"
 futures = "0.3.31"
 futures-util = "0.3.31"
 rand = "0.8.5"

src/config.rs

@@ -1,6 +1,6 @@
 use std::time::Duration;
 
-pub const PEER_TIMEOUT: u64 = 5;
+pub const PEER_TIMEOUT: u64 = 7;
 pub const DNS_RECORD_TTL: u32 = 300;
 pub const MAX_CONCURRENT_TASKS: usize = 100;
 pub const MAX_RECORDS_TO_RETURN: usize = 32;

src/dns.rs

@@ -55,12 +55,18 @@ impl RandomizedAuthority {
         }
     }
 
+    pub async fn known_peer(&self, addr: &SocketAddr) -> bool {
+        self.peers.read().await.contains(addr)
+    }
+
     pub async fn get_peers(&self) -> Vec<SocketAddr> {
         let peers = self.peers.read().await;
         peers.iter().cloned().collect()
     }
 
-    pub fn block_peer(&self, addr: SocketAddr, duration: Duration) {
+    pub async fn block_peer(&self, addr: SocketAddr, duration: Duration) {
+        self.remove_peer(addr).await;
+
         let mut blocked = self.blocked_peers.lock().unwrap();
         blocked.retain(|peer| peer.addr != addr);
         blocked.push(BlockedPeer {