feat:add active field for validator

app/app.go

@@ -698,6 +698,7 @@ func NewExocoreApp(
 		&app.DelegationKeeper, // intentionally a pointer, since not yet initialized.
 		&app.OracleKeeper,
 		&app.AVSManagerKeeper,
+		&app.StakingKeeper,
 		delegationTypes.VirtualSlashKeeper{},
 	)
 	// the fee distribution keeper is used to allocate reward to exocore validators on epoch-basis,

proto/exocore/operator/v1/validator.proto

@@ -56,6 +56,8 @@ message Validator {
   ];
   // delegator_tokens is the list of asset infos
   repeated DelegatorInfo delegator_tokens = 11 [(gogoproto.nullable) = false];
+  // active defines whether the validator exists in the Tendermint validator set
+  bool active = 12;
 }
 
 // DelegatorInfo records the total opted-in USD value for the specified operator

x/dogfood/keeper/validators.go

@@ -155,6 +155,14 @@ func (k Keeper) GetExocoreValidator(
 	return
 }
 
+// IsExocoreValidator gets a validator based on the pub key derived (consensus) address.
+func (k Keeper) IsExocoreValidator(
+	ctx sdk.Context, addr sdk.ConsAddress,
+) bool {
+	store := ctx.KVStore(k.storeKey)
+	return store.Has(types.ExocoreValidatorKey(addr.Bytes()))
+}
+
 // DeleteExocoreValidator deletes a validator based on the pub key derived address.
 func (k Keeper) DeleteExocoreValidator(ctx sdk.Context, addr sdk.ConsAddress) {
 	store := ctx.KVStore(k.storeKey)

x/operator/keeper/consensus_keys.go

@@ -7,16 +7,13 @@ import (
 	errorsmod "cosmossdk.io/errors"
 	sdkmath "cosmossdk.io/math"
 
+	assetstypes "github.com/ExocoreNetwork/exocore/x/assets/types"
 	delegationkeeper "github.com/ExocoreNetwork/exocore/x/delegation/keeper"
 	oracletype "github.com/ExocoreNetwork/exocore/x/oracle/types"
-
-	assetstypes "github.com/ExocoreNetwork/exocore/x/assets/types"
-
+	"github.com/cometbft/cometbft/libs/log"
 	"github.com/cosmos/cosmos-sdk/store/prefix"
 	"github.com/ethereum/go-ethereum/common/hexutil"
 
-	"github.com/cometbft/cometbft/libs/log"
-
 	sdk "github.com/cosmos/cosmos-sdk/types"
 	stakingtypes "github.com/cosmos/cosmos-sdk/x/staking/types"
 
@@ -610,6 +607,7 @@ func (k Keeper) GetValidatorByConsAddrForChainID(
 		ctx.Logger().Error(" new validator error", "err", err)
 		return types.Validator{}, false
 	}
+	val.Active = k.stakingKeeper.IsExocoreValidator(ctx, wrappedKey.ToConsAddr())
 	val.OperatorEarningsAddr = ops.EarningsAddr
 	val.OperatorApproveAddr = ops.ApproveAddr
 	val.OperatorMetaInfo = ops.OperatorMetaInfo

x/operator/keeper/keeper.go

@@ -20,9 +20,9 @@ type Keeper struct {
 	delegationKeeper operatortypes.DelegationKeeper
 	oracleKeeper     operatortypes.OracleKeeper
 	avsKeeper        operatortypes.AVSKeeper
-
-	hooks       operatortypes.OperatorHooks // set separately via call to SetHooks
-	slashKeeper operatortypes.SlashKeeper   // for jailing and unjailing check TODO(mm)
+	stakingKeeper    operatortypes.StakingKeeper
+	hooks            operatortypes.OperatorHooks // set separately via call to SetHooks
+	slashKeeper      operatortypes.SlashKeeper   // for jailing and unjailing check TODO(mm)
 }
 
 func NewKeeper(
@@ -32,6 +32,7 @@ func NewKeeper(
 	delegationKeeper operatortypes.DelegationKeeper,
 	oracleKeeper operatortypes.OracleKeeper,
 	avsKeeper operatortypes.AVSKeeper,
+	stakingKeeper operatortypes.StakingKeeper,
 	slashKeeper operatortypes.SlashKeeper,
 ) Keeper {
 	return Keeper{
@@ -41,6 +42,7 @@ func NewKeeper(
 		delegationKeeper: delegationKeeper,
 		oracleKeeper:     oracleKeeper,
 		avsKeeper:        avsKeeper,
+		stakingKeeper:    stakingKeeper,
 		slashKeeper:      slashKeeper,
 	}
 }

x/operator/types/expected_keepers.go

@@ -141,3 +141,6 @@ type OperatorHooks interface {
 		ctx sdk.Context, addr sdk.AccAddress, affectedAVSList []string,
 	)
 }
+type StakingKeeper interface {
+	IsExocoreValidator(ctx sdk.Context, addr sdk.ConsAddress) bool
+}