diff --git a/cl/beacon/beaconevents/model.go b/cl/beacon/beaconevents/model.go index fcbe6a3204a..f8fa1a03edc 100644 --- a/cl/beacon/beaconevents/model.go +++ b/cl/beacon/beaconevents/model.go @@ -17,6 +17,7 @@ type EventTopic string // Operation event topics const ( OpAttestation EventTopic = "attestation" + OpSingleAttestation EventTopic = "single_attestation" OpVoluntaryExit EventTopic = "voluntary_exit" OpProposerSlashing EventTopic = "proposer_slashing" OpAttesterSlashing EventTopic = "attester_slashing" diff --git a/cl/beacon/beaconevents/operation_feed.go b/cl/beacon/beaconevents/operation_feed.go index 13a42cf846e..f496eeddc4a 100644 --- a/cl/beacon/beaconevents/operation_feed.go +++ b/cl/beacon/beaconevents/operation_feed.go @@ -25,7 +25,7 @@ func (f *operationFeed) SendAttestation(value *AttestationData) int { func (f *operationFeed) SendSingleAttestation(value *SingleAttestationData) int { return f.feed.Send(&EventStream{ - Event: OpAttestation, + Event: OpSingleAttestation, Data: value, }) } diff --git a/cl/beacon/handler/events.go b/cl/beacon/handler/events.go index ca7bf0747b9..2583813e477 100644 --- a/cl/beacon/handler/events.go +++ b/cl/beacon/handler/events.go @@ -33,6 +33,7 @@ import ( var validTopics = map[event.EventTopic]struct{}{ // operation events event.OpAttestation: {}, + event.OpSingleAttestation: {}, event.OpAttesterSlashing: {}, event.OpBlobSidecar: {}, event.OpDataColumnSidecar: {},