use reqwest;
use super::{Error, configuration};
use crate::apis::ResponseContent;
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum LookupAccountAppLocalStatesError {
Status400(algonaut_model::indexer::ErrorResponse),
Status404(algonaut_model::indexer::ErrorResponse),
Status500(algonaut_model::indexer::ErrorResponse),
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum LookupAccountAssetsError {
Status400(algonaut_model::indexer::ErrorResponse),
Status404(algonaut_model::indexer::ErrorResponse),
Status500(algonaut_model::indexer::ErrorResponse),
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum LookupAccountByIdError {
Status400(algonaut_model::indexer::ErrorResponse),
Status404(algonaut_model::indexer::ErrorResponse),
Status500(algonaut_model::indexer::ErrorResponse),
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum LookupAccountCreatedApplicationsError {
Status400(algonaut_model::indexer::ErrorResponse),
Status404(algonaut_model::indexer::ErrorResponse),
Status500(algonaut_model::indexer::ErrorResponse),
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum LookupAccountCreatedAssetsError {
Status400(algonaut_model::indexer::ErrorResponse),
Status404(algonaut_model::indexer::ErrorResponse),
Status500(algonaut_model::indexer::ErrorResponse),
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum LookupAccountTransactionsError {
Status400(algonaut_model::indexer::ErrorResponse),
Status500(algonaut_model::indexer::ErrorResponse),
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum LookupApplicationBoxByIdAndNameError {
Status400(algonaut_model::indexer::ErrorResponse),
Status404(algonaut_model::indexer::ErrorResponse),
Status500(algonaut_model::indexer::ErrorResponse),
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum LookupApplicationByIdError {
Status404(algonaut_model::indexer::ErrorResponse),
Status500(algonaut_model::indexer::ErrorResponse),
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum LookupApplicationLogsByIdError {
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum LookupAssetBalancesError {
Status400(algonaut_model::indexer::ErrorResponse),
Status500(algonaut_model::indexer::ErrorResponse),
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum LookupAssetByIdError {
Status400(algonaut_model::indexer::ErrorResponse),
Status404(algonaut_model::indexer::ErrorResponse),
Status500(algonaut_model::indexer::ErrorResponse),
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum LookupAssetTransactionsError {
Status400(algonaut_model::indexer::ErrorResponse),
Status500(algonaut_model::indexer::ErrorResponse),
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum LookupBlockError {
Status404(algonaut_model::indexer::ErrorResponse),
Status500(algonaut_model::indexer::ErrorResponse),
UnknownValue(serde_json::Value),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum LookupTransactionError {
Status400(algonaut_model::indexer::ErrorResponse),
Status404(algonaut_model::indexer::ErrorResponse),
Status500(algonaut_model::indexer::ErrorResponse),
UnknownValue(serde_json::Value),
}
pub async fn lookup_account_app_local_states(
configuration: &configuration::Configuration,
account_id: &str,
application_id: Option<u64>,
include_all: Option<bool>,
limit: Option<u64>,
next: Option<&str>,
) -> Result<
algonaut_model::indexer::AccountApplicationLocalStatesResponse,
Error<LookupAccountAppLocalStatesError>,
> {
let local_var_configuration = configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/v2/accounts/{account_id}/apps-local-state",
local_var_configuration.base_path,
account_id = crate::apis::urlencode(account_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_str) = application_id {
local_var_req_builder =
local_var_req_builder.query(&[("application-id", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = include_all {
local_var_req_builder =
local_var_req_builder.query(&[("include-all", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = limit {
local_var_req_builder =
local_var_req_builder.query(&[("limit", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = next {
local_var_req_builder =
local_var_req_builder.query(&[("next", &local_var_str.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 = local_var_resp.text().await?;
if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
serde_json::from_str(&local_var_content).map_err(Error::from)
} else {
let local_var_entity: Option<LookupAccountAppLocalStatesError> =
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))
}
}
pub async fn lookup_account_assets(
configuration: &configuration::Configuration,
account_id: &str,
asset_id: Option<u64>,
include_all: Option<bool>,
limit: Option<u64>,
next: Option<&str>,
) -> Result<algonaut_model::indexer::AccountAssetsResponse, Error<LookupAccountAssetsError>> {
let local_var_configuration = configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/v2/accounts/{account_id}/assets",
local_var_configuration.base_path,
account_id = crate::apis::urlencode(account_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_str) = asset_id {
local_var_req_builder =
local_var_req_builder.query(&[("asset-id", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = include_all {
local_var_req_builder =
local_var_req_builder.query(&[("include-all", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = limit {
local_var_req_builder =
local_var_req_builder.query(&[("limit", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = next {
local_var_req_builder =
local_var_req_builder.query(&[("next", &local_var_str.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 = local_var_resp.text().await?;
if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
serde_json::from_str(&local_var_content).map_err(Error::from)
} else {
let local_var_entity: Option<LookupAccountAssetsError> =
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))
}
}
pub async fn lookup_account_by_id(
configuration: &configuration::Configuration,
account_id: &str,
round: Option<u64>,
include_all: Option<bool>,
exclude: Option<Vec<String>>,
) -> Result<algonaut_model::indexer::AccountResponse, Error<LookupAccountByIdError>> {
let local_var_configuration = configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/v2/accounts/{account_id}",
local_var_configuration.base_path,
account_id = crate::apis::urlencode(account_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_str) = round {
local_var_req_builder =
local_var_req_builder.query(&[("round", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = include_all {
local_var_req_builder =
local_var_req_builder.query(&[("include-all", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = exclude {
local_var_req_builder = match "csv" {
"multi" => local_var_req_builder.query(
&local_var_str
.iter()
.map(|p| ("exclude".to_owned(), p.to_string()))
.collect::<Vec<(std::string::String, std::string::String)>>(),
),
_ => local_var_req_builder.query(&[(
"exclude",
&local_var_str
.iter()
.map(|p| p.to_string())
.collect::<Vec<String>>()
.join(","),
)]),
};
}
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 = local_var_resp.text().await?;
if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
serde_json::from_str(&local_var_content).map_err(Error::from)
} else {
let local_var_entity: Option<LookupAccountByIdError> =
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))
}
}
pub async fn lookup_account_created_applications(
configuration: &configuration::Configuration,
account_id: &str,
application_id: Option<u64>,
include_all: Option<bool>,
limit: Option<u64>,
next: Option<&str>,
) -> Result<
algonaut_model::indexer::AccountCreatedApplicationsResponse,
Error<LookupAccountCreatedApplicationsError>,
> {
let local_var_configuration = configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/v2/accounts/{account_id}/created-applications",
local_var_configuration.base_path,
account_id = crate::apis::urlencode(account_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_str) = application_id {
local_var_req_builder =
local_var_req_builder.query(&[("application-id", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = include_all {
local_var_req_builder =
local_var_req_builder.query(&[("include-all", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = limit {
local_var_req_builder =
local_var_req_builder.query(&[("limit", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = next {
local_var_req_builder =
local_var_req_builder.query(&[("next", &local_var_str.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 = local_var_resp.text().await?;
if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
serde_json::from_str(&local_var_content).map_err(Error::from)
} else {
let local_var_entity: Option<LookupAccountCreatedApplicationsError> =
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))
}
}
pub async fn lookup_account_created_assets(
configuration: &configuration::Configuration,
account_id: &str,
asset_id: Option<u64>,
include_all: Option<bool>,
limit: Option<u64>,
next: Option<&str>,
) -> Result<
algonaut_model::indexer::AccountCreatedAssetsResponse,
Error<LookupAccountCreatedAssetsError>,
> {
let local_var_configuration = configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/v2/accounts/{account_id}/created-assets",
local_var_configuration.base_path,
account_id = crate::apis::urlencode(account_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_str) = asset_id {
local_var_req_builder =
local_var_req_builder.query(&[("asset-id", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = include_all {
local_var_req_builder =
local_var_req_builder.query(&[("include-all", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = limit {
local_var_req_builder =
local_var_req_builder.query(&[("limit", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = next {
local_var_req_builder =
local_var_req_builder.query(&[("next", &local_var_str.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 = local_var_resp.text().await?;
if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
serde_json::from_str(&local_var_content).map_err(Error::from)
} else {
let local_var_entity: Option<LookupAccountCreatedAssetsError> =
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))
}
}
#[allow(clippy::too_many_arguments)]
pub async fn lookup_account_transactions(
configuration: &configuration::Configuration,
account_id: &str,
limit: Option<u64>,
next: Option<&str>,
note_prefix: Option<&str>,
tx_type: Option<&str>,
sig_type: Option<&str>,
txid: Option<&str>,
round: Option<u64>,
min_round: Option<u64>,
max_round: Option<u64>,
asset_id: Option<u64>,
before_time: Option<String>,
after_time: Option<String>,
currency_greater_than: Option<u64>,
currency_less_than: Option<u64>,
rekey_to: Option<bool>,
) -> Result<
algonaut_model::indexer::AccountTransactionsResponse,
Error<LookupAccountTransactionsError>,
> {
let local_var_configuration = configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/v2/accounts/{account_id}/transactions",
local_var_configuration.base_path,
account_id = crate::apis::urlencode(account_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_str) = limit {
local_var_req_builder =
local_var_req_builder.query(&[("limit", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = next {
local_var_req_builder =
local_var_req_builder.query(&[("next", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = note_prefix {
local_var_req_builder =
local_var_req_builder.query(&[("note-prefix", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = tx_type {
local_var_req_builder =
local_var_req_builder.query(&[("tx-type", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = sig_type {
local_var_req_builder =
local_var_req_builder.query(&[("sig-type", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = txid {
local_var_req_builder =
local_var_req_builder.query(&[("txid", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = round {
local_var_req_builder =
local_var_req_builder.query(&[("round", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = min_round {
local_var_req_builder =
local_var_req_builder.query(&[("min-round", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = max_round {
local_var_req_builder =
local_var_req_builder.query(&[("max-round", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = asset_id {
local_var_req_builder =
local_var_req_builder.query(&[("asset-id", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = before_time {
local_var_req_builder =
local_var_req_builder.query(&[("before-time", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = after_time {
local_var_req_builder =
local_var_req_builder.query(&[("after-time", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = currency_greater_than {
local_var_req_builder =
local_var_req_builder.query(&[("currency-greater-than", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = currency_less_than {
local_var_req_builder =
local_var_req_builder.query(&[("currency-less-than", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = rekey_to {
local_var_req_builder =
local_var_req_builder.query(&[("rekey-to", &local_var_str.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 = local_var_resp.text().await?;
if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
serde_json::from_str(&local_var_content).map_err(Error::from)
} else {
let local_var_entity: Option<LookupAccountTransactionsError> =
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))
}
}
pub async fn lookup_application_box_by_id_and_name(
configuration: &configuration::Configuration,
application_id: u64,
name: &str,
) -> Result<algonaut_model::indexer::Box, Error<LookupApplicationBoxByIdAndNameError>> {
let local_var_configuration = configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/v2/applications/{application_id}/box",
local_var_configuration.base_path,
application_id = application_id
);
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(&[("name", &name.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 = local_var_resp.text().await?;
if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
serde_json::from_str(&local_var_content).map_err(Error::from)
} else {
let local_var_entity: Option<LookupApplicationBoxByIdAndNameError> =
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))
}
}
pub async fn lookup_application_by_id(
configuration: &configuration::Configuration,
application_id: u64,
include_all: Option<bool>,
) -> Result<algonaut_model::indexer::ApplicationResponse, Error<LookupApplicationByIdError>> {
let local_var_configuration = configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/v2/applications/{application_id}",
local_var_configuration.base_path,
application_id = application_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_str) = include_all {
local_var_req_builder =
local_var_req_builder.query(&[("include-all", &local_var_str.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 = local_var_resp.text().await?;
if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
serde_json::from_str(&local_var_content).map_err(Error::from)
} else {
let local_var_entity: Option<LookupApplicationByIdError> =
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))
}
}
#[allow(clippy::too_many_arguments)]
pub async fn lookup_application_logs_by_id(
configuration: &configuration::Configuration,
application_id: u64,
limit: Option<u64>,
next: Option<&str>,
txid: Option<&str>,
min_round: Option<u64>,
max_round: Option<u64>,
sender_address: Option<&str>,
) -> Result<algonaut_model::indexer::ApplicationLogsResponse, Error<LookupApplicationLogsByIdError>>
{
let local_var_configuration = configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/v2/applications/{application_id}/logs",
local_var_configuration.base_path,
application_id = application_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_str) = limit {
local_var_req_builder =
local_var_req_builder.query(&[("limit", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = next {
local_var_req_builder =
local_var_req_builder.query(&[("next", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = txid {
local_var_req_builder =
local_var_req_builder.query(&[("txid", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = min_round {
local_var_req_builder =
local_var_req_builder.query(&[("min-round", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = max_round {
local_var_req_builder =
local_var_req_builder.query(&[("max-round", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = sender_address {
local_var_req_builder =
local_var_req_builder.query(&[("sender-address", &local_var_str.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 = local_var_resp.text().await?;
if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
serde_json::from_str(&local_var_content).map_err(Error::from)
} else {
let local_var_entity: Option<LookupApplicationLogsByIdError> =
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))
}
}
pub async fn lookup_asset_balances(
configuration: &configuration::Configuration,
asset_id: u64,
include_all: Option<bool>,
limit: Option<u64>,
next: Option<&str>,
currency_greater_than: Option<u64>,
currency_less_than: Option<u64>,
) -> Result<algonaut_model::indexer::AssetBalancesResponse, Error<LookupAssetBalancesError>> {
let local_var_configuration = configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/v2/assets/{asset_id}/balances",
local_var_configuration.base_path,
asset_id = asset_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_str) = include_all {
local_var_req_builder =
local_var_req_builder.query(&[("include-all", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = limit {
local_var_req_builder =
local_var_req_builder.query(&[("limit", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = next {
local_var_req_builder =
local_var_req_builder.query(&[("next", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = currency_greater_than {
local_var_req_builder =
local_var_req_builder.query(&[("currency-greater-than", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = currency_less_than {
local_var_req_builder =
local_var_req_builder.query(&[("currency-less-than", &local_var_str.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 = local_var_resp.text().await?;
if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
serde_json::from_str(&local_var_content).map_err(Error::from)
} else {
let local_var_entity: Option<LookupAssetBalancesError> =
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))
}
}
pub async fn lookup_asset_by_id(
configuration: &configuration::Configuration,
asset_id: u64,
include_all: Option<bool>,
) -> Result<algonaut_model::indexer::AssetResponse, Error<LookupAssetByIdError>> {
let local_var_configuration = configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/v2/assets/{asset_id}",
local_var_configuration.base_path,
asset_id = asset_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_str) = include_all {
local_var_req_builder =
local_var_req_builder.query(&[("include-all", &local_var_str.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 = local_var_resp.text().await?;
if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
serde_json::from_str(&local_var_content).map_err(Error::from)
} else {
let local_var_entity: Option<LookupAssetByIdError> =
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))
}
}
#[allow(clippy::too_many_arguments)]
pub async fn lookup_asset_transactions(
configuration: &configuration::Configuration,
asset_id: u64,
limit: Option<u64>,
next: Option<&str>,
note_prefix: Option<&str>,
tx_type: Option<&str>,
sig_type: Option<&str>,
txid: Option<&str>,
round: Option<u64>,
min_round: Option<u64>,
max_round: Option<u64>,
before_time: Option<String>,
after_time: Option<String>,
currency_greater_than: Option<u64>,
currency_less_than: Option<u64>,
address: Option<&str>,
address_role: Option<&str>,
exclude_close_to: Option<bool>,
rekey_to: Option<bool>,
) -> Result<algonaut_model::indexer::AccountTransactionsResponse, Error<LookupAssetTransactionsError>>
{
let local_var_configuration = configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/v2/assets/{asset_id}/transactions",
local_var_configuration.base_path,
asset_id = asset_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_str) = limit {
local_var_req_builder =
local_var_req_builder.query(&[("limit", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = next {
local_var_req_builder =
local_var_req_builder.query(&[("next", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = note_prefix {
local_var_req_builder =
local_var_req_builder.query(&[("note-prefix", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = tx_type {
local_var_req_builder =
local_var_req_builder.query(&[("tx-type", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = sig_type {
local_var_req_builder =
local_var_req_builder.query(&[("sig-type", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = txid {
local_var_req_builder =
local_var_req_builder.query(&[("txid", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = round {
local_var_req_builder =
local_var_req_builder.query(&[("round", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = min_round {
local_var_req_builder =
local_var_req_builder.query(&[("min-round", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = max_round {
local_var_req_builder =
local_var_req_builder.query(&[("max-round", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = before_time {
local_var_req_builder =
local_var_req_builder.query(&[("before-time", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = after_time {
local_var_req_builder =
local_var_req_builder.query(&[("after-time", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = currency_greater_than {
local_var_req_builder =
local_var_req_builder.query(&[("currency-greater-than", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = currency_less_than {
local_var_req_builder =
local_var_req_builder.query(&[("currency-less-than", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = address {
local_var_req_builder =
local_var_req_builder.query(&[("address", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = address_role {
local_var_req_builder =
local_var_req_builder.query(&[("address-role", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = exclude_close_to {
local_var_req_builder =
local_var_req_builder.query(&[("exclude-close-to", &local_var_str.to_string())]);
}
if let Some(ref local_var_str) = rekey_to {
local_var_req_builder =
local_var_req_builder.query(&[("rekey-to", &local_var_str.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 = local_var_resp.text().await?;
if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
serde_json::from_str(&local_var_content).map_err(Error::from)
} else {
let local_var_entity: Option<LookupAssetTransactionsError> =
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))
}
}
pub async fn lookup_block(
configuration: &configuration::Configuration,
round_number: u64,
header_only: Option<bool>,
) -> Result<algonaut_model::indexer::Block, Error<LookupBlockError>> {
let local_var_configuration = configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/v2/blocks/{round_number}",
local_var_configuration.base_path,
round_number = round_number
);
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_str) = header_only {
local_var_req_builder =
local_var_req_builder.query(&[("header-only", &local_var_str.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 = local_var_resp.text().await?;
if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
serde_json::from_str(&local_var_content).map_err(Error::from)
} else {
let local_var_entity: Option<LookupBlockError> =
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))
}
}
pub async fn lookup_transaction(
configuration: &configuration::Configuration,
txid: &str,
) -> Result<algonaut_model::indexer::TransactionResponse, Error<LookupTransactionError>> {
let local_var_configuration = configuration;
let local_var_client = &local_var_configuration.client;
let local_var_uri_str = format!(
"{}/v2/transactions/{txid}",
local_var_configuration.base_path,
txid = crate::apis::urlencode(txid)
);
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 = local_var_resp.text().await?;
if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
serde_json::from_str(&local_var_content).map_err(Error::from)
} else {
let local_var_entity: Option<LookupTransactionError> =
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))
}
}