fix(CI): fix CI build errors

Author: Anyitechs

lightning-background-processor/src/lib.rs

@@ -763,7 +763,7 @@ pub async fn process_events_async<
 		G,
 		L,
 		P,
-		EH,
+		EventHandler,
 		PS,
 		M,
 		CM,
@@ -818,31 +818,41 @@ where
 			event_handler(event).await
 		})
 	};
+	// We should extract these out of config because the macro expects individual arguments
+	let persister = config.persister;
+	let chain_monitor = config.chain_monitor;
+	let channel_manager = config.channel_manager;
+	let onion_messenger = config.onion_messenger;
+	let peer_manager = config.peer_manager;
+	let gossip_sync = config.gossip_sync;
+	let logger = config.logger;
+	let scorer = config.scorer;
+
 	define_run_body!(
-		config.persister,
-		config.chain_monitor,
-		config.chain_monitor.process_pending_events_async(async_event_handler).await,
-		config.channel_manager,
-		config.channel_manager.get_cm().process_pending_events_async(async_event_handler).await,
-		config.onion_messenger,
-		if let Some(om) = &config.onion_messenger {
+		persister,
+		chain_monitor,
+		chain_monitor.process_pending_events_async(async_event_handler).await,
+		channel_manager,
+		channel_manager.get_cm().process_pending_events_async(async_event_handler).await,
+		onion_messenger,
+		if let Some(om) = &onion_messenger {
 			om.get_om().process_pending_events_async(async_event_handler).await
 		},
-		config.peer_manager,
-		config.gossip_sync,
-		config.logger,
-		config.scorer,
+		peer_manager,
+		gossip_sync,
+		logger,
+		scorer,
 		should_break,
 		{
-			let om_fut = if let Some(om) = config.onion_messenger.as_ref() {
+			let om_fut = if let Some(om) = onion_messenger.as_ref() {
 				let fut = om.get_om().get_update_future();
 				OptionalSelector { optional_future: Some(fut) }
 			} else {
 				OptionalSelector { optional_future: None }
 			};
 			let fut = Selector {
-				a: config.channel_manager.get_cm().get_event_or_persistence_needed_future(),
-				b: config.chain_monitor.get_update_future(),
+				a: channel_manager.get_cm().get_event_or_persistence_needed_future(),
+				b: chain_monitor.get_update_future(),
 				c: om_fut,
 				d: sleeper(if mobile_interruptable_platform {
 					Duration::from_millis(100)
@@ -1209,7 +1219,7 @@ impl BackgroundProcessor {
 /// process_events_async(config, sleeper, mobile_interruptable_platform, fetch_time).await?;"
 )]
 /// ```
-#[cfg(feature = "std")]
+#[cfg(any(feature = "std", feature = "futures"))]
 pub struct BackgroundProcessorConfig<
 	'a,
 	UL: 'static + Deref + Send + Sync,
@@ -1346,7 +1356,7 @@ where
 	PM::Target: APeerManager + Send + Sync,
 {
 	/// Creates a new builder instance.
-	pub(crate) fn new(
+	pub fn new(
 		persister: PS, event_handler: EH, chain_monitor: M, channel_manager: CM,
 		gossip_sync: GossipSync<PGS, RGS, G, UL, L>, peer_manager: PM, logger: L,
 	) -> Self {
@@ -1405,7 +1415,9 @@ impl Drop for BackgroundProcessor {
 
 #[cfg(all(feature = "std", test))]
 mod tests {
-	use super::{BackgroundProcessor, GossipSync, FRESHNESS_TIMER};
+	use super::{
+		BackgroundProcessor, BackgroundProcessorConfigBuilder, GossipSync, FRESHNESS_TIMER,
+	};
 	use bitcoin::constants::{genesis_block, ChainHash};
 	use bitcoin::hashes::Hash;
 	use bitcoin::locktime::absolute::LockTime;
@@ -3086,11 +3098,11 @@ mod tests {
 	}
 
 	#[test]
-	fn test_background_processor_builder() {
+	fn test_background_processor_config_builder() {
 		// Test that when a new channel is created, the ChannelManager needs to be re-persisted with
 		// updates. Also test that when new updates are available, the manager signals that it needs
 		// re-persistence and is successfully re-persisted.
-		let (persist_dir, nodes) = create_nodes(2, "test_background_processor_builder");
+		let (persist_dir, nodes) = create_nodes(2, "test_background_processor_config_builder");
 
 		// Go through the channel creation process so that each node has something to persist. Since
 		// open_channel consumes events, it must complete before starting BackgroundProcessor to
@@ -3164,7 +3176,7 @@ mod tests {
 			.unwrap();
 
 		// Check that the force-close updates are persisted
-		check_persisted_data!(nodes[0].node, manager_path.clone());
+		check_persisted_data!(nodes[0].node, filepath.clone());
 		loop {
 			if !nodes[0].node.get_event_or_persist_condvar_value() {
 				break;