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

Code cleanup
Some checks failed
Rust Build / Check (pull_request) Failing after 33s
Details
Rust Build / Test Suite (pull_request) Failing after 34s
Details
Rust Build / Rustfmt (pull_request) Successful in 26s
Details
Rust Build / Clippy (pull_request) Failing after 31s
Details
Rust Build / build (pull_request) Failing after 33s
Details

Browse Source
This commit is contained in:
kdeng00
2025-06-13 21:14:07 -04:00
parent eaa3c6f40e
commit 420ba98622
1 changed files with 87 additions and 78 deletions
Download Patch File Download Diff File Expand all files Collapse all files

165
src/main.rs
View File

@@ -9,87 +9,21 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
loop { loop {
println!("Base URL: {}", app_base_url); println!("Base URL: {}", app_base_url);
match api::fetch_next_queue_item(&app_base_url).await { match is_queue_empty(&app_base_url).await {
Ok(response) => { Ok((empty, song_queue_item)) => {
match response if !empty {
.json::<responses::fetch_next_queue_item::SongQueueItem>() println!("Queue is not empty");
.await println!("SongQueueItem: {:?}", song_queue_item);
{ let song_queue_id = song_queue_item.data[0].id;
Ok(song_queue_item) => {
if !song_queue_item.data.is_empty() {
println!("Song queue item: {:?}", song_queue_item);
let song_queue_id = song_queue_item.data[0].id;
println!("Fetching song queue data"); process_song(&app_base_url, &song_queue_id);
match api::fetch_song_queue_data::get_data( } else {
&app_base_url, println!("Queue is empty");
&song_queue_id,
)
.await
{
Ok(response) => {
// Process data here...
let all_bytes =
api::fetch_song_queue_data::response::parse_response(
response,
)
.await?;
let (directory, filename) =
generate_song_queue_dir_and_filename().await;
let save_path =
save_song_to_fs(&directory, &filename, &all_bytes).await;
println!("Saved at: {:?}", save_path);
match api::get_metadata_queue::get(
&app_base_url,
&song_queue_id,
)
.await
{
Ok(response) => {
match response.json::<api::get_metadata_queue::response::Response>().await {
Ok(response) => {
let id = &response.data[0].id;
let metadata = &response.data[0].metadata;
let created_at = &response.data[0].created_at;
println!("Id: {:?}", id);
println!("Metadata: {:?}", metadata);
println!("Created at: {:?}", created_at);
// TODO: Get queued coverart
// TODO: Get queued coverart's data
// TODO: Apply metadata to the queued song (modifying file)
// TODO: Update the queued song with the updated queued song
// TODO: Create song
// TODO: Create coverart
// TODO: Wipe data from queued song
// TODO: Wipe data from queued coverart
}
Err(err) => {
eprintln!("Error: {:?}", err);
}
}
}
Err(err) => {
eprintln!("Error: {:?}", err);
}
}
}
Err(err) => {
eprintln!("Error fetching song queue data: {:?}", err);
}
}
} else {
println!("No data to fetch");
}
}
Err(err) => {
eprintln!("Error: {:?}", err);
}
} }
} }
Err(e) => eprintln!("API call failed: {}", e), Err(err) => {
eprintln!("Error: {:?}", err);
}
} }
println!("Sleeping"); println!("Sleeping");
@@ -97,6 +31,81 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
} }
} }
async fn is_queue_empty(
api_url: &String,
) -> Result<(bool, responses::fetch_next_queue_item::SongQueueItem), reqwest::Error> {
match api::fetch_next_queue_item(api_url).await {
Ok(response) => {
match response
.json::<responses::fetch_next_queue_item::SongQueueItem>()
.await
{
Ok(response) => {
if response.data.is_empty() {
Ok((true, response))
} else {
Ok((false, response))
}
}
Err(err) => Err(err),
}
}
Err(err) => Err(err),
}
}
async fn process_song(api_url: &String, song_queue_id: &uuid::Uuid) {
match api::fetch_song_queue_data::get_data(&api_url, &song_queue_id).await {
Ok(response) => {
// Process data here...
match api::fetch_song_queue_data::response::parse_response(response).await {
Ok(all_bytes) => {
let (directory, filename) = generate_song_queue_dir_and_filename().await;
let save_path = save_song_to_fs(&directory, &filename, &all_bytes).await;
println!("Saved at: {:?}", save_path);
match api::get_metadata_queue::get(&api_url, &song_queue_id).await {
Ok(response) => {
match response
.json::<api::get_metadata_queue::response::Response>()
.await
{
Ok(response) => {
let id = &response.data[0].id;
let metadata = &response.data[0].metadata;
let created_at = &response.data[0].created_at;
println!("Id: {:?}", id);
println!("Metadata: {:?}", metadata);
println!("Created at: {:?}", created_at);
// TODO: Get queued coverart
// TODO: Get queued coverart's data
// TODO: Apply metadata to the queued song (modifying file)
// TODO: Update the queued song with the updated queued song
// TODO: Create song
// TODO: Create coverart
// TODO: Wipe data from queued song
// TODO: Wipe data from queued coverart
}
Err(err) => {
eprintln!("Error: {:?}", err);
}
}
}
Err(err) => {
eprintln!("Error: {:?}", err);
}
}
}
Err(err) => {}
}
}
Err(err) => {
eprintln!("Error fetching song queue data: {:?}", err);
}
}
}
// TODO: Consider having something like this in icarus_models // TODO: Consider having something like this in icarus_models
pub async fn generate_song_queue_dir_and_filename() -> (String, String) { pub async fn generate_song_queue_dir_and_filename() -> (String, String) {
let mut song = icarus_models::song::Song::default(); let mut song = icarus_models::song::Song::default();