From 4d898e376aafea97a01ed96ac9381d4fe35ac81e Mon Sep 17 00:00:00 2001
From: vlad zverzhkhovskiy <v.zverzhkhovskiyvd@gmail.com>
Date: Tue, 9 Sep 2025 10:51:02 +0300
Subject: [PATCH] =?UTF-8?q?=D1=83=D0=B4=D0=B0=D0=BB=D0=B8=D0=BB=20=D0=B7?=
 =?UTF-8?q?=D0=B0=D0=BF=D1=80=D0=BE=D1=81=20=D0=BF=D0=BE=D1=81=D0=BB=D0=B5?=
 =?UTF-8?q?=D0=B4=D0=BD=D0=B8=D1=85=20=D1=86=D0=B5=D0=BD?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../Exchange/Services/ExchangeDataReader.cs   | 30 -------------------
 1 file changed, 30 deletions(-)

diff --git a/KLHZ.Trader.Core/Exchange/Services/ExchangeDataReader.cs b/KLHZ.Trader.Core/Exchange/Services/ExchangeDataReader.cs
index 27dc11f..086ce34 100644
--- a/KLHZ.Trader.Core/Exchange/Services/ExchangeDataReader.cs
+++ b/KLHZ.Trader.Core/Exchange/Services/ExchangeDataReader.cs
@@ -72,11 +72,6 @@ namespace KLHZ.Trader.Core.Exchange.Services
         {
             using var stream = _investApiClient.MarketDataStream.MarketDataStream();
 
-            //var request = new SubscribeLastPriceRequest
-            //{
-            //    SubscriptionAction = SubscriptionAction.Subscribe
-            //};
-
             var tradesRequest = new SubscribeTradesRequest
             {
                 SubscriptionAction = SubscriptionAction.Subscribe
@@ -89,12 +84,6 @@ namespace KLHZ.Trader.Core.Exchange.Services
 
             foreach (var f in _instrumentsFigis)
             {
-                //request.Instruments.Add(
-                //    new LastPriceInstrument()
-                //    {
-                //        InstrumentId = f
-                //    });
-
                 tradesRequest.Instruments.Add(
                     new TradeInstrument()
                     {
@@ -109,11 +98,6 @@ namespace KLHZ.Trader.Core.Exchange.Services
                     });
             }
 
-            //await stream.RequestStream.WriteAsync(new MarketDataRequest
-            //{
-            //    SubscribeLastPriceRequest = request,
-            //});
-
             await stream.RequestStream.WriteAsync(new MarketDataRequest
             {
                 SubscribeTradesRequest = tradesRequest,
@@ -129,20 +113,6 @@ namespace KLHZ.Trader.Core.Exchange.Services
             var lastWrite = DateTime.UtcNow;
             await foreach (var response in stream.ResponseStream.ReadAllAsync())
             {
-                //if (response.LastPrice != null)
-                //{
-                //    var message = new PriceChange()
-                //    {
-                //        Figi = response.LastPrice.Figi,
-                //        Ticker = _tradeDataProvider.GetTickerByFigi(response.LastPrice.Figi),
-                //        Time = response.LastPrice.Time.ToDateTime().ToUniversalTime(),
-                //        Value = response.LastPrice.Price,
-                //        IsHistoricalData = false,
-                //    };
-                //    await _eventBus.Broadcast(message);
-
-                //    pricesBuffer.Add(message);
-                //}
                 if (response.Trade != null)
                 {
                     var message = new PriceChange()