added download with delete; new file format

2 files changed, 51 insertions, 59 deletions

diff --git a/src/commands/download.rs b/src/commands/download.rs
index 421f058..9f70499 100644
--- a/src/commands/download.rs
+++ b/src/commands/download.rs
@@ -1,50 +1,51 @@
-use crate::{files::get_downloaded_versions, db::{userlist_get_all_applicable_versions_with_mods, userlist_get_all_current_versions_with_mods}};
+use crate::{files::{get_downloaded_versions, download_versions, delete_version, disable_version}, db::userlist_get_all_current_versions_with_mods, modrinth::get_raw_versions};
 #[allow(unused_imports)]
 use crate::{List, get_current_list, config::Cfg, db::userlist_get_all_downloads, input::Input};
 
-pub async fn download(config: Cfg, _input: Input) -> Result<(), Box<dyn std::error::Error>> {
+pub async fn download(config: Cfg, input: Input) -> Result<(), Box<dyn std::error::Error>> {
 
     let current_list = get_current_list(config.clone())?;
 
-    println!("NO IMPLEMENTATION FOR DOWNLOAD YET");
-
     let downloaded_versions = get_downloaded_versions(current_list.clone())?;
-    println!("DL: {:?}", downloaded_versions);
-
     let current_version_ids = userlist_get_all_current_versions_with_mods(config.clone(), String::from(&current_list.id))?;
-    println!("CU: {:?}", current_version_ids);
 
-    let applicable_version_ids = userlist_get_all_applicable_versions_with_mods(config, current_list.id)?;
-    println!("AP: {:?}", applicable_version_ids);
-    
-    /*
-    let list = get_current_list(config.clone())?;
+    let mut to_download: Vec<String> = vec![];
+    //(mod_id, version_id)
+    let mut to_disable: Vec<(String, String)> = vec![];
 
-    let links = userlist_get_all_downloads(config.clone(), list.clone().id)?;
+    for version in current_version_ids {
+        let mod_id = version.0;
+        let current_version = version.1;
 
-    download_links(config, input, list, links).await?;
-    */
-    Ok(())
-}
+        let current_download = downloaded_versions.get(&mod_id);
 
-#[allow(dead_code)]
-async fn download_links(_config: Cfg, _input: Input, _current_list: List, _links: Vec<String>) -> Result<String, Box<dyn std::error::Error>> {
-    println!("NO DL IMPLEMENTATION FOR DOWNLOAD YET");
-    //TODO copy dl from update if possible
-    /*
-    let dl_path = String::from(&current_list.download_folder);
-
-    if input.clean {
-        let dl_path = &current_list.download_folder;
-        println!("Cleaning {}", dl_path);
-        for entry in std::fs::read_dir(dl_path)? {
-            let entry = entry?;
-            std::fs::remove_file(entry.path())?;
+        if current_download.is_none() {
+            to_download.push(current_version);
+        } else {
+            let downloaded_version = current_download.ok_or("SOMETHING_HAS_REALLY_GONE_WRONG")?;
+            if &current_version != downloaded_version {
+                to_disable.push((mod_id.clone(), String::from(downloaded_version)));
+                to_download.push(current_version);
+            }
+        }
+    }
+    
+    if !to_download.is_empty() {
+        download_versions(current_list.clone(), get_raw_versions(String::from(&config.apis.modrinth), to_download).await).await?;
+    } else {
+        println!("There are no new versions to download");
+    }
+    
+    if !to_disable.is_empty() {
+        for ver in to_disable {
+            if input.delete_old {
+                println!("Deleting version {} for mod {}", ver.1, ver.0);
+                delete_version(current_list.clone(), ver.1)?;
+            } else { 
+                disable_version(config.clone(), current_list.clone(), ver.1, ver.0)?;
+            };
         }
     }
-    */
 
-    Ok(String::new())
+    Ok(())
 }
-
-
diff --git a/src/commands/update.rs b/src/commands/update.rs
index eeb5a4d..498b6a9 100644
--- a/src/commands/update.rs
+++ b/src/commands/update.rs
@@ -1,6 +1,6 @@
-use std::{io::{Error, ErrorKind}, fs::rename};
+use std::io::{Error, ErrorKind};
 
-use crate::{config::Cfg, modrinth::{projects, Project, versions, extract_current_version, Version}, get_current_list, db::{userlist_get_all_ids, mods_get_versions, userlist_get_applicable_versions, userlist_change_versions, lists_get_all_ids, lists_get, userlist_get_current_version, userlist_add_disabled_versions, mods_change_versions}, List, input::Input, files::{get_file_path, delete_version, download_versions}};
+use crate::{config::Cfg, modrinth::{projects, Project, versions, extract_current_version, Version}, get_current_list, db::{userlist_get_all_ids, mods_get_versions, userlist_get_applicable_versions, userlist_change_versions, lists_get_all_ids, lists_get, userlist_get_current_version, mods_change_versions}, List, input::Input, files::{delete_version, download_versions, disable_version}};
 
 pub async fn update(config: Cfg, input: Input) -> Result<(), Box<dyn std::error::Error>> {
 
@@ -69,18 +69,21 @@ pub async fn update(config: Cfg, input: Input) -> Result<(), Box<dyn std::error:
             }
         }
         
-        if input.direct_download { download_versions(current_list.clone(), updatestack).await?; };
+        if input.direct_download {
+            download_versions(current_list.clone(), updatestack).await?;
+
+            //Disable old versions
+            for ver in current_versions {
+                if input.delete_old {
+                    println!("Deleting version {} for mod {}", ver.0, ver.1);
+                    delete_version(current_list.clone(), ver.0)?;
+                } else if ver.0 != "NONE" { 
+                    println!("Disabling version {} for mod {}", ver.0, ver.1);
+                    disable_version(config.clone(), current_list.clone(), ver.0, ver.1)?;
+                };
+            }
+        };
         
-        //Disable old versions
-        for ver in current_versions {
-            if input.delete_old {
-                println!("Deleting version {} for mod {}", ver.0, ver.1);
-                delete_version(current_list.clone(), ver.0)?;
-            } else if ver.0 != "NONE" { 
-                println!("Disabling version {} for mod {}", ver.0, ver.1);
-                disable_old(config.clone(), current_list.clone(), ver.0, ver.1)?;
-            };
-        }
     }
 
     Ok(())
@@ -120,18 +123,6 @@ async fn specific_update(config: Cfg, input: Input, list: List, project: Project
     Ok(current[0].clone())
 }
 
-fn disable_old(config: Cfg, current_list: List, versionid: String, mod_id: String) -> Result<(), Box<dyn std::error::Error>> {
-    println!("Disabling version {} for mod {}", versionid, mod_id);
-    let file = get_file_path(current_list.clone(), String::from(&versionid))?;
-    let disabled = format!("{}.disabled", file);
-
-    rename(file, disabled)?;
-
-    userlist_add_disabled_versions(config, current_list.id, versionid, mod_id)?;
-
-    Ok(())
-}
-
 #[tokio::test]
 async fn download_updates_test() {