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

fix: inscription_number

Browse Source
This commit is contained in:
Ludo Galabru
2023-04-04 13:39:32 -04:00
parent 11509e4435
commit a7d8153a8c
3 changed files with 15 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -551,9 +551,19 @@ async fn handle_command(opts: Opts, ctx: Context) -> Result<(), String> {
}
};
let _ = initialize_hord_db(&config.expected_cache_path(), &ctx);
let hord_db_conn = open_readonly_hord_db_conn(&config.expected_cache_path(), &ctx)?;
let start_block = find_latest_compacted_block_known(&hord_db_conn) as u64;
if start_block == 0 {
let _ = initialize_hord_db(&config.expected_cache_path(), &ctx);
} else {
info!(
ctx.expect_logger(),
"Resuming hord indexing from block #{}", start_block
);
}
perform_hord_db_update(0, end_block, cmd.network_threads, &config, &ctx).await?;
perform_hord_db_update(start_block, end_block, cmd.network_threads, &config, &ctx)
.await?;
}
DbCommand::Sync(cmd) => {
let config = Config::default(false, false, false, &cmd.config_path)?;

3
components/chainhook-event-observer/src/hord/db/mod.rs
View File

@@ -412,7 +412,8 @@ pub fn find_inscriptions_at_wached_outpoint(
.prepare("SELECT inscription_id, inscription_number, ordinal_number, offset FROM inscriptions WHERE outpoint_to_watch = ? ORDER BY offset ASC")
.map_err(|e| format!("unable to query inscriptions table: {}", e.to_string()))?;
let mut results = vec![];
let mut rows = stmt.query(args)
let mut rows = stmt
.query(args)
.map_err(|e| format!("unable to query inscriptions table: {}", e.to_string()))?;
while let Ok(Some(row)) = rows.next() {
let inscription_id: String = row.get(0).unwrap();

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

@@ -211,7 +211,7 @@ pub fn update_storage_and_augment_bitcoin_block_with_inscription_reveal_data(
} else {
inscription.inscription_number =
match find_latest_inscription_number(&hord_db_conn, &ctx) {
Ok(inscription_number) => inscription_number,
Ok(inscription_number) => inscription_number + 1,
Err(e) => {
ctx.try_log(|logger| {
slog::error!(