Let it go

migrations/20250420185217_init_migration.sql

@@ -63,7 +63,7 @@ CREATE TABLE IF NOT EXISTS "song" (
     date_created timestamptz DEFAULT now(),
     filename TEXT NOT NULL,
     directory TEXT NOT NULL,
-    file_type TEXT NOT NULL,
+    file_key TEXT NOT NULL,
     user_id UUID NULL
     -- TODO: Add coverart id later. This will allow multiple songs to be linked to a single cover art
 );

src/callers/song.rs

@@ -143,9 +143,13 @@ pub mod endpoint {
             let lab_config = crate::util::maze::get_config();
             let lr = labyrinth::Labyrinth { config: lab_config };
 
+            println!("Wut?");
+
             match repo_queue::data::get_with_song_queue_id(&pool, &payload.song_queue_id).await {
                 Ok((_id, file_key, _bucket, _region, _)) => match lr.download(&file_key).await {
                     Ok(data) => {
+                        println!("Okay!");
+                        println!("File key: {:?}", file_key);
                         song.data = data;
                         let dir = std::path::Path::new(&song.directory);
                         if !dir.exists() {
@@ -161,6 +165,7 @@ pub mod endpoint {
                         }
 
                         song.file_key = format!("processed/song/{}", song.filename);
+                        println!("Processed file key: {:?}", song.file_key);
                         let data_of_song = labyrinth::Data {
                             raw_data: song.data.clone(),
                             ..Default::default()
@@ -177,12 +182,14 @@ pub mod endpoint {
                                     (axum::http::StatusCode::OK, axum::Json(response))
                                 }
                                 Err(err) => {
+                                    eprintln!("Error inserting");
                                     response.message =
                                         format!("{:?} song {:?}", err.to_string(), song);
                                     (axum::http::StatusCode::BAD_REQUEST, axum::Json(response))
                                 }
                             },
                             Err(err) => {
+                                eprintln!("Error uploading");
                                 eprintln!("Error: {err:?}");
                                 (
                                     axum::http::StatusCode::INTERNAL_SERVER_ERROR,

src/main.rs

@@ -1205,7 +1205,6 @@ mod tests {
 
         match sequence_flow::queue_song_and_coverart_flow(&app).await {
             Ok((resp_one, song_queue_id)) => {
-                assert!(false, "Got here 2");
                 let resp = util::get_resp_data::<
                     soaricarus_api::callers::queue::coverart::response::fetch_coverart_no_data::Response,
                 >(resp_one)

test_migrations/20250725213944_init.sql

@@ -61,7 +61,7 @@ CREATE TABLE IF NOT EXISTS "song" (
     date_created timestamptz DEFAULT now(),
     filename TEXT NOT NULL,
     directory TEXT NOT NULL,
-    file_type TEXT NOT NULL,
+    file_key TEXT NOT NULL,
     user_id UUID NULL
 );