fix fmt

Author: nitisht

server/src/banner.rs

@@ -71,7 +71,7 @@ fn status_info(config: &Config, scheme: &str, id: Uid) {
     eprintln!(
         "
     Welcome to Parseable Server! Deployment UID: \"{}\"",
-    id.to_string(),
+        id.to_string(),
     );
 
     eprintln!(

server/src/localcache.rs

@@ -21,11 +21,11 @@ use std::{io, path::PathBuf};
 use fs_extra::file::CopyOptions;
 use futures_util::TryFutureExt;
 use hashlru::Cache;
+use human_size::{Byte, Gigibyte, SpecificSize};
 use itertools::{Either, Itertools};
 use object_store::{local::LocalFileSystem, ObjectStore};
 use once_cell::sync::OnceCell;
 use tokio::{fs, sync::Mutex};
-use human_size::{SpecificSize, Gigibyte, Byte};
 
 use crate::option::CONFIG;
 
@@ -100,7 +100,7 @@ impl LocalCacheManager {
     pub async fn validate(&self, config_capacity: u64) -> Result<(), CacheError> {
         fs::create_dir_all(&self.cache_path).await?;
         let path = cache_meta_path(&self.cache_path)
-        .map_err(|err| CacheError::ObjectStoreError(err.into()))?;
+            .map_err(|err| CacheError::ObjectStoreError(err.into()))?;
         let resp = self
             .filesystem
             .get(&path)
@@ -112,8 +112,14 @@ impl LocalCacheManager {
                 let mut meta: CacheMeta = serde_json::from_slice(&bytes)?;
                 if meta.size_capacity != config_capacity {
                     // log the change in cache size
-                    let configured_size_human: SpecificSize<Gigibyte> = SpecificSize::new(config_capacity as f64, Byte).unwrap().into();
-                    let current_size_human: SpecificSize<Gigibyte> = SpecificSize::new(meta.size_capacity as f64, Byte).unwrap().into();
+                    let configured_size_human: SpecificSize<Gigibyte> =
+                        SpecificSize::new(config_capacity as f64, Byte)
+                            .unwrap()
+                            .into();
+                    let current_size_human: SpecificSize<Gigibyte> =
+                        SpecificSize::new(meta.size_capacity as f64, Byte)
+                            .unwrap()
+                            .into();
                     log::warn!(
                         "Cache size is updated from {} to {}",
                         current_size_human,

server/src/option.rs

@@ -609,9 +609,9 @@ pub mod validation {
         str::FromStr,
     };
 
-    use human_size::{SpecificSize,multiples};
     use crate::option::MIN_CACHE_SIZE_BYTES;
     use crate::storage::LOCAL_SYNC_INTERVAL;
+    use human_size::{multiples, SpecificSize};
 
     pub fn file_path(s: &str) -> Result<PathBuf, String> {
         if s.is_empty() {
@@ -684,7 +684,9 @@ pub mod validation {
     }
 
     pub fn upload_interval(s: &str) -> Result<u64, String> {
-        let u = s.parse::<u64>().map_err(|_| "invalid upload interval".to_string())?;
+        let u = s
+            .parse::<u64>()
+            .map_err(|_| "invalid upload interval".to_string())?;
         if u < LOCAL_SYNC_INTERVAL {
             return Err("object storage upload interval must be 60 seconds or more".to_string());
         }