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: sats overflow handling

Browse Source
This commit is contained in:
Ludo Galabru
2023-05-18 21:36:20 -04:00
parent f7d0bf8a4c
commit a3f745cfa7
1 changed files with 31 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -376,6 +376,8 @@ pub fn update_storage_and_augment_bitcoin_block_with_inscription_reveal_data(
return;
}
};
let mut sats_overflow = vec![];
for new_tx in block.transactions.iter_mut().skip(1) {
let mut ordinals_events_indexes_to_discard = VecDeque::new();
// Have a new inscription been revealed, if so, are looking at a re-inscription
@@ -428,7 +430,9 @@ pub fn update_storage_and_augment_bitcoin_block_with_inscription_reveal_data(
} else {
// If the satoshi inscribed correspond to a sat overflow, we will store the inscription
// but exclude it from the block data
sats_overflow.push(inscription.clone());
ordinals_events_indexes_to_discard.push_front(ordinal_event_index);
continue;
}
latest_inscription_number += 1;
inscription.inscription_number = inscription_number;
@@ -472,6 +476,33 @@ pub fn update_storage_and_augment_bitcoin_block_with_inscription_reveal_data(
new_tx.metadata.ordinal_operations.remove(index);
}
}
for inscription in sats_overflow.iter_mut() {
match storage {
Storage::Sqlite(rw_hord_db_conn) => {
latest_inscription_number += 1;
inscription.inscription_number = latest_inscription_number;
ctx.try_log(|logger| {
slog::info!(
logger,
"Inscription {} (#{}) detected on Satoshi overflow {} (block {}, {} transfers)",
inscription.inscription_id,
inscription.inscription_number,
inscription.ordinal_number,
block.block_identifier.index,
inscription.transfers_pre_inscription,
);
});
store_new_inscription(
&inscription,
&block.block_identifier,
&rw_hord_db_conn,
&ctx,
);
}
_ => {}
}
}
}
/// For each input of each transaction in the block, we retrieve the UTXO spent (outpoint_pre_transfer)