kylefang/bitcoin-indexer
1
0
Fork 0
mirror of https://github.com/alexgo-io/bitcoin-indexer.git synced 2026-06-15 00:49:30 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: early return

Browse Source
This commit is contained in:
Ludo Galabru
2023-04-12 14:49:18 -04:00
parent 5441851db7
commit 8f97b5643b
2 changed files with 37 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
components/chainhook-cli/src/scan/bitcoin.rs
View File

@@ -169,11 +169,20 @@ pub async fn scan_bitcoin_chain_with_predicate(
let block_hash = retrieve_block_hash_with_retry(&cursor, &bitcoin_config, ctx).await?;
let block_breakdown =
download_and_parse_block_with_retry(&block_hash, &bitcoin_config, ctx).await?;
let mut block = indexer::bitcoin::standardize_bitcoin_block(
let mut block = match indexer::bitcoin::standardize_bitcoin_block(
block_breakdown,
&event_observer_config.bitcoin_network,
ctx,
)?;
) {
Ok(data) => data,
Err(e) => {
warn!(
ctx.expect_logger(),
"Unable to standardize block#{} {}: {}", cursor, block_hash, e
);
continue;
}
};
update_storage_and_augment_bitcoin_block_with_inscription_reveal_data(
&mut block,
@@ -215,11 +224,21 @@ pub async fn scan_bitcoin_chain_with_predicate(
let block_hash = retrieve_block_hash_with_retry(&cursor, &bitcoin_config, ctx).await?;
let block_breakdown =
download_and_parse_block_with_retry(&block_hash, &bitcoin_config, ctx).await?;
let block = indexer::bitcoin::standardize_bitcoin_block(
let block = match indexer::bitcoin::standardize_bitcoin_block(
block_breakdown,
&event_observer_config.bitcoin_network,
ctx,
)?;
) {
Ok(data) => data,
Err(e) => {
warn!(
ctx.expect_logger(),
"Unable to standardize block#{} {}: {}", cursor, block_hash, e
);
continue;
}
};
let chain_event =
BitcoinChainEvent::ChainUpdatedWithBlocks(BitcoinChainUpdatedWithBlocksData {

16
components/chainhook-cli/src/service/mod.rs
View File

@@ -465,11 +465,23 @@ impl Service {
.result::<indexer::bitcoin::BitcoinBlockFullBreakdown>()
.map_err(|e| format!("unable to parse response ({})", e))?;
let block = indexer::bitcoin::standardize_bitcoin_block(
let block = match indexer::bitcoin::standardize_bitcoin_block(
raw_block,
&event_observer_config.bitcoin_network,
&self.ctx,
)?;
) {
Ok(data) => data,
Err(e) => {
warn!(
self.ctx.expect_logger(),
"Unable to standardize block#{} {}: {}",
cursor,
block_hash,
e
);
continue;
}
};
let mut hits = vec![];
for tx in block.transactions.iter() {