From 9251f12d8355837ac4a146ac8e40ffe6cb896128 Mon Sep 17 00:00:00 2001 From: c9s Date: Mon, 18 Nov 2024 15:36:32 +0800 Subject: [PATCH] fix connectivity initialization --- pkg/bbgo/session.go | 13 +++++++++++-- 1 file changed, 11 insertions(+), 2 deletions(-) diff --git a/pkg/bbgo/session.go b/pkg/bbgo/session.go index dd3b275d57..cbb06bbd1b 100644 --- a/pkg/bbgo/session.go +++ b/pkg/bbgo/session.go @@ -134,12 +134,13 @@ type ExchangeSession struct { func NewExchangeSession(name string, exchange types.Exchange) *ExchangeSession { userDataStream := exchange.NewStream() - userDataConnectivity := types.NewConnectivity() - userDataConnectivity.Bind(userDataStream) marketDataStream := exchange.NewStream() marketDataStream.SetPublicOnly() + userDataConnectivity := types.NewConnectivity() + userDataConnectivity.Bind(userDataStream) + marketDataConnectivity := types.NewConnectivity() marketDataConnectivity.Bind(marketDataStream) @@ -870,6 +871,14 @@ func (session *ExchangeSession) InitExchange(name string, ex types.Exchange) err session.MarketDataStream = ex.NewStream() session.MarketDataStream.SetPublicOnly() + session.UserDataConnectivity = types.NewConnectivity() + session.UserDataConnectivity.Bind(session.UserDataStream) + + session.MarketDataConnectivity = types.NewConnectivity() + session.MarketDataConnectivity.Bind(session.MarketDataStream) + + session.Connectivity = types.NewConnectivityGroup(session.MarketDataConnectivity, session.MarketDataConnectivity) + // pointer fields session.Subscriptions = make(map[types.Subscription]types.Subscription) session.Account = &types.Account{}