ci3

Author: Riateche

.github/workflows/ci-lazer-solana-contract.yml

@@ -18,9 +18,6 @@ jobs:
     steps:
       - uses: actions/checkout@v4
       - uses: actions-rust-lang/setup-rust-toolchain@v1
-        with:
-          toolchain: 1.82.0
-          components: clippy, rustfmt
       - name: install taplo
         run: cargo install --locked [email protected]
       - uses: actions/setup-node@v4

apps/hermes/server/src/api/rest.rs

@@ -76,7 +76,7 @@ impl IntoResponse for RestError {
 
                 (
                     StatusCode::NOT_FOUND,
-                    format!("Price ids not found: {}", missing_ids),
+                    format!("Price ids not found: {missing_ids}"),
                 )
                     .into_response()
             }

apps/hermes/server/src/api/rest/v2/price_feeds_metadata.rs

@@ -54,7 +54,7 @@ where
         .map_err(|e| {
             tracing::warn!("RPC connection error: {}", e);
             RestError::RpcConnectionError {
-                message: format!("RPC connection error: {}", e),
+                message: format!("RPC connection error: {e}"),
             }
         })?;
 

apps/hermes/server/src/api/rest/v2/sse.rs

@@ -185,9 +185,7 @@ where
             price_feed
                 .metadata
                 .prev_publish_time
-                .map_or(false, |prev_time| {
-                    prev_time != price_feed.price.publish_time
-                })
+                .is_some_and(|prev_time| prev_time != price_feed.price.publish_time)
         });
         // Retain price id in price_ids that are in parsed_price_updates
         price_ids.retain(|price_id| {
@@ -231,5 +229,5 @@ where
 fn error_event<E: std::fmt::Debug>(e: E) -> Event {
     Event::default()
         .event("error")
-        .data(format!("Error receiving update: {:?}", e))
+        .data(format!("Error receiving update: {e:?}"))
 }

apps/hermes/server/src/api/ws.rs

@@ -579,8 +579,7 @@ where
                             serde_json::to_string(&ServerMessage::Response(
                                 ServerResponseMessage::Err {
                                     error: format!(
-                                        "Price feed(s) with id(s) {:?} not found",
-                                        not_found_price_ids
+                                        "Price feed(s) with id(s) {not_found_price_ids:?} not found",
                                     ),
                                 },
                             ))?

apps/hermes/server/src/state/aggregate/metrics.rs

@@ -79,7 +79,7 @@ impl Metrics {
         let order = if self
             .newest_observed_slot
             .get(&event)
-            .map_or(true, |&observed_slot| slot > observed_slot)
+            .is_none_or(|&observed_slot| slot > observed_slot)
         {
             self.newest_observed_slot.insert(event.clone(), slot);
             SlotOrder::New

apps/hermes/server/src/state/benchmarks.rs

@@ -88,7 +88,7 @@ where
             .endpoint
             .as_ref()
             .ok_or_else(|| anyhow::anyhow!("Benchmarks endpoint is not set"))?
-            .join(&format!("/v1/updates/price/{}", publish_time))
+            .join(&format!("/v1/updates/price/{publish_time}"))
             .context("failed to construct price endpoint")?;
 
         let mut request = reqwest::Client::new()

apps/hermes/server/src/state/cache.rs

@@ -183,10 +183,7 @@ where
 
         // Sometimes, some keys are removed from the accumulator. We track which keys are not
         // present in the message states and remove them from the cache.
-        let keys_in_cache = message_cache
-            .iter()
-            .map(|(key, _)| key.clone())
-            .collect::<HashSet<_>>();
+        let keys_in_cache = message_cache.keys().cloned().collect::<HashSet<_>>();
 
         for key in keys_in_cache {
             if !current_keys.contains(&key) {

apps/hermes/server/src/state/price_feeds_metadata.rs

@@ -73,16 +73,16 @@ where
         // Filter by query if provided
         if let Some(query_str) = &query {
             price_feeds_metadata.retain(|feed| {
-                feed.attributes.get("symbol").map_or(false, |symbol| {
-                    symbol.to_lowercase().contains(&query_str.to_lowercase())
-                })
+                feed.attributes
+                    .get("symbol")
+                    .is_some_and(|symbol| symbol.to_lowercase().contains(&query_str.to_lowercase()))
             });
         }
 
         // Filter by asset_type if provided
         if let Some(asset_type) = &asset_type {
             price_feeds_metadata.retain(|feed| {
-                feed.attributes.get("asset_type").map_or(false, |type_str| {
+                feed.attributes.get("asset_type").is_some_and(|type_str| {
                     type_str.to_lowercase().trim().replace(" ", "_")
                         == asset_type.to_string().to_lowercase()
                 })

lazer/contracts/solana/clippy.toml

@@ -0,0 +1,3 @@
+allow-unwrap-in-tests = true
+allow-expect-in-tests = true
+#allow-indexing-slicing-in-tests = true