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

xdepthmaker: run profit fixer before s.CrossExchangeMarketMakingStrategy.Initialize

Browse Source
This commit is contained in:
c9s 2024-03-06 12:53:36 +08:00
parent ac43937847
commit 31676cce8e
No known key found for this signature in database
GPG Key ID: 7385E7E464CB0A54
1 changed files with 13 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
pkg/strategy/xdepthmaker/strategy.go
View File

@ -319,19 +319,6 @@ func (s *Strategy) CrossRun(
log.Infof("makerSession: %s hedgeSession: %s", makerSession.Name, hedgeSession.Name) log.Infof("makerSession: %s hedgeSession: %s", makerSession.Name, hedgeSession.Name)
if err := s.CrossExchangeMarketMakingStrategy.Initialize(ctx, s.Environment, makerSession, hedgeSession, s.Symbol, ID, s.InstanceID()); err != nil {
return err
}
s.pricingBook = types.NewStreamBook(s.Symbol)
s.pricingBook.BindStream(s.hedgeSession.MarketDataStream)
s.stopC = make(chan struct{})
s.authedC = make(chan struct{}, 5)
bindAuthSignal(ctx, s.makerSession.UserDataStream, s.authedC)
bindAuthSignal(ctx, s.hedgeSession.UserDataStream, s.authedC)
if s.ProfitFixerConfig != nil { if s.ProfitFixerConfig != nil {
if s.ProfitFixerConfig.TradesSince.Time().IsZero() { if s.ProfitFixerConfig.TradesSince.Time().IsZero() {
return errors.New("tradesSince time can not be zero") return errors.New("tradesSince time can not be zero")
@ -349,6 +336,19 @@ func (s *Strategy) CrossRun(
} }
} }
if err := s.CrossExchangeMarketMakingStrategy.Initialize(ctx, s.Environment, makerSession, hedgeSession, s.Symbol, ID, s.InstanceID()); err != nil {
return err
}
s.pricingBook = types.NewStreamBook(s.Symbol)
s.pricingBook.BindStream(s.hedgeSession.MarketDataStream)
s.stopC = make(chan struct{})
s.authedC = make(chan struct{}, 5)
bindAuthSignal(ctx, s.makerSession.UserDataStream, s.authedC)
bindAuthSignal(ctx, s.hedgeSession.UserDataStream, s.authedC)
if s.RecoverTrade { if s.RecoverTrade {
go s.runTradeRecover(ctx) go s.runTradeRecover(ctx)
} }