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

exchange/ftx: add more guard condition

Browse Source
This commit is contained in:
TonyQ 2021-12-21 20:46:40 +08:00
parent 1ab20e6397
commit 740989ca64
1 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
pkg/exchange/ftx/stream.go
View File

@ -177,11 +177,14 @@ func (s *Stream) pollKLines(ctx context.Context) {
s.EmitKLineClosed(klines[0]) s.EmitKLineClosed(klines[0])
lastClosed = klines[0].StartTime.Time() lastClosed = klines[0].StartTime.Time()
} }
if len(klines) > 1 {
s.EmitKLine(klines[1]) s.EmitKLine(klines[1])
} }
} }
} }
} }
}
} }
func getLast2KLine(e *Exchange, ctx context.Context, symbol string, interval types.Interval) []types.KLine { func getLast2KLine(e *Exchange, ctx context.Context, symbol string, interval types.Interval) []types.KLine {
@ -202,6 +205,9 @@ func getLast2KLine(e *Exchange, ctx context.Context, symbol string, interval typ
func getLastClosedKLine(e *Exchange, ctx context.Context, symbol string, interval types.Interval) []types.KLine { func getLastClosedKLine(e *Exchange, ctx context.Context, symbol string, interval types.Interval) []types.KLine {
// set since to more 30s ago to avoid getting no kline candle // set since to more 30s ago to avoid getting no kline candle
klines := getLast2KLine(e, ctx, symbol, interval) klines := getLast2KLine(e, ctx, symbol, interval)
if len(klines) == 0 {
return []types.KLine{}
}
return []types.KLine{klines[0]} return []types.KLine{klines[0]}
} }