From 0f24eec715308785e8e35a3ccad73cc9d6fa25ee Mon Sep 17 00:00:00 2001
From: c9s <yoan@maicoin.com>
Date: Mon, 27 Dec 2021 16:32:30 +0800
Subject: [PATCH] bbgo: fix: filter trades by symbol

---
 pkg/bbgo/session.go | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/pkg/bbgo/session.go b/pkg/bbgo/session.go
index 6a4d6e66b..72b81f158 100644
--- a/pkg/bbgo/session.go
+++ b/pkg/bbgo/session.go
@@ -412,7 +412,9 @@ func (session *ExchangeSession) initSymbol(ctx context.Context, environ *Environ
 
 	session.Trades[symbol] = &types.TradeSlice{Trades: trades}
 	session.UserDataStream.OnTradeUpdate(func(trade types.Trade) {
-		session.Trades[symbol].Append(trade)
+		if trade.Symbol == symbol {
+			session.Trades[symbol].Append(trade)
+		}
 	})
 
 	position := &types.Position{