diff --git a/src/callers/queue/song.rs b/src/callers/queue/song.rs index 8b1e99b..a2b99f1 100644 --- a/src/callers/queue/song.rs +++ b/src/callers/queue/song.rs @@ -160,7 +160,6 @@ pub mod endpoint { match super::is_song_valid(&raw_data).await { Ok(valid) => { if valid { - println!("Go"); match repo::song::insert( &pool, &file_name, @@ -179,23 +178,13 @@ pub mod endpoint { raw_data: copied_raw_data, ..Default::default() }; - /* - let filename = simodels::song::generate_filename( - simodels::types::MusicType::FlacExtension, - true, - ) - .unwrap(); - */ + println!("Filename: {file_name:?}"); let file_path = format!("queued/song/{file_name}"); println!("Path: {file_path:?}"); match lr.upload(&file_path, &data).await { - Ok(res) => { - println!("Result: {res:?}"); - - println!("Saving to db"); - + Ok(_res) => { match repo::data::insert( &pool, &file_path, diff --git a/src/repo/queue/song.rs b/src/repo/queue/song.rs index 680f374..01a5922 100644 --- a/src/repo/queue/song.rs +++ b/src/repo/queue/song.rs @@ -251,53 +251,3 @@ pub async fn get_song_queue( Err(_err) => Err(sqlx::Error::RowNotFound), } } - -/* -pub async fn wipe_data(pool: &sqlx::PgPool, id: &uuid::Uuid) -> Result { - let result = sqlx::query( - r#" - UPDATE "songQueue" SET data = NULL WHERE id = $1 RETURNING id; - "#, - ) - .bind(id) - .fetch_one(pool) - .await - .map_err(|e| { - eprintln!("Error updating record: {e}"); - }); - - match result { - Ok(row) => Ok(row - .try_get("id") - .map_err(|_e| sqlx::Error::RowNotFound) - .unwrap()), - Err(_) => Err(sqlx::Error::RowNotFound), - } -} - -pub async fn get_data(pool: &sqlx::PgPool, id: &uuid::Uuid) -> Result, sqlx::Error> { - let result = sqlx::query( - r#" - SELECT data FROM "songQueue" - WHERE id = $1; - "#, - ) - .bind(id) - .fetch_one(pool) - .await - .map_err(|e| { - eprintln!("Error inserting: {e}"); - }); - - match result { - Ok(row) => { - let data = row - .try_get("data") - .map_err(|_e| sqlx::Error::RowNotFound) - .unwrap(); - Ok(data) - } - Err(_err) => Err(sqlx::Error::RowNotFound), - } -} -*/