feat(hermes): add uniqueness check for benchmark price

hermes/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name        = "hermes"
-version     = "0.4.2"
+version     = "0.4.3"
 description = "Hermes is an agent that provides Verified Prices from the Pythnet Pyth Oracle."
 edition     = "2021"
 

hermes/src/aggregate/wormhole_merkle.rs

@@ -114,7 +114,7 @@ pub fn construct_message_states_proofs(
 }
 
 pub fn construct_update_data(mut messages: Vec<RawMessageWithMerkleProof>) -> Result<Vec<Vec<u8>>> {
-    tracing::info!("Constructing update data for {} messages", messages.len());
+    tracing::debug!("Constructing update data for {} messages", messages.len());
 
     messages.sort_by_key(|m| m.slot);
 
@@ -140,7 +140,7 @@ pub fn construct_update_data(mut messages: Vec<RawMessageWithMerkleProof>) -> Re
             }
         }
 
-        tracing::info!(
+        tracing::debug!(
             slot = slot,
             "Combining {} messages in a single updateData",
             updates.len()

hermes/src/api/rest.rs

@@ -33,6 +33,7 @@ pub use {
 };
 
 pub enum RestError {
+    BenchmarkPriceNotUnique,
     UpdateDataNotFound,
     CcipUpdateDataNotFound,
     InvalidCCIPInput,
@@ -42,6 +43,9 @@ pub enum RestError {
 impl IntoResponse for RestError {
     fn into_response(self) -> Response {
         match self {
+            RestError::BenchmarkPriceNotUnique => {
+                (StatusCode::NOT_FOUND, "Benchmark price is not unique").into_response()
+            }
             RestError::UpdateDataNotFound => {
                 (StatusCode::NOT_FOUND, "Update data not found").into_response()
             }

hermes/src/api/rest/get_price_feed.rs

@@ -89,6 +89,15 @@ pub async fn get_price_feed(
         .next()
         .ok_or(RestError::UpdateDataNotFound)?;
 
+    // Currently Benchmarks API doesn't support returning the previous publish time. So we
+    // are assuming that it is doing the same filter as us and returns not found if the
+    // price update is not unique.
+    if let Some(prev_publish_time) = price_feed.prev_publish_time {
+        if prev_publish_time == price_feed.price_feed.get_price_unchecked().publish_time {
+            return Err(RestError::BenchmarkPriceNotUnique);
+        }
+    }
+
     // Note: This is a hack to get around the fact that Benchmark doesn't give per price feed
     // update data. Since we request only for a single feed then the whole prices update data
     // is this price feed update data.

hermes/src/api/rest/get_vaa.rs

@@ -97,13 +97,22 @@ pub async fn get_vaa(
         .map(|bytes| base64_standard_engine.encode(bytes))
         .ok_or(RestError::UpdateDataNotFound)?;
 
-    let publish_time = price_feeds_with_update_data
+    let price_feed = price_feeds_with_update_data
         .price_feeds
-        .get(0)
-        .ok_or(RestError::UpdateDataNotFound)?
-        .price_feed
-        .get_price_unchecked()
-        .publish_time;
+        .into_iter()
+        .next()
+        .ok_or(RestError::UpdateDataNotFound)?;
+
+    let publish_time = price_feed.price_feed.get_price_unchecked().publish_time;
+
+    // Currently Benchmarks API doesn't support returning the previous publish time. So we
+    // are assuming that it is doing the same filter as us and returns not found if the
+    // price update is not unique.
+    if let Some(prev_publish_time) = price_feed.prev_publish_time {
+        if prev_publish_time == price_feed.price_feed.get_price_unchecked().publish_time {
+            return Err(RestError::BenchmarkPriceNotUnique);
+        }
+    }
 
     Ok(Json(GetVaaResponse { vaa, publish_time }))
 }