xnav: subscribe BTCUSDT symbol

c9s · Dec 23, 2024 · 420d128 · 420d128
1 parent ebe6238
commit 420d128
Showing 1 changed file with 9 additions and 1 deletion.
diff --git a/pkg/strategy/xnav/strategy.go b/pkg/strategy/xnav/strategy.go
@@ -148,9 +148,17 @@ func (s *Strategy) Validate() error {
 	return nil
 }
 
+const anchorSymbol = "BTCUSDT"
+
 var ten = fixedpoint.NewFromInt(10)
 
-func (s *Strategy) CrossSubscribe(sessions map[string]*bbgo.ExchangeSession) {}
+func (s *Strategy) CrossSubscribe(sessions map[string]*bbgo.ExchangeSession) {
+	for _, session := range sessions {
+		session.Subscribe(types.KLineChannel, anchorSymbol, types.SubscribeOptions{
+			Interval: types.Interval1m,
+		})
+	}
+}
 
 func (s *Strategy) recordNetAssetValue(ctx context.Context, sessions map[string]*bbgo.ExchangeSession) {
 	log.Infof("recording net asset value...")