handle cleanup errors

src/dns.rs

@@ -183,14 +183,13 @@ impl PeerDiscoveryAuthority {
         }
     }
 
-    pub fn cleanup_unreachable_peers(&self) {
+    pub fn cleanup_unreachable_peers(&self) -> Result<(), rusqlite::Error> {
         let conn = self.db_pool.get().unwrap();
-
         conn.execute(
             "DELETE FROM peers WHERE is_reachable = 0 AND expires_at <= strftime('%s', 'now')",
             [],
-        )
-        .unwrap();
+        )?;
+        Ok(())
     }
 
     pub fn get_reachable_peer_count(&self) -> usize {

src/peer.rs

@@ -7,7 +7,7 @@ use dashmap::DashSet;
 use futures::stream::StreamExt;
 use std::{net::SocketAddr, sync::Arc};
 use tokio::time::{sleep, timeout};
-use tracing::{debug, info};
+use tracing::{debug, error, info};
 
 #[derive(Clone)]
 pub struct PeerProcessor {
@@ -162,8 +162,6 @@ pub async fn start_peer_rechecker(
     authority: Arc<PeerDiscoveryAuthority>,
 ) -> anyhow::Result<()> {
     loop {
-        authority.cleanup_unreachable_peers();
-
         let expired_peers = authority
             .get_expired_reachable_peers(PEER_RECHECK_BATCH_SIZE)
             .await;
@@ -182,6 +180,10 @@ pub async fn start_peer_rechecker(
             }
         }
 
+        if let Err(e) = authority.cleanup_unreachable_peers() {
+            error!("Failed to cleanup peers: {:?}", e);
+        }
+
         sleep(PEER_RECHECK_INTERVAL).await;
     }
 }