Added SingleAttestationEvent

data/beaconrestapi/src/main/java/tech/pegasys/teku/beaconrestapi/handlers/v1/events/EventSubscriptionManager.java

@@ -211,8 +211,14 @@ protected void onSyncCommitteeContribution(
   }
 
   protected void onNewAttestation(final ValidatableAttestation attestation) {
-    final AttestationEvent attestationEvent = new AttestationEvent(attestation.getAttestation());
-    notifySubscribersOfEvent(EventType.attestation, attestationEvent);
+    if (!attestation.getAttestation().isSingleAttestation()) {
+      final AttestationEvent attestationEvent = new AttestationEvent(attestation.getAttestation());
+      notifySubscribersOfEvent(EventType.attestation, attestationEvent);
+    } else {
+      final SingleAttestationEvent attestationEvent =
+          new SingleAttestationEvent(attestation.getAttestation().toSingleAttestationRequired());
+      notifySubscribersOfEvent(EventType.single_attestation, attestationEvent);
+    }
   }
 
   protected void onNewBlock(final SignedBeaconBlock block, final boolean executionOptimistic) {

data/beaconrestapi/src/main/java/tech/pegasys/teku/beaconrestapi/handlers/v1/events/SingleAttestationEvent.java

@@ -0,0 +1,23 @@
+/*
+ * Copyright Consensys Software Inc., 2024
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on
+ * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations under the License.
+ */
+
+package tech.pegasys.teku.beaconrestapi.handlers.v1.events;
+
+import tech.pegasys.teku.spec.datastructures.operations.SingleAttestation;
+
+public class SingleAttestationEvent extends Event<SingleAttestation> {
+  SingleAttestationEvent(final SingleAttestation attestation) {
+    super(
+        attestation.toSingleAttestationRequired().getSchema().getJsonTypeDefinition(), attestation);
+  }
+}

data/beaconrestapi/src/test/java/tech/pegasys/teku/beaconrestapi/handlers/v1/events/EventSubscriptionManagerTest.java

@@ -55,6 +55,7 @@
 import tech.pegasys.teku.spec.datastructures.operations.ProposerSlashing;
 import tech.pegasys.teku.spec.datastructures.operations.SignedBlsToExecutionChange;
 import tech.pegasys.teku.spec.datastructures.operations.SignedVoluntaryExit;
+import tech.pegasys.teku.spec.datastructures.operations.SingleAttestation;
 import tech.pegasys.teku.spec.datastructures.operations.versions.altair.SignedContributionAndProof;
 import tech.pegasys.teku.spec.datastructures.state.Checkpoint;
 import tech.pegasys.teku.spec.executionlayer.ForkChoiceState;
@@ -65,7 +66,7 @@
 import tech.pegasys.teku.storage.api.ReorgContext;
 
 public class EventSubscriptionManagerTest {
-  private final Spec spec = TestSpecFactory.createMinimalDeneb();
+  private final Spec spec = TestSpecFactory.createMinimalElectra();
   private final SpecConfig specConfig = spec.getGenesisSpecConfig();
   private final DataStructureUtil data = new DataStructureUtil(spec);
   protected final NodeDataProvider nodeDataProvider = mock(NodeDataProvider.class);
@@ -107,6 +108,7 @@ public class EventSubscriptionManagerTest {
       SignedBeaconBlock.create(data.randomSignedBeaconBlock(0));
   private final BlobSidecar sampleBlobSidecar = data.randomBlobSidecar();
   private final Attestation sampleAttestation = data.randomAttestation(0);
+  private final SingleAttestation singleAttestation = data.randomSingleAttestation();
 
   private final AttesterSlashing sampleAttesterSlashing =
       spec.getGenesisSchemaDefinitions()
@@ -123,7 +125,7 @@ public class EventSubscriptionManagerTest {
       data.randomPayloadBuildingAttributes(true);
   final PayloadAttributesData samplePayloadAttributesData =
       new PayloadAttributesData(
-          SpecMilestone.DENEB,
+          SpecMilestone.ELECTRA,
           new Data(
               samplePayloadAttributes.getProposalSlot(),
               samplePayloadAttributes.getParentBeaconBlockRoot(),
@@ -299,6 +301,15 @@ void shouldPropagateAttestation() throws IOException {
     checkEvent("attestation", new AttestationEvent(sampleAttestation));
   }
 
+  @Test
+  void shouldPropagateSingleAttestation() throws IOException {
+    when(req.getQueryString()).thenReturn("&topics=single_attestation");
+    manager.registerClient(client1);
+
+    triggerSingleAttestationEvent();
+    checkEvent("single_attestation", new SingleAttestationEvent(singleAttestation));
+  }
+
   @Test
   void shouldPropagateAttesterSlashing() throws IOException {
     when(req.getQueryString()).thenReturn("&topics=attester_slashing");
@@ -438,6 +449,11 @@ private void triggerAttestationEvent() {
     asyncRunner.executeQueuedActions();
   }
 
+  private void triggerSingleAttestationEvent() {
+    manager.onNewAttestation(ValidatableAttestation.from(spec, singleAttestation));
+    asyncRunner.executeQueuedActions();
+  }
+
   private void triggerAttesterSlashingEvent() {
     manager.onNewAttesterSlashing(sampleAttesterSlashing, InternalValidationResult.ACCEPT, false);
     asyncRunner.executeQueuedActions();

data/serializer/src/main/java/tech/pegasys/teku/api/response/v1/EventType.java

@@ -30,7 +30,8 @@ public enum EventType {
   attester_slashing,
   proposer_slashing,
   payload_attributes,
-  block_gossip;
+  block_gossip,
+  single_attestation;
 
   public static List<EventType> getTopics(final List<String> topics) {
     return topics.stream().map(EventType::valueOf).toList();