From 9bdcd5eb3bf9fa1e7e530d1cdc0b3770ff71f838 Mon Sep 17 00:00:00 2001 From: Agnish Ghosh Date: Mon, 24 Jun 2024 21:09:43 +0530 Subject: [PATCH] fix: sync tests --- tests/test_block_processor.nim | 5 +++-- tests/test_sync_manager.nim | 2 +- 2 files changed, 4 insertions(+), 3 deletions(-) diff --git a/tests/test_block_processor.nim b/tests/test_block_processor.nim index 9f699ffe1..c4123796d 100644 --- a/tests/test_block_processor.nim +++ b/tests/test_block_processor.nim @@ -16,6 +16,7 @@ import ../beacon_chain/conf, ../beacon_chain/spec/[beaconstate, forks, helpers, state_transition], ../beacon_chain/spec/datatypes/deneb, + ../beacon_chain/spec/datatypes/eip7594, ../beacon_chain/gossip_processing/block_processor, ../beacon_chain/consensus_object_pools/[ attestation_pool, blockchain_dag, blob_quarantine, block_quarantine, @@ -64,7 +65,7 @@ suite "Block processor" & preset(): let missing = await processor[].addBlock( MsgSource.gossip, ForkedSignedBeaconBlock.init(b2), - Opt.none(BlobSidecars)) + Opt.none(BlobSidecars), Opt.none(DataColumnSidecars)) check: missing.error == VerifierError.MissingParent @@ -76,7 +77,7 @@ suite "Block processor" & preset(): let status = await processor[].addBlock( MsgSource.gossip, ForkedSignedBeaconBlock.init(b1), - Opt.none(BlobSidecars)) + Opt.none(BlobSidecars), Opt.none(DataColumnSidecars)) b1Get = dag.getBlockRef(b1.root) check: diff --git a/tests/test_sync_manager.nim b/tests/test_sync_manager.nim index 65fa75cd0..5433ea6eb 100644 --- a/tests/test_sync_manager.nim +++ b/tests/test_sync_manager.nim @@ -50,7 +50,7 @@ func collector(queue: AsyncQueue[BlockEntry]): BlockVerifier = # testing goes, this is risky because it might introduce differences between # the BlockProcessor and this test proc verify(signedBlock: ForkedSignedBeaconBlock, blobs: Opt[BlobSidecars], - maybeFinalized: bool): + data_columns: Opt[DataColumnSidecars], maybeFinalized: bool): Future[Result[void, VerifierError]] {.async: (raises: [CancelledError], raw: true).} = let fut = Future[Result[void, VerifierError]].Raising([CancelledError]).init() try: queue.addLastNoWait(BlockEntry(blck: signedBlock, resfut: fut))