diff --git a/rocks-db/src/clients/asset_streaming_client.rs b/rocks-db/src/clients/asset_streaming_client.rs index 64c9208f..b09c9146 100644 --- a/rocks-db/src/clients/asset_streaming_client.rs +++ b/rocks-db/src/clients/asset_streaming_client.rs @@ -201,7 +201,7 @@ async fn get_complete_asset_details( .get(url.clone().value)? .map(Into::into); let cutoff_slot = Storage::column::>(backend.clone(), metrics.clone()) - .get(Parameter::TopSeenSlot)? + .get(Parameter::LastBackfilledSlot)? .flatten() .unwrap_or_default() .wrapping_sub(OFFSET_SLOTS); diff --git a/rocks-db/src/sequence_consistent.rs b/rocks-db/src/sequence_consistent.rs index 706dcf69..16fbe87d 100644 --- a/rocks-db/src/sequence_consistent.rs +++ b/rocks-db/src/sequence_consistent.rs @@ -41,7 +41,7 @@ impl SequenceConsistentManager for Storage { #[async_trait] impl LastProcessedSlotGetter for Storage { async fn get_last_ingested_slot(&self) -> Result, interface::error::StorageError> { - self.get_parameter::(crate::parameters::Parameter::TopSeenSlot) + self.get_parameter::(crate::parameters::Parameter::LastBackfilledSlot) .await .map_err(|e| e.into()) } diff --git a/rocks-db/tests/parameters_tests.rs b/rocks-db/tests/parameters_tests.rs index 5b1d60ff..22e3fecc 100644 --- a/rocks-db/tests/parameters_tests.rs +++ b/rocks-db/tests/parameters_tests.rs @@ -30,18 +30,27 @@ mod tests { assert!(response == None); let last_seen_slot = 242827927u64; - storage.merge_top_parameter::(Parameter::TopSeenSlot, last_seen_slot).await.unwrap(); + storage + .merge_top_parameter::(Parameter::LastBackfilledSlot, last_seen_slot) + .await + .unwrap(); let response = storage.get_last_ingested_slot().await.unwrap(); assert!(response == Some(last_seen_slot)); let some_old_slot = 137_827_927u64; - storage.merge_top_parameter::(Parameter::TopSeenSlot, some_old_slot).await.unwrap(); + storage + .merge_top_parameter::(Parameter::LastBackfilledSlot, some_old_slot) + .await + .unwrap(); let response = storage.get_last_ingested_slot().await.unwrap(); assert!(response == Some(last_seen_slot)); let some_new_slot = 243_827_927u64; - storage.merge_top_parameter::(Parameter::TopSeenSlot, some_new_slot).await.unwrap(); + storage + .merge_top_parameter::(Parameter::LastBackfilledSlot, some_new_slot) + .await + .unwrap(); let response = storage.get_last_ingested_slot().await.unwrap(); assert!(response == Some(some_new_slot)); }