lychiyu/bbgo_origin
1
0
Fork 0
mirror of https://github.com/c9s/bbgo.git synced 2024-09-20 08:11:08 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix withdraw state check

Browse Source
This commit is contained in:
c9s 2021-05-11 23:42:49 +08:00
parent 4d24a96778
commit 41163346ea
1 changed files with 19 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
examples/max-withdraw/main.go
View File

@ -11,6 +11,8 @@ import (
) )
func waitWithdrawalsComplete(ctx context.Context, client *maxapi.RestClient, currency string, limit int) error { func waitWithdrawalsComplete(ctx context.Context, client *maxapi.RestClient, currency string, limit int) error {
var lastState string
for {
withdrawals, err := client.WithdrawalService.NewGetWithdrawalHistoryRequest(). withdrawals, err := client.WithdrawalService.NewGetWithdrawalHistoryRequest().
Currency(currency). Currency(currency).
Limit(limit). Limit(limit).
@ -19,12 +21,14 @@ func waitWithdrawalsComplete(ctx context.Context, client *maxapi.RestClient, cur
return err return err
} }
var lastState string
for {
pending := false pending := false
for _, withdrawal := range withdrawals { for _, withdrawal := range withdrawals {
if withdrawal.State != lastState { if lastState == "" {
log.Printf("-> %s", withdrawal.State)
} else if withdrawal.State != lastState {
log.Printf("%s -> %s", lastState, withdrawal.State) log.Printf("%s -> %s", lastState, withdrawal.State)
log.Printf("withdrawal %s %s: %s", withdrawal.Amount, withdrawal.Currency, withdrawal.State)
log.Printf("\t%+v", withdrawal)
} }
lastState = withdrawal.State lastState = withdrawal.State
@ -32,13 +36,14 @@ func waitWithdrawalsComplete(ctx context.Context, client *maxapi.RestClient, cur
case "submitting", "submitted", "pending", "processing", "approved": case "submitting", "submitted", "pending", "processing", "approved":
pending = true pending = true
log.Printf("there is a pending withdrawal request, waiting\n") log.Printf("there is a pending withdrawal request, waiting...")
log.Printf("%+v", withdrawal)
break break
case "sent": case "sent", "confirmed":
continue continue
case "rejected":
} }
} }
@ -84,7 +89,7 @@ func main() {
maxRest := maxapi.NewRestClient(maxapi.ProductionAPIURL) maxRest := maxapi.NewRestClient(maxapi.ProductionAPIURL)
maxRest.Auth(key, secret) maxRest.Auth(key, secret)
if err := waitWithdrawalsComplete(ctx, maxRest, currency, 1) ; err != nil { if err := waitWithdrawalsComplete(ctx, maxRest, currency, 1); err != nil {
log.Fatal(err) log.Fatal(err)
} }
log.Printf("all withdrawals are sent, sending new withdrawal request...") log.Printf("all withdrawals are sent, sending new withdrawal request...")
@ -113,7 +118,7 @@ func main() {
} }
} }
if err := waitWithdrawalsComplete(ctx, maxRest, currency, 1) ; err != nil { if err := waitWithdrawalsComplete(ctx, maxRest, currency, 1); err != nil {
log.Fatal(err) log.Fatal(err)
} }
log.Printf("all withdrawals are sent") log.Printf("all withdrawals are sent")