From 00615532cea202037ef41981f2d2cb7c816d7bfb Mon Sep 17 00:00:00 2001 From: KD Date: Thu, 30 Oct 2025 15:33:09 -0400 Subject: [PATCH] icarus_models version bump (#93) * icarus_models version bump * Build fix * Removed method * Some refactoring * More cleanup * Version bump * Using standard version --- Cargo.lock | 6 ++-- Cargo.toml | 4 +-- src/managers/commit_manager.rs | 59 ++++++++++++++-------------------- src/managers/token_manager.rs | 17 +++------- 4 files changed, 35 insertions(+), 51 deletions(-) diff --git a/Cargo.lock b/Cargo.lock index fd486b5..f4a734d 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -451,7 +451,7 @@ dependencies = [ [[package]] name = "icarus-dm" -version = "0.8.10" +version = "0.8.11" dependencies = [ "futures", "http", @@ -466,8 +466,8 @@ dependencies = [ [[package]] name = "icarus_models" -version = "0.8.3" -source = "git+ssh://git@git.kundeng.us/phoenix/icarus_models.git?tag=v0.8.3#0a27b8ccb1ac40361df8d3131f567f37f06cdc08" +version = "0.9.2" +source = "git+ssh://git@git.kundeng.us/phoenix/icarus_models.git?tag=v0.9.2#05525618514409101c1d6474dafb201386d14a30" dependencies = [ "josekit", "rand", diff --git a/Cargo.toml b/Cargo.toml index a64f1fd..15359ef 100644 --- a/Cargo.toml +++ b/Cargo.toml @@ -1,6 +1,6 @@ [package] name = "icarus-dm" -version = "0.8.10" +version = "0.8.11" rust-version = "1.90" edition = "2024" @@ -14,4 +14,4 @@ serde_json = "1.0.145" tokio = { version = "1.47.1", features = ["full"] } tokio-util = { version = "0.7.16", features = ["codec"] } uuid = { version = "1.18.1", features = ["v4", "serde"] } -icarus_models = { git = "ssh://git@git.kundeng.us/phoenix/icarus_models.git", tag = "v0.8.3" } +icarus_models = { git = "ssh://git@git.kundeng.us/phoenix/icarus_models.git", tag = "v0.9.2" } diff --git a/src/managers/commit_manager.rs b/src/managers/commit_manager.rs index 31b476d..7973e40 100644 --- a/src/managers/commit_manager.rs +++ b/src/managers/commit_manager.rs @@ -131,7 +131,7 @@ impl CommitManager { } fn map_actions(&self) -> HashMap { - let actions: HashMap = HashMap::from([ + HashMap::from([ ("download".to_string(), ActionValues::DownloadAct), ("download".to_string(), ActionValues::DownloadAct), ( @@ -140,9 +140,7 @@ impl CommitManager { ), ("retrieve".to_string(), ActionValues::RetrieveAct), ("delete".to_string(), ActionValues::DeleteAct), - ]); - - actions + ]) } async fn delete_song(&self, token: &icarus_models::token::AccessToken) { @@ -189,10 +187,17 @@ impl CommitManager { song.data = o.as_bytes().to_vec(); song.directory = String::from("."); - song.filename = icarus_models::song::generate_filename( - icarus_models::types::MusicTypes::FlacExtension, + song.filename = match icarus_models::song::generate_filename( + icarus_models::types::MusicType::FlacExtension, true, - ); + ) { + Ok(filename) => filename, + Err(err) => { + eprintln!("Error generating song filename: {err:?}"); + utilities::checks::exit_program(-3); + return; + } + }; match song.save_to_filesystem() { Ok(_) => { println!("Song saved"); @@ -300,7 +305,7 @@ impl CommitManager { } else if multitarget { let _ = self.multi_target_upload(&uni, token).await; } else { - println!("Single or Multi target has not been chosen"); + eprintln!("Single or Multi target has not been chosen"); } } @@ -429,21 +434,14 @@ impl CommitManager { println!("Queued coverart Id: {id:?}"); println!("Linked queued song to queued coverart"); println!("Queued status updated"); + Ok(()) } - Err(err) => { - return Err(std::io::Error::other(err.to_string())); - } + Err(err) => Err(std::io::Error::other(err.to_string())), }, - Err(err) => { - return Err(std::io::Error::other(err.to_string())); - } + Err(err) => Err(std::io::Error::other(err.to_string())), }, - Err(err) => { - return Err(std::io::Error::other(err.to_string())); - } + Err(err) => Err(std::io::Error::other(err.to_string())), } - - Ok(()) } fn get_songs( @@ -486,7 +484,7 @@ impl CommitManager { } Ok(songs) } - Err(_) => Ok(Vec::new()), + Err(_) => Err(std::io::Error::other("Songs not retrieved")), } } @@ -531,7 +529,7 @@ impl CommitManager { println!("Response: {o:?}"); } Err(err) => { - println!("Error: {err:?}"); + eprintln!("Error: {err:?}"); return Err(err); } } @@ -540,12 +538,12 @@ impl CommitManager { Ok(()) } Err(err) => { - println!("Error: {err:?}"); + eprintln!("Error: {err:?}"); Err(std::io::Error::other(err.to_string())) } }, Err(error) => { - println!("Error: {error:?}"); + eprintln!("Error: {error:?}"); Err(std::io::Error::other(error.to_string())) } } @@ -567,7 +565,9 @@ impl CommitManager { } } - Ok((String::new(), String::new())) + Err(std::io::Error::other( + "CoverArt directory and filename not found", + )) } fn find_file_extension(&self, file_name: &std::ffi::OsString) -> En { @@ -635,15 +635,6 @@ impl CommitManager { } } - Ok(String::new()) - } - - fn _check_for_no_confirm(&self) -> bool { - for flag in self.ica_action.flags.iter() { - if flag.flag == "-nc" { - return true; - } - } - false + Err(std::io::Error::other("Metadata path not found")) } } diff --git a/src/managers/token_manager.rs b/src/managers/token_manager.rs index a539f0e..e6a53c3 100644 --- a/src/managers/token_manager.rs +++ b/src/managers/token_manager.rs @@ -23,7 +23,6 @@ impl Default for TokenManager { user: icarus_models::user::User::default(), api: models::api::Api::default(), }; - token.init(); token @@ -35,7 +34,6 @@ impl TokenManager { println!("Sending request for a token"); let url = self.retrieve_url(); - println!("URL: {url}"); let mut token = icarus_models::token::AccessToken { @@ -62,19 +60,18 @@ impl TokenManager { token.token_type = login_result.token_type.clone(); token.expiration = login_result.expiration; token.message = response.message; + Ok(token) } - Err(_) => println!("Hm, the response didn't match the shape we expected."), - }; + Err(err) => Err(std::io::Error::other(err.to_string())), + } } reqwest::StatusCode::UNAUTHORIZED => { - println!("Need to grab a new token"); + Err(std::io::Error::other("Need to grab a new token")) } other => { panic!("Uh oh! Something unexpected happened: {other:?}"); } } - - Ok(token) } pub fn init(&mut self) { @@ -84,10 +81,6 @@ impl TokenManager { } pub fn retrieve_url(&self) -> String { - let api = &self.api; - let mut url = String::from(&api.url); - url += &String::from(&api.endpoint); - - url + format!("{}{}", self.api.url, self.api.endpoint) } }