Fix fob property for dxlink scheme (#93)

Author: stdcion

NuGet.Config

@@ -3,6 +3,5 @@
 <configuration>
   <packageSources>
     <add key="nuget.org" value="https://api.nuget.org/v3/index.json" protocolVersion="3" />
-    <add key="dxFeed" value="https://dxfeed.jfrog.io/artifactory/api/nuget/v3/nuget-open" protocolVersion="3" />
   </packageSources>
 </configuration>

README.md

@@ -318,7 +318,7 @@ using DxFeed.Graal.Net.Events.Market;
 // Enable experimental feature.
 SystemProperty.SetProperty("dxfeed.experimental.dxlink.enable", "true");
 // Set scheme for dxLink.
-SystemProperty.SetProperty("scheme", "ext:opt:sysprops,resource:dxlink.xml");
+SystemProperty.SetProperty("scheme", "ext:opt:sysprops,opt:dxprops,resource:dxlink.xml");
 
 // For token-based authorization, use the following address format:
 // "dxlink:wss://demo.dxfeed.com/dxlink-ws[login=dxlink:token]"

samples/dxfeed.system.properties

@@ -6,7 +6,7 @@ dxfeed.address=demo.dxfeed.com:7300
 
 # Required properties for connect to dxLink
 #dxfeed.experimental.dxlink.enable=true
-#scheme=ext:opt:sysprops,resource:dxlink.xml
+#scheme=ext:opt:sysprops,opt:dxprops,resource:dxlink.xml
 
 # Connect to demo dxLink endpoint
 #dxfeed.address=dxlink:wss://demo.dxfeed.com/dxlink-ws

src/DxFeed.Graal.Net.Tools/Program.cs

@@ -14,7 +14,7 @@ public static void Main(string[] args)
     {
         SystemProperty.SetProperty(DXEndpoint.DXFeedWildcardEnableProperty, "true");
         SystemProperty.SetProperty("dxfeed.experimental.dxlink.enable", "true");
-        SystemProperty.SetProperty("scheme", "ext:opt:sysprops,resource:dxlink.xml");
+        SystemProperty.SetProperty("scheme", "ext:opt:sysprops,opt:dxprops,resource:dxlink.xml");
         Tools.Run(args);
     }
 }

src/DxFeed.Graal.Net/DxFeed.Graal.Net.csproj

@@ -29,7 +29,7 @@
     <PackageReference Include="Microsoft.Extensions.Configuration.Ini" Version="8.0.0" />
     <PackageReference Include="Microsoft.Extensions.Configuration.EnvironmentVariables" Version="8.0.0" />
     <PackageReference Include="System.Collections.Immutable" Version="8.0.0"/>
-    <PackageReference Include="DxFeed.Graal.Native" Version="3.2.0" />
+    <PackageReference Include="DxFeed.Graal.Native" Version="3.2.10" />
   </ItemGroup>
 
 </Project>

tests/DxFeed.Graal.Net.Tests/Api/DXEndpointTest.cs

@@ -4,6 +4,8 @@
 // If a copy of the MPL was not distributed with this file, You can obtain one at http://mozilla.org/MPL/2.0/.
 // </copyright>
 
+using System.Net;
+using System.Net.Sockets;
 using DxFeed.Graal.Net.Api;
 using DxFeed.Graal.Net.Api.Osub;
 using DxFeed.Graal.Net.Events;
@@ -17,27 +19,45 @@ namespace DxFeed.Graal.Net.Tests.Api;
 [TestFixture]
 public class DXEndpointTest
 {
-    private static readonly Random rnd = new();
-
     [Test]
     public void ConnectToLocalPublisher()
     {
-        var port = rnd.Next(48658, 49150);
+        var port = GetFreePort();
         var countdownEvent = new CountdownEvent(1);
 
         var pub = Create(Publisher).Connect($":{port}");
         var feed = Create(Feed);
-        feed.AddStateChangeListener((_, newState) =>
+        try
         {
-            if (newState == State.Connected)
+            feed.AddStateChangeListener((_, newState) =>
             {
-                countdownEvent.Signal();
-            }
-        });
-        feed.Connect($"localhost:{port}");
-        Assert.That(countdownEvent.Wait(new TimeSpan(0, 0, 3)), Is.True);
-        pub.Close();
-        feed.Close();
+                if (newState == State.Connected)
+                {
+                    countdownEvent.Signal();
+                }
+            });
+            feed.Connect($"localhost:{port}");
+            Assert.That(countdownEvent.Wait(new TimeSpan(0, 0, 10)), Is.True);
+        }
+        finally
+        {
+            pub.Close();
+            feed.Close();
+        }
+    }
+
+    private static int GetFreePort()
+    {
+        var listener = new TcpListener(IPAddress.Loopback, 0);
+        listener.Start();
+        try
+        {
+            return ((IPEndPoint)listener.LocalEndpoint).Port;
+        }
+        finally
+        {
+            listener.Stop();
+        }
     }
 
     [Test]
@@ -222,7 +242,7 @@ public void CheckOtcMarketsOrder()
         publisher.PublishEvents(order1);
         publisher.PublishEvents(order2);
 
-        cde.Wait(3000);
+        Assert.That(cde.Wait(TimeSpan.FromSeconds(10)), Is.True, "Expected both published orders to be received");
 
         foreach (var eventType in resultList)
         {