WIP

Author: martinsaposnic

lightning-background-processor/src/lib.rs

@@ -230,7 +230,8 @@ impl<
 		G,
 		&'a (dyn UtxoLookup + Send + Sync),
 		L,
-	> where
+	>
+where
 	L::Target: Logger,
 {
 	/// Initializes a new [`GossipSync::Rapid`] variant.
@@ -247,7 +248,8 @@ impl<'a, L: Deref>
 		&'a NetworkGraph<L>,
 		&'a (dyn UtxoLookup + Send + Sync),
 		L,
-	> where
+	>
+where
 	L::Target: Logger,
 {
 	/// Initializes a new [`GossipSync::None`] variant.
@@ -1097,7 +1099,7 @@ impl Drop for BackgroundProcessor {
 	}
 }
 
-#[cfg(all(feature = "std", feature = "time", test))]
+#[cfg(all(feature = "std", test))]
 mod tests {
 	use super::{BackgroundProcessor, GossipSync, FRESHNESS_TIMER};
 	use bitcoin::constants::{genesis_block, ChainHash};
@@ -1142,6 +1144,7 @@ mod tests {
 	use lightning::util::sweep::{OutputSpendStatus, OutputSweeper, PRUNE_DELAY_BLOCKS};
 	use lightning::util::test_utils;
 	use lightning::{get_event, get_event_msg};
+	use lightning_liquidity::lsps5::service::TimeProvider;
 	use lightning_liquidity::LiquidityManager;
 	use lightning_persister::fs_store::FilesystemStore;
 	use lightning_rapid_gossip_sync::RapidGossipSync;
@@ -1578,6 +1581,16 @@ mod tests {
 		path.to_str().unwrap().to_string()
 	}
 
+	pub struct DefaultTimeProvider;
+
+	#[cfg(feature = "std")]
+	impl TimeProvider for DefaultTimeProvider {
+		fn duration_since_epoch(&self) -> Duration {
+			use std::time::{SystemTime, UNIX_EPOCH};
+			SystemTime::now().duration_since(UNIX_EPOCH).expect("system time before Unix epoch")
+		}
+	}
+
 	fn create_nodes(num_nodes: usize, persist_dir: &str) -> (String, Vec<Node>) {
 		let persist_temp_path = env::temp_dir().join(persist_dir);
 		let persist_dir = persist_temp_path.to_string_lossy().to_string();
@@ -1676,13 +1689,15 @@ mod tests {
 				logger.clone(),
 				keys_manager.clone(),
 			));
-			let liquidity_manager = Arc::new(LiquidityManager::new(
+			let time_provider = Arc::new(DefaultTimeProvider);
+			let liquidity_manager = Arc::new(LiquidityManager::new_with_custom_time_provider(
 				Arc::clone(&keys_manager),
 				Arc::clone(&manager),
 				None,
 				None,
 				None,
 				None,
+				time_provider,
 			));
 			let node = Node {
 				node: manager,

lightning-liquidity/src/lsps5/event.rs

@@ -24,8 +24,8 @@ use super::msgs::WebhookNotification;
 pub enum LSPS5ServiceEvent {
 	/// A webhook was registered by a client
 	///
-	/// This event occurs when a client successfully registers a webhook via `lsps5.set_webhook`.
-	/// You should store this information to be able to contact the client when they are offline.
+	/// This event occurs when a client successfully registers or updates a webhook via [`lsps5.set_webhook`].
+	/// [`lsps5.set_webhook`]: super::msgs::LSPS5Request::SetWebhook
 	WebhookRegistered {
 		/// Client node ID that registered the webhook.
 		counterparty_node_id: PublicKey,
@@ -57,7 +57,9 @@ pub enum LSPS5ServiceEvent {
 
 	/// Webhooks were listed for a client.
 	///
-	/// This event occurs when a client requests their registered webhooks via `lsps5.list_webhooks`.
+	/// This event occurs when a client requests their registered webhooks via [`lsps5.list_webhooks`].
+	///
+	/// [`lsps5.list_webhooks`]: super::msgs::LSPS5Request::ListWebhooks
 	WebhooksListed {
 		/// Client node ID that requested their webhooks.
 		counterparty_node_id: PublicKey,