Added trend bars call to console app

Author: Ahmad Noman Musleh

src/Console.Sample/Program.cs

@@ -103,7 +103,6 @@ private static async Task Main()
                 ShowDashLine();
 
                 Console.WriteLine($"Access token generated: {_token.AccessToken}");
-
             }
 
             var host = ApiInfo.GetHost(mode);
@@ -192,6 +191,7 @@ private static void ProcessCommand(string command)
                         Console.WriteLine("For getting an account symbols list type (Requires account authorization): symbolslist {Account ID}\n");
                         Console.WriteLine("For subscribing to symbol(s) spot quotes type (Requires account authorization): subscribe spot {Account ID} {Symbol ID,}\n");
                         Console.WriteLine("For subscribing to symbol(s) trend bar type (Requires account authorization and spot subscription): subscribe trendbar {Period} {Account ID} {Symbol ID}\n");
+                        Console.WriteLine("For getting trend bar data: trendbar {Period} {Account ID} {Symbol ID} {numberOfDays}\n");
                         Console.WriteLine("For trend bar period parameter, you can use these values:\n");
 
                         var trendbars = Enum.GetValues(typeof(ProtoOATrendbarPeriod)).Cast<ProtoOATrendbarPeriod>();
@@ -239,6 +239,10 @@ private static void ProcessCommand(string command)
                         ProcessSubscriptionCommand(commandSplit);
                         break;
 
+                    case "trendbar":
+                        TrendbarRequest(commandSplit);
+                        break;
+
                     case "tickdata":
                         TickDataRequest(commandSplit);
                         break;
@@ -424,6 +428,30 @@ private static async void TickDataRequest(string[] commandSplit)
             await _client.SendMessage(request);
         }
 
+        private static async void TrendbarRequest(string[] commandSplit)
+        {
+            var period = (ProtoOATrendbarPeriod)Enum.Parse(typeof(ProtoOATrendbarPeriod), commandSplit[1], true);
+            var accountId = long.Parse(commandSplit[2]);
+            var symbolId = long.Parse(commandSplit[3]);
+
+            var days = long.Parse(commandSplit[4]);
+
+            Console.WriteLine("Sending ProtoOAGetTrendbarsReq...");
+
+            var request = new ProtoOAGetTrendbarsReq
+            {
+                CtidTraderAccountId = accountId,
+                SymbolId = symbolId,
+                Period = period,
+                FromTimestamp = DateTimeOffset.UtcNow.AddDays(-days).ToUnixTimeMilliseconds(),
+                ToTimestamp = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds(),
+            };
+
+            Console.WriteLine($"FromTimestamp: {request.FromTimestamp} | ToTimestamp: {request.ToTimestamp}");
+
+            await _client.SendMessage(request);
+        }
+
         private static async void ProfileRequest()
         {
             Console.WriteLine("Sending ProtoOAGetCtidProfileByTokenReq...");

src/OpenAPI.Net/OpenClient.cs

@@ -43,7 +43,6 @@ public sealed class OpenClient : IDisposable, IObservable<IMessage>
 
         private IDisposable _webSocketMessageReceivedDisposable;
 
-
         /// <summary>
         /// Creates an instance of OpenClient which is not connected yet
         /// </summary>
@@ -56,7 +55,7 @@ public OpenClient(string host, int port, TimeSpan heartbeatInerval, int maxReque
         {
             Host = host ?? throw new ArgumentNullException(nameof(host));
 
-            if (port < 0 || port > 65535) throw new ArgumentOutOfRangeException(nameof(port));
+            if (port is < 0 or > 65535) throw new ArgumentOutOfRangeException(nameof(port));
 
             Port = port;
 
@@ -137,7 +136,7 @@ public async Task Connect()
                 _heartbeatDisposable = Observable.Interval(_heartbeatInerval).DoWhile(() => !IsDisposed)
                     .Subscribe(x => SendHeartbeat());
             }
-            catch(Exception ex)
+            catch (Exception ex)
             {
                 var connectionException = new ConnectionException(ex);
 
@@ -173,7 +172,7 @@ public IDisposable Subscribe(IObserver<IMessage> observer)
         public async Task SendMessage<T>(T message, string clientMsgId = null) where T : IMessage
         {
             var protoMessage = MessageFactory.GetMessage(message.GetPayloadType(), message.ToByteString(), clientMsgId);
-            
+
             await SendMessage(protoMessage);
         }
 
@@ -439,7 +438,7 @@ private async void ReadTcp(CancellationToken cancellationToken)
         private int GetLength(byte[] lengthBytes)
         {
             var lengthSpan = lengthBytes.AsSpan();
-            
+
             lengthSpan.Reverse();
 
             return BitConverter.ToInt32(lengthSpan);