feat: update to LiteNetLib 2.0

Author: insthync

Plugins/LiteNetLib/BaseChannel.cs

@@ -5,16 +5,14 @@ namespace LiteNetLib
 {
     internal abstract class BaseChannel
     {
-        protected readonly NetPeer Peer;
+        protected readonly LiteNetPeer Peer;
         protected readonly Queue<NetPacket> OutgoingQueue = new Queue<NetPacket>(NetConstants.DefaultWindowSize);
         private int _isAddedToPeerChannelSendQueue;
 
         public int PacketsInQueue => OutgoingQueue.Count;
 
-        protected BaseChannel(NetPeer peer)
-        {
+        protected BaseChannel(LiteNetPeer peer) =>
             Peer = peer;
-        }
 
         public void AddToQueue(NetPacket packet)
         {
@@ -28,9 +26,7 @@ public void AddToQueue(NetPacket packet)
         protected void AddToPeerChannelSendQueue()
         {
             if (Interlocked.CompareExchange(ref _isAddedToPeerChannelSendQueue, 1, 0) == 0)
-            {
                 Peer.AddToReliableChannelSendQueue(this);
-            }
         }
 
         public bool SendAndCheckQueue()
@@ -42,7 +38,8 @@ public bool SendAndCheckQueue()
             return hasPacketsToSend;
         }
 
-        protected abstract bool SendNextPackets();
+        public abstract bool SendNextPackets();
+
         public abstract bool ProcessPacket(NetPacket packet);
     }
 }

Plugins/LiteNetLib/ConnectionRequest.cs

@@ -14,7 +14,7 @@ internal enum ConnectionRequestResult
 
     public class ConnectionRequest
     {
-        private readonly NetManager _listener;
+        private readonly LiteNetManager _listener;
         private int _used;
 
         public NetDataReader Data => InternalPacket.Data;
@@ -37,19 +37,17 @@ internal void UpdateRequest(NetConnectRequestPacket connectRequest)
             InternalPacket = connectRequest;
         }
 
-        private bool TryActivate()
-        {
-            return Interlocked.CompareExchange(ref _used, 1, 0) == 0;
-        }
+        private bool TryActivate() =>
+            Interlocked.CompareExchange(ref _used, 1, 0) == 0;
 
-        internal ConnectionRequest(IPEndPoint remoteEndPoint, NetConnectRequestPacket requestPacket, NetManager listener)
+        internal ConnectionRequest(IPEndPoint remoteEndPoint, NetConnectRequestPacket requestPacket, LiteNetManager listener)
         {
             InternalPacket = requestPacket;
             RemoteEndPoint = remoteEndPoint;
             _listener = listener;
         }
 
-        public NetPeer AcceptIfKey(string key)
+        public LiteNetPeer AcceptIfKey(string key)
         {
             if (!TryActivate())
                 return null;
@@ -74,7 +72,7 @@ public NetPeer AcceptIfKey(string key)
         /// Accept connection and get new NetPeer as result
         /// </summary>
         /// <returns>Connected NetPeer</returns>
-        public NetPeer Accept()
+        public LiteNetPeer Accept()
         {
             if (!TryActivate())
                 return null;
@@ -90,45 +88,28 @@ public void Reject(byte[] rejectData, int start, int length, bool force)
             _listener.OnConnectionSolved(this, rejectData, start, length);
         }
 
-        public void Reject(byte[] rejectData, int start, int length)
-        {
+        public void Reject(byte[] rejectData, int start, int length) =>
             Reject(rejectData, start, length, false);
-        }
-
 
-        public void RejectForce(byte[] rejectData, int start, int length)
-        {
+        public void RejectForce(byte[] rejectData, int start, int length) =>
             Reject(rejectData, start, length, true);
-        }
 
-        public void RejectForce()
-        {
+        public void RejectForce() =>
             Reject(null, 0, 0, true);
-        }
 
-        public void RejectForce(byte[] rejectData)
-        {
+        public void RejectForce(byte[] rejectData) =>
             Reject(rejectData, 0, rejectData.Length, true);
-        }
 
-        public void RejectForce(NetDataWriter rejectData)
-        {
+        public void RejectForce(NetDataWriter rejectData) =>
             Reject(rejectData.Data, 0, rejectData.Length, true);
-        }
 
-        public void Reject()
-        {
+        public void Reject() =>
             Reject(null, 0, 0, false);
-        }
 
-        public void Reject(byte[] rejectData)
-        {
+        public void Reject(byte[] rejectData) =>
             Reject(rejectData, 0, rejectData.Length, false);
-        }
 
-        public void Reject(NetDataWriter rejectData)
-        {
+        public void Reject(NetDataWriter rejectData) =>
             Reject(rejectData.Data, 0, rejectData.Length, false);
-        }
     }
 }