Solana and other crate updates

Author: merolish

Cargo.lock

@@ -10,7 +10,7 @@ path = "src/bin/agent.rs"
 [dependencies]
 anyhow = "1.0.81"
 ed25519-dalek = "1.0.1"
-serde = { version = "1.0.197", features = ["derive"] }
+serde = { version = "1.0.197", features = ["derive", "rc"] }
 async-trait = "0.1.79"
 warp = { version = "0.3.6", features = ["websocket"] }
 tokio = { version = "1.37.0", features = ["full"] }
@@ -23,25 +23,21 @@ jrpc = "0.4.1"
 serde_json = "1.0.115"
 chrono = "0.4.37"
 chrono-tz = "0.8.6"
-parking_lot = "0.12.1"
 pyth-sdk = "0.8.0"
 pyth-sdk-solana = "0.10.4"
-solana-account-decoder = "1.18.8"
-solana-client = "1.18.8"
-solana-pubkey = "2.3.0"
-solana-sdk = "1.18.8"
-solana-transaction-status = "1.18.26"
+solana-account-decoder = "2.2.1"
+solana-client = "2.2.1"
+solana-pubkey = "2.2.1"
+solana-sdk = "2.2.1"
+solana-transaction-status = "2.2.1"
 bincode = { version = "2.0.1", features = ["serde"] }
-rand = "0.8.5"
 config = "0.14.0"
 thiserror = "1.0.58"
 clap = { version = "4.5.4", features = ["derive"] }
 humantime-serde = "1.1.1"
 serde-this-or-that = "0.4.2"
-humantime = "2.1.0"
 prometheus-client = "0.22.2"
 lazy_static = "1.4.0"
-toml_edit = "0.22.9"
 winnow = "0.6.5"
 proptest = "1.4.0"
 reqwest = { version = "0.12.0", features = ["json"] }
@@ -59,14 +55,6 @@ tokio-tungstenite = { version = "0.26.2", features = ["native-tls", "url"] }
 http = "1.3.1"
 url = { version = "2.5.4", features = ["serde"] }
 pyth-lazer-publisher-sdk = "0.1.1"
-tokio-util = { version = "0.7.14", features = ["full"] }
-
-[dev-dependencies]
-soketto = "0.8.0"
-portpicker = "0.1.1"
-rand = "0.8.5"
-tokio-retry = "0.3.0"
-iobuffer = "0.2.0"
 
 [profile.release]
 panic = 'abort'

Cargo.toml

@@ -109,7 +109,7 @@ impl MarketSchedule {
     }
 }
 
-fn market_schedule_parser<'s>(input: &mut &'s str) -> ModalResult<MarketSchedule> {
+fn market_schedule_parser(input: &mut &str) -> ModalResult<MarketSchedule> {
     seq!(
         MarketSchedule {
             timezone: take_till(0.., ';').verify_map(|s| Tz::from_str(s).ok()),
@@ -157,13 +157,13 @@ pub struct HolidayDaySchedule {
     pub kind:  ScheduleDayKind,
 }
 
-fn two_digit_parser<'s>(input: &mut &'s str) -> ModalResult<u32> {
+fn two_digit_parser(input: &mut &str) -> ModalResult<u32> {
     take(2usize)
         .verify_map(|s| u32::from_str(s).ok())
         .parse_next(input)
 }
 
-fn holiday_day_schedule_parser<'s>(input: &mut &'s str) -> ModalResult<HolidayDaySchedule> {
+fn holiday_day_schedule_parser(input: &mut &str) -> ModalResult<HolidayDaySchedule> {
     // day and month are not validated to be correct dates
     // if they are invalid, it will be ignored since there
     // are no real dates that match the invalid input

src/agent/market_schedule.rs

@@ -63,6 +63,7 @@ pub async fn spawn(addr: impl Into<SocketAddr> + 'static) {
         .and(warp::path::end())
         .and_then(move || async move {
             let mut buf = String::new();
+            #[allow(clippy::needless_borrow)]
             let response = encode(&mut buf, &&PROMETHEUS_REGISTRY.lock().await)
                 .map_err(|e| -> Box<dyn std::error::Error> { e.into() })
                 .map(|_| Box::new(reply::with_status(buf, StatusCode::OK)))

src/agent/metrics.rs

@@ -210,6 +210,7 @@ where
     handles
 }
 
+#[allow(clippy::module_inception)]
 mod exporter {
     use {
         super::NetworkState,

src/agent/services/exporter.rs

@@ -152,14 +152,14 @@ async fn fetch_symbols(history_url: &Url) -> Result<Vec<SymbolResponse>> {
 
 #[instrument(skip(config, state))]
 pub fn lazer_exporter(config: Config, state: Arc<state::State>) -> Vec<JoinHandle<()>> {
-    let mut handles = Vec::new();
-    handles.push(tokio::spawn(lazer_exporter::lazer_exporter(
+    let handles = vec![tokio::spawn(lazer_exporter::lazer_exporter(
         config.clone(),
         state,
-    )));
+    ))];
     handles
 }
 
+#[allow(clippy::module_inception)]
 mod lazer_exporter {
     use {
         crate::agent::{

src/agent/services/lazer_exporter.rs

@@ -132,6 +132,7 @@ where
             },
             filters:        None,
             with_context:   Some(true),
+            sort_results:   None,
         };
         client.program_subscribe(&program_key, Some(config)).await
     }?;

src/agent/services/oracle.rs

@@ -446,6 +446,7 @@ async fn estimate_compute_unit_price_micro_lamports(
 /// - Degrade gracefully if the blockchain RPC node exhibits poor performance. If the RPC node takes a long
 ///   time to respond, no internal queues grow unboundedly. At any single point in time there are at most
 ///   (n / batch_size) requests in flight.
+#[allow(clippy::too_many_arguments)]
 #[instrument(
     skip(state, rpc_multi_client, network_state_rx, publish_keypair, staleness_threshold, permissioned_updates),
     fields(
@@ -527,6 +528,7 @@ where
     Ok(())
 }
 
+#[allow(clippy::too_many_arguments)]
 #[instrument(
     skip(state, rpc_multi_client, network_state, publish_keypair, batch, staleness_threshold),
     fields(