pool_calc_join_pool_shares.go

package types

import (
	"errors"

	"cosmossdk.io/math"
	sdk "github.com/cosmos/cosmos-sdk/types"
)

// calcPoolOutGivenSingleIn - balance pAo.
func (p *Pool) calcSingleAssetJoin(tokenIn sdk.Coin, spreadFactor sdk.Dec, tokenInPoolAsset PoolAsset, totalShares math.Int) (numShares math.Int, err error) {
	totalWeight := p.TotalWeight
	if totalWeight.IsZero() {
		return sdk.ZeroInt(), errors.New("pool misconfigured, total weight = 0")
	}
	normalizedWeight := sdk.NewDecFromInt(tokenInPoolAsset.Weight).Quo(sdk.NewDecFromInt(totalWeight))
	poolShares, err := calcPoolSharesOutGivenSingleAssetIn(
		sdk.NewDecFromInt(tokenInPoolAsset.Token.Amount),
		normalizedWeight,
		sdk.NewDecFromInt(totalShares),
		sdk.NewDecFromInt(tokenIn.Amount),
		spreadFactor,
	)
	if err != nil {
		return sdk.ZeroInt(), err
	}
	return poolShares.TruncateInt(), nil
}

// CalcJoinPoolShares calculates the number of shares created to join pool with the provided amount of `tokenIn`.
// The input tokens must either be:
// - a single token
// - contain exactly the same tokens as the pool contains
//
// It returns the number of shares created, the amount of coins actually joined into the pool
// (in case of not being able to fully join), or an error.
func (p *Pool) CalcSingleAssetJoinPoolShares(tokensIn sdk.Coins) (numShares math.Int, tokensJoined sdk.Coins, err error) {
	// get all 'pool assets' (aka current pool liquidity + balancer weight)
	poolAssetsByDenom, err := GetPoolAssetsByDenom(p.GetAllPoolAssets())
	if err != nil {
		return sdk.ZeroInt(), sdk.NewCoins(), err
	}

	err = EnsureDenomInPool(poolAssetsByDenom, tokensIn)
	if err != nil {
		return sdk.ZeroInt(), sdk.NewCoins(), err
	}

	// ensure that there aren't too many or too few assets in `tokensIn`
	if tokensIn.Len() != 1 {
		return sdk.ZeroInt(), sdk.NewCoins(), errors.New("pool only supports LP'ing with one asset")
	}

	// 2) Single token provided, so do single asset join and exit.
	totalShares := p.GetTotalShares()
	numShares, err = p.calcSingleAssetJoin(tokensIn[0], p.PoolParams.SwapFee, poolAssetsByDenom[tokensIn[0].Denom], totalShares.Amount)
	if err != nil {
		return sdk.ZeroInt(), sdk.NewCoins(), err
	}
	// we join all the tokens.
	tokensJoined = tokensIn
	return numShares, tokensJoined, nil
}