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

xalign: resetFaultBalanceRecords when pending deposit/withdraw was found

Browse Source
This commit is contained in:
c9s 2024-11-04 16:13:05 +08:00
parent 634ded1759
commit bac8d489bc
No known key found for this signature in database
GPG Key ID: 7385E7E464CB0A54
1 changed files with 22 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
pkg/strategy/xalign/strategy.go
View File

@ -436,6 +436,10 @@ func (s *Strategy) CrossRun(ctx context.Context, _ bbgo.OrderExecutionRouter, se
return nil return nil
} }
func (s *Strategy) resetFaultBalanceRecords(currency string) {
s.faultBalanceRecords[currency] = nil
}
func (s *Strategy) recordBalance(totalBalances types.BalanceMap) { func (s *Strategy) recordBalance(totalBalances types.BalanceMap) {
now := time.Now() now := time.Now()
for currency, expectedBalance := range s.ExpectedBalances { for currency, expectedBalance := range s.ExpectedBalances {
@ -450,7 +454,7 @@ func (s *Strategy) recordBalance(totalBalances types.BalanceMap) {
}) })
} else { } else {
// reset counter // reset counter
s.faultBalanceRecords[currency] = nil s.resetFaultBalanceRecords(currency)
} }
} }
} }
@ -473,11 +477,18 @@ func (s *Strategy) align(ctx context.Context, sessions map[string]*bbgo.Exchange
if err != nil { if err != nil {
log.WithError(err).Errorf("unable to check active transfers (withdraw)") log.WithError(err).Errorf("unable to check active transfers (withdraw)")
} else if pendingWithdraw != nil { } else if pendingWithdraw != nil {
log.Warnf("found active transfer (withdraw), skip balance align check") log.Warnf("found active transfer (%f %s withdraw), skip balance align check",
pendingWithdraw.Amount.Float64(),
pendingWithdraw.Asset)
s.resetFaultBalanceRecords(pendingWithdraw.Asset)
if activeTransferNotificationLimiter.Allow() { if activeTransferNotificationLimiter.Allow() {
bbgo.Notify("Found active withdraw, skip balance align", pendingWithdraw) bbgo.Notify("Found active %s withdraw, skip balance align",
pendingWithdraw.Asset,
pendingWithdraw)
} }
return return
} }
@ -485,10 +496,16 @@ func (s *Strategy) align(ctx context.Context, sessions map[string]*bbgo.Exchange
if err != nil { if err != nil {
log.WithError(err).Errorf("unable to check active transfers (deposit)") log.WithError(err).Errorf("unable to check active transfers (deposit)")
} else if pendingDeposit != nil { } else if pendingDeposit != nil {
log.Warnf("found active transfer (deposit), skip balance align check") log.Warnf("found active transfer (%f %s deposit), skip balance align check",
pendingDeposit.Amount.Float64(),
pendingDeposit.Asset)
s.resetFaultBalanceRecords(pendingDeposit.Asset)
if activeTransferNotificationLimiter.Allow() { if activeTransferNotificationLimiter.Allow() {
bbgo.Notify("Found active deposit, skip balance align", pendingDeposit) bbgo.Notify("Found active %s deposit, skip balance align",
pendingDeposit.Asset,
pendingDeposit)
} }
return return
} }