Skip to content

Commit e51bf8c

Browse files
refactor changes
1 parent 29469ac commit e51bf8c

File tree

1 file changed

+31
-44
lines changed

1 file changed

+31
-44
lines changed

src/chain/mod.rs

Lines changed: 31 additions & 44 deletions
Original file line numberDiff line numberDiff line change
@@ -207,66 +207,55 @@ impl ChainSource {
207207
) {
208208
match self {
209209
Self::Esplora { sync_config, logger, .. } => {
210-
// Setup background syncing intervals if enabled
210+
// Setup syncing intervals if enabled
211211
if let Some(background_sync_config) = sync_config.background_sync_config {
212-
let onchain_interval_secs = background_sync_config
212+
let onchain_wallet_sync_interval_secs = background_sync_config
213213
.onchain_wallet_sync_interval_secs
214214
.max(WALLET_SYNC_INTERVAL_MINIMUM_SECS);
215-
let mut onchain_interval =
216-
tokio::time::interval(Duration::from_secs(onchain_interval_secs));
217-
onchain_interval
218-
.set_missed_tick_behavior(tokio::time::MissedTickBehavior::Skip);
219-
log_info!(
220-
logger,
221-
"Onchain wallet background syncing enabled with interval of {} seconds",
222-
onchain_interval_secs
215+
let mut onchain_wallet_sync_interval = tokio::time::interval(
216+
Duration::from_secs(onchain_wallet_sync_interval_secs),
223217
);
224-
225-
let lightning_interval_secs = background_sync_config
226-
.lightning_wallet_sync_interval_secs
227-
.max(WALLET_SYNC_INTERVAL_MINIMUM_SECS);
228-
let mut lightning_interval =
229-
tokio::time::interval(Duration::from_secs(lightning_interval_secs));
230-
lightning_interval
218+
onchain_wallet_sync_interval
231219
.set_missed_tick_behavior(tokio::time::MissedTickBehavior::Skip);
232-
log_info!(
233-
logger,
234-
"Lightning wallet background syncing enabled with interval of {} seconds",
235-
lightning_interval_secs
236-
);
237220

238-
let fee_rate_interval_secs = background_sync_config
221+
let fee_rate_cache_update_interval_secs = background_sync_config
239222
.fee_rate_cache_update_interval_secs
240223
.max(WALLET_SYNC_INTERVAL_MINIMUM_SECS);
241-
let mut fee_rate_interval =
242-
tokio::time::interval(Duration::from_secs(fee_rate_interval_secs));
224+
let mut fee_rate_update_interval = tokio::time::interval(Duration::from_secs(
225+
fee_rate_cache_update_interval_secs,
226+
));
243227
// When starting up, we just blocked on updating, so skip the first tick.
244-
fee_rate_interval.reset();
245-
fee_rate_interval
228+
fee_rate_update_interval.reset();
229+
fee_rate_update_interval
246230
.set_missed_tick_behavior(tokio::time::MissedTickBehavior::Skip);
247-
log_info!(
248-
logger,
249-
"Fee rate background syncing enabled with interval of {} seconds",
250-
fee_rate_interval_secs
231+
232+
let lightning_wallet_sync_interval_secs = background_sync_config
233+
.lightning_wallet_sync_interval_secs
234+
.max(WALLET_SYNC_INTERVAL_MINIMUM_SECS);
235+
let mut lightning_wallet_sync_interval = tokio::time::interval(
236+
Duration::from_secs(lightning_wallet_sync_interval_secs),
251237
);
238+
lightning_wallet_sync_interval
239+
.set_missed_tick_behavior(tokio::time::MissedTickBehavior::Skip);
252240

241+
// Start the syncing loop.
253242
loop {
254243
tokio::select! {
255244
_ = stop_sync_receiver.changed() => {
256-
log_trace!(logger, "Stopping Esplora background syncing.");
245+
log_trace!(
246+
logger,
247+
"Stopping background syncing on-chain wallet.",
248+
);
257249
return;
258250
}
259-
260-
_ = onchain_interval.tick() => {
261-
let _ = self.sync_onchain_wallet().await;
251+
_ = onchain_wallet_sync_interval.tick() => {
252+
let * = self.sync_onchain_wallet().await;
262253
}
263-
264-
_ = fee_rate_interval.tick() => {
265-
let _ = self.update_fee_rate_estimates().await;
254+
_ = fee_rate_update_interval.tick() => {
255+
let * = self.update_fee_rate_estimates().await;
266256
}
267-
268-
_ = lightning_interval.tick() => {
269-
let _ = self.sync_lightning_wallet(
257+
_ = lightning_wallet_sync_interval.tick() => {
258+
let * = self.sync_lightning_wallet(
270259
Arc::clone(&channel_manager),
271260
Arc::clone(&chain_monitor),
272261
Arc::clone(&output_sweeper),
@@ -277,10 +266,8 @@ impl ChainSource {
277266
} else {
278267
// Background syncing is disabled
279268
log_info!(
280-
logger,
281-
"Background syncing disabled. Manual syncing required for onchain wallet, lightning wallet, and fee rate updates.",
269+
logger, "Background syncing disabled. Manual syncing required for onchain wallet, lightning wallet, and fee rate updates.",
282270
);
283-
284271
return;
285272
}
286273
},

0 commit comments

Comments
 (0)