lychiyu/bbgo_origin
1
0
Fork 0
mirror of https://github.com/c9s/bbgo.git synced 2024-11-22 06:53:52 +00:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

core: change TradeConverter to interface and integrate trade converter

Browse Source
This commit is contained in:
c9s 2024-08-07 17:29:03 +08:00
parent 25b0b5ded5
commit 813684fc77
No known key found for this signature in database
GPG Key ID: 7385E7E464CB0A54
1 changed files with 14 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
pkg/core/tradecollector.go
View File

@ -12,7 +12,9 @@ import (
"github.com/c9s/bbgo/pkg/types"
)
type TradeConverter func(trade types.Trade) (types.Trade, error)
type TradeConverter interface {
Convert(trade types.Trade) (types.Trade, error)
}
//go:generate callbackgen -type TradeCollector
type TradeCollector struct {
@ -58,10 +60,14 @@ func (c *TradeCollector) AddTradeConverter(converter TradeConverter) {
}
func (c *TradeCollector) convertTrade(trade types.Trade) types.Trade {
if len(c.tradeConverters) == 0 {
return trade
}
for _, converter := range c.tradeConverters {
convTrade, err := converter(trade)
convTrade, err := converter.Convert(trade)
if err != nil {
logrus.WithError(err).Errorf("trade converter error, trade: %s", trade.String())
logrus.WithError(err).Errorf("trade %+v converter error, trade: %s", converter, trade.String())
continue
}
@ -138,6 +144,8 @@ func (c *TradeCollector) Recover(
}
func (c *TradeCollector) RecoverTrade(td types.Trade) bool {
td = c.convertTrade(td)
logrus.Debugf("checking trade: %s", td.String())
if c.processTrade(td) {
logrus.Infof("recovered trade: %s", td.String())
@ -252,7 +260,7 @@ func (c *TradeCollector) processTrade(trade types.Trade) bool {
// return true when the given trade is added
// return false when the given trade is not added
func (c *TradeCollector) ProcessTrade(trade types.Trade) bool {
return c.processTrade(trade)
return c.processTrade(c.convertTrade(trade))
}
// Run is a goroutine executed in the background
@ -271,7 +279,8 @@ func (c *TradeCollector) Run(ctx context.Context) {
c.Process()
case trade := <-c.tradeC:
c.processTrade(trade)
c.processTrade(c.convertTrade(trade))
}
}
}