Update BDK sync parameters

Author: tnull

src/lib.rs

@@ -169,11 +169,11 @@ const DEFAULT_FEE_RATE_CACHE_UPDATE_INTERVAL_SECS: u64 = 60 * 10;
 const DEFAULT_LOG_LEVEL: LogLevel = LogLevel::Debug;
 
 // The 'stop gap' parameter used by BDK's wallet sync. This seems to configure the threshold
-// number of blocks after which BDK stops looking for scripts belonging to the wallet.
+// number of derivation indexes after which BDK stops looking for new scripts belonging to the wallet.
 const BDK_CLIENT_STOP_GAP: usize = 20;
 
 // The number of concurrent requests made against the API provider.
-const BDK_CLIENT_CONCURRENCY: u8 = 8;
+const BDK_CLIENT_CONCURRENCY: u8 = 4;
 
 // The default Esplora server we're using.
 const DEFAULT_ESPLORA_SERVER_URL: &str = "https://blockstream.info/api";
@@ -354,11 +354,17 @@ impl<K: KVStore + Sync + Send + 'static> Node<K> {
 							_ = onchain_wallet_sync_interval.tick() => {
 								let now = Instant::now();
 								match wallet.sync().await {
-									Ok(()) => log_trace!(
+									Ok(()) => {
+										println!(
+										"Background sync of on-chain wallet finished in {}ms.",
+										now.elapsed().as_millis()
+										);
+										log_trace!(
 										sync_logger,
 										"Background sync of on-chain wallet finished in {}ms.",
 										now.elapsed().as_millis()
-										),
+										);
+									}
 									Err(err) => {
 										log_error!(
 											sync_logger,
@@ -371,11 +377,17 @@ impl<K: KVStore + Sync + Send + 'static> Node<K> {
 							_ = fee_rate_update_interval.tick() => {
 								let now = Instant::now();
 								match wallet.update_fee_estimates().await {
-									Ok(()) => log_trace!(
+									Ok(()) => {
+										println!(
+										"Background update of fee rate cache finished in {}ms.",
+										now.elapsed().as_millis()
+										);
+										log_trace!(
 										sync_logger,
 										"Background update of fee rate cache finished in {}ms.",
 										now.elapsed().as_millis()
-										),
+										);
+									}
 									Err(err) => {
 										log_error!(
 											sync_logger,
@@ -414,11 +426,17 @@ impl<K: KVStore + Sync + Send + 'static> Node<K> {
 						];
 						let now = Instant::now();
 						match tx_sync.sync(confirmables).await {
-							Ok(()) => log_trace!(
+							Ok(()) => {
+								println!(
+								"Background sync of Lightning wallet finished in {}ms.",
+								now.elapsed().as_millis()
+								);
+								log_trace!(
 								sync_logger,
 								"Background sync of Lightning wallet finished in {}ms.",
 								now.elapsed().as_millis()
-								),
+								);
+							}
 							Err(e) => {
 								log_error!(sync_logger, "Background sync of Lightning wallet failed: {}", e)
 							}