xdepthmaker: run profit fixer before s.CrossExchangeMarketMakingStrat…

…egy.Initialize
c9s · Mar 6, 2024 · 31676cc · 31676cc
1 parent ac43937
commit 31676cc
Showing 1 changed file with 13 additions and 13 deletions.
diff --git a/pkg/strategy/xdepthmaker/strategy.go b/pkg/strategy/xdepthmaker/strategy.go
@@ -319,19 +319,6 @@ func (s *Strategy) CrossRun(
 
 	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.TradesSince.Time().IsZero() {
 			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 {
 		go s.runTradeRecover(ctx)
 	}