use std::{io::Write, collections::HashMap}; use indicatif::{ProgressBar, ProgressStyle, MultiProgress}; use crate::{ config::Cfg, db::{ lists_get_all_ids, mods_get_id, mods_insert, mods_remove, userlist_get_all_ids, userlist_get_current_version, userlist_insert, userlist_remove, mods_get_info, }, error::{ErrorType, MLError, MLE}, files::{delete_version, download_versions}, modrinth::{extract_current_version, get_raw_versions, project, projects, versions, Version}, List, PROGRESS_CHARS, STYLE_BAR_POS, STYLE_SPINNER, }; #[derive(Debug)] pub struct AddMod { pub id: IDSelector, pub set_version: bool } #[derive(Debug, PartialEq, Eq)] pub enum IDSelector { ModificationID(String), VersionID(String), } #[derive(Debug, Clone)] pub struct ProjectInfo { pub mod_id: String, pub slug: String, pub title: String, pub current_version: Option, pub applicable_versions: Vec, pub download_link: String, pub set_version: bool, } pub async fn mod_add( config: &Cfg, mods: Vec, list: List, direct_download: bool, ) -> MLE<()> { //TODO MultiProgress let spinner_style = ProgressStyle::with_template(STYLE_SPINNER).unwrap(); let bar_style = ProgressStyle::with_template(STYLE_BAR_POS).unwrap().progress_chars(PROGRESS_CHARS); let mut mod_ids: Vec<(String, bool)> = Vec::new(); let mut ver_ids: Vec<(String, bool)> = Vec::new(); let p = ProgressBar::new(mods.len().try_into().unwrap()); p.set_style(spinner_style.clone()); p.set_message("Sort ids"); //"Sort" project ids from version ids to be able to handle them differently but in a batch for m in mods { p.inc(1); match m.id { IDSelector::ModificationID(pid) => mod_ids.push((pid, m.set_version)), IDSelector::VersionID(vid) => ver_ids.push((vid, m.set_version)), } } p.finish_with_message("Sort ids done"); let info_p = ProgressBar::new(2); info_p.set_message("Get infos"); info_p.set_style(bar_style.clone()); let mut projectinfo: Vec = Vec::new(); if !mod_ids.is_empty() { projectinfo.append(&mut get_mod_infos(config, mod_ids, list.clone()).await?); info_p.inc(1); }; if !ver_ids.is_empty() { projectinfo.append(&mut get_ver_info(config, ver_ids).await?); info_p.inc(1); }; info_p.finish_with_message("Get infos done"); if projectinfo.is_empty() { return Err(MLError::new(ErrorType::ArgumentError, "NO_IDS?")); }; let mut downloadstack: Vec = Vec::new(); //Adding each mod to the lists and downloadstack let add_p = ProgressBar::new(projectinfo.len().try_into().unwrap()); add_p.set_style(bar_style); for project in projectinfo { add_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().unwrap().id }; match userlist_insert( config, &list.id, &project.mod_id, ¤t_version_id, project.clone().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(MLError::new( ErrorType::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(..), }?; if project.current_version.is_some() { downloadstack.push(project.current_version.unwrap()) }; // add_p.println(format!("Added {}", project.title)); add_p.inc(1); } add_p.finish_with_message("Added all mods"); //Download all the added mods if direct_download { let mp = MultiProgress::new(); download_versions(list.clone(), config.clone(), downloadstack, &mp, None).await?; }; Ok(()) } async fn get_mod_infos(config: &Cfg, mod_ids: Vec<(String, bool)>, list: List) -> MLE> { let mut setmap: HashMap = HashMap::new(); let mut ids = vec![]; // println!("{:?}", mod_ids); for id in mod_ids { setmap.insert(id.0.to_string(), id.1); ids.push(id.0); } let mut projectinfo: Vec = Vec::new(); //Get required information from mod_ids let m_projects = match ids.len() { 1 => vec![project(&config.apis.modrinth, &ids[0]).await], 2.. => projects(&config.apis.modrinth, ids).await, _ => panic!("PANIC"), }; for project in m_projects { // println!("\t└{}", project.title); // println!("\t └Get versions"); let available_versions = versions( &config.apis.modrinth, String::from(&project.id), list.clone(), ) .await; let mut available_versions_vec: Vec = Vec::new(); let current_version: Option; let file: String; if !available_versions.is_empty() { let current_id = extract_current_version(available_versions.clone())?; // println!("\t └Current version: {}", current_id); current_version = Some( available_versions .clone() .into_iter() .find(|v| v.id == current_id) .unwrap(), ); // match primary, if none? let files = current_version .clone() .ok_or("") .unwrap() .files; file = match files.clone().into_iter().find(|f| f.primary) { Some(f) => f, None => { files[0].clone() } } .url; for ver in available_versions { available_versions_vec.push(ver.id); } // println!("{:?}", setmap); projectinfo.push(ProjectInfo { mod_id: String::from(&project.id), slug: project.slug.clone(), title: project.title, current_version, applicable_versions: available_versions_vec, download_link: file, set_version: *setmap.get(&project.slug).unwrap(), }) } else { // println!("\t └There's currently no mod version for your specified target"); current_version = None; file = String::from("NONE"); available_versions_vec.push(String::from("NONE")); projectinfo.push(ProjectInfo { mod_id: String::from(&project.id), slug: project.slug, title: project.title, current_version, applicable_versions: available_versions_vec, download_link: file, set_version: *setmap.get(&project.id).unwrap(), }) } } Ok(projectinfo) } async fn get_ver_info(config: &Cfg, ver_ids: Vec<(String, bool)>) -> MLE> { let mut setmap: HashMap = HashMap::new(); let mut ids = vec![]; for id in ver_ids { setmap.insert(id.0.to_string(), id.1); ids.push(id.0); } let mut projectinfo: Vec = Vec::new(); //Get required information from ver_ids let mut v_versions = get_raw_versions(&config.apis.modrinth, ids).await; let mut v_mod_ids: Vec = Vec::new(); for ver in v_versions.clone() { v_mod_ids.push(ver.project_id); } let mut v_projects = projects(&config.apis.modrinth, v_mod_ids).await; v_versions.sort_by(|a, b| a.project_id.cmp(&b.project_id)); v_projects.sort_by(|a, b| a.id.cmp(&b.id)); for (i, project) in v_projects.into_iter().enumerate() { let version = &v_versions[i]; // println!("\t└{}({})", project.title, version.id); let file = version .clone() .files .into_iter() .find(|f| f.primary) .unwrap() .url; projectinfo.push(ProjectInfo { mod_id: String::from(&project.id), slug: project.slug, title: project.title, current_version: Some(version.clone()), applicable_versions: vec![String::from(&version.id)], download_link: file, set_version: *setmap.get(&version.id).unwrap(), }) } Ok(projectinfo) } /// Remove mod from a list /// # Arguments /// /// * `config` - config struct /// * `id` - name, slug or id of the mod /// * `list` - List struct pub fn mod_remove(config: &Cfg, id: &str, list: List) -> MLE<()> { let mod_id = mods_get_id(&config.data, id)?; println!("Remove mod {} from {}", mods_get_info(config, &mod_id)?.title, list.id); let version = userlist_get_current_version(config, &list.id, &mod_id)?; print!(" └Remove from list"); //Force flush of stdout, else print! doesn't print instantly std::io::stdout().flush()?; userlist_remove(config, &list.id, &mod_id)?; println!(" ✓"); print!(" └Delete file"); //Force flush of stdout, else print! doesn't print instantly std::io::stdout().flush()?; match delete_version(list, version) { Ok(_) => (), Err(err) => { if err.to_string() != "User input not accepted: VERSION_NOT_FOUND_IN_FILES" { return Err(err); }; }, }; println!(" ✓"); print!(" └Clean main db table"); //Force flush of stdout, else print! doesn't print instantly std::io::stdout().flush()?; let list_ids = lists_get_all_ids(config)?; // Remove mod from main list if not used elsewhere let mut mod_used = false; for id in list_ids { let mods = match userlist_get_all_ids(config, &id) { Ok(m) => m, Err(err) => { if err.to_string() == "Database: NO_MODS_USERLIST" { println!(" ✓"); return Ok(()); }; return Err(err) } }; if mods.contains(&mod_id) { mod_used = true; break; }; } if !mod_used { mods_remove(config, mod_id)?; }; println!(" ✓"); Ok(()) }