diff --git a/KLHZ.Trader.Core/Exchange/Services/ExchangeDataReader.cs b/KLHZ.Trader.Core/Exchange/Services/ExchangeDataReader.cs index 818688f..c2d69aa 100644 --- a/KLHZ.Trader.Core/Exchange/Services/ExchangeDataReader.cs +++ b/KLHZ.Trader.Core/Exchange/Services/ExchangeDataReader.cs @@ -95,7 +95,6 @@ namespace KLHZ.Trader.Core.Exchange.Services SubscriptionAction = SubscriptionAction.Subscribe }; - var tradesRequest = new SubscribeTradesRequest { SubscriptionAction = SubscriptionAction.Subscribe diff --git a/migration1.sql b/KLHZ.Trader.Infrastructure/postgres/migration1.sql similarity index 100% rename from migration1.sql rename to KLHZ.Trader.Infrastructure/postgres/migration1.sql diff --git a/KLHZ.Trader.Infrastructure/postgres/migration2.sql b/KLHZ.Trader.Infrastructure/postgres/migration2.sql new file mode 100644 index 0000000..52606f7 --- /dev/null +++ b/KLHZ.Trader.Infrastructure/postgres/migration2.sql @@ -0,0 +1,12 @@ +drop table if exists instrument_trades; +create table instrument_trades +( + trade_id bigserial, + bought_at timestamp default current_timestamp, + figi text not null, + ticker text not null, + price decimal not null, + count decimal not null, + direction int not null default 1, + primary key (trade_id) +); \ No newline at end of file