enable parsing of payload_attributes events

attestantio · Sep 29, 2023 · 8858257 · 8858257
1 parent 813e947
commit 8858257
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/http/events.go b/http/events.go
@@ -26,6 +26,7 @@ import (
 
 	client "github.com/attestantio/go-eth2-client"
 	api "github.com/attestantio/go-eth2-client/api/v1"
+	v1 "github.com/attestantio/go-eth2-client/api/v1"
 	"github.com/attestantio/go-eth2-client/spec/altair"
 	"github.com/attestantio/go-eth2-client/spec/phase0"
 	"github.com/pkg/errors"
@@ -159,6 +160,14 @@ func (s *Service) handleEvent(ctx context.Context, msg *sse.Event, handler clien
 			return
 		}
 		event.Data = contributionAndProofEvent
+	case "payload_attributes":
+		payloadAttributesEvent := &v1.PayloadAttributesEvent{}
+		err := json.Unmarshal(msg.Data, payloadAttributesEvent)
+		if err != nil {
+			log.Error().Err(err).RawJSON("data", msg.Data).Msg("Failed to parse payload attributes event")
+			return
+		}
+		event.Data = payloadAttributesEvent
 	case "":
 		// Used as keepalive.  Ignore.
 		return