phoenix/songparser
1
0
Fork 0
Code Issues 1 Pull Requests Actions Packages Projects Releases 42 Wiki Activity

Refactoring parsing

Browse Source
This commit is contained in:
phoenix
2025-10-26 15:32:35 -04:00
parent b0394c54bb
commit 6d2de0a21a
1 changed files with 78 additions and 69 deletions
Download Patch File Download Diff File Expand all files Collapse all files

109
src/parser/mod.rs
View File

@@ -139,15 +139,46 @@ pub async fn prep_song(
.await .await
{ {
Ok(response) => { Ok(response) => {
let id = &response.data[0].id; let bod = &response.data[0];
let created_at = &response.data[0].created_at; match process_coverart(app, &queued_song.id, bod).await {
let metadata = &response.data[0].metadata; Ok(qc) => {
Ok((queued_song, qc, bod.metadata.clone()))
}
Err(err) => {
Err(err)
}
}
}
Err(err) => Err(err),
}
}
Err(err) => Err(err),
}
}
Err(err) => Err(err),
}
}
Err(err) => Err(err),
}
}
pub async fn process_coverart(
app: &crate::config::App,
queued_song_id: &uuid::Uuid,
queued_item: &crate::api::get_metadata_queue::response::QueueItem
) -> Result<
crate::queued_item::QueuedCoverArt
, reqwest::Error> {
let id = queued_item.id;
let created_at = queued_item.created_at;
let metadata = &queued_item.metadata;
println!("Id: {id:?}"); println!("Id: {id:?}");
println!("Metadata: {metadata:?}"); println!("Metadata: {metadata:?}");
println!("Created at: {created_at:?}"); println!("Created at: {created_at:?}");
println!("Getting coverart queue"); println!("Getting coverart queue");
match crate::api::get_coverart_queue::get(app, &queued_song.id).await { match crate::api::get_coverart_queue::get(app, queued_song_id).await {
Ok(response) => { Ok(response) => {
match response.json::<crate::api::get_coverart_queue::response::Response>().await { match response.json::<crate::api::get_coverart_queue::response::Response>().await {
Ok(response) => { Ok(response) => {
@@ -158,10 +189,28 @@ pub async fn prep_song(
match crate::api::get_coverart_queue::get_data(app, &coverart_queue_id).await { match crate::api::get_coverart_queue::get_data(app, &coverart_queue_id).await {
Ok(response) => match crate::api::parsing::parse_response_into_bytes(response).await { Ok(response) => match crate::api::parsing::parse_response_into_bytes(response).await {
Ok(coverart_queue_bytes) => { Ok(coverart_queue_bytes) => {
let queued_coverart = init_queued_coverart(&coverart_queue_id, &coverart_queue.file_type, coverart_queue_bytes).await;
println!("Saved coverart queue file at: {:?}", queued_coverart.path);
Ok(queued_coverart)
}
Err(err) => Err(err)
}
Err(err) => Err(err)
}
}
Err(err) => Err(err)
}
}
Err(err) => Err(err),
}
}
async fn init_queued_coverart(coverart_queue_id: &uuid::Uuid, file_type: &str, bytes: Vec<u8>) -> crate::queued_item::QueuedCoverArt {
// TODO: Consider separating song and coverart when saving to the filesystem // TODO: Consider separating song and coverart when saving to the filesystem
let covart_type = if coverart_queue.file_type == "png" { let covart_type = if file_type == "png" {
icarus_models::types::CoverArtTypes::PngExtension icarus_models::types::CoverArtTypes::PngExtension
} else if coverart_queue.file_type == "jpeg" { } else if file_type == "jpeg" {
icarus_models::types::CoverArtTypes::JpegExtension icarus_models::types::CoverArtTypes::JpegExtension
} else { } else {
// TODO: This doesn't seem right // TODO: This doesn't seem right
@@ -170,58 +219,18 @@ pub async fn prep_song(
let coverart = icarus_models::coverart::CoverArt { let coverart = icarus_models::coverart::CoverArt {
directory: icarus_envy::environment::get_root_directory().await.value, directory: icarus_envy::environment::get_root_directory().await.value,
filename: icarus_models::coverart::generate_filename(covart_type, true), filename: icarus_models::coverart::generate_filename(covart_type, true),
data: coverart_queue_bytes, data: bytes,
..Default::default() ..Default::default()
}; };
coverart.save_to_filesystem().unwrap(); coverart.save_to_filesystem().unwrap();
let coverart_queue_fs_path = match coverart.get_path() { let coverart_queue_fs_path = coverart.get_path().unwrap();
Ok(path) => {
path
}
Err(err) => {
eprintln!("Error: {err:?}");
std::process::exit(-1);
}
};
let queued_coverart = crate::queued_item::QueuedCoverArt { let queued_coverart = crate::queued_item::QueuedCoverArt {
id: coverart_queue_id, id: *coverart_queue_id,
coverart, coverart,
path: coverart_queue_fs_path path: coverart_queue_fs_path
}; };
println!("Saved coverart queue file at: {:?}", queued_coverart.path); queued_coverart
Ok((queued_song, queued_coverart, metadata.clone()))
}
Err(err) => {
Err(err)
}
}
Err(err) => {
Err(err)
}
}
}
Err(err) => {
Err(err)
}
}
}
Err(err) => Err(err),
}
}
Err(err) => Err(err),
}
}
Err(err) => Err(err),
}
}
Err(err) => Err(err),
}
}
Err(err) => Err(err),
}
} }
pub async fn cleanup( pub async fn cleanup(