feat: update isKeyper metric when handling messages and add successfull_dkg metric

Author: blockchainluffy

rolling-shutter/keyper/epochkghandler/key.go

@@ -3,6 +3,7 @@ package epochkghandler
 import (
 	"bytes"
 	"context"
+	"strconv"
 
 	"github.com/jackc/pgx/v4"
 	"github.com/jackc/pgx/v4/pgxpool"
@@ -14,6 +15,7 @@ import (
 	"github.com/shutter-network/shutter/shlib/shcrypto"
 
 	"github.com/shutter-network/rolling-shutter/rolling-shutter/keyper/database"
+	"github.com/shutter-network/rolling-shutter/rolling-shutter/keyper/keypermetrics"
 	"github.com/shutter-network/rolling-shutter/rolling-shutter/medley"
 	"github.com/shutter-network/rolling-shutter/rolling-shutter/p2p"
 	"github.com/shutter-network/rolling-shutter/rolling-shutter/p2pmsg"
@@ -52,25 +54,31 @@ func (handler *DecryptionKeyHandler) ValidateMessage(ctx context.Context, msg p2
 		return pubsub.ValidationReject, err
 	}
 	if !isKeyper {
+		keypermetrics.MetricsKeyperIsKeyper.WithLabelValues(strconv.FormatInt(eon, 10)).Set(0)
 		log.Debug().Int64("eon", eon).Msg("Ignoring decryptionKey for eon; we're not a Keyper")
 		return pubsub.ValidationReject, nil
 	}
+	keypermetrics.MetricsKeyperIsKeyper.WithLabelValues(strconv.FormatInt(eon, 10)).Set(1)
 
 	dkgResultDB, err := queries.GetDKGResultForKeyperConfigIndex(ctx, eon)
 	if errors.Is(err, pgx.ErrNoRows) {
+		keypermetrics.MetricsKeyperSuccessfullDKG.WithLabelValues(strconv.FormatInt(eon, 10)).Set(0)
 		return pubsub.ValidationReject, errors.Errorf("no DKG result found for eon %d", eon)
 	}
 	if err != nil {
+		keypermetrics.MetricsKeyperSuccessfullDKG.WithLabelValues(strconv.FormatInt(eon, 10)).Set(0)
 		return pubsub.ValidationReject, errors.Wrapf(err, "failed to get dkg result for eon %d from db", eon)
 	}
 	if !dkgResultDB.Success {
+		keypermetrics.MetricsKeyperSuccessfullDKG.WithLabelValues(strconv.FormatInt(eon, 10)).Set(0)
 		return pubsub.ValidationReject, errors.Errorf("no successful DKG result found for eon %d", eon)
 	}
 	pureDKGResult, err := shdb.DecodePureDKGResult(dkgResultDB.PureResult)
 	if err != nil {
 		return pubsub.ValidationReject, errors.Wrapf(err, "error while decoding pure DKG result for eon %d", eon)
 	}
 
+	keypermetrics.MetricsKeyperSuccessfullDKG.WithLabelValues(strconv.FormatInt(eon, 10)).Set(1)
 	if len(decryptionKeys.Keys) == 0 {
 		return pubsub.ValidationReject, errors.New("no keys in message")
 	}

rolling-shutter/keyper/keypermetrics/metrics.go

@@ -79,6 +79,16 @@ var MetricsKeyperBatchConfigInfo = prometheus.NewGaugeVec(
 	},
 	[]string{"batch_config_index", "keyper_addresses"})
 
+var MetricsKeyperSuccessfullDKG = prometheus.NewGaugeVec(
+	prometheus.GaugeOpts{
+		Namespace: "shutter",
+		Subsystem: "keyper",
+		Name:      "successfull_dkg",
+		Help:      "Is DKG successful",
+	},
+	[]string{"eon"},
+)
+
 func InitMetrics() {
 	prometheus.MustRegister(MetricsKeyperCurrentBlockL1)
 	prometheus.MustRegister(MetricsKeyperCurrentBlockShuttermint)
@@ -88,4 +98,5 @@ func InitMetrics() {
 	prometheus.MustRegister(MetricsKeyperCurrentPhase)
 	prometheus.MustRegister(MetricsKeyperCurrentBatchConfigIndex)
 	prometheus.MustRegister(MetricsKeyperBatchConfigInfo)
+	prometheus.MustRegister(MetricsKeyperSuccessfullDKG)
 }

rolling-shutter/keyper/smobserver/smstate.go

@@ -489,6 +489,7 @@ func (st *ShuttermintState) finalizeDKG(
 	dkgresultmsg := shmsg.NewDKGResult(eon, err == nil)
 
 	if err != nil {
+		keypermetrics.MetricsKeyperSuccessfullDKG.WithLabelValues(strconv.FormatInt(int64(eon), 10)).Set(0)
 		log.Error().Err(err).Uint64("eon", eon).Bool("success", false).
 			Msg("DKG process failed")
 		dkgerror = sql.NullString{String: err.Error(), Valid: true}
@@ -497,6 +498,7 @@ func (st *ShuttermintState) finalizeDKG(
 			return err
 		}
 	} else {
+		keypermetrics.MetricsKeyperSuccessfullDKG.WithLabelValues(strconv.FormatInt(int64(eon), 10)).Set(1)
 		log.Info().Uint64("eon", eon).Bool("success", true).Msg("DKG process succeeded")
 		pureResult, err = shdb.EncodePureDKGResult(&dkgresult)
 		if err != nil {