use {
super::{Error, configuration},
crate::{
apis::{ContentType, ResponseContent},
models,
},
async_trait::async_trait,
reqwest,
serde::{Deserialize, Serialize, de::Error as _},
std::sync::Arc,
};
#[async_trait]
pub trait NftsApi: Send + Sync {
async fn get_nft(
&self,
params: GetNftParams,
) -> Result<models::TokenResponse, Error<GetNftError>>;
async fn get_nfts(
&self,
params: GetNftsParams,
) -> Result<models::GetNftsResponse, Error<GetNftsError>>;
async fn get_ownership_tokens(
&self,
params: GetOwnershipTokensParams,
) -> Result<models::GetOwnershipTokensResponse, Error<GetOwnershipTokensError>>;
async fn list_owned_collections(
&self,
params: ListOwnedCollectionsParams,
) -> Result<models::ListOwnedCollectionsResponse, Error<ListOwnedCollectionsError>>;
async fn list_owned_tokens(
&self,
params: ListOwnedTokensParams,
) -> Result<models::ListOwnedTokensResponse, Error<ListOwnedTokensError>>;
async fn refresh_nft_metadata(
&self,
params: RefreshNftMetadataParams,
) -> Result<(), Error<RefreshNftMetadataError>>;
async fn update_ownership_tokens(
&self,
params: UpdateOwnershipTokensParams,
) -> Result<(), Error<UpdateOwnershipTokensError>>;
async fn update_token_ownership_status(
&self,
params: UpdateTokenOwnershipStatusParams,
) -> Result<(), Error<UpdateTokenOwnershipStatusError>>;
async fn update_tokens_ownership_spam(
&self,
params: UpdateTokensOwnershipSpamParams,
) -> Result<(), Error<UpdateTokensOwnershipSpamError>>;
async fn update_tokens_ownership_status(
&self,
params: UpdateTokensOwnershipStatusParams,
) -> Result<(), Error<UpdateTokensOwnershipStatusError>>;
}
pub struct NftsApiClient {
configuration: Arc<configuration::Configuration>,
}
impl NftsApiClient {
pub fn new(configuration: Arc<configuration::Configuration>) -> Self {
Self { configuration }
}
}
#[derive(Clone, Debug)]
#[cfg_attr(feature = "bon", derive(::bon::Builder))]
pub struct GetNftParams {
pub id: String,
}
#[derive(Clone, Debug)]
#[cfg_attr(feature = "bon", derive(::bon::Builder))]
pub struct GetNftsParams {
pub ids: String,
pub page_cursor: Option<String>,
pub page_size: Option<f64>,
pub sort: Option<Vec<String>>,
pub order: Option<String>,
}
#[derive(Clone, Debug)]
#[cfg_attr(feature = "bon", derive(::bon::Builder))]
pub struct GetOwnershipTokensParams {
pub blockchain_descriptor: Option<String>,
pub vault_account_ids: Option<String>,
pub ncw_id: Option<String>,
pub ncw_account_ids: Option<String>,
pub wallet_type: Option<String>,
pub ids: Option<String>,
pub collection_ids: Option<String>,
pub page_cursor: Option<String>,
pub page_size: Option<f64>,
pub sort: Option<Vec<String>>,
pub order: Option<String>,
pub status: Option<String>,
pub search: Option<String>,
pub spam: Option<String>,
}
#[derive(Clone, Debug)]
#[cfg_attr(feature = "bon", derive(::bon::Builder))]
pub struct ListOwnedCollectionsParams {
pub ncw_id: Option<String>,
pub wallet_type: Option<String>,
pub search: Option<String>,
pub page_cursor: Option<String>,
pub page_size: Option<f64>,
pub sort: Option<Vec<String>>,
pub order: Option<String>,
pub status: Option<String>,
}
#[derive(Clone, Debug)]
#[cfg_attr(feature = "bon", derive(::bon::Builder))]
pub struct ListOwnedTokensParams {
pub ncw_id: Option<String>,
pub wallet_type: Option<String>,
pub page_cursor: Option<String>,
pub page_size: Option<f64>,
pub sort: Option<Vec<String>>,
pub order: Option<String>,
pub status: Option<String>,
pub search: Option<String>,
pub spam: Option<String>,
}
#[derive(Clone, Debug)]
#[cfg_attr(feature = "bon", derive(::bon::Builder))]
pub struct RefreshNftMetadataParams {
pub id: String,
pub idempotency_key: Option<String>,
}
#[derive(Clone, Debug)]
#[cfg_attr(feature = "bon", derive(::bon::Builder))]
pub struct UpdateOwnershipTokensParams {
pub blockchain_descriptor: String,
pub vault_account_id: String,
pub idempotency_key: Option<String>,
}
#[derive(Clone, Debug)]
#[cfg_attr(feature = "bon", derive(::bon::Builder))]
pub struct UpdateTokenOwnershipStatusParams {
pub id: String,
pub update_token_ownership_status_dto: models::UpdateTokenOwnershipStatusDto,
pub idempotency_key: Option<String>,
}
#[derive(Clone, Debug)]
#[cfg_attr(feature = "bon", derive(::bon::Builder))]
pub struct UpdateTokensOwnershipSpamParams {
pub token_ownership_spam_update_payload: Vec<models::TokenOwnershipSpamUpdatePayload>,
pub idempotency_key: Option<String>,
}
#[derive(Clone, Debug)]
#[cfg_attr(feature = "bon", derive(::bon::Builder))]
pub struct UpdateTokensOwnershipStatusParams {
pub token_ownership_status_update_payload: Vec<models::TokenOwnershipStatusUpdatePayload>,
pub idempotency_key: Option<String>,
}
#[async_trait]
impl NftsApi for NftsApiClient {
async fn get_nft(
&self,
params: GetNftParams,
) -> Result<models::TokenResponse, Error<GetNftError>> {
let GetNftParams { id } = params;
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/nfts/tokens/{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 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());
}
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 => {
crate::deserialize_wrapper(&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::TokenResponse`",
)));
}
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::TokenResponse`"
))));
}
}
} else {
let local_var_entity: Option<GetNftError> =
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_nfts(
&self,
params: GetNftsParams,
) -> Result<models::GetNftsResponse, Error<GetNftsError>> {
let GetNftsParams {
ids,
page_cursor,
page_size,
sort,
order,
} = params;
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!("{}/nfts/tokens", local_var_configuration.base_path);
let mut local_var_req_builder =
local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
local_var_req_builder = local_var_req_builder.query(&[("ids", &ids.to_string())]);
if let Some(ref param_value) = page_cursor {
local_var_req_builder =
local_var_req_builder.query(&[("pageCursor", ¶m_value.to_string())]);
}
if let Some(ref param_value) = page_size {
local_var_req_builder =
local_var_req_builder.query(&[("pageSize", ¶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) = order {
local_var_req_builder =
local_var_req_builder.query(&[("order", ¶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());
}
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 => {
crate::deserialize_wrapper(&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::GetNftsResponse`",
)));
}
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::GetNftsResponse`"
))));
}
}
} else {
let local_var_entity: Option<GetNftsError> =
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_ownership_tokens(
&self,
params: GetOwnershipTokensParams,
) -> Result<models::GetOwnershipTokensResponse, Error<GetOwnershipTokensError>> {
let GetOwnershipTokensParams {
blockchain_descriptor,
vault_account_ids,
ncw_id,
ncw_account_ids,
wallet_type,
ids,
collection_ids,
page_cursor,
page_size,
sort,
order,
status,
search,
spam,
} = params;
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/nfts/ownership/tokens",
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) = blockchain_descriptor {
local_var_req_builder =
local_var_req_builder.query(&[("blockchainDescriptor", ¶m_value.to_string())]);
}
if let Some(ref param_value) = vault_account_ids {
local_var_req_builder =
local_var_req_builder.query(&[("vaultAccountIds", ¶m_value.to_string())]);
}
if let Some(ref param_value) = ncw_id {
local_var_req_builder =
local_var_req_builder.query(&[("ncwId", ¶m_value.to_string())]);
}
if let Some(ref param_value) = ncw_account_ids {
local_var_req_builder =
local_var_req_builder.query(&[("ncwAccountIds", ¶m_value.to_string())]);
}
if let Some(ref param_value) = wallet_type {
local_var_req_builder =
local_var_req_builder.query(&[("walletType", ¶m_value.to_string())]);
}
if let Some(ref param_value) = ids {
local_var_req_builder =
local_var_req_builder.query(&[("ids", ¶m_value.to_string())]);
}
if let Some(ref param_value) = collection_ids {
local_var_req_builder =
local_var_req_builder.query(&[("collectionIds", ¶m_value.to_string())]);
}
if let Some(ref param_value) = page_cursor {
local_var_req_builder =
local_var_req_builder.query(&[("pageCursor", ¶m_value.to_string())]);
}
if let Some(ref param_value) = page_size {
local_var_req_builder =
local_var_req_builder.query(&[("pageSize", ¶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) = order {
local_var_req_builder =
local_var_req_builder.query(&[("order", ¶m_value.to_string())]);
}
if let Some(ref param_value) = status {
local_var_req_builder =
local_var_req_builder.query(&[("status", ¶m_value.to_string())]);
}
if let Some(ref param_value) = search {
local_var_req_builder =
local_var_req_builder.query(&[("search", ¶m_value.to_string())]);
}
if let Some(ref param_value) = spam {
local_var_req_builder =
local_var_req_builder.query(&[("spam", ¶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());
}
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 => {
crate::deserialize_wrapper(&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::GetOwnershipTokensResponse`",
)));
}
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::GetOwnershipTokensResponse`"
))));
}
}
} else {
let local_var_entity: Option<GetOwnershipTokensError> =
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 list_owned_collections(
&self,
params: ListOwnedCollectionsParams,
) -> Result<models::ListOwnedCollectionsResponse, Error<ListOwnedCollectionsError>> {
let ListOwnedCollectionsParams {
ncw_id,
wallet_type,
search,
page_cursor,
page_size,
sort,
order,
status,
} = params;
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/nfts/ownership/collections",
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) = ncw_id {
local_var_req_builder =
local_var_req_builder.query(&[("ncwId", ¶m_value.to_string())]);
}
if let Some(ref param_value) = wallet_type {
local_var_req_builder =
local_var_req_builder.query(&[("walletType", ¶m_value.to_string())]);
}
if let Some(ref param_value) = search {
local_var_req_builder =
local_var_req_builder.query(&[("search", ¶m_value.to_string())]);
}
if let Some(ref param_value) = page_cursor {
local_var_req_builder =
local_var_req_builder.query(&[("pageCursor", ¶m_value.to_string())]);
}
if let Some(ref param_value) = page_size {
local_var_req_builder =
local_var_req_builder.query(&[("pageSize", ¶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) = order {
local_var_req_builder =
local_var_req_builder.query(&[("order", ¶m_value.to_string())]);
}
if let Some(ref param_value) = status {
local_var_req_builder =
local_var_req_builder.query(&[("status", ¶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());
}
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 => {
crate::deserialize_wrapper(&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::ListOwnedCollectionsResponse`",
)));
}
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::ListOwnedCollectionsResponse`"
))));
}
}
} else {
let local_var_entity: Option<ListOwnedCollectionsError> =
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 list_owned_tokens(
&self,
params: ListOwnedTokensParams,
) -> Result<models::ListOwnedTokensResponse, Error<ListOwnedTokensError>> {
let ListOwnedTokensParams {
ncw_id,
wallet_type,
page_cursor,
page_size,
sort,
order,
status,
search,
spam,
} = params;
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/nfts/ownership/assets",
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) = ncw_id {
local_var_req_builder =
local_var_req_builder.query(&[("ncwId", ¶m_value.to_string())]);
}
if let Some(ref param_value) = wallet_type {
local_var_req_builder =
local_var_req_builder.query(&[("walletType", ¶m_value.to_string())]);
}
if let Some(ref param_value) = page_cursor {
local_var_req_builder =
local_var_req_builder.query(&[("pageCursor", ¶m_value.to_string())]);
}
if let Some(ref param_value) = page_size {
local_var_req_builder =
local_var_req_builder.query(&[("pageSize", ¶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) = order {
local_var_req_builder =
local_var_req_builder.query(&[("order", ¶m_value.to_string())]);
}
if let Some(ref param_value) = status {
local_var_req_builder =
local_var_req_builder.query(&[("status", ¶m_value.to_string())]);
}
if let Some(ref param_value) = search {
local_var_req_builder =
local_var_req_builder.query(&[("search", ¶m_value.to_string())]);
}
if let Some(ref param_value) = spam {
local_var_req_builder =
local_var_req_builder.query(&[("spam", ¶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());
}
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 => {
crate::deserialize_wrapper(&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::ListOwnedTokensResponse`",
)));
}
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::ListOwnedTokensResponse`"
))));
}
}
} else {
let local_var_entity: Option<ListOwnedTokensError> =
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 refresh_nft_metadata(
&self,
params: RefreshNftMetadataParams,
) -> Result<(), Error<RefreshNftMetadataError>> {
let RefreshNftMetadataParams {
id,
idempotency_key,
} = params;
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/nfts/tokens/{id}",
local_var_configuration.base_path,
id = crate::apis::urlencode(id)
);
let mut local_var_req_builder =
local_var_client.request(reqwest::Method::PUT, 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(local_var_param_value) = idempotency_key {
local_var_req_builder =
local_var_req_builder.header("Idempotency-Key", local_var_param_value.to_string());
}
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<RefreshNftMetadataError> =
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 update_ownership_tokens(
&self,
params: UpdateOwnershipTokensParams,
) -> Result<(), Error<UpdateOwnershipTokensError>> {
let UpdateOwnershipTokensParams {
blockchain_descriptor,
vault_account_id,
idempotency_key,
} = params;
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/nfts/ownership/tokens",
local_var_configuration.base_path
);
let mut local_var_req_builder =
local_var_client.request(reqwest::Method::PUT, local_var_uri_str.as_str());
local_var_req_builder = local_var_req_builder
.query(&[("blockchainDescriptor", &blockchain_descriptor.to_string())]);
local_var_req_builder =
local_var_req_builder.query(&[("vaultAccountId", &vault_account_id.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(local_var_param_value) = idempotency_key {
local_var_req_builder =
local_var_req_builder.header("Idempotency-Key", local_var_param_value.to_string());
}
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<UpdateOwnershipTokensError> =
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 update_token_ownership_status(
&self,
params: UpdateTokenOwnershipStatusParams,
) -> Result<(), Error<UpdateTokenOwnershipStatusError>> {
let UpdateTokenOwnershipStatusParams {
id,
update_token_ownership_status_dto,
idempotency_key,
} = params;
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/nfts/ownership/tokens/{id}/status",
local_var_configuration.base_path,
id = crate::apis::urlencode(id)
);
let mut local_var_req_builder =
local_var_client.request(reqwest::Method::PUT, 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(local_var_param_value) = idempotency_key {
local_var_req_builder =
local_var_req_builder.header("Idempotency-Key", local_var_param_value.to_string());
}
local_var_req_builder = local_var_req_builder.json(&update_token_ownership_status_dto);
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<UpdateTokenOwnershipStatusError> =
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 update_tokens_ownership_spam(
&self,
params: UpdateTokensOwnershipSpamParams,
) -> Result<(), Error<UpdateTokensOwnershipSpamError>> {
let UpdateTokensOwnershipSpamParams {
token_ownership_spam_update_payload,
idempotency_key,
} = params;
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/nfts/ownership/tokens/spam",
local_var_configuration.base_path
);
let mut local_var_req_builder =
local_var_client.request(reqwest::Method::PUT, 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(local_var_param_value) = idempotency_key {
local_var_req_builder =
local_var_req_builder.header("Idempotency-Key", local_var_param_value.to_string());
}
local_var_req_builder = local_var_req_builder.json(&token_ownership_spam_update_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<UpdateTokensOwnershipSpamError> =
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 update_tokens_ownership_status(
&self,
params: UpdateTokensOwnershipStatusParams,
) -> Result<(), Error<UpdateTokensOwnershipStatusError>> {
let UpdateTokensOwnershipStatusParams {
token_ownership_status_update_payload,
idempotency_key,
} = params;
let local_var_configuration = &self.configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/nfts/ownership/tokens/status",
local_var_configuration.base_path
);
let mut local_var_req_builder =
local_var_client.request(reqwest::Method::PUT, 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(local_var_param_value) = idempotency_key {
local_var_req_builder =
local_var_req_builder.header("Idempotency-Key", local_var_param_value.to_string());
}
local_var_req_builder = local_var_req_builder.json(&token_ownership_status_update_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<UpdateTokensOwnershipStatusError> =
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 GetNftError {
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum GetNftsError {
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum GetOwnershipTokensError {
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum ListOwnedCollectionsError {
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum ListOwnedTokensError {
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum RefreshNftMetadataError {
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum UpdateOwnershipTokensError {
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum UpdateTokenOwnershipStatusError {
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum UpdateTokensOwnershipSpamError {
Status400(),
Status404(),
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum UpdateTokensOwnershipStatusError {
Status400(),
Status404(),
UnknownValue(serde_json::Value),
}