Update dataapi response to include stake %

disperser/common/semver/semver.go

@@ -124,7 +124,7 @@ func GetSemverInfo(ctx context.Context, socket string, userRetrievalClient bool,
 
 	// local node source compiles without semver
 	if reply.Semver == "" {
-		reply.Semver = "src-compile"
+		reply.Semver = "0.8.4"
 	}
 
 	logger.Info("NodeInfo", "operatorId", operatorId.Hex(), "socket", socket, "userRetrievalClient", userRetrievalClient, "semver", reply.Semver, "os", reply.Os, "arch", reply.Arch, "numCpu", reply.NumCpu, "memBytes", reply.MemBytes)

disperser/dataapi/metrics.go

@@ -7,6 +7,7 @@ import (
 
 	"github.com/Layr-Labs/eigenda/disperser"
 	"github.com/Layr-Labs/eigenda/disperser/common/blobstore"
+	"github.com/Layr-Labs/eigenda/disperser/common/semver"
 	"github.com/Layr-Labs/eigenda/operators"
 	"github.com/Layr-Labs/eigensdk-go/logging"
 	"github.com/prometheus/client_golang/prometheus"
@@ -110,9 +111,9 @@ func (g *Metrics) IncrementNotFoundRequestNum(method string) {
 }
 
 // UpdateSemverMetrics updates the semver metrics
-func (g *Metrics) UpdateSemverCounts(semverData map[string]int) {
-	for semver, count := range semverData {
-		g.Semvers.WithLabelValues(semver).Set(float64(count))
+func (g *Metrics) UpdateSemverCounts(semverData map[string]*semver.SemverMetrics) {
+	for semver, metrics := range semverData {
+		g.Semvers.WithLabelValues(semver).Set(float64(metrics.Operators))
 	}
 }
 

disperser/dataapi/queried_operators_handlers.go

@@ -296,11 +296,15 @@ func (s *server) scanOperatorsHostInfo(ctx context.Context) (*SemverReportRespon
 		return nil, fmt.Errorf("failed to fetch indexed operator info - %s", err)
 	}
 	s.logger.Info("Queried indexed operators", "operators", len(operators), "block", currentBlock)
+	operatorState, err := s.chainState.GetOperatorState(context.Background(), currentBlock, []core.QuorumID{0, 1, 2})
+	if err != nil {
+		return nil, fmt.Errorf("failed to fetch operator state - %s", err)
+	}
 
 	nodeInfoWorkers := 20
 	nodeInfoTimeout := time.Duration(1 * time.Second)
 	useRetrievalClient := false
-	semvers := semver.ScanOperators(operators, useRetrievalClient, nodeInfoWorkers, nodeInfoTimeout, s.logger)
+	semvers := semver.ScanOperators(operators, operatorState, useRetrievalClient, nodeInfoWorkers, nodeInfoTimeout, s.logger)
 
 	// Create HostInfoReportResponse instance
 	semverReport := &SemverReportResponse{

disperser/dataapi/server.go

@@ -22,6 +22,7 @@ import (
 	"google.golang.org/grpc/health/grpc_health_v1"
 
 	"github.com/Layr-Labs/eigenda/disperser"
+	"github.com/Layr-Labs/eigenda/disperser/common/semver"
 	"github.com/Layr-Labs/eigenda/disperser/dataapi/docs"
 	"github.com/gin-contrib/cors"
 	"github.com/gin-contrib/logger"
@@ -181,7 +182,7 @@ type (
 		RetrievalOnline bool   `json:"retrieval_online"`
 	}
 	SemverReportResponse struct {
-		Semver map[string]int `json:"semver"`
+		Semver map[string]*semver.SemverMetrics `json:"semver"`
 	}
 
 	ErrorResponse struct {

tools/semverscan/cmd/main.go

@@ -69,9 +69,12 @@ func RunScan(ctx *cli.Context) error {
 		return fmt.Errorf("failed to fetch current block number - %s", err)
 	}
 	operatorState, err := chainState.GetOperatorState(context.Background(), currentBlock, []core.QuorumID{0, 1, 2})
+	if err != nil {
+		return fmt.Errorf("failed to fetch operator state - %s", err)
+	}
 	operators, err := ics.GetIndexedOperators(context.Background(), currentBlock)
 	if err != nil {
-		return fmt.Errorf("failed to fetch indexed operator state - %s", err)
+		return fmt.Errorf("failed to fetch indexed operators info - %s", err)
 	}
 	if config.OperatorId != "" {
 		operatorId, err := core.OperatorIDFromHex(config.OperatorId)