Valve sockets networking

Nebula.sln

@@ -19,18 +19,22 @@ Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "Solution Items", "Solution
 EndProject
 Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "NebulaWorld", "NebulaWorld\NebulaWorld.csproj", "{28AEA139-FB22-4672-AF51-28B728CF2978}"
 EndProject
-Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "websocket-sharp", "dep\websocket-sharp\websocket-sharp\websocket-sharp.csproj", "{B357BAC7-529E-4D81-A0D2-71041B19C8DE}"
-EndProject
 Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "NebulaNetwork", "NebulaNetwork\NebulaNetwork.csproj", "{36A3D8AE-2A0A-4A1F-8A65-4FB61B01F779}"
 EndProject
-Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "NebulaAPI", "NebulaAPI\NebulaAPI.csproj", "{B59DB3BB-DBA2-42AF-B4F1-32A9A6A273D2}"
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "NebulaAPI", "NebulaAPI\NebulaAPI.csproj", "{B59DB3BB-DBA2-42AF-B4F1-32A9A6A273D2}"
+EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "ValveSockets", "dep\valve.sockets\ValveSockets.csproj", "{D4EEDD8E-0ED6-4426-A3F0-3642A04434D6}"
 EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
 		Debug|Any CPU = Debug|Any CPU
 		Release|Any CPU = Release|Any CPU
 	EndGlobalSection
 	GlobalSection(ProjectConfigurationPlatforms) = postSolution
+		{47B9362C-E91B-4AE4-979B-7D811AB4D1EA}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{47B9362C-E91B-4AE4-979B-7D811AB4D1EA}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{47B9362C-E91B-4AE4-979B-7D811AB4D1EA}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{47B9362C-E91B-4AE4-979B-7D811AB4D1EA}.Release|Any CPU.Build.0 = Release|Any CPU
 		{C6237195-F77C-40C0-B06A-4AD51CAD314D}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
 		{C6237195-F77C-40C0-B06A-4AD51CAD314D}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{C6237195-F77C-40C0-B06A-4AD51CAD314D}.Release|Any CPU.ActiveCfg = Release|Any CPU
@@ -39,22 +43,18 @@ Global
 		{28AEA139-FB22-4672-AF51-28B728CF2978}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{28AEA139-FB22-4672-AF51-28B728CF2978}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{28AEA139-FB22-4672-AF51-28B728CF2978}.Release|Any CPU.Build.0 = Release|Any CPU
-		{B357BAC7-529E-4D81-A0D2-71041B19C8DE}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
-		{B357BAC7-529E-4D81-A0D2-71041B19C8DE}.Debug|Any CPU.Build.0 = Debug|Any CPU
-		{B357BAC7-529E-4D81-A0D2-71041B19C8DE}.Release|Any CPU.ActiveCfg = Release|Any CPU
-		{B357BAC7-529E-4D81-A0D2-71041B19C8DE}.Release|Any CPU.Build.0 = Release|Any CPU
 		{36A3D8AE-2A0A-4A1F-8A65-4FB61B01F779}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
 		{36A3D8AE-2A0A-4A1F-8A65-4FB61B01F779}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{36A3D8AE-2A0A-4A1F-8A65-4FB61B01F779}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{36A3D8AE-2A0A-4A1F-8A65-4FB61B01F779}.Release|Any CPU.Build.0 = Release|Any CPU
-		{47B9362C-E91B-4AE4-979B-7D811AB4D1EA}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
-		{47B9362C-E91B-4AE4-979B-7D811AB4D1EA}.Debug|Any CPU.Build.0 = Debug|Any CPU
-		{47B9362C-E91B-4AE4-979B-7D811AB4D1EA}.Release|Any CPU.ActiveCfg = Release|Any CPU
-		{47B9362C-E91B-4AE4-979B-7D811AB4D1EA}.Release|Any CPU.Build.0 = Release|Any CPU
 		{B59DB3BB-DBA2-42AF-B4F1-32A9A6A273D2}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
 		{B59DB3BB-DBA2-42AF-B4F1-32A9A6A273D2}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{B59DB3BB-DBA2-42AF-B4F1-32A9A6A273D2}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{B59DB3BB-DBA2-42AF-B4F1-32A9A6A273D2}.Release|Any CPU.Build.0 = Release|Any CPU
+		{D4EEDD8E-0ED6-4426-A3F0-3642A04434D6}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{D4EEDD8E-0ED6-4426-A3F0-3642A04434D6}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{D4EEDD8E-0ED6-4426-A3F0-3642A04434D6}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{D4EEDD8E-0ED6-4426-A3F0-3642A04434D6}.Release|Any CPU.Build.0 = Release|Any CPU
 	EndGlobalSection
 	GlobalSection(SolutionProperties) = preSolution
 		HideSolutionNode = FALSE

NebulaAPI/Packets/NetworkOptionAttributes.cs

@@ -0,0 +1,10 @@
+using System;
+
+namespace NebulaAPI
+{
+    [AttributeUsage(AttributeTargets.Class, AllowMultiple = false)]
+    public class NetworkOptionsAttribute : Attribute 
+    {
+        public bool Reliable = true;
+    }
+}

NebulaModel/NebulaModel.csproj

@@ -1,7 +1,7 @@
 <?xml version="1.0" encoding="utf-8"?>
 <Project Sdk="Microsoft.NET.Sdk">
   <ItemGroup>
-    <ProjectReference Include="..\dep\websocket-sharp\websocket-sharp\websocket-sharp.csproj" />
+    <ProjectReference Include="..\dep\valve.sockets\ValveSockets.csproj" />
     <ProjectReference Include="..\NebulaAPI\NebulaAPI.csproj" Private="false" />
   </ItemGroup>
 

NebulaModel/NetworkProvider.cs

@@ -1,6 +1,9 @@
 using NebulaAPI;
+using NebulaModel.Logger;
 using NebulaModel.Networking.Serialization;
 using System;
+using System.Threading;
+using Valve.Sockets;
 
 namespace NebulaModel
 {
@@ -10,12 +13,67 @@ public abstract class NetworkProvider : IDisposable, INetworkProvider
 
         public IPlayerManager PlayerManager { get; }
 
+        protected static NetworkingSockets Sockets { get; private set; }
+
+        protected static NetworkingUtils Utils { get; private set; }
+
+        protected static NetworkProvider Provider { get; set; }
+
+        protected static Thread Worker { get; private set; }
+
+        protected static bool ShouldPoll { get; set; } = false;
+
+        static NetworkProvider()
+        {
+            Library.Initialize();
+
+            Sockets = new NetworkingSockets();
+            Utils = new NetworkingUtils();
+
+#if DEBUG
+            Utils.SetDebugCallback(DebugType.Everything, (DebugType type, string message) =>
+            {
+                Log.Debug(message);
+            });
+#endif
+
+            // We have to store a static instance to the current NetworkProvider as this callback comes from native code and 
+            // therefore has to be a flat cdecl call, it cannot capture anything or have any context
+            Utils.SetStatusCallback((ref StatusInfo info) =>
+            {
+                Provider?.OnEvent(ref info);
+            });
+
+            // Set high speeds
+            Configuration configSendRateMax = new Configuration();
+            configSendRateMax.data.Int32 = 0x10000000;
+            configSendRateMax.dataType = ConfigurationDataType.Int32;
+            configSendRateMax.value = ConfigurationValue.SendRateMax;
+
+            Configuration configSendRateMin = new Configuration();
+            configSendRateMin.data.Int32 = 5 * 1024 * 1024; // Make it user configurable?
+            configSendRateMin.dataType = ConfigurationDataType.Int32;
+            configSendRateMin.value = ConfigurationValue.SendRateMin;
+
+            Configuration configSendBuffer = new Configuration();
+            configSendBuffer.data.Int32 = 0x1000000;
+            configSendBuffer.dataType = ConfigurationDataType.Int32;
+            configSendBuffer.value = ConfigurationValue.SendBufferSize;
+
+            Utils.SetConfigurationValue(configSendRateMax, ConfigurationScope.Global, new IntPtr());
+            Utils.SetConfigurationValue(configSendRateMin, ConfigurationScope.Global, new IntPtr());
+            Utils.SetConfigurationValue(configSendBuffer, ConfigurationScope.Global, new IntPtr());
+        }
+
         protected NetworkProvider(IPlayerManager playerManager)
         {
+            Provider = this;
             PacketProcessor = new NetPacketProcessor();
             PlayerManager = playerManager;
         }
 
+        protected abstract void OnEvent(ref StatusInfo info);
+
         public abstract void Start();
 
         public abstract void Stop();