Skip to content

Commit 8e367b0

Browse files
committed
Use extract_entries_from_results instead of single result parsing
1 parent aee37da commit 8e367b0

File tree

1 file changed

+11
-7
lines changed

1 file changed

+11
-7
lines changed

crates/cli-client/src/cli/option.rs

Lines changed: 11 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,8 @@
11
use std::collections::HashMap;
22

33
use crate::cli::interactive::{
4-
GRANTOR_TOKEN_TAG, OPTION_TOKEN_TAG, current_timestamp, extract_entries_from_result, format_relative_time,
5-
get_grantor_tokens_from_wallet, get_option_tokens_from_wallet, parse_expiry, prompt_amount,
4+
GRANTOR_TOKEN_TAG, OPTION_TOKEN_TAG, current_timestamp, extract_entries_from_result, extract_entries_from_results,
5+
format_relative_time, get_grantor_tokens_from_wallet, get_option_tokens_from_wallet, parse_expiry, prompt_amount,
66
select_enriched_token_interactive,
77
};
88
use crate::cli::{Cli, OptionCommand};
@@ -86,7 +86,7 @@ impl Cli {
8686
.limit(3);
8787

8888
let lbtc_results = <_ as UtxoStore>::query_utxos(wallet.store(), &[lbtc_fee_filter]).await?;
89-
let lbtc_entries = extract_entries_from_result(&lbtc_results[0]);
89+
let lbtc_entries = extract_entries_from_results(lbtc_results);
9090

9191
if lbtc_entries.len() < 3 {
9292
return Err(Error::Config(
@@ -105,7 +105,7 @@ impl Cli {
105105
.required_value(*total_collateral);
106106
coll_query_results = <_ as UtxoStore>::query_utxos(wallet.store(), &[collateral_filter]).await?;
107107

108-
let coll_entries = extract_entries_from_result(&coll_query_results[0]);
108+
let coll_entries = extract_entries_from_results(coll_query_results);
109109
let coll_entry = coll_entries.first().ok_or_else(|| {
110110
Error::Config(format!("No UTXOs found for collateral asset {collateral_asset}"))
111111
})?;
@@ -348,7 +348,7 @@ impl Cli {
348348
let collateral_filter = UtxoFilter::new().taproot_pubkey_gen(tpg).asset_id(collateral_asset_id);
349349

350350
if let Ok(results) = <_ as UtxoStore>::query_utxos(wallet.store(), &[collateral_filter]).await {
351-
let collateral_entries = extract_entries_from_result(&results[0]);
351+
let collateral_entries = extract_entries_from_results(results);
352352
if !collateral_entries.is_empty() {
353353
contracts_with_collateral.insert(entry.taproot_pubkey_gen_str.clone());
354354
}
@@ -596,10 +596,12 @@ impl Cli {
596596
)?;
597597

598598
let collateral_asset_id = entry.option_arguments.get_collateral_asset_id();
599-
let collateral_filter = UtxoFilter::new().taproot_pubkey_gen(tpg).asset_id(collateral_asset_id);
599+
let collateral_filter = UtxoFilter::new()
600+
.taproot_pubkey_gen(tpg)
601+
.asset_id(collateral_asset_id);
600602

601603
if let Ok(results) = <_ as UtxoStore>::query_utxos(wallet.store(), &[collateral_filter]).await {
602-
let collateral_entries = extract_entries_from_result(&results[0]);
604+
let collateral_entries = extract_entries_from_results(results);
603605
if !collateral_entries.is_empty() {
604606
contracts_with_collateral.insert(entry.taproot_pubkey_gen_str.clone());
605607
}
@@ -621,6 +623,8 @@ impl Cli {
621623
})
622624
.collect();
623625

626+
dbg!("here");
627+
624628
if entries_with_collateral.is_empty() {
625629
return Err(Error::Config(
626630
"No expirable options found. Collateral may have already been claimed, \

0 commit comments

Comments
 (0)