add frame delimiter

Author: erwan-joly

src/NosCore.Networking/Encoding/FrameDelimiter.cs

@@ -0,0 +1,48 @@
+//  __  _  __    __   ___ __  ___ ___
+// |  \| |/__\ /' _/ / _//__\| _ \ __|
+// | | ' | \/ |`._`.| \_| \/ | v / _|
+// |_|\__|\__/ |___/ \__/\__/|_|_\___|
+// -----------------------------------
+
+using System.Collections.Generic;
+using DotNetty.Buffers;
+using DotNetty.Codecs;
+using DotNetty.Transport.Channels;
+using NosCore.Networking.SessionRef;
+
+namespace NosCore.Networking.Encoding;
+
+public class FrameDelimiter : ByteToMessageDecoder
+{
+    private readonly ISessionRefHolder _sessionRefHolder;
+    private readonly IPipelineConfiguration _pipelineConfiguration;
+
+    public FrameDelimiter(ISessionRefHolder sessionRefHolder, IPipelineConfiguration pipelineConfiguration)
+    {
+        _sessionRefHolder = sessionRefHolder;
+        _pipelineConfiguration = pipelineConfiguration;
+    }
+
+    protected override void Decode(IChannelHandlerContext context, IByteBuffer input, List<object> output)
+    {
+        var sessionId = context.Channel.Id.AsLongText();
+        var mapper = _sessionRefHolder[sessionId];
+
+        var currentDelimiter = mapper.SessionId == 0 ? (byte)0xE : unchecked((byte)((_pipelineConfiguration.Delimiter ?? 0) + mapper.SessionId));
+
+        var startReaderIndex = input.ReaderIndex;
+        var endReaderIndex = startReaderIndex + input.ReadableBytes;
+
+        for (var i = startReaderIndex; i < endReaderIndex; i++)
+        {
+            if (input.GetByte(i) == currentDelimiter)
+            {
+                var frameLength = i - startReaderIndex + 1;
+                var frame = input.Copy(startReaderIndex, frameLength);
+                output.Add(frame);
+                input.SetReaderIndex(i + 1);
+                break;
+            }
+        }
+    }
+}

…/NosCore.Networking/IRequestDelimiter.cs …ore.Networking/IPipelineConfiguration.cssrc/NosCore.Networking/IRequestDelimiter.cs renamed to src/NosCore.Networking/IPipelineConfiguration.cs src/NosCore.Networking/IRequestDelimiter.cs renamed to src/NosCore.Networking/IPipelineConfiguration.cs

@@ -12,7 +12,7 @@
 		<RepositoryUrl>https://github.com/NosCoreIO/NosCore.Networking.git</RepositoryUrl>
 		<PackageIconUrl></PackageIconUrl>
 		<PackageTags>nostale, noscore, nostale private server source, nostale emulator</PackageTags>
-		<Version>4.0.4</Version>
+		<Version>5.0.0</Version>
 		<PackageRequireLicenseAcceptance>false</PackageRequireLicenseAcceptance>
 		<Description>NosCore Networking</Description>
 		<PackageLicenseExpression>MIT</PackageLicenseExpression>

src/NosCore.Networking/NosCore.Networking.csproj

@@ -54,9 +54,8 @@ public void CreatePipeline()
 
             if (_pipelineConfiguration.Delimiter != null)
             {
-                pipeline.AddLast(new DelimiterBasedFrameDecoder(8192, new[] {
-                    Unpooled.WrappedBuffer(new[] { (byte)_pipelineConfiguration.Delimiter })
-                }));
+
+                pipeline.AddLast(new FrameDelimiter(_sessionRefHolder, _pipelineConfiguration));
             }
 
             pipeline.AddLast(_decoder);