From d67e3202789bab91cc8479c294b1240a5221bdaa Mon Sep 17 00:00:00 2001
From: KD <kundeng00@pm.me>
Date: Thu, 28 Aug 2025 16:44:55 -0400
Subject: [PATCH] Link queued coverart to queued song (#62)

* Added code to link queued coverart to queued song

* Code formatting
---
 src/managers/commit_manager.rs | 15 ++++++++++++---
 src/syncers/upload.rs          | 32 ++++++++++++++++++++++++++++++++
 2 files changed, 44 insertions(+), 3 deletions(-)

diff --git a/src/managers/commit_manager.rs b/src/managers/commit_manager.rs
index 00cd7d4..aebb9c6 100644
--- a/src/managers/commit_manager.rs
+++ b/src/managers/commit_manager.rs
@@ -454,9 +454,18 @@ impl CommitManager {
         println!("Queued metadata Id: {queued_metadata_id:?}");
 
         match up.queue_coverart(token, coverart).await {
-            Ok(id) => {
-                println!("Queued coverart Id: {id:?}");
-            }
+            Ok(id) => match up
+                .link_queued_song_to_queued_coverart(token, &queued_song_id, &id)
+                .await
+            {
+                Ok(_) => {
+                    println!("Queued coverart Id: {id:?}");
+                    println!("Linked queued song to queued coverart");
+                }
+                Err(err) => {
+                    return Err(std::io::Error::other(err.to_string()));
+                }
+            },
             Err(err) => {
                 return Err(std::io::Error::other(err.to_string()));
             }
diff --git a/src/syncers/upload.rs b/src/syncers/upload.rs
index f51ae60..fe2f088 100644
--- a/src/syncers/upload.rs
+++ b/src/syncers/upload.rs
@@ -268,6 +268,38 @@ impl Upload {
         }
     }
 
+    pub async fn link_queued_song_to_queued_coverart(
+        &self,
+        token: &icarus_models::token::AccessToken,
+        queued_song_id: &uuid::Uuid,
+        queued_coverart_id: &uuid::Uuid,
+    ) -> Result<(), reqwest::Error> {
+        let endpoint = String::from("api/v2/coverart/queue/link");
+        let url = format!("{}/{endpoint}", self.api.url);
+
+        let mut headers = reqwest::header::HeaderMap::new();
+        let (auth, auth_val) = syncers::common::auth_header(token).await;
+        headers.insert(auth, auth_val);
+
+        let payload = serde_json::json!({
+            "song_queue_id": queued_song_id,
+            "coverart_id": queued_coverart_id
+        });
+
+        let client = reqwest::Client::builder().build().unwrap();
+
+        match client
+            .patch(url)
+            .headers(headers)
+            .json(&payload)
+            .send()
+            .await
+        {
+            Ok(_) => Ok(()),
+            Err(err) => Err(err),
+        }
+    }
+
     fn init_form(
         &self,
         song: &icarus_models::song::Song,