/// transactions. `parallel_requests` specifies the max number of HTTP requests to make in
/// parallel.
#[allow(clippy::result_large_err)]
- async fn update_tx_graph<K: Ord + Clone + Send>(
+ async fn scan_txs_with_keychains<K: Ord + Clone + Send>(
&self,
keychain_spks: BTreeMap<
K,
parallel_requests: usize,
) -> Result<(TxGraph<ConfirmationTimeAnchor>, BTreeMap<K, u32>), Error>;
- /// Convenience method to call [`update_tx_graph`] without requiring a keychain.
+ /// Convenience method to call [`scan_txs_with_keychains`] without requiring a keychain.
///
- /// [`update_tx_graph`]: EsploraAsyncExt::update_tx_graph
+ /// [`scan_txs_with_keychains`]: EsploraAsyncExt::scan_txs_with_keychains
#[allow(clippy::result_large_err)]
- async fn update_tx_graph_without_keychain(
+ async fn scan_txs(
&self,
misc_spks: impl IntoIterator<IntoIter = impl Iterator<Item = ScriptBuf> + Send> + Send,
txids: impl IntoIterator<IntoIter = impl Iterator<Item = Txid> + Send> + Send,
outpoints: impl IntoIterator<IntoIter = impl Iterator<Item = OutPoint> + Send> + Send,
parallel_requests: usize,
) -> Result<TxGraph<ConfirmationTimeAnchor>, Error> {
- self.update_tx_graph(
+ self.scan_txs_with_keychains(
[(
(),
misc_spks
})
}
- async fn update_tx_graph<K: Ord + Clone + Send>(
+ async fn scan_txs_with_keychains<K: Ord + Clone + Send>(
&self,
keychain_spks: BTreeMap<
K,
/// transactions. `parallel_requests` specifies the max number of HTTP requests to make in
/// parallel.
#[allow(clippy::result_large_err)]
- fn update_tx_graph<K: Ord + Clone>(
+ fn scan_txs_with_keychains<K: Ord + Clone>(
&self,
keychain_spks: BTreeMap<K, impl IntoIterator<Item = (u32, ScriptBuf)>>,
txids: impl IntoIterator<Item = Txid>,
parallel_requests: usize,
) -> Result<(TxGraph<ConfirmationTimeAnchor>, BTreeMap<K, u32>), Error>;
- /// Convenience method to call [`update_tx_graph`] without requiring a keychain.
+ /// Convenience method to call [`scan_txs_with_keychains`] without requiring a keychain.
///
- /// [`update_tx_graph`]: EsploraExt::update_tx_graph
+ /// [`scan_txs_with_keychains`]: EsploraExt::scan_txs_with_keychains
#[allow(clippy::result_large_err)]
- fn update_tx_graph_without_keychain(
+ fn scan_txs(
&self,
misc_spks: impl IntoIterator<Item = ScriptBuf>,
txids: impl IntoIterator<Item = Txid>,
outpoints: impl IntoIterator<Item = OutPoint>,
parallel_requests: usize,
) -> Result<TxGraph<ConfirmationTimeAnchor>, Error> {
- self.update_tx_graph(
+ self.scan_txs_with_keychains(
[(
(),
misc_spks
})
}
- fn update_tx_graph<K: Ord + Clone>(
+ fn scan_txs_with_keychains<K: Ord + Clone>(
&self,
keychain_spks: BTreeMap<K, impl IntoIterator<Item = (u32, ScriptBuf)>>,
txids: impl IntoIterator<Item = Txid>,
// represents the last active spk derivation indices of keychains
// (`keychain_indices_update`).
let (graph_update, last_active_indices) = client
- .update_tx_graph(
+ .scan_txs_with_keychains(
keychain_spks,
core::iter::empty(),
core::iter::empty(),
}
}
- let graph_update = client.update_tx_graph_without_keychain(
- spks,
- txids,
- outpoints,
- scan_options.parallel_requests,
- )?;
+ let graph_update =
+ client.scan_txs(spks, txids, outpoints, scan_options.parallel_requests)?;
graph.lock().unwrap().apply_update(graph_update)
}
})
.collect();
let (update_graph, last_active_indices) = client
- .update_tx_graph(keychain_spks, None, None, STOP_GAP, PARALLEL_REQUESTS)
+ .scan_txs_with_keychains(keychain_spks, None, None, STOP_GAP, PARALLEL_REQUESTS)
.await?;
let missing_heights = wallet.tx_graph().missing_heights(wallet.local_chain());
let chain_update = client.update_local_chain(prev_tip, missing_heights).await?;
.collect();
let (update_graph, last_active_indices) =
- client.update_tx_graph(keychain_spks, None, None, STOP_GAP, PARALLEL_REQUESTS)?;
+ client.scan_txs_with_keychains(keychain_spks, None, None, STOP_GAP, PARALLEL_REQUESTS)?;
let missing_heights = wallet.tx_graph().missing_heights(wallet.local_chain());
let chain_update = client.update_local_chain(prev_tip, missing_heights)?;
let update = WalletUpdate {