refactoring

Consensys · Aug 2, 2024 · 26af271 · 26af271
1 parent fdc8a57
commit 26af271
Show file tree

Hide file tree

Showing 15 changed files with 52 additions and 90 deletions.
diff --git a/.../validator/src/main/java/tech/pegasys/teku/validator/coordinator/ValidatorApiHandler.java b/.../validator/src/main/java/tech/pegasys/teku/validator/coordinator/ValidatorApiHandler.java
@@ -79,7 +79,6 @@
 import tech.pegasys.teku.spec.datastructures.builder.SignedValidatorRegistration;
 import tech.pegasys.teku.spec.datastructures.genesis.GenesisData;
 import tech.pegasys.teku.spec.datastructures.metadata.BlockContainerAndMetaData;
-import tech.pegasys.teku.spec.datastructures.metadata.ObjectAndMetaData;
 import tech.pegasys.teku.spec.datastructures.operations.Attestation;
 import tech.pegasys.teku.spec.datastructures.operations.AttestationData;
 import tech.pegasys.teku.spec.datastructures.operations.SignedAggregateAndProof;
@@ -498,29 +497,18 @@ private AttestationData createAttestationData(
   }
 
   @Override
-  public SafeFuture<Optional<ObjectAndMetaData<Attestation>>> createAggregate(
+  public SafeFuture<Optional<Attestation>> createAggregate(
       final UInt64 slot,
       final Bytes32 attestationHashTreeRoot,
       final Optional<UInt64> committeeIndex) {
     if (isSyncActive()) {
       return NodeSyncingException.failedFuture();
     }
-
-    final Optional<Attestation> maybeAttestation =
+    return SafeFuture.completedFuture(
         attestationPool
             .createAggregateFor(attestationHashTreeRoot, committeeIndex)
             .filter(attestation -> attestation.getData().getSlot().equals(slot))
-            .map(ValidatableAttestation::getAttestation);
-
-    return SafeFuture.completedFuture(
-        maybeAttestation.map(
-            attestation ->
-                new ObjectAndMetaData<>(
-                    attestation,
-                    spec.atSlot(attestation.getData().getSlot()).getMilestone(),
-                    false,
-                    false,
-                    false)));
+            .map(ValidatableAttestation::getAttestation));
   }
 
   @Override

diff --git a/...idator/src/test/java/tech/pegasys/teku/validator/coordinator/ValidatorApiHandlerTest.java b/...idator/src/test/java/tech/pegasys/teku/validator/coordinator/ValidatorApiHandlerTest.java
@@ -695,7 +695,7 @@ public void createAttestationData_shouldUseCorrectSourceWhenEpochTransitionRequi
   @Test
   public void createAggregate_shouldFailWhenNodeIsSyncing() {
     nodeIsSyncing();
-    final SafeFuture<Optional<ObjectAndMetaData<Attestation>>> result =
+    final SafeFuture<Optional<Attestation>> result =
         validatorApiHandler.createAggregate(
             ONE, dataStructureUtil.randomAttestationData().hashTreeRoot(), Optional.empty());
 
@@ -717,18 +717,17 @@ public void createSyncCommitteeContribution() {
   @Test
   public void createAggregate_shouldReturnAggregateFromAttestationPool() {
     final AttestationData attestationData = dataStructureUtil.randomAttestationData();
-    final Attestation aggregate = dataStructureUtil.randomAttestation();
+    final Optional<Attestation> aggregate = Optional.of(dataStructureUtil.randomAttestation());
     when(attestationPool.createAggregateFor(
             eq(attestationData.hashTreeRoot()), eq(Optional.empty())))
-        .thenReturn(Optional.of(ValidatableAttestation.from(spec, aggregate)));
+        .thenReturn(aggregate.map(attestation -> ValidatableAttestation.from(spec, attestation)));
 
     assertThat(
             validatorApiHandler.createAggregate(
-                aggregate.getData().getSlot(), attestationData.hashTreeRoot(), Optional.empty()))
-        .isCompletedWithValue(
-            Optional.of(
-                new ObjectAndMetaData<>(
-                    aggregate, spec.getGenesisSpec().getMilestone(), false, false, false)));
+                aggregate.get().getData().getSlot(),
+                attestationData.hashTreeRoot(),
+                Optional.empty()))
+        .isCompletedWithValue(aggregate);
   }
 
   @Test

diff --git a/...n/java/tech/pegasys/teku/beaconrestapi/handlers/v1/validator/GetAggregateAttestation.java b/...n/java/tech/pegasys/teku/beaconrestapi/handlers/v1/validator/GetAggregateAttestation.java
@@ -34,7 +34,6 @@
 import tech.pegasys.teku.infrastructure.restapi.endpoints.RestApiRequest;
 import tech.pegasys.teku.infrastructure.unsigned.UInt64;
 import tech.pegasys.teku.spec.Spec;
-import tech.pegasys.teku.spec.datastructures.metadata.ObjectAndMetaData;
 import tech.pegasys.teku.spec.datastructures.operations.Attestation;
 import tech.pegasys.teku.spec.datastructures.operations.AttestationSchema;
 
@@ -72,16 +71,14 @@ public void handleRequest(final RestApiRequest request) throws JsonProcessingExc
     final Bytes32 beaconBlockRoot = request.getQueryParameter(ATTESTATION_DATA_ROOT_PARAMETER);
     final UInt64 slot = request.getQueryParameter(SLOT_PARAM);
 
-    final SafeFuture<Optional<ObjectAndMetaData<Attestation>>> future =
+    final SafeFuture<Optional<Attestation>> future =
         provider.createAggregate(slot, beaconBlockRoot, Optional.empty());
 
     request.respondAsync(
         future.thenApply(
-            maybeAttestationAndMetaData ->
-                maybeAttestationAndMetaData
-                    .map(
-                        attestationObjectAndMetaData ->
-                            AsyncApiResponse.respondOk(attestationObjectAndMetaData.getData()))
+            maybeAttestation ->
+                maybeAttestation
+                    .map(AsyncApiResponse::respondOk)
                     .orElseGet(AsyncApiResponse::respondNotFound)));
   }
 

diff --git a/...va/tech/pegasys/teku/beaconrestapi/handlers/v1/validator/GetAggregateAttestationTest.java b/...va/tech/pegasys/teku/beaconrestapi/handlers/v1/validator/GetAggregateAttestationTest.java
@@ -34,7 +34,6 @@
 import tech.pegasys.teku.beaconrestapi.AbstractMigratedBeaconHandlerTest;
 import tech.pegasys.teku.infrastructure.async.SafeFuture;
 import tech.pegasys.teku.infrastructure.unsigned.UInt64;
-import tech.pegasys.teku.spec.datastructures.metadata.ObjectAndMetaData;
 import tech.pegasys.teku.spec.datastructures.operations.Attestation;
 
 class GetAggregateAttestationTest extends AbstractMigratedBeaconHandlerTest {
@@ -53,11 +52,7 @@ public void shouldReturnAttestationInformation() throws JsonProcessingException
     Attestation attestation = dataStructureUtil.randomAttestation();
     when(validatorDataProvider.createAggregate(
             eq(UInt64.valueOf(1)), eq(attestationDataRoot), eq(Optional.empty())))
-        .thenReturn(
-            SafeFuture.completedFuture(
-                Optional.of(
-                    new ObjectAndMetaData<>(
-                        attestation, spec.getGenesisSpec().getMilestone(), false, false, false))));
+        .thenReturn(SafeFuture.completedFuture(Optional.of(attestation)));
 
     handler.handleRequest(request);
 

diff --git a/data/provider/src/main/java/tech/pegasys/teku/api/ValidatorDataProvider.java b/data/provider/src/main/java/tech/pegasys/teku/api/ValidatorDataProvider.java
@@ -240,7 +240,7 @@ private Optional<SyncCommitteeMessage> checkInternalCommitteeSignature(
     return Optional.of(message);
   }
 
-  public SafeFuture<Optional<ObjectAndMetaData<Attestation>>> createAggregate(
+  public SafeFuture<Optional<Attestation>> createAggregate(
       final UInt64 slot,
       final Bytes32 attestationHashTreeRoot,
       final Optional<UInt64> committeeIndex) {
@@ -249,7 +249,8 @@ public SafeFuture<Optional<ObjectAndMetaData<Attestation>>> createAggregate(
 
   public SafeFuture<Optional<ObjectAndMetaData<Attestation>>> createAggregateAndMetaData(
       final UInt64 slot, final Bytes32 attestationHashTreeRoot, final UInt64 committeeIndex) {
-    return createAggregate(slot, attestationHashTreeRoot, Optional.of(committeeIndex));
+    return createAggregate(slot, attestationHashTreeRoot, Optional.of(committeeIndex))
+        .thenApply(maybeAttestation -> maybeAttestation.map(this::lookUpMetadata));
   }
 
   public SafeFuture<List<SubmitDataError>> sendAggregateAndProofs(
@@ -348,4 +349,13 @@ private static ValidatorBlockResult generateSubmitSignedBlockResponse(
 
     return new ValidatorBlockResult(responseCode, result.getRejectionReason(), hashRoot);
   }
+
+  private ObjectAndMetaData<Attestation> lookUpMetadata(final Attestation attestation) {
+    return new ObjectAndMetaData<>(
+        attestation,
+        spec.atSlot(attestation.getData().getSlot()).getMilestone(),
+        false,
+        false,
+        false);
+  }
 }
diff --git a/validator/api/src/main/java/tech/pegasys/teku/validator/api/ValidatorApiChannel.java b/validator/api/src/main/java/tech/pegasys/teku/validator/api/ValidatorApiChannel.java
@@ -39,7 +39,6 @@
 import tech.pegasys.teku.spec.datastructures.builder.SignedValidatorRegistration;
 import tech.pegasys.teku.spec.datastructures.genesis.GenesisData;
 import tech.pegasys.teku.spec.datastructures.metadata.BlockContainerAndMetaData;
-import tech.pegasys.teku.spec.datastructures.metadata.ObjectAndMetaData;
 import tech.pegasys.teku.spec.datastructures.operations.Attestation;
 import tech.pegasys.teku.spec.datastructures.operations.AttestationData;
 import tech.pegasys.teku.spec.datastructures.operations.SignedAggregateAndProof;
@@ -109,7 +108,7 @@ public SafeFuture<Optional<AttestationData>> createAttestationData(
         }
 
         @Override
-        public SafeFuture<Optional<ObjectAndMetaData<Attestation>>> createAggregate(
+        public SafeFuture<Optional<Attestation>> createAggregate(
             UInt64 slot, Bytes32 attestationHashTreeRoot, Optional<UInt64> committeeIndex) {
           return SafeFuture.completedFuture(Optional.empty());
         }
@@ -232,7 +231,7 @@ SafeFuture<Optional<BlockContainerAndMetaData>> createUnsignedBlock(
 
   SafeFuture<Optional<AttestationData>> createAttestationData(UInt64 slot, int committeeIndex);
 
-  SafeFuture<Optional<ObjectAndMetaData<Attestation>>> createAggregate(
+  SafeFuture<Optional<Attestation>> createAggregate(
       UInt64 slot, Bytes32 attestationHashTreeRoot, Optional<UInt64> committeeIndex);
 
   SafeFuture<Optional<SyncCommitteeContribution>> createSyncCommitteeContribution(

diff --git a/...va/tech/pegasys/teku/validator/beaconnode/metrics/MetricRecordingValidatorApiChannel.java b/...va/tech/pegasys/teku/validator/beaconnode/metrics/MetricRecordingValidatorApiChannel.java
@@ -48,7 +48,6 @@
 import tech.pegasys.teku.spec.datastructures.builder.SignedValidatorRegistration;
 import tech.pegasys.teku.spec.datastructures.genesis.GenesisData;
 import tech.pegasys.teku.spec.datastructures.metadata.BlockContainerAndMetaData;
-import tech.pegasys.teku.spec.datastructures.metadata.ObjectAndMetaData;
 import tech.pegasys.teku.spec.datastructures.operations.Attestation;
 import tech.pegasys.teku.spec.datastructures.operations.AttestationData;
 import tech.pegasys.teku.spec.datastructures.operations.SignedAggregateAndProof;
@@ -157,7 +156,7 @@ public SafeFuture<Optional<AttestationData>> createAttestationData(
   }
 
   @Override
-  public SafeFuture<Optional<ObjectAndMetaData<Attestation>>> createAggregate(
+  public SafeFuture<Optional<Attestation>> createAggregate(
       final UInt64 slot,
       final Bytes32 attestationHashTreeRoot,
       final Optional<UInt64> committeeIndex) {

diff --git a/...ech/pegasys/teku/validator/beaconnode/metrics/MetricRecordingValidatorApiChannelTest.java b/...ech/pegasys/teku/validator/beaconnode/metrics/MetricRecordingValidatorApiChannelTest.java
@@ -35,10 +35,8 @@
 import tech.pegasys.teku.infrastructure.metrics.StubMetricsSystem;
 import tech.pegasys.teku.infrastructure.metrics.TekuMetricCategory;
 import tech.pegasys.teku.infrastructure.unsigned.UInt64;
-import tech.pegasys.teku.spec.SpecMilestone;
 import tech.pegasys.teku.spec.TestSpecFactory;
 import tech.pegasys.teku.spec.datastructures.genesis.GenesisData;
-import tech.pegasys.teku.spec.datastructures.metadata.ObjectAndMetaData;
 import tech.pegasys.teku.spec.datastructures.operations.Attestation;
 import tech.pegasys.teku.spec.datastructures.operations.AttestationData;
 import tech.pegasys.teku.spec.datastructures.operations.SignedAggregateAndProof;
@@ -210,8 +208,7 @@ public static Stream<Arguments> getDataRequestArguments() {
                 channel.createAggregate(
                     attestationData.getSlot(), attestationData.hashTreeRoot(), Optional.empty()),
             BeaconNodeRequestLabels.CREATE_AGGREGATE_METHOD,
-            new ObjectAndMetaData<>(
-                dataStructureUtil.randomAttestation(), SpecMilestone.PHASE0, false, false, false)),
+            dataStructureUtil.randomAttestation()),
         requestDataTest(
             "createSyncCommitteeContribution",
             channel ->

diff --git a/...src/main/java/tech/pegasys/teku/validator/client/duties/attestations/AggregationDuty.java b/...src/main/java/tech/pegasys/teku/validator/client/duties/attestations/AggregationDuty.java
@@ -26,7 +26,6 @@
 import tech.pegasys.teku.infrastructure.metrics.Validator.ValidatorDutyMetricsSteps;
 import tech.pegasys.teku.infrastructure.unsigned.UInt64;
 import tech.pegasys.teku.spec.Spec;
-import tech.pegasys.teku.spec.datastructures.metadata.ObjectAndMetaData;
 import tech.pegasys.teku.spec.datastructures.operations.AggregateAndProof;
 import tech.pegasys.teku.spec.datastructures.operations.Attestation;
 import tech.pegasys.teku.spec.datastructures.operations.AttestationData;
@@ -137,14 +136,10 @@ public SafeFuture<ProductionResult<SignedAggregateAndProof>> createAggregate(
     final SafeFuture<Optional<Attestation>> createAggregationFuture =
         validatorDutyMetrics.record(
             () ->
-                validatorApiChannel
-                    .createAggregate(
-                        slot,
-                        attestationData.hashTreeRoot(),
-                        Optional.of(aggregator.attestationCommitteeIndex))
-                    .thenApply(
-                        maybeAttestationAndMetaData ->
-                            maybeAttestationAndMetaData.map(ObjectAndMetaData::getData)),
+                validatorApiChannel.createAggregate(
+                    slot,
+                    attestationData.hashTreeRoot(),
+                    Optional.of(aggregator.attestationCommitteeIndex)),
             this,
             ValidatorDutyMetricsSteps.CREATE);
 

diff --git a/...r/client/src/test/java/tech/pegasys/teku/validator/client/duties/AggregationDutyTest.java b/...r/client/src/test/java/tech/pegasys/teku/validator/client/duties/AggregationDutyTest.java
@@ -45,10 +45,8 @@
 import tech.pegasys.teku.infrastructure.metrics.Validator.ValidatorDutyMetricsSteps;
 import tech.pegasys.teku.infrastructure.unsigned.UInt64;
 import tech.pegasys.teku.spec.Spec;
-import tech.pegasys.teku.spec.SpecMilestone;
 import tech.pegasys.teku.spec.TestSpecContext;
 import tech.pegasys.teku.spec.TestSpecInvocationContextProvider.SpecContext;
-import tech.pegasys.teku.spec.datastructures.metadata.ObjectAndMetaData;
 import tech.pegasys.teku.spec.datastructures.operations.AggregateAndProof;
 import tech.pegasys.teku.spec.datastructures.operations.AggregateAndProof.AggregateAndProofSchema;
 import tech.pegasys.teku.spec.datastructures.operations.Attestation;
@@ -80,19 +78,18 @@ class AggregationDutyTest {
       spy(ValidatorDutyMetrics.create(new StubMetricsSystem()));
 
   private Spec spec;
-  private SpecMilestone specMilestone;
   private DataStructureUtil dataStructureUtil;
   private AggregateAndProofSchema aggregateAndProofSchema;
   private SignedAggregateAndProofSchema signedAggregateAndProofSchema;
   private ForkInfo forkInfo;
   private Validator validator1;
   private Validator validator2;
+
   private AggregationDuty duty;
 
   @BeforeEach
   public void setUp(final SpecContext specContext) {
     spec = specContext.getSpec();
-    specMilestone = specContext.getSpecMilestone();
     dataStructureUtil = specContext.getDataStructureUtil();
     aggregateAndProofSchema = spec.getGenesisSchemaDefinitions().getAggregateAndProofSchema();
     signedAggregateAndProofSchema =
@@ -145,7 +142,7 @@ public void shouldProduceAggregateAndProof() {
             SLOT,
             attestationData.hashTreeRoot(),
             Optional.of(UInt64.valueOf(attestationCommitteeIndex))))
-        .thenReturn(completedFuture(Optional.of(addMetaData(aggregate))));
+        .thenReturn(completedFuture(Optional.of(aggregate)));
 
     final AggregateAndProof expectedAggregateAndProof =
         aggregateAndProofSchema.create(UInt64.valueOf(validatorIndex), aggregate, proof);
@@ -199,12 +196,12 @@ public void shouldProduceAggregateAndProofForMultipleCommittees() {
             SLOT,
             committee1AttestationData.hashTreeRoot(),
             Optional.of(UInt64.valueOf(validator1CommitteeIndex))))
-        .thenReturn(completedFuture(Optional.of(addMetaData(committee1Aggregate))));
+        .thenReturn(completedFuture(Optional.of(committee1Aggregate)));
     when(validatorApiChannel.createAggregate(
             SLOT,
             committee2AttestationData.hashTreeRoot(),
             Optional.of(UInt64.valueOf(validator2CommitteeIndex))))
-        .thenReturn(completedFuture(Optional.of(addMetaData(committee2Aggregate))));
+        .thenReturn(completedFuture(Optional.of(committee2Aggregate)));
 
     final AggregateAndProof aggregateAndProof1 =
         aggregateAndProofSchema.create(
@@ -264,7 +261,7 @@ public void shouldProduceSingleAggregateAndProofWhenMultipleValidatorsAggregateS
 
     when(validatorApiChannel.createAggregate(
             SLOT, attestationData.hashTreeRoot(), Optional.of(UInt64.valueOf(committeeIndex))))
-        .thenReturn(completedFuture(Optional.of(addMetaData(aggregate))));
+        .thenReturn(completedFuture(Optional.of(aggregate)));
     when(validatorApiChannel.sendAggregateAndProofs(anyList()))
         .thenReturn(SafeFuture.completedFuture(Collections.emptyList()));
 
@@ -383,8 +380,4 @@ private void performAndReportDuty() {
     assertThat(result).isCompleted();
     safeJoin(result).report(TYPE, SLOT, validatorLogger);
   }
-
-  private ObjectAndMetaData<Attestation> addMetaData(final Attestation aggregate) {
-    return new ObjectAndMetaData<>(aggregate, specMilestone, false, false, false);
-  }
 }
diff --git a/.../remote/src/main/java/tech/pegasys/teku/validator/remote/FailoverValidatorApiHandler.java b/.../remote/src/main/java/tech/pegasys/teku/validator/remote/FailoverValidatorApiHandler.java
@@ -50,7 +50,6 @@
 import tech.pegasys.teku.spec.datastructures.builder.SignedValidatorRegistration;
 import tech.pegasys.teku.spec.datastructures.genesis.GenesisData;
 import tech.pegasys.teku.spec.datastructures.metadata.BlockContainerAndMetaData;
-import tech.pegasys.teku.spec.datastructures.metadata.ObjectAndMetaData;
 import tech.pegasys.teku.spec.datastructures.operations.Attestation;
 import tech.pegasys.teku.spec.datastructures.operations.AttestationData;
 import tech.pegasys.teku.spec.datastructures.operations.SignedAggregateAndProof;
@@ -190,7 +189,7 @@ public SafeFuture<Optional<AttestationData>> createAttestationData(
   }
 
   @Override
-  public SafeFuture<Optional<ObjectAndMetaData<Attestation>>> createAggregate(
+  public SafeFuture<Optional<Attestation>> createAggregate(
       final UInt64 slot,
       final Bytes32 attestationHashTreeRoot,
       final Optional<UInt64> committeeIndex) {

diff --git a/...or/remote/src/main/java/tech/pegasys/teku/validator/remote/RemoteValidatorApiHandler.java b/...or/remote/src/main/java/tech/pegasys/teku/validator/remote/RemoteValidatorApiHandler.java
@@ -307,28 +307,24 @@ private List<SubmitDataError> convertPostDataFailureResponseToSubmitDataErrors(
   }
 
   @Override
-  public SafeFuture<Optional<ObjectAndMetaData<Attestation>>> createAggregate(
+  public SafeFuture<Optional<Attestation>> createAggregate(
       final UInt64 slot,
       final Bytes32 attestationHashTreeRoot,
       final Optional<UInt64> committeeIndex) {
     if (spec.atSlot(slot).getMilestone().isGreaterThanOrEqualTo(SpecMilestone.ELECTRA)
         && committeeIndex.isPresent()) {
       return sendRequest(
-          () -> typeDefClient.createAggregate(slot, attestationHashTreeRoot, committeeIndex.get()));
+          () ->
+              typeDefClient
+                  .createAggregate(slot, attestationHashTreeRoot, committeeIndex.get())
+                  .map(ObjectAndMetaData::getData));
     }
 
     return sendRequest(
         () ->
             apiClient
                 .createAggregate(slot, attestationHashTreeRoot)
-                .map(
-                    attestation ->
-                        new ObjectAndMetaData<>(
-                            attestation.asInternalAttestation(spec),
-                            spec.atSlot(attestation.data.slot).getMilestone(),
-                            false,
-                            false,
-                            false)));
+                .map(attestation -> attestation.asInternalAttestation(spec)));
   }
 
   @Override

diff --git a/...te/src/main/java/tech/pegasys/teku/validator/remote/sentry/SentryValidatorApiChannel.java b/...te/src/main/java/tech/pegasys/teku/validator/remote/sentry/SentryValidatorApiChannel.java
@@ -38,7 +38,6 @@
 import tech.pegasys.teku.spec.datastructures.builder.SignedValidatorRegistration;
 import tech.pegasys.teku.spec.datastructures.genesis.GenesisData;
 import tech.pegasys.teku.spec.datastructures.metadata.BlockContainerAndMetaData;
-import tech.pegasys.teku.spec.datastructures.metadata.ObjectAndMetaData;
 import tech.pegasys.teku.spec.datastructures.operations.Attestation;
 import tech.pegasys.teku.spec.datastructures.operations.AttestationData;
 import tech.pegasys.teku.spec.datastructures.operations.SignedAggregateAndProof;
@@ -127,7 +126,7 @@ public SafeFuture<Optional<AttestationData>> createAttestationData(
   }
 
   @Override
-  public SafeFuture<Optional<ObjectAndMetaData<Attestation>>> createAggregate(
+  public SafeFuture<Optional<Attestation>> createAggregate(
       final UInt64 slot,
       final Bytes32 attestationHashTreeRoot,
       final Optional<UInt64> committeeIndex) {