cosmos-sdk/x/staking/keeper/pool.go

79 lines
2.8 KiB
Go
Raw Normal View History

2019-06-28 13:11:27 -07:00
package keeper
import (
sdk "github.com/cosmos/cosmos-sdk/types"
authtypes "github.com/cosmos/cosmos-sdk/x/auth/types"
2019-06-28 13:11:27 -07:00
"github.com/cosmos/cosmos-sdk/x/staking/types"
)
// GetBondedPool returns the bonded tokens pool's module account
func (k Keeper) GetBondedPool(ctx sdk.Context) (bondedPool authtypes.ModuleAccountI) {
return k.authKeeper.GetModuleAccount(ctx, types.BondedPoolName)
2019-06-28 13:11:27 -07:00
}
// GetNotBondedPool returns the not bonded tokens pool's module account
func (k Keeper) GetNotBondedPool(ctx sdk.Context) (notBondedPool authtypes.ModuleAccountI) {
return k.authKeeper.GetModuleAccount(ctx, types.NotBondedPoolName)
2019-06-28 13:11:27 -07:00
}
// bondedTokensToNotBonded transfers coins from the bonded to the not bonded pool within staking
func (k Keeper) bondedTokensToNotBonded(ctx sdk.Context, tokens sdk.Int) {
coins := sdk.NewCoins(sdk.NewCoin(k.BondDenom(ctx), tokens))
if err := k.bankKeeper.SendCoinsFromModuleToModule(ctx, types.BondedPoolName, types.NotBondedPoolName, coins); err != nil {
2019-06-28 13:11:27 -07:00
panic(err)
}
}
// notBondedTokensToBonded transfers coins from the not bonded to the bonded pool within staking
func (k Keeper) notBondedTokensToBonded(ctx sdk.Context, tokens sdk.Int) {
coins := sdk.NewCoins(sdk.NewCoin(k.BondDenom(ctx), tokens))
if err := k.bankKeeper.SendCoinsFromModuleToModule(ctx, types.NotBondedPoolName, types.BondedPoolName, coins); err != nil {
2019-06-28 13:11:27 -07:00
panic(err)
}
}
// burnBondedTokens removes coins from the bonded pool module account
func (k Keeper) burnBondedTokens(ctx sdk.Context, amt sdk.Int) error {
2019-06-28 13:11:27 -07:00
if !amt.IsPositive() {
// skip as no coins need to be burned
2019-06-28 13:11:27 -07:00
return nil
}
2019-06-28 13:11:27 -07:00
coins := sdk.NewCoins(sdk.NewCoin(k.BondDenom(ctx), amt))
return k.bankKeeper.BurnCoins(ctx, types.BondedPoolName, coins)
2019-06-28 13:11:27 -07:00
}
// burnNotBondedTokens removes coins from the not bonded pool module account
func (k Keeper) burnNotBondedTokens(ctx sdk.Context, amt sdk.Int) error {
2019-06-28 13:11:27 -07:00
if !amt.IsPositive() {
// skip as no coins need to be burned
2019-06-28 13:11:27 -07:00
return nil
}
2019-06-28 13:11:27 -07:00
coins := sdk.NewCoins(sdk.NewCoin(k.BondDenom(ctx), amt))
return k.bankKeeper.BurnCoins(ctx, types.NotBondedPoolName, coins)
2019-06-28 13:11:27 -07:00
}
// TotalBondedTokens total staking tokens supply which is bonded
func (k Keeper) TotalBondedTokens(ctx sdk.Context) sdk.Int {
bondedPool := k.GetBondedPool(ctx)
2020-01-30 13:31:16 -08:00
return k.bankKeeper.GetBalance(ctx, bondedPool.GetAddress(), k.BondDenom(ctx)).Amount
2019-06-28 13:11:27 -07:00
}
// StakingTokenSupply staking tokens from the total supply
func (k Keeper) StakingTokenSupply(ctx sdk.Context) sdk.Int {
return k.bankKeeper.GetSupply(ctx, k.BondDenom(ctx)).Amount
2019-06-28 13:11:27 -07:00
}
// BondedRatio the fraction of the staking tokens which are currently bonded
func (k Keeper) BondedRatio(ctx sdk.Context) sdk.Dec {
stakeSupply := k.StakingTokenSupply(ctx)
if stakeSupply.IsPositive() {
2020-01-30 13:31:16 -08:00
return k.TotalBondedTokens(ctx).ToDec().QuoInt(stakeSupply)
2019-06-28 13:11:27 -07:00
}
2020-01-30 13:31:16 -08:00
2019-06-28 13:11:27 -07:00
return sdk.ZeroDec()
}