use std::str::FromStr;
use crate::{
client::{
api::GetAddressesBuilderOptions, node_api::indexer::query_parameters::QueryParameter, secret::SecretManager,
Client, Result,
},
types::block::{
address::Address,
input::{UtxoInput, INPUT_COUNT_MAX},
output::{unlock_condition::AddressUnlockCondition, BasicOutputBuilder, NativeTokensBuilder, Output, OutputId},
payload::transaction::TransactionId,
},
};
impl Client {
pub async fn consolidate_funds(
&self,
secret_manager: &SecretManager,
address_builder_options: GetAddressesBuilderOptions,
) -> Result<String> {
let token_supply = self.get_token_supply().await?;
let mut last_transfer_index = address_builder_options.range.as_ref().unwrap_or(&(0..1)).start;
let offset = last_transfer_index;
let addresses = self
.get_addresses(secret_manager)
.set_options(address_builder_options)?
.finish()
.await?;
let consolidation_address = addresses[0].clone();
'consolidation: loop {
let mut block_ids = Vec::new();
for (index, address) in addresses.iter().enumerate().rev() {
let index = index as u32;
let index = index + offset;
let output_ids_response = self
.basic_output_ids(vec![
QueryParameter::Address(address.to_string()),
QueryParameter::HasExpiration(false),
QueryParameter::HasTimelock(false),
QueryParameter::HasStorageDepositReturn(false),
])
.await?;
let basic_outputs_responses = self.get_outputs(output_ids_response.items).await?;
if !basic_outputs_responses.is_empty() {
if last_transfer_index == index {
if basic_outputs_responses.len() < 2 {
break 'consolidation;
}
} else {
last_transfer_index = index;
}
}
let outputs_chunks = basic_outputs_responses.chunks(INPUT_COUNT_MAX.into());
let (bech32_hrp, consolidation_address) = Address::try_from_bech32_with_hrp(&consolidation_address)?;
self.bech32_hrp_matches(&bech32_hrp).await?;
for chunk in outputs_chunks {
let mut block_builder = self.block().with_secret_manager(secret_manager);
let mut total_amount = 0;
let mut total_native_tokens = NativeTokensBuilder::new();
for output_response in chunk {
block_builder = block_builder.with_input(UtxoInput::from(OutputId::new(
TransactionId::from_str(&output_response.metadata.transaction_id)?,
output_response.metadata.output_index,
)?))?;
let output = Output::try_from_dto(&output_response.output, token_supply)?;
if let Some(native_tokens) = output.native_tokens() {
total_native_tokens.add_native_tokens(native_tokens.clone())?;
}
total_amount += output.amount();
}
let consolidation_output = BasicOutputBuilder::new_with_amount(total_amount)
.add_unlock_condition(AddressUnlockCondition::new(consolidation_address))
.with_native_tokens(total_native_tokens.finish()?)
.finish_output(token_supply)?;
let block = block_builder
.with_input_range(index..index + 1)
.with_outputs(vec![consolidation_output])?
.with_initial_address_index(0)
.finish()
.await?;
block_ids.push(block.id());
}
}
if block_ids.is_empty() {
break 'consolidation;
}
for block_id in block_ids {
let _ = self.retry_until_included(&block_id, None, None).await?;
}
}
Ok(consolidation_address)
}
}