remove allow too_many_lines and fix them

3 files changed, 195 insertions, 187 deletions

diff --git a/src/commands/download.rs b/src/commands/download.rs
index 7af1066..7ea5c29 100644
--- a/src/commands/download.rs
+++ b/src/commands/download.rs
@@ -1,5 +1,3 @@
-#![allow(clippy::too_many_lines)]
-
 use indicatif::{MultiProgress, ProgressBar, ProgressStyle};
 
 use crate::{config::Cfg, List};
@@ -35,105 +33,113 @@ pub async fn download(
     );
 
     for current_list in liststack {
-        download_p.set_message(format!("Download in {}", current_list.id));
-
-        let downloaded_versions = get_downloaded_versions(&current_list)?;
-        let current_version_ids =
-            match userlist_get_all_current_versions_with_mods(
-                config,
-                &current_list.id,
-            ) {
-                Ok(i) => Ok(i),
-                Err(e) => {
-                    Err(MLErr::new(EType::DBError, e.to_string().as_str()))
-                }
-            }?;
-
-        let mut to_download: Vec<String> = vec![];
-        //(mod_id, version_id)
-        let mut to_disable: Vec<(String, String)> = vec![];
-
-        for version in current_version_ids {
-            let mod_id = version.0;
-            let current_version = version.1;
-
-            let current_download = downloaded_versions.get(&mod_id);
-
-            if current_download.is_none() || clean {
-                to_download.push(current_version);
-            } else {
-                let downloaded_version = current_download
-                    .ok_or(MLErr::new(EType::Other, "IDK, WTF"))?;
-                if &current_version != downloaded_version {
-                    to_disable.push((
-                        mod_id.clone(),
-                        String::from(downloaded_version),
-                    ));
-                    to_download.push(current_version);
-                }
-            }
-        }
+        download_list(config, mp.clone(), download_p.clone(), current_list, clean, delete_old).await?;
+    }
 
-        if clean {
-            clean_list_dir(&current_list)?;
-        };
+    download_p.finish_with_message("Downloaded all lists");
+
+    Ok(())
+}
+
+async fn download_list(
+    config: &Cfg,
+    mp: MultiProgress,
+    download_p: ProgressBar,
+    current_list: List,
+    clean: bool,
+    delete_old: bool,
+) -> MLE<()> {
+    download_p.set_message(format!("Download in {}", current_list.id));
+
+    let downloaded_versions = get_downloaded_versions(&current_list)?;
+    let current_version_ids = match userlist_get_all_current_versions_with_mods(
+        config,
+        &current_list.id,
+    ) {
+        Ok(i) => Ok(i),
+        Err(e) => Err(MLErr::new(EType::DBError, e.to_string().as_str())),
+    }?;
+
+    let mut to_download: Vec<String> = vec![];
+    //(mod_id, version_id)
+    let mut to_disable: Vec<(String, String)> = vec![];
+
+    for version in current_version_ids {
+        let mod_id = version.0;
+        let current_version = version.1;
 
-        if to_download.is_empty() {
-            download_p.println(format!(
-                "There are no new versions to download for {}",
-                current_list.id
-            ));
+        let current_download = downloaded_versions.get(&mod_id);
+
+        if current_download.is_none() || clean {
+            to_download.push(current_version);
         } else {
-            download_versions(
-                current_list.clone(),
-                config.clone(),
-                get_raw_versions(&config.apis.modrinth, to_download).await?,
-                &mp,
-                &download_p,
-            )
-            .await?;
+            let downloaded_version =
+                current_download.ok_or(MLErr::new(EType::Other, "IDK, WTF"))?;
+            if &current_version != downloaded_version {
+                to_disable
+                    .push((mod_id.clone(), String::from(downloaded_version)));
+                to_download.push(current_version);
+            }
         }
+    }
 
-        if !to_disable.is_empty() {
-            let d_p =
-                mp.insert_before(
-                    &download_p,
-                    ProgressBar::new(to_disable.len().try_into().map_err(
-                        |_| MLErr::new(EType::Other, "ListStackLen"),
-                    )?),
-                );
-            d_p.set_style(
-                ProgressStyle::with_template(STYLE_BAR_POS)
-                    .map_err(|_| {
-                        MLErr::new(EType::LibIndicatif, "template error")
-                    })?
-                    .progress_chars(PROGRESS_CHARS),
-            );
-            for ver in to_disable {
-                if delete_old {
-                    d_p.set_message(format!("Delete version {}", ver.1));
-                    d_p.inc(1);
-                    delete_version(&current_list, &ver.1)?;
-                } else {
-                    d_p.set_message(format!("Disable version {}", ver.1));
-                    d_p.inc(1);
-                    disable_version(config, &current_list, ver.1, ver.0)?;
-                };
-            }
+    if clean {
+        clean_list_dir(&current_list)?;
+    };
+
+    if to_download.is_empty() {
+        download_p.println(format!(
+            "There are no new versions to download for {}",
+            current_list.id
+        ));
+    } else {
+        download_versions(
+            current_list.clone(),
+            config.clone(),
+            get_raw_versions(&config.apis.modrinth, to_download).await?,
+            &mp,
+            &download_p,
+        )
+        .await?;
+    }
 
-            let del_msg = if delete_old {
-                "Deleted all old versions"
+    if !to_disable.is_empty() {
+        let d_p = mp.insert_before(
+            &download_p,
+            ProgressBar::new(
+                to_disable
+                    .len()
+                    .try_into()
+                    .map_err(|_| MLErr::new(EType::Other, "ListStackLen"))?,
+            ),
+        );
+        d_p.set_style(
+            ProgressStyle::with_template(STYLE_BAR_POS)
+                .map_err(|_| MLErr::new(EType::LibIndicatif, "template error"))?
+                .progress_chars(PROGRESS_CHARS),
+        );
+        for ver in to_disable {
+            if delete_old {
+                d_p.set_message(format!("Delete version {}", ver.1));
+                d_p.inc(1);
+                delete_version(&current_list, &ver.1)?;
             } else {
-                "Disabled all old versions"
+                d_p.set_message(format!("Disable version {}", ver.1));
+                d_p.inc(1);
+                disable_version(config, &current_list, ver.1, ver.0)?;
             };
-
-            d_p.finish_with_message(del_msg);
         }
 
-        download_p.inc(1);
+        let del_msg = if delete_old {
+            "Deleted all old versions"
+        } else {
+            "Disabled all old versions"
+        };
+
+        d_p.finish_with_message(del_msg);
     }
 
-    download_p.finish_with_message("Downloaded all lists");
+    download_p.inc(1);
 
     Ok(())
 }
diff --git a/src/commands/modification.rs b/src/commands/modification.rs
index aa1174a..8f115ee 100644
--- a/src/commands/modification.rs
+++ b/src/commands/modification.rs
@@ -1,5 +1,3 @@
-#![allow(clippy::too_many_lines)]
-
 use std::collections::HashMap;
 
 use indicatif::{MultiProgress, ProgressBar, ProgressStyle};
@@ -114,60 +112,7 @@ pub async fn mod_add(
     );
 
     for project in projectinfo {
-        project_p.set_message(format!("Add {}", project.title));
-
-        let current_version_id = if project.current_version.is_none() {
-            String::from("NONE")
-        } else {
-            project
-                .current_version
-                .clone()
-                .ok_or(MLErr::new(EType::Other, "cur_ver"))?
-                .id
-        };
-
-        match userlist_insert(
-            config,
-            &list.id,
-            &project.mod_id,
-            &current_version_id,
-            &project.applicable_versions,
-            &project.download_link,
-            project.set_version,
-        ) {
-            Err(e) => {
-                let expected_err = format!(
-                    "SQL: UNIQUE constraint failed: {}.mod_id",
-                    list.id
-                );
-                if e.to_string() == expected_err {
-                    Err(MLErr::new(
-                        EType::ModError,
-                        "MOD_ALREADY_ON_SELECTED_LIST",
-                    ))
-                } else {
-                    Err(e)
-                }
-            }
-            Ok(..) => Ok(..),
-        }?;
-
-        match mods_insert(
-            config,
-            &project.mod_id,
-            &project.slug,
-            &project.title,
-        ) {
-            Err(e) => {
-                if e.to_string() == "SQL: UNIQUE constraint failed: mods.id" {
-                    Ok(..)
-                } else {
-                    Err(e)
-                }
-            }
-            Ok(..) => Ok(..),
-        }?;
-
+        add_project(config, &project_p, &project, &list)?;
         if project.current_version.is_some() {
             downloadstack.push(
                 project
@@ -175,8 +120,6 @@ pub async fn mod_add(
                     .ok_or(MLErr::new(EType::Other, "cur_ver"))?,
             );
         };
-
-        project_p.inc(1);
     }
 
     project_p.finish_with_message("Added all mods to the database");
@@ -199,6 +142,61 @@ pub async fn mod_add(
     Ok(())
 }
 
+fn add_project(
+    config: &Cfg,
+    project_p: &ProgressBar,
+    project: &ProjectInfo,
+    list: &List,
+) -> MLE<()> {
+    project_p.set_message(format!("Add {}", project.title));
+
+    let current_version_id = if project.current_version.is_none() {
+        String::from("NONE")
+    } else {
+        project
+            .current_version
+            .clone()
+            .ok_or(MLErr::new(EType::Other, "cur_ver"))?
+            .id
+    };
+
+    match userlist_insert(
+        config,
+        &list.id,
+        &project.mod_id,
+        &current_version_id,
+        &project.applicable_versions,
+        &project.download_link,
+        project.set_version,
+    ) {
+        Err(e) => {
+            let expected_err =
+                format!("SQL: UNIQUE constraint failed: {}.mod_id", list.id);
+            if e.to_string() == expected_err {
+                Err(MLErr::new(EType::ModError, "MOD_ALREADY_ON_SELECTED_LIST"))
+            } else {
+                Err(e)
+            }
+        }
+        Ok(..) => Ok(..),
+    }?;
+
+    match mods_insert(config, &project.mod_id, &project.slug, &project.title) {
+        Err(e) => {
+            if e.to_string() == "SQL: UNIQUE constraint failed: mods.id" {
+                Ok(..)
+            } else {
+                Err(e)
+            }
+        }
+        Ok(..) => Ok(..),
+    }?;
+
+    project_p.inc(1);
+
+    Ok(())
+}
+
 async fn get_mod_infos(
     config: &Cfg,
     mod_ids: Vec<(String, bool)>,
diff --git a/src/commands/update.rs b/src/commands/update.rs
index c7965e3..f83030d 100644
--- a/src/commands/update.rs
+++ b/src/commands/update.rs
@@ -1,5 +1,3 @@
-#![allow(clippy::too_many_lines)]
-
 use indicatif::{MultiProgress, ProgressBar, ProgressStyle};
 
 use crate::{
@@ -70,44 +68,7 @@ pub async fn update(
         let mut updatestack: Vec<Version> = vec![];
 
         for id in mods {
-            let info = mods_get_info(config, &id)?;
-            list_u_p.set_message(format!("Update {}", info.title));
-
-            //Skip check if version is set
-            if userlist_get_set_version(config, &current_list.id, &id)? {
-                list_u_p.inc(1);
-                continue;
-            }
-
-            //Getting current installed version for disable or delete
-            let disable_version =
-                userlist_get_current_version(config, &current_list.id, &id)?;
-
-            updatestack.push(
-                match specific_update(
-                    config,
-                    clean,
-                    current_list.clone(),
-                    &id,
-                    &list_u_p,
-                )
-                .await
-                {
-                    Ok(ver) => {
-                        current_versions.push((disable_version, id));
-                        ver
-                    }
-                    Err(e) => {
-                        if e.to_string() == "Mod: NO_UPDATE_AVAILABLE" {
-                        } else {
-                            return Err(e);
-                        };
-                        list_u_p.inc(1);
-                        continue;
-                    }
-                },
-            );
-            list_u_p.inc(1);
+            update_mod(config, id, list_u_p.clone(), &current_list, &mut updatestack, &mut current_versions, clean).await?;
         }
 
         list_u_p.finish_with_message(format!(
@@ -173,6 +134,49 @@ pub async fn update(
     Ok(())
 }
 
+async fn update_mod(config: &Cfg, id: String, list_u_p: ProgressBar, current_list: &List, updatestack: &mut Vec<Version>, current_versions: &mut Vec<(String, String)>, clean: bool) -> MLE<()> {
+            let info = mods_get_info(config, &id)?;
+            list_u_p.set_message(format!("Update {}", info.title));
+
+            //Skip check if version is set
+            if userlist_get_set_version(config, &current_list.id, &id)? {
+                list_u_p.inc(1);
+                return Ok(());
+            }
+
+            //Getting current installed version for disable or delete
+            let disable_version =
+                userlist_get_current_version(config, &current_list.id, &id)?;
+
+            updatestack.push(
+                match specific_update(
+                    config,
+                    clean,
+                    current_list.clone(),
+                    &id,
+                    &list_u_p,
+                )
+                .await
+                {
+                    Ok(ver) => {
+                        current_versions.push((disable_version, id.to_string()));
+                        ver
+                    }
+                    Err(e) => {
+                        if e.to_string() == "Mod: NO_UPDATE_AVAILABLE" {
+                        } else {
+                            return Err(e);
+                        };
+                        list_u_p.inc(1);
+                        return Ok(());
+                    }
+                },
+            );
+            list_u_p.inc(1);
+
+    Ok(())
+}
+
 async fn specific_update(
     config: &Cfg,
     clean: bool,