f make Matt's life easier with respect to lightningdevkit#2595

Author: domZippilli

lightning/src/util/persist.rs

@@ -216,7 +216,7 @@ impl<ChannelSigner: WriteableEcdsaChannelSigner, K: KVStore> Persist<ChannelSign
 /// Read previously persisted [`ChannelMonitor`]s from the store.
 pub fn read_channel_monitors<K: Deref, ES: Deref, SP: Deref>(
 	kv_store: K, entropy_source: ES, signer_provider: SP,
-) -> io::Result<Vec<(BlockHash, ChannelMonitor<<SP::Target as SignerProvider>::Signer>)>>
+) -> Result<Vec<(BlockHash, ChannelMonitor<<SP::Target as SignerProvider>::Signer>)>, io::Error>
 where
 	K::Target: KVStore,
 	ES::Target: EntropySource + Sized,
@@ -403,7 +403,7 @@ where
 	/// documentation for [`MonitorUpdatingPersister`].
 	pub fn read_all_channel_monitors_with_updates<B: Deref, F: Deref + Clone>(
 		&self, broadcaster: B, fee_estimator: F,
-	) -> io::Result<Vec<(BlockHash, ChannelMonitor<<SP::Target as SignerProvider>::Signer>)>>
+	) -> Result<Vec<(BlockHash, ChannelMonitor<<SP::Target as SignerProvider>::Signer>)>, io::Error>
 	where
 		ES::Target: EntropySource + Sized,
 		SP::Target: SignerProvider + Sized,
@@ -435,7 +435,7 @@ where
 	/// function to accomplish this. Take care to limit the number of parallel readers.
 	pub fn read_channel_monitor_with_updates<B: Deref, F: Deref + Clone>(
 		&self, broadcaster: B, fee_estimator: F, monitor_key: String,
-	) -> io::Result<(BlockHash, ChannelMonitor<<SP::Target as SignerProvider>::Signer>)>
+	) -> Result<(BlockHash, ChannelMonitor<<SP::Target as SignerProvider>::Signer>), io::Error>
 	where
 		ES::Target: EntropySource + Sized,
 		SP::Target: SignerProvider + Sized,
@@ -478,7 +478,7 @@ where
 	/// Read a channel monitor.
 	fn read_monitor(
 		&self, monitor_name: &MonitorName,
-	) -> io::Result<(BlockHash, ChannelMonitor<<SP::Target as SignerProvider>::Signer>)> {
+	) -> Result<(BlockHash, ChannelMonitor<<SP::Target as SignerProvider>::Signer>), io::Error> {
 		let outpoint: OutPoint = monitor_name.try_into()?;
 		let mut monitor_cursor = io::Cursor::new(self.kv_store.read(
 			CHANNEL_MONITOR_PERSISTENCE_NAMESPACE,
@@ -525,7 +525,7 @@ where
 	/// Read a channel monitor update.
 	fn read_monitor_update(
 		&self, monitor_name: &MonitorName, update_name: &UpdateName,
-	) -> io::Result<ChannelMonitorUpdate> {
+	) -> Result<ChannelMonitorUpdate, io::Error> {
 		let update_bytes = self.kv_store.read(
 			CHANNEL_MONITOR_UPDATE_PERSISTENCE_NAMESPACE,
 			monitor_name.as_str(),
@@ -550,7 +550,7 @@ where
 	/// updates. The updates that have an `update_id` less than or equal to than the stored monitor
 	/// are deleted. The deletion can either be lazy or non-lazy based on the `lazy` flag; this will
 	/// be passed to [`KVStore::remove`].
-	pub fn cleanup_stale_updates(&self, lazy: bool) -> io::Result<()> {
+	pub fn cleanup_stale_updates(&self, lazy: bool) -> Result<(), io::Error> {
 		let monitor_keys = self.kv_store.list(
 			CHANNEL_MONITOR_PERSISTENCE_NAMESPACE,
 			CHANNEL_MONITOR_PERSISTENCE_SUB_NAMESPACE,