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

fix: build

Browse Source
This commit is contained in:
Ludo Galabru
2023-04-19 10:16:08 -04:00
parent 1ccbc30597
commit 607ac953b1
3 changed files with 18 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -590,8 +590,8 @@ async fn handle_command(opts: Opts, ctx: Context) -> Result<(), String> {
index: cmd.block_height,
hash: "".into(),
};
let traversal = retrieve_satoshi_point_using_local_storage(
// let global_block_cache = HashMap::new();
let (traversal, _) = retrieve_satoshi_point_using_local_storage(
&hord_db_conn,
&block_identifier,
&transaction_identifier,

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

@@ -4,7 +4,8 @@ use std::{
};
use chainhook_types::{
BitcoinBlockData, BlockIdentifier, OrdinalInscriptionRevealData, TransactionIdentifier,
BitcoinBlockData, BlockIdentifier, OrdinalInscriptionRevealData, StacksBlockData,
TransactionIdentifier,
};
use hiro_system_kit::slog;

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

@@ -9,6 +9,8 @@ use chainhook_types::{
OrdinalOperation, TransactionIdentifier,
};
use hiro_system_kit::slog;
use rand::seq::SliceRandom;
use rand::thread_rng;
use rocksdb::DB;
use rusqlite::Connection;
use std::collections::{BTreeMap, HashMap, VecDeque};
@@ -148,19 +150,20 @@ pub fn update_hord_db_and_augment_bitcoin_block(
let moved_traversal_tx = traversal_tx.clone();
let moved_ctx = ctx.clone();
let block_identifier = new_block.block_identifier.clone();
let blocks_db = open_readonly_hord_db_conn_rocks_db(hord_db_path, &ctx)?;
let moved_hord_db_path = hord_db_path.clone();
traversal_data_pool.execute(move || {
let traversal = retrieve_satoshi_point_using_local_storage(
&blocks_db,
&block_identifier,
&transaction_id,
0,
&moved_ctx,
);
let _ = moved_traversal_tx.send((transaction_id, traversal));
if let Ok(blocks_db) = open_readonly_hord_db_conn_rocks_db(&moved_hord_db_path, &moved_ctx) {
let traversal = retrieve_satoshi_point_using_local_storage(
&blocks_db,
&block_identifier,
&transaction_id,
0,
&moved_ctx,
);
let _ = moved_traversal_tx.send((transaction_id, traversal));
}
});
}
let _ = traversal_data_pool.join();
let mut traversals_received = 0;
while let Ok((transaction_identifier, traversal_result)) = traversal_rx.recv() {
@@ -171,6 +174,7 @@ pub fn update_hord_db_and_augment_bitcoin_block(
break;
}
}
let _ = traversal_data_pool.join();
}
let mut storage = Storage::Sqlite(inscriptions_db_conn_rw);