vladzvx
/
klhztrader
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

удалил запрос последних цен

dev
vlad zverzhkhovskiy 2025-09-09 10:51:02 +03:00
parent c0e29c06a5
commit 4d898e376a
1 changed files with 0 additions and 30 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
KLHZ.Trader.Core/Exchange/Services/ExchangeDataReader.cs
View File

@ -72,11 +72,6 @@ namespace KLHZ.Trader.Core.Exchange.Services
{ {
using var stream = _investApiClient.MarketDataStream.MarketDataStream(); using var stream = _investApiClient.MarketDataStream.MarketDataStream();
//var request = new SubscribeLastPriceRequest
//{
// SubscriptionAction = SubscriptionAction.Subscribe
//};
var tradesRequest = new SubscribeTradesRequest var tradesRequest = new SubscribeTradesRequest
{ {
SubscriptionAction = SubscriptionAction.Subscribe SubscriptionAction = SubscriptionAction.Subscribe
@ -89,12 +84,6 @@ namespace KLHZ.Trader.Core.Exchange.Services
foreach (var f in _instrumentsFigis) foreach (var f in _instrumentsFigis)
{ {
//request.Instruments.Add(
// new LastPriceInstrument()
// {
// InstrumentId = f
// });
tradesRequest.Instruments.Add( tradesRequest.Instruments.Add(
new TradeInstrument() 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 await stream.RequestStream.WriteAsync(new MarketDataRequest
{ {
SubscribeTradesRequest = tradesRequest, SubscribeTradesRequest = tradesRequest,
@ -129,20 +113,6 @@ namespace KLHZ.Trader.Core.Exchange.Services
var lastWrite = DateTime.UtcNow; var lastWrite = DateTime.UtcNow;
await foreach (var response in stream.ResponseStream.ReadAllAsync()) 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) if (response.Trade != null)
{ {
var message = new PriceChange() var message = new PriceChange()