status-im
/
nimbus-eth2
mirror of https://github.com/status-im/nimbus-eth2.git
2
0
Fork 0
Code Issues Projects Releases Wiki Activity

fix: sync tests

This commit is contained in:
Agnish Ghosh 2024-06-24 21:09:43 +05:30
parent 791d2fb0d1
commit 9bdcd5eb3b
No known key found for this signature in database
GPG Key ID: 7E927C221EBA4F6E
2 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
tests/test_block_processor.nim
View File

@ -16,6 +16,7 @@ import
../beacon_chain/conf, ../beacon_chain/conf,
../beacon_chain/spec/[beaconstate, forks, helpers, state_transition], ../beacon_chain/spec/[beaconstate, forks, helpers, state_transition],
../beacon_chain/spec/datatypes/deneb, ../beacon_chain/spec/datatypes/deneb,
../beacon_chain/spec/datatypes/eip7594,
../beacon_chain/gossip_processing/block_processor, ../beacon_chain/gossip_processing/block_processor,
../beacon_chain/consensus_object_pools/[ ../beacon_chain/consensus_object_pools/[
attestation_pool, blockchain_dag, blob_quarantine, block_quarantine, attestation_pool, blockchain_dag, blob_quarantine, block_quarantine,
@ -64,7 +65,7 @@ suite "Block processor" & preset():
let let
missing = await processor[].addBlock( missing = await processor[].addBlock(
MsgSource.gossip, ForkedSignedBeaconBlock.init(b2), MsgSource.gossip, ForkedSignedBeaconBlock.init(b2),
Opt.none(BlobSidecars)) Opt.none(BlobSidecars), Opt.none(DataColumnSidecars))
check: missing.error == VerifierError.MissingParent check: missing.error == VerifierError.MissingParent
@ -76,7 +77,7 @@ suite "Block processor" & preset():
let let
status = await processor[].addBlock( status = await processor[].addBlock(
MsgSource.gossip, ForkedSignedBeaconBlock.init(b1), MsgSource.gossip, ForkedSignedBeaconBlock.init(b1),
Opt.none(BlobSidecars)) Opt.none(BlobSidecars), Opt.none(DataColumnSidecars))
b1Get = dag.getBlockRef(b1.root) b1Get = dag.getBlockRef(b1.root)
check: check:

2
tests/test_sync_manager.nim
View File

@ -50,7 +50,7 @@ func collector(queue: AsyncQueue[BlockEntry]): BlockVerifier =
# testing goes, this is risky because it might introduce differences between # testing goes, this is risky because it might introduce differences between
# the BlockProcessor and this test # the BlockProcessor and this test
proc verify(signedBlock: ForkedSignedBeaconBlock, blobs: Opt[BlobSidecars], proc verify(signedBlock: ForkedSignedBeaconBlock, blobs: Opt[BlobSidecars],
maybeFinalized: bool): data_columns: Opt[DataColumnSidecars], maybeFinalized: bool):
Future[Result[void, VerifierError]] {.async: (raises: [CancelledError], raw: true).} = Future[Result[void, VerifierError]] {.async: (raises: [CancelledError], raw: true).} =
let fut = Future[Result[void, VerifierError]].Raising([CancelledError]).init() let fut = Future[Result[void, VerifierError]].Raising([CancelledError]).init()
try: queue.addLastNoWait(BlockEntry(blck: signedBlock, resfut: fut)) try: queue.addLastNoWait(BlockEntry(blck: signedBlock, resfut: fut))