use crate::error::Error;
use crate::request::builder::MusicRequestBuilder;
use crate::request::context::ContextContainer;
use crate::request::paginated::paginate;
use crate::request::try_resource_response;
use crate::resource::catalog::artist::Artist;
use crate::resource::library::album::LibraryAlbum;
use crate::resource::relationship::Relationship;
use crate::resource::{ResourceHeader};
use crate::ApiClient;
use am_api_proc_macro::{Context, ResourceProperty};
use futures::Stream;
use serde::{Deserialize, Serialize};
use std::sync::Arc;
#[derive(Context, Serialize, Deserialize, Default, Debug, Clone, PartialEq, Eq, Hash)]
#[serde(rename_all = "camelCase")]
pub struct LibraryArtist {
#[context(skip)]
#[serde(flatten)]
pub header: ResourceHeader,
#[context(skip)]
#[serde(default)]
pub attributes: Option<LibraryArtistAttributes>,
#[serde(default)]
pub relationships: LibraryArtistRelationships,
}
#[derive(Serialize, Deserialize, Default, Debug, Clone, PartialEq, Eq, Hash)]
#[serde(rename_all = "camelCase", default)]
pub struct LibraryArtistAttributes {
pub name: String,
}
#[derive(
Context, ResourceProperty, Serialize, Deserialize, Default, Debug, Clone, PartialEq, Eq, Hash,
)]
#[serde(rename_all = "camelCase", default)]
#[resource_property(
LibraryArtistRelationshipType,
object = "library-artists",
relationship
)]
pub struct LibraryArtistRelationships {
pub albums: Option<Relationship<LibraryAlbum>>,
pub catalog: Option<Relationship<Artist>>,
}
pub struct LibraryArtistRequestBuilder;
pub type LibraryArtistGetRequestBuilder<'a> = MusicRequestBuilder<'a, LibraryArtistRequestBuilder>;
impl<'a> LibraryArtistGetRequestBuilder<'a> {
pub async fn one(
mut self,
client: &ApiClient,
id: &str,
) -> Result<Option<LibraryArtist>, Error> {
let request_context = Arc::new(self.get_request_context_drain(client));
let response = client
.get(&format!("/v1/me/library/artists/{id}"))
.query(&request_context.query)
.send()
.await?;
let mut response = try_resource_response(response).await?;
response.data.set_context(request_context);
Ok(response.data.into_iter().next())
}
pub async fn many(
mut self,
client: &ApiClient,
ids: &[&str],
) -> Result<Vec<LibraryArtist>, Error> {
let mut request_context = self.get_request_context_drain(client);
request_context
.query
.push((String::from("ids"), ids.to_vec().join(",")));
let request_context = Arc::new(request_context);
let response = client
.get("/v1/me/library/albums")
.query(&request_context.query)
.send()
.await?;
let mut response = try_resource_response(response).await?;
response.data.set_context(request_context);
Ok(response.data)
}
pub fn all(
mut self,
client: &ApiClient,
limit: usize,
offset: usize,
) -> impl Stream<Item = Result<LibraryArtist, Error>> {
let mut request_context = self.get_request_context_drain(client);
request_context
.query
.push((String::from("limit"), limit.to_string()));
paginate(
client.clone(),
String::from("/v1/me/library/artists"),
request_context,
offset,
)
}
}