feat: add more consumer chains metrics

pkg/app.go

@@ -63,6 +63,7 @@ func NewApp(configPath string, version string) *App {
 		queriersPkg.NewValidatorQuerier(logger, appConfig, tracer),
 		queriersPkg.NewDenomCoefficientsQuerier(logger, appConfig),
 		queriersPkg.NewSigningInfoQuerier(logger, appConfig, tracer),
+		queriersPkg.NewChainInfoQuerier(logger, appConfig, tracer),
 		queriersPkg.NewUptimeQuerier(),
 	}
 

pkg/queriers/chain_info.go

@@ -0,0 +1,103 @@
+package queriers
+
+import (
+	"context"
+	"main/pkg/config"
+	"main/pkg/tendermint"
+	"main/pkg/types"
+	"main/pkg/utils"
+	"sync"
+
+	"go.opentelemetry.io/otel/trace"
+
+	"github.com/prometheus/client_golang/prometheus"
+	"github.com/rs/zerolog"
+)
+
+type ChainInfoQuerier struct {
+	Logger zerolog.Logger
+	Config *config.Config
+	Tracer trace.Tracer
+}
+
+func NewChainInfoQuerier(
+	logger *zerolog.Logger,
+	config *config.Config,
+	tracer trace.Tracer,
+) *ChainInfoQuerier {
+	return &ChainInfoQuerier{
+		Logger: logger.With().Str("component", "chain_info_querier").Logger(),
+		Config: config,
+		Tracer: tracer,
+	}
+}
+
+func (q *ChainInfoQuerier) GetMetrics(
+	ctx context.Context,
+) ([]prometheus.Collector, []*types.QueryInfo) {
+	isConsumerGauge := prometheus.NewGaugeVec(
+		prometheus.GaugeOpts{
+			Name: "cosmos_validators_exporter_is_consumer",
+			Help: "Whether the chain is consumer (1 if yes, 0 if no)",
+		},
+		[]string{"chain"},
+	)
+
+	softOptOutThresholdGauge := prometheus.NewGaugeVec(
+		prometheus.GaugeOpts{
+			Name: "cosmos_validators_exporter_soft_opt_out_threshold",
+			Help: "Consumer chain's soft opt-out threshold",
+		},
+		[]string{"chain"},
+	)
+
+	queryInfos := make([]*types.QueryInfo, 0)
+
+	var wg sync.WaitGroup
+	var mutex sync.Mutex
+
+	for _, chain := range q.Config.Chains {
+		isConsumerGauge.With(prometheus.Labels{
+			"chain": chain.Name,
+		}).Set(utils.BoolToFloat64(chain.IsConsumer()))
+
+		if chain.IsConsumer() {
+			wg.Add(1)
+
+			go func(chain config.Chain) {
+				defer wg.Done()
+
+				rpc := tendermint.NewRPC(chain, q.Config.Timeout, q.Logger, q.Tracer)
+
+				threshold, query, err := rpc.GetConsumerSoftOutOutThreshold(ctx)
+
+				mutex.Lock()
+				defer mutex.Unlock()
+
+				if query != nil {
+					queryInfos = append(queryInfos, query)
+				}
+
+				if err != nil {
+					q.Logger.Error().
+						Err(err).
+						Str("chain", chain.Name).
+						Msg("Error querying soft opt-out threshold")
+					return
+				}
+
+				softOptOutThresholdGauge.With(prometheus.Labels{
+					"chain": chain.Name,
+				}).Set(threshold)
+			}(chain)
+		}
+	}
+
+	wg.Wait()
+
+	return []prometheus.Collector{isConsumerGauge, softOptOutThresholdGauge}, queryInfos
+}
+
+func (q *ChainInfoQuerier) Name() string {
+	return "chain-info-querier"
+}

pkg/tendermint/tendermint.go

@@ -7,6 +7,8 @@ import (
 	"main/pkg/http"
 	"main/pkg/types"
 	"main/pkg/utils"
+	"strconv"
+	"strings"
 
 	"go.opentelemetry.io/otel/attribute"
 	"go.opentelemetry.io/otel/trace"
@@ -415,6 +417,44 @@ func (rpc *RPC) GetSlashingParams(
 	return response, &info, nil
 }
 
+func (rpc *RPC) GetConsumerSoftOutOutThreshold(
+	ctx context.Context,
+) (float64, *types.QueryInfo, error) {
+	if !rpc.Chain.QueryEnabled("params") {
+		return 0, nil, nil
+	}
+
+	childQuerierCtx, span := rpc.Tracer.Start(
+		ctx,
+		"Fetching soft opt-out threshold params",
+	)
+	defer span.End()
+
+	var response *types.ParamsResponse
+	info, err := rpc.Client.Get(
+		rpc.Chain.LCDEndpoint+"/cosmos/params/v1beta1/params?subspace=ccvconsumer&key=SoftOptOutThreshold",
+		&response,
+		childQuerierCtx,
+	)
+	if err != nil {
+		return 0, &info, err
+	}
+
+	if response.Code != 0 {
+		info.Success = false
+		return 0, &info, fmt.Errorf("expected code 0, but got %d", response.Code)
+	}
+
+	valueStripped := strings.ReplaceAll(response.Param.Value, "\"", "")
+	value, err := strconv.ParseFloat(valueStripped, 64)
+	if err != nil {
+		info.Success = false
+		return 0, &info, err
+	}
+
+	return value, &info, nil
+}
+
 func (rpc *RPC) GetStakingParams(
 	ctx context.Context,
 ) (*types.StakingParamsResponse, *types.QueryInfo, error) {

pkg/types/tendermint.go

@@ -147,3 +147,12 @@ type CommissionResponse struct {
 		Commission []ResponseAmount `json:"commission"`
 	} `json:"commission"`
 }
+
+type ParamsResponse struct {
+	Code  int `json:"code"`
+	Param struct {
+		Subspace string `json:"subspace"`
+		Key      string `json:"key"`
+		Value    string `json:"value"`
+	} `json:"param"`
+}