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

feat: locations are now ordinal_number centric (instead of inscription_id)

Browse Source
This commit is contained in:
Ludovic Galabru
2024-01-11 14:47:25 -05:00
parent 3ce1932a54
commit d6679588fa
2 changed files with 65 additions and 72 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
components/ordhook-core/src/core/protocol/inscription_tracking.rs
View File

@@ -103,8 +103,13 @@ pub fn augment_transaction_with_ordinals_transfers_data(
.map(|o| o.previous_output.value)
.collect::<_>();
let outputs = tx.metadata.outputs.iter().map(|o| o.value).collect::<_>();
let post_transfer_data =
compute_next_satpoint_data(input_index, watched_satpoint.offset, &inputs, &outputs);
let post_transfer_data = compute_next_satpoint_data(
input_index,
watched_satpoint.offset,
&inputs,
&outputs,
0,
);
let (
outpoint_post_transfer,
@@ -151,8 +156,8 @@ pub fn augment_transaction_with_ordinals_transfers_data(
ctx.try_log(|logger| {
info!(
logger,
"Inscription {} moved from {} to {} (block: {})",
watched_satpoint.inscription_id,
"Inscribed satoshi {} moved from {} to {} (block: {})",
watched_satpoint.ordinal_number,
satpoint_pre_transfer,
outpoint,
block_identifier.index,
@@ -173,8 +178,8 @@ pub fn augment_transaction_with_ordinals_transfers_data(
ctx.try_log(|logger| {
info!(
logger,
"Inscription {} spent in fees ({}+{}+{})",
watched_satpoint.inscription_id,
"Inscribed satoshi {} spent in fees ({}+{}+{})",
watched_satpoint.ordinal_number,
coinbase_subsidy,
cumulated_fees,
offset
@@ -193,7 +198,7 @@ pub fn augment_transaction_with_ordinals_transfers_data(
format!("{}:{}", outpoint_post_transfer, offset_post_transfer);
let transfer_data = OrdinalInscriptionTransferData {
inscription_id: watched_satpoint.inscription_id.clone(),
ordinal_number: watched_satpoint.ordinal_number,
destination,
tx_index,
satpoint_pre_transfer,

118
components/ordhook-core/src/db/mod.rs
View File

@@ -104,7 +104,7 @@ pub fn initialize_ordhook_db(base_dir: &PathBuf, ctx: &Context) -> Connection {
}
if let Err(e) = conn.execute(
"CREATE TABLE IF NOT EXISTS locations (
inscription_id TEXT NOT NULL,
ordinal_number TEXT NOT NULL,
block_height INTEGER NOT NULL,
tx_index INTEGER NOT NULL,
outpoint_to_watch TEXT NOT NULL,
@@ -133,7 +133,7 @@ pub fn initialize_ordhook_db(base_dir: &PathBuf, ctx: &Context) -> Connection {
ctx.try_log(|logger| warn!(logger, "unable to query hord.sqlite: {}", e.to_string()));
}
if let Err(e) = conn.execute(
"CREATE INDEX IF NOT EXISTS locations_indexed_on_inscription_id ON locations(inscription_id);",
"CREATE INDEX IF NOT EXISTS locations_indexed_on_ordinal_number ON locations(ordinal_number);",
[],
) {
ctx.try_log(|logger| warn!(logger, "unable to query hord.sqlite: {}", e.to_string()));
@@ -264,6 +264,10 @@ fn rocks_db_default_options(ulimit: usize, memory_available: usize) -> rocksdb::
// opts.set_target_file_size_base(64 * 1024 * 1024);
opts.set_max_open_files(ulimit as i32);
opts.create_if_missing(true);
opts.set_allow_mmap_reads(true);
// set_arena_block_size
// opts.optimize_for_point_lookup(1 * 1024 * 1024 * 1024);
// opts.set_level_zero_stop_writes_trigger(64);
// opts.set_level_zero_slowdown_writes_trigger(20);
@@ -523,8 +527,8 @@ pub fn insert_inscription_in_locations(
parse_satpoint_to_watch(&inscription_data.satpoint_post_inscription);
let outpoint_to_watch = format_outpoint_to_watch(&tx, output_index);
while let Err(e) = inscriptions_db_conn_rw.execute(
"INSERT INTO locations (inscription_id, outpoint_to_watch, offset, block_height, tx_index) VALUES (?1, ?2, ?3, ?4, ?5)",
rusqlite::params![&inscription_data.inscription_id, &outpoint_to_watch, offset, &block_identifier.index, &inscription_data.tx_index],
"INSERT INTO locations (ordinal_number, outpoint_to_watch, offset, block_height, tx_index) VALUES (?1, ?2, ?3, ?4, ?5)",
rusqlite::params![&inscription_data.ordinal_number, &outpoint_to_watch, offset, &block_identifier.index, &inscription_data.tx_index],
) {
ctx.try_log(|logger| warn!(logger, "unable to query hord.sqlite: {}", e.to_string()));
std::thread::sleep(std::time::Duration::from_secs(1));
@@ -630,8 +634,8 @@ pub fn insert_transfer_in_locations_tx(
let (tx, output_index, offset) = parse_satpoint_to_watch(&transfer_data.satpoint_post_transfer);
let outpoint_to_watch = format_outpoint_to_watch(&tx, output_index);
while let Err(e) = inscriptions_db_conn_rw.execute(
"INSERT INTO locations (inscription_id, outpoint_to_watch, offset, block_height, tx_index) VALUES (?1, ?2, ?3, ?4, ?5)",
rusqlite::params![&transfer_data.inscription_id, &outpoint_to_watch, offset, &block_identifier.index, &transfer_data.tx_index],
"INSERT INTO locations (ordinal_number, outpoint_to_watch, offset, block_height, tx_index) VALUES (?1, ?2, ?3, ?4, ?5)",
rusqlite::params![&transfer_data.ordinal_number, &outpoint_to_watch, offset, &block_identifier.index, &transfer_data.tx_index],
) {
ctx.try_log(|logger| warn!(logger, "unable to query hord.sqlite: {}", e.to_string()));
std::thread::sleep(std::time::Duration::from_secs(1));
@@ -647,8 +651,8 @@ pub fn insert_transfer_in_locations(
let (tx, output_index, offset) = parse_satpoint_to_watch(&transfer_data.satpoint_post_transfer);
let outpoint_to_watch = format_outpoint_to_watch(&tx, output_index);
while let Err(e) = inscriptions_db_conn_rw.execute(
"INSERT INTO locations (inscription_id, outpoint_to_watch, offset, block_height, tx_index) VALUES (?1, ?2, ?3, ?4, ?5)",
rusqlite::params![&transfer_data.inscription_id, &outpoint_to_watch, offset, &block_identifier.index, &transfer_data.tx_index],
"INSERT INTO locations (ordinal_number, outpoint_to_watch, offset, block_height, tx_index) VALUES (?1, ?2, ?3, ?4, ?5)",
rusqlite::params![&transfer_data.ordinal_number, &outpoint_to_watch, offset, &block_identifier.index, &transfer_data.tx_index],
) {
ctx.try_log(|logger| warn!(logger, "unable to query hord.sqlite: {}", e.to_string()));
std::thread::sleep(std::time::Duration::from_secs(1));
@@ -785,12 +789,12 @@ pub fn find_latest_inscription_block_height(
}
pub fn find_initial_inscription_transfer_data(
inscription_id: &str,
ordinal_number: &u64,
db_conn: &Connection,
ctx: &Context,
) -> Result<Option<TransferData>, String> {
let args: &[&dyn ToSql] = &[&inscription_id.to_sql().unwrap()];
let query = "SELECT outpoint_to_watch, offset, tx_index FROM locations WHERE inscription_id = ? ORDER BY block_height ASC, tx_index ASC LIMIT 1";
let args: &[&dyn ToSql] = &[&ordinal_number.to_sql().unwrap()];
let query = "SELECT outpoint_to_watch, offset, tx_index FROM locations WHERE ordinal_number = ? ORDER BY block_height ASC, tx_index ASC LIMIT 1";
let entry = perform_query_one(query, args, db_conn, ctx, |row| {
let outpoint_to_watch: String = row.get(0).unwrap();
let (transaction_identifier_location, output_index) =
@@ -808,12 +812,12 @@ pub fn find_initial_inscription_transfer_data(
}
pub fn find_latest_inscription_transfer_data(
inscription_id: &str,
ordinal_number: &u64,
db_conn: &Connection,
ctx: &Context,
) -> Result<Option<TransferData>, String> {
let args: &[&dyn ToSql] = &[&inscription_id.to_sql().unwrap()];
let query = "SELECT outpoint_to_watch, offset, tx_index FROM locations WHERE inscription_id = ? ORDER BY block_height DESC, tx_index DESC LIMIT 1";
let args: &[&dyn ToSql] = &[&ordinal_number.to_sql().unwrap()];
let query = "SELECT outpoint_to_watch, offset, tx_index FROM locations WHERE ordinal_number = ? ORDER BY block_height DESC, tx_index DESC LIMIT 1";
let entry = perform_query_one(query, args, db_conn, ctx, |row| {
let outpoint_to_watch: String = row.get(0).unwrap();
let (transaction_identifier_location, output_index) =
@@ -852,11 +856,11 @@ pub fn find_all_transfers_in_block(
block_height: &u64,
db_conn: &Connection,
ctx: &Context,
) -> BTreeMap<String, Vec<TransferData>> {
) -> BTreeMap<u64, Vec<TransferData>> {
let args: &[&dyn ToSql] = &[&block_height.to_sql().unwrap()];
let mut stmt = loop {
match db_conn.prepare("SELECT inscription_id, offset, outpoint_to_watch, tx_index FROM locations WHERE block_height = ? ORDER BY tx_index ASC")
match db_conn.prepare("SELECT ordinal_number, offset, outpoint_to_watch, tx_index FROM locations WHERE block_height = ? ORDER BY tx_index ASC")
{
Ok(stmt) => break stmt,
Err(e) => {
@@ -868,7 +872,7 @@ pub fn find_all_transfers_in_block(
}
};
let mut results: BTreeMap<String, Vec<TransferData>> = BTreeMap::new();
let mut results: BTreeMap<u64, Vec<TransferData>> = BTreeMap::new();
let mut rows = loop {
match stmt.query(args) {
Ok(rows) => break rows,
@@ -883,7 +887,7 @@ pub fn find_all_transfers_in_block(
loop {
match rows.next() {
Ok(Some(row)) => {
let inscription_id: String = row.get(0).unwrap();
let ordinal_number: u64 = row.get(0).unwrap();
let inscription_offset_intra_output: u64 = row.get(1).unwrap();
let outpoint_to_watch: String = row.get(2).unwrap();
let tx_index: u64 = row.get(3).unwrap();
@@ -896,7 +900,7 @@ pub fn find_all_transfers_in_block(
tx_index,
};
results
.entry(inscription_id)
.entry(ordinal_number)
.and_modify(|v| v.push(transfer.clone()))
.or_insert(vec![transfer]);
}
@@ -1054,10 +1058,6 @@ pub fn find_inscription_with_id(
db_conn: &Connection,
ctx: &Context,
) -> Result<Option<(TraversalResult, u64)>, String> {
let Some(transfer_data) = find_initial_inscription_transfer_data(inscription_id, db_conn, ctx)?
else {
return Err(format!("unable to retrieve location for {inscription_id}"));
};
let args: &[&dyn ToSql] = &[&inscription_id.to_sql().unwrap()];
let query = "SELECT classic_inscription_number, jubilee_inscription_number, ordinal_number, block_height, input_index FROM inscriptions WHERE inscription_id = ?";
let entry = perform_query_one(query, args, db_conn, ctx, move |row| {
@@ -1077,27 +1077,36 @@ pub fn find_inscription_with_id(
block_height,
)
});
Ok(entry.map(
|(
let Some((
inscription_number,
ordinal_number,
inscription_input_index,
transaction_identifier_inscription,
block_height,
)) = entry
else {
return Err(format!(
"unable to retrieve inscription for {inscription_id}"
));
};
let Some(transfer_data) =
find_initial_inscription_transfer_data(&ordinal_number, db_conn, ctx)?
else {
return Err(format!("unable to retrieve location for {inscription_id}"));
};
Ok(Some((
TraversalResult {
inscription_number,
ordinal_number,
inscription_input_index,
transaction_identifier_inscription,
block_height,
)| {
(
TraversalResult {
inscription_number,
ordinal_number,
inscription_input_index,
transaction_identifier_inscription,
transfers: 0,
transfer_data,
},
block_height,
)
transfers: 0,
transfer_data,
},
))
block_height,
)))
}
pub fn find_all_inscriptions_in_block(
@@ -1147,7 +1156,7 @@ pub fn find_all_inscriptions_in_block(
let (transaction_identifier_inscription, _) =
{ parse_inscription_id(&inscription_id) };
let Some(transfer_data) = transfers_data
.get(&inscription_id)
.get(&ordinal_number)
.and_then(|entries| entries.first())
else {
ctx.try_log(|logger| {
@@ -1183,43 +1192,22 @@ pub fn find_all_inscriptions_in_block(
#[derive(Clone, Debug)]
pub struct WatchedSatpoint {
pub inscription_id: String,
pub ordinal_number: u64,
pub offset: u64,
}
pub fn find_watched_satpoint_for_inscription(
inscription_id: &str,
db_conn: &Connection,
ctx: &Context,
) -> Option<(u64, WatchedSatpoint)> {
let args: &[&dyn ToSql] = &[&inscription_id.to_sql().unwrap()];
let query = "SELECT inscription_id, offset, block_height FROM locations WHERE inscription_id = ? ORDER BY offset ASC";
perform_query_one(query, args, db_conn, ctx, |row| {
let inscription_id: String = row.get(0).unwrap();
let offset: u64 = row.get(1).unwrap();
let block_height: u64 = row.get(2).unwrap();
(
block_height,
WatchedSatpoint {
inscription_id,
offset,
},
)
})
}
pub fn find_inscriptions_at_wached_outpoint(
outpoint: &str,
db_conn: &Connection,
ctx: &Context,
) -> Vec<WatchedSatpoint> {
let args: &[&dyn ToSql] = &[&outpoint.to_sql().unwrap()];
let query = "SELECT inscription_id, offset FROM locations WHERE outpoint_to_watch = ? ORDER BY offset ASC";
let query = "SELECT ordinal_number, offset FROM locations WHERE outpoint_to_watch = ? ORDER BY offset ASC";
perform_query_set(query, args, db_conn, ctx, |row| {
let inscription_id: String = row.get(0).unwrap();
let ordinal_number: u64 = row.get(0).unwrap();
let offset: u64 = row.get(1).unwrap();
WatchedSatpoint {
inscription_id,
ordinal_number,
offset,
}
})