f Not TIMSTAMP lol

Author: tnull

src/io/mod.rs

@@ -35,8 +35,8 @@ pub(crate) const LATEST_RGS_SYNC_TIMESTAMP_NAMESPACE: &str = "";
 pub(crate) const LATEST_RGS_SYNC_TIMESTAMP_KEY: &str = "latest_rgs_sync_timestamp";
 
 /// The last time we broadcast a node announcement will be persisted under this key.
-pub(crate) const LATEST_NODE_ANN_BCAST_TIMSTAMP_NAMESPACE: &str = "";
-pub(crate) const LATEST_NODE_ANN_BCAST_TIMSTAMP_KEY: &str = "latest_node_ann_bcast_timestamp";
+pub(crate) const LATEST_NODE_ANN_BCAST_TIMESTAMP_NAMESPACE: &str = "";
+pub(crate) const LATEST_NODE_ANN_BCAST_TIMESTAMP_KEY: &str = "latest_node_ann_bcast_timestamp";
 
 /// Provides an interface that allows to store and retrieve persisted values that are associated
 /// with given keys.

src/io/utils.rs

@@ -208,7 +208,7 @@ 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)?;
+		.read(LATEST_NODE_ANN_BCAST_TIMESTAMP_NAMESPACE, LATEST_NODE_ANN_BCAST_TIMESTAMP_KEY)?;
 	u64::read(&mut reader).map_err(|_| {
 		std::io::Error::new(
 			std::io::ErrorKind::InvalidData,
@@ -225,13 +225,17 @@ where
 {
 	let data = updated_timestamp.encode();
 	kv_store
-		.write(LATEST_NODE_ANN_BCAST_TIMSTAMP_NAMESPACE, LATEST_NODE_ANN_BCAST_TIMSTAMP_KEY, &data)
+		.write(
+			LATEST_NODE_ANN_BCAST_TIMESTAMP_NAMESPACE,
+			LATEST_NODE_ANN_BCAST_TIMESTAMP_KEY,
+			&data,
+		)
 		.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,
+				LATEST_NODE_ANN_BCAST_TIMESTAMP_NAMESPACE,
+				LATEST_NODE_ANN_BCAST_TIMESTAMP_KEY,
 				e
 			);
 			Error::PersistenceFailed