Insight.Tinkoff.InvestSdk 1.0.1

Unofficial Tinkoff Invest OpenApi csharp Sdk

There is a newer version of this package available.
See the version list below for details.
Install-Package Insight.Tinkoff.InvestSdk -Version 1.0.1
dotnet add package Insight.Tinkoff.InvestSdk --version 1.0.1
<PackageReference Include="Insight.Tinkoff.InvestSdk" Version="1.0.1" />
For projects that support PackageReference, copy this XML node into the project file to reference the package.
paket add Insight.Tinkoff.InvestSdk --version 1.0.1
The NuGet Team does not provide support for this client. Please contact its maintainers for support.

Unofficial Tinkoff Invest .Net Sdk

nuget version

About

Данное sdk предназначено для взаимодействия с OpenApi Тинькофф Инвестиций. Так как на момент публикации официального sdk больше половины работы над данным проектом было закончено, я решил, что буду пользоваться им и поддерживать по мере возможности. Вопросы и предложения прошу в Issues.

Get started

Для начала вам необходимо получить токен, процедура подробно описана здесь

Структура SDK

Взаимодействие с API происходит через следующие сервисы:

  • MarketService - Получение информации об инструментах (Rest, реализует IMarketService)
  • OrderService - Получение информации о лимитных заявках, а также их размещение (Rest, реализует IOrderService)
  • PortfolioService - Получение информации о портфолио (Rest, реализует IPortfolioService)
  • OperationService - Получение информации об операциях (Rest, реализует IOperationService)
  • SandboxService - Взаимодействие с песочницей (Rest, реализует ISandboxService)
  • StreamMarketService - Взаимодействие с API по протоколу WebSocket (WebSocket, Реализует IStreamMarketService)

Все Rest сервисы инициализируются объектом конфигурации типа TinkoffRestServiceConfiguration:

  • string AccessToken - Токен доступа к API
  • string BaseUrl - Базовый адрес API, default = "https://api-invest.tinkoff.ru"
  • bool SandboxMode - Признак активна ли песочница, default = true

StreamMarketService инициализируется объектом конфигурации типа StreamMarketServiceConfiguration:

  • string Token - Токен доступа к API
  • string Address - Адрес, по которому доступен WebSocket

StreamMarketService

Данный сервис реализует интерфейс IStreamMarketService:

public interface IStreamMarketService
{
    Task Send(IWsMessage message);

    IObservable<WsMessage> AsObservable();
}

Соотвественно метод Send служит для отправки сообщений на подписку/отписку от событий. Типы исходящих сообщений реализуют интерфейс IWsMessage: SubscribeCandleMessage, UnsubscribeCandleMessage, SubscribeOrderBookMessage, UnsubscribeOrderBookMessage, SubscribeInstrumentInfoMessage, UnsubscribeInstrumentInfoMessage;
Метод AsObservable() реализован с помощью System.Reactive, а именно с помощью Observable.FromEventPattern, благодаря этому вы получаете Push коллекцию, в которую будут приходить сообщения типа WsMessage: CandleMessage, OrderBookMessage, InstrumentInfoMessage. На выходе сообщения десериализуются в правильный тип на основе свойства Event, вы можете использовать Pattern Matching. Пример кода:

public sealed class Program {
  private StreamMarketServiceConfiguration _config;
  
  public Program(StreamMarketServiceConfiguration config) {
    if(config == null)
      throw new ArgumentNullException(nameof(config));
      
    _config = config;
  }
  
  public async Task DoWork() {
    using (var client = new StreamMarketService(_config))
    {
      IDisposable subscription = client
        .AsObservable()
        .Do(x =>
        {
          switch (x)
          {
            case CandleMessage message:
              Console.WriteLine($"type: {message}, figi: {message.Payload.Figi}");
              break;
            default:
              Console.WriteLine("Unknown message type");
              break;
          }
        }, ex => { throw ex; })
        .RetryAfterDelay(TimeSpan.FromSeconds(1))
        .Subscribe();
    
      await client.Send(new SubscribeCandleMessage
      {
        Figi = "{figi}",
        Interval = CandleInterval.Minute
      });

      await Task.Delay(1000 * 5);

      await client.Send(new UnsubscribeCandleMessage()
      {
        Figi = "{figi}",
        Interval = CandleInterval.Minute
      });
      
      subscription?.Dispose()
    }
  }
}

RetryAfterDelay - лечит разрыв соединения.

Тесты

Вы можете запустить примитивные тесты для Rest сервисов добавив в файл Insight.Tinkoff.Invest.Tests/appsettings.json токен для сандбокса. По дефолту изменения файла игнорируются в .gitignore

Unofficial Tinkoff Invest .Net Sdk

nuget version

About

Данное sdk предназначено для взаимодействия с OpenApi Тинькофф Инвестиций. Так как на момент публикации официального sdk больше половины работы над данным проектом было закончено, я решил, что буду пользоваться им и поддерживать по мере возможности. Вопросы и предложения прошу в Issues.

Get started

Для начала вам необходимо получить токен, процедура подробно описана здесь

Структура SDK

Взаимодействие с API происходит через следующие сервисы:

  • MarketService - Получение информации об инструментах (Rest, реализует IMarketService)
  • OrderService - Получение информации о лимитных заявках, а также их размещение (Rest, реализует IOrderService)
  • PortfolioService - Получение информации о портфолио (Rest, реализует IPortfolioService)
  • OperationService - Получение информации об операциях (Rest, реализует IOperationService)
  • SandboxService - Взаимодействие с песочницей (Rest, реализует ISandboxService)
  • StreamMarketService - Взаимодействие с API по протоколу WebSocket (WebSocket, Реализует IStreamMarketService)

Все Rest сервисы инициализируются объектом конфигурации типа TinkoffRestServiceConfiguration:

  • string AccessToken - Токен доступа к API
  • string BaseUrl - Базовый адрес API, default = "https://api-invest.tinkoff.ru"
  • bool SandboxMode - Признак активна ли песочница, default = true

StreamMarketService инициализируется объектом конфигурации типа StreamMarketServiceConfiguration:

  • string Token - Токен доступа к API
  • string Address - Адрес, по которому доступен WebSocket

StreamMarketService

Данный сервис реализует интерфейс IStreamMarketService:

public interface IStreamMarketService
{
    Task Send(IWsMessage message);

    IObservable<WsMessage> AsObservable();
}

Соотвественно метод Send служит для отправки сообщений на подписку/отписку от событий. Типы исходящих сообщений реализуют интерфейс IWsMessage: SubscribeCandleMessage, UnsubscribeCandleMessage, SubscribeOrderBookMessage, UnsubscribeOrderBookMessage, SubscribeInstrumentInfoMessage, UnsubscribeInstrumentInfoMessage;
Метод AsObservable() реализован с помощью System.Reactive, а именно с помощью Observable.FromEventPattern, благодаря этому вы получаете Push коллекцию, в которую будут приходить сообщения типа WsMessage: CandleMessage, OrderBookMessage, InstrumentInfoMessage. На выходе сообщения десериализуются в правильный тип на основе свойства Event, вы можете использовать Pattern Matching. Пример кода:

public sealed class Program {
  private StreamMarketServiceConfiguration _config;
  
  public Program(StreamMarketServiceConfiguration config) {
    if(config == null)
      throw new ArgumentNullException(nameof(config));
      
    _config = config;
  }
  
  public async Task DoWork() {
    using (var client = new StreamMarketService(_config))
    {
      IDisposable subscription = client
        .AsObservable()
        .Do(x =>
        {
          switch (x)
          {
            case CandleMessage message:
              Console.WriteLine($"type: {message}, figi: {message.Payload.Figi}");
              break;
            default:
              Console.WriteLine("Unknown message type");
              break;
          }
        }, ex => { throw ex; })
        .RetryAfterDelay(TimeSpan.FromSeconds(1))
        .Subscribe();
    
      await client.Send(new SubscribeCandleMessage
      {
        Figi = "{figi}",
        Interval = CandleInterval.Minute
      });

      await Task.Delay(1000 * 5);

      await client.Send(new UnsubscribeCandleMessage()
      {
        Figi = "{figi}",
        Interval = CandleInterval.Minute
      });
      
      subscription?.Dispose()
    }
  }
}

RetryAfterDelay - лечит разрыв соединения.

Тесты

Вы можете запустить примитивные тесты для Rest сервисов добавив в файл Insight.Tinkoff.Invest.Tests/appsettings.json токен для сандбокса. По дефолту изменения файла игнорируются в .gitignore

Release Notes

OpenApi 19.2 supported. MarketInstrumentResponce.Total type fixed (decimal -> int)

This package is not used by any popular GitHub repositories.

Version History

Version Downloads Last updated
2.2.2 0 4/4/2020
2.2.1 75 3/22/2020
2.2.0 45 3/10/2020
1.3.0 65 11/14/2019
1.2.1 63 11/8/2019
1.2.0 51 11/8/2019
1.1.1 92 10/18/2019
1.0.1 69 10/16/2019
1.0.0 62 10/16/2019
Show less