feat: starting to add ability to like all songs

still need to add YtMusic support + properly handle CLI arg

Author: SilentVoid13

src/args.rs

@@ -13,6 +13,9 @@ pub struct RootArgs {
     #[arg(long, default_value = "false")]
     pub debug: bool,
 
+    /// Like all songs that will be sychronized on the destination platform
+    pub like_all: bool,
+
     /// Proxy to use for all requests in the format http://<ip>:<port>
     #[arg(long)]
     pub proxy: Option<String>,

src/music_api.rs

@@ -53,6 +53,8 @@ pub trait MusicApi {
         let results = try_join_all(requests).await?;
         Ok(results)
     }
+
+    async fn like_songs(&self, songs: &[Song]) -> Result<()>;
 }
 
 #[derive(Deserialize, Serialize, Clone, Debug, PartialEq, Eq)]

src/spotify/mod.rs

@@ -33,6 +33,7 @@ pub struct SpotifyApi {
 enum HttpMethod<'a> {
     Get(&'a [(&'a str, &'a str)]),
     Post(&'a serde_json::Value),
+    Put(&'a serde_json::Value),
     Delete(&'a serde_json::Value),
 }
 
@@ -43,6 +44,7 @@ impl SpotifyApi {
     const SCOPES: &'static [&'static str] = &[
         "user-read-email",
         "user-read-private",
+        "user-library-modify",
         "playlist-read-collaborative",
         "playlist-modify-public",
         "playlist-read-private",
@@ -200,9 +202,10 @@ impl SpotifyApi {
         let mut request = match method {
             HttpMethod::Get(p) => self.client.get(endpoint).query(p),
             HttpMethod::Post(b) => self.client.post(endpoint).json(b),
+            HttpMethod::Put(b) => self.client.put(endpoint).json(b),
             HttpMethod::Delete(b) => self.client.delete(endpoint).json(b),
         };
-        request = request.query(&[("limit", limit), ("offset", offset)]);
+        //request = request.query(&[("limit", limit), ("offset", offset)]);
         let res = request.send().await?;
         if res.status() == StatusCode::TOO_MANY_REQUESTS {
             self.api_rate_wait(&res).await?;
@@ -411,6 +414,20 @@ impl MusicApi for SpotifyApi {
         }
         return Ok(None);
     }
+
+    async fn like_songs(&self, songs: &[Song]) -> Result<()> {
+        // NOTE: A maximum of 50 items can be specified in one request
+        for songs_chunk in songs.chunks(50) {
+            let ids: Vec<&str> = songs_chunk.iter().map(|s| s.id.as_str()).collect();
+            let body = json!({
+                "ids": ids,
+            });
+            dbg!(&body);
+            self.make_request("/me/tracks", &HttpMethod::Put(&body), 50, 0)
+                .await?;
+        }
+        Ok(())
+    }
 }
 
 #[cfg(test)]

src/tidal/mod.rs

@@ -31,6 +31,7 @@ pub struct TidalApi {
 #[derive(Debug)]
 enum HttpMethod<'a> {
     Get(&'a serde_json::Value),
+    Post(&'a serde_json::Value),
     Put(&'a serde_json::Value),
 }
 
@@ -182,6 +183,7 @@ impl TidalApi {
     ) -> Result<Response> {
         let mut request = match method {
             HttpMethod::Get(p) => self.client.get(url).query(p),
+            HttpMethod::Post(b) => self.client.post(url).form(b),
             HttpMethod::Put(b) => self.client.put(url).form(b),
         };
         if let Some((limit, offset)) = lim_off {
@@ -371,4 +373,25 @@ impl MusicApi for TidalApi {
         }
         Ok(None)
     }
+
+    async fn like_songs(&self, songs: &[Song]) -> Result<()> {
+        let url = format!(
+            "{}/v1/users/{}/favorites/tracks",
+            Self::API_URL,
+            self.user_id
+        );
+        let tracks = songs
+            .iter()
+            .map(|s| s.id.as_str())
+            .collect::<Vec<_>>()
+            .join(",");
+        let params = json!({
+            "countryCode": self.country_code,
+            "trackIds": tracks,
+            "onArtifactNotFound": "FAIL",
+        });
+        self.make_request(&url, &HttpMethod::Post(&params), None)
+            .await?;
+        Ok(())
+    }
 }

src/yt_music/mod.rs

@@ -379,6 +379,10 @@ impl MusicApi for YtMusicApi {
         }
         Ok(None)
     }
+
+    async fn like_songs(&self, _songs: &[Song]) -> Result<()> {
+        todo!();
+    }
 }
 
 #[cfg(test)]