Method AddLiquidity

x/clp/keeper/msg_server.go:647–772

(goCtx context.Context, msg *types.MsgAddLiquidity)

}

func (k msgServer) AddLiquidity(goCtx context.Context, msg *types.MsgAddLiquidity) (*types.MsgAddLiquidityResponse, error) {
	ctx := sdk.UnwrapSDKContext(goCtx)
	registry := k.tokenRegistryKeeper.GetRegistry(ctx)

	nAsset, err := k.tokenRegistryKeeper.GetEntry(registry, types.NativeSymbol)
	if err != nil {
		return nil, types.ErrTokenNotSupported
	}

	eAsset, err := k.tokenRegistryKeeper.GetEntry(registry, msg.ExternalAsset.Symbol)
	if err != nil {
		return nil, types.ErrTokenNotSupported
	}

	if !k.tokenRegistryKeeper.CheckEntryPermissions(eAsset, []tokenregistrytypes.Permission{tokenregistrytypes.Permission_CLP}) {
		return nil, tokenregistrytypes.ErrPermissionDenied
	}

	pool, err := k.Keeper.GetPool(ctx, msg.ExternalAsset.Symbol)
	if err != nil {
		return nil, types.ErrPoolDoesNotExist
	}

	pmtpCurrentRunningRate := k.GetPmtpRateParams(ctx).PmtpCurrentRunningRate
	sellNativeSwapFeeRate := k.GetSwapFeeRate(ctx, types.GetSettlementAsset(), false)
	buyNativeSwapFeeRate := k.GetSwapFeeRate(ctx, *msg.ExternalAsset, false)

	nativeAssetDepth, externalAssetDepth := pool.ExtractDebt(pool.NativeAssetBalance, pool.ExternalAssetBalance, false)

	newPoolUnits, lpUnits, swapStatus, swapAmount, err := CalculatePoolUnits(
		pool.PoolUnits,
		nativeAssetDepth,
		externalAssetDepth,
		msg.NativeAssetAmount,
		msg.ExternalAssetAmount,
		sellNativeSwapFeeRate,
		buyNativeSwapFeeRate,
		pmtpCurrentRunningRate)
	if err != nil {
		return nil, err
	}

	switch swapStatus {
	case NoSwap:
		// do nothing
	case SellNative:
		// check sell permission for native
		if k.tokenRegistryKeeper.CheckEntryPermissions(nAsset, []tokenregistrytypes.Permission{tokenregistrytypes.Permission_DISABLE_SELL}) {
			return nil, tokenregistrytypes.ErrNotAllowedToSellAsset
		}
		// check buy permission for external
		if k.tokenRegistryKeeper.CheckEntryPermissions(eAsset, []tokenregistrytypes.Permission{tokenregistrytypes.Permission_DISABLE_BUY}) {
			return nil, tokenregistrytypes.ErrNotAllowedToBuyAsset
		}

		if k.GetLiquidityProtectionParams(ctx).IsActive {
			price, err := k.GetNativePrice(ctx)
			if err != nil {