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 PlaylistsApi: Send + Sync {
async fn add_items_to_playlist<
'id,
'country_code,
'playlist_items_relationship_add_operation_payload,
>(
&self,
id: &'id str,
country_code: Option<&'country_code str>,
playlist_items_relationship_add_operation_payload: Option<
models::PlaylistItemsRelationshipAddOperationPayload,
>,
) -> Result<(), Error<AddItemsToPlaylistError>>;
async fn create_playlist<'country_code, 'playlist_create_operation_payload>(
&self,
country_code: Option<&'country_code str>,
playlist_create_operation_payload: Option<models::PlaylistCreateOperationPayload>,
) -> Result<models::PlaylistsSingleResourceDataDocument, Error<CreatePlaylistError>>;
async fn delete_playlist<'id>(&self, id: &'id str) -> Result<(), Error<DeletePlaylistError>>;
async fn delete_playlist_items<'id, 'playlist_items_relationship_remove_operation_payload>(
&self,
id: &'id str,
playlist_items_relationship_remove_operation_payload: Option<
models::PlaylistItemsRelationshipRemoveOperationPayload,
>,
) -> Result<(), Error<DeletePlaylistItemsError>>;
async fn get_playlist<'id, 'country_code, 'include>(
&self,
id: &'id str,
country_code: Option<&'country_code str>,
include: Option<Vec<String>>,
) -> Result<models::PlaylistsSingleResourceDataDocument, Error<GetPlaylistError>>;
async fn get_playlist_cover_art<'id, 'country_code, 'include, 'page_cursor>(
&self,
id: &'id str,
country_code: Option<&'country_code str>,
include: Option<Vec<String>>,
page_cursor: Option<&'page_cursor str>,
) -> Result<models::PlaylistsMultiRelationshipDataDocument, Error<GetPlaylistCoverArtError>>;
async fn get_playlist_items<'id, 'page_cursor, 'country_code, 'include>(
&self,
id: &'id str,
page_cursor: Option<&'page_cursor str>,
country_code: Option<&'country_code str>,
include: Option<Vec<String>>,
) -> Result<models::PlaylistsItemsMultiRelationshipDataDocument, Error<GetPlaylistItemsError>>;
async fn get_playlist_owner_profiles<'id, 'country_code, 'include, 'page_cursor>(
&self,
id: &'id str,
country_code: Option<&'country_code str>,
include: Option<Vec<String>>,
page_cursor: Option<&'page_cursor str>,
) -> Result<models::PlaylistsMultiRelationshipDataDocument, Error<GetPlaylistOwnerProfilesError>>;
async fn get_playlist_owners<'id, 'country_code, 'include, 'page_cursor>(
&self,
id: &'id str,
country_code: Option<&'country_code str>,
include: Option<Vec<String>>,
page_cursor: Option<&'page_cursor str>,
) -> Result<models::PlaylistsMultiRelationshipDataDocument, Error<GetPlaylistOwnersError>>;
async fn get_playlists<
'page_cursor,
'sort,
'country_code,
'include,
'filter_left_square_bracket_id_right_square_bracket,
'filter_left_square_bracket_owners_id_right_square_bracket,
>(
&self,
page_cursor: Option<&'page_cursor str>,
sort: Option<Vec<String>>,
country_code: Option<&'country_code str>,
include: Option<Vec<String>>,
filter_left_square_bracket_id_right_square_bracket: Option<Vec<String>>,
filter_left_square_bracket_owners_id_right_square_bracket: Option<Vec<String>>,
) -> Result<models::PlaylistsMultiResourceDataDocument, Error<GetPlaylistsError>>;
async fn patch_playlist<'id, 'country_code, 'playlist_update_operation_payload>(
&self,
id: &'id str,
country_code: Option<&'country_code str>,
playlist_update_operation_payload: Option<models::PlaylistUpdateOperationPayload>,
) -> Result<(), Error<PatchPlaylistError>>;
async fn patch_playlist_cover_art<
'id,
'playlist_cover_art_relationship_update_operation_payload,
>(
&self,
id: &'id str,
playlist_cover_art_relationship_update_operation_payload: Option<
models::PlaylistCoverArtRelationshipUpdateOperationPayload,
>,
) -> Result<(), Error<PatchPlaylistCoverArtError>>;
async fn patch_playlist_items<'id, 'playlist_items_relationship_reorder_operation_payload>(
&self,
id: &'id str,
playlist_items_relationship_reorder_operation_payload: Option<
models::PlaylistItemsRelationshipReorderOperationPayload,
>,
) -> Result<(), Error<PatchPlaylistItemsError>>;
}
#[derive(Clone)]
pub struct PlaylistsApiClient {
configuration: Arc<configuration::Configuration>,
}
impl PlaylistsApiClient {
pub fn new(configuration: Arc<configuration::Configuration>) -> Self {
Self { configuration }
}
}
#[async_trait]
impl PlaylistsApi for PlaylistsApiClient {
async fn add_items_to_playlist<
'id,
'country_code,
'playlist_items_relationship_add_operation_payload,
>(
&self,
id: &'id str,
country_code: Option<&'country_code str>,
playlist_items_relationship_add_operation_payload: Option<
models::PlaylistItemsRelationshipAddOperationPayload,
>,
) -> Result<(), Error<AddItemsToPlaylistError>> {
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/playlists/{id}/relationships/items",
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(&playlist_items_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<AddItemsToPlaylistError> =
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 create_playlist<'country_code, 'playlist_create_operation_payload>(
&self,
country_code: Option<&'country_code str>,
playlist_create_operation_payload: Option<models::PlaylistCreateOperationPayload>,
) -> Result<models::PlaylistsSingleResourceDataDocument, Error<CreatePlaylistError>> {
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!("{}/playlists", local_var_configuration.base_path);
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(&playlist_create_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_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::PlaylistsSingleResourceDataDocument`"))),
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::PlaylistsSingleResourceDataDocument`")))),
}
} else {
let local_var_entity: Option<CreatePlaylistError> =
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_playlist<'id>(&self, id: &'id str) -> Result<(), Error<DeletePlaylistError>> {
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/playlists/{id}",
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());
};
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<DeletePlaylistError> =
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_playlist_items<'id, 'playlist_items_relationship_remove_operation_payload>(
&self,
id: &'id str,
playlist_items_relationship_remove_operation_payload: Option<
models::PlaylistItemsRelationshipRemoveOperationPayload,
>,
) -> Result<(), Error<DeletePlaylistItemsError>> {
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/playlists/{id}/relationships/items",
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(&playlist_items_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<DeletePlaylistItemsError> =
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_playlist<'id, 'country_code, 'include>(
&self,
id: &'id str,
country_code: Option<&'country_code str>,
include: Option<Vec<String>>,
) -> Result<models::PlaylistsSingleResourceDataDocument, Error<GetPlaylistError>> {
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/playlists/{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) = 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());
};
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::PlaylistsSingleResourceDataDocument`"))),
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::PlaylistsSingleResourceDataDocument`")))),
}
} else {
let local_var_entity: Option<GetPlaylistError> =
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_playlist_cover_art<'id, 'country_code, 'include, 'page_cursor>(
&self,
id: &'id str,
country_code: Option<&'country_code str>,
include: Option<Vec<String>>,
page_cursor: Option<&'page_cursor str>,
) -> Result<models::PlaylistsMultiRelationshipDataDocument, Error<GetPlaylistCoverArtError>>
{
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/playlists/{id}/relationships/coverArt",
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) = 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());
};
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::PlaylistsMultiRelationshipDataDocument`"))),
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::PlaylistsMultiRelationshipDataDocument`")))),
}
} else {
let local_var_entity: Option<GetPlaylistCoverArtError> =
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_playlist_items<'id, 'page_cursor, 'country_code, 'include>(
&self,
id: &'id str,
page_cursor: Option<&'page_cursor str>,
country_code: Option<&'country_code str>,
include: Option<Vec<String>>,
) -> Result<models::PlaylistsItemsMultiRelationshipDataDocument, Error<GetPlaylistItemsError>>
{
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/playlists/{id}/relationships/items",
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) = country_code {
local_var_req_builder =
local_var_req_builder.query(&[("countryCode", ¶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());
};
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::PlaylistsItemsMultiRelationshipDataDocument`"))),
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::PlaylistsItemsMultiRelationshipDataDocument`")))),
}
} else {
let local_var_entity: Option<GetPlaylistItemsError> =
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_playlist_owner_profiles<'id, 'country_code, 'include, 'page_cursor>(
&self,
id: &'id str,
country_code: Option<&'country_code str>,
include: Option<Vec<String>>,
page_cursor: Option<&'page_cursor str>,
) -> Result<models::PlaylistsMultiRelationshipDataDocument, Error<GetPlaylistOwnerProfilesError>>
{
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/playlists/{id}/relationships/ownerProfiles",
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) = 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());
};
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::PlaylistsMultiRelationshipDataDocument`"))),
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::PlaylistsMultiRelationshipDataDocument`")))),
}
} else {
let local_var_entity: Option<GetPlaylistOwnerProfilesError> =
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_playlist_owners<'id, 'country_code, 'include, 'page_cursor>(
&self,
id: &'id str,
country_code: Option<&'country_code str>,
include: Option<Vec<String>>,
page_cursor: Option<&'page_cursor str>,
) -> Result<models::PlaylistsMultiRelationshipDataDocument, Error<GetPlaylistOwnersError>> {
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/playlists/{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) = country_code {
local_var_req_builder =
local_var_req_builder.query(&[("countryCode", ¶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 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());
};
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::PlaylistsMultiRelationshipDataDocument`"))),
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::PlaylistsMultiRelationshipDataDocument`")))),
}
} else {
let local_var_entity: Option<GetPlaylistOwnersError> =
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_playlists<
'page_cursor,
'sort,
'country_code,
'include,
'filter_left_square_bracket_id_right_square_bracket,
'filter_left_square_bracket_owners_id_right_square_bracket,
>(
&self,
page_cursor: Option<&'page_cursor str>,
sort: Option<Vec<String>>,
country_code: Option<&'country_code str>,
include: Option<Vec<String>>,
filter_left_square_bracket_id_right_square_bracket: Option<Vec<String>>,
filter_left_square_bracket_owners_id_right_square_bracket: Option<Vec<String>>,
) -> Result<models::PlaylistsMultiResourceDataDocument, Error<GetPlaylistsError>> {
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!("{}/playlists", local_var_configuration.base_path);
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) = 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) = filter_left_square_bracket_id_right_square_bracket {
local_var_req_builder = match "multi" {
"multi" => local_var_req_builder.query(
¶m_value
.into_iter()
.map(|p| ("filter[id]".to_owned(), p.to_string()))
.collect::<Vec<(std::string::String, std::string::String)>>(),
),
_ => local_var_req_builder.query(&[(
"filter[id]",
¶m_value
.into_iter()
.map(|p| p.to_string())
.collect::<Vec<String>>()
.join(",")
.to_string(),
)]),
};
}
if let Some(ref param_value) = filter_left_square_bracket_owners_id_right_square_bracket {
local_var_req_builder = match "multi" {
"multi" => local_var_req_builder.query(
¶m_value
.into_iter()
.map(|p| ("filter[owners.id]".to_owned(), p.to_string()))
.collect::<Vec<(std::string::String, std::string::String)>>(),
),
_ => local_var_req_builder.query(&[(
"filter[owners.id]",
¶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());
};
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::PlaylistsMultiResourceDataDocument`"))),
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::PlaylistsMultiResourceDataDocument`")))),
}
} else {
let local_var_entity: Option<GetPlaylistsError> =
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 patch_playlist<'id, 'country_code, 'playlist_update_operation_payload>(
&self,
id: &'id str,
country_code: Option<&'country_code str>,
playlist_update_operation_payload: Option<models::PlaylistUpdateOperationPayload>,
) -> Result<(), Error<PatchPlaylistError>> {
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/playlists/{id}",
local_var_configuration.base_path,
id = crate::apis::urlencode(id)
);
let mut local_var_req_builder =
local_var_client.request(reqwest::Method::PATCH, 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(&playlist_update_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<PatchPlaylistError> =
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 patch_playlist_cover_art<
'id,
'playlist_cover_art_relationship_update_operation_payload,
>(
&self,
id: &'id str,
playlist_cover_art_relationship_update_operation_payload: Option<
models::PlaylistCoverArtRelationshipUpdateOperationPayload,
>,
) -> Result<(), Error<PatchPlaylistCoverArtError>> {
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/playlists/{id}/relationships/coverArt",
local_var_configuration.base_path,
id = crate::apis::urlencode(id)
);
let mut local_var_req_builder =
local_var_client.request(reqwest::Method::PATCH, 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(&playlist_cover_art_relationship_update_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<PatchPlaylistCoverArtError> =
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 patch_playlist_items<'id, 'playlist_items_relationship_reorder_operation_payload>(
&self,
id: &'id str,
playlist_items_relationship_reorder_operation_payload: Option<
models::PlaylistItemsRelationshipReorderOperationPayload,
>,
) -> Result<(), Error<PatchPlaylistItemsError>> {
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/playlists/{id}/relationships/items",
local_var_configuration.base_path,
id = crate::apis::urlencode(id)
);
let mut local_var_req_builder =
local_var_client.request(reqwest::Method::PATCH, 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(&playlist_items_relationship_reorder_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<PatchPlaylistItemsError> =
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 AddItemsToPlaylistError {
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 CreatePlaylistError {
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 DeletePlaylistError {
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 DeletePlaylistItemsError {
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 GetPlaylistError {
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 GetPlaylistCoverArtError {
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 GetPlaylistItemsError {
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 GetPlaylistOwnerProfilesError {
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 GetPlaylistOwnersError {
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 GetPlaylistsError {
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 PatchPlaylistError {
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 PatchPlaylistCoverArtError {
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 PatchPlaylistItemsError {
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),
}