script_req.satisfy(txids_per_script)?
}
- Request::Conftime(conftimereq) => {
+ Request::Conftime(conftime_req) => {
// collect up to chunk_size heights to fetch from electrum
let needs_block_height = {
- let mut needs_block_height_iter = conftimereq
+ let mut needs_block_height_iter = conftime_req
.request()
.filter_map(|txid| txid_to_height.get(txid).cloned())
.filter(|height| block_times.get(height).is_none());
block_times.insert(height, header.time);
}
- let conftimes = conftimereq
+ let conftimes = conftime_req
.request()
.take(chunk_size)
.map(|txid| {
})
.collect::<Result<_, Error>>()?;
- conftimereq.satisfy(conftimes)?
+ conftime_req.satisfy(conftimes)?
}
- Request::Tx(txreq) => {
- let needs_full = txreq.request().take(chunk_size);
+ Request::Tx(tx_req) => {
+ let needs_full = tx_req.request().take(chunk_size);
tx_cache.save_txs(needs_full.clone())?;
let full_transactions = needs_full
.map(|txid| tx_cache.get(*txid).ok_or_else(electrum_goof))
})
.collect::<Result<Vec<_>, Error>>()?;
- txreq.satisfy(full_details)?
+ tx_req.satisfy(full_details)?
}
Request::Finish(batch_update) => break batch_update,
}
script_req.satisfy(satisfaction)?
}
- Request::Conftime(conftimereq) => {
- let conftimes = conftimereq
+ Request::Conftime(conftime_req) => {
+ let conftimes = conftime_req
.request()
.map(|txid| {
tx_index
.confirmation_time()
})
.collect();
- conftimereq.satisfy(conftimes)?
+ conftime_req.satisfy(conftimes)?
}
- Request::Tx(txreq) => {
- let full_txs = txreq
+ Request::Tx(tx_req) => {
+ let full_txs = tx_req
.request()
.map(|txid| {
let tx = tx_index.get(txid).expect("must be in index");
(tx.previous_outputs(), tx.to_tx())
})
.collect();
- txreq.satisfy(full_txs)?
+ tx_req.satisfy(full_txs)?
}
Request::Finish(batch_update) => break batch_update,
}
script_req.satisfy(satisfaction)?
}
- Request::Conftime(conftimereq) => {
- let conftimes = conftimereq
+ Request::Conftime(conftime_req) => {
+ let conftimes = conftime_req
.request()
.map(|txid| {
tx_index
.confirmation_time()
})
.collect();
- conftimereq.satisfy(conftimes)?
+ conftime_req.satisfy(conftimes)?
}
- Request::Tx(txreq) => {
- let full_txs = txreq
+ Request::Tx(tx_req) => {
+ let full_txs = tx_req
.request()
.map(|txid| {
let tx = tx_index.get(txid).expect("must be in index");
(tx.previous_outputs(), tx.to_tx())
})
.collect();
- txreq.satisfy(full_txs)?
+ tx_req.satisfy(full_txs)?
}
Request::Finish(batch_update) => break batch_update,
}
use log::*;
use std::collections::{HashMap, HashSet, VecDeque};
-/// A reqeust for on-chain information
+/// A request for on-chain information
pub enum Request<'a, D: BatchDatabase> {
/// A request for transactions related to script pubkeys.
Script(ScriptReq<'a, D>),