Fix typos (#448)

Author: m30m

auction-server/src/api/ws.rs

@@ -124,8 +124,8 @@ impl WsState {
     pub async fn get_new_subscriber_id(&self, ip: Option<IpAddr>) -> Option<SubscriberId> {
         let id = self.subscriber_counter.fetch_add(1, Ordering::SeqCst);
         if let Some(ip) = ip {
-            let mut write_gaurd = self.subscriber_per_ip.write().await;
-            let ids = write_gaurd.entry(ip).or_insert_with(HashSet::new);
+            let mut write_guard = self.subscriber_per_ip.write().await;
+            let ids = write_guard.entry(ip).or_insert_with(HashSet::new);
             if ids.len() >= MAXIMUM_SUBSCRIBERS_PER_IP {
                 return None;
             }
@@ -136,11 +136,11 @@ impl WsState {
 
     pub async fn remove_subscriber(&self, id: SubscriberId, ip: Option<IpAddr>) {
         if let Some(ip) = ip {
-            let mut write_gaurd = self.subscriber_per_ip.write().await;
-            if let Some(ids) = write_gaurd.get_mut(&ip) {
+            let mut write_guard = self.subscriber_per_ip.write().await;
+            if let Some(ids) = write_guard.get_mut(&ip) {
                 ids.remove(&id);
                 if ids.is_empty() {
-                    write_gaurd.remove(&ip);
+                    write_guard.remove(&ip);
                 }
             }
         }

auction-server/src/auction/repository/add_recent_priotization_fee.rs

@@ -11,7 +11,7 @@ use {
 };
 
 impl Repository<Svm> {
-    pub async fn add_recent_priotization_fee(&self, fee: u64) {
+    pub async fn add_recent_prioritization_fee(&self, fee: u64) {
         let mut write_guard = self
             .in_memory_store
             .chain_store

auction-server/src/auction/repository/update_in_memory_auction.rs

@@ -10,8 +10,8 @@ impl<T: ChainTrait> Repository<T> {
     #[tracing::instrument(skip_all, fields(auction_id))]
     pub async fn update_in_memory_auction(&self, auction: entities::Auction<T>) {
         tracing::Span::current().record("auction_id", auction.id.to_string());
-        let mut write_gaurd = self.in_memory_store.auctions.write().await;
-        match write_gaurd.get_mut(&auction.id) {
+        let mut write_guard = self.in_memory_store.auctions.write().await;
+        match write_guard.get_mut(&auction.id) {
             Some(a) => {
                 *a = auction;
             }

auction-server/src/auction/service/conclude_auction.rs

@@ -105,7 +105,7 @@ where
             })
             .await?;
         } else if Self::is_auction_expired(&auction) {
-            // This only happens if auction submission to chain failes
+            // This only happens if auction submission to chain fails
             // This is a very rare case and should not happen
             tracing::warn!("Auction has no transaction hash and is expired");
             let lost_status = T::BidStatusType::new_lost();

auction-server/src/auction/service/handle_auction.rs

@@ -31,7 +31,7 @@ where
     async fn submit_auction<'a>(
         &self,
         auction: entities::Auction<T>,
-        _auction_mutex_gaurd: MutexGuard<'a, ()>,
+        _auction_mutex_guard: MutexGuard<'a, ()>,
     ) -> anyhow::Result<()> {
         tracing::Span::current().record("auction_id", auction.id.to_string());
         tracing::Span::current().record(

auction-server/src/auction/service/update_recent_prioritization_fee.rs

@@ -10,7 +10,7 @@ use {
 pub const RECENT_FEES_SLOT_WINDOW: usize = 12;
 
 impl Service<Svm> {
-    /// Returns an estimate of recent priotization fees.
+    /// Returns an estimate of recent prioritization fees.
     /// For each of the last 150 slots, client returns the `config.prioritization_fee_percentile`th percentile
     /// of prioritization fees for transactions that landed in that slot.
     /// The median of such values for the `RECENT_FEES_SLOT_WINDOW` most recent slots is returned.
@@ -53,7 +53,7 @@ impl Service<Svm> {
                 RestError::TemporarilyUnavailable
             })?;
 
-        self.repo.add_recent_priotization_fee(fee).await;
+        self.repo.add_recent_prioritization_fee(fee).await;
         Ok(fee)
     }
 }

auction-server/src/auction/service/verification.rs

@@ -2246,7 +2246,7 @@ mod tests {
         let minimum_budget = 10;
         service
             .repo
-            .add_recent_priotization_fee(minimum_budget)
+            .add_recent_prioritization_fee(minimum_budget)
             .await;
         let result =
             get_verify_bid_result(service, searcher, vec![], opportunities[0].clone()).await;
@@ -2265,7 +2265,7 @@ mod tests {
             compute_budget::ComputeBudgetInstruction::set_compute_unit_price(minimum_budget - 1);
         service
             .repo
-            .add_recent_priotization_fee(minimum_budget)
+            .add_recent_prioritization_fee(minimum_budget)
             .await;
         let result = get_verify_bid_result(
             service,

auction-server/src/config/server.rs

@@ -6,7 +6,7 @@ use {
 const DEFAULT_LISTEN_ADDR: &str = "127.0.0.1:9000";
 const DEFAULT_METRICS_ADDR: &str = "127.0.0.1:9001";
 const DEFAULT_DATABASE_MAX_CONNECTIONS: &str = "10";
-const DEAFULT_REQUESTER_IP_HEADER_NAME: &str = "X-Forwarded-For";
+const DEFAULT_REQUESTER_IP_HEADER_NAME: &str = "X-Forwarded-For";
 
 #[derive(Args, Clone, Debug)]
 #[command(next_help_heading = "Server Options")]
@@ -33,7 +33,7 @@ pub struct Options {
     pub metrics_addr:             SocketAddr,
     /// The header name to use for the requester IP address.
     #[arg(long = "requester-ip-header-name")]
-    #[arg(default_value = DEAFULT_REQUESTER_IP_HEADER_NAME)]
+    #[arg(default_value = DEFAULT_REQUESTER_IP_HEADER_NAME)]
     #[arg(env = "REQUESTER_IP_HEADER_NAME")]
     pub requester_ip_header_name: String,
 }

auction-server/src/opportunity/service/handle_opportunity_bid.rs

@@ -45,7 +45,7 @@ pub struct HandleOpportunityBidInput {
 }
 
 fn parse_revert_error(revert: &Bytes) -> Option<String> {
-    let apdapter_decoded =
+    let adapter_decoded =
         OpportunityAdapterErrors::decode_with_selector(revert).map(|decoded_error| {
             format!(
                 "Opportunity Adapter Contract Revert Error: {:#?}",
@@ -54,7 +54,7 @@ fn parse_revert_error(revert: &Bytes) -> Option<String> {
         });
     let erc20_decoded = erc20::ERC20Errors::decode_with_selector(revert)
         .map(|decoded_error| format!("ERC20 Contract Revert Error: {:#?}", decoded_error));
-    apdapter_decoded.or(erc20_decoded)
+    adapter_decoded.or(erc20_decoded)
 }
 
 impl Service<ChainTypeEvm> {