Skip to content

Commit

Permalink
fix: make all
Browse files Browse the repository at this point in the history
  • Loading branch information
troykessler committed Dec 18, 2024
1 parent 513fadd commit 7a81510
Show file tree
Hide file tree
Showing 7 changed files with 99 additions and 100 deletions.
2 changes: 1 addition & 1 deletion proto/kyve/query/v1beta1/query.proto
Original file line number Diff line number Diff line change
Expand Up @@ -4,9 +4,9 @@ package kyve.query.v1beta1;

import "amino/amino.proto";
import "cosmos/base/v1beta1/coin.proto";
import "cosmos/staking/v1beta1/staking.proto";
import "gogoproto/gogo.proto";
import "kyve/pool/v1beta1/pool.proto";
import "cosmos/staking/v1beta1/staking.proto";

option go_package = "github.com/KYVENetwork/chain/x/query/types";

Expand Down
1 change: 0 additions & 1 deletion proto/kyve/query/v1beta1/stakers.proto
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,6 @@ import "cosmos/base/query/v1beta1/pagination.proto";
import "gogoproto/gogo.proto";
import "google/api/annotations.proto";
import "kyve/query/v1beta1/query.proto";
import "kyve/stakers/v1beta1/stakers.proto";

option go_package = "github.com/KYVENetwork/chain/x/query/types";

Expand Down
16 changes: 8 additions & 8 deletions testutil/integration/checks.go
Original file line number Diff line number Diff line change
Expand Up @@ -2,6 +2,7 @@ package integration

import (
"fmt"
"sort"
"time"

"github.com/KYVENetwork/chain/util"
Expand Down Expand Up @@ -123,19 +124,18 @@ func (suite *KeeperTestSuite) VerifyPoolQueries() {

// test stakers by pool
valaccounts := suite.App().StakersKeeper.GetAllValaccountsOfPool(suite.Ctx(), poolsState[i].Id)
stakersByPoolState := make([]querytypes.StakerPoolResponse, 0)
stakersByPoolState := make([]querytypes.FullStaker, 0)

for _, valaccount := range valaccounts {
_, stakerFound := suite.App().StakersKeeper.GetValidator(suite.Ctx(), valaccount.Staker)

if stakerFound {
stakersByPoolState = append(stakersByPoolState, querytypes.StakerPoolResponse{
Staker: suite.App().QueryKeeper.GetFullStaker(suite.Ctx(), valaccount.Staker),
Valaccount: valaccount,
})
if _, stakerFound := suite.App().StakersKeeper.GetValidator(suite.Ctx(), valaccount.Staker); stakerFound {
stakersByPoolState = append(stakersByPoolState, *suite.App().QueryKeeper.GetFullStaker(suite.Ctx(), valaccount.Staker))
}
}

sort.Slice(stakersByPoolState, func(a, b int) bool {
return suite.App().StakersKeeper.GetValidatorPoolStake(suite.Ctx(), stakersByPoolState[a].Address, poolsState[i].Id) > suite.App().StakersKeeper.GetValidatorPoolStake(suite.Ctx(), stakersByPoolState[b].Address, poolsState[i].Id)
})

stakersByPoolQuery, stakersByPoolQueryErr := suite.App().QueryKeeper.StakersByPool(suite.Ctx(), &querytypes.QueryStakersByPoolRequest{
PoolId: poolsState[i].Id,
})
Expand Down
1 change: 1 addition & 0 deletions x/query/keeper/grpc_query_stakers_by_pool_count.go
Original file line number Diff line number Diff line change
Expand Up @@ -2,6 +2,7 @@ package keeper

import (
"context"

"github.com/KYVENetwork/chain/x/query/types"
sdk "github.com/cosmos/cosmos-sdk/types"
"github.com/cosmos/cosmos-sdk/types/query"
Expand Down
86 changes: 43 additions & 43 deletions x/query/types/query.pb.go

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

90 changes: 44 additions & 46 deletions x/query/types/stakers.pb.go

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

Loading

0 comments on commit 7a81510

Please sign in to comment.