Change log level for invalid fidelity

src/taker/api.rs

@@ -2395,6 +2395,11 @@ impl Taker {
     pub fn is_offerbook_syncing(&self) -> bool {
         self.offer_sync_handle.is_syncing()
     }
+
+    /// Run offer sync now.
+    pub fn run_offer_sync_now(&self) {
+        self.offer_sync_handle.run_sync_now()
+    }
 }
 
 impl Role for Taker {

src/taker/api2.rs

@@ -1823,6 +1823,11 @@ impl Taker {
     pub fn is_offerbook_syncing(&self) -> bool {
         self.offer_sync_handle.is_syncing()
     }
+
+    /// Run offer sync now.
+    pub fn run_offer_sync_now(&self) {
+        self.offer_sync_handle.run_sync_now()
+    }
 }
 
 impl Role for Taker {

src/taker/offers.rs

@@ -302,13 +302,15 @@ pub struct OfferSyncService {
     socks_port: u16,
     rpc_backend: BitcoinRpc,
     is_syncing: Arc<AtomicBool>,
+    run_now: Arc<AtomicBool>,
 }
 
 /// OfferSync handle, use for shutting down OfferSyncService
 pub struct OfferSyncHandle {
     shutdown: Arc<AtomicBool>,
     join: Option<JoinHandle<()>>,
     is_syncing: Arc<AtomicBool>,
+    run_now: Arc<AtomicBool>,
 }
 
 impl OfferSyncHandle {
@@ -325,6 +327,11 @@ impl OfferSyncHandle {
     pub fn is_syncing(&self) -> bool {
         self.is_syncing.load(Ordering::SeqCst)
     }
+
+    /// Runs manual sync, rather than waiting for routine to trigger it.
+    pub fn run_sync_now(&self) {
+        self.run_now.store(true, Ordering::Relaxed);
+    }
 }
 
 impl OfferSyncService {
@@ -341,6 +348,7 @@ impl OfferSyncService {
             socks_port,
             rpc_backend,
             is_syncing: Arc::new(AtomicBool::new(false)),
+            run_now: Arc::new(AtomicBool::new(false)),
         }
     }
 
@@ -397,6 +405,7 @@ impl OfferSyncService {
         let shutdown = Arc::new(AtomicBool::new(false));
         let shutdown_flag = shutdown.clone();
         let is_syncing = self.is_syncing.clone();
+        let run_now = self.run_now.clone();
         self.is_syncing.store(true, Ordering::SeqCst);
 
         let join = std::thread::Builder::new()
@@ -414,10 +423,16 @@ impl OfferSyncService {
                     log::debug!("Running offerbook sync completed");
                     self.is_syncing.store(false, Ordering::SeqCst);
                     let mut slept = Duration::ZERO;
-                    while slept < OFFER_SYNC_INTERVAL && !shutdown_flag.load(Ordering::Relaxed) {
+                    while slept < OFFER_SYNC_INTERVAL
+                        && !self.run_now.load(Ordering::Relaxed)
+                        && !shutdown_flag.load(Ordering::Relaxed)
+                    {
                         std::thread::sleep(Duration::from_secs(1));
                         slept += Duration::from_secs(1);
                     }
+                    if self.run_now.swap(false, Ordering::Relaxed) {
+                        log::info!("Manual offerbook syncing initiated");
+                    }
                 }
 
                 log::debug!("Offer sync service stopped");
@@ -428,6 +443,7 @@ impl OfferSyncService {
             shutdown,
             join: Some(join),
             is_syncing,
+            run_now,
         }
     }
 

src/watch_tower/rpc_backend.rs

@@ -265,7 +265,7 @@ impl BitcoinRpc {
                         }
                     }
                     None => {
-                        log::warn!("Invalid fidelity {txid}:{vout} via {relay_url}");
+                        log::debug!("Invalid fidelity {txid}:{vout} via {relay_url}");
                     }
                 }
             }