add Example project

Author: vitaliy-art

DigitexConnectorCSharp.sln

@@ -10,6 +10,11 @@ Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "Solution Items", "Solution
 		README.md = README.md
 	EndProjectSection
 EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Example", "Example\Example.csproj", "{1CE9B672-B2A5-4FC1-8B83-3AFC46CB00C9}"
+	ProjectSection(ProjectDependencies) = postProject
+		{5BDAF922-88F8-4B73-8848-221469768845} = {5BDAF922-88F8-4B73-8848-221469768845}
+	EndProjectSection
+EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
 		Debug|Any CPU = Debug|Any CPU
@@ -20,6 +25,10 @@ Global
 		{5BDAF922-88F8-4B73-8848-221469768845}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{5BDAF922-88F8-4B73-8848-221469768845}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{5BDAF922-88F8-4B73-8848-221469768845}.Release|Any CPU.Build.0 = Release|Any CPU
+		{1CE9B672-B2A5-4FC1-8B83-3AFC46CB00C9}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{1CE9B672-B2A5-4FC1-8B83-3AFC46CB00C9}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{1CE9B672-B2A5-4FC1-8B83-3AFC46CB00C9}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{1CE9B672-B2A5-4FC1-8B83-3AFC46CB00C9}.Release|Any CPU.Build.0 = Release|Any CPU
 	EndGlobalSection
 	GlobalSection(SolutionProperties) = preSolution
 		HideSolutionNode = FALSE

Example/Example.csproj

@@ -0,0 +1,12 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <OutputType>Exe</OutputType>
+    <TargetFramework>netcoreapp3.1</TargetFramework>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\DigitexConnector\DigitexConnector.csproj" />
+  </ItemGroup>
+
+</Project>

Example/IntervalAlgorithm.cs

@@ -0,0 +1,110 @@
+using DigitexConnector;
+using DigitexConnector.EngineAPI;
+using DigitexConnector.Orders;
+using DigitexConnector.Trading;
+using System;
+using System.Collections.Generic;
+using System.Threading;
+
+namespace Example
+{
+    class IntervalAlgorithm : TradingAlgorithm
+    {
+        private int Interval = 10;
+        private string SymbolName = "BTC/USD1";
+        private Symbol Smbl;
+        private OrderBook OBook;
+
+        private Timer TradingTimer;
+
+        public IntervalAlgorithm(string host, string token, bool wss)
+            : base(host, token, wss)
+        { }
+
+        public override void Prepare()
+        {
+            Smbl = SymbolsContainer.GetSymbol(SymbolName);
+            SpotPriceUpdated += SpotPriceHandler;
+            OrderBookUpdated += OrderBookHandler;
+            OBook = TrackSymbol(Smbl);
+            TradingTimer = new Timer((object obj) => PlaceOrder(), null, Interval * 1000, Interval * 1000);
+        }
+
+        private void SpotPriceHandler(OrderBook oBook)
+        {
+            if (oBook.Equals(OBook))
+            {
+                // Do something for handle spot price changing.
+            }
+        }
+
+        private void OrderBookHandler(OrderBook oBook)
+        {
+            if (oBook.Equals(OBook))
+            {
+                // Do something for handle market depth changing.
+            }
+        }
+
+        private void PlaceOrder()
+        {
+            bool positivePosition = Account.GetTraderInfo(Smbl).PositionType == DigitexWire.OrderPosition.Long;
+            decimal price;
+            DigitexWire.OrderSide side;
+
+            if (positivePosition)
+            {
+                price = OBook.GetBestAskPrice() ?? OBook.AdjustedSpotPrice;
+                side = DigitexWire.OrderSide.Sell;
+            }
+            else
+            {
+                price = OBook.GetBestBidPrice() ?? OBook.AdjustedSpotPrice;
+                side = DigitexWire.OrderSide.Buy;
+            }
+
+            OrderBase order = PlaceOrderLimit(Smbl, side, 1, price, OrderStatusHandler, ErrorHandler);
+
+            Console.WriteLine($"Place {order?.OrigClientId} - {(order is null ? "fail" : "success")}");
+        }
+
+        private void OrderStatusHandler(OrderBase order)
+        {
+            // Do something for handle order status changing.
+
+            Console.WriteLine($"Order {order.OrigClientId} is {order.Status}");
+
+            // Use OrigClientId for comparison of orders.
+        }
+
+        private void ErrorHandler(OrderBase order, ErrorCodes code)
+        {
+            // Do something for handle order errors.
+
+            Console.WriteLine($"Error {code}, order {order.OrigClientId}");
+        }
+
+        public override List<ModuleState> GetParams()
+        {
+            return new List<ModuleState>()
+            {
+                new ModuleState("interval", "10")
+            };
+        }
+
+        public override void SetAlgoArguments(Dictionary<string, string> algoArguments)
+        {
+            if (algoArguments.ContainsKey("interval")) { Interval = int.Parse(algoArguments["interval"]); }
+        }
+
+        public override void Stop()
+        {
+            TradingTimer.Dispose();
+        }
+
+        public override void OnDispose()
+        {
+            TradingTimer?.Dispose();
+        }
+    }
+}

Example/Program.cs

@@ -0,0 +1,21 @@
+using System;
+
+namespace Example
+{
+    class Program
+    {
+        static void Main(string[] args)
+        {
+            // for mainnet set host to "ws.mainnet.digitexfutures.com"
+            string host = "ws.testnet.digitexfutures.com";
+            bool wss = true;
+            string token = "d030b17c9b993107399eb19121daea0f04e4b476";
+
+            IntervalAlgorithm algorithm = new IntervalAlgorithm(host, token, wss);
+            algorithm.Prepare();
+            algorithm.Connect();
+
+            while (Console.ReadKey().Key != ConsoleKey.Q) { }
+        }
+    }
+}