Fix warnings

Signed-off-by: Denys Fedoryshchenko <denys.f@collabora.com>

Author: nuclearcat

src/azure.rs

@@ -106,6 +106,7 @@ mod tests {
     }
 }
 
+#[allow(dead_code)]
 fn calculate_checksum(filename: &String, data: &[u8]) {
     let hash = sha2_512::default().update(data).finalize();
     let digest = hash.digest();
@@ -217,6 +218,7 @@ async fn write_file_to_blob_streaming(
 
 /// Write file to Azure blob storage (legacy version using Vec<u8>)
 /// TBD: Rework, do not keep whole file as Vec<u8> in memory!!!
+#[allow(dead_code)]
 async fn write_file_to_blob(
     filename: String,
     data: Vec<u8>,
@@ -378,7 +380,6 @@ async fn get_file_from_blob(filename: String) -> ReceivedFile {
     let blob_client = ClientBuilder::new(storage_account, storage_credential)
         .blob_client(storage_container, storage_blob);
     let blob_url_res = blob_client.url();
-    let mut blob_url = "".to_string();
     let mut received_file = ReceivedFile {
         original_filename: "".to_string(),
         cached_filename: "".to_string(),
@@ -387,16 +388,13 @@ async fn get_file_from_blob(filename: String) -> ReceivedFile {
     };
     received_file.original_filename = filename.clone();
 
-    match blob_url_res {
-        Ok(url) => {
-            //println!("Blob URL: {}", url);
-            blob_url = url.to_string();
-        }
+    let mut blob_url = match blob_url_res {
+        Ok(url) => url.to_string(),
         Err(e) => {
             eprintln!("Error getting blob URL: {:?}", e);
             return received_file;
         }
-    }
+    };
     // append SAS token to blob URL
     blob_url.push_str(storage_sastoken);
     // we generate a hash of the filename to use as cache filename
@@ -527,6 +525,7 @@ async fn get_file_from_blob(filename: String) -> ReceivedFile {
 
 // Implement set tags for Azure blob storage
 // tags are in format "key=value"
+#[allow(dead_code)]
 async fn azure_set_filename_tags(
     filename: String,
     user_tags: Vec<(String, String)>,
@@ -571,7 +570,8 @@ async fn azure_set_filename_tags(
     }
 }
 
-async fn azure_list_files(directory: String) -> Vec<String> {
+#[allow(dead_code)]
+async fn azure_list_files(_directory: String) -> Vec<String> {
     let azure_cfg = Arc::new(get_azure_credentials("azure"));
     let storage_account = azure_cfg.account.as_str();
     let storage_key = azure_cfg.key.clone();

src/local.rs

@@ -100,6 +100,7 @@ fn get_metadata_file_path(filename: &str) -> PathBuf {
 }
 
 /// Calculate SHA-512 checksum of file data
+#[allow(dead_code)]
 fn calculate_checksum(filename: &str, data: &[u8]) {
     let hash = sha2_512::default().update(data).finalize();
     let digest = hash.digest();
@@ -157,6 +158,7 @@ async fn write_file_to_local_streaming(
 }
 
 /// Write file to local storage (legacy version using Vec<u8>)
+#[allow(dead_code)]
 fn write_file_to_local(
     filename: String,
     data: Vec<u8>,
@@ -298,6 +300,7 @@ fn list_files_in_local(directory: String) -> Vec<String> {
 }
 
 /// Set tags for local storage (stored in metadata)
+#[allow(dead_code)]
 fn set_tags_for_local_file(
     filename: String,
     user_tags: Vec<(String, String)>,

src/main.rs

@@ -190,6 +190,7 @@ impl<'a> tokio::io::AsyncRead for FieldStream<'a> {
     }
 }
 
+#[allow(dead_code)]
 #[async_trait]
 trait Driver: Send + Sync {
     async fn write_file(
@@ -1149,6 +1150,7 @@ async fn driver_get_file(filepath: String) -> ReceivedFile {
     driver.get_file(filepath).await
 }
 
+#[allow(dead_code)]
 async fn write_file_driver(
     filename: String,
     data: Vec<u8>,

src/storcaching.rs

@@ -1,4 +1,4 @@
-use crate::{debug_log, get_config_content};
+use crate::get_config_content;
 use serde::Deserialize;
 use std::cmp::Ordering;
 use std::collections::{BinaryHeap, HashSet};
@@ -325,15 +325,14 @@ pub async fn cache_loop(cache_dir: &str) {
     let cleanup_chunk_size = config.cleanup_chunk_size.max(1);
     let mut deleted_entries_counter: u64 = 0;
     let mut reclaimed_bytes_counter: u64 = 0;
-    let mut cached_file_count: usize = 0;
     let mut next_log = Instant::now();
 
     loop {
         let (limit_outcome, file_count) =
             enforce_cache_file_limit(cache_dir, cleanup_chunk_size).await;
         deleted_entries_counter += limit_outcome.deleted_entries;
         reclaimed_bytes_counter += limit_outcome.reclaimed_bytes;
-        cached_file_count = file_count;
+        let mut cached_file_count = file_count;
 
         let mut free_space = freediskspace_percent(cache_dir).await;
         if free_space < DISK_SPACE_LOW_PERCENT {

src/storjwt.rs

@@ -1,4 +1,4 @@
-use crate::{debug_log, get_config_content};
+use crate::get_config_content;
 use jsonwebtoken::{decode, encode, DecodingKey, EncodingKey, Header, Validation};
 use serde::{Deserialize, Serialize};
 use std::collections::BTreeMap;