Fixed TCP mode disconnection issue

Author: Ahmad Noman Musleh

src/ASP.NET.Sample/README.md

@@ -16,6 +16,4 @@ The app will load your Open API application credentials and it will use it.
 
 You have to also add your web app host URL in your API application redirect URIs, otherwise the account authorization will not work and you will get an error.
 
-The application default URL is set to https://localhost:5001/ and http://localhost:5000/, add both to your API application redirect URIs.
-
 You can find the application URL on project/properties/launchSettings.json file, you can change it from there if you want to.

src/ASP.NET.Sample/appsettings-dev.json

@@ -1,6 +1,6 @@
 {
   "ApiCredentials": {
-    "ClientId": "2175_xzl5IOUElxoQJSXIOrJz7Da65B0bFv8K9xLjYhL7eO85sKT885",
-    "Secret": "pA5Yova9jEpzgVMYCjTrS54LCX31MD0chqO94wDScE1qHgko3C"
+    "ClientId": "699_9UIX3RJWkl3BwGfKi30xzfiyCaMkEA1FLKD020gy57i4e3XplL",
+    "Secret": "dfJVd3Ud1HkLcQJaLPx5fmEqR8iUkmLYeCBikQUa6J3bJH2Jce"
   }
 }

src/Blazor.WebSocket.Sample/Pages/Index.razor

@@ -427,8 +427,6 @@
         await Task.Delay(1000);
 
         await ApiCredentialsModal.Open();
-
-        ApiService.Error += exception => Console.Error.WriteLine($"API Service Exception: {exception}");
     }
 
     private async Task Connect()

src/OpenAPI.Net/OpenAPI.Net.csproj

@@ -9,7 +9,7 @@
     <PackageTags>cTrader, Open API, Spotware</PackageTags>
     <Description>A .NET RX library for Spotware Open API</Description>
     <PackageId>Spotware.OpenAPI.Net</PackageId>
-    <Version>1.3.4</Version>
+    <Version>1.3.5</Version>
     <Platforms>AnyCPU</Platforms>
     <Company>Spotware</Company>
     <Authors>Spotware</Authors>

src/OpenAPI.Net/OpenClient.cs

@@ -258,17 +258,13 @@ public async Task SendMessageInstant(ProtoMessage message)
             {
                 var messageByte = message.ToByteArray();
 
-                var length = BitConverter.GetBytes(messageByte.Length);
-
-                Array.Reverse(length);
-
                 if (UseWebSocket)
                 {
                     _websocketClient.Send(messageByte);
                 }
                 else
                 {
-                    await WriteTcp(messageByte, length);
+                    await WriteTcp(messageByte);
                 }
 
                 LastSentMessageTime = DateTimeOffset.Now;
@@ -406,15 +402,15 @@ private async Task<ProtoMessage> ReadTcp()
         /// <param name="messageByte"></param>
         /// <param name="length"></param>
         /// <returns>Task</returns>
-        private async Task WriteTcp(byte[] messageByte, byte[] length)
+        private async Task WriteTcp(byte[] messageByte)
         {
             ThrowObjectDisposedExceptionIfDisposed();
 
             try
             {
-                await _sslStream.WriteAsync(length, 0, length.Length).ConfigureAwait(false);
+                var data = BitConverter.GetBytes(messageByte.Length).Reverse().Concat(messageByte).ToArray();
 
-                await _sslStream.WriteAsync(messageByte, 0, messageByte.Length).ConfigureAwait(false);
+                await _sslStream.WriteAsync(data, 0, data.Length).ConfigureAwait(false);
             }
             catch (Exception ex)
             {