mirror of
https://github.com/0glabs/0g-chain.git
synced 2024-12-26 08:15:19 +00:00
e2f515ba9e
* query auction by lot owner * add SavingsRateDistributed to store * v2cdps: filtered cdps query * update v2cdps cli examples * add savings rate dist counter to begin blocker * implement savings rate dist cli query * implement cdp REST queries * minor auction CLI/REST updates * fix auction querier bug * update REST endpoint to 'cdps' * update to savings-rate-dist * update SavingsRateDistributed get/set * update tests * fix savings rate dist rounding errors * 'collateralDenom' -> 'collateralType' * refactor 'v2cdps' -> 'cdps', add ratio param * fix augmented CDP type, msg string() method * fix cdp querier test * filter query results efficiently * querier tests * limit type iteration if owner defined * improve savings rate dist genesis validation * default sdk.Dec{} to sdk.ZeroDec in queries * update condition logic for finding intersection * fix cdp querier filtering * Update kava-4 swagger (#653) * add collateral_type, update cdp params * savings rate, auctions, get cdps * drop owner from AuctionResponse * remove duplicate collateral denom * update query paths with {collateral-type}
123 lines
3.5 KiB
Go
123 lines
3.5 KiB
Go
package keeper
|
|
|
|
import (
|
|
"fmt"
|
|
|
|
sdk "github.com/cosmos/cosmos-sdk/types"
|
|
|
|
"github.com/kava-labs/kava/x/cdp/types"
|
|
)
|
|
|
|
// GetParams returns the params from the store
|
|
func (k Keeper) GetParams(ctx sdk.Context) types.Params {
|
|
var p types.Params
|
|
k.paramSubspace.GetParamSet(ctx, &p)
|
|
return p
|
|
}
|
|
|
|
// SetParams sets params on the store
|
|
func (k Keeper) SetParams(ctx sdk.Context, params types.Params) {
|
|
k.paramSubspace.SetParamSet(ctx, ¶ms)
|
|
}
|
|
|
|
// GetCollateral returns the collateral param with corresponding denom
|
|
func (k Keeper) GetCollateral(ctx sdk.Context, collateralType string) (types.CollateralParam, bool) {
|
|
params := k.GetParams(ctx)
|
|
for _, cp := range params.CollateralParams {
|
|
if cp.Type == collateralType {
|
|
return cp, true
|
|
}
|
|
}
|
|
return types.CollateralParam{}, false
|
|
}
|
|
|
|
// GetCollateralTypes returns an array of collateral types
|
|
func (k Keeper) GetCollateralTypes(ctx sdk.Context) []string {
|
|
params := k.GetParams(ctx)
|
|
var denoms []string
|
|
for _, cp := range params.CollateralParams {
|
|
denoms = append(denoms, cp.Type)
|
|
}
|
|
return denoms
|
|
}
|
|
|
|
// GetDebtParam returns the debt param with matching denom
|
|
func (k Keeper) GetDebtParam(ctx sdk.Context, denom string) (types.DebtParam, bool) {
|
|
dp := k.GetParams(ctx).DebtParam
|
|
if dp.Denom == denom {
|
|
return dp, true
|
|
}
|
|
return types.DebtParam{}, false
|
|
}
|
|
|
|
// GetCollateralTypePrefix returns the prefix of the matching denom
|
|
func (k Keeper) GetCollateralTypePrefix(ctx sdk.Context, collateralType string) (byte, bool) {
|
|
params := k.GetParams(ctx)
|
|
for _, cp := range params.CollateralParams {
|
|
if cp.Type == collateralType {
|
|
return cp.Prefix, true
|
|
}
|
|
}
|
|
return 0x00, false
|
|
}
|
|
|
|
// private methods assume collateral has been validated, panic if the input is invalid
|
|
func (k Keeper) getDenomFromByte(ctx sdk.Context, db byte) string {
|
|
params := k.GetParams(ctx)
|
|
for _, cp := range params.CollateralParams {
|
|
if cp.Prefix == db {
|
|
return cp.Denom
|
|
}
|
|
}
|
|
panic(fmt.Sprintf("no collateral denom with prefix %b", db))
|
|
}
|
|
|
|
func (k Keeper) getSpotMarketID(ctx sdk.Context, collateralType string) string {
|
|
cp, found := k.GetCollateral(ctx, collateralType)
|
|
if !found {
|
|
panic(fmt.Sprintf("collateral not found: %s", collateralType))
|
|
}
|
|
return cp.SpotMarketID
|
|
}
|
|
|
|
func (k Keeper) getliquidationMarketID(ctx sdk.Context, collateralType string) string {
|
|
cp, found := k.GetCollateral(ctx, collateralType)
|
|
if !found {
|
|
panic(fmt.Sprintf("collateral not found: %s", collateralType))
|
|
}
|
|
return cp.LiquidationMarketID
|
|
}
|
|
|
|
func (k Keeper) getLiquidationRatio(ctx sdk.Context, collateralType string) sdk.Dec {
|
|
cp, found := k.GetCollateral(ctx, collateralType)
|
|
if !found {
|
|
panic(fmt.Sprintf("collateral not found: %s", collateralType))
|
|
}
|
|
return cp.LiquidationRatio
|
|
}
|
|
|
|
func (k Keeper) getLiquidationPenalty(ctx sdk.Context, collateralType string) sdk.Dec {
|
|
cp, found := k.GetCollateral(ctx, collateralType)
|
|
if !found {
|
|
panic(fmt.Sprintf("collateral not found: %s", collateralType))
|
|
}
|
|
return cp.LiquidationPenalty
|
|
}
|
|
|
|
func (k Keeper) getAuctionSize(ctx sdk.Context, collateralType string) sdk.Int {
|
|
cp, found := k.GetCollateral(ctx, collateralType)
|
|
if !found {
|
|
panic(fmt.Sprintf("collateral not found: %s", collateralType))
|
|
}
|
|
return cp.AuctionSize
|
|
}
|
|
|
|
// GetFeeRate returns the per second fee rate for the input denom
|
|
func (k Keeper) getFeeRate(ctx sdk.Context, collateralType string) (fee sdk.Dec) {
|
|
collalateralParam, found := k.GetCollateral(ctx, collateralType)
|
|
if !found {
|
|
panic(fmt.Sprintf("could not get fee rate for %s, collateral not found", collateralType))
|
|
}
|
|
return collalateralParam.StabilityFee
|
|
}
|