Skip to content

Commit 9fab5a3

Browse files
author
Ludo Galabru
committed
fix: return blocks to rollback in reverse order
1 parent 88206ef commit 9fab5a3

File tree

3 files changed

+8
-5
lines changed

3 files changed

+8
-5
lines changed

components/chainhook-event-observer/src/indexer/mod.rs

-1
Original file line numberDiff line numberDiff line change
@@ -313,7 +313,6 @@ impl ChainSegment {
313313
slog::debug!(logger, "Blocks to rollback: {:?}", block_ids_to_rollback)
314314
});
315315
ctx.try_log(|logger| slog::debug!(logger, "Blocks to apply: {:?}", block_ids_to_apply));
316-
block_ids_to_rollback.reverse();
317316
block_ids_to_apply.reverse();
318317
match common_root.take() {
319318
Some(_common_root) => Ok(ChainSegmentDivergence {

components/chainhook-event-observer/src/indexer/tests/helpers/bitcoin_shapes.rs

+2-1
Original file line numberDiff line numberDiff line change
@@ -88,10 +88,11 @@ pub fn expect_chain_updated_with_blocks(
8888
}
8989

9090
pub fn expect_chain_updated_with_block_reorg(
91-
blocks_to_rollback: Vec<BitcoinBlockData>,
91+
mut blocks_to_rollback: Vec<BitcoinBlockData>,
9292
blocks_to_apply: Vec<BitcoinBlockData>,
9393
_confirmed_blocks: Vec<BitcoinBlockData>,
9494
) -> BlockchainEventExpectation {
95+
blocks_to_rollback.reverse();
9596
Box::new(move |chain_event_to_check: Option<BlockchainEvent>| {
9697
assert!(
9798
match chain_event_to_check {

components/chainhook-event-observer/src/indexer/tests/helpers/stacks_shapes.rs

+6-3
Original file line numberDiff line numberDiff line change
@@ -146,10 +146,11 @@ pub fn expect_chain_updated_with_blocks(
146146

147147
pub fn expect_chain_updated_with_block_and_microblock_updates(
148148
expected_block: BlockEvent,
149-
microblocks_to_rollback: Vec<BlockEvent>,
149+
mut microblocks_to_rollback: Vec<BlockEvent>,
150150
microblocks_to_apply: Vec<BlockEvent>,
151151
_confirmed_blocks: Vec<BlockEvent>,
152152
) -> StacksChainEventExpectation {
153+
microblocks_to_rollback.reverse();
153154
Box::new(move |chain_event_to_check: Option<StacksChainEvent>| {
154155
assert!(
155156
match chain_event_to_check {
@@ -362,10 +363,11 @@ pub fn expect_chain_updated_with_block_reorg_and_microblock_updates(
362363
}
363364

364365
pub fn expect_chain_updated_with_block_reorg(
365-
blocks_to_rollback: Vec<BlockEvent>,
366+
mut blocks_to_rollback: Vec<BlockEvent>,
366367
blocks_to_apply: Vec<BlockEvent>,
367368
_confirmed_blocks: Vec<BlockEvent>,
368369
) -> StacksChainEventExpectation {
370+
blocks_to_rollback.reverse();
369371
Box::new(move |chain_event_to_check: Option<StacksChainEvent>| {
370372
assert!(
371373
match chain_event_to_check {
@@ -415,9 +417,10 @@ pub fn expect_chain_updated_with_block_reorg(
415417
}
416418

417419
pub fn expect_chain_updated_with_microblock_reorg(
418-
microblocks_to_rollback: Vec<BlockEvent>,
420+
mut microblocks_to_rollback: Vec<BlockEvent>,
419421
microblocks_to_apply: Vec<BlockEvent>,
420422
) -> StacksChainEventExpectation {
423+
microblocks_to_rollback.reverse();
421424
Box::new(move |chain_event_to_check: Option<StacksChainEvent>| {
422425
assert!(
423426
match chain_event_to_check {

0 commit comments

Comments
 (0)