Meris/refactor playable playcontext

CHANGELOG.md

@@ -4,6 +4,7 @@
 - ([#332](https://github.com/ramsayleung/rspotify/pull/332)) Fix typo in `RestrictionReason` enum values
 
 **Breaking changes**:
+- ([#305](https://github.com/ramsayleung/rspotify/pull/305)) The `Id` types have been refactored to maximize usability. Instead of focusing on having an object-safe trait and using `dyn`, we now have enums to group up the IDs. This is based on how [`enum_dispatch`](https://docs.rs/enum_dispatch) works, and it's not only easier to use, but also faster. It makes it possible to have borrowed IDs again, so we've chosen to use `Cow` internally for flexibility. Check out the docs for more information!
 - ([#325](https://github.com/ramsayleung/rspotify/pull/325)) The `auth_code`, `auth_code_pkce`, `client_creds`, `clients::base` and `clients::oauth` modules have been removed from the public API; you should access the same types from their parent modules instead
 - ([#326](https://github.com/ramsayleung/rspotify/pull/326)) The `rspotify::clients::mutex` module has been renamed to `rspotify::sync`
 - ([#330](https://github.com/ramsayleung/rspotify/pull/330)) `search` now accepts `Option<IncludeExternal>` instead of `Option<&IncludeExternal>`

examples/auth_code.rs

@@ -49,5 +49,5 @@ async fn main() {
         .current_playing(Some(&market), Some(&additional_types))
         .await;
 
-    println!("Response: {:?}", artists);
+    println!("Response: {artists:?}");
 }

examples/auth_code_pkce.rs

@@ -39,7 +39,7 @@ async fn main() {
 
     // Running the requests
     let history = spotify.current_playback(None, None::<Vec<_>>).await;
-    println!("Response: {:?}", history);
+    println!("Response: {history:?}");
 
     // Token refreshing works as well, but only with the one generated in the
     // previous request (they actually expire, unlike the regular code auth
@@ -51,5 +51,5 @@ async fn main() {
 
     // Running the requests again
     let history = spotify.current_playback(None, None::<Vec<_>>).await;
-    println!("Response after refreshing token: {:?}", history);
+    println!("Response after refreshing token: {history:?}");
 }

examples/client_creds.rs

@@ -33,7 +33,7 @@ async fn main() {
 
     // Running the requests
     let birdy_uri = AlbumId::from_uri("spotify:album:0sNOF9WDwhWunNAHPD3Baj").unwrap();
-    let albums = spotify.album(&birdy_uri).await;
+    let albums = spotify.album(birdy_uri).await;
 
-    println!("Response: {:#?}", albums);
+    println!("Response: {albums:#?}");
 }

examples/tasks.rs

@@ -28,7 +28,7 @@ async fn main() {
         let spotify = Arc::clone(&spotify);
         let wr = wr.clone();
         let handle = task::spawn(async move {
-            let albums = spotify.album(&id).await.unwrap();
+            let albums = spotify.album(id).await.unwrap();
             wr.send(albums).unwrap();
         });
 

examples/ureq/device.rs

@@ -18,5 +18,5 @@ fn main() {
 
     let devices = spotify.device();
 
-    println!("Request: {:?}", devices);
+    println!("Request: {devices:?}");
 }

examples/ureq/me.rs

@@ -17,5 +17,5 @@ fn main() {
     spotify.prompt_for_token(&url).unwrap();
 
     let user = spotify.me();
-    println!("Request: {:?}", user);
+    println!("Request: {user:?}");
 }

examples/ureq/search.rs

@@ -19,8 +19,8 @@ fn main() {
     let album_query = "album:arrival artist:abba";
     let result = spotify.search(album_query, &SearchType::Album, None, None, Some(10), None);
     match result {
-        Ok(album) => println!("searched album:{:?}", album),
-        Err(err) => println!("search error!{:?}", err),
+        Ok(album) => println!("Searched album: {album:?}"),
+        Err(err) => println!("Search error! {err:?}"),
     }
 
     let artist_query = "tania bowra";
@@ -33,8 +33,8 @@ fn main() {
         None,
     );
     match result {
-        Ok(album) => println!("searched artist:{:?}", album),
-        Err(err) => println!("search error!{:?}", err),
+        Ok(album) => println!("Searched artist: {album:?}"),
+        Err(err) => println!("Search error! {err:?}"),
     }
 
     let playlist_query = "\"doom metal\"";
@@ -47,8 +47,8 @@ fn main() {
         None,
     );
     match result {
-        Ok(album) => println!("searched playlist:{:?}", album),
-        Err(err) => println!("search error!{:?}", err),
+        Ok(album) => println!("Searched playlist: {album:?}"),
+        Err(err) => println!("Search error! {err:?}"),
     }
 
     let track_query = "abba";
@@ -61,15 +61,15 @@ fn main() {
         None,
     );
     match result {
-        Ok(album) => println!("searched track:{:?}", album),
-        Err(err) => println!("search error!{:?}", err),
+        Ok(album) => println!("Searched track: {album:?}"),
+        Err(err) => println!("Search error! {err:?}"),
     }
 
     let show_query = "love";
     let result = spotify.search(show_query, &SearchType::Show, None, None, Some(10), None);
     match result {
-        Ok(show) => println!("searched show:{:?}", show),
-        Err(err) => println!("search error!{:?}", err),
+        Ok(show) => println!("Searched show: {show:?}"),
+        Err(err) => println!("Search error! {err:?}"),
     }
 
     let episode_query = "love";
@@ -82,7 +82,7 @@ fn main() {
         None,
     );
     match result {
-        Ok(episode) => println!("searched episode:{:?}", episode),
-        Err(err) => println!("search error!{:?}", err),
+        Ok(episode) => println!("Searched episode: {episode:?}"),
+        Err(err) => println!("Search error! {err:?}"),
     }
 }

examples/ureq/seek_track.rs

@@ -17,7 +17,7 @@ fn main() {
     spotify.prompt_for_token(&url).unwrap();
 
     match spotify.seek_track(25000, None) {
-        Ok(_) => println!("change to previous playback successful"),
-        Err(_) => eprintln!("change to previous playback failed"),
+        Ok(_) => println!("Change to previous playback successful"),
+        Err(_) => eprintln!("Change to previous playback failed"),
     }
 }

examples/ureq/threading.rs

@@ -29,7 +29,7 @@ fn main() {
         let spotify = Arc::clone(&spotify);
         let wr = wr.clone();
         let handle = thread::spawn(move || {
-            let albums = spotify.album(&id).unwrap();
+            let albums = spotify.album(id).unwrap();
             wr.send(albums).unwrap();
         });
 

examples/webapp/Cargo.toml

@@ -1,12 +1,15 @@
 [package]
 name = "webapp"
 version = "0.1.0"
-authors = ["Ramsay <[email protected]>"]
+authors = [
+    "Ramsay Leung <[email protected]>",
+    "Mario Ortiz Manero <[email protected]>"
+]
 edition = "2018"
 
 [dependencies]
-rocket = "0.4.5"
-rocket_contrib = { version = "0.4.5", features = ["tera_templates"] }
-getrandom = "0.2.0"
+rocket = "0.4.10"
+rocket_contrib = { version = "0.4.10", features = ["tera_templates"] }
+getrandom = "0.2.6"
 # Rocket is synchronous, so this uses the `ureq` client
 rspotify = { path = "../..", features = ["client-ureq", "ureq-rustls-tls"], default-features = false }

examples/webapp/src/main.rs

@@ -14,13 +14,13 @@ use rocket::response::Redirect;
 use rocket_contrib::json;
 use rocket_contrib::json::JsonValue;
 use rocket_contrib::templates::Template;
-use rspotify::{scopes, AuthCodeSpotify, OAuth, Credentials, Config, prelude::*, Token};
+use rspotify::{prelude::*, scopes, AuthCodeSpotify, Config, Credentials, OAuth, Token};
 
-use std::fs;
 use std::{
     collections::HashMap,
-    env,
+    env, fs,
     path::PathBuf,
+    sync::{Arc, Mutex},
 };
 
 #[derive(Debug, Responder)]
@@ -95,7 +95,7 @@ fn init_spotify(cookies: &Cookies) -> AuthCodeSpotify {
     // Replacing client_id and client_secret with yours.
     let creds = Credentials::new(
         "e1dce60f1e274e20861ce5d96142a4d3",
-        "0e4e03b9be8d465d87fc32857a4b5aa3"
+        "0e4e03b9be8d465d87fc32857a4b5aa3",
     );
 
     AuthCodeSpotify::with_config(creds, oauth, config)
@@ -168,9 +168,10 @@ fn playlist(cookies: Cookies) -> AppResponse {
         return AppResponse::Redirect(Redirect::to("/"));
     }
 
-    let token = spotify.read_token_cache().unwrap();
-    spotify.token = Some(token);
-    let playlists = spotify.current_user_playlists()
+    let token = spotify.read_token_cache(false).unwrap();
+    spotify.token = Arc::new(Mutex::new(token));
+    let playlists = spotify
+        .current_user_playlists()
         .take(50)
         .filter_map(Result::ok)
         .collect::<Vec<_>>();
@@ -189,7 +190,7 @@ fn me(cookies: Cookies) -> AppResponse {
         return AppResponse::Redirect(Redirect::to("/"));
     }
 
-    spotify.token = Some(spotify.read_token_cache().unwrap());
+    spotify.token = Arc::new(Mutex::new(spotify.read_token_cache(false).unwrap()));
     match spotify.me() {
         Ok(user_info) => AppResponse::Json(json!(user_info)),
         Err(_) => AppResponse::Redirect(Redirect::to("/")),

examples/with_auto_reauth.rs

@@ -14,15 +14,16 @@ use rspotify::{
 // followed artists, and then unfollow the artists.
 async fn auth_code_do_things(spotify: &AuthCodeSpotify) {
     let artists = [
-        &ArtistId::from_id("3RGLhK1IP9jnYFH4BRFJBS").unwrap(), // The Clash
-        &ArtistId::from_id("0yNLKJebCb8Aueb54LYya3").unwrap(), // New Order
-        &ArtistId::from_id("2jzc5TC5TVFLXQlBNiIUzE").unwrap(), // a-ha
+        ArtistId::from_id("3RGLhK1IP9jnYFH4BRFJBS").unwrap(), // The Clash
+        ArtistId::from_id("0yNLKJebCb8Aueb54LYya3").unwrap(), // New Order
+        ArtistId::from_id("2jzc5TC5TVFLXQlBNiIUzE").unwrap(), // a-ha
     ];
+    let num_artists = artists.len();
     spotify
-        .user_follow_artists(artists)
+        .user_follow_artists(artists.iter().map(|a| a.as_ref()))
         .await
         .expect("couldn't follow artists");
-    println!("Followed {} artists successfully.", artists.len());
+    println!("Followed {num_artists} artists successfully.");
 
     // Printing the followed artists
     let followed = spotify
@@ -38,13 +39,13 @@ async fn auth_code_do_things(spotify: &AuthCodeSpotify) {
         .user_unfollow_artists(artists)
         .await
         .expect("couldn't unfollow artists");
-    println!("Unfollowed {} artists successfully.", artists.len());
+    println!("Unfollowed {num_artists} artists successfully.");
 }
 
 async fn client_creds_do_things(spotify: &ClientCredsSpotify) {
     // Running the requests
     let birdy_uri = AlbumId::from_uri("spotify:album:0sNOF9WDwhWunNAHPD3Baj").unwrap();
-    let albums = spotify.album(&birdy_uri).await;
+    let albums = spotify.album(birdy_uri).await;
     println!("Get albums: {}", albums.unwrap().id);
 }
 

examples/with_refresh_token.rs

@@ -21,15 +21,16 @@ use rspotify::{model::ArtistId, prelude::*, scopes, AuthCodeSpotify, Credentials
 // followed artists, and then unfollow the artists.
 async fn do_things(spotify: AuthCodeSpotify) {
     let artists = [
-        &ArtistId::from_id("3RGLhK1IP9jnYFH4BRFJBS").unwrap(), // The Clash
-        &ArtistId::from_id("0yNLKJebCb8Aueb54LYya3").unwrap(), // New Order
-        &ArtistId::from_id("2jzc5TC5TVFLXQlBNiIUzE").unwrap(), // a-ha
+        ArtistId::from_id("3RGLhK1IP9jnYFH4BRFJBS").unwrap(), // The Clash
+        ArtistId::from_id("0yNLKJebCb8Aueb54LYya3").unwrap(), // New Order
+        ArtistId::from_id("2jzc5TC5TVFLXQlBNiIUzE").unwrap(), // a-ha
     ];
+    let num_artists = artists.len();
     spotify
-        .user_follow_artists(artists)
+        .user_follow_artists(artists.iter().map(|a| a.as_ref()))
         .await
         .expect("couldn't follow artists");
-    println!("Followed {} artists successfully.", artists.len());
+    println!("Followed {num_artists} artists successfully.");
 
     // Printing the followed artists
     let followed = spotify
@@ -45,7 +46,7 @@ async fn do_things(spotify: AuthCodeSpotify) {
         .user_unfollow_artists(artists)
         .await
         .expect("couldn't unfollow artists");
-    println!("Unfollowed {} artists successfully.", artists.len());
+    println!("Unfollowed {num_artists} artists successfully.");
 }
 
 #[tokio::main]

rspotify-model/Cargo.toml

@@ -15,8 +15,8 @@ readme = "../README.md"
 
 [dependencies]
 chrono = { version = "0.4.19", features = ["serde", "rustc-serialize"] }
+enum_dispatch = "0.3.8"
 serde = { version = "1.0.130", features = ["derive"] }
 serde_json = "1.0.67"
 strum = { version = "0.24.0", features = ["derive"] }
 thiserror = "1.0.29"
-

rspotify-model/src/album.rs

@@ -21,7 +21,7 @@ pub struct SimplifiedAlbum {
     pub available_markets: Vec<String>,
     pub external_urls: HashMap<String, String>,
     pub href: Option<String>,
-    pub id: Option<AlbumId>,
+    pub id: Option<AlbumId<'static>>,
     pub images: Vec<Image>,
     pub name: String,
     #[serde(skip_serializing_if = "Option::is_none")]
@@ -43,7 +43,7 @@ pub struct FullAlbum {
     pub external_urls: HashMap<String, String>,
     pub genres: Vec<String>,
     pub href: String,
-    pub id: AlbumId,
+    pub id: AlbumId<'static>,
     pub images: Vec<Image>,
     pub name: String,
     pub popularity: u32,

rspotify-model/src/artist.rs

@@ -11,7 +11,7 @@ use crate::{ArtistId, CursorBasedPage, Followers, Image};
 pub struct SimplifiedArtist {
     pub external_urls: HashMap<String, String>,
     pub href: Option<String>,
-    pub id: Option<ArtistId>,
+    pub id: Option<ArtistId<'static>>,
     pub name: String,
 }
 
@@ -22,7 +22,7 @@ pub struct FullArtist {
     pub followers: Followers,
     pub genres: Vec<String>,
     pub href: String,
-    pub id: ArtistId,
+    pub id: ArtistId<'static>,
     pub images: Vec<Image>,
     pub name: String,
     pub popularity: u32,

rspotify-model/src/audio.rs

@@ -18,7 +18,7 @@ pub struct AudioFeatures {
     #[serde(with = "duration_ms", rename = "duration_ms")]
     pub duration: Duration,
     pub energy: f32,
-    pub id: TrackId,
+    pub id: TrackId<'static>,
     pub instrumentalness: f32,
     pub key: i32,
     pub liveness: f32,