From dc6fd622eee8b48fe50eba01567808e588f8e39d Mon Sep 17 00:00:00 2001
From: phoenix <kundeng00@pm.me>
Date: Tue, 15 Jul 2025 16:00:18 -0400
Subject: [PATCH] Added functionality to wipe data from coverart_queue

---
 src/main.rs     | 13 ++++++++++---
 src/the_rest.rs | 23 +++++++++++++++++++++++
 2 files changed, 33 insertions(+), 3 deletions(-)

diff --git a/src/main.rs b/src/main.rs
index 226db68..1173077 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -73,9 +73,16 @@ async fn wipe_data_from_queues(
             .json::<the_rest::wipe_data::song_queue::response::Response>()
             .await
         {
-            Ok(_resp) => {
-                println!("Wiped data from song queue");
-                Ok(())
+            Ok(_resp) => match the_rest::wipe_data::coverart_queue::wipe_data(app_base_url, coverart_queue_id).await {
+                Ok(inner_response) => match inner_response.json::<the_rest::wipe_data::coverart_queue::response::Response>().await {
+                    Ok(_inner_resp) => {
+                        println!("Wiped data from CoverArt queue");
+                        println!("Resp: {_inner_resp:?}");
+                        Ok(())
+                    }
+                    Err(err) => Err(std::io::Error::other(err.to_string()))
+                }
+                Err(err) => Err(std::io::Error::other(err.to_string()))
             }
             Err(err) => Err(std::io::Error::other(err.to_string())),
         },
diff --git a/src/the_rest.rs b/src/the_rest.rs
index b5fa85f..c806f0f 100644
--- a/src/the_rest.rs
+++ b/src/the_rest.rs
@@ -99,4 +99,27 @@ pub mod wipe_data {
         }
     }
     // TODO: Wipe data from queued coverart
+    pub mod coverart_queue {
+        pub async fn wipe_data(
+            base_url: &String,
+            coverart_queue_id: &uuid::Uuid,
+        ) -> Result<reqwest::Response, reqwest::Error> {
+            let client = reqwest::Client::builder().build()?;
+            let url = format!("{base_url}/api/v2/coverart/queue/data/wipe");
+            let payload = serde_json::json!({
+                "coverart_queue_id": coverart_queue_id
+            });
+            let request = client.patch(url).json(&payload);
+
+            request.send().await
+        }
+
+        pub mod response {
+            #[derive(Debug, serde::Deserialize, serde::Serialize)]
+            pub struct Response {
+                pub message: String,
+                pub data: Vec<uuid::Uuid>,
+            }
+        }
+    }
 }