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

chore: add logging

Browse Source
This commit is contained in:
Ludo Galabru
2023-03-24 14:47:29 -04:00
parent 0dad9492a7
commit 88206efc07
1 changed files with 31 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

38
components/chainhook-event-observer/src/observer/mod.rs
View File

@@ -480,9 +480,7 @@ pub async fn start_observer_commands_handler(
let mut chainhooks_lookup: HashMap<String, ApiKey> = HashMap::new();
let networks = (&config.bitcoin_network, &config.stacks_network);
let mut bitcoin_block_store: HashMap<BlockIdentifier, BitcoinBlockData> = HashMap::new();
// {
// let _ = initialize_hord_db(&config.get_cache_path_buf(), &ctx);
// }
loop {
let command = match observer_commands_rx.recv() {
Ok(cmd) => cmd,
@@ -529,7 +527,16 @@ pub async fn start_observer_commands_handler(
for header in data.new_headers.iter() {
match bitcoin_block_store.get_mut(&header.block_identifier) {
Some(block) => {
update_hord_db_and_augment_bitcoin_block(block, &config, &ctx);
if let Err(e) = update_hord_db_and_augment_bitcoin_block(
block, &config, &ctx,
) {
ctx.try_log(|logger| {
slog::error!(
logger,
"Unable to augment bitcoin block with hord_db: {e}",
)
});
}
new_blocks.push(block.clone());
}
None => {
@@ -576,9 +583,17 @@ pub async fn start_observer_commands_handler(
for header in data.headers_to_rollback.iter() {
match bitcoin_block_store.get(&header.block_identifier) {
Some(block) => {
revert_hord_db_with_augmented_bitcoin_block(
if let Err(e) = revert_hord_db_with_augmented_bitcoin_block(
block, &config, &ctx,
);
) {
ctx.try_log(|logger| {
slog::error!(
logger,
"Unable to rollback bitcoin block {}: {e}",
header.block_identifier
)
});
}
blocks_to_rollback.push(block.clone());
}
None => {
@@ -596,7 +611,16 @@ pub async fn start_observer_commands_handler(
for header in data.headers_to_apply.iter() {
match bitcoin_block_store.get_mut(&header.block_identifier) {
Some(block) => {
update_hord_db_and_augment_bitcoin_block(block, &config, &ctx);
if let Err(e) = update_hord_db_and_augment_bitcoin_block(
block, &config, &ctx,
) {
ctx.try_log(|logger| {
slog::error!(
logger,
"Unable to augment bitcoin block with hord_db: {e}",
)
});
}
blocks_to_apply.push(block.clone());
}
None => {