feat: add EL & CL version metrics

Author: blockchainluffy

rolling-shutter/keyper/keyper.go

@@ -147,7 +147,7 @@ func (kpr *KeyperCore) Start(ctx context.Context, runner service.Runner) error {
 	messageSender := fx.NewRPCMessageSender(shuttermintClient, config.Ethereum.PrivateKey.Key)
 
 	if kpr.config.Metrics.Enabled {
-		keypermetrics.InitMetrics()
+		keypermetrics.InitMetrics(kpr.config)
 		epochkghandler.InitMetrics()
 		deployment.InitMetrics()
 		kpr.metricsServer = metricsserver.New(kpr.config.Metrics)

rolling-shutter/keyper/keypermetrics/metrics.go

@@ -1,7 +1,13 @@
 package keypermetrics
 
 import (
+	"context"
+
+	"github.com/ethereum/go-ethereum/rpc"
 	"github.com/prometheus/client_golang/prometheus"
+	"github.com/rs/zerolog/log"
+
+	"github.com/shutter-network/rolling-shutter/rolling-shutter/keyper/kprconfig"
 )
 
 var MetricsKeyperCurrentBlockL1 = prometheus.NewGauge(
@@ -79,7 +85,7 @@ var MetricsKeyperBatchConfigInfo = prometheus.NewGaugeVec(
 	},
 	[]string{"batch_config_index", "keyper_addresses"})
 
-func InitMetrics() {
+func InitMetrics(config *kprconfig.Config) {
 	prometheus.MustRegister(MetricsKeyperCurrentBlockL1)
 	prometheus.MustRegister(MetricsKeyperCurrentBlockShuttermint)
 	prometheus.MustRegister(MetricsKeyperCurrentEon)
@@ -88,4 +94,32 @@ func InitMetrics() {
 	prometheus.MustRegister(MetricsKeyperCurrentPhase)
 	prometheus.MustRegister(MetricsKeyperCurrentBatchConfigIndex)
 	prometheus.MustRegister(MetricsKeyperBatchConfigInfo)
+
+	version, err := getClientVersion(config.Ethereum.EthereumURL)
+	if err != nil {
+		log.Error().Err(err).Msg("Failed to get execution client version")
+	}
+
+	executionClientVersion := prometheus.NewGauge(
+		prometheus.GaugeOpts{
+			Namespace: "shutter",
+			Subsystem: "keyper",
+			Name:      "execution_client_version",
+			Help:      "Version of the execution client",
+			ConstLabels: prometheus.Labels{
+				"version": version,
+			},
+		},
+	)
+	prometheus.MustRegister(executionClientVersion)
+}
+
+func getClientVersion(rpcURL string) (string, error) {
+	client, err := rpc.DialContext(context.Background(), rpcURL)
+	if err != nil {
+		return "", err
+	}
+	var version string
+	err = client.CallContext(context.Background(), &version, "web3_clientVersion")
+	return version, err
 }

rolling-shutter/keyperimpl/gnosis/keyper.go

@@ -71,6 +71,10 @@ func New(c *Config) *Keyper {
 func (kpr *Keyper) Start(ctx context.Context, runner service.Runner) error {
 	var err error
 
+	if kpr.config.Metrics.Enabled {
+		InitMetrics(kpr.beaconAPIClient)
+	}
+
 	kpr.newBlocks = make(chan *syncevent.LatestBlock)
 	kpr.newKeyperSets = make(chan *syncevent.KeyperSet)
 	kpr.newEonPublicKeys = make(chan keyper.EonPublicKey)

rolling-shutter/keyperimpl/gnosis/metrics.go

@@ -1,6 +1,11 @@
 package gnosis
 
-import "github.com/prometheus/client_golang/prometheus"
+import (
+	"github.com/prometheus/client_golang/prometheus"
+	"github.com/rs/zerolog/log"
+
+	"github.com/shutter-network/rolling-shutter/rolling-shutter/medley/beaconapiclient"
+)
 
 var metricsTxPointer = prometheus.NewGaugeVec(
 	prometheus.GaugeOpts{
@@ -93,3 +98,22 @@ func init() {
 	prometheus.MustRegister(metricsKeysSentTimeDelta)
 	prometheus.MustRegister(metricsKeySharesSentTimeDelta)
 }
+
+func InitMetrics(beaconClient *beaconapiclient.Client) {
+	version, err := beaconClient.GetBeaconNodeVersion()
+	if err != nil {
+		log.Error().Err(err).Msg("Failed to get beacon node version")
+	}
+	beaconClientVersion := prometheus.NewGauge(
+		prometheus.GaugeOpts{
+			Namespace: "shutter",
+			Subsystem: "gnosis",
+			Name:      "beacon_client_version",
+			Help:      "Version of the beacon client",
+			ConstLabels: prometheus.Labels{
+				"version": version,
+			},
+		},
+	)
+	prometheus.MustRegister(beaconClientVersion)
+}

rolling-shutter/medley/beaconapiclient/beaconapiclient.go

@@ -1,6 +1,9 @@
 package beaconapiclient
 
 import (
+	"encoding/json"
+	"fmt"
+	"io"
 	"net/http"
 	"net/url"
 )
@@ -20,3 +23,29 @@ func New(rawURL string) (*Client, error) {
 		url: parsedURL,
 	}, nil
 }
+
+func (c *Client) GetBeaconNodeVersion() (string, error) {
+	endpoint := "/eth/v1/node/version"
+	resp, err := c.c.Get(c.url.JoinPath(endpoint).String())
+	if err != nil {
+		return "", err
+	}
+	defer resp.Body.Close()
+	if resp.StatusCode != http.StatusOK {
+		return "", fmt.Errorf("unexpected status code: %d", resp.StatusCode)
+	}
+	body, err := io.ReadAll(resp.Body)
+	if err != nil {
+		return "", err
+	}
+	var result struct {
+		Data struct {
+			Version string `json:"version"`
+		} `json:"data"`
+	}
+	err = json.Unmarshal(body, &result)
+	if err != nil {
+		return "", err
+	}
+	return result.Data.Version, nil
+}