Skip to content

Commit d30caa0

Browse files
Small fixes pre-release (#10044)
1 parent 75264a3 commit d30caa0

File tree

4 files changed

+12
-13
lines changed

4 files changed

+12
-13
lines changed

gradle/versions.gradle

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -64,7 +64,7 @@ dependencyManagement {
6464
entry 'oshi-core-java11'
6565
}
6666

67-
dependencySet(group: 'io.netty', version: '4.2.5.Final') {
67+
dependencySet(group: 'io.netty', version: '4.2.7.Final') {
6868
entry 'netty-handler'
6969
entry 'netty-codec-http'
7070
}

networking/eth2/src/main/java/tech/pegasys/teku/networking/eth2/peers/DataColumnSidecarSignatureValidator.java

Lines changed: 4 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,6 @@
1616
import java.util.Optional;
1717
import org.apache.tuweni.bytes.Bytes;
1818
import org.apache.tuweni.bytes.Bytes32;
19-
import tech.pegasys.teku.bls.BLSSignatureVerifier;
2019
import tech.pegasys.teku.infrastructure.async.SafeFuture;
2120
import tech.pegasys.teku.infrastructure.collections.cache.LRUCache;
2221
import tech.pegasys.teku.infrastructure.unsigned.UInt64;
@@ -31,18 +30,13 @@
3130
public class DataColumnSidecarSignatureValidator {
3231
private final Spec spec;
3332
private final CombinedChainDataClient chainDataClient;
34-
private final BLSSignatureVerifier signatureVerifier;
35-
3633
private final LRUCache<Bytes32, SafeFuture<Boolean>>
3734
cachedSignatureValidationResultsBySignedHeaderRoot;
3835

3936
public DataColumnSidecarSignatureValidator(
40-
final Spec spec,
41-
final CombinedChainDataClient chainDataClient,
42-
final BLSSignatureVerifier signatureVerifier) {
37+
final Spec spec, final CombinedChainDataClient chainDataClient) {
4338
this.spec = spec;
4439
this.chainDataClient = chainDataClient;
45-
this.signatureVerifier = signatureVerifier;
4640

4741
// let's cache enough headers so that we can be effective even during syncing,
4842
// when we try to download columns for multiple blocks in parallel
@@ -83,8 +77,9 @@ public SafeFuture<Boolean> validateSignature(final DataColumnSidecar sidecar) {
8377
return spec.getValidatorPubKey(state, proposerIndex)
8478
.map(
8579
pubKey ->
86-
signatureVerifier.verify(
87-
pubKey, signingRoot, signedBlockHeader.getSignature()))
80+
spec.getSpecConfig(epoch)
81+
.getBLSSignatureVerifier()
82+
.verify(pubKey, signingRoot, signedBlockHeader.getSignature()))
8883
.orElse(false);
8984
});
9085
});

networking/eth2/src/main/java/tech/pegasys/teku/networking/eth2/peers/Eth2PeerFactory.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,6 @@
1515

1616
import java.util.Optional;
1717
import org.hyperledger.besu.plugin.services.MetricsSystem;
18-
import tech.pegasys.teku.bls.BLSSignatureVerifier;
1918
import tech.pegasys.teku.infrastructure.time.TimeProvider;
2019
import tech.pegasys.teku.networking.eth2.rpc.beaconchain.BeaconChainMethods;
2120
import tech.pegasys.teku.networking.eth2.rpc.beaconchain.methods.MetadataMessagesFactory;
@@ -65,7 +64,7 @@ public Eth2PeerFactory(
6564
this.peerRequestLimit = peerRequestLimit;
6665
this.discoveryNodeIdExtractor = discoveryNodeIdExtractor;
6766
this.dataColumnSidecarSignatureValidator =
68-
new DataColumnSidecarSignatureValidator(spec, chainDataClient, BLSSignatureVerifier.SIMPLE);
67+
new DataColumnSidecarSignatureValidator(spec, chainDataClient);
6968
}
7069

7170
public Eth2Peer create(final Peer peer, final BeaconChainMethods rpcMethods) {

networking/eth2/src/test/java/tech/pegasys/teku/networking/eth2/peers/DataColumnSidecarSignatureValidatorTest.java

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,6 +14,7 @@
1414
package tech.pegasys.teku.networking.eth2.peers;
1515

1616
import static org.assertj.core.api.Assertions.assertThat;
17+
import static org.mockito.ArgumentMatchers.any;
1718
import static org.mockito.Mockito.mock;
1819
import static org.mockito.Mockito.never;
1920
import static org.mockito.Mockito.verify;
@@ -34,6 +35,7 @@
3435
import tech.pegasys.teku.spec.ForkSchedule;
3536
import tech.pegasys.teku.spec.Spec;
3637
import tech.pegasys.teku.spec.TestSpecFactory;
38+
import tech.pegasys.teku.spec.config.SpecConfig;
3739
import tech.pegasys.teku.spec.constants.Domain;
3840
import tech.pegasys.teku.spec.datastructures.blobs.DataColumnSidecar;
3941
import tech.pegasys.teku.spec.datastructures.blocks.SignedBeaconBlockHeader;
@@ -44,6 +46,7 @@
4446

4547
public class DataColumnSidecarSignatureValidatorTest {
4648
private final Spec spec = Mockito.mock(Spec.class);
49+
private final SpecConfig specConfig = mock(SpecConfig.class);
4750
private final DataStructureUtil dataStructureUtil =
4851
new DataStructureUtil(TestSpecFactory.createMinimalFulu());
4952

@@ -68,7 +71,7 @@ dataStructureUtil.new RandomDataColumnSidecarBuilder()
6871
.build();
6972

7073
private final DataColumnSidecarSignatureValidator validator =
71-
new DataColumnSidecarSignatureValidator(spec, chainDataClient, signatureVerifier);
74+
new DataColumnSidecarSignatureValidator(spec, chainDataClient);
7275

7376
@BeforeEach
7477
void setUp() {
@@ -87,6 +90,8 @@ void setUp() {
8790
when(spec.computeSigningRoot(signedBeaconBlockHeader.getMessage(), domain))
8891
.thenReturn(signingRoot);
8992

93+
when(spec.getSpecConfig(any())).thenReturn(specConfig);
94+
when(specConfig.getBLSSignatureVerifier()).thenReturn(signatureVerifier);
9095
// valid by default
9196
when(signatureVerifier.verify(
9297
proposerPubKey, signingRoot, signedBeaconBlockHeader.getSignature()))

0 commit comments

Comments
 (0)