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

improve depth error messages

Browse Source
This commit is contained in:
c9s 2021-05-26 01:31:58 +08:00
parent 06e982124b
commit 9c331063f4
1 changed files with 6 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
pkg/exchange/binance/depthframe.go
View File

@ -2,11 +2,11 @@ package binance
import ( import (
"context" "context"
"fmt"
"sync" "sync"
"time" "time"
"github.com/adshao/go-binance/v2" "github.com/adshao/go-binance/v2"
"github.com/pkg/errors"
) )
//go:generate callbackgen -type DepthFrame //go:generate callbackgen -type DepthFrame
@ -68,27 +68,21 @@ func (f *DepthFrame) loadDepthSnapshot() error {
time.Sleep(3 * time.Second) time.Sleep(3 * time.Second)
if debugBinanceDepth {
log.Infof("loading %s depth from the restful api", f.Symbol)
}
depth, err := f.fetch(f.context) depth, err := f.fetch(f.context)
if err != nil { if err != nil {
log.WithError(err).Errorf("depth api error")
return err return err
} }
if len(depth.Asks) == 0 { if len(depth.Asks) == 0 {
log.Errorf("depth response error: empty asks") return fmt.Errorf("%s depth response error: empty asks", f.Symbol)
return errors.New("depth response error: empty asks")
} }
if len(depth.Bids) == 0 { if len(depth.Bids) == 0 {
return errors.New("depth response error: empty bids") return fmt.Errorf("%s depth response error: empty bids", f.Symbol)
} }
if debugBinanceDepth { if debugBinanceDepth {
log.Infof("loaded %s depth, last update ID = %d", f.Symbol, depth.FinalUpdateID) log.Infof("fetched %s depth, last update ID = %d", f.Symbol, depth.FinalUpdateID)
} }
// filter the events by the event IDs // filter the events by the event IDs
@ -130,8 +124,7 @@ func (f *DepthFrame) loadDepthSnapshot() error {
// valid // valid
nextID := depth.FinalUpdateID + 1 nextID := depth.FinalUpdateID + 1
if firstEvent.FirstUpdateID > nextID || firstEvent.FinalUpdateID < nextID { if firstEvent.FirstUpdateID > nextID || firstEvent.FinalUpdateID < nextID {
log.Warn("MISMATCH final update id for order book, resetting depth...") return fmt.Errorf("mismatch %s final update id for order book, resetting depth", f.Symbol)
return errors.New("MISMATCH final update id for order book, resetting depth...")
} }
if debugBinanceDepth { if debugBinanceDepth {
@ -171,7 +164,7 @@ func (f *DepthFrame) PushEvent(e DepthEvent) {
go f.once.Do(func() { go f.once.Do(func() {
if err := f.loadDepthSnapshot(); err != nil { if err := f.loadDepthSnapshot(); err != nil {
log.WithError(err).Error("depth snapshot load failed, resetting..") log.WithError(err).Error("%s depth snapshot load failed, resetting..", f.Symbol)
f.emitReset() f.emitReset()
} }
}) })