chore: added staker status

docs/static/openapi.yml

@@ -8063,15 +8063,19 @@ paths:
             status looks whether a staker is participating in pools or not
 
              - STAKER_STATUS_UNSPECIFIED: STAKER_STATUS_UNSPECIFIED ...
-             - STAKER_STATUS_ACTIVE: STAKER_STATUS_ACTIVE ...
-             - STAKER_STATUS_INACTIVE: STAKER_STATUS_INACTIVE ...
+             - STAKER_STATUS_PROTOCOL_ACTIVE: STAKER_STATUS_PROTOCOL_ACTIVE ...
+             - STAKER_STATUS_PROTOCOL_INACTIVE: STAKER_STATUS_PROTOCOL_INACTIVE ...
+             - STAKER_STATUS_CHAIN_ACTIVE: STAKER_STATUS_CHAIN_ACTIVE ...
+             - STAKER_STATUS_CHAIN_INACTIVE: STAKER_STATUS_CHAIN_INACTIVE ...
           in: query
           required: false
           type: string
           enum:
             - STAKER_STATUS_UNSPECIFIED
-            - STAKER_STATUS_ACTIVE
-            - STAKER_STATUS_INACTIVE
+            - STAKER_STATUS_PROTOCOL_ACTIVE
+            - STAKER_STATUS_PROTOCOL_INACTIVE
+            - STAKER_STATUS_CHAIN_ACTIVE
+            - STAKER_STATUS_CHAIN_INACTIVE
           default: STAKER_STATUS_UNSPECIFIED
         - name: search
           description: search searches for moniker OR address

proto/kyve/query/v1beta1/stakers.proto

@@ -56,10 +56,14 @@ enum StakerStatus {
 
   // STAKER_STATUS_UNSPECIFIED ...
   STAKER_STATUS_UNSPECIFIED = 0;
-  // STAKER_STATUS_ACTIVE ...
-  STAKER_STATUS_ACTIVE = 1;
-  // STAKER_STATUS_INACTIVE ...
-  STAKER_STATUS_INACTIVE = 2;
+  // STAKER_STATUS_PROTOCOL_ACTIVE ...
+  STAKER_STATUS_PROTOCOL_ACTIVE = 1;
+  // STAKER_STATUS_PROTOCOL_INACTIVE ...
+  STAKER_STATUS_PROTOCOL_INACTIVE = 2;
+  // STAKER_STATUS_CHAIN_ACTIVE ...
+  STAKER_STATUS_CHAIN_ACTIVE = 3;
+  // STAKER_STATUS_CHAIN_INACTIVE ...
+  STAKER_STATUS_CHAIN_INACTIVE = 4;
 }
 
 // QueryStakersResponse is the response type for the Query/Stakers RPC method.

x/query/keeper/grpc_query_staker.go

@@ -41,7 +41,7 @@ func (k Keeper) Stakers(c context.Context, req *types.QueryStakersRequest) (*typ
 	var pageRes *query.PageResponse
 	var err error
 
-	pageRes, err = k.stakerKeeper.GetPaginatedStakersByPoolStake(ctx, req.Pagination, accumulator)
+	pageRes, err = k.stakerKeeper.GetPaginatedStakersByPoolStake(ctx, req.Pagination, req.Status, accumulator)
 
 	if err != nil {
 		return nil, err

x/stakers/keeper/exported_functions.go

@@ -2,6 +2,7 @@ package keeper
 
 import (
 	"context"
+	querytypes "github.com/KYVENetwork/chain/x/query/types"
 	"google.golang.org/grpc/codes"
 	"google.golang.org/grpc/status"
 	"sort"
@@ -46,7 +47,7 @@ func (k Keeper) GetAllStakerAddressesOfPool(ctx sdk.Context, poolId uint64) (sta
 	return stakers
 }
 
-func (k Keeper) GetPaginatedStakersByPoolStake(ctx sdk.Context, pagination *query.PageRequest, accumulator func(validator string, accumulate bool) bool) (*query.PageResponse, error) {
+func (k Keeper) GetPaginatedStakersByPoolStake(ctx sdk.Context, pagination *query.PageRequest, stakerStatus querytypes.StakerStatus, accumulator func(validator string, accumulate bool) bool) (*query.PageResponse, error) {
 	validators, err := k.stakingKeeper.GetBondedValidatorsByPower(ctx)
 	if err != nil {
 		return nil, err
@@ -55,13 +56,33 @@ func (k Keeper) GetPaginatedStakersByPoolStake(ctx sdk.Context, pagination *quer
 	addresses := make([]string, 0)
 
 	for _, validator := range validators {
-		addresses = append(addresses, util.MustAccountAddressFromValAddress(validator.OperatorAddress))
+		address := util.MustAccountAddressFromValAddress(validator.OperatorAddress)
+
+		if stakerStatus == querytypes.STAKER_STATUS_PROTOCOL_ACTIVE && len(k.GetValaccountsFromStaker(ctx, address)) == 0 {
+			continue
+		}
+
+		if stakerStatus == querytypes.STAKER_STATUS_PROTOCOL_INACTIVE && len(k.GetValaccountsFromStaker(ctx, address)) > 0 {
+			continue
+		}
+
+		if stakerStatus == querytypes.STAKER_STATUS_CHAIN_ACTIVE && !validator.IsBonded() {
+			continue
+		}
+
+		if stakerStatus == querytypes.STAKER_STATUS_CHAIN_INACTIVE && validator.IsBonded() {
+			continue
+		}
+
+		addresses = append(addresses, address)
 	}
 
 	// TODO: is this too expensive?
-	sort.Slice(addresses, func(i, j int) bool {
-		return k.GetValidatorTotalPoolStake(ctx, addresses[i]) > k.GetValidatorTotalPoolStake(ctx, addresses[j])
-	})
+	if stakerStatus == querytypes.STAKER_STATUS_UNSPECIFIED || stakerStatus == querytypes.STAKER_STATUS_PROTOCOL_ACTIVE {
+		sort.Slice(addresses, func(i, j int) bool {
+			return k.GetValidatorTotalPoolStake(ctx, addresses[i]) > k.GetValidatorTotalPoolStake(ctx, addresses[j])
+		})
+	}
 
 	pageRes, err := arrayPaginationAccumulator(addresses, pagination, accumulator)
 	if err != nil {