Skip to content

Commit

Permalink
Merge pull request #7 from ethpandaops/feat/implementation-contributoor
Browse files Browse the repository at this point in the history
feat: Change xatu event Implementation field
  • Loading branch information
samcm authored Jan 13, 2025
2 parents fbc618a + e83aabc commit c10f069
Show file tree
Hide file tree
Showing 6 changed files with 53 additions and 4 deletions.
4 changes: 4 additions & 0 deletions .gitignore
Original file line number Diff line number Diff line change
Expand Up @@ -4,3 +4,7 @@
# Any go workspace files a user may have created.
go.work
go.work.sum

# Contributoor
config.yaml
dist
3 changes: 3 additions & 0 deletions .goreleaser.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -15,6 +15,9 @@ builds:
goarch:
- amd64
- arm64
ldflags:
- -s -w -X github.com/ethpandaops/contributoor/internal/contributoor.Release={{.Tag}} -X github.com/ethpandaops/contributoor/internal/contributoor.GitCommit={{.ShortCommit}} -X github.com/ethpandaops/contributoor/internal/contributoor.GOOS={{.Os}} -X github.com/ethpandaops/contributoor/internal/contributoor.GOARCH={{.Arch}}
mod_timestamp: "{{ .CommitTimestamp }}"

dockers:
- image_templates:
Expand Down
3 changes: 3 additions & 0 deletions cmd/sentry/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -12,6 +12,7 @@ import (
"time"

"github.com/ethpandaops/contributoor/internal/clockdrift"
contr "github.com/ethpandaops/contributoor/internal/contributoor"
"github.com/ethpandaops/contributoor/internal/events"
"github.com/ethpandaops/contributoor/internal/sinks"
"github.com/ethpandaops/contributoor/pkg/config/v1"
Expand Down Expand Up @@ -76,6 +77,8 @@ func main() {
"config_path": s.config.ContributoorDirectory,
"name": s.name,
"version": s.config.Version,
"commit": contr.GitCommit,
"release": contr.Release,
}).Info("Starting contributoor")

if err := s.initClockDrift(ctx); err != nil {
Expand Down
2 changes: 1 addition & 1 deletion go.mod
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,6 @@ require (
github.com/mitchellh/hashstructure/v2 v2.0.2
github.com/pkg/errors v0.9.1
github.com/prometheus/client_golang v1.20.0
github.com/prysmaticlabs/go-bitfield v0.0.0-20240328144219-a1caa50c3a1e
github.com/sirupsen/logrus v1.9.3
github.com/stretchr/testify v1.10.0
github.com/urfave/cli/v2 v2.27.5
Expand Down Expand Up @@ -151,6 +150,7 @@ require (
github.com/prometheus/common v0.55.0 // indirect
github.com/prometheus/procfs v0.15.1 // indirect
github.com/prysmaticlabs/fastssz v0.0.0-20241008181541-518c4ce73516 // indirect
github.com/prysmaticlabs/go-bitfield v0.0.0-20240328144219-a1caa50c3a1e // indirect
github.com/prysmaticlabs/gohashtree v0.0.4-beta.0.20240624100937-73632381301b // indirect
github.com/prysmaticlabs/prysm/v5 v5.1.0 // indirect
github.com/quic-go/qpack v0.4.0 // indirect
Expand Down
38 changes: 38 additions & 0 deletions internal/contributoor/contributoor.go
Original file line number Diff line number Diff line change
@@ -0,0 +1,38 @@
package contributoor

import (
"fmt"
"runtime"
"strings"

"github.com/ethpandaops/xatu/pkg/proto/xatu"
)

var (
Release = "dev"
GitCommit = "dev"
Implementation = "Contributoor"
GOOS = runtime.GOOS
GOARCH = runtime.GOARCH
Module = xatu.ModuleName_SENTRY
)

func Full() string {
return fmt.Sprintf("%s/%s", Implementation, Short())
}

func Short() string {
return fmt.Sprintf("%s-%s", Release, GitCommit)
}

func FullVWithGOOS() string {
return fmt.Sprintf("%s/%s", Full(), GOOS)
}

func FullVWithPlatform() string {
return fmt.Sprintf("%s/%s/%s", Full(), GOOS, GOARCH)
}

func ImplementationLower() string {
return strings.ToLower(Implementation)
}
7 changes: 4 additions & 3 deletions pkg/ethereum/beacon.go
Original file line number Diff line number Diff line change
Expand Up @@ -10,6 +10,7 @@ import (
eth2v1 "github.com/attestantio/go-eth2-client/api/v1"
"github.com/ethpandaops/beacon/pkg/beacon"
"github.com/ethpandaops/contributoor/internal/clockdrift"
"github.com/ethpandaops/contributoor/internal/contributoor"
"github.com/ethpandaops/contributoor/internal/events"
v1 "github.com/ethpandaops/contributoor/internal/events/v1"
"github.com/ethpandaops/contributoor/internal/sinks"
Expand Down Expand Up @@ -411,10 +412,10 @@ func (b *BeaconNode) createEventMeta(ctx context.Context) (*xatu.Meta, error) {
return &xatu.Meta{
Client: &xatu.ClientMeta{
Name: clientName,
Version: xatu.Short(),
Version: contributoor.Short(),
Id: uuid.New().String(),
Implementation: xatu.Implementation,
ModuleName: xatu.ModuleName_SENTRY,
Implementation: contributoor.Implementation,
ModuleName: contributoor.Module,
Os: runtime.GOOS,
ClockDrift: uint64(b.clockDrift.GetDrift().Milliseconds()),
Ethereum: &xatu.ClientMeta_Ethereum{
Expand Down

0 comments on commit c10f069

Please sign in to comment.