src/callers/queue/coverart.rs

@@ -197,13 +197,7 @@ pub mod endpoint {
 
                     match lr.upload(&file_path, &data).await {
                         Ok(_res) => {
-                            match repo::coverart::insert(
-                                &pool,
-                                &data.raw_data,
-                                &file_type.file_type,
-                            )
-                            .await
-                            {
+                            match repo::coverart::insert(&pool, &file_type.file_type).await {
                                 Ok(id) => {
                                     println!("Inserting queued data");
                                     match repo::data::queue::coverart::insert(

src/repo/queue/coverart.rs

@@ -1,16 +1,11 @@
 use sqlx::Row;
 
-pub async fn insert(
-    pool: &sqlx::PgPool,
-    data: &Vec<u8>,
-    file_type: &str,
-) -> Result<uuid::Uuid, sqlx::Error> {
+pub async fn insert(pool: &sqlx::PgPool, file_type: &str) -> Result<uuid::Uuid, sqlx::Error> {
     let result = sqlx::query(
         r#"
-        INSERT INTO "coverartQueue" (data, file_type) VALUES($1, $2) RETURNING id;
+        INSERT INTO "coverartQueue" (file_type) VALUES($1) RETURNING id;
         "#,
     )
-    .bind(data)
     .bind(file_type)
     .fetch_one(pool)
     .await
@@ -121,6 +116,7 @@ pub async fn get_coverart_queue_with_song_queue_id(
     }
 }
 
+/*
 pub async fn get_coverart_queue_data_with_id(
     pool: &sqlx::PgPool,
     id: &uuid::Uuid,
@@ -195,3 +191,4 @@ pub async fn wipe_data(
         Err(_) => Err(sqlx::Error::RowNotFound),
     }
 }
+*/