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

deposit2transfer: refactor deposit check and add more logs

Browse Source
This commit is contained in:
c9s 2023-08-08 12:23:17 +08:00
parent 29727c12be
commit 073c4562fd
No known key found for this signature in database
GPG Key ID: 7385E7E464CB0A54
1 changed files with 35 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

58
pkg/strategy/deposit2transfer/strategy.go
View File

@ -87,6 +87,8 @@ func (s *Strategy) Run(ctx context.Context, orderExecutor bbgo.OrderExecutor, se
return errDepositHistoryNotSupport
}
go s.tickWatcher(ctx, s.Interval.Duration())
return nil
}
@ -94,42 +96,52 @@ func (s *Strategy) tickWatcher(ctx context.Context, interval time.Duration) {
ticker := time.NewTicker(interval)
defer ticker.Stop()
s.checkDeposits(ctx)
for {
select {
case <-ctx.Done():
return
case <-ticker.C:
for _, asset := range s.Assets {
account := s.session.Account
s.checkDeposits(ctx)
}
}
}
succeededDeposits, err := s.scanDepositHistory(ctx, asset, 4*time.Hour)
if err != nil {
log.WithError(err).Errorf("unable to scan deposit history")
continue
}
func (s *Strategy) checkDeposits(ctx context.Context) {
for _, asset := range s.Assets {
log.Infof("checking %s deposits...", asset)
for _, d := range succeededDeposits {
log.Infof("found succeeded deposit: %+v", d)
account := s.session.Account
succeededDeposits, err := s.scanDepositHistory(ctx, asset, 4*time.Hour)
if err != nil {
log.WithError(err).Errorf("unable to scan deposit history")
return
}
bal, ok := account.Balance(d.Asset)
if !ok {
log.Errorf("unexpected error: %s balance not found", d.Asset)
continue
}
if len(succeededDeposits) == 0 {
log.Infof("no %s deposit found", asset)
}
log.Infof("%s balance: %+v", d.Asset, bal)
for _, d := range succeededDeposits {
log.Infof("found succeeded deposit: %+v", d)
amount := fixedpoint.Min(bal.Available, d.Amount)
bal, ok := account.Balance(d.Asset)
if !ok {
log.Errorf("unexpected error: %s balance not found", d.Asset)
return
}
bbgo.Notify("Found succeeded deposit %s %s, transferring %s %s into the margin account",
d.Amount.String(), d.Asset,
amount.String(), d.Asset)
log.Infof("%s balance: %+v", d.Asset, bal)
if err2 := s.marginTransferService.TransferMarginAccountAsset(ctx, d.Asset, amount, types.TransferIn); err2 != nil {
log.WithError(err2).Errorf("unable to transfer deposit asset into the margin account")
}
}
amount := fixedpoint.Min(bal.Available, d.Amount)
bbgo.Notify("Found succeeded deposit %s %s, transferring %s %s into the margin account",
d.Amount.String(), d.Asset,
amount.String(), d.Asset)
if err2 := s.marginTransferService.TransferMarginAccountAsset(ctx, d.Asset, amount, types.TransferIn); err2 != nil {
log.WithError(err2).Errorf("unable to transfer deposit asset into the margin account")
}
}
}