BEP70 - Support busd pair listing and trading

.gitignore

@@ -20,3 +20,9 @@ vendor
 *.swp
 .vscode/*.json
 
+# Test generate tmp files
+app/data
+app/apptest/data
+app_test/data
+plugins/param/data
+plugins/tokens/data

app/app.go

@@ -95,6 +95,8 @@ type BinanceChain struct {
 	publicationConfig  *config.PublicationConfig
 	publisher          pub.MarketDataPublisher
 
+	dexConfig *config.DexConfig
+
 	// Unlike tendermint, we don't need implement a no-op metrics, usage of this field should
 	// check nil-ness to know whether metrics collection is turn on
 	// TODO(#246): make it an aggregated wrapper of all component metrics (i.e. DexKeeper, StakeKeeper)
@@ -119,6 +121,7 @@ func NewBinanceChain(logger log.Logger, db dbm.DB, traceStore io.Writer, baseApp
 		upgradeConfig:      ServerContext.UpgradeConfig,
 		abciQueryBlackList: getABCIQueryBlackList(ServerContext.QueryConfig),
 		publicationConfig:  ServerContext.PublicationConfig,
+		dexConfig:          ServerContext.DexConfig,
 	}
 	// set upgrade config
 	SetUpgradeConfig(app.upgradeConfig)
@@ -263,6 +266,7 @@ func SetUpgradeConfig(upgradeConfig *config.UpgradeConfig) {
 	upgrade.Mgr.AddUpgradeHeight(upgrade.LotSizeOptimization, upgradeConfig.LotSizeUpgradeHeight)
 	upgrade.Mgr.AddUpgradeHeight(upgrade.ListingRuleUpgrade, upgradeConfig.ListingRuleUpgradeHeight)
 	upgrade.Mgr.AddUpgradeHeight(upgrade.FixZeroBalance, upgradeConfig.FixZeroBalanceHeight)
+	upgrade.Mgr.AddUpgradeHeight(upgrade.BEP_BUSD, upgradeConfig.BEP_BUSDHeight)
 
 	// register store keys of upgrade
 	upgrade.Mgr.RegisterStoreKeys(upgrade.BEP9, common.TimeLockStoreKey.Name())
@@ -302,7 +306,8 @@ func (app *BinanceChain) initRunningMode() {
 
 func (app *BinanceChain) initDex(pairMapper dex.TradingPairMapper) {
 	app.DexKeeper = dex.NewOrderKeeper(common.DexStoreKey, app.AccountKeeper, pairMapper,
-		app.RegisterCodespace(dex.DefaultCodespace), app.baseConfig.OrderKeeperConcurrency, app.Codec,
+		app.RegisterCodespace(dex.DefaultCodespace), app.baseConfig.OrderKeeperConcurrency,
+		app.dexConfig.BUSDSymbol, app.Codec,
 		app.publicationConfig.ShouldPublishAny())
 	app.DexKeeper.SubscribeParamChange(app.ParamHub)
 

app/config/config.go

@@ -67,6 +67,8 @@ LotSizeUpgradeHeight = {{ .UpgradeConfig.LotSizeUpgradeHeight }}
 ListingRuleUpgradeHeight = {{ .UpgradeConfig.ListingRuleUpgradeHeight }}
 # Block height of FixZeroBalanceHeight upgrade
 FixZeroBalanceHeight = {{ .UpgradeConfig.FixZeroBalanceHeight }}
+# Block height to BEP_BUSD upgrade
+BEP_BUSDHeight = {{ .UpgradeConfig.BEP_BUSDHeight }}
 
 [query]
 # ABCI query interface black list, suggested value: ["custom/gov/proposals", "custom/timelock/timelocks", "custom/atomicSwap/swapcreator", "custom/atomicSwap/swaprecipient"]
@@ -152,6 +154,10 @@ logFileRoot = "{{ .LogConfig.LogFileRoot }}"
 logFilePath = "{{ .LogConfig.LogFilePath }}"
 # Number of logs keep in memory before writing to file
 logBuffSize = {{ .LogConfig.LogBuffSize }}
+
+[dex]
+# The suffixed symbol of BUSD
+BUSDSymbol = "{{ .DexConfig.BUSDSymbol }}"
 `
 
 type BinanceChainContext struct {
@@ -178,6 +184,7 @@ type BinanceChainConfig struct {
 	*BaseConfig        `mapstructure:"base"`
 	*UpgradeConfig     `mapstructure:"upgrade"`
 	*QueryConfig       `mapstructure:"query"`
+	*DexConfig         `mapstructure:"dex"`
 }
 
 func DefaultBinanceChainConfig() *BinanceChainConfig {
@@ -188,6 +195,7 @@ func DefaultBinanceChainConfig() *BinanceChainConfig {
 		BaseConfig:        defaultBaseConfig(),
 		UpgradeConfig:     defaultUpgradeConfig(),
 		QueryConfig:       defaultQueryConfig(),
+		DexConfig:         defaultGovConfig(),
 	}
 }
 
@@ -358,7 +366,9 @@ type UpgradeConfig struct {
 	// Hubble Upgrade
 	BEP12Height int64 `mapstructure:"BEP12Height"`
 	// Archimedes Upgrade
-	BEP3Height int64 `mapstructure:"BEP3Height"`
+	BEP3Height     int64 `mapstructure:"BEP3Height"`
+	BEP_BUSDHeight int64 `mapstructure:"BEP_BUSDHeight"`
+
 	// TODO: add upgrade name
 	FixSignBytesOverflowHeight int64 `mapstructure:"FixSignBytesOverflowHeight"`
 	LotSizeUpgradeHeight       int64 `mapstructure:"LotSizeUpgradeHeight"`
@@ -375,6 +385,7 @@ func defaultUpgradeConfig() *UpgradeConfig {
 		BEP19Height:                1,
 		BEP12Height:                1,
 		BEP3Height:                 1,
+		BEP_BUSDHeight:             1,
 		FixSignBytesOverflowHeight: math.MaxInt64,
 		LotSizeUpgradeHeight:       math.MaxInt64,
 		ListingRuleUpgradeHeight:   math.MaxInt64,
@@ -392,6 +403,16 @@ func defaultQueryConfig() *QueryConfig {
 	}
 }
 
+type DexConfig struct {
+	BUSDSymbol string `mapstructure:"BUSDSymbol"`
+}
+
+func defaultGovConfig() *DexConfig {
+	return &DexConfig{
+		BUSDSymbol: "",
+	}
+}
+
 func (context *BinanceChainContext) ParseAppConfigInPlace() error {
 	// this piece of code should be consistent with bindFlagsLoadViper
 	// vendor/github.com/tendermint/tendermint/libs/cli/setup.go:125

app/pub/keeper_pub_test.go

@@ -61,7 +61,7 @@ func setupKeeperTest(t *testing.T) (*assert.Assertions, *require.Assertions) {
 	ctx = sdk.NewContext(ms, abci.Header{ChainID: "mychainid"}, sdk.RunTxModeDeliver, logger).WithAccountCache(accountCache)
 
 	pairMapper := store.NewTradingPairMapper(cdc, common.PairStoreKey)
-	keeper = orderPkg.NewKeeper(capKey2, am, pairMapper, sdk.NewCodespacer().RegisterNext(dextypes.DefaultCodespace), 2, cdc, true)
+	keeper = orderPkg.NewKeeper(capKey2, am, pairMapper, sdk.NewCodespacer().RegisterNext(dextypes.DefaultCodespace), 2, "", cdc, true)
 	tradingPair := dextypes.NewTradingPair("XYZ-000", types.NativeTokenSymbol, 1e8)
 	keeper.PairMapper.AddTradingPair(ctx, tradingPair)
 	keeper.AddEngine(tradingPair)

common/upgrade/upgrade.go

@@ -17,6 +17,9 @@ const (
 	BEP12 = "BEP12" // https://github.com/binance-chain/BEPs/pull/17
 	// Archimedes Upgrade
 	BEP3 = "BEP3" // https://github.com/binance-chain/BEPs/pull/30
+	//TODO: change the correct BEP number
+	BEP_BUSD = "BEP_BUSD" // supporting listing and trading BUSD pairs
+
 	// TODO: add upgrade name
 	FixSignBytesOverflow = sdk.FixSignBytesOverflow
 	LotSizeOptimization  = "LotSizeOptimization"

plugins/dex/list/handler_test.go

@@ -66,7 +66,7 @@ func MakeKeepers(cdc *codec.Codec) (ms sdkStore.CommitMultiStore, orderKeeper *o
 	codespacer := sdk.NewCodespacer()
 	pairMapper := store.NewTradingPairMapper(cdc, pairKey)
 	orderKeeper = order.NewKeeper(common.DexStoreKey, accKeeper, pairMapper,
-		codespacer.RegisterNext(dexTypes.DefaultCodespace), 2, cdc, false)
+		codespacer.RegisterNext(dexTypes.DefaultCodespace), 2, "", cdc, false)
 
 	tokenMapper = tokenStore.NewMapper(cdc, tokenKey)
 

plugins/dex/order/fee.go

@@ -6,6 +6,8 @@ import (
 	"math"
 	"math/big"
 
+	"github.com/binance-chain/node/common/upgrade"
+
 	sdk "github.com/cosmos/cosmos-sdk/types"
 
 	tmlog "github.com/tendermint/tendermint/libs/log"
@@ -42,16 +44,18 @@ var (
 )
 
 type FeeManager struct {
-	cdc       *wire.Codec
-	logger    tmlog.Logger
-	FeeConfig FeeConfig
+	cdc        *wire.Codec
+	logger     tmlog.Logger
+	FeeConfig  FeeConfig
+	BUSDSymbol string
 }
 
-func NewFeeManager(cdc *wire.Codec, storeKey sdk.StoreKey, logger tmlog.Logger) *FeeManager {
+func NewFeeManager(cdc *wire.Codec, storeKey sdk.StoreKey, busdSymbol string, logger tmlog.Logger) *FeeManager {
 	return &FeeManager{
-		cdc:       cdc,
-		logger:    logger,
-		FeeConfig: NewFeeConfig(),
+		cdc:        cdc,
+		logger:     logger,
+		FeeConfig:  NewFeeConfig(),
+		BUSDSymbol: busdSymbol,
 	}
 }
 
@@ -134,7 +138,7 @@ func (m *FeeManager) calcTradeFeeForSingleTransfer(balances sdk.Coins, tran *Tra
 }
 
 func (m *FeeManager) calcNativeFee(inSymbol string, inQty int64, engines map[string]*matcheng.MatchEng) (fee int64, isOverflow bool) {
-	var nativeNotional *big.Int
+	var nativeNotional = big.NewInt(0)
 	if isNativeToken(inSymbol) {
 		nativeNotional = big.NewInt(inQty)
 	} else {
@@ -143,15 +147,44 @@ func (m *FeeManager) calcNativeFee(inSymbol string, inQty int64, engines map[str
 		if engine, ok := engines[utils.Assets2TradingPair(inSymbol, types.NativeTokenSymbol)]; ok {
 			// XYZ_BNB
 			nativeNotional = utils.CalBigNotional(engine.LastTradePrice, inQty)
-		} else {
+		} else if engine, ok := engines[utils.Assets2TradingPair(types.NativeTokenSymbol, inSymbol)]; ok {
 			// BNB_XYZ
-			engine := engines[utils.Assets2TradingPair(types.NativeTokenSymbol, inSymbol)]
 			var amount big.Int
 			nativeNotional = amount.Div(
 				amount.Mul(
 					big.NewInt(inQty),
 					big.NewInt(cmnUtils.Fixed8One.ToInt64())),
 				big.NewInt(engine.LastTradePrice))
+		} else {
+			// for BUSD pairs, it is possible that there is no trading pair between BNB and inAsset, e.g., BUSD -> XYZ
+			if sdk.IsUpgrade(upgrade.BEP_BUSD) {
+				var intermediateAmount = big.NewInt(0)
+				if market, ok := engines[utils.Assets2TradingPair(m.BUSDSymbol, inSymbol)]; ok {
+					var tmp big.Int
+					intermediateAmount = tmp.Div(tmp.Mul(
+						big.NewInt(inQty),
+						big.NewInt(cmnUtils.Fixed8One.ToInt64())),
+						big.NewInt(market.LastTradePrice))
+				} else if market, ok := engines[utils.Assets2TradingPair(inSymbol, m.BUSDSymbol)]; ok {
+					intermediateAmount = utils.CalBigNotional(market.LastTradePrice, inQty)
+				}
+
+				var intermediateAmountTmp int64
+				if intermediateAmount.IsInt64() {
+					intermediateAmountTmp = intermediateAmount.Int64()
+				} else {
+					intermediateAmountTmp = math.MaxInt64
+				}
+				if market, ok := engines[utils.Assets2TradingPair(types.NativeTokenSymbol, m.BUSDSymbol)]; ok {
+					var tmp big.Int
+					nativeNotional = tmp.Div(tmp.Mul(
+						big.NewInt(intermediateAmountTmp),
+						big.NewInt(cmnUtils.Fixed8One.ToInt64())),
+						big.NewInt(market.LastTradePrice))
+				} else if market, ok := engines[utils.Assets2TradingPair(m.BUSDSymbol, types.NativeTokenSymbol)]; ok {
+					nativeNotional = utils.CalBigNotional(market.LastTradePrice, intermediateAmountTmp)
+				}
+			}
 		}
 	}
 
@@ -238,18 +271,47 @@ func (m *FeeManager) CalcFixedFee(balances sdk.Coins, eventType transferEventTyp
 	} else {
 		// the amount may overflow int64, so use big.Int instead.
 		// TODO: (perf) may remove the big.Int use to improve the performance
-		var amount *big.Int
+		var amount = big.NewInt(0)
 		if market, ok := engines[utils.Assets2TradingPair(inAsset, types.NativeTokenSymbol)]; ok {
 			// XYZ_BNB
 			var tmp big.Int
 			amount = tmp.Div(tmp.Mul(
 				big.NewInt(feeAmount),
 				big.NewInt(cmnUtils.Fixed8One.ToInt64())),
 				big.NewInt(market.LastTradePrice))
-		} else {
+		} else if market, ok := engines[utils.Assets2TradingPair(types.NativeTokenSymbol, inAsset)]; ok {
 			// BNB_XYZ
-			market = engines[utils.Assets2TradingPair(types.NativeTokenSymbol, inAsset)]
 			amount = utils.CalBigNotional(market.LastTradePrice, feeAmount)
+		} else {
+			// for BUSD pairs, it is possible that there is no trading pair between BNB and inAsset, e.g., BUSD -> XYZ
+			if sdk.IsUpgrade(upgrade.BEP_BUSD) {
+				var intermediateAmount = big.NewInt(0)
+				if market, ok := engines[utils.Assets2TradingPair(m.BUSDSymbol, types.NativeTokenSymbol)]; ok {
+					var tmp big.Int
+					intermediateAmount = tmp.Div(tmp.Mul(
+						big.NewInt(feeAmount),
+						big.NewInt(cmnUtils.Fixed8One.ToInt64())),
+						big.NewInt(market.LastTradePrice))
+				} else if market, ok := engines[utils.Assets2TradingPair(types.NativeTokenSymbol, m.BUSDSymbol)]; ok {
+					intermediateAmount = utils.CalBigNotional(market.LastTradePrice, feeAmount)
+				}
+
+				var intermediateAmountTmp int64
+				if intermediateAmount.IsInt64() {
+					intermediateAmountTmp = intermediateAmount.Int64()
+				} else {
+					intermediateAmountTmp = math.MaxInt64
+				}
+				if market, ok := engines[utils.Assets2TradingPair(inAsset, m.BUSDSymbol)]; ok {
+					var tmp big.Int
+					amount = tmp.Div(tmp.Mul(
+						big.NewInt(intermediateAmountTmp),
+						big.NewInt(cmnUtils.Fixed8One.ToInt64())),
+						big.NewInt(market.LastTradePrice))
+				} else if market, ok := engines[utils.Assets2TradingPair(m.BUSDSymbol, inAsset)]; ok {
+					amount = utils.CalBigNotional(market.LastTradePrice, intermediateAmountTmp)
+				}
+			}
 		}
 
 		if amount.IsInt64() {