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 TracksApi: Send + Sync {
#[cfg(feature = "internal")]
async fn create_track<'track_create_operation_payload>(
&self,
track_create_operation_payload: Option<models::TrackCreateOperationPayload>,
) -> Result<models::TracksSingleResourceDataDocument, Error<CreateTrackError>>;
#[cfg(feature = "internal")]
async fn delete_track<'id>(&self, id: &'id str) -> Result<(), Error<DeleteTrackError>>;
async fn get_track<'id, 'country_code, 'include, 'share_code>(
&self,
id: &'id str,
country_code: Option<&'country_code str>,
include: Option<Vec<String>>,
share_code: Option<&'share_code str>,
) -> Result<models::TracksSingleResourceDataDocument, Error<GetTrackError>>;
async fn get_track_albums<'id, 'country_code, 'include, 'page_cursor, 'share_code>(
&self,
id: &'id str,
country_code: Option<&'country_code str>,
include: Option<Vec<String>>,
page_cursor: Option<&'page_cursor str>,
share_code: Option<&'share_code str>,
) -> Result<models::TracksMultiRelationshipDataDocument, Error<GetTrackAlbumsError>>;
#[cfg(feature = "internal")]
async fn get_track_genres<'id, 'country_code, 'include, 'page_cursor, 'share_code>(
&self,
id: &'id str,
country_code: Option<&'country_code str>,
include: Option<Vec<String>>,
page_cursor: Option<&'page_cursor str>,
share_code: Option<&'share_code str>,
) -> Result<models::TracksMultiRelationshipDataDocument, Error<GetTrackGenresError>>;
#[cfg(feature = "internal")]
async fn get_track_lyrics<'id, 'include, 'page_cursor, 'share_code>(
&self,
id: &'id str,
include: Option<Vec<String>>,
page_cursor: Option<&'page_cursor str>,
share_code: Option<&'share_code str>,
) -> Result<models::TracksMultiRelationshipDataDocument, Error<GetTrackLyricsError>>;
async fn get_track_owners<'id, 'include, 'page_cursor, 'share_code>(
&self,
id: &'id str,
include: Option<Vec<String>>,
page_cursor: Option<&'page_cursor str>,
share_code: Option<&'share_code str>,
) -> Result<models::TracksMultiRelationshipDataDocument, Error<GetTrackOwnersError>>;
async fn get_track_providers<'id, 'country_code, 'include, 'page_cursor, 'share_code>(
&self,
id: &'id str,
country_code: Option<&'country_code str>,
include: Option<Vec<String>>,
page_cursor: Option<&'page_cursor str>,
share_code: Option<&'share_code str>,
) -> Result<models::TracksMultiRelationshipDataDocument, Error<GetTrackProvidersError>>;
async fn get_track_radio<'id, 'include, 'page_cursor, 'share_code>(
&self,
id: &'id str,
include: Option<Vec<String>>,
page_cursor: Option<&'page_cursor str>,
share_code: Option<&'share_code str>,
) -> Result<models::TracksMultiRelationshipDataDocument, Error<GetTrackRadioError>>;
#[cfg(feature = "internal")]
async fn get_track_replacement_relationship<'id, 'country_code, 'include, 'share_code>(
&self,
id: &'id str,
country_code: Option<&'country_code str>,
include: Option<Vec<String>>,
share_code: Option<&'share_code str>,
) -> Result<
models::TracksSingleRelationshipDataDocument,
Error<GetTrackReplacementRelationshipError>,
>;
#[cfg(feature = "internal")]
async fn get_track_shares<'id, 'include, 'page_cursor, 'share_code>(
&self,
id: &'id str,
include: Option<Vec<String>>,
page_cursor: Option<&'page_cursor str>,
share_code: Option<&'share_code str>,
) -> Result<models::TracksMultiRelationshipDataDocument, Error<GetTrackSharesError>>;
async fn get_track_similar_tracks<'id, 'page_cursor, 'country_code, 'include, 'share_code>(
&self,
id: &'id str,
page_cursor: Option<&'page_cursor str>,
country_code: Option<&'country_code str>,
include: Option<Vec<String>>,
share_code: Option<&'share_code str>,
) -> Result<models::TracksMultiRelationshipDataDocument, Error<GetTrackSimilarTracksError>>;
#[cfg(feature = "internal")]
async fn get_track_track_source_file<'id, 'include, 'share_code>(
&self,
id: &'id str,
include: Option<Vec<String>>,
share_code: Option<&'share_code str>,
) -> Result<models::TracksSingleRelationshipDataDocument, Error<GetTrackTrackSourceFileError>>;
#[cfg(feature = "internal")]
async fn get_track_track_statistics<'id, 'include, 'share_code>(
&self,
id: &'id str,
include: Option<Vec<String>>,
share_code: Option<&'share_code str>,
) -> Result<models::TracksSingleRelationshipDataDocument, Error<GetTrackTrackStatisticsError>>;
async fn get_tracks<
'page_cursor,
'country_code,
'include,
'filter_left_square_bracket_id_right_square_bracket,
'filter_left_square_bracket_isrc_right_square_bracket,
'filter_left_square_bracket_owners_id_right_square_bracket,
'share_code,
>(
&self,
page_cursor: Option<&'page_cursor str>,
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_isrc_right_square_bracket: Option<Vec<String>>,
filter_left_square_bracket_owners_id_right_square_bracket: Option<Vec<String>>,
share_code: Option<&'share_code str>,
) -> Result<models::TracksMultiResourceDataDocument, Error<GetTracksError>>;
#[cfg(feature = "internal")]
async fn patch_track<'id, 'track_update_operation_payload>(
&self,
id: &'id str,
track_update_operation_payload: Option<models::TrackUpdateOperationPayload>,
) -> Result<(), Error<PatchTrackError>>;
#[cfg(feature = "internal")]
async fn patch_track_albums<'id, 'track_albums_relationship_update_operation_payload>(
&self,
id: &'id str,
track_albums_relationship_update_operation_payload: Option<
models::TrackAlbumsRelationshipUpdateOperationPayload,
>,
) -> Result<(), Error<PatchTrackAlbumsError>>;
#[cfg(feature = "internal")]
async fn patch_track_artists<'id, 'page_cursor, 'country_code, 'include, 'share_code>(
&self,
id: &'id str,
page_cursor: Option<&'page_cursor str>,
country_code: Option<&'country_code str>,
include: Option<Vec<String>>,
share_code: Option<&'share_code str>,
) -> Result<models::TracksMultiRelationshipDataDocument, Error<PatchTrackArtistsError>>;
}
#[derive(Clone)]
pub struct TracksApiClient {
configuration: Arc<configuration::Configuration>,
}
impl TracksApiClient {
pub fn new(configuration: Arc<configuration::Configuration>) -> Self {
Self { configuration }
}
}
#[async_trait]
impl TracksApi for TracksApiClient {
#[cfg(feature = "internal")]
async fn create_track<'track_create_operation_payload>(
&self,
track_create_operation_payload: Option<models::TrackCreateOperationPayload>,
) -> Result<models::TracksSingleResourceDataDocument, Error<CreateTrackError>> {
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!("{}/tracks", 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 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(&track_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::TracksSingleResourceDataDocument`"))),
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::TracksSingleResourceDataDocument`")))),
}
} else {
let local_var_entity: Option<CreateTrackError> =
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))
}
}
#[cfg(feature = "internal")]
async fn delete_track<'id>(&self, id: &'id str) -> Result<(), Error<DeleteTrackError>> {
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/tracks/{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<DeleteTrackError> =
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_track<'id, 'country_code, 'include, 'share_code>(
&self,
id: &'id str,
country_code: Option<&'country_code str>,
include: Option<Vec<String>>,
share_code: Option<&'share_code str>,
) -> Result<models::TracksSingleResourceDataDocument, Error<GetTrackError>> {
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/tracks/{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 param_value) = share_code {
local_var_req_builder =
local_var_req_builder.query(&[("shareCode", ¶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::TracksSingleResourceDataDocument`"))),
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::TracksSingleResourceDataDocument`")))),
}
} else {
let local_var_entity: Option<GetTrackError> =
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_track_albums<'id, 'country_code, 'include, 'page_cursor, 'share_code>(
&self,
id: &'id str,
country_code: Option<&'country_code str>,
include: Option<Vec<String>>,
page_cursor: Option<&'page_cursor str>,
share_code: Option<&'share_code str>,
) -> Result<models::TracksMultiRelationshipDataDocument, Error<GetTrackAlbumsError>> {
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/tracks/{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) = 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 param_value) = share_code {
local_var_req_builder =
local_var_req_builder.query(&[("shareCode", ¶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::TracksMultiRelationshipDataDocument`"))),
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::TracksMultiRelationshipDataDocument`")))),
}
} else {
let local_var_entity: Option<GetTrackAlbumsError> =
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))
}
}
#[cfg(feature = "internal")]
async fn get_track_genres<'id, 'country_code, 'include, 'page_cursor, 'share_code>(
&self,
id: &'id str,
country_code: Option<&'country_code str>,
include: Option<Vec<String>>,
page_cursor: Option<&'page_cursor str>,
share_code: Option<&'share_code str>,
) -> Result<models::TracksMultiRelationshipDataDocument, Error<GetTrackGenresError>> {
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/tracks/{id}/relationships/genres",
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 param_value) = share_code {
local_var_req_builder =
local_var_req_builder.query(&[("shareCode", ¶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::TracksMultiRelationshipDataDocument`"))),
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::TracksMultiRelationshipDataDocument`")))),
}
} else {
let local_var_entity: Option<GetTrackGenresError> =
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))
}
}
#[cfg(feature = "internal")]
async fn get_track_lyrics<'id, 'include, 'page_cursor, 'share_code>(
&self,
id: &'id str,
include: Option<Vec<String>>,
page_cursor: Option<&'page_cursor str>,
share_code: Option<&'share_code str>,
) -> Result<models::TracksMultiRelationshipDataDocument, Error<GetTrackLyricsError>> {
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/tracks/{id}/relationships/lyrics",
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 param_value) = share_code {
local_var_req_builder =
local_var_req_builder.query(&[("shareCode", ¶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::TracksMultiRelationshipDataDocument`"))),
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::TracksMultiRelationshipDataDocument`")))),
}
} else {
let local_var_entity: Option<GetTrackLyricsError> =
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_track_owners<'id, 'include, 'page_cursor, 'share_code>(
&self,
id: &'id str,
include: Option<Vec<String>>,
page_cursor: Option<&'page_cursor str>,
share_code: Option<&'share_code str>,
) -> Result<models::TracksMultiRelationshipDataDocument, Error<GetTrackOwnersError>> {
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/tracks/{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 param_value) = share_code {
local_var_req_builder =
local_var_req_builder.query(&[("shareCode", ¶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::TracksMultiRelationshipDataDocument`"))),
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::TracksMultiRelationshipDataDocument`")))),
}
} else {
let local_var_entity: Option<GetTrackOwnersError> =
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_track_providers<'id, 'country_code, 'include, 'page_cursor, 'share_code>(
&self,
id: &'id str,
country_code: Option<&'country_code str>,
include: Option<Vec<String>>,
page_cursor: Option<&'page_cursor str>,
share_code: Option<&'share_code str>,
) -> Result<models::TracksMultiRelationshipDataDocument, Error<GetTrackProvidersError>> {
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/tracks/{id}/relationships/providers",
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 param_value) = share_code {
local_var_req_builder =
local_var_req_builder.query(&[("shareCode", ¶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::TracksMultiRelationshipDataDocument`"))),
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::TracksMultiRelationshipDataDocument`")))),
}
} else {
let local_var_entity: Option<GetTrackProvidersError> =
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_track_radio<'id, 'include, 'page_cursor, 'share_code>(
&self,
id: &'id str,
include: Option<Vec<String>>,
page_cursor: Option<&'page_cursor str>,
share_code: Option<&'share_code str>,
) -> Result<models::TracksMultiRelationshipDataDocument, Error<GetTrackRadioError>> {
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/tracks/{id}/relationships/radio",
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 param_value) = share_code {
local_var_req_builder =
local_var_req_builder.query(&[("shareCode", ¶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::TracksMultiRelationshipDataDocument`"))),
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::TracksMultiRelationshipDataDocument`")))),
}
} else {
let local_var_entity: Option<GetTrackRadioError> =
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))
}
}
#[cfg(feature = "internal")]
async fn get_track_replacement_relationship<'id, 'country_code, 'include, 'share_code>(
&self,
id: &'id str,
country_code: Option<&'country_code str>,
include: Option<Vec<String>>,
share_code: Option<&'share_code str>,
) -> Result<
models::TracksSingleRelationshipDataDocument,
Error<GetTrackReplacementRelationshipError>,
> {
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/tracks/{id}/relationships/replacement",
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) = share_code {
local_var_req_builder =
local_var_req_builder.query(&[("shareCode", ¶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::TracksSingleRelationshipDataDocument`"))),
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::TracksSingleRelationshipDataDocument`")))),
}
} else {
let local_var_entity: Option<GetTrackReplacementRelationshipError> =
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))
}
}
#[cfg(feature = "internal")]
async fn get_track_shares<'id, 'include, 'page_cursor, 'share_code>(
&self,
id: &'id str,
include: Option<Vec<String>>,
page_cursor: Option<&'page_cursor str>,
share_code: Option<&'share_code str>,
) -> Result<models::TracksMultiRelationshipDataDocument, Error<GetTrackSharesError>> {
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/tracks/{id}/relationships/shares",
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 param_value) = share_code {
local_var_req_builder =
local_var_req_builder.query(&[("shareCode", ¶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::TracksMultiRelationshipDataDocument`"))),
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::TracksMultiRelationshipDataDocument`")))),
}
} else {
let local_var_entity: Option<GetTrackSharesError> =
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_track_similar_tracks<'id, 'page_cursor, 'country_code, 'include, 'share_code>(
&self,
id: &'id str,
page_cursor: Option<&'page_cursor str>,
country_code: Option<&'country_code str>,
include: Option<Vec<String>>,
share_code: Option<&'share_code str>,
) -> Result<models::TracksMultiRelationshipDataDocument, Error<GetTrackSimilarTracksError>>
{
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/tracks/{id}/relationships/similarTracks",
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 param_value) = share_code {
local_var_req_builder =
local_var_req_builder.query(&[("shareCode", ¶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::TracksMultiRelationshipDataDocument`"))),
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::TracksMultiRelationshipDataDocument`")))),
}
} else {
let local_var_entity: Option<GetTrackSimilarTracksError> =
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))
}
}
#[cfg(feature = "internal")]
async fn get_track_track_source_file<'id, 'include, 'share_code>(
&self,
id: &'id str,
include: Option<Vec<String>>,
share_code: Option<&'share_code str>,
) -> Result<models::TracksSingleRelationshipDataDocument, Error<GetTrackTrackSourceFileError>>
{
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/tracks/{id}/relationships/sourceFile",
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) = share_code {
local_var_req_builder =
local_var_req_builder.query(&[("shareCode", ¶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::TracksSingleRelationshipDataDocument`"))),
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::TracksSingleRelationshipDataDocument`")))),
}
} else {
let local_var_entity: Option<GetTrackTrackSourceFileError> =
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))
}
}
#[cfg(feature = "internal")]
async fn get_track_track_statistics<'id, 'include, 'share_code>(
&self,
id: &'id str,
include: Option<Vec<String>>,
share_code: Option<&'share_code str>,
) -> Result<models::TracksSingleRelationshipDataDocument, Error<GetTrackTrackStatisticsError>>
{
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/tracks/{id}/relationships/trackStatistics",
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) = share_code {
local_var_req_builder =
local_var_req_builder.query(&[("shareCode", ¶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::TracksSingleRelationshipDataDocument`"))),
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::TracksSingleRelationshipDataDocument`")))),
}
} else {
let local_var_entity: Option<GetTrackTrackStatisticsError> =
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_tracks<
'page_cursor,
'country_code,
'include,
'filter_left_square_bracket_id_right_square_bracket,
'filter_left_square_bracket_isrc_right_square_bracket,
'filter_left_square_bracket_owners_id_right_square_bracket,
'share_code,
>(
&self,
page_cursor: Option<&'page_cursor str>,
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_isrc_right_square_bracket: Option<Vec<String>>,
filter_left_square_bracket_owners_id_right_square_bracket: Option<Vec<String>>,
share_code: Option<&'share_code str>,
) -> Result<models::TracksMultiResourceDataDocument, Error<GetTracksError>> {
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!("{}/tracks", 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) = 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_isrc_right_square_bracket {
local_var_req_builder = match "multi" {
"multi" => local_var_req_builder.query(
¶m_value
.into_iter()
.map(|p| ("filter[isrc]".to_owned(), p.to_string()))
.collect::<Vec<(std::string::String, std::string::String)>>(),
),
_ => local_var_req_builder.query(&[(
"filter[isrc]",
¶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 param_value) = share_code {
local_var_req_builder =
local_var_req_builder.query(&[("shareCode", ¶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::TracksMultiResourceDataDocument`"))),
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::TracksMultiResourceDataDocument`")))),
}
} else {
let local_var_entity: Option<GetTracksError> =
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))
}
}
#[cfg(feature = "internal")]
async fn patch_track<'id, 'track_update_operation_payload>(
&self,
id: &'id str,
track_update_operation_payload: Option<models::TrackUpdateOperationPayload>,
) -> Result<(), Error<PatchTrackError>> {
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/tracks/{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 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(&track_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<PatchTrackError> =
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))
}
}
#[cfg(feature = "internal")]
async fn patch_track_albums<'id, 'track_albums_relationship_update_operation_payload>(
&self,
id: &'id str,
track_albums_relationship_update_operation_payload: Option<
models::TrackAlbumsRelationshipUpdateOperationPayload,
>,
) -> Result<(), Error<PatchTrackAlbumsError>> {
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/tracks/{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::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(&track_albums_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<PatchTrackAlbumsError> =
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))
}
}
#[cfg(feature = "internal")]
async fn patch_track_artists<'id, 'page_cursor, 'country_code, 'include, 'share_code>(
&self,
id: &'id str,
page_cursor: Option<&'page_cursor str>,
country_code: Option<&'country_code str>,
include: Option<Vec<String>>,
share_code: Option<&'share_code str>,
) -> Result<models::TracksMultiRelationshipDataDocument, Error<PatchTrackArtistsError>> {
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/tracks/{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) = 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) = share_code {
local_var_req_builder =
local_var_req_builder.query(&[("shareCode", ¶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::TracksMultiRelationshipDataDocument`"))),
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::TracksMultiRelationshipDataDocument`")))),
}
} else {
let local_var_entity: Option<PatchTrackArtistsError> =
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)]
#[cfg(feature = "internal")]
pub enum CreateTrackError {
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)]
#[cfg(feature = "internal")]
pub enum DeleteTrackError {
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 GetTrackError {
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 GetTrackAlbumsError {
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)]
#[cfg(feature = "internal")]
pub enum GetTrackGenresError {
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)]
#[cfg(feature = "internal")]
pub enum GetTrackLyricsError {
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 GetTrackOwnersError {
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 GetTrackProvidersError {
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 GetTrackRadioError {
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)]
#[cfg(feature = "internal")]
pub enum GetTrackReplacementRelationshipError {
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)]
#[cfg(feature = "internal")]
pub enum GetTrackSharesError {
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 GetTrackSimilarTracksError {
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)]
#[cfg(feature = "internal")]
pub enum GetTrackTrackSourceFileError {
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)]
#[cfg(feature = "internal")]
pub enum GetTrackTrackStatisticsError {
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 GetTracksError {
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)]
#[cfg(feature = "internal")]
pub enum PatchTrackError {
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)]
#[cfg(feature = "internal")]
pub enum PatchTrackAlbumsError {
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)]
#[cfg(feature = "internal")]
pub enum PatchTrackArtistsError {
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),
}