Skip to content

feat: subscribe to and deliver head_v2 events #79

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
samcm merged 1 commit into from
Jul 12, 2026
Merged

feat: subscribe to and deliver head_v2 events #79

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion go.mod
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ require (
github.com/chuckpreslar/emission v0.0.0-20170206194824-a7ddd980baf9
github.com/ethereum/go-ethereum v1.17.3-0.20260507223249-73944e329925
github.com/ethpandaops/ethwallclock v0.2.0
github.com/ethpandaops/go-eth2-client v0.1.6-0.20260708061330-ed85bf5c3bab
github.com/ethpandaops/go-eth2-client v0.1.7-0.20260712074542-bca0dce49005
github.com/go-co-op/gocron v1.16.2
github.com/prometheus/client_golang v1.23.2
github.com/prometheus/client_model v0.6.2
Expand Down
2 changes: 2 additions & 0 deletions go.sum
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -24,6 +24,8 @@ github.com/ethpandaops/ethwallclock v0.2.0 h1:EeFKtZ7v6TAdn/oAh0xaPujD7N4amjBxrW
github.com/ethpandaops/ethwallclock v0.2.0/go.mod h1:y0Cu+mhGLlem19vnAV2x0hpFS5KZ7oOi2SWYayv9l24=
github.com/ethpandaops/go-eth2-client v0.1.6-0.20260708061330-ed85bf5c3bab h1:lOnMzC2Oyzd+hJ0BOH1HXXYou1jMnlX2dVsP8vztX7U=
github.com/ethpandaops/go-eth2-client v0.1.6-0.20260708061330-ed85bf5c3bab/go.mod h1:97Oq3omOQSGPPYgrbsOIIw2Pc4T5Ph21f8ZRyHJQBHU=
github.com/ethpandaops/go-eth2-client v0.1.7-0.20260712074542-bca0dce49005 h1:hN4nugJUYn/O1Or4cW8jBYJBgCCrIGeMU2bXbpKWInU=
github.com/ethpandaops/go-eth2-client v0.1.7-0.20260712074542-bca0dce49005/go.mod h1:97Oq3omOQSGPPYgrbsOIIw2Pc4T5Ph21f8ZRyHJQBHU=
github.com/frankban/quicktest v1.14.6 h1:7Xjx+VpznH+oBnejlPUj8oUpdxnVs4f8XU8WnHkI4W8=
github.com/frankban/quicktest v1.14.6/go.mod h1:4ptaffx2x8+WTWXmUCuVU6aPUX1/Mz7zb5vbUoiM6w0=
github.com/fsnotify/fsnotify v1.4.7/go.mod h1:jwhsz4b93w/PPRr/qN1Yymfu8t87LnFCMoQvtojpjFo=
Expand Down
2 changes: 2 additions & 0 deletions pkg/beacon/beacon.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -124,6 +124,8 @@ type Node interface {
OnFinalizedCheckpoint(ctx context.Context, handler func(ctx context.Context, ev *v1.FinalizedCheckpointEvent) error)
// OnHead is called when the head is received.
OnHead(ctx context.Context, handler func(ctx context.Context, ev *v1.HeadEvent) error)
// OnHeadV2 is called when a head_v2 event (gloas) is received.
OnHeadV2(ctx context.Context, handler func(ctx context.Context, ev *v1.HeadEventV2) error)
// OnChainReOrg is called when a chain reorg is received.
OnChainReOrg(ctx context.Context, handler func(ctx context.Context, ev *v1.ChainReorgEvent) error)
// OnVoluntaryExit is called when a voluntary exit is received.
Expand Down
1 change: 1 addition & 0 deletions pkg/beacon/event.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -57,6 +57,7 @@ const (
topicExecutionPayloadGossip = "execution_payload_gossip"
topicPayloadAttestationMessage = "payload_attestation_message"
topicProposerPreferences = "proposer_preferences"
topicHeadV2 = "head_v2"
)

type ReadyEvent struct {
Expand Down
4 changes: 4 additions & 0 deletions pkg/beacon/publisher.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -43,6 +43,10 @@ func (n *node) publishHead(ctx context.Context, event *v1.HeadEvent) {
n.broker.Emit(topicHead, event)
}

func (n *node) publishHeadV2(ctx context.Context, event *v1.HeadEventV2) {
n.broker.Emit(topicHeadV2, event)
}

func (n *node) publishVoluntaryExit(ctx context.Context, event *phase0.SignedVoluntaryExit) {
n.broker.Emit(topicVoluntaryExit, event)
}
Expand Down
6 changes: 6 additions & 0 deletions pkg/beacon/subscriber.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -60,6 +60,12 @@ func (n *node) OnHead(ctx context.Context, handler func(ctx context.Context, eve
})
}

func (n *node) OnHeadV2(ctx context.Context, handler func(ctx context.Context, event *v1.HeadEventV2) error) {
n.broker.On(topicHeadV2, func(event *v1.HeadEventV2) {
n.handleSubscriberError(handler(ctx, event), topicHeadV2)
})
}

func (n *node) OnVoluntaryExit(ctx context.Context, handler func(ctx context.Context, event *phase0.SignedVoluntaryExit) error) {
n.broker.On(topicVoluntaryExit, func(event *phase0.SignedVoluntaryExit) {
n.handleSubscriberError(handler(ctx, event), topicVoluntaryExit)
Expand Down
13 changes: 13 additions & 0 deletions pkg/beacon/subscriptions.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -95,6 +95,8 @@ func (n *node) handleEvent(ctx context.Context, event *v1.Event) error {
return n.handleFinalizedCheckpoint(ctx, event)
case topicHead:
return n.handleHead(ctx, event)
case topicHeadV2:
return n.handleHeadV2(ctx, event)
case topicVoluntaryExit:
return n.handleVoluntaryExit(ctx, event)
case topicContributionAndProof:
Expand Down Expand Up @@ -200,6 +202,17 @@ func (n *node) handleFinalizedCheckpoint(ctx context.Context, event *v1.Event) e
return nil
}

func (n *node) handleHeadV2(ctx context.Context, event *v1.Event) error {
head, valid := event.Data.(*v1.HeadEventV2)
if !valid {
return errors.New("invalid head_v2 event")
}

n.publishHeadV2(ctx, head)

return nil
}

func (n *node) handleHead(ctx context.Context, event *v1.Event) error {
head, valid := event.Data.(*v1.HeadEvent)
if !valid {
Expand Down