Skip to content

Commit

Permalink
add test to 7702-all playbook & append long running tests to kurtosis…
Browse files Browse the repository at this point in the history
…/all.yaml
  • Loading branch information
pk910 committed Jan 19, 2025
1 parent 7affc5d commit 49f2a49
Show file tree
Hide file tree
Showing 3 changed files with 399 additions and 7 deletions.
12 changes: 6 additions & 6 deletions pkg/coordinator/tasks/check_consensus_block_proposals/task.go
Original file line number Diff line number Diff line change
Expand Up @@ -719,6 +719,7 @@ func (t *Task) checkBlockDepositRequests(block *consensus.Block, blockData *spec
expectedWithdrawalCreds = common.FromHex(expectedDepositRequest.WithdrawalCredentials)
}

requestLoop:
for _, depositRequest := range depositRequests {
if expectedDepositRequest.PublicKey == "" || depositRequest.Pubkey.String() == expectedDepositRequest.PublicKey {
depositAmount := big.NewInt(int64(depositRequest.Amount))
Expand All @@ -730,9 +731,8 @@ func (t *Task) checkBlockDepositRequests(block *consensus.Block, blockData *spec
t.logger.Warnf("check failed: deposit request found, but amount does not match (have: %v, want: %v)", depositAmount, expectedDepositRequest.Amount.String())
default:
found = true
break requestLoop
}

break
}
}

Expand Down Expand Up @@ -773,6 +773,7 @@ func (t *Task) checkBlockWithdrawalRequests(block *consensus.Block, blockData *s
expectedPubKey = common.FromHex(expectedWithdrawalRequest.ValidatorPubkey)
}

requestLoop:
for _, withdrawalRequest := range withdrawalRequests {
if expectedWithdrawalRequest.ValidatorPubkey == "" || bytes.Equal(withdrawalRequest.ValidatorPubkey[:], expectedPubKey) {
withdrawalAmount := big.NewInt(int64(withdrawalRequest.Amount))
Expand All @@ -784,9 +785,8 @@ func (t *Task) checkBlockWithdrawalRequests(block *consensus.Block, blockData *s
t.logger.Warnf("check failed: deposit request found, but amount does not match (have: %v, want: %v)", withdrawalAmount, expectedWithdrawalRequest.Amount.String())
default:
found = true
break requestLoop
}

break
}
}

Expand Down Expand Up @@ -831,6 +831,7 @@ func (t *Task) checkBlockConsolidationRequests(block *consensus.Block, blockData
expectedTgtPubKey = common.FromHex(expectedConsolidationRequest.TargetPubkey)
}

requestLoop:
for _, consolidationRequest := range consolidationRequests {
if expectedConsolidationRequest.SourcePubkey == "" || bytes.Equal(consolidationRequest.SourcePubkey[:], expectedSrcPubKey) {
switch {
Expand All @@ -841,9 +842,8 @@ func (t *Task) checkBlockConsolidationRequests(block *consensus.Block, blockData

default:
found = true
break requestLoop
}

break
}
}

Expand Down
Loading

0 comments on commit 49f2a49

Please sign in to comment.