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

fix: broken test

Browse Source
This commit is contained in:
Ludo Galabru
2023-05-17 23:05:40 -04:00
parent efc498b3b6
commit 239b26a614
2 changed files with 51 additions and 45 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
components/chainhook-cli/src/cli/mod.rs
View File

@@ -827,7 +827,7 @@ async fn handle_command(opts: Opts, ctx: Context) -> Result<(), String> {
cmd.end_block - cmd.start_block + 1
);
}
DbCommand::Patch(cmd) => {
DbCommand::Patch(_cmd) => {
unimplemented!()
}
DbCommand::Migrate(cmd) => {

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

@@ -14,7 +14,6 @@ use crate::hord::db::open_readwrite_hord_dbs;
use crate::hord::new_traversals_lazy_cache;
#[cfg(feature = "ordinals")]
use crate::hord::{
db::{open_readwrite_hord_db_conn, open_readwrite_hord_db_conn_rocks_db},
revert_hord_db_with_augmented_bitcoin_block, update_hord_db_and_augment_bitcoin_block,
};
use crate::indexer::bitcoin::{
@@ -653,51 +652,9 @@ pub async fn start_observer_commands_handler(
BlockchainEvent::BlockchainUpdatedWithHeaders(data) => {
let mut new_blocks = vec![];
#[cfg(feature = "ordinals")]
let (blocks_db, inscriptions_db_conn_rw) =
match open_readwrite_hord_dbs(&config.get_cache_path_buf(), &ctx) {
Ok(dbs) => dbs,
Err(e) => {
if let Some(ref tx) = observer_events_tx {
let _ = tx.send(ObserverEvent::Error(format!(
"Channel error: {:?}",
e
)));
} else {
ctx.try_log(|logger| {
slog::error!(
logger,
"Unable to open readwtite connection",
)
});
}
continue;
}
};
for header in data.new_headers.iter() {
match bitcoin_block_store.get_mut(&header.block_identifier) {
match bitcoin_block_store.get(&header.block_identifier) {
Some(block) => {
#[cfg(feature = "ordinals")]
{
if let Err(e) = update_hord_db_and_augment_bitcoin_block(
block,
&blocks_db,
&inscriptions_db_conn_rw,
true,
&config.get_cache_path_buf(),
&traversals_cache,
&ctx,
) {
ctx.try_log(|logger| {
slog::error!(
logger,
"Unable to insert bitcoin block {} in hord_db: {e}",
block.block_identifier.index
)
});
}
}
new_blocks.push(block.clone());
}
None => {
@@ -712,6 +669,55 @@ pub async fn start_observer_commands_handler(
}
}
#[cfg(feature = "ordinals")]
{
if config.ordinals_enabled {
let (blocks_db, inscriptions_db_conn_rw) =
match open_readwrite_hord_dbs(
&config.get_cache_path_buf(),
&ctx,
) {
Ok(dbs) => dbs,
Err(e) => {
if let Some(ref tx) = observer_events_tx {
let _ = tx.send(ObserverEvent::Error(format!(
"Channel error: {:?}",
e
)));
} else {
ctx.try_log(|logger| {
slog::error!(
logger,
"Unable to open readwtite connection",
)
});
}
continue;
}
};
for block in new_blocks.iter_mut() {
if let Err(e) = update_hord_db_and_augment_bitcoin_block(
block,
&blocks_db,
&inscriptions_db_conn_rw,
true,
&config.get_cache_path_buf(),
&traversals_cache,
&ctx,
) {
ctx.try_log(|logger| {
slog::error!(
logger,
"Unable to insert bitcoin block {} in hord_db: {e}",
block.block_identifier.index
)
});
}
}
}
};
for header in data.confirmed_headers.iter() {
match bitcoin_block_store.remove(&header.block_identifier) {
Some(block) => {