Added protocol version support

Author: sakno

src/cluster/DotNext.Net.Cluster/ExceptionMessages.cs

@@ -59,5 +59,5 @@ internal static string UnknownRaftMessageType<T>(T messageType)
 
     internal static string ConnectionTimedOut => (string)Resources.Get();
 
-    internal static string PipeTimedOut => (string)Resources.Get();
+    internal static string BadProtocolVersion(byte version) => Resources.Get().Format(version);
 }

src/cluster/DotNext.Net.Cluster/ExceptionMessages.restext

@@ -21,4 +21,4 @@ InvalidPartitionFormat=Partition has invalid binary format or broken
 StreamRejected=The stream has been rejected by the server due to overflow of its backlog
 ConnectionClosed=The underlying connection is closed
 ConnectionTimedOut=The data cannot be sent or received on time
-PipeTimedOut=The data cannot be written on time
+BadProtocolVersion=Multiplexing protocol version is not supported: {0}

src/cluster/DotNext.Net.Cluster/Net/Multiplexing/FrameHeader.cs

@@ -14,12 +14,14 @@ namespace DotNext.Net.Multiplexing;
 [StructLayout(LayoutKind.Auto)]
 internal readonly struct FrameHeader(ulong id, FrameControl control, ushort length) : IBinaryFormattable<FrameHeader>
 {
+    private const byte CurrentVersion = 0;
+    
     /// <summary>
     /// All protocol-specific fragments have ID = 0.
     /// </summary>
     public const ulong SystemStreamId = 0U;
-    
-    public const int Size = sizeof(ulong) + sizeof(FrameControl) + sizeof(ushort);
+
+    public const int Size = sizeof(byte) + sizeof(ulong) + sizeof(FrameControl) + sizeof(ushort);
 
     public ulong Id => id; // if 0, then the packet is protocol-specific
     public FrameControl Control => control;
@@ -32,6 +34,7 @@ internal readonly struct FrameHeader(ulong id, FrameControl control, ushort leng
     public void Format(Span<byte> destination)
     {
         var writer = new SpanWriter<byte>(destination);
+        writer.Add(CurrentVersion);
         writer.WriteLittleEndian(id);
         writer.WriteLittleEndian((ushort)control);
         writer.WriteLittleEndian(length);
@@ -40,6 +43,11 @@ public void Format(Span<byte> destination)
     public static FrameHeader Parse(ReadOnlySpan<byte> source)
     {
         var reader = new SpanReader<byte>(source);
+        var version = reader.Read();
+
+        if (version > CurrentVersion)
+            throw new UnsupportedVersionException(version);
+        
         return new(
             reader.ReadLittleEndian<ulong>(),
             (FrameControl)reader.ReadLittleEndian<ushort>(),

src/cluster/DotNext.Net.Cluster/Net/Multiplexing/MultiplexingProtocolException.cs

@@ -22,4 +22,15 @@ internal StreamRejectedException()
         : base(ExceptionMessages.StreamRejected)
     {
     }
+}
+
+/// <summary>
+/// Indicates that the protocol version is not supported.
+/// </summary>
+public sealed class UnsupportedVersionException : MultiplexingProtocolException
+{
+    internal UnsupportedVersionException(byte version)
+        : base(ExceptionMessages.BadProtocolVersion(version))
+    {
+    }
 }