f Fix for node announcement broadcast after rebase

Author: tnull

src/io/utils.rs

@@ -204,12 +204,9 @@ where
 	Ok(())
 }
 
-pub(crate) fn read_latest_node_ann_bcast_timestamp<K: Deref>(
-	kv_store: K,
-) -> Result<u64, std::io::Error>
-where
-	K::Target: KVStore,
-{
+pub(crate) fn read_latest_node_ann_bcast_timestamp<K: KVStore + Sync + Send>(
+	kv_store: Arc<K>,
+) -> Result<u64, std::io::Error> {
 	let mut reader = kv_store
 		.read(LATEST_NODE_ANN_BCAST_TIMSTAMP_NAMESPACE, LATEST_NODE_ANN_BCAST_TIMSTAMP_KEY)?;
 	u64::read(&mut reader).map_err(|_| {
@@ -220,43 +217,24 @@ where
 	})
 }
 
-pub(crate) fn write_latest_node_ann_bcast_timestamp<K: Deref, L: Deref>(
-	updated_timestamp: u64, kv_store: K, logger: L,
+pub(crate) fn write_latest_node_ann_bcast_timestamp<K: KVStore + Sync + Send, L: Deref>(
+	updated_timestamp: u64, kv_store: Arc<K>, logger: L,
 ) -> Result<(), Error>
 where
-	K::Target: KVStore,
 	L::Target: Logger,
 {
-	let mut writer = kv_store
-		.write(LATEST_NODE_ANN_BCAST_TIMSTAMP_NAMESPACE, LATEST_NODE_ANN_BCAST_TIMSTAMP_KEY)
+	let data = updated_timestamp.encode();
+	kv_store
+		.write(LATEST_NODE_ANN_BCAST_TIMSTAMP_NAMESPACE, LATEST_NODE_ANN_BCAST_TIMSTAMP_KEY, &data)
 		.map_err(|e| {
 			log_error!(
 				logger,
-				"Getting writer for key {}/{} failed due to: {}",
+				"Writing data to key {}/{} failed due to: {}",
 				LATEST_NODE_ANN_BCAST_TIMSTAMP_NAMESPACE,
 				LATEST_NODE_ANN_BCAST_TIMSTAMP_KEY,
 				e
 			);
 			Error::PersistenceFailed
 		})?;
-	updated_timestamp.write(&mut writer).map_err(|e| {
-		log_error!(
-			logger,
-			"Writing data to key {}/{} failed due to: {}",
-			LATEST_NODE_ANN_BCAST_TIMSTAMP_NAMESPACE,
-			LATEST_NODE_ANN_BCAST_TIMSTAMP_KEY,
-			e
-		);
-		Error::PersistenceFailed
-	})?;
-	writer.commit().map_err(|e| {
-		log_error!(
-			logger,
-			"Committing data to key {}/{} failed due to: {}",
-			LATEST_NODE_ANN_BCAST_TIMSTAMP_NAMESPACE,
-			LATEST_NODE_ANN_BCAST_TIMSTAMP_KEY,
-			e
-		);
-		Error::PersistenceFailed
-	})
+	Ok(())
 }