Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

libxc/binance: Add flags for binance live tests #3107

Open
wants to merge 1 commit into
base: master
Choose a base branch
from
Open

libxc/binance: Add flags for binance live tests #3107

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
194 changes: 140 additions & 54 deletions client/mm/libxc/binance_live_test.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -5,9 +5,10 @@ package libxc
import (
"context"
"encoding/json"
"flag"
"fmt"
"math"
"os"
"os/user"
"strings"
"sync"
"testing"
Expand All @@ -17,16 +18,48 @@ import (
_ "decred.org/dcrdex/client/asset/importall"
"decred.org/dcrdex/client/mm/libxc/bntypes"
"decred.org/dcrdex/dex"
"decred.org/dcrdex/dex/calc"
)

var (
log = dex.StdOutLogger("T", dex.LevelTrace)
u, _ = user.Current()
apiKey = ""
apiSecret = ""
binanceUS = true
net = dex.Mainnet
apiKey string
apiSecret string
baseID uint64
quoteID uint64
rate float64
qty float64
sell bool
tradeID string
assetID uint64
txID string
addr string
)

func TestMain(m *testing.M) {
var global, testnet bool
flag.BoolVar(&global, "global", false, "use Binance global")
flag.BoolVar(&testnet, "testnet", false, "use testnet")
flag.Uint64Var(&baseID, "base", ^uint64(0), "base asset ID")
flag.Uint64Var(&quoteID, "quote", ^uint64(0), "quote asset ID")
flag.Float64Var(&rate, "rate", -1, "rate")
flag.Float64Var(&qty, "qty", -1, "qty")
flag.StringVar(&tradeID, "trade", "", "trade ID")
flag.BoolVar(&sell, "sell", false, "sell")
flag.Uint64Var(&assetID, "asset", ^uint64(0), "asset ID")
flag.StringVar(&txID, "tx", "", "tx ID")
flag.StringVar(&addr, "addr", "", "address")
flag.Parse()

if global {
binanceUS = false
}
if testnet {
net = dex.Testnet
}

if s := os.Getenv("SECRET"); s != "" {
apiSecret = s
}
Expand All @@ -37,7 +70,7 @@ func TestMain(m *testing.M) {
m.Run()
}

func tNewBinance(t *testing.T, net dex.Network) *binance {
func tNewBinance() *binance {
cfg := &CEXConfig{
Net: net,
APIKey: apiKey,
Expand All @@ -47,7 +80,6 @@ func tNewBinance(t *testing.T, net dex.Network) *binance {
log.Infof("Notification sent: %+v", n)
},
}
const binanceUS = true
return newBinance(cfg, binanceUS)
}

Expand All @@ -73,33 +105,12 @@ func (drv *spoofDriver) Info() *asset.WalletInfo {
}
}

func TestConnect(t *testing.T) {
bnc := tNewBinance(t, dex.Simnet)
ctx, cancel := context.WithTimeout(context.Background(), time.Hour*23)
defer cancel()

_, err := bnc.Connect(ctx)
if err != nil {
t.Fatalf("Connect error: %v", err)
}

balance, err := bnc.Balance(60)
if err != nil {
t.Fatalf("Balance error: %v", err)
func TestPlaceTrade(t *testing.T) {
if baseID == ^uint64(0) || quoteID == ^uint64(0) || rate < 0 || qty < 0 {
t.Fatalf("baseID, quoteID, rate, or qty not set")
}
t.Logf("usdc balance: %v", balance)

balance, err = bnc.Balance(0)
if err != nil {
t.Fatalf("Balance error: %v", err)
}
t.Logf("btc balance: %v", balance)
}

// This may fail due to balance being to low. You can try switching the side
// of the trade or the qty.
func TestTrade(t *testing.T) {
bnc := tNewBinance(t, dex.Testnet)
bnc := tNewBinance()
ctx, cancel := context.WithTimeout(context.Background(), time.Hour*23)
defer cancel()
_, err := bnc.Connect(ctx)
Expand Down Expand Up @@ -131,7 +142,13 @@ func TestTrade(t *testing.T) {
}
}()

trade, err := bnc.Trade(ctx, 60, 60001, false, 3600e5, 1e7, updaterID)
baseUI, _ := asset.UnitInfo(uint32(baseID))
quoteUI, _ := asset.UnitInfo(uint32(quoteID))
msgRate := calc.MessageRate(rate, baseUI, quoteUI)
msgQty := uint64(math.Round(qty * float64(baseUI.Conventional.ConversionFactor)))

t.Logf("msgRate: %v, msgQty: %v", msgRate, msgQty)
trade, err := bnc.Trade(ctx, uint32(baseID), uint32(quoteID), false, msgRate, msgQty, updaterID)
if err != nil {
t.Fatalf("trade error: %v", err)
}
Expand All @@ -148,24 +165,29 @@ func TestTrade(t *testing.T) {
}

func TestCancelTrade(t *testing.T) {
tradeID := "42641326270691d752e000000001"
if tradeID == "" {
t.Fatalf("tradeID not set")
}
if baseID == ^uint64(0) || quoteID == ^uint64(0) {
t.Fatalf("baseID or quoteID not set")
}

bnc := tNewBinance(t, dex.Testnet)
bnc := tNewBinance()
ctx, cancel := context.WithTimeout(context.Background(), time.Hour*23)
defer cancel()
_, err := bnc.Connect(ctx)
if err != nil {
t.Fatalf("Connect error: %v", err)
}

err = bnc.CancelTrade(ctx, 60, 0, tradeID)
err = bnc.CancelTrade(ctx, uint32(baseID), uint32(quoteID), tradeID)
if err != nil {
t.Fatalf("error cancelling trade: %v", err)
}
}

func TestMatchedMarkets(t *testing.T) {
bnc := tNewBinance(t, dex.Mainnet)
bnc := tNewBinance()
ctx, cancel := context.WithTimeout(context.Background(), time.Hour*23)
defer cancel()

Expand All @@ -185,7 +207,7 @@ func TestMatchedMarkets(t *testing.T) {
}

func TestVWAP(t *testing.T) {
bnc := tNewBinance(t, dex.Mainnet)
bnc := tNewBinance()
ctx, cancel := context.WithTimeout(context.Background(), time.Hour*23)
defer cancel()
_, err := bnc.Connect(ctx)
Expand Down Expand Up @@ -250,15 +272,19 @@ func TestVWAP(t *testing.T) {
}

func TestSubscribeMarket(t *testing.T) {
bnc := tNewBinance(t, dex.Testnet)
if baseID == ^uint64(0) || quoteID == ^uint64(0) {
t.Fatalf("baseID or quoteID not set")
}

bnc := tNewBinance()
ctx, cancel := context.WithTimeout(context.Background(), time.Hour*23)
defer cancel()
wg, err := bnc.Connect(ctx)
if err != nil {
t.Fatalf("Connect error: %v", err)
}

err = bnc.SubscribeMarket(ctx, 60, 0)
err = bnc.SubscribeMarket(ctx, uint32(baseID), uint32(quoteID))
if err != nil {
t.Fatalf("failed to subscribe to market: %v", err)
}
Expand All @@ -267,7 +293,17 @@ func TestSubscribeMarket(t *testing.T) {
}

func TestWithdrawal(t *testing.T) {
bnc := tNewBinance(t, dex.Mainnet)
if assetID == ^uint64(0) {
t.Fatalf("assetID not set")
}
if qty < 0 {
t.Fatalf("qty not set")
}
if addr == "" {
t.Fatalf("addr not set")
}

bnc := tNewBinance()
ctx, cancel := context.WithTimeout(context.Background(), time.Hour*23)
defer cancel()

Expand All @@ -276,7 +312,11 @@ func TestWithdrawal(t *testing.T) {
t.Fatalf("Connect error: %v", err)
}

withdrawalID, err := bnc.Withdraw(ctx, 966, 2e10, "")
ui, _ := asset.UnitInfo(uint32(assetID))
msgQty := uint64(math.Round(qty * float64(ui.Conventional.ConversionFactor)))

t.Logf("msgQty: %v", msgQty)
withdrawalID, err := bnc.Withdraw(ctx, uint32(assetID), msgQty, addr)
if err != nil {
fmt.Printf("withdrawal error: %v", err)
return
Expand All @@ -286,7 +326,14 @@ func TestWithdrawal(t *testing.T) {
}

func TestConfirmDeposit(t *testing.T) {
bnc := tNewBinance(t, dex.Mainnet)
if assetID == ^uint64(0) {
t.Fatalf("assetID not set")
}
if txID == "" {
t.Fatalf("txID not set")
}

bnc := tNewBinance()
ctx, cancel := context.WithTimeout(context.Background(), time.Hour*23)
defer cancel()

Expand All @@ -295,12 +342,20 @@ func TestConfirmDeposit(t *testing.T) {
t.Fatalf("Connect error: %v", err)
}

confirmed, amt := bnc.ConfirmDeposit(ctx, &DepositData{})
t.Logf("confirmed: %v, amt: %v", confirmed, amt)
confirmed, amt := bnc.ConfirmDeposit(ctx, &DepositData{
AssetID: uint32(assetID),
TxID: txID,
})

t.Logf("Confirmed: %v, Amt: %v", confirmed, amt)
}

func TestGetDepositAddress(t *testing.T) {
bnc := tNewBinance(t, dex.Mainnet)
if assetID == ^uint64(0) {
t.Fatalf("assetID not set")
}

bnc := tNewBinance()
ctx, cancel := context.WithTimeout(context.Background(), time.Hour*23)
defer cancel()

Expand All @@ -309,16 +364,20 @@ func TestGetDepositAddress(t *testing.T) {
t.Fatalf("Connect error: %v", err)
}

addr, err := bnc.GetDepositAddress(ctx, 966)
addr, err := bnc.GetDepositAddress(ctx, uint32(assetID))
if err != nil {
t.Fatalf("getDepositAddress error: %v", err)
}

t.Logf("deposit address: %v", addr)
t.Logf("Deposit Address: %v", addr)
}

func TestBalances(t *testing.T) {
bnc := tNewBinance(t, dex.Testnet)
func TestBalanceIndividually(t *testing.T) {
if assetID == ^uint64(0) {
t.Fatalf("assetID not set")
}

bnc := tNewBinance()
ctx, cancel := context.WithTimeout(context.Background(), time.Hour*23)
defer cancel()

Expand All @@ -327,16 +386,36 @@ func TestBalances(t *testing.T) {
t.Fatalf("Connect error: %v", err)
}

balance, err := bnc.Balance(0)
balance, err := bnc.Balance(uint32(assetID))
if err != nil {
t.Fatalf("balances error: %v", err)
}

t.Logf("%+v", balance)
}

func TestBalances(t *testing.T) {
bnc := tNewBinance()
ctx, cancel := context.WithTimeout(context.Background(), time.Hour*23)
defer cancel()

_, err := bnc.Connect(ctx)
if err != nil {
t.Fatalf("Connect error: %v", err)
}

balances, err := bnc.Balances(ctx)
if err != nil {
t.Fatalf("balances error: %v", err)
}

for assetID, b := range balances {
t.Logf("%s: %+v", dex.BipIDSymbol(assetID), b)
}
}

func TestGetCoinInfo(t *testing.T) {
bnc := tNewBinance(t, dex.Mainnet)
bnc := tNewBinance()
ctx, cancel := context.WithTimeout(context.Background(), time.Hour*23)
defer cancel()

Expand Down Expand Up @@ -371,7 +450,14 @@ func TestGetCoinInfo(t *testing.T) {
}

func TestTradeStatus(t *testing.T) {
bnc := tNewBinance(t, dex.Testnet)
if tradeID == "" {
t.Fatalf("tradeID not set")
}
if baseID == ^uint64(0) || quoteID == ^uint64(0) {
t.Fatalf("baseID or quoteID not set")
}

bnc := tNewBinance()
ctx, cancel := context.WithTimeout(context.Background(), time.Hour*23)
defer cancel()

Expand All @@ -380,7 +466,7 @@ func TestTradeStatus(t *testing.T) {
t.Fatalf("Connect error: %v", err)
}

trade, err := bnc.TradeStatus(ctx, "eb6b6e1177213643142700000001", 60, 60001)
trade, err := bnc.TradeStatus(ctx, tradeID, uint32(baseID), uint32(quoteID))
if err != nil {
t.Fatalf("trade status error: %v", err)
}
Expand All @@ -390,7 +476,7 @@ func TestTradeStatus(t *testing.T) {

func TestMarkets(t *testing.T) {
// Need keys for getCoinInfo
bnc := tNewBinance(t, dex.Testnet)
bnc := tNewBinance()
ctx, cancel := context.WithTimeout(context.Background(), time.Hour*23)
defer cancel()

Expand Down
Loading