86 lines
2.3 KiB
Go
86 lines
2.3 KiB
Go
package keeper
|
|
|
|
import (
|
|
"context"
|
|
|
|
"github.com/cosmos/cosmos-sdk/store/prefix"
|
|
"github.com/cosmos/cosmos-sdk/types/query"
|
|
|
|
"google.golang.org/grpc/codes"
|
|
"google.golang.org/grpc/status"
|
|
|
|
codectypes "github.com/cosmos/cosmos-sdk/codec/types"
|
|
sdk "github.com/cosmos/cosmos-sdk/types"
|
|
"github.com/cosmos/cosmos-sdk/x/auth/types"
|
|
)
|
|
|
|
var _ types.QueryServer = AccountKeeper{}
|
|
|
|
func (ak AccountKeeper) Accounts(c context.Context, req *types.QueryAccountsRequest) (*types.QueryAccountsResponse, error) {
|
|
if req == nil {
|
|
return nil, status.Error(codes.InvalidArgument, "empty request")
|
|
}
|
|
|
|
ctx := sdk.UnwrapSDKContext(c)
|
|
store := ctx.KVStore(ak.key)
|
|
accountsStore := prefix.NewStore(store, types.AddressStoreKeyPrefix)
|
|
|
|
var accounts []*codectypes.Any
|
|
pageRes, err := query.Paginate(accountsStore, req.Pagination, func(key, value []byte) error {
|
|
account := ak.decodeAccount(value)
|
|
any, err := codectypes.NewAnyWithValue(account)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
accounts = append(accounts, any)
|
|
return nil
|
|
})
|
|
|
|
if err != nil {
|
|
return nil, status.Errorf(codes.Internal, "paginate: %v", err)
|
|
}
|
|
|
|
return &types.QueryAccountsResponse{Accounts: accounts, Pagination: pageRes}, err
|
|
}
|
|
|
|
// Account returns account details based on address
|
|
func (ak AccountKeeper) Account(c context.Context, req *types.QueryAccountRequest) (*types.QueryAccountResponse, error) {
|
|
if req == nil {
|
|
return nil, status.Errorf(codes.InvalidArgument, "empty request")
|
|
}
|
|
|
|
if req.Address == "" {
|
|
return nil, status.Error(codes.InvalidArgument, "Address cannot be empty")
|
|
}
|
|
|
|
ctx := sdk.UnwrapSDKContext(c)
|
|
addr, err := sdk.AccAddressFromBech32(req.Address)
|
|
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
account := ak.GetAccount(ctx, addr)
|
|
if account == nil {
|
|
return nil, status.Errorf(codes.NotFound, "account %s not found", req.Address)
|
|
}
|
|
|
|
any, err := codectypes.NewAnyWithValue(account)
|
|
if err != nil {
|
|
return nil, status.Errorf(codes.Internal, err.Error())
|
|
}
|
|
|
|
return &types.QueryAccountResponse{Account: any}, nil
|
|
}
|
|
|
|
// Params returns parameters of auth module
|
|
func (ak AccountKeeper) Params(c context.Context, req *types.QueryParamsRequest) (*types.QueryParamsResponse, error) {
|
|
if req == nil {
|
|
return nil, status.Error(codes.InvalidArgument, "empty request")
|
|
}
|
|
ctx := sdk.UnwrapSDKContext(c)
|
|
params := ak.GetParams(ctx)
|
|
|
|
return &types.QueryParamsResponse{Params: params}, nil
|
|
}
|