use super::{configuration, Error};
use crate::apis::ContentType;
use crate::{apis::ResponseContent, models};
use async_trait::async_trait;
use reqwest;
use serde::{de::Error as _, Deserialize, Serialize};
use std::sync::Arc;
#[async_trait]
pub trait UserCollectionsApi: Send + Sync {
async fn add_user_collection_albums<
'id,
'country_code,
'user_collection_albums_relationship_add_operation_payload,
>(
&self,
id: &'id str,
country_code: Option<&'country_code str>,
user_collection_albums_relationship_add_operation_payload: Option<
models::UserCollectionAlbumsRelationshipAddOperationPayload,
>,
) -> Result<(), Error<AddUserCollectionAlbumsError>>;
async fn add_user_collection_artists<
'id,
'country_code,
'user_collection_artists_relationship_add_operation_payload,
>(
&self,
id: &'id str,
country_code: Option<&'country_code str>,
user_collection_artists_relationship_add_operation_payload: Option<
models::UserCollectionArtistsRelationshipAddOperationPayload,
>,
) -> Result<(), Error<AddUserCollectionArtistsError>>;
async fn add_user_collection_playlists<
'id,
'user_collection_playlists_relationship_remove_operation_payload,
>(
&self,
id: &'id str,
user_collection_playlists_relationship_remove_operation_payload: Option<
models::UserCollectionPlaylistsRelationshipRemoveOperationPayload,
>,
) -> Result<(), Error<AddUserCollectionPlaylistsError>>;
async fn add_user_collection_tracks<
'id,
'country_code,
'user_collection_tracks_relationship_add_operation_payload,
>(
&self,
id: &'id str,
country_code: Option<&'country_code str>,
user_collection_tracks_relationship_add_operation_payload: Option<
models::UserCollectionTracksRelationshipAddOperationPayload,
>,
) -> Result<(), Error<AddUserCollectionTracksError>>;
async fn add_user_collection_videos<
'id,
'country_code,
'user_collection_videos_relationship_add_operation_payload,
>(
&self,
id: &'id str,
country_code: Option<&'country_code str>,
user_collection_videos_relationship_add_operation_payload: Option<
models::UserCollectionVideosRelationshipAddOperationPayload,
>,
) -> Result<(), Error<AddUserCollectionVideosError>>;
async fn delete_user_collection_albums<
'id,
'user_collection_albums_relationship_remove_operation_payload,
>(
&self,
id: &'id str,
user_collection_albums_relationship_remove_operation_payload: Option<
models::UserCollectionAlbumsRelationshipRemoveOperationPayload,
>,
) -> Result<(), Error<DeleteUserCollectionAlbumsError>>;
async fn delete_user_collection_artists<
'id,
'user_collection_artists_relationship_remove_operation_payload,
>(
&self,
id: &'id str,
user_collection_artists_relationship_remove_operation_payload: Option<
models::UserCollectionArtistsRelationshipRemoveOperationPayload,
>,
) -> Result<(), Error<DeleteUserCollectionArtistsError>>;
async fn delete_user_collection_tracks<
'id,
'user_collection_tracks_relationship_remove_operation_payload,
>(
&self,
id: &'id str,
user_collection_tracks_relationship_remove_operation_payload: Option<
models::UserCollectionTracksRelationshipRemoveOperationPayload,
>,
) -> Result<(), Error<DeleteUserCollectionTracksError>>;
async fn delete_user_collection_videos<
'id,
'user_collection_videos_relationship_remove_operation_payload,
>(
&self,
id: &'id str,
user_collection_videos_relationship_remove_operation_payload: Option<
models::UserCollectionVideosRelationshipRemoveOperationPayload,
>,
) -> Result<(), Error<DeleteUserCollectionVideosError>>;
async fn deleteuser_collection_playlists<
'id,
'user_collection_playlists_relationship_remove_operation_payload,
>(
&self,
id: &'id str,
user_collection_playlists_relationship_remove_operation_payload: Option<
models::UserCollectionPlaylistsRelationshipRemoveOperationPayload,
>,
) -> Result<(), Error<DeleteuserCollectionPlaylistsError>>;
async fn get_user_collection<'id, 'country_code, 'locale, 'include>(
&self,
id: &'id str,
country_code: Option<&'country_code str>,
locale: Option<&'locale str>,
include: Option<Vec<String>>,
) -> Result<models::UserCollectionsSingleResourceDataDocument, Error<GetUserCollectionError>>;
async fn get_user_collection_albums<
'id,
'page_cursor,
'sort,
'country_code,
'locale,
'include,
>(
&self,
id: &'id str,
page_cursor: Option<&'page_cursor str>,
sort: Option<Vec<String>>,
country_code: Option<&'country_code str>,
locale: Option<&'locale str>,
include: Option<Vec<String>>,
) -> Result<
models::UserCollectionsAlbumsMultiRelationshipDataDocument,
Error<GetUserCollectionAlbumsError>,
>;
async fn get_user_collection_artists<
'id,
'page_cursor,
'sort,
'country_code,
'locale,
'include,
>(
&self,
id: &'id str,
page_cursor: Option<&'page_cursor str>,
sort: Option<Vec<String>>,
country_code: Option<&'country_code str>,
locale: Option<&'locale str>,
include: Option<Vec<String>>,
) -> Result<
models::UserCollectionsArtistsMultiRelationshipDataDocument,
Error<GetUserCollectionArtistsError>,
>;
async fn get_user_collection_owners<'id, 'include, 'page_cursor>(
&self,
id: &'id str,
include: Option<Vec<String>>,
page_cursor: Option<&'page_cursor str>,
) -> Result<
models::UserCollectionsMultiRelationshipDataDocument,
Error<GetUserCollectionOwnersError>,
>;
async fn get_user_collection_playlists<'id, 'collection_view, 'page_cursor, 'sort, 'include>(
&self,
id: &'id str,
collection_view: Option<&'collection_view str>,
page_cursor: Option<&'page_cursor str>,
sort: Option<Vec<String>>,
include: Option<Vec<String>>,
) -> Result<
models::UserCollectionsPlaylistsMultiRelationshipDataDocument,
Error<GetUserCollectionPlaylistsError>,
>;
async fn get_user_collection_tracks<
'id,
'page_cursor,
'sort,
'country_code,
'locale,
'include,
>(
&self,
id: &'id str,
page_cursor: Option<&'page_cursor str>,
sort: Option<Vec<String>>,
country_code: Option<&'country_code str>,
locale: Option<&'locale str>,
include: Option<Vec<String>>,
) -> Result<
models::UserCollectionsTracksMultiRelationshipDataDocument,
Error<GetUserCollectionTracksError>,
>;
async fn get_user_collection_videos<
'id,
'page_cursor,
'sort,
'country_code,
'locale,
'include,
>(
&self,
id: &'id str,
page_cursor: Option<&'page_cursor str>,
sort: Option<Vec<String>>,
country_code: Option<&'country_code str>,
locale: Option<&'locale str>,
include: Option<Vec<String>>,
) -> Result<
models::UserCollectionsVideosMultiRelationshipDataDocument,
Error<GetUserCollectionVideosError>,
>;
}
#[derive(Clone)]
pub struct UserCollectionsApiClient {
configuration: Arc<configuration::Configuration>,
}
impl UserCollectionsApiClient {
pub fn new(configuration: Arc<configuration::Configuration>) -> Self {
Self { configuration }
}
}
#[async_trait]
impl UserCollectionsApi for UserCollectionsApiClient {
async fn add_user_collection_albums<
'id,
'country_code,
'user_collection_albums_relationship_add_operation_payload,
>(
&self,
id: &'id str,
country_code: Option<&'country_code str>,
user_collection_albums_relationship_add_operation_payload: Option<
models::UserCollectionAlbumsRelationshipAddOperationPayload,
>,
) -> Result<(), Error<AddUserCollectionAlbumsError>> {
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/userCollections/{id}/relationships/albums",
local_var_configuration.base_path,
id = crate::apis::urlencode(id)
);
let mut local_var_req_builder =
local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
if let Some(ref param_value) = country_code {
local_var_req_builder =
local_var_req_builder.query(&[("countryCode", ¶m_value.to_string())]);
}
if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
local_var_req_builder = local_var_req_builder
.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
}
if let Some(ref local_var_token) = local_var_configuration.oauth_access_token {
local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
};
local_var_req_builder =
local_var_req_builder.json(&user_collection_albums_relationship_add_operation_payload);
let local_var_req = local_var_req_builder.build()?;
let local_var_resp = local_var_client.execute(local_var_req).await?;
let local_var_status = local_var_resp.status();
let local_var_content = local_var_resp.text().await?;
if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
Ok(())
} else {
let local_var_entity: Option<AddUserCollectionAlbumsError> =
serde_json::from_str(&local_var_content).ok();
let local_var_error = ResponseContent {
status: local_var_status,
content: local_var_content,
entity: local_var_entity,
};
Err(Error::ResponseError(local_var_error))
}
}
async fn add_user_collection_artists<
'id,
'country_code,
'user_collection_artists_relationship_add_operation_payload,
>(
&self,
id: &'id str,
country_code: Option<&'country_code str>,
user_collection_artists_relationship_add_operation_payload: Option<
models::UserCollectionArtistsRelationshipAddOperationPayload,
>,
) -> Result<(), Error<AddUserCollectionArtistsError>> {
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/userCollections/{id}/relationships/artists",
local_var_configuration.base_path,
id = crate::apis::urlencode(id)
);
let mut local_var_req_builder =
local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
if let Some(ref param_value) = country_code {
local_var_req_builder =
local_var_req_builder.query(&[("countryCode", ¶m_value.to_string())]);
}
if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
local_var_req_builder = local_var_req_builder
.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
}
if let Some(ref local_var_token) = local_var_configuration.oauth_access_token {
local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
};
local_var_req_builder =
local_var_req_builder.json(&user_collection_artists_relationship_add_operation_payload);
let local_var_req = local_var_req_builder.build()?;
let local_var_resp = local_var_client.execute(local_var_req).await?;
let local_var_status = local_var_resp.status();
let local_var_content = local_var_resp.text().await?;
if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
Ok(())
} else {
let local_var_entity: Option<AddUserCollectionArtistsError> =
serde_json::from_str(&local_var_content).ok();
let local_var_error = ResponseContent {
status: local_var_status,
content: local_var_content,
entity: local_var_entity,
};
Err(Error::ResponseError(local_var_error))
}
}
async fn add_user_collection_playlists<
'id,
'user_collection_playlists_relationship_remove_operation_payload,
>(
&self,
id: &'id str,
user_collection_playlists_relationship_remove_operation_payload: Option<
models::UserCollectionPlaylistsRelationshipRemoveOperationPayload,
>,
) -> Result<(), Error<AddUserCollectionPlaylistsError>> {
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/userCollections/{id}/relationships/playlists",
local_var_configuration.base_path,
id = crate::apis::urlencode(id)
);
let mut local_var_req_builder =
local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
local_var_req_builder = local_var_req_builder
.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
}
if let Some(ref local_var_token) = local_var_configuration.oauth_access_token {
local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
};
local_var_req_builder = local_var_req_builder
.json(&user_collection_playlists_relationship_remove_operation_payload);
let local_var_req = local_var_req_builder.build()?;
let local_var_resp = local_var_client.execute(local_var_req).await?;
let local_var_status = local_var_resp.status();
let local_var_content = local_var_resp.text().await?;
if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
Ok(())
} else {
let local_var_entity: Option<AddUserCollectionPlaylistsError> =
serde_json::from_str(&local_var_content).ok();
let local_var_error = ResponseContent {
status: local_var_status,
content: local_var_content,
entity: local_var_entity,
};
Err(Error::ResponseError(local_var_error))
}
}
async fn add_user_collection_tracks<
'id,
'country_code,
'user_collection_tracks_relationship_add_operation_payload,
>(
&self,
id: &'id str,
country_code: Option<&'country_code str>,
user_collection_tracks_relationship_add_operation_payload: Option<
models::UserCollectionTracksRelationshipAddOperationPayload,
>,
) -> Result<(), Error<AddUserCollectionTracksError>> {
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/userCollections/{id}/relationships/tracks",
local_var_configuration.base_path,
id = crate::apis::urlencode(id)
);
let mut local_var_req_builder =
local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
if let Some(ref param_value) = country_code {
local_var_req_builder =
local_var_req_builder.query(&[("countryCode", ¶m_value.to_string())]);
}
if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
local_var_req_builder = local_var_req_builder
.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
}
if let Some(ref local_var_token) = local_var_configuration.oauth_access_token {
local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
};
local_var_req_builder =
local_var_req_builder.json(&user_collection_tracks_relationship_add_operation_payload);
let local_var_req = local_var_req_builder.build()?;
let local_var_resp = local_var_client.execute(local_var_req).await?;
let local_var_status = local_var_resp.status();
let local_var_content = local_var_resp.text().await?;
if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
Ok(())
} else {
let local_var_entity: Option<AddUserCollectionTracksError> =
serde_json::from_str(&local_var_content).ok();
let local_var_error = ResponseContent {
status: local_var_status,
content: local_var_content,
entity: local_var_entity,
};
Err(Error::ResponseError(local_var_error))
}
}
async fn add_user_collection_videos<
'id,
'country_code,
'user_collection_videos_relationship_add_operation_payload,
>(
&self,
id: &'id str,
country_code: Option<&'country_code str>,
user_collection_videos_relationship_add_operation_payload: Option<
models::UserCollectionVideosRelationshipAddOperationPayload,
>,
) -> Result<(), Error<AddUserCollectionVideosError>> {
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/userCollections/{id}/relationships/videos",
local_var_configuration.base_path,
id = crate::apis::urlencode(id)
);
let mut local_var_req_builder =
local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
if let Some(ref param_value) = country_code {
local_var_req_builder =
local_var_req_builder.query(&[("countryCode", ¶m_value.to_string())]);
}
if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
local_var_req_builder = local_var_req_builder
.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
}
if let Some(ref local_var_token) = local_var_configuration.oauth_access_token {
local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
};
local_var_req_builder =
local_var_req_builder.json(&user_collection_videos_relationship_add_operation_payload);
let local_var_req = local_var_req_builder.build()?;
let local_var_resp = local_var_client.execute(local_var_req).await?;
let local_var_status = local_var_resp.status();
let local_var_content = local_var_resp.text().await?;
if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
Ok(())
} else {
let local_var_entity: Option<AddUserCollectionVideosError> =
serde_json::from_str(&local_var_content).ok();
let local_var_error = ResponseContent {
status: local_var_status,
content: local_var_content,
entity: local_var_entity,
};
Err(Error::ResponseError(local_var_error))
}
}
async fn delete_user_collection_albums<
'id,
'user_collection_albums_relationship_remove_operation_payload,
>(
&self,
id: &'id str,
user_collection_albums_relationship_remove_operation_payload: Option<
models::UserCollectionAlbumsRelationshipRemoveOperationPayload,
>,
) -> Result<(), Error<DeleteUserCollectionAlbumsError>> {
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/userCollections/{id}/relationships/albums",
local_var_configuration.base_path,
id = crate::apis::urlencode(id)
);
let mut local_var_req_builder =
local_var_client.request(reqwest::Method::DELETE, local_var_uri_str.as_str());
if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
local_var_req_builder = local_var_req_builder
.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
}
if let Some(ref local_var_token) = local_var_configuration.oauth_access_token {
local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
};
local_var_req_builder = local_var_req_builder
.json(&user_collection_albums_relationship_remove_operation_payload);
let local_var_req = local_var_req_builder.build()?;
let local_var_resp = local_var_client.execute(local_var_req).await?;
let local_var_status = local_var_resp.status();
let local_var_content = local_var_resp.text().await?;
if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
Ok(())
} else {
let local_var_entity: Option<DeleteUserCollectionAlbumsError> =
serde_json::from_str(&local_var_content).ok();
let local_var_error = ResponseContent {
status: local_var_status,
content: local_var_content,
entity: local_var_entity,
};
Err(Error::ResponseError(local_var_error))
}
}
async fn delete_user_collection_artists<
'id,
'user_collection_artists_relationship_remove_operation_payload,
>(
&self,
id: &'id str,
user_collection_artists_relationship_remove_operation_payload: Option<
models::UserCollectionArtistsRelationshipRemoveOperationPayload,
>,
) -> Result<(), Error<DeleteUserCollectionArtistsError>> {
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/userCollections/{id}/relationships/artists",
local_var_configuration.base_path,
id = crate::apis::urlencode(id)
);
let mut local_var_req_builder =
local_var_client.request(reqwest::Method::DELETE, local_var_uri_str.as_str());
if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
local_var_req_builder = local_var_req_builder
.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
}
if let Some(ref local_var_token) = local_var_configuration.oauth_access_token {
local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
};
local_var_req_builder = local_var_req_builder
.json(&user_collection_artists_relationship_remove_operation_payload);
let local_var_req = local_var_req_builder.build()?;
let local_var_resp = local_var_client.execute(local_var_req).await?;
let local_var_status = local_var_resp.status();
let local_var_content = local_var_resp.text().await?;
if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
Ok(())
} else {
let local_var_entity: Option<DeleteUserCollectionArtistsError> =
serde_json::from_str(&local_var_content).ok();
let local_var_error = ResponseContent {
status: local_var_status,
content: local_var_content,
entity: local_var_entity,
};
Err(Error::ResponseError(local_var_error))
}
}
async fn delete_user_collection_tracks<
'id,
'user_collection_tracks_relationship_remove_operation_payload,
>(
&self,
id: &'id str,
user_collection_tracks_relationship_remove_operation_payload: Option<
models::UserCollectionTracksRelationshipRemoveOperationPayload,
>,
) -> Result<(), Error<DeleteUserCollectionTracksError>> {
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/userCollections/{id}/relationships/tracks",
local_var_configuration.base_path,
id = crate::apis::urlencode(id)
);
let mut local_var_req_builder =
local_var_client.request(reqwest::Method::DELETE, local_var_uri_str.as_str());
if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
local_var_req_builder = local_var_req_builder
.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
}
if let Some(ref local_var_token) = local_var_configuration.oauth_access_token {
local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
};
local_var_req_builder = local_var_req_builder
.json(&user_collection_tracks_relationship_remove_operation_payload);
let local_var_req = local_var_req_builder.build()?;
let local_var_resp = local_var_client.execute(local_var_req).await?;
let local_var_status = local_var_resp.status();
let local_var_content = local_var_resp.text().await?;
if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
Ok(())
} else {
let local_var_entity: Option<DeleteUserCollectionTracksError> =
serde_json::from_str(&local_var_content).ok();
let local_var_error = ResponseContent {
status: local_var_status,
content: local_var_content,
entity: local_var_entity,
};
Err(Error::ResponseError(local_var_error))
}
}
async fn delete_user_collection_videos<
'id,
'user_collection_videos_relationship_remove_operation_payload,
>(
&self,
id: &'id str,
user_collection_videos_relationship_remove_operation_payload: Option<
models::UserCollectionVideosRelationshipRemoveOperationPayload,
>,
) -> Result<(), Error<DeleteUserCollectionVideosError>> {
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/userCollections/{id}/relationships/videos",
local_var_configuration.base_path,
id = crate::apis::urlencode(id)
);
let mut local_var_req_builder =
local_var_client.request(reqwest::Method::DELETE, local_var_uri_str.as_str());
if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
local_var_req_builder = local_var_req_builder
.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
}
if let Some(ref local_var_token) = local_var_configuration.oauth_access_token {
local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
};
local_var_req_builder = local_var_req_builder
.json(&user_collection_videos_relationship_remove_operation_payload);
let local_var_req = local_var_req_builder.build()?;
let local_var_resp = local_var_client.execute(local_var_req).await?;
let local_var_status = local_var_resp.status();
let local_var_content = local_var_resp.text().await?;
if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
Ok(())
} else {
let local_var_entity: Option<DeleteUserCollectionVideosError> =
serde_json::from_str(&local_var_content).ok();
let local_var_error = ResponseContent {
status: local_var_status,
content: local_var_content,
entity: local_var_entity,
};
Err(Error::ResponseError(local_var_error))
}
}
async fn deleteuser_collection_playlists<
'id,
'user_collection_playlists_relationship_remove_operation_payload,
>(
&self,
id: &'id str,
user_collection_playlists_relationship_remove_operation_payload: Option<
models::UserCollectionPlaylistsRelationshipRemoveOperationPayload,
>,
) -> Result<(), Error<DeleteuserCollectionPlaylistsError>> {
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/userCollections/{id}/relationships/playlists",
local_var_configuration.base_path,
id = crate::apis::urlencode(id)
);
let mut local_var_req_builder =
local_var_client.request(reqwest::Method::DELETE, local_var_uri_str.as_str());
if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
local_var_req_builder = local_var_req_builder
.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
}
if let Some(ref local_var_token) = local_var_configuration.oauth_access_token {
local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
};
local_var_req_builder = local_var_req_builder
.json(&user_collection_playlists_relationship_remove_operation_payload);
let local_var_req = local_var_req_builder.build()?;
let local_var_resp = local_var_client.execute(local_var_req).await?;
let local_var_status = local_var_resp.status();
let local_var_content = local_var_resp.text().await?;
if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
Ok(())
} else {
let local_var_entity: Option<DeleteuserCollectionPlaylistsError> =
serde_json::from_str(&local_var_content).ok();
let local_var_error = ResponseContent {
status: local_var_status,
content: local_var_content,
entity: local_var_entity,
};
Err(Error::ResponseError(local_var_error))
}
}
async fn get_user_collection<'id, 'country_code, 'locale, 'include>(
&self,
id: &'id str,
country_code: Option<&'country_code str>,
locale: Option<&'locale str>,
include: Option<Vec<String>>,
) -> Result<models::UserCollectionsSingleResourceDataDocument, Error<GetUserCollectionError>>
{
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/userCollections/{id}",
local_var_configuration.base_path,
id = crate::apis::urlencode(id)
);
let mut local_var_req_builder =
local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
if let Some(ref param_value) = country_code {
local_var_req_builder =
local_var_req_builder.query(&[("countryCode", ¶m_value.to_string())]);
}
if let Some(ref param_value) = locale {
local_var_req_builder =
local_var_req_builder.query(&[("locale", ¶m_value.to_string())]);
}
if let Some(ref param_value) = include {
local_var_req_builder = match "multi" {
"multi" => local_var_req_builder.query(
¶m_value
.into_iter()
.map(|p| ("include".to_owned(), p.to_string()))
.collect::<Vec<(std::string::String, std::string::String)>>(),
),
_ => local_var_req_builder.query(&[(
"include",
¶m_value
.into_iter()
.map(|p| p.to_string())
.collect::<Vec<String>>()
.join(",")
.to_string(),
)]),
};
}
if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
local_var_req_builder = local_var_req_builder
.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
}
if let Some(ref local_var_token) = local_var_configuration.oauth_access_token {
local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
};
let local_var_req = local_var_req_builder.build()?;
let local_var_resp = local_var_client.execute(local_var_req).await?;
let local_var_status = local_var_resp.status();
let local_var_content_type = local_var_resp
.headers()
.get("content-type")
.and_then(|v| v.to_str().ok())
.unwrap_or("application/octet-stream");
let local_var_content_type = super::ContentType::from(local_var_content_type);
let local_var_content = local_var_resp.text().await?;
if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
match local_var_content_type {
ContentType::Json => serde_path_to_error::deserialize(&mut serde_json::Deserializer::from_str(&local_var_content)).map_err(Error::from),
ContentType::Text => return Err(Error::from(serde_json::Error::custom("Received `text/plain` content type response that cannot be converted to `models::UserCollectionsSingleResourceDataDocument`"))),
ContentType::Unsupported(local_var_unknown_type) => return Err(Error::from(serde_json::Error::custom(format!("Received `{local_var_unknown_type}` content type response that cannot be converted to `models::UserCollectionsSingleResourceDataDocument`")))),
}
} else {
let local_var_entity: Option<GetUserCollectionError> =
serde_json::from_str(&local_var_content).ok();
let local_var_error = ResponseContent {
status: local_var_status,
content: local_var_content,
entity: local_var_entity,
};
Err(Error::ResponseError(local_var_error))
}
}
async fn get_user_collection_albums<
'id,
'page_cursor,
'sort,
'country_code,
'locale,
'include,
>(
&self,
id: &'id str,
page_cursor: Option<&'page_cursor str>,
sort: Option<Vec<String>>,
country_code: Option<&'country_code str>,
locale: Option<&'locale str>,
include: Option<Vec<String>>,
) -> Result<
models::UserCollectionsAlbumsMultiRelationshipDataDocument,
Error<GetUserCollectionAlbumsError>,
> {
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/userCollections/{id}/relationships/albums",
local_var_configuration.base_path,
id = crate::apis::urlencode(id)
);
let mut local_var_req_builder =
local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
if let Some(ref param_value) = page_cursor {
local_var_req_builder =
local_var_req_builder.query(&[("page[cursor]", ¶m_value.to_string())]);
}
if let Some(ref param_value) = sort {
local_var_req_builder = match "multi" {
"multi" => local_var_req_builder.query(
¶m_value
.into_iter()
.map(|p| ("sort".to_owned(), p.to_string()))
.collect::<Vec<(std::string::String, std::string::String)>>(),
),
_ => local_var_req_builder.query(&[(
"sort",
¶m_value
.into_iter()
.map(|p| p.to_string())
.collect::<Vec<String>>()
.join(",")
.to_string(),
)]),
};
}
if let Some(ref param_value) = country_code {
local_var_req_builder =
local_var_req_builder.query(&[("countryCode", ¶m_value.to_string())]);
}
if let Some(ref param_value) = locale {
local_var_req_builder =
local_var_req_builder.query(&[("locale", ¶m_value.to_string())]);
}
if let Some(ref param_value) = include {
local_var_req_builder = match "multi" {
"multi" => local_var_req_builder.query(
¶m_value
.into_iter()
.map(|p| ("include".to_owned(), p.to_string()))
.collect::<Vec<(std::string::String, std::string::String)>>(),
),
_ => local_var_req_builder.query(&[(
"include",
¶m_value
.into_iter()
.map(|p| p.to_string())
.collect::<Vec<String>>()
.join(",")
.to_string(),
)]),
};
}
if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
local_var_req_builder = local_var_req_builder
.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
}
if let Some(ref local_var_token) = local_var_configuration.oauth_access_token {
local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
};
let local_var_req = local_var_req_builder.build()?;
let local_var_resp = local_var_client.execute(local_var_req).await?;
let local_var_status = local_var_resp.status();
let local_var_content_type = local_var_resp
.headers()
.get("content-type")
.and_then(|v| v.to_str().ok())
.unwrap_or("application/octet-stream");
let local_var_content_type = super::ContentType::from(local_var_content_type);
let local_var_content = local_var_resp.text().await?;
if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
match local_var_content_type {
ContentType::Json => serde_path_to_error::deserialize(&mut serde_json::Deserializer::from_str(&local_var_content)).map_err(Error::from),
ContentType::Text => return Err(Error::from(serde_json::Error::custom("Received `text/plain` content type response that cannot be converted to `models::UserCollectionsAlbumsMultiRelationshipDataDocument`"))),
ContentType::Unsupported(local_var_unknown_type) => return Err(Error::from(serde_json::Error::custom(format!("Received `{local_var_unknown_type}` content type response that cannot be converted to `models::UserCollectionsAlbumsMultiRelationshipDataDocument`")))),
}
} else {
let local_var_entity: Option<GetUserCollectionAlbumsError> =
serde_json::from_str(&local_var_content).ok();
let local_var_error = ResponseContent {
status: local_var_status,
content: local_var_content,
entity: local_var_entity,
};
Err(Error::ResponseError(local_var_error))
}
}
async fn get_user_collection_artists<
'id,
'page_cursor,
'sort,
'country_code,
'locale,
'include,
>(
&self,
id: &'id str,
page_cursor: Option<&'page_cursor str>,
sort: Option<Vec<String>>,
country_code: Option<&'country_code str>,
locale: Option<&'locale str>,
include: Option<Vec<String>>,
) -> Result<
models::UserCollectionsArtistsMultiRelationshipDataDocument,
Error<GetUserCollectionArtistsError>,
> {
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/userCollections/{id}/relationships/artists",
local_var_configuration.base_path,
id = crate::apis::urlencode(id)
);
let mut local_var_req_builder =
local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
if let Some(ref param_value) = page_cursor {
local_var_req_builder =
local_var_req_builder.query(&[("page[cursor]", ¶m_value.to_string())]);
}
if let Some(ref param_value) = sort {
local_var_req_builder = match "multi" {
"multi" => local_var_req_builder.query(
¶m_value
.into_iter()
.map(|p| ("sort".to_owned(), p.to_string()))
.collect::<Vec<(std::string::String, std::string::String)>>(),
),
_ => local_var_req_builder.query(&[(
"sort",
¶m_value
.into_iter()
.map(|p| p.to_string())
.collect::<Vec<String>>()
.join(",")
.to_string(),
)]),
};
}
if let Some(ref param_value) = country_code {
local_var_req_builder =
local_var_req_builder.query(&[("countryCode", ¶m_value.to_string())]);
}
if let Some(ref param_value) = locale {
local_var_req_builder =
local_var_req_builder.query(&[("locale", ¶m_value.to_string())]);
}
if let Some(ref param_value) = include {
local_var_req_builder = match "multi" {
"multi" => local_var_req_builder.query(
¶m_value
.into_iter()
.map(|p| ("include".to_owned(), p.to_string()))
.collect::<Vec<(std::string::String, std::string::String)>>(),
),
_ => local_var_req_builder.query(&[(
"include",
¶m_value
.into_iter()
.map(|p| p.to_string())
.collect::<Vec<String>>()
.join(",")
.to_string(),
)]),
};
}
if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
local_var_req_builder = local_var_req_builder
.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
}
if let Some(ref local_var_token) = local_var_configuration.oauth_access_token {
local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
};
let local_var_req = local_var_req_builder.build()?;
let local_var_resp = local_var_client.execute(local_var_req).await?;
let local_var_status = local_var_resp.status();
let local_var_content_type = local_var_resp
.headers()
.get("content-type")
.and_then(|v| v.to_str().ok())
.unwrap_or("application/octet-stream");
let local_var_content_type = super::ContentType::from(local_var_content_type);
let local_var_content = local_var_resp.text().await?;
if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
match local_var_content_type {
ContentType::Json => serde_path_to_error::deserialize(&mut serde_json::Deserializer::from_str(&local_var_content)).map_err(Error::from),
ContentType::Text => return Err(Error::from(serde_json::Error::custom("Received `text/plain` content type response that cannot be converted to `models::UserCollectionsArtistsMultiRelationshipDataDocument`"))),
ContentType::Unsupported(local_var_unknown_type) => return Err(Error::from(serde_json::Error::custom(format!("Received `{local_var_unknown_type}` content type response that cannot be converted to `models::UserCollectionsArtistsMultiRelationshipDataDocument`")))),
}
} else {
let local_var_entity: Option<GetUserCollectionArtistsError> =
serde_json::from_str(&local_var_content).ok();
let local_var_error = ResponseContent {
status: local_var_status,
content: local_var_content,
entity: local_var_entity,
};
Err(Error::ResponseError(local_var_error))
}
}
async fn get_user_collection_owners<'id, 'include, 'page_cursor>(
&self,
id: &'id str,
include: Option<Vec<String>>,
page_cursor: Option<&'page_cursor str>,
) -> Result<
models::UserCollectionsMultiRelationshipDataDocument,
Error<GetUserCollectionOwnersError>,
> {
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/userCollections/{id}/relationships/owners",
local_var_configuration.base_path,
id = crate::apis::urlencode(id)
);
let mut local_var_req_builder =
local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
if let Some(ref param_value) = include {
local_var_req_builder = match "multi" {
"multi" => local_var_req_builder.query(
¶m_value
.into_iter()
.map(|p| ("include".to_owned(), p.to_string()))
.collect::<Vec<(std::string::String, std::string::String)>>(),
),
_ => local_var_req_builder.query(&[(
"include",
¶m_value
.into_iter()
.map(|p| p.to_string())
.collect::<Vec<String>>()
.join(",")
.to_string(),
)]),
};
}
if let Some(ref param_value) = page_cursor {
local_var_req_builder =
local_var_req_builder.query(&[("page[cursor]", ¶m_value.to_string())]);
}
if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
local_var_req_builder = local_var_req_builder
.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
}
if let Some(ref local_var_token) = local_var_configuration.oauth_access_token {
local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
};
let local_var_req = local_var_req_builder.build()?;
let local_var_resp = local_var_client.execute(local_var_req).await?;
let local_var_status = local_var_resp.status();
let local_var_content_type = local_var_resp
.headers()
.get("content-type")
.and_then(|v| v.to_str().ok())
.unwrap_or("application/octet-stream");
let local_var_content_type = super::ContentType::from(local_var_content_type);
let local_var_content = local_var_resp.text().await?;
if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
match local_var_content_type {
ContentType::Json => serde_path_to_error::deserialize(&mut serde_json::Deserializer::from_str(&local_var_content)).map_err(Error::from),
ContentType::Text => return Err(Error::from(serde_json::Error::custom("Received `text/plain` content type response that cannot be converted to `models::UserCollectionsMultiRelationshipDataDocument`"))),
ContentType::Unsupported(local_var_unknown_type) => return Err(Error::from(serde_json::Error::custom(format!("Received `{local_var_unknown_type}` content type response that cannot be converted to `models::UserCollectionsMultiRelationshipDataDocument`")))),
}
} else {
let local_var_entity: Option<GetUserCollectionOwnersError> =
serde_json::from_str(&local_var_content).ok();
let local_var_error = ResponseContent {
status: local_var_status,
content: local_var_content,
entity: local_var_entity,
};
Err(Error::ResponseError(local_var_error))
}
}
async fn get_user_collection_playlists<'id, 'collection_view, 'page_cursor, 'sort, 'include>(
&self,
id: &'id str,
collection_view: Option<&'collection_view str>,
page_cursor: Option<&'page_cursor str>,
sort: Option<Vec<String>>,
include: Option<Vec<String>>,
) -> Result<
models::UserCollectionsPlaylistsMultiRelationshipDataDocument,
Error<GetUserCollectionPlaylistsError>,
> {
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/userCollections/{id}/relationships/playlists",
local_var_configuration.base_path,
id = crate::apis::urlencode(id)
);
let mut local_var_req_builder =
local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
if let Some(ref param_value) = collection_view {
local_var_req_builder =
local_var_req_builder.query(&[("collectionView", ¶m_value.to_string())]);
}
if let Some(ref param_value) = page_cursor {
local_var_req_builder =
local_var_req_builder.query(&[("page[cursor]", ¶m_value.to_string())]);
}
if let Some(ref param_value) = sort {
local_var_req_builder = match "multi" {
"multi" => local_var_req_builder.query(
¶m_value
.into_iter()
.map(|p| ("sort".to_owned(), p.to_string()))
.collect::<Vec<(std::string::String, std::string::String)>>(),
),
_ => local_var_req_builder.query(&[(
"sort",
¶m_value
.into_iter()
.map(|p| p.to_string())
.collect::<Vec<String>>()
.join(",")
.to_string(),
)]),
};
}
if let Some(ref param_value) = include {
local_var_req_builder = match "multi" {
"multi" => local_var_req_builder.query(
¶m_value
.into_iter()
.map(|p| ("include".to_owned(), p.to_string()))
.collect::<Vec<(std::string::String, std::string::String)>>(),
),
_ => local_var_req_builder.query(&[(
"include",
¶m_value
.into_iter()
.map(|p| p.to_string())
.collect::<Vec<String>>()
.join(",")
.to_string(),
)]),
};
}
if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
local_var_req_builder = local_var_req_builder
.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
}
if let Some(ref local_var_token) = local_var_configuration.oauth_access_token {
local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
};
let local_var_req = local_var_req_builder.build()?;
let local_var_resp = local_var_client.execute(local_var_req).await?;
let local_var_status = local_var_resp.status();
let local_var_content_type = local_var_resp
.headers()
.get("content-type")
.and_then(|v| v.to_str().ok())
.unwrap_or("application/octet-stream");
let local_var_content_type = super::ContentType::from(local_var_content_type);
let local_var_content = local_var_resp.text().await?;
if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
match local_var_content_type {
ContentType::Json => serde_path_to_error::deserialize(&mut serde_json::Deserializer::from_str(&local_var_content)).map_err(Error::from),
ContentType::Text => return Err(Error::from(serde_json::Error::custom("Received `text/plain` content type response that cannot be converted to `models::UserCollectionsPlaylistsMultiRelationshipDataDocument`"))),
ContentType::Unsupported(local_var_unknown_type) => return Err(Error::from(serde_json::Error::custom(format!("Received `{local_var_unknown_type}` content type response that cannot be converted to `models::UserCollectionsPlaylistsMultiRelationshipDataDocument`")))),
}
} else {
let local_var_entity: Option<GetUserCollectionPlaylistsError> =
serde_json::from_str(&local_var_content).ok();
let local_var_error = ResponseContent {
status: local_var_status,
content: local_var_content,
entity: local_var_entity,
};
Err(Error::ResponseError(local_var_error))
}
}
async fn get_user_collection_tracks<
'id,
'page_cursor,
'sort,
'country_code,
'locale,
'include,
>(
&self,
id: &'id str,
page_cursor: Option<&'page_cursor str>,
sort: Option<Vec<String>>,
country_code: Option<&'country_code str>,
locale: Option<&'locale str>,
include: Option<Vec<String>>,
) -> Result<
models::UserCollectionsTracksMultiRelationshipDataDocument,
Error<GetUserCollectionTracksError>,
> {
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/userCollections/{id}/relationships/tracks",
local_var_configuration.base_path,
id = crate::apis::urlencode(id)
);
let mut local_var_req_builder =
local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
if let Some(ref param_value) = page_cursor {
local_var_req_builder =
local_var_req_builder.query(&[("page[cursor]", ¶m_value.to_string())]);
}
if let Some(ref param_value) = sort {
local_var_req_builder = match "multi" {
"multi" => local_var_req_builder.query(
¶m_value
.into_iter()
.map(|p| ("sort".to_owned(), p.to_string()))
.collect::<Vec<(std::string::String, std::string::String)>>(),
),
_ => local_var_req_builder.query(&[(
"sort",
¶m_value
.into_iter()
.map(|p| p.to_string())
.collect::<Vec<String>>()
.join(",")
.to_string(),
)]),
};
}
if let Some(ref param_value) = country_code {
local_var_req_builder =
local_var_req_builder.query(&[("countryCode", ¶m_value.to_string())]);
}
if let Some(ref param_value) = locale {
local_var_req_builder =
local_var_req_builder.query(&[("locale", ¶m_value.to_string())]);
}
if let Some(ref param_value) = include {
local_var_req_builder = match "multi" {
"multi" => local_var_req_builder.query(
¶m_value
.into_iter()
.map(|p| ("include".to_owned(), p.to_string()))
.collect::<Vec<(std::string::String, std::string::String)>>(),
),
_ => local_var_req_builder.query(&[(
"include",
¶m_value
.into_iter()
.map(|p| p.to_string())
.collect::<Vec<String>>()
.join(",")
.to_string(),
)]),
};
}
if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
local_var_req_builder = local_var_req_builder
.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
}
if let Some(ref local_var_token) = local_var_configuration.oauth_access_token {
local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
};
let local_var_req = local_var_req_builder.build()?;
let local_var_resp = local_var_client.execute(local_var_req).await?;
let local_var_status = local_var_resp.status();
let local_var_content_type = local_var_resp
.headers()
.get("content-type")
.and_then(|v| v.to_str().ok())
.unwrap_or("application/octet-stream");
let local_var_content_type = super::ContentType::from(local_var_content_type);
let local_var_content = local_var_resp.text().await?;
if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
match local_var_content_type {
ContentType::Json => serde_path_to_error::deserialize(&mut serde_json::Deserializer::from_str(&local_var_content)).map_err(Error::from),
ContentType::Text => return Err(Error::from(serde_json::Error::custom("Received `text/plain` content type response that cannot be converted to `models::UserCollectionsTracksMultiRelationshipDataDocument`"))),
ContentType::Unsupported(local_var_unknown_type) => return Err(Error::from(serde_json::Error::custom(format!("Received `{local_var_unknown_type}` content type response that cannot be converted to `models::UserCollectionsTracksMultiRelationshipDataDocument`")))),
}
} else {
let local_var_entity: Option<GetUserCollectionTracksError> =
serde_json::from_str(&local_var_content).ok();
let local_var_error = ResponseContent {
status: local_var_status,
content: local_var_content,
entity: local_var_entity,
};
Err(Error::ResponseError(local_var_error))
}
}
async fn get_user_collection_videos<
'id,
'page_cursor,
'sort,
'country_code,
'locale,
'include,
>(
&self,
id: &'id str,
page_cursor: Option<&'page_cursor str>,
sort: Option<Vec<String>>,
country_code: Option<&'country_code str>,
locale: Option<&'locale str>,
include: Option<Vec<String>>,
) -> Result<
models::UserCollectionsVideosMultiRelationshipDataDocument,
Error<GetUserCollectionVideosError>,
> {
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/userCollections/{id}/relationships/videos",
local_var_configuration.base_path,
id = crate::apis::urlencode(id)
);
let mut local_var_req_builder =
local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
if let Some(ref param_value) = page_cursor {
local_var_req_builder =
local_var_req_builder.query(&[("page[cursor]", ¶m_value.to_string())]);
}
if let Some(ref param_value) = sort {
local_var_req_builder = match "multi" {
"multi" => local_var_req_builder.query(
¶m_value
.into_iter()
.map(|p| ("sort".to_owned(), p.to_string()))
.collect::<Vec<(std::string::String, std::string::String)>>(),
),
_ => local_var_req_builder.query(&[(
"sort",
¶m_value
.into_iter()
.map(|p| p.to_string())
.collect::<Vec<String>>()
.join(",")
.to_string(),
)]),
};
}
if let Some(ref param_value) = country_code {
local_var_req_builder =
local_var_req_builder.query(&[("countryCode", ¶m_value.to_string())]);
}
if let Some(ref param_value) = locale {
local_var_req_builder =
local_var_req_builder.query(&[("locale", ¶m_value.to_string())]);
}
if let Some(ref param_value) = include {
local_var_req_builder = match "multi" {
"multi" => local_var_req_builder.query(
¶m_value
.into_iter()
.map(|p| ("include".to_owned(), p.to_string()))
.collect::<Vec<(std::string::String, std::string::String)>>(),
),
_ => local_var_req_builder.query(&[(
"include",
¶m_value
.into_iter()
.map(|p| p.to_string())
.collect::<Vec<String>>()
.join(",")
.to_string(),
)]),
};
}
if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
local_var_req_builder = local_var_req_builder
.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
}
if let Some(ref local_var_token) = local_var_configuration.oauth_access_token {
local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
};
let local_var_req = local_var_req_builder.build()?;
let local_var_resp = local_var_client.execute(local_var_req).await?;
let local_var_status = local_var_resp.status();
let local_var_content_type = local_var_resp
.headers()
.get("content-type")
.and_then(|v| v.to_str().ok())
.unwrap_or("application/octet-stream");
let local_var_content_type = super::ContentType::from(local_var_content_type);
let local_var_content = local_var_resp.text().await?;
if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
match local_var_content_type {
ContentType::Json => serde_path_to_error::deserialize(&mut serde_json::Deserializer::from_str(&local_var_content)).map_err(Error::from),
ContentType::Text => return Err(Error::from(serde_json::Error::custom("Received `text/plain` content type response that cannot be converted to `models::UserCollectionsVideosMultiRelationshipDataDocument`"))),
ContentType::Unsupported(local_var_unknown_type) => return Err(Error::from(serde_json::Error::custom(format!("Received `{local_var_unknown_type}` content type response that cannot be converted to `models::UserCollectionsVideosMultiRelationshipDataDocument`")))),
}
} else {
let local_var_entity: Option<GetUserCollectionVideosError> =
serde_json::from_str(&local_var_content).ok();
let local_var_error = ResponseContent {
status: local_var_status,
content: local_var_content,
entity: local_var_entity,
};
Err(Error::ResponseError(local_var_error))
}
}
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum AddUserCollectionAlbumsError {
Status400(models::Default400ResponseBody),
Status404(models::Default404ResponseBody),
Status405(models::Default405ResponseBody),
Status406(models::Default406ResponseBody),
Status415(models::Default415ResponseBody),
Status429(models::Default429ResponseBody),
Status500(models::Default500ResponseBody),
Status503(models::Default503ResponseBody),
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum AddUserCollectionArtistsError {
Status400(models::Default400ResponseBody),
Status404(models::Default404ResponseBody),
Status405(models::Default405ResponseBody),
Status406(models::Default406ResponseBody),
Status415(models::Default415ResponseBody),
Status429(models::Default429ResponseBody),
Status500(models::Default500ResponseBody),
Status503(models::Default503ResponseBody),
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum AddUserCollectionPlaylistsError {
Status400(models::Default400ResponseBody),
Status404(models::Default404ResponseBody),
Status405(models::Default405ResponseBody),
Status406(models::Default406ResponseBody),
Status415(models::Default415ResponseBody),
Status429(models::Default429ResponseBody),
Status500(models::Default500ResponseBody),
Status503(models::Default503ResponseBody),
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum AddUserCollectionTracksError {
Status400(models::Default400ResponseBody),
Status404(models::Default404ResponseBody),
Status405(models::Default405ResponseBody),
Status406(models::Default406ResponseBody),
Status415(models::Default415ResponseBody),
Status429(models::Default429ResponseBody),
Status500(models::Default500ResponseBody),
Status503(models::Default503ResponseBody),
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum AddUserCollectionVideosError {
Status400(models::Default400ResponseBody),
Status404(models::Default404ResponseBody),
Status405(models::Default405ResponseBody),
Status406(models::Default406ResponseBody),
Status415(models::Default415ResponseBody),
Status429(models::Default429ResponseBody),
Status500(models::Default500ResponseBody),
Status503(models::Default503ResponseBody),
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum DeleteUserCollectionAlbumsError {
Status400(models::Default400ResponseBody),
Status404(models::Default404ResponseBody),
Status405(models::Default405ResponseBody),
Status406(models::Default406ResponseBody),
Status415(models::Default415ResponseBody),
Status429(models::Default429ResponseBody),
Status500(models::Default500ResponseBody),
Status503(models::Default503ResponseBody),
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum DeleteUserCollectionArtistsError {
Status400(models::Default400ResponseBody),
Status404(models::Default404ResponseBody),
Status405(models::Default405ResponseBody),
Status406(models::Default406ResponseBody),
Status415(models::Default415ResponseBody),
Status429(models::Default429ResponseBody),
Status500(models::Default500ResponseBody),
Status503(models::Default503ResponseBody),
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum DeleteUserCollectionTracksError {
Status400(models::Default400ResponseBody),
Status404(models::Default404ResponseBody),
Status405(models::Default405ResponseBody),
Status406(models::Default406ResponseBody),
Status415(models::Default415ResponseBody),
Status429(models::Default429ResponseBody),
Status500(models::Default500ResponseBody),
Status503(models::Default503ResponseBody),
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum DeleteUserCollectionVideosError {
Status400(models::Default400ResponseBody),
Status404(models::Default404ResponseBody),
Status405(models::Default405ResponseBody),
Status406(models::Default406ResponseBody),
Status415(models::Default415ResponseBody),
Status429(models::Default429ResponseBody),
Status500(models::Default500ResponseBody),
Status503(models::Default503ResponseBody),
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum DeleteuserCollectionPlaylistsError {
Status400(models::Default400ResponseBody),
Status404(models::Default404ResponseBody),
Status405(models::Default405ResponseBody),
Status406(models::Default406ResponseBody),
Status415(models::Default415ResponseBody),
Status429(models::Default429ResponseBody),
Status500(models::Default500ResponseBody),
Status503(models::Default503ResponseBody),
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum GetUserCollectionError {
Status400(models::Default400ResponseBody),
Status404(models::Default404ResponseBody),
Status405(models::Default405ResponseBody),
Status406(models::Default406ResponseBody),
Status415(models::Default415ResponseBody),
Status429(models::Default429ResponseBody),
Status500(models::Default500ResponseBody),
Status503(models::Default503ResponseBody),
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum GetUserCollectionAlbumsError {
Status400(models::Default400ResponseBody),
Status404(models::Default404ResponseBody),
Status405(models::Default405ResponseBody),
Status406(models::Default406ResponseBody),
Status415(models::Default415ResponseBody),
Status429(models::Default429ResponseBody),
Status500(models::Default500ResponseBody),
Status503(models::Default503ResponseBody),
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum GetUserCollectionArtistsError {
Status400(models::Default400ResponseBody),
Status404(models::Default404ResponseBody),
Status405(models::Default405ResponseBody),
Status406(models::Default406ResponseBody),
Status415(models::Default415ResponseBody),
Status429(models::Default429ResponseBody),
Status500(models::Default500ResponseBody),
Status503(models::Default503ResponseBody),
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum GetUserCollectionOwnersError {
Status400(models::Default400ResponseBody),
Status404(models::Default404ResponseBody),
Status405(models::Default405ResponseBody),
Status406(models::Default406ResponseBody),
Status415(models::Default415ResponseBody),
Status429(models::Default429ResponseBody),
Status500(models::Default500ResponseBody),
Status503(models::Default503ResponseBody),
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum GetUserCollectionPlaylistsError {
Status400(models::Default400ResponseBody),
Status404(models::Default404ResponseBody),
Status405(models::Default405ResponseBody),
Status406(models::Default406ResponseBody),
Status415(models::Default415ResponseBody),
Status429(models::Default429ResponseBody),
Status500(models::Default500ResponseBody),
Status503(models::Default503ResponseBody),
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum GetUserCollectionTracksError {
Status400(models::Default400ResponseBody),
Status404(models::Default404ResponseBody),
Status405(models::Default405ResponseBody),
Status406(models::Default406ResponseBody),
Status415(models::Default415ResponseBody),
Status429(models::Default429ResponseBody),
Status500(models::Default500ResponseBody),
Status503(models::Default503ResponseBody),
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum GetUserCollectionVideosError {
Status400(models::Default400ResponseBody),
Status404(models::Default404ResponseBody),
Status405(models::Default405ResponseBody),
Status406(models::Default406ResponseBody),
Status415(models::Default415ResponseBody),
Status429(models::Default429ResponseBody),
Status500(models::Default500ResponseBody),
Status503(models::Default503ResponseBody),
UnknownValue(serde_json::Value),
}