From 6ded4c101183fc3f4c192c4bf868b0ba3bd04150 Mon Sep 17 00:00:00 2001 From: speeddragon Date: Thu, 23 Jul 2026 13:34:57 +0100 Subject: [PATCH] impr: Add topic debug_copycat_tx for print TXID that are being indexed --- src/preloaded/query/dev_copycat_arweave.erl | 18 ++++++++++++++++++ 1 file changed, 18 insertions(+) diff --git a/src/preloaded/query/dev_copycat_arweave.erl b/src/preloaded/query/dev_copycat_arweave.erl index 0b06b0666..a1179db5b 100644 --- a/src/preloaded/query/dev_copycat_arweave.erl +++ b/src/preloaded/query/dev_copycat_arweave.erl @@ -432,6 +432,12 @@ process_tx({{TX, _TXDataRoot}, EndOffset}, BlockStartOffset, IndexMode, Opts) -> TXID = hb_util:encode(TX#tx.id), TXEndOffset = BlockStartOffset + EndOffset, TXStartOffset = TXEndOffset - TX#tx.data_size, + ?event(debug_copycat_tx, + {indexed_tx, + {type, tx}, + {pending, false}, + {txid, {explicit, TXID}} + }), ?event(debug_copycat, {writing_index, {id, {explicit, TXID}}, {offset, TXStartOffset}, @@ -628,6 +634,12 @@ process_pending_tx(TXID, IndexMode, Opts) -> case hb_store_arweave:write_offset( Store, TXID, <<"tx@1.0">>, relative, TX#tx.data_size) of ok -> + ?event(debug_copycat_tx, + {indexed_tx, + {type, tx}, + {pending, true}, + {txid, {explicit, TXID}} + }), index_pending_children(TXID, TX, IndexMode, Store, Opts); WriteError -> ?event( @@ -725,6 +737,12 @@ index_full_bundle_items( catch _:_ -> error end end, + ?event(debug_copycat_tx, + {indexed_tx, + {type, ans104}, + {pending, not is_integer(ItemStartOffset)}, + {txid, {explicit, EncodedItemID}} + }), case hb_store_arweave:write_offset( Store, EncodedItemID,