Implement continuously_sync_wallets for ChainSource::Electrum

Author: tnull

src/chain/mod.rs

@@ -304,18 +304,18 @@ impl ChainSource {
 		channel_manager: Arc<ChannelManager>, chain_monitor: Arc<ChainMonitor>,
 		output_sweeper: Arc<Sweeper>,
 	) {
-		match self {
-			Self::Esplora { sync_config, logger, .. } => {
+		macro_rules! start_tx_based_sync_loop {
+			($sync_config: expr, $logger: expr) => {{
 				// Setup syncing intervals
-				let onchain_wallet_sync_interval_secs = sync_config
+				let onchain_wallet_sync_interval_secs = $sync_config
 					.onchain_wallet_sync_interval_secs
 					.max(WALLET_SYNC_INTERVAL_MINIMUM_SECS);
 				let mut onchain_wallet_sync_interval =
 					tokio::time::interval(Duration::from_secs(onchain_wallet_sync_interval_secs));
 				onchain_wallet_sync_interval
 					.set_missed_tick_behavior(tokio::time::MissedTickBehavior::Skip);
 
-				let fee_rate_cache_update_interval_secs = sync_config
+				let fee_rate_cache_update_interval_secs = $sync_config
 					.fee_rate_cache_update_interval_secs
 					.max(WALLET_SYNC_INTERVAL_MINIMUM_SECS);
 				let mut fee_rate_update_interval =
@@ -325,7 +325,7 @@ impl ChainSource {
 				fee_rate_update_interval
 					.set_missed_tick_behavior(tokio::time::MissedTickBehavior::Skip);
 
-				let lightning_wallet_sync_interval_secs = sync_config
+				let lightning_wallet_sync_interval_secs = $sync_config
 					.lightning_wallet_sync_interval_secs
 					.max(WALLET_SYNC_INTERVAL_MINIMUM_SECS);
 				let mut lightning_wallet_sync_interval =
@@ -338,9 +338,9 @@ impl ChainSource {
 					tokio::select! {
 						_ = stop_sync_receiver.changed() => {
 							log_trace!(
-								logger,
+								$logger,
 								"Stopping background syncing on-chain wallet.",
-							);
+								);
 							return;
 						}
 						_ = onchain_wallet_sync_interval.tick() => {
@@ -354,12 +354,20 @@ impl ChainSource {
 								Arc::clone(&channel_manager),
 								Arc::clone(&chain_monitor),
 								Arc::clone(&output_sweeper),
-							).await;
+								).await;
 						}
 					}
 				}
+			}};
+		}
+
+		match self {
+			Self::Esplora { sync_config, logger, .. } => {
+				start_tx_based_sync_loop!(sync_config, logger)
+			},
+			Self::Electrum { sync_config, logger, .. } => {
+				start_tx_based_sync_loop!(sync_config, logger)
 			},
-			Self::Electrum { .. } => todo!(),
 			Self::BitcoindRpc {
 				bitcoind_rpc_client,
 				header_cache,