chore: udpate rust toolchain 1.72.0-nightly

Fixing cargo fmt and clipply errors and warnings

src/app.rs

@@ -28,6 +28,11 @@ pub struct Running {
     pub tracker_data_importer_handle: tokio::task::JoinHandle<()>,
 }
 
+/// Runs the application.
+///
+/// # Panics
+///
+/// It panics if there is an error connecting to the database.
 #[allow(clippy::too_many_lines)]
 pub async fn run(configuration: Configuration, api_version: &Version) -> Running {
     let log_level = configuration.settings.read().await.log_level.clone();

src/cache/image/manager.rs

@@ -19,6 +19,11 @@ pub enum Error {
 
 type UserQuotas = HashMap<i64, ImageCacheQuota>;
 
+/// Returns the current time in seconds.
+///
+/// # Panics
+///
+/// This function will panic if the current time is before the UNIX EPOCH.
 #[must_use]
 pub fn now_in_secs() -> u64 {
     SystemTime::now()
@@ -87,6 +92,11 @@ pub struct ImageCacheService {
 }
 
 impl ImageCacheService {
+    /// Create a new image cache service.
+    ///
+    /// # Panics
+    ///
+    /// This function will panic if the image cache could not be created.
     pub async fn new(cfg: Arc<Configuration>) -> Self {
         let settings = cfg.settings.read().await;
 

src/cache/mod.rs

@@ -98,7 +98,7 @@ impl BytesCache {
     pub fn total_size(&self) -> usize {
         let mut size: usize = 0;
 
-        for (_, entry) in self.bytes_table.iter() {
+        for (_, entry) in &self.bytes_table {
             size += entry.bytes.len();
         }
 

src/config.rs

@@ -362,6 +362,10 @@ impl Configuration {
     }
 
     /// Returns the save to file of this [`Configuration`].
+    ///
+    /// # Panics
+    ///
+    /// This function will panic if it can't write to the file.
     pub async fn save_to_file(&self, config_path: &str) {
         let settings = self.settings.read().await;
 

src/console/commands/import_tracker_statistics.rs

@@ -70,6 +70,11 @@ fn print_usage() {
     );
 }
 
+/// Import Tracker Statistics Command
+///
+/// # Panics
+///
+/// Panics if arguments cannot be parsed.
 pub async fn run_importer() {
     parse_args().expect("unable to parse command arguments");
     import().await;

src/databases/mysql.rs

@@ -329,7 +329,7 @@ impl Database for Mysql {
         let category_filter_query = if let Some(c) = categories {
             let mut i = 0;
             let mut category_filters = String::new();
-            for category in c.iter() {
+            for category in c {
                 // don't take user input in the db query
                 if let Ok(sanitized_category) = self.get_category_from_name(category).await {
                     let mut str = format!("tc.name = '{}'", sanitized_category.name);
@@ -352,7 +352,7 @@ impl Database for Mysql {
         let tag_filter_query = if let Some(t) = tags {
             let mut i = 0;
             let mut tag_filters = String::new();
-            for tag in t.iter() {
+            for tag in t {
                 // don't take user input in the db query
                 if let Ok(sanitized_tag) = self.get_tag_from_name(tag).await {
                     let mut str = format!("tl.tag_id = '{}'", sanitized_tag.tag_id);
@@ -479,7 +479,7 @@ impl Database for Mysql {
         } else {
             let files = torrent.info.files.as_ref().unwrap();
 
-            for file in files.iter() {
+            for file in files {
                 let path = file.path.join("/");
 
                 let _ = query("INSERT INTO torrust_torrent_files (md5sum, torrent_id, length, path) VALUES (?, ?, ?, ?)")

src/databases/sqlite.rs

@@ -319,7 +319,7 @@ impl Database for Sqlite {
         let category_filter_query = if let Some(c) = categories {
             let mut i = 0;
             let mut category_filters = String::new();
-            for category in c.iter() {
+            for category in c {
                 // don't take user input in the db query
                 if let Ok(sanitized_category) = self.get_category_from_name(category).await {
                     let mut str = format!("tc.name = '{}'", sanitized_category.name);
@@ -342,7 +342,7 @@ impl Database for Sqlite {
         let tag_filter_query = if let Some(t) = tags {
             let mut i = 0;
             let mut tag_filters = String::new();
-            for tag in t.iter() {
+            for tag in t {
                 // don't take user input in the db query
                 if let Ok(sanitized_tag) = self.get_tag_from_name(tag).await {
                     let mut str = format!("tl.tag_id = '{}'", sanitized_tag.tag_id);
@@ -469,7 +469,7 @@ impl Database for Sqlite {
         } else {
             let files = torrent.info.files.as_ref().unwrap();
 
-            for file in files.iter() {
+            for file in files {
                 let path = file.path.join("/");
 
                 let _ = query("INSERT INTO torrust_torrent_files (md5sum, torrent_id, length, path) VALUES (?, ?, ?, ?)")

src/mailer.rs

@@ -58,11 +58,15 @@ impl Service {
         }
     }
 
-    /// Send Verification Email
+    /// Send Verification Email.
     ///
     /// # Errors
     ///
     /// This function will return an error if unable to send an email.
+    ///
+    /// # Panics
+    ///
+    /// This function will panic if the multipart builder had an error.
     pub async fn send_verification_mail(
         &self,
         to: &str,

src/models/torrent_file.rs

@@ -50,6 +50,12 @@ impl TorrentInfo {
         }
     }
 
+    /// It returns the root hash as a `i64` value.
+    ///
+    /// # Panics
+    ///
+    /// This function will panic if the root hash cannot be converted into a
+    /// `i64` value.
     #[must_use]
     pub fn get_root_hash_as_i64(&self) -> i64 {
         match &self.root_hash {
@@ -96,6 +102,11 @@ pub struct Torrent {
 }
 
 impl Torrent {
+    /// It hydrates a `Torrent` struct from the database data.
+    ///
+    /// # Panics
+    ///
+    /// This function will panic if the `torrent_info.pieces` is not a valid hex string.
     #[must_use]
     pub fn from_db_info_files_and_announce_urls(
         torrent_info: DbTorrentInfo,
@@ -180,6 +191,11 @@ impl Torrent {
         }
     }
 
+    /// It calculates the info hash of the torrent file.
+    ///
+    /// # Panics
+    ///
+    /// This function will panic if the `info` part of the torrent file cannot be serialized.
     #[must_use]
     pub fn calculate_info_hash_as_bytes(&self) -> [u8; 20] {
         let info_bencoded = ser::to_bytes(&self.info).expect("variable `info` was not able to be serialized.");
@@ -204,7 +220,7 @@ impl Torrent {
                 None => 0,
                 Some(files) => {
                     let mut file_size = 0;
-                    for file in files.iter() {
+                    for file in files {
                         file_size += file.length;
                     }
                     file_size
@@ -213,6 +229,11 @@ impl Torrent {
         }
     }
 
+    /// It returns the announce urls of the torrent file.
+    ///
+    /// # Panics
+    ///
+    /// This function will panic if both the `announce_list` and the `announce` are `None`.
     #[must_use]
     pub fn announce_urls(&self) -> Vec<String> {
         match &self.announce_list {

src/services/authentication.rs

@@ -120,6 +120,11 @@ impl JsonWebToken {
     }
 
     /// Create Json Web Token.
+    ///
+    /// # Panics
+    ///
+    /// This function will panic if the default encoding algorithm does not ç
+    /// match the encoding key.
     pub async fn sign(&self, user: UserCompact) -> String {
         let settings = self.cfg.settings.read().await;
 

src/services/user.rs

@@ -61,6 +61,10 @@ impl RegistrationService {
     /// * `ServiceError::FailedToSendVerificationEmail` if unable to send the required verification email.
     /// * An error if unable to successfully hash the password.
     /// * An error if unable to insert user into the database.
+    ///
+    /// # Panics
+    ///
+    /// This function will panic if the email is required, but missing.
     pub async fn register_user(&self, registration_form: &RegistrationForm, api_base_url: &str) -> Result<UserId, ServiceError> {
         info!("registering user: {}", registration_form.username);
 
@@ -328,6 +332,11 @@ impl DbBannedUserList {
     /// # Errors
     ///
     /// It returns an error if there is a database error.
+    ///
+    /// # Panics
+    ///
+    /// It panics if the expiration date cannot be parsed. It should never
+    /// happen as the date is hardcoded for now.
     pub async fn add(&self, user_id: &UserId) -> Result<(), Error> {
         // todo: add reason and `date_expiry` parameters to request.
 

src/upgrades/from_v1_0_0_to_v2_0_0/databases/mod.rs

@@ -21,6 +21,11 @@ pub async fn migrate_target_database(target_database: Arc<SqliteDatabaseV2_0_0>)
     target_database.migrate().await;
 }
 
+/// It truncates all tables in the target database.
+///
+/// # Panics
+///
+/// It panics if it cannot truncate the tables.
 pub async fn truncate_target_database(target_database: Arc<SqliteDatabaseV2_0_0>) {
     println!("Truncating all tables in target database ...");
     target_database

src/upgrades/from_v1_0_0_to_v2_0_0/databases/sqlite_v1_0_0.rs

@@ -58,6 +58,11 @@ pub struct SqliteDatabaseV1_0_0 {
 }
 
 impl SqliteDatabaseV1_0_0 {
+    /// It creates a new instance of the `SqliteDatabaseV1_0_0`.
+    ///
+    /// # Panics
+    ///
+    /// This function will panic if it is unable to create the database pool.
     pub async fn new(database_url: &str) -> Self {
         let db = SqlitePoolOptions::new()
             .connect(database_url)

src/upgrades/from_v1_0_0_to_v2_0_0/databases/sqlite_v2_0_0.rs

@@ -49,6 +49,11 @@ impl TorrentRecordV2 {
     }
 }
 
+/// It converts a timestamp in seconds to a datetime string.
+///
+/// # Panics
+///
+/// It panics if the timestamp is too big and it overflows i64. Very future!
 #[must_use]
 pub fn convert_timestamp_to_datetime(timestamp: i64) -> String {
     // The expected format in database is: 2022-11-04 09:53:57
@@ -66,6 +71,11 @@ pub struct SqliteDatabaseV2_0_0 {
 }
 
 impl SqliteDatabaseV2_0_0 {
+    /// Creates a new instance of the database.
+    ///
+    /// # Panics
+    ///
+    /// It panics if it cannot create the database pool.
     pub async fn new(database_url: &str) -> Self {
         let db = SqlitePoolOptions::new()
             .connect(database_url)
@@ -74,6 +84,11 @@ impl SqliteDatabaseV2_0_0 {
         Self { pool: db }
     }
 
+    /// It migrates the database to the latest version.
+    ///
+    /// # Panics
+    ///
+    /// It panics if it cannot run the migrations.
     pub async fn migrate(&self) {
         sqlx::migrate!("migrations/sqlite3")
             .run(&self.pool)

src/upgrades/from_v1_0_0_to_v2_0_0/transferrers/torrent_transferrer.rs

@@ -96,7 +96,7 @@ pub async fn transfer_torrents(
             // Multiple files are being shared
             let files = torrent_from_file.info.files.as_ref().unwrap();
 
-            for file in files.iter() {
+            for file in files {
                 println!(
                     "[v2][torrust_torrent_files][multiple-file-torrent] adding torrent file: {:?} ...",
                     &file

src/utils/clock.rs

@@ -1,3 +1,9 @@
+/// Returns the current timestamp in seconds.
+///
+/// # Panics
+///
+/// This function should never panic unless the current timestamp from the
+/// time library is negative, which should never happen.
 #[must_use]
 pub fn now() -> u64 {
     u64::try_from(chrono::prelude::Utc::now().timestamp()).expect("timestamp should be positive")

src/utils/regex.rs

@@ -1,5 +1,10 @@
 use regex::Regex;
 
+/// Validates an email address.
+///
+/// # Panics
+///
+/// It panics if the regex fails to compile.
 #[must_use]
 pub fn validate_email_address(email_address_to_be_checked: &str) -> bool {
     let email_regex = Regex::new(r"^([a-z\d_+]([a-z\d_+.]*[a-z\d_+])?)@([a-z\d]+([\-.][a-z\d]+)*\.[a-z]{2,6})")

src/web/api/v1/auth.rs

@@ -142,6 +142,10 @@ impl Authentication {
 }
 
 /// Parses the token from the `Authorization` header.
+///
+/// # Panics
+///
+/// This function will panic if the `Authorization` header is not a valid `String`.
 pub fn parse_token(authorization: &HeaderValue) -> String {
     let split: Vec<&str> = authorization
         .to_str()

src/web/api/v1/contexts/proxy/handlers.rs

@@ -22,7 +22,9 @@ pub async fn get_proxy_image_handler(
         return png_image(map_error_to_image(&Error::Unauthenticated));
     }
 
-    let Ok(user_id) = app_data.auth.get_user_id_from_bearer_token(&maybe_bearer_token).await else { return png_image(map_error_to_image(&Error::Unauthenticated)) };
+    let Ok(user_id) = app_data.auth.get_user_id_from_bearer_token(&maybe_bearer_token).await else {
+        return png_image(map_error_to_image(&Error::Unauthenticated));
+    };
 
     // code-review: Handling status codes in the frontend other tan OK is quite a pain.
     // Return OK for now.

src/web/api/v1/contexts/torrent/handlers.rs

@@ -74,7 +74,9 @@ pub async fn download_torrent_handler(
     Extract(maybe_bearer_token): Extract,
     Path(info_hash): Path<InfoHashParam>,
 ) -> Response {
-    let Ok(info_hash) = InfoHash::from_str(&info_hash.lowercase()) else { return ServiceError::BadRequest.into_response() };
+    let Ok(info_hash) = InfoHash::from_str(&info_hash.lowercase()) else {
+        return ServiceError::BadRequest.into_response();
+    };
 
     let opt_user_id = match get_optional_logged_in_user(maybe_bearer_token, app_data.clone()).await {
         Ok(opt_user_id) => opt_user_id,
@@ -86,7 +88,9 @@ pub async fn download_torrent_handler(
         Err(error) => return error.into_response(),
     };
 
-    let Ok(bytes) = parse_torrent::encode_torrent(&torrent) else { return ServiceError::InternalServerError.into_response() };
+    let Ok(bytes) = parse_torrent::encode_torrent(&torrent) else {
+        return ServiceError::InternalServerError.into_response();
+    };
 
     torrent_file_response(bytes)
 }
@@ -120,7 +124,9 @@ pub async fn get_torrent_info_handler(
     Extract(maybe_bearer_token): Extract,
     Path(info_hash): Path<InfoHashParam>,
 ) -> Response {
-    let Ok(info_hash) = InfoHash::from_str(&info_hash.lowercase()) else { return ServiceError::BadRequest.into_response() };
+    let Ok(info_hash) = InfoHash::from_str(&info_hash.lowercase()) else {
+        return ServiceError::BadRequest.into_response();
+    };
 
     let opt_user_id = match get_optional_logged_in_user(maybe_bearer_token, app_data.clone()).await {
         Ok(opt_user_id) => opt_user_id,
@@ -149,7 +155,9 @@ pub async fn update_torrent_info_handler(
     Path(info_hash): Path<InfoHashParam>,
     extract::Json(update_torrent_info_form): extract::Json<UpdateTorrentInfoForm>,
 ) -> Response {
-    let Ok(info_hash) = InfoHash::from_str(&info_hash.lowercase()) else { return ServiceError::BadRequest.into_response() };
+    let Ok(info_hash) = InfoHash::from_str(&info_hash.lowercase()) else {
+        return ServiceError::BadRequest.into_response();
+    };
 
     let user_id = match app_data.auth.get_user_id_from_bearer_token(&maybe_bearer_token).await {
         Ok(user_id) => user_id,
@@ -188,7 +196,9 @@ pub async fn delete_torrent_handler(
     Extract(maybe_bearer_token): Extract,
     Path(info_hash): Path<InfoHashParam>,
 ) -> Response {
-    let Ok(info_hash) = InfoHash::from_str(&info_hash.lowercase()) else { return ServiceError::BadRequest.into_response() };
+    let Ok(info_hash) = InfoHash::from_str(&info_hash.lowercase()) else {
+        return ServiceError::BadRequest.into_response();
+    };
 
     let user_id = match app_data.auth.get_user_id_from_bearer_token(&maybe_bearer_token).await {
         Ok(user_id) => user_id,