wip

fix: websocket server now can receive large messages
fix: buffer resize on read array

.github/workflows/main.yml

@@ -49,7 +49,7 @@ jobs:
       - name: Setup dotnet
         uses: actions/setup-dotnet@v1
         with:
-          dotnet-version: 7.0.x
+          dotnet-version: 8.0.x
       - name: Build
         shell: bash
         run: |

Ragon.Client.Property/Ragon.Client.Property.csproj

@@ -1,13 +0,0 @@
-<Project Sdk="Microsoft.NET.Sdk">
-
-    <PropertyGroup>
-        <TargetFramework>net7.0</TargetFramework>
-        <ImplicitUsings>enable</ImplicitUsings>
-        <Nullable>enable</Nullable>
-    </PropertyGroup>
-
-    <ItemGroup>
-      <ProjectReference Include="..\Ragon.Client\Ragon.Client.csproj" />
-    </ItemGroup>
-
-</Project>

Ragon.Client.Property/Sources/RagonBool.cs

@@ -1,60 +0,0 @@
-/*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-
-using Ragon.Protocol;
-
-namespace Ragon.Client.Property
-{
-  [Serializable]
-  public class RagonBool : RagonProperty
-  {
-    public bool Value
-    {
-      get => _value;
-      set
-      {
-        _value = value;
-        
-        MarkAsChanged();
-      }
-    }
-
-    private bool _value;
-
-    public RagonBool(
-      bool initialValue,
-      bool invokeLocal = true,
-      int priority = 0
-    ) : base(priority, invokeLocal)
-    {
-      _value = initialValue;
-      SetFixedSize(1);
-    }
-
-    public override void Serialize(RagonBuffer buffer)
-    {
-      buffer.WriteBool(_value);
-    }
-
-    public override void Deserialize(RagonBuffer buffer)
-    {
-      _value = buffer.ReadBool();
-
-      InvokeChanged();
-    }
-  }
-}

Ragon.Client.Property/Sources/RagonFloat.cs

@@ -1,104 +0,0 @@
-/*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-
-using Ragon.Protocol;
-
-namespace Ragon.Client
-{
-  [Serializable]
-  public class RagonFloat : RagonProperty
-  {
-    public float Value
-    {
-      get => _value;
-      set
-      {
-        _value = value;
-
-        if (_value < _min)
-          _value = _min;
-        else if (_value > _max)
-          _value = _max;
-
-        MarkAsChanged();
-      }
-    }
-
-    private float _value;
-    private float _min;
-    private float _max;
-    private int _requiredBits;
-    private float _precision;
-    private uint _mask;
-
-    public RagonFloat(
-      float initialValue,
-      bool invokeLocal = true,
-      int priority = 0
-    ) : base(priority, invokeLocal)
-    {
-      _value = initialValue;
-      _min = -1024.0f;
-      _max = 1024.0f;
-      _precision = 0.01f;
-
-      _requiredBits = DeBruijn.Log2((uint)((_max - _min) * (1.0f / _precision) + 0.5f)) + 1;
-      _mask = (uint)((1L << _requiredBits) - 1);
-
-      SetFixedSize(_requiredBits);
-    }
-
-    public RagonFloat(
-      float initialValue,
-      float min = -1024.0f,
-      float max = 1024.0f,
-      float precision = 0.01f,
-      bool invokeLocal = true,
-      int priority = 0
-    ) : base(priority, invokeLocal)
-    {
-      _value = initialValue;
-      _min = min;
-      _max = max;
-      _precision = precision;
-
-      _requiredBits = DeBruijn.Log2((uint)((_max - _min) * (1.0f / _precision) + 0.5f)) + 1;
-      _mask = (uint)((1L << _requiredBits) - 1);
-
-      SetFixedSize(_requiredBits);
-    }
-
-    public override void Serialize(RagonBuffer buffer)
-    {
-      var compressedValue = (uint)((_value - _min) * (1f / _precision) + 0.5f) & _mask;
-      buffer.Write(compressedValue, _requiredBits);
-    }
-
-    public override void Deserialize(RagonBuffer buffer)
-    {
-      var compressedValue = buffer.Read(_requiredBits);
-      _value = compressedValue * _precision + _min;
-
-      if (_value < _min)
-        _value = _min;
-      else if (_value > _max)
-        _value = _max;
-      
-      InvokeChanged();
-    }
-  }
-}

Ragon.Client.Property/Sources/RagonInt.cs

@@ -1,87 +0,0 @@
-/*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-
-using Ragon.Protocol;
-
-namespace Ragon.Client.Property
-{
-  [Serializable]
-  public class RagonInt : RagonProperty
-  {
-    public int Value
-    {
-      get => _value;
-      set
-      {
-        _value = value;
-        MarkAsChanged();
-      }
-    }
-
-    private int _min;
-    private int _max;
-    private int _requiredBits;
-    private int _value;
-
-    public RagonInt(
-      int initialValue,
-      bool invokeLocal = true,
-      int priority = 0
-    ) : base(priority, invokeLocal)
-    {
-      _value = initialValue;
-      _min = -1000;
-      _max = 1000;
-
-      _max = Math.Max(Math.Abs(_min), Math.Abs(_max));
-      _requiredBits = Bits.Compute(_max);
-
-      SetFixedSize(_requiredBits);
-    }
-
-    public RagonInt(
-      int initialValue,
-      int min = -1000,
-      int max = 1000,
-      bool invokeLocal = true,
-      int priority = 0
-    ) : base(priority, invokeLocal)
-    {
-      _value = initialValue;
-      _min = min;
-      _max = max;
-
-      _requiredBits = Bits.Compute(_max);
-
-      SetFixedSize(_requiredBits);
-    }
-
-    public override void Serialize(RagonBuffer buffer)
-    {
-      uint compressedValue = (uint)((_value << 1) ^ (_value >> 31));
-      buffer.Write(compressedValue, _requiredBits);
-    }
-
-    public override void Deserialize(RagonBuffer buffer)
-    {
-      var compressedValue = buffer.Read(_requiredBits);
-      _value = (int)((compressedValue >> 1) ^ -(int)(compressedValue & 1));
-
-      InvokeChanged();
-    }
-  }
-}

Ragon.Client.Property/Sources/RagonQuaternion.cs

@@ -1,76 +0,0 @@
-/*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-using System.Numerics;
-using Ragon.Client.Compressor;
-using Ragon.Protocol;
-
-namespace Ragon.Client.Property;
-
-public class RagonQuaternion : RagonProperty
-{
-  private Quaternion _value;
-
-  public Quaternion Value
-  {
-    get => _value;
-    set
-    {
-      _value = value;
-
-      MarkAsChanged();
-    }
-  }
-
-  private readonly FloatCompressor _compressor;
-
-  public RagonQuaternion(bool invokeLocal = false, int priority = 0) : base(priority, invokeLocal)
-  {
-    _compressor = new FloatCompressor(-1.0f, 1f, 0.01f);
-
-    SetFixedSize(_compressor.RequiredBits * 4);
-  }
-
-  public override void Serialize(RagonBuffer buffer)
-  {
-    var compressedX = _compressor.Compress(_value.X);
-    var compressedY = _compressor.Compress(_value.Y);
-    var compressedZ = _compressor.Compress(_value.Z);
-    var compressedW = _compressor.Compress(_value.W);
-
-    buffer.Write(compressedX, _compressor.RequiredBits);
-    buffer.Write(compressedY, _compressor.RequiredBits);
-    buffer.Write(compressedZ, _compressor.RequiredBits);
-    buffer.Write(compressedW, _compressor.RequiredBits);
-  }
-
-  public override void Deserialize(RagonBuffer buffer)
-  {
-    var compressedX = buffer.Read(_compressor.RequiredBits);
-    var compressedY = buffer.Read(_compressor.RequiredBits);
-    var compressedZ = buffer.Read(_compressor.RequiredBits);
-    var compressedW = buffer.Read(_compressor.RequiredBits);
-
-    var x = _compressor.Decompress(compressedX);
-    var y = _compressor.Decompress(compressedY);
-    var z = _compressor.Decompress(compressedZ);
-    var w = _compressor.Decompress(compressedW);
-
-    _value = new Quaternion(x, y, z, w);
-
-    InvokeChanged();
-  }
-}

Ragon.Client.Property/Sources/RagonString.cs

@@ -1,68 +0,0 @@
-/*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-
-using System.Text;
-using Ragon.Protocol;
-
-namespace Ragon.Client.Property
-{
-  [Serializable]
-  public class RagonString : RagonProperty
-  {
-    public string Value
-    {
-      get => _value;
-      set
-      {
-        _value = value;
-        
-        MarkAsChanged();
-      }
-    }
-
-    private string _value;
-    private readonly UTF8Encoding _utf8Encoding = new UTF8Encoding(false, true);
-    
-    public RagonString(
-      string initialValue,
-      bool invokeLocal = true,
-      int priority = 0
-    ) : base(priority, invokeLocal)
-    {
-      _value = initialValue;
-    }
-
-    public override void Serialize(RagonBuffer buffer)
-    {
-      var data = _utf8Encoding.GetBytes(_value);
-      var len = (uint) data.Length;
-      
-      buffer.Write(len, 16);
-      buffer.WriteBytes(data);
-    }
-
-    public override void Deserialize(RagonBuffer buffer)
-    {
-      var len = (int) buffer.Read(16);
-      var data = buffer.ReadBytes(len);
-      
-      _value = _utf8Encoding.GetString(data);
-      
-      InvokeChanged();
-    }
-  }
-}

Ragon.Client.Property/Sources/RagonVector3.cs

@@ -1,330 +0,0 @@
-/*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-using System;
-using System.Numerics;
-using Ragon.Client.Compressor;
-using Ragon.Protocol;
-
-namespace Ragon.Client.Property
-{
-  [Serializable]
-  public enum RagonAxis
-  {
-    XYZ,
-    XY,
-    YZ,
-    XZ,
-    X,
-    Y,
-    Z
-  }
-
-  [Serializable]
-  public class RagonVector3 : RagonProperty
-  {
-    private Vector3 _value;
-
-    public Vector3 Value
-    {
-      get => _value;
-      set
-      {
-        _value = value;
-        
-        MarkAsChanged();
-      }
-    }
-
-    private RagonAxis _axis;
-    private FloatCompressor _compressorX;
-    private FloatCompressor _compressorY;
-    private FloatCompressor _compressorZ;
-
-
-    public RagonVector3(
-      RagonAxis axis = RagonAxis.XYZ,
-      bool invokeLocal = true,
-      int priority = 0
-    ) : base(priority, invokeLocal)
-    {
-      _axis = axis;
-
-      var defaultCompressor = new FloatCompressor(-1024.0f, 1024f, 0.01f);
-
-      _compressorX = defaultCompressor;
-      _compressorY = defaultCompressor;
-      _compressorZ = defaultCompressor;
-
-      switch (_axis)
-      {
-        case RagonAxis.XYZ:
-          SetFixedSize(_compressorX.RequiredBits + _compressorY.RequiredBits + _compressorZ.RequiredBits);
-          break;
-        case RagonAxis.XY:
-          SetFixedSize(_compressorX.RequiredBits + _compressorY.RequiredBits);
-          break;
-        case RagonAxis.XZ:
-          SetFixedSize(_compressorX.RequiredBits + _compressorZ.RequiredBits);
-          break;
-        case RagonAxis.YZ:
-          SetFixedSize(_compressorY.RequiredBits + _compressorZ.RequiredBits);
-          break;
-        case RagonAxis.X:
-          SetFixedSize(_compressorX.RequiredBits);
-          break;
-        case RagonAxis.Y:
-          SetFixedSize(_compressorY.RequiredBits);
-          break;
-        case RagonAxis.Z:
-          SetFixedSize(_compressorZ.RequiredBits);
-          break;
-      }
-    }
-
-    public RagonVector3(
-      Vector3 initialValue,
-      RagonAxis axis = RagonAxis.XYZ,
-      float min = -1024.0f,
-      float max = 1024.0f,
-      float precision = 0.1f,
-      bool invokeLocal = true,
-      int priority = 0
-    ) : base(priority, invokeLocal)
-    {
-      _value = initialValue;
-      _axis = axis;
-      
-      var defaultCompressor = new FloatCompressor(min, max, precision);
-
-      _compressorX = defaultCompressor;
-      _compressorY = defaultCompressor;
-      _compressorZ = defaultCompressor;
-
-      switch (_axis)
-      {
-        case RagonAxis.XYZ:
-          SetFixedSize(_compressorX.RequiredBits + _compressorY.RequiredBits + _compressorZ.RequiredBits);
-          break;
-        case RagonAxis.XY:
-          SetFixedSize(_compressorX.RequiredBits + _compressorY.RequiredBits);
-          break;
-        case RagonAxis.XZ:
-          SetFixedSize(_compressorX.RequiredBits + _compressorZ.RequiredBits);
-          break;
-        case RagonAxis.YZ:
-          SetFixedSize(_compressorY.RequiredBits + _compressorZ.RequiredBits);
-          break;
-        case RagonAxis.X:
-          SetFixedSize(_compressorX.RequiredBits);
-          break;
-        case RagonAxis.Y:
-          SetFixedSize(_compressorY.RequiredBits);
-          break;
-        case RagonAxis.Z:
-          SetFixedSize(_compressorZ.RequiredBits);
-          break;
-      }
-    }
-
-    public RagonVector3(
-      RagonAxis axis = RagonAxis.XYZ,
-      FloatCompressor compressorX = null,
-      FloatCompressor compressorY = null,
-      FloatCompressor compressorZ = null,
-      bool invokeLocal = true,
-      int priority = 0
-    ) : base(priority, invokeLocal)
-    {
-      _axis = axis;
-
-      var defaultCompressor = new FloatCompressor(-1024.0f, 1024f, 0.01f);
-
-      _compressorX = defaultCompressor;
-      _compressorY = defaultCompressor;
-      _compressorZ = defaultCompressor;
-
-      if (compressorX != null)
-        _compressorX = compressorX;
-
-      if (compressorY != null)
-        _compressorY = compressorY;
-
-      if (compressorZ != null)
-        _compressorZ = compressorZ;
-
-      switch (_axis)
-      {
-        case RagonAxis.XYZ:
-          SetFixedSize(_compressorX.RequiredBits + _compressorY.RequiredBits + _compressorZ.RequiredBits);
-          break;
-        case RagonAxis.XY:
-          SetFixedSize(_compressorX.RequiredBits + _compressorY.RequiredBits);
-          break;
-        case RagonAxis.XZ:
-          SetFixedSize(_compressorX.RequiredBits + _compressorZ.RequiredBits);
-          break;
-        case RagonAxis.YZ:
-          SetFixedSize(_compressorY.RequiredBits + _compressorZ.RequiredBits);
-          break;
-        case RagonAxis.X:
-          SetFixedSize(_compressorX.RequiredBits);
-          break;
-        case RagonAxis.Y:
-          SetFixedSize(_compressorY.RequiredBits);
-          break;
-        case RagonAxis.Z:
-          SetFixedSize(_compressorZ.RequiredBits);
-          break;
-      }
-    }
-
-    public override void Serialize(RagonBuffer buffer)
-    {
-      switch (_axis)
-      {
-        case RagonAxis.XYZ:
-        {
-          var compressedX = _compressorX.Compress(_value.X);
-          var compressedY = _compressorY.Compress(_value.Y);
-          var compressedZ = _compressorZ.Compress(_value.Z);
-
-          buffer.Write(compressedX, _compressorX.RequiredBits);
-          buffer.Write(compressedY, _compressorY.RequiredBits);
-          buffer.Write(compressedZ, _compressorZ.RequiredBits);
-        }
-          break;
-        case RagonAxis.XY:
-        {
-          var compressedX = _compressorX.Compress(_value.X);
-          var compressedY = _compressorY.Compress(_value.Y);
-          
-          buffer.Write(compressedX, _compressorX.RequiredBits);
-          buffer.Write(compressedY, _compressorY.RequiredBits);
-        }
-          break;
-        case RagonAxis.XZ:
-        {
-          var compressedX = _compressorX.Compress(_value.X);
-          var compressedZ = _compressorZ.Compress(_value.Z);
-
-          buffer.Write(compressedX, _compressorX.RequiredBits);
-          buffer.Write(compressedZ, _compressorZ.RequiredBits);
-          break;
-        }
-
-        case RagonAxis.YZ:
-        {
-          var compressedY = _compressorY.Compress(_value.Y);
-          var compressedZ = _compressorZ.Compress(_value.Z);
-
-          buffer.Write(compressedY, _compressorY.RequiredBits);
-          buffer.Write(compressedZ, _compressorZ.RequiredBits);
-          break;
-        }
-        case RagonAxis.X:
-        {
-          var compressedX = _compressorX.Compress(_value.X);
-
-          buffer.Write(compressedX, _compressorX.RequiredBits);
-          break;
-        }
-        case RagonAxis.Y:
-        {
-          var compressedY = _compressorY.Compress(_value.Y);
-          
-          buffer.Write(compressedY, _compressorY.RequiredBits);
-          break;
-        }
-        case RagonAxis.Z:
-        {
-          var compressedZ = _compressorZ.Compress(_value.Z);
-          
-          buffer.Write(compressedZ, _compressorZ.RequiredBits);
-          break;
-        }
-      }
-    }
-
-    public override void Deserialize(RagonBuffer buffer)
-    {
-      switch (_axis)
-      {
-        case RagonAxis.XYZ:
-        {
-          var compressedX = buffer.Read(_compressorX.RequiredBits);
-          var compressedY = buffer.Read(_compressorY.RequiredBits);
-          var compressedZ = buffer.Read(_compressorZ.RequiredBits);
-
-          _value.X = _compressorX.Decompress(compressedX);
-          _value.Y = _compressorY.Decompress(compressedY);
-          _value.Z = _compressorZ.Decompress(compressedZ);
-          break;
-        }
-        case RagonAxis.XY:
-        {
-          var compressedX = buffer.Read(_compressorX.RequiredBits);
-          var compressedY = buffer.Read(_compressorY.RequiredBits);
-
-          _value.X = _compressorX.Decompress(compressedX);
-          _value.Z = _compressorY.Decompress(compressedY);
-          break;
-        }
-        case RagonAxis.XZ:
-        {
-          var compressedX = buffer.Read(_compressorX.RequiredBits);
-          var compressedZ = buffer.Read(_compressorZ.RequiredBits);
-
-          _value.X = _compressorX.Decompress(compressedX);
-          _value.Z = _compressorZ.Decompress(compressedZ);
-          break;
-        }
-        case RagonAxis.YZ:
-        {
-          var compressedY = buffer.Read(_compressorY.RequiredBits);
-          var compressedZ = buffer.Read(_compressorZ.RequiredBits);
-
-          _value.Y = _compressorY.Decompress(compressedY);
-          _value.Z = _compressorZ.Decompress(compressedZ);
-          break;
-        }
-        case RagonAxis.X:
-        {
-          var compressedX = buffer.Read(_compressorX.RequiredBits);
-
-          _value.X = _compressorX.Decompress(compressedX);
-          break;
-        }
-        case RagonAxis.Y:
-        {
-          var compressedY = buffer.Read(_compressorY.RequiredBits);
-
-          _value.Y = _compressorY.Decompress(compressedY);
-          break;
-        }
-        case RagonAxis.Z:
-        {
-          var compressedZ = buffer.Read(_compressorZ.RequiredBits);
-
-          _value.Z = _compressorZ.Decompress(compressedZ);
-          break;
-        }
-      }
-
-      InvokeChanged();
-    }
-  }
-}

Ragon.Client/Ragon.Client.csproj

@@ -1,3 +1,4 @@
+
 <Project Sdk="Microsoft.NET.Sdk">
 
     <PropertyGroup>
@@ -5,7 +6,7 @@
         <Nullable>enable</Nullable>
         <LangVersion>10</LangVersion>
         <RootNamespace>Ragon.Client.Simulation</RootNamespace>
-        <Authors>Eduard Kargin (Edmand46)</Authors>
+        <Authors>Eduard Kargin</Authors>
         <TargetFramework>netstandard2.0</TargetFramework>
     </PropertyGroup>
 

Ragon.Client/Sources/Compressor/FloatCompressor.cs

@@ -1,57 +0,0 @@
-/*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-
-using Ragon.Protocol;
-
-namespace Ragon.Client.Compressor;
-
-public class FloatCompressor
-{
-  public float Min { get; private set; }
-  public float Max { get; private set; }
-  public float Precision { get; private set; }
-  public int RequiredBits { get; private set; }
-  
-  private uint _mask;
-
-  public FloatCompressor(float min = -1024.0f, float max = 1024.0f, float precision = 0.01f)
-  {
-    Min = min;
-    Max = max;
-    Precision = precision;
-    RequiredBits = DeBruijn.Log2((uint)((Max - Min) * (1f / Precision) + 0.5f)) + 1;
-    
-    _mask = (uint)((1L << RequiredBits) - 1);
-  }
-
-  public uint Compress(float value)
-  {
-    return (uint)((value - Min) * 1f / Precision + 0.5f) & _mask;
-  }
-
-  public float Decompress(uint value)
-  {
-    var result = value * Precision + Min;
-
-    if (result < Min)
-      result = Min;
-    else if (result > Max)
-      result = Max;
-
-    return result;
-  }
-}

Ragon.Client/Sources/Compressor/IntCompressor.cs

@@ -1,44 +0,0 @@
-/*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-
-using Ragon.Protocol;
-
-namespace Ragon.Client.Compressor;
-
-public class IntCompressor
-{
-  public int Min { get; private set; }
-  public int Max { get; private set; }
-  public int RequiredBits { get; private set; }
-
-  public IntCompressor(int min = -1000, int max = 1000)
-  {
-    Min = min;
-    Max = max;
-    RequiredBits = Bits.Compute(Max);
-  }
-
-  public uint Compress(int value)
-  {
-    return (uint)((value << 1) ^ (value >> 31));;
-  }
-
-  public int Decompress(uint value)
-  {
-    return (int)((value >> 1) ^ -(int)(value & 1));
-  }
-}

Ragon.Client/Sources/Entity/RagonEntity.cs

@@ -1,303 +0,0 @@
-/*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-
-using Ragon.Protocol;
-
-namespace Ragon.Client
-{
-  public sealed class RagonEntity : IDisposable
-  {
-    private class EventSubscription : IDisposable
-    {
-      private List<Action<RagonPlayer, IRagonEvent>> _callbacks;
-      private List<Action<RagonPlayer, IRagonEvent>> _localCallbacks;
-      private Action<RagonPlayer, IRagonEvent> _callback;
-
-      public EventSubscription(
-        List<Action<RagonPlayer, IRagonEvent>> callbacks,
-        List<Action<RagonPlayer, IRagonEvent>> localCallbacks,
-        Action<RagonPlayer, IRagonEvent> callback)
-      {
-        _callbacks = callbacks;
-        _localCallbacks = localCallbacks;
-        _callback = callback;
-      }
-
-      public void Dispose()
-      {
-        _callbacks?.Remove(_callback);
-        _localCallbacks?.Remove(_callback);
-
-        _callbacks = null!;
-        _localCallbacks = null!;
-        _callback = null!;
-      }
-    }
-
-    private delegate void OnEventDelegate(RagonPlayer player, RagonBuffer serializer);
-
-    private RagonClient _client;
-
-    public ushort Id { get; private set; }
-    public ushort Type { get; private set; }
-    
-    public RagonAuthority Authority { get; private set; }
-    public RagonPlayer Owner { get; private set; }
-    public RagonEntityState State { get; private set; }
-
-    public bool IsStatic => SceneId > 0;  
-    public bool IsReplicated { get; private set; }
-    public bool IsAttached { get; private set; }
-    public bool HasAuthority { get; private set; }
-
-    public event Action<RagonEntity> Attached;
-    public event Action Detached;
-    public event Action<RagonPlayer, RagonPlayer> OwnershipChanged;
-
-    internal bool PropertiesChanged => _propertiesChanged;
-    internal ushort SceneId => _sceneId;
-
-    private ushort _sceneId;
-    private bool _propertiesChanged;
-
-    private RagonPayload _spawnPayload;
-    private RagonPayload _destroyPayload;
-
-    private readonly Dictionary<int, OnEventDelegate> _events = new Dictionary<int, OnEventDelegate>();
-    private readonly Dictionary<int, List<Action<RagonPlayer, IRagonEvent>>> _localListeners = new Dictionary<int, List<Action<RagonPlayer, IRagonEvent>>>();
-    private readonly Dictionary<int, List<Action<RagonPlayer, IRagonEvent>>> _listeners = new Dictionary<int, List<Action<RagonPlayer, IRagonEvent>>>();
-
-    public RagonEntity(ushort type = 0, ushort sceneId = 0, bool replicated = true)
-    {
-      State = new RagonEntityState(this);
-      Type = type;
-      IsReplicated = replicated;
-      
-      _spawnPayload = new RagonPayload(0);
-      _destroyPayload = new RagonPayload(0);
-      _sceneId = sceneId;
-    }
-
-    internal void Attach()
-    {
-      IsAttached = true;
-     
-      Attached?.Invoke(this);
-    }
-
-    public void SetReplication(bool enabled)
-    {
-      IsReplicated = enabled;
-    }
-
-    internal void Detach(RagonPayload payload)
-    {
-      _destroyPayload = payload;
-      
-      Detached?.Invoke();
-    }
-
-    internal T GetPayload<T>(RagonPayload data) where T : IRagonPayload, new()
-    {
-      var payload = new T();
-      if (data.Size <= 0) return payload;
-
-      var buffer = new RagonBuffer();
-
-      data.Write(buffer);
-
-      payload.Deserialize(buffer);
-
-      return payload;
-    }
-
-    public void Prepare(RagonClient client, ushort entityId, ushort entityType, bool hasAuthority, RagonPlayer player, RagonPayload payload)
-    {
-      Type = entityType;
-      Id = entityId;
-      HasAuthority = hasAuthority;
-
-      _client = client;
-      _spawnPayload = payload;
-      
-      Owner = player;
-    }
-
-    public T GetAttachPayload<T>() where T : IRagonPayload, new()
-    {
-      return GetPayload<T>(_spawnPayload);
-    }
-
-    public T GetDetachPayload<T>() where T : IRagonPayload, new()
-    {
-      return GetPayload<T>(_destroyPayload);
-    }
-
-    public void ReplicateEvent<TEvent>(TEvent evnt, RagonPlayer target, RagonReplicationMode replicationMode)
-      where TEvent : IRagonEvent, new()
-    {
-      if (!IsAttached)
-      {
-        RagonLog.Error("Entity not attached");
-        return;
-      }
-
-      var evntId = _client.Event.GetEventCode(evnt);
-      var buffer = _client.Buffer;
-
-      buffer.Clear();
-      buffer.WriteOperation(RagonOperation.REPLICATE_ENTITY_EVENT);
-      buffer.WriteUShort(Id);
-      buffer.WriteUShort(evntId);
-      buffer.WriteByte((byte)replicationMode);
-      buffer.WriteByte((byte)RagonTarget.Player);
-      buffer.WriteUShort(target.PeerId);
-
-      evnt.Serialize(buffer);
-
-      var sendData = buffer.ToArray();
-      _client.Reliable.Send(sendData);
-    }
-
-    public void ReplicateEvent<TEvent>(
-      TEvent evnt,
-      RagonTarget target = RagonTarget.All,
-      RagonReplicationMode replicationMode = RagonReplicationMode.Server)
-      where TEvent : IRagonEvent, new()
-    {
-      if (!IsAttached)
-      {
-        RagonLog.Error("Entity not attached");
-        return;
-      }
-
-      var eventCode = _client.Event.GetEventCode(evnt);
-      if (target != RagonTarget.ExceptOwner)
-      {
-        if (replicationMode == RagonReplicationMode.Local)
-        {
-          var localListeners = _localListeners[eventCode];
-          foreach (var listener in localListeners)
-            listener.Invoke(_client.Room.Local, evnt);
-          return;
-        }
-
-        if (replicationMode == RagonReplicationMode.LocalAndServer)
-        {
-          var localListeners = _localListeners[eventCode];
-          foreach (var listener in localListeners)
-            listener.Invoke(_client.Room.Local, evnt);
-        }
-      }
-
-      var buffer = _client.Buffer;
-
-      buffer.Clear();
-      buffer.WriteOperation(RagonOperation.REPLICATE_ENTITY_EVENT);
-      buffer.WriteUShort(Id);
-      buffer.WriteUShort(eventCode);
-      buffer.WriteByte((byte)replicationMode);
-      buffer.WriteByte((byte)target);
-
-      evnt.Serialize(buffer);
-
-      var sendData = buffer.ToArray();
-      _client.Reliable.Send(sendData);
-    }
-
-    public IDisposable OnEvent<TEvent>(Action<RagonPlayer, TEvent> callback) where TEvent : IRagonEvent, new()
-    {
-      var t = new TEvent();
-      var eventCode = _client.Event.GetEventCode(t);
-      var action = (RagonPlayer player, IRagonEvent eventData) => callback.Invoke(player, (TEvent)eventData);
-
-      if (!_listeners.TryGetValue(eventCode, out var callbacks))
-      {
-        callbacks = new List<Action<RagonPlayer, IRagonEvent>>();
-        _listeners.Add(eventCode, callbacks);
-      }
-
-      if (!_localListeners.TryGetValue(eventCode, out var localCallbacks))
-      {
-        localCallbacks = new List<Action<RagonPlayer, IRagonEvent>>();
-        _localListeners.Add(eventCode, localCallbacks);
-      }
-
-      callbacks.Add(action);
-      localCallbacks.Add(action);
-
-      if (!_events.ContainsKey(eventCode))
-      {
-        _events.Add(eventCode, (player, serializer) =>
-        {
-          t.Deserialize(serializer);
-
-          foreach (var callbackListener in callbacks)
-            callbackListener.Invoke(player, t);
-        });
-      }
-
-      return new EventSubscription(callbacks, localCallbacks, action);
-    }
-
-    internal void Write(RagonBuffer buffer)
-    {
-      buffer.WriteUShort(Id);
-
-      State.WriteState(buffer);
-
-      _propertiesChanged = false;
-    }
-    
-    internal void Read(RagonBuffer buffer)
-    {
-      State.ReadState(buffer);
-    }
-
-    internal void Event(ushort eventCode, RagonPlayer caller, RagonBuffer buffer)
-    {
-      if (!IsReplicated) return;
-      
-      if (_events.TryGetValue(eventCode, out var evnt))
-        evnt?.Invoke(caller, buffer);
-      else
-        RagonLog.Warn($"Handler event on entity {Id} with eventCode {eventCode} not defined");
-    }
-
-    internal void TrackChangedProperty(RagonProperty property)
-    {
-      _propertiesChanged = true;
-    }
-
-    public void OnOwnershipChanged(RagonPlayer player)
-    {
-      var prevOwner = Owner;
-
-      Owner = player;
-      HasAuthority = player.IsLocal;
-
-      OwnershipChanged?.Invoke(prevOwner, player);
-    }
-
-    public void Dispose()
-    {
-      _events.Clear();
-      _listeners.Clear();
-      _localListeners.Clear();
-    }
-  }
-}

Ragon.Client/Sources/Entity/RagonEntityState.cs

@@ -1,77 +0,0 @@
-/*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-
-using Ragon.Protocol;
-
-namespace Ragon.Client;
-
-public sealed class RagonEntityState
-{
-  private List<RagonProperty> _properties;
-  private RagonEntity _entity;
-  
-  public RagonEntityState(RagonEntity entity)
-  {
-    _entity = entity;
-    _properties = new List<RagonProperty>(6);
-  }
-  
-  public void AddProperty(RagonProperty property)
-  {
-    _properties.Add(property);
-    
-    property.AssignEntity(_entity);
-  }
-  
-  internal void WriteInfo(RagonBuffer buffer)
-  {
-    buffer.WriteUShort((ushort)_properties.Count);
-    foreach (var property in _properties)
-    {
-      buffer.WriteBool(property.IsFixed);
-      buffer.WriteUShort((ushort)property.Size);
-    }
-  }
-  
-  internal void ReadState(RagonBuffer buffer)
-  {
-    foreach (var property in _properties)
-    {
-      var changed = buffer.ReadBool();
-      if (changed)
-        property.Read(buffer);
-    }
-  }
-
-  internal void WriteState(RagonBuffer buffer)
-  {
-    foreach (var prop in _properties)
-    {
-      if (prop.IsDirty)
-      {
-        buffer.WriteBool(true);
-        prop.Write(buffer);
-        prop.Flush();
-      }
-      else
-      {
-        prop.AddTick();
-        buffer.WriteBool(false);
-      }
-    }
-  }
-}

Ragon.Client/Sources/Entity/RagonPayload.cs

@@ -1,49 +0,0 @@
-/*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-
-using Ragon.Protocol;
-
-namespace Ragon.Client;
-
-public class RagonPayload
-{
-  public static RagonPayload Empty = new RagonPayload(0);
-  
-  private readonly uint[] _data = new uint[128];
-  private readonly int _size = 0;
-
-  public RagonPayload(int capacity)
-  {
-    _size = capacity;
-  }
-  public int Size => _size;
-
-  public void Read(RagonBuffer buffer)
-  {
-    buffer.ReadArray(_data, _size);
-  }
-
-  public void Write(RagonBuffer buffer)
-  {
-    buffer.WriteArray(_data, _size);
-  }
-
-  public override string ToString()
-  {
-    return $"Payload Size: {_size}";
-  }
-}

Ragon.Client/Sources/Entity/RagonProperty.cs

@@ -1,146 +0,0 @@
-/*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-using Ragon.Protocol;
-
-namespace Ragon.Client
-{
-  [Serializable]
-  public class RagonProperty
-  {
-    public string Name => _name;
-    public RagonEntity Entity => _entity;
-
-    public event Action Changed;
-    public bool IsDirty => _dirty && _ticks >= _priority;
-    public bool IsFixed => _fixed;
-    public int Size => _size;
-
-    private RagonBuffer _propertyBuffer;
-    private RagonEntity _entity;
-    private bool _dirty;
-    private int _size;
-    private int _ticks;
-    private int _priority;
-    private bool _fixed;
-    private string _name;
-
-    protected bool InvokeLocal;
-
-    protected RagonProperty(int priority, bool invokeLocal)
-    {
-      _size = 0;
-      _priority = priority;
-      _fixed = false;
-      _propertyBuffer = new RagonBuffer();
-
-      InvokeLocal = invokeLocal;
-    }
-
-    public void SetName(string name)
-    {
-      _name = name;
-    }
-
-    protected void SetFixedSize(int size)
-    {
-      _size = size;
-      _fixed = true;
-    }
-
-    protected void InvokeChanged()
-    {
-      if (_entity.HasAuthority)
-        return;
-
-      Changed?.Invoke();
-    }
-
-    protected void MarkAsChanged()
-    {
-      if (InvokeLocal)
-        Changed?.Invoke();
-      
-      if (_dirty || _entity == null)
-        return;
-
-      _dirty = true;
-      _entity.TrackChangedProperty(this);
-    }
-
-    internal void Flush()
-    {
-      _dirty = false;
-      _ticks = 0;
-    }
-
-    internal void AddTick()
-    {
-      _ticks++;
-    }
-
-    internal void AssignEntity(RagonEntity ent)
-    {
-      _entity = ent;
-
-      Changed?.Invoke();
-    }
-
-    internal void Write(RagonBuffer buffer)
-    {
-      _propertyBuffer.Clear();
-
-      if (_fixed)
-      {
-        Serialize(_propertyBuffer);
-
-        buffer.CopyFrom(_propertyBuffer, _size);
-        return;
-      }
-
-      Serialize(_propertyBuffer);
-
-      var propertySize = (ushort)_propertyBuffer.WriteOffset;
-      buffer.WriteUShort(propertySize);
-      buffer.CopyFrom(_propertyBuffer, propertySize);
-    }
-
-    internal void Read(RagonBuffer buffer)
-    {
-      _propertyBuffer.Clear();
-
-      if (_fixed)
-      {
-        buffer.ToBuffer(_propertyBuffer, _size);
-
-        Deserialize(_propertyBuffer);
-        return;
-      }
-
-      var propSize = buffer.ReadUShort();
-      buffer.ToBuffer(_propertyBuffer, propSize);
-      Deserialize(_propertyBuffer);
-    }
-
-    public virtual void Serialize(RagonBuffer buffer)
-    {
-    }
-
-    public virtual void Deserialize(RagonBuffer buffer)
-    {
-    }
-  }
-}

Ragon.Client/Sources/Handler/AuthorizeFailedHandler.cs

@@ -1,5 +1,5 @@
 /*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
+ * Copyright 2023-2024 Eduard Kargin <kargin.eduard@gmail.com>
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -27,7 +27,7 @@ internal class AuthorizeFailedHandler: IHandler
     _listenerList = list;
   }
   
-  public void Handle(RagonBuffer reader)
+  public void Handle(RagonStream reader)
   {
     var message = reader.ReadString();
     _listenerList.OnAuthorizationFailed(message);

Ragon.Client/Sources/Handler/AuthorizeSuccessHandler.cs

@@ -1,5 +1,5 @@
 /*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
+ * Copyright 2023-2024 Eduard Kargin <kargin.eduard@gmail.com>
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -32,13 +32,13 @@ internal class AuthorizeSuccessHandler: IHandler
     _listenerList = listenerList;
   }
   
-  public void Handle(RagonBuffer reader)
+  public void Handle(RagonStream reader)
   {
     var playerId = reader.ReadString();
     var playerName = reader.ReadString();
     var playerPayload = reader.ReadString();
 
-    _client.SetStatus(RagonStatus.LOBBY);
+    _client.UpdateState(RagonState.LOBBY);
     _listenerList.OnAuthorizationSuccess(playerId, playerName, playerPayload);
   }
 }

Ragon.Client/Sources/Handler/EntityCreateHandler.cs

@@ -1,69 +0,0 @@
-/*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-using Ragon.Protocol;
-
-namespace Ragon.Client;
-
-internal class EntityCreateHandler : IHandler
-{
-  private readonly RagonClient _client;
-  private readonly RagonPlayerCache _playerCache;
-  private readonly RagonEntityCache _entityCache;
-  private readonly IRagonEntityListener _entityListener;
-  
-  public EntityCreateHandler(
-    RagonClient client,
-    RagonPlayerCache playerCache,
-    RagonEntityCache entityCache,
-    IRagonEntityListener entityListener
-  )
-  {
-    _client = client;
-    _entityCache = entityCache;
-    _playerCache = playerCache;
-    _entityListener = entityListener;
-  }
-
-  public void Handle(RagonBuffer reader)
-  {
-    var attachId = reader.ReadUShort();
-    var entityType = reader.ReadUShort();
-    var entityId = reader.ReadUShort();
-    var ownerId = reader.ReadUShort();
-    var player = _playerCache.GetPlayerByPeer(ownerId);
-    var payload = new RagonPayload(reader.Capacity);
-    payload.Read(reader);
-
-    if (player == null)
-    {
-      RagonLog.Warn($"Owner {ownerId}|{player.Name} not found in players");
-      
-      _playerCache.Dump();
-      return;
-    }
-    
-    var hasAuthority = _playerCache.Local.Id == player.Id;
-    var entity = _entityCache.TryGetEntity(attachId, entityType, 0, entityId, hasAuthority, out var hasCreated);
-    
-    entity.Prepare(_client, entityId, entityType, hasAuthority, player, payload);
-
-    if (hasCreated)
-      _entityListener.OnEntityCreated(entity);
-    
-    entity.Attach();
-  }
-}

Ragon.Client/Sources/Handler/EntityEventHandler.cs

@@ -1,56 +0,0 @@
-/*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-using Ragon.Protocol;
-
-namespace Ragon.Client;
-
-internal class EntityEventHandler : IHandler
-{
-  private readonly RagonPlayerCache _playerCache;
-  private readonly RagonEntityCache _entityCache;
-
-  public EntityEventHandler(
-    RagonPlayerCache playerCache,
-    RagonEntityCache entityCache
-  )
-  {
-    _playerCache = playerCache;
-    _entityCache = entityCache;
-  }
-
-  public void Handle(RagonBuffer reader)
-  {
-    var eventCode = reader.ReadUShort();
-    var peerId = reader.ReadUShort();
-    var executionMode = (RagonReplicationMode)reader.ReadByte();
-    var entityId = reader.ReadUShort();
-
-    var player = _playerCache.GetPlayerByPeer(peerId);
-    if (player == null)
-    {
-      RagonLog.Error($"Player with peerId:{peerId} not found as owner of event with code:{eventCode}");
-      
-      _playerCache.Dump();
-      return;
-    }
-
-    if (player.IsLocal && executionMode == RagonReplicationMode.LocalAndServer)
-      return;
-
-    _entityCache.OnEvent(player, entityId, eventCode, reader);
-  }
-}

Ragon.Client/Sources/Handler/EntityOwnershipHandler.cs

@@ -1,60 +0,0 @@
-/*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-
-using Ragon.Protocol;
-
-namespace Ragon.Client;
-
-internal class EntityOwnershipHandler: IHandler
-{
-  private readonly RagonListenerList _listenerList;
-  private readonly RagonPlayerCache _playerCache;
-  private readonly RagonEntityCache _entityCache;
-  
-  public EntityOwnershipHandler(
-    RagonListenerList listenerList,
-    RagonPlayerCache playerCache,
-    RagonEntityCache entityCache)
-  {
-    _listenerList = listenerList;
-    _playerCache = playerCache;
-    _entityCache = entityCache;
-  }
-  
-  public void Handle(RagonBuffer reader)
-  {
-    var newOwnerId = reader.ReadUShort();
-    var entities = reader.ReadUShort();
-    
-    var player = _playerCache.GetPlayerByPeer(newOwnerId);
-    if (player == null)
-    {
-      RagonLog.Error($"Player with Id:{newOwnerId} not found in cache");
-      
-      _playerCache.Dump();
-      return;
-    }
-    
-    for (var i = 0; i < entities; i++)
-    {
-      var entityId = reader.ReadUShort();
-      _entityCache.OnOwnershipChanged(player, entityId);
-      
-      RagonLog.Trace("Entity changed owner: " + entityId);
-    }  
-  }
-}

Ragon.Client/Sources/Handler/EntityRemoveHandler.cs

@@ -1,39 +0,0 @@
-/*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-
-using Ragon.Protocol;
-
-namespace Ragon.Client;
-
-internal class EntityRemoveHandler: IHandler
-{
-  private readonly RagonEntityCache _entityCache;
-  
-  public EntityRemoveHandler(RagonEntityCache entityCache)
-  {
-    _entityCache = entityCache;
-  }
-  
-  public void Handle(RagonBuffer reader)
-  {
-    var entityId = reader.ReadUShort();
-    var payload = new RagonPayload(reader.Capacity);
-    payload.Read(reader);
-    
-    _entityCache.OnDestroy(entityId, payload);
-  }
-}

Ragon.Client/Sources/Handler/IHandler.cs

@@ -1,5 +1,5 @@
 /*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
+ * Copyright 2023-2024 Eduard Kargin <kargin.eduard@gmail.com>
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -21,5 +21,5 @@ namespace Ragon.Client;
 
 public interface IHandler
 {
-  public void Handle(RagonBuffer reader);
+  public void Handle(RagonStream reader);
 }

Ragon.Client/Sources/Handler/JoinFailedHandler.cs

@@ -1,5 +1,5 @@
 /*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
+ * Copyright 2023-2024 Eduard Kargin <kargin.eduard@gmail.com>
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -28,7 +28,7 @@ internal  class JoinFailedHandler: IHandler
     _listenerList = listenerList;
   }
   
-  public void Handle(RagonBuffer reader)
+  public void Handle(RagonStream reader)
   {
     var message = reader.ReadString();
     _listenerList.OnFailed(message);

Ragon.Client/Sources/Handler/JoinSuccessHandler.cs

@@ -1,5 +1,5 @@
 /*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
+ * Copyright 2023-2024 Eduard Kargin <kargin.eduard@gmail.com>
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -39,42 +39,50 @@ public struct RoomParameters
 
 internal class JoinSuccessHandler : IHandler
 {
-  
-  
   private readonly RagonListenerList _listenerList;
   private readonly RagonPlayerCache _playerCache;
-  private readonly RagonEntityCache _entityCache;
   private readonly RagonClient _client;
+  private readonly RagonRoom _room;
 
   public JoinSuccessHandler(
     RagonClient client,
-    RagonListenerList listenerList,
-    RagonPlayerCache playerCache,
-    RagonEntityCache entityCache
+    RagonRoom room
   )
   {
     _client = client;
-    _listenerList = listenerList;
-    _entityCache = entityCache;
-    _playerCache = playerCache;
+    _room = room;
   }
 
-  public void Handle(RagonBuffer reader)
+  public void Handle(RagonStream reader)
   {
     var roomId = reader.ReadString();
-    var localId = reader.ReadString();
-    var ownerId = reader.ReadString();
     var min = reader.ReadUShort();
     var max = reader.ReadUShort();
-    var sceneName = reader.ReadString();
-
-    var scene = new RagonScene(_client, _playerCache, _entityCache, sceneName);
+    var localId = reader.ReadString();
+    var ownerId = reader.ReadString();
     var roomInfo = new RoomParameters(roomId, localId, ownerId, min, max);
-    var room = new RagonRoom(_client, _entityCache, _playerCache, roomInfo, scene);
-
-    _playerCache.SetOwnerAndLocal(ownerId, localId);
-    _client.AssignRoom(room);
     
-    _listenerList.OnSceneRequest(sceneName);
+    _playerCache.SetOwnerAndLocal(ownerId, localId);
+    _room.Reset(roomInfo);
+    _room.UserData.Read(reader);
+
+    var playersCount = reader.ReadUShort();
+    RagonLog.Trace("Players: " + playersCount);
+    for (var i = 0; i < playersCount; i++)
+    {
+      var playerPeerId = reader.ReadUShort();
+      var playerId = reader.ReadString();
+      var playerName = reader.ReadString();
+
+      var player = _playerCache.AddPlayer(playerPeerId, playerId, playerName);
+
+      player.UserData.Read(reader);
+
+      RagonLog.Trace($"Player {playerPeerId} - {playerId} - {playerName}");
+    }
+
+    _client.UpdateState(RagonState.ROOM);
+
+    _listenerList.OnJoined();
   }
 }

Ragon.Client/Sources/Handler/LeaveRoomHandler.cs

@@ -1,5 +1,5 @@
 /*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
+ * Copyright 2023-2024 Eduard Kargin <kargin.eduard@gmail.com>
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -23,22 +23,19 @@ internal class LeaveRoomHandler : IHandler
 {
   private readonly RagonClient _client;
   private readonly RagonListenerList _listenerList;
-  private readonly RagonEntityCache _entityCache;
   
   public LeaveRoomHandler(
     RagonClient client,
-    RagonListenerList listenerList,
-    RagonEntityCache entityCache)
+    RagonListenerList listenerList)
   {
     _client = client;
     _listenerList = listenerList;
-    _entityCache = entityCache;
   }
 
-  public void Handle(RagonBuffer reader)
+  public void Handle(RagonStream reader)
   {    
     _listenerList.OnLeft();
-    _entityCache.Cleanup();
-    _client.Room.Cleanup();
+    
+    _client.Room.Clear();
   }
 }

Ragon.Client/Sources/Handler/LoadSceneHandler.cs

@@ -1,45 +0,0 @@
-/*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-using Ragon.Protocol;
-
-namespace Ragon.Client;
-
-internal class SceneLoadHandler: IHandler
-{
-  private readonly RagonClient _client;
-  private readonly RagonListenerList _listenerList;
-  
-  public SceneLoadHandler(
-    RagonClient ragonClient,
-    RagonListenerList listenerList
-    )
-  {
-    _client = ragonClient;
-    _listenerList = listenerList;
-  }
-  
-  public void Handle(RagonBuffer reader)
-  {
-    var sceneName = reader.ReadString();
-    var room = _client.Room;
-    
-    room.Cleanup();
-    room.Update(sceneName);
-    
-    _listenerList.OnSceneRequest(sceneName);
-  }
-}

Ragon.Client/Sources/Handler/OwnershipRoomHandler.cs

@@ -1,5 +1,5 @@
 /*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
+ * Copyright 2023-2024 Eduard Kargin <kargin.eduard@gmail.com>
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -23,19 +23,16 @@ internal class OwnershipRoomHandler : IHandler
 {
   private readonly RagonListenerList _listenerList;
   private readonly RagonPlayerCache _playerCache;
-  private readonly RagonEntityCache _entityCache;
 
   public OwnershipRoomHandler(
     RagonListenerList listenerList,
-    RagonPlayerCache playerCache,
-    RagonEntityCache entityCache)
+    RagonPlayerCache playerCache)
   {
     _listenerList = listenerList;
     _playerCache = playerCache;
-    _entityCache = entityCache;
   }
 
-  public void Handle(RagonBuffer reader)
+  public void Handle(RagonStream reader)
   {
     var newOwnerId = reader.ReadUShort();
     var player = _playerCache.GetPlayerByPeer(newOwnerId);

Ragon.Client/Sources/Handler/PlayerJoinHandler.cs

@@ -1,5 +1,5 @@
 /*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
+ * Copyright 2023-2024 Eduard Kargin <kargin.eduard@gmail.com>
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -33,7 +33,7 @@ internal class PlayerJoinHandler : IHandler
     _listenerList = listenerList;
   }
 
-  public void Handle(RagonBuffer reader)
+  public void Handle(RagonStream reader)
   {
     var playerPeerId = reader.ReadUShort();
     var playerId = reader.ReadString();

Ragon.Client/Sources/Handler/PlayerLeftHandler.cs

@@ -1,5 +1,5 @@
 /*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
+ * Copyright 2023-2024 Eduard Kargin <kargin.eduard@gmail.com>
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -22,21 +22,18 @@ namespace Ragon.Client;
 internal class PlayerLeftHandler : IHandler
 {
   private RagonPlayerCache _playerCache;
-  private RagonEntityCache _entityCache;
   private RagonListenerList _listenerList;
 
   public PlayerLeftHandler(
-    RagonEntityCache entityCache,
     RagonPlayerCache playerCache,
     RagonListenerList listenerList
   )
   {
-    _entityCache = entityCache;
     _playerCache = playerCache;
     _listenerList = listenerList;
   }
 
-  public void Handle(RagonBuffer reader)
+  public void Handle(RagonStream reader)
   {
     var playerId = reader.ReadString();
     var player = _playerCache.GetPlayerById(playerId);
@@ -53,9 +50,10 @@ internal class PlayerLeftHandler : IHandler
         toDeleteIds[i] = entityId;
       }
 
-      var emptyPayload = new RagonPayload(0);
-      foreach (var id in toDeleteIds)
-        _entityCache.OnDestroy(id, emptyPayload);
+    
+      // var emptyPayload = new RagonPayload(0);
+      // foreach (var id in toDeleteIds)
+        // _entityCache.OnDestroy(id, emptyPayload);
     }
     else
     {

Ragon.Client/Sources/Handler/PlayerUserDataHandler.cs

@@ -32,16 +32,16 @@ namespace Ragon.Client
       _playerCache = playerCache;
       _listenerList = listenerList;
     }
-    public void Handle(RagonBuffer reader)
+    public void Handle(RagonStream reader)
     {
       var playerPeerId = reader.ReadUShort();
       var player = _playerCache.GetPlayerByPeer(playerPeerId);
 
       if (player != null)
       {
-        player.UserData.Read(reader);
+        var changes = player.UserData.Read(reader);
         
-        _listenerList.OnPlayerUserData(player);
+        _listenerList.OnPlayerUserData(player, changes);
         
         return;
       }

Ragon.Client/Sources/Handler/RoomDataHandler.cs

@@ -1,56 +0,0 @@
-/*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-
-using Ragon.Protocol;
-
-namespace Ragon.Client;
-
-internal class RoomDataHandler: IHandler
-{
-  private readonly RagonListenerList _listeners;
-  private readonly RagonPlayerCache _playerCache;
-    
-  public RoomDataHandler(
-    RagonPlayerCache playerCache,
-    RagonListenerList listeners)
-  {
-    _playerCache = playerCache;
-    _listeners = listeners;
-  }
-
-  public void Handle(RagonBuffer reader)
-  {
-    var rawData = reader.RawData;
-    var peerId = (ushort)(rawData[1] + (rawData[2] << 8));
-    var player = _playerCache.GetPlayerByPeer(peerId);
-    
-    if (player == null)
-    {
-      RagonLog.Error($"Player with peerId:{peerId} not found");
-      
-      _playerCache.Dump();
-      return;
-    }
-    
-    var headerSize = 3;
-    var payload = new byte[rawData.Length - headerSize];
-    
-    Array.Copy(rawData, headerSize, payload, 0, payload.Length);
-    
-    _listeners.OnData(player, payload);
-  }
-}

Ragon.Client/Sources/Handler/RoomEventHandler.cs

@@ -1,5 +1,5 @@
 /*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
+ * Copyright 2023-2024 Eduard Kargin <kargin.eduard@gmail.com>
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -32,17 +32,17 @@ public class RoomEventHandler : IHandler
     _playerCache = playerCache;
   }
 
-  public void Handle(RagonBuffer buffer)
+  public void Handle(RagonStream buffer)
   {
     var eventCode = buffer.ReadUShort();
     var peerId = buffer.ReadUShort();
-    var executionMode = (RagonReplicationMode)buffer.ReadByte();
+    var executionMode = (RagonReplicationMode) buffer.ReadByte();
 
     var player = _playerCache.GetPlayerByPeer(peerId);
     if (player == null)
     {
       RagonLog.Error($"Player with peerId:{peerId} not found as owner of event with code:{eventCode}");
-      
+
       _playerCache.Dump();
       return;
     }

Ragon.Client/Sources/Handler/RoomListHandler.cs

@@ -13,7 +13,7 @@ internal class RoomListHandler: IHandler
     _listenerList = list;
   }
   
-  public void Handle(RagonBuffer reader)
+  public void Handle(RagonStream reader)
   {
     var roomCount = reader.ReadUShort();
     var roomList = new RagonRoomInformation[roomCount];

Ragon.Client/Sources/Handler/RoomUserDataHandler.cs

@@ -29,10 +29,10 @@ namespace Ragon.Client
       _listenerList = listenerList;
     }
 
-    public void Handle(RagonBuffer reader)
+    public void Handle(RagonStream reader)
     {
-      _client.Room?.HandleUserData(reader);
-      _listenerList.OnRoomUserData();
+      var changes = _client.Room?.UserData.Read(reader);
+      _listenerList.OnRoomUserData(changes);
     }
   }
 }

Ragon.Client/Sources/Handler/SnapshotHandler.cs

@@ -1,137 +0,0 @@
-/*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-
-using System.Diagnostics;
-using Ragon.Protocol;
-
-namespace Ragon.Client;
-
-internal class SnapshotHandler : IHandler
-{
-  private readonly IRagonEntityListener _entityListener;
-  private readonly RagonClient _client;
-  private readonly RagonListenerList _listenerList;
-  private readonly RagonEntityCache _entityCache;
-  private readonly RagonPlayerCache _playerCache;
-  
-  public SnapshotHandler(
-    RagonClient ragonClient,
-    RagonListenerList listenerList,
-    RagonEntityCache entityCache,
-    RagonPlayerCache playerCache,
-    IRagonEntityListener entityListener
-  )
-  {
-    _client = ragonClient;
-    _entityListener = entityListener;
-    _listenerList = listenerList;
-    _entityCache = entityCache;
-    _playerCache = playerCache;
-  }
-
-  public void Handle(RagonBuffer buffer)
-  {
-    var entities = new List<RagonEntity>();
-    var playersCount = buffer.ReadUShort();
-    RagonLog.Trace("Players: " + playersCount);
-    for (var i = 0; i < playersCount; i++)
-    {
-      var playerPeerId = buffer.ReadUShort();
-      var playerId = buffer.ReadString();
-      var playerName = buffer.ReadString();
-
-      _playerCache.AddPlayer(playerPeerId, playerId, playerName);
-
-      RagonLog.Trace($"Player {playerPeerId} - {playerId} - {playerName}");
-    }
-
-    var dynamicEntities = buffer.ReadUShort();
-    RagonLog.Trace("Dynamic Entities: " + dynamicEntities);
-    for (var i = 0; i < dynamicEntities; i++)
-    {
-      var entityType = buffer.ReadUShort();
-      var entityId = buffer.ReadUShort();
-      var ownerPeerId = buffer.ReadUShort();
-      var payloadSize = buffer.ReadUShort();
-      
-      var player = _playerCache.GetPlayerByPeer(ownerPeerId);
-      if (player == null)
-      {
-        RagonLog.Error($"Player not found with peerId: {ownerPeerId}");
-
-        _playerCache.Dump();
-        return;
-      }
-
-      var hasAuthority = _playerCache.Local.Id == player.Id;
-      var entity = _entityCache.TryGetEntity(0, entityType, 0, entityId, hasAuthority, out _);
-      var payload = RagonPayload.Empty;
-      if (payloadSize > 0)
-      {
-        payload = new RagonPayload(payloadSize);
-        payload.Read(buffer);
-      }
-      
-      entity.Prepare(_client, entityId, entityType, hasAuthority, player, payload);
-      
-      _entityListener.OnEntityCreated(entity);
-      
-      entity.Read(buffer);
-      
-      entities.Add(entity);
-    }
-
-    var staticEntities = buffer.ReadUShort();
-    RagonLog.Trace("Scene Entities: " + staticEntities);
-    for (var i = 0; i < staticEntities; i++)
-    {
-      var entityType = buffer.ReadUShort();
-      var entityId = buffer.ReadUShort();
-      var staticId = buffer.ReadUShort();
-      var ownerPeerId = buffer.ReadUShort();
-      var payloadSize = buffer.ReadUShort();
-
-      var player = _playerCache.GetPlayerByPeer(ownerPeerId);
-      if (player == null)
-      {
-        RagonLog.Error($"Player not found with peerId: {ownerPeerId}");
-        
-        _playerCache.Dump();
-        return;
-      }
-
-      var hasAuthority = _playerCache.Local.Id == player.Id;
-      var entity = _entityCache.TryGetEntity(0, entityType, staticId, entityId, hasAuthority, out _);
-      
-      entity.Prepare(_client, entityId, entityType, hasAuthority, player, RagonPayload.Empty);
-      entity.Read(buffer);
-      
-      entities.Add(entity);
-    }
-
-    if (_client.Status == RagonStatus.LOBBY)
-    { 
-      _client.SetStatus(RagonStatus.ROOM);
-      _listenerList.OnJoined();
-    }
-
-    foreach (var entity in entities)
-      entity.Attach();
-
-    _listenerList.OnSceneLoaded();
-  }
-}

Ragon.Client/Sources/Handler/TimestampHandler.cs

@@ -10,12 +10,12 @@ public class TimestampHandler: IHandler
     _client = client;
   }
   
-  public void Handle(RagonBuffer buffer)
+  public void Handle(RagonStream buffer)
   {
-    var timestamp0 = buffer.Read(32); 
-    var timestamp1 = buffer.Read(32);
+    var timestamp0 = (uint)buffer.ReadInt(); 
+    var timestamp1 = (uint)buffer.ReadInt();
     var value = new DoubleToUInt { Int0 = timestamp0, Int1 = timestamp1 };
     
-    _client.SetTimestamp(value.Double);
+    _client.UpdateTimestamp(value.Double);
   }
 }

Ragon.Client/Sources/IO/INetworkChannel.cs

@@ -1,5 +1,5 @@
 /*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
+ * Copyright 2023-2024 Eduard Kargin <kargin.eduard@gmail.com>
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.

Ragon.Client/Sources/IO/INetworkConnection.cs

@@ -1,5 +1,5 @@
 /*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
+ * Copyright 2023-2024 Eduard Kargin <kargin.eduard@gmail.com>
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.

Ragon.Client/Sources/IO/NetworkStatistics.cs

@@ -1,5 +1,5 @@
 /*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
+ * Copyright 2023-2024 Eduard Kargin <kargin.eduard@gmail.com>
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.

Ragon.Client/Sources/IRagonConnection.cs

@@ -1,5 +1,5 @@
 /*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
+ * Copyright 2023-2024 Eduard Kargin <kargin.eduard@gmail.com>
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.

Ragon.Client/Sources/IRagonEntityListener.cs

@@ -1,22 +0,0 @@
-/*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-namespace Ragon.Client;
-
-public interface IRagonEntityListener
-{
-  public void OnEntityCreated(RagonEntity entity);
-}

Ragon.Client/Sources/IRagonEvent.cs

@@ -1,5 +1,5 @@
 /*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
+ * Copyright 2023-2024 Eduard Kargin <kargin.eduard@gmail.com>
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -20,6 +20,5 @@ namespace Ragon.Client
 {
   public interface IRagonEvent: IRagonSerializable
   {
-    
   }
 }

Ragon.Client/Sources/IRagonPayload.cs

@@ -1,25 +0,0 @@
-/*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-using Ragon.Protocol;
-
-namespace Ragon.Client
-{
-  public interface IRagonPayload: IRagonSerializable
-  {
-    
-  }
-}

Ragon.Client/Sources/IRagonSceneCollector.cs

@@ -1,22 +0,0 @@
-/*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-namespace Ragon.Client;
-
-public interface IRagonSceneCollector
-{
-  public RagonEntity[] Collect();
-}

Ragon.Client/Sources/IUserData.cs

@@ -22,6 +22,6 @@ public interface IUserData
 {
   public byte[] this[string key] { get; set; }
   bool Dirty { get; }
-  void Read(RagonBuffer buffer);
-  void Write(RagonBuffer buffer);
+  IReadOnlyList<string> Read(RagonStream buffer);
+  void Write(RagonStream buffer);
 }

Ragon.Client/Sources/Listener/IRagonAuthorizationListener.cs

@@ -1,5 +1,5 @@
 /*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
+ * Copyright 2023-2024 Eduard Kargin <kargin.eduard@gmail.com>
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.

Ragon.Client/Sources/Listener/IRagonConnectionListener.cs

@@ -1,5 +1,5 @@
 /*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
+ * Copyright 2023-2024 Eduard Kargin <kargin.eduard@gmail.com>
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.

Ragon.Client/Sources/Listener/IRagonDataListener.cs

@@ -1,5 +1,5 @@
 /*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
+ * Copyright 2023-2024 Eduard Kargin <kargin.eduard@gmail.com>
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -18,5 +18,5 @@ namespace Ragon.Client;
 
 public interface IRagonDataListener
 {
-  public void OnData(RagonPlayer player, byte[] data);
+  public void OnData(RagonClient client, RagonPlayer player, byte[] data);
 }

Ragon.Client/Sources/Listener/IRagonFailedListener.cs

@@ -1,5 +1,5 @@
 /*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
+ * Copyright 2023-2024 Eduard Kargin <kargin.eduard@gmail.com>
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.

Ragon.Client/Sources/Listener/IRagonJoinListener.cs

@@ -1,5 +1,5 @@
 /*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
+ * Copyright 2023-2024 Eduard Kargin <kargin.eduard@gmail.com>
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.

Ragon.Client/Sources/Listener/IRagonLeftListener.cs

@@ -1,5 +1,5 @@
 /*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
+ * Copyright 2023-2024 Eduard Kargin <kargin.eduard@gmail.com>
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.

Ragon.Client/Sources/Listener/IRagonListener.cs

@@ -1,5 +1,5 @@
 /*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
+ * Copyright 2023-2024 Eduard Kargin <kargin.eduard@gmail.com>
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -22,7 +22,6 @@ namespace Ragon.Client
     IRagonFailedListener,
     IRagonJoinListener, 
     IRagonLeftListener, 
-    IRagonSceneListener, 
     IRagonOwnershipChangedListener,
     IRagonPlayerJoinListener, 
     IRagonPlayerLeftListener,

Ragon.Client/Sources/Listener/IRagonOwnershipChangedListener.cs

@@ -1,5 +1,5 @@
 /*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
+ * Copyright 2023-2024 Eduard Kargin <kargin.eduard@gmail.com>
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.

Ragon.Client/Sources/Listener/IRagonPlayerJoinListener.cs

@@ -1,5 +1,5 @@
 /*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
+ * Copyright 2023-2024 Eduard Kargin <kargin.eduard@gmail.com>
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.

Ragon.Client/Sources/Listener/IRagonPlayerLeftListener.cs

@@ -1,5 +1,5 @@
 /*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
+ * Copyright 2023-2024 Eduard Kargin <kargin.eduard@gmail.com>
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.

Ragon.Client/Sources/Listener/IRagonPlayerUserDataListener.cs

@@ -1,5 +1,5 @@
 /*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
+ * Copyright 2023-2024 Eduard Kargin <kargin.eduard@gmail.com>
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -18,5 +18,5 @@ namespace Ragon.Client;
 
 public interface IRagonPlayerUserDataListener
 {
-  void OnPlayerUserDataUpdated(RagonClient client, RagonPlayer player);
+  void OnPlayerUserDataUpdated(RagonClient client, RagonPlayer player, IReadOnlyList<string> changes);
 }

Ragon.Client/Sources/Listener/IRagonRoomListListener.cs

@@ -2,5 +2,5 @@ namespace Ragon.Client;
 
 public interface IRagonRoomListListener
 {
-  public void OnRoomListUpdate(IReadOnlyList<RagonRoomInformation> roomsInfos);
+  public void OnRoomListUpdate(RagonClient client, IReadOnlyList<RagonRoomInformation> roomsInfos);
 }

Ragon.Client/Sources/Listener/IRagonRoomUserDataListener.cs

@@ -2,5 +2,5 @@ namespace Ragon.Client;
 
 public interface IRagonRoomUserDataListener
 {
-  public void OnUserDataUpdated(RagonClient client);
+  public void OnUserDataUpdated(RagonClient client, IReadOnlyList<string> changes);
 }

Ragon.Client/Sources/Listener/IRagonSceneListener.cs

@@ -1,22 +0,0 @@
-/*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-namespace Ragon.Client;
-
-public interface IRagonSceneListener
-{
-  void OnSceneLoaded(RagonClient client);
-}

Ragon.Client/Sources/Listener/IRagonSceneRequestListener.cs

@@ -1,6 +0,0 @@
-namespace Ragon.Client;
-
-public interface IRagonSceneRequestListener
-{
-  void OnRequestScene(RagonClient client, string sceneName);
-}

Ragon.Client/Sources/Log/IRagonLogger.cs

@@ -1,5 +1,5 @@
 /*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
+ * Copyright 2023-2024 Eduard Kargin <kargin.eduard@gmail.com>
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.

Ragon.Client/Sources/Log/Loggers/RagonConsoleLogger.cs

@@ -1,5 +1,5 @@
 /*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
+ * Copyright 2023-2024 Eduard Kargin <kargin.eduard@gmail.com>
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.

Ragon.Client/Sources/Log/RagonLog.cs

@@ -1,5 +1,5 @@
 /*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
+ * Copyright 2023-2024 Eduard Kargin <kargin.eduard@gmail.com>
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.

Ragon.Client/Sources/Log/RagonLogLevel.cs

@@ -1,5 +1,5 @@
 /*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
+ * Copyright 2023-2024 Eduard Kargin <kargin.eduard@gmail.com>
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.

Ragon.Client/Sources/RagonClient.cs

@@ -22,18 +22,16 @@ namespace Ragon.Client
   {
     private readonly INetworkConnection _connection;
     private readonly NetworkStatistics _stats;
-    private IRagonEntityListener _entityListener;
-    private IRagonSceneCollector _sceneCollector;
+
     private IHandler[] _handlers;
-    private RagonBuffer _readBuffer;
-    private RagonBuffer _writeBuffer;
+    private RagonStream _readBuffer;
+    private RagonStream _writeBuffer;
     private RagonRoom _room;
     private RagonSession _session;
     private RagonListenerList _listeners;
     private RagonPlayerCache _playerCache;
-    private RagonEntityCache _entityCache;
     private RagonEventCache _eventCache;
-    private RagonStatus _status;
+    private RagonState _state;
 
     private double _serverTimestamp;
     private float _replicationRate = 0;
@@ -41,14 +39,13 @@ namespace Ragon.Client
 
     public double ServerTimestamp => _serverTimestamp;
     public IRagonConnection Connection => _connection;
-    public RagonStatus Status => _status;
+    public RagonState State => _state;
     public RagonSession Session => _session;
     public RagonEventCache Event => _eventCache;
-    public RagonEntityCache Entity => _entityCache;
     public NetworkStatistics Statistics => _stats;
     public RagonRoom Room => _room;
 
-    internal RagonBuffer Buffer => _writeBuffer;
+    internal RagonStream Buffer => _writeBuffer;
     internal INetworkChannel Reliable => _connection.Reliable;
     internal INetworkChannel Unreliable => _connection.Unreliable;
 
@@ -67,77 +64,41 @@ namespace Ragon.Client
       _replicationTime = 0;
 
       _eventCache = new RagonEventCache();
-      _stats = new NetworkStatistics();
-      _status = RagonStatus.DISCONNECTED;
-    }
-
-
-    public void Configure(IRagonSceneCollector sceneCollector)
-    {
-      _sceneCollector = sceneCollector;
-    }
-
-    public void Configure(IRagonEntityListener listener)
-    {
-      _entityListener = listener;
-    }
-
-    public void Connect(string address, ushort port, string protocol)
-    {
-      if (_sceneCollector == null)
-      {
-        RagonLog.Error("Scene collector is not defined!");
-        return;
-      }
-
-      if (_entityListener == null)
-      {
-        RagonLog.Error("Entity Listener is not defined!");
-        return;
-      }
-
-      _writeBuffer = new RagonBuffer();
-      _readBuffer = new RagonBuffer();
+      _writeBuffer = new RagonStream();
+      _readBuffer = new RagonStream();
       _playerCache = new RagonPlayerCache();
       _session = new RagonSession(this, _writeBuffer);
-      _entityCache = new RagonEntityCache(this, _playerCache, _sceneCollector);
-
+      _room = new RagonRoom(this, _playerCache);
+      _stats = new NetworkStatistics();
+      _state = RagonState.DISCONNECTED;
+      
       _handlers = new IHandler[byte.MaxValue];
       _handlers[(byte)RagonOperation.AUTHORIZED_SUCCESS] = new AuthorizeSuccessHandler(this, _listeners);
       _handlers[(byte)RagonOperation.AUTHORIZED_FAILED] = new AuthorizeFailedHandler(_listeners);
-      _handlers[(byte)RagonOperation.JOIN_SUCCESS] =
-        new JoinSuccessHandler(this, _listeners, _playerCache, _entityCache);
+      _handlers[(byte)RagonOperation.JOIN_SUCCESS] = new JoinSuccessHandler(this, _room);
       _handlers[(byte)RagonOperation.JOIN_FAILED] = new JoinFailedHandler(_listeners);
-      _handlers[(byte)RagonOperation.LEAVE_ROOM] = new LeaveRoomHandler(this, _listeners, _entityCache);
-      _handlers[(byte)RagonOperation.OWNERSHIP_ROOM_CHANGED] =
-        new OwnershipRoomHandler(_listeners, _playerCache, _entityCache);
-      _handlers[(byte)RagonOperation.OWNERSHIP_ENTITY_CHANGED] =
-        new EntityOwnershipHandler(_listeners, _playerCache, _entityCache);
+      _handlers[(byte)RagonOperation.LEAVE_ROOM] = new LeaveRoomHandler(this, _listeners);
+      _handlers[(byte)RagonOperation.OWNERSHIP_ROOM_CHANGED] = new OwnershipRoomHandler(_listeners, _playerCache);
       _handlers[(byte)RagonOperation.PLAYER_JOINED] = new PlayerJoinHandler(_playerCache, _listeners);
-      _handlers[(byte)RagonOperation.PLAYER_LEAVED] = new PlayerLeftHandler(_entityCache, _playerCache, _listeners);
-      _handlers[(byte)RagonOperation.LOAD_SCENE] = new SceneLoadHandler(this, _listeners);
-      _handlers[(byte)RagonOperation.CREATE_ENTITY] =
-        new EntityCreateHandler(this, _playerCache, _entityCache, _entityListener);
-      _handlers[(byte)RagonOperation.REMOVE_ENTITY] = new EntityRemoveHandler(_entityCache);
-      _handlers[(byte)RagonOperation.REPLICATE_ENTITY_STATE] = new StateEntityHandler(_entityCache);
-      _handlers[(byte)RagonOperation.REPLICATE_ENTITY_EVENT] = new EntityEventHandler(_playerCache, _entityCache);
+      _handlers[(byte)RagonOperation.PLAYER_LEAVED] = new PlayerLeftHandler(_playerCache, _listeners);
       _handlers[(byte)RagonOperation.REPLICATE_ROOM_EVENT] = new RoomEventHandler(this, _playerCache);
-      _handlers[(byte)RagonOperation.SNAPSHOT] =
-        new SnapshotHandler(this, _listeners, _entityCache, _playerCache, _entityListener);
       _handlers[(byte)RagonOperation.TIMESTAMP_SYNCHRONIZATION] = new TimestampHandler(this);
-      _handlers[(byte)RagonOperation.REPLICATE_RAW_DATA] = new RoomDataHandler(_playerCache, _listeners);
       _handlers[(byte)RagonOperation.ROOM_LIST_UPDATED] = new RoomListHandler(_session, _listeners);
       _handlers[(byte)RagonOperation.ROOM_DATA_UPDATED] = new RoomUserDataHandler(this, _listeners);
       _handlers[(byte)RagonOperation.PLAYER_DATA_UPDATED] = new PlayerUserDataHandler(_playerCache, _listeners);
-
+    }
+    
+    public void Connect(string address, ushort port, string protocol)
+    {
       var protocolRaw = RagonVersion.Parse(protocol);
       _connection.Connect(address, port, protocolRaw);
     }
 
     public void Disconnect()
     {
-      _status = RagonStatus.DISCONNECTED;
-      _room.Cleanup();
+      _state = RagonState.DISCONNECTED;
+      _room.Clear();
+      
       _connection.Disconnect();
 
       OnDisconnected(RagonDisconnect.MANUAL);
@@ -145,14 +106,13 @@ namespace Ragon.Client
 
     public void Update(float dt)
     {
-      if (_status != RagonStatus.DISCONNECTED)
+      if (_state != RagonState.DISCONNECTED)
       {
         _replicationTime += dt;
         if (_replicationTime >= _replicationRate)
         {
           _replicationTime = 0;
-          _entityCache.WriteState(_writeBuffer);
-
+        
           SendTimestamp();
           SendRoomUserData();
           SendPlayerUserData();
@@ -167,9 +127,9 @@ namespace Ragon.Client
 
     public void Dispose()
     {
-      if (_status != RagonStatus.DISCONNECTED)
+      if (_state != RagonState.DISCONNECTED)
       {
-        _status = RagonStatus.DISCONNECTED;
+        _state = RagonState.DISCONNECTED;
         _connection.Disconnect();
       }
 
@@ -185,9 +145,6 @@ namespace Ragon.Client
     public void AddListener(IRagonOwnershipChangedListener listener) => _listeners.Add(listener);
     public void AddListener(IRagonPlayerJoinListener listener) => _listeners.Add(listener);
     public void AddListener(IRagonPlayerLeftListener listener) => _listeners.Add(listener);
-    public void AddListener(IRagonSceneListener listener) => _listeners.Add(listener);
-    public void AddListener(IRagonSceneRequestListener listener) => _listeners.Add(listener);
-    public void AddListener(IRagonDataListener listener) => _listeners.Add(listener);
     public void AddListener(IRagonRoomListListener listener) => _listeners.Add(listener);
     public void AddListener(IRagonPlayerUserDataListener listener) => _listeners.Add(listener);
     public void AddListener(IRagonRoomUserDataListener listener) => _listeners.Add(listener);
@@ -200,9 +157,6 @@ namespace Ragon.Client
     public void RemoveListener(IRagonOwnershipChangedListener listener) => _listeners.Remove(listener);
     public void RemoveListener(IRagonPlayerJoinListener listener) => _listeners.Remove(listener);
     public void RemoveListener(IRagonPlayerLeftListener listener) => _listeners.Remove(listener);
-    public void RemoveListener(IRagonSceneListener listener) => _listeners.Remove(listener);
-    public void RemoveListener(IRagonSceneRequestListener listener) => _listeners.Remove(listener);
-    public void RemoveListener(IRagonDataListener listener) => _listeners.Remove(listener);
     public void RemoveListener(IRagonRoomListListener listener) => _listeners.Remove(listener);
     public void RemoveListener(IRagonRoomUserDataListener listener) => _listeners.Remove(listener);
     public void RemoveListener(IRagonPlayerUserDataListener listener) => _listeners.Remove(listener);
@@ -210,19 +164,13 @@ namespace Ragon.Client
     #endregion
 
     #region INTERNAL
-
-    internal void AssignRoom(RagonRoom room)
+    
+    internal void UpdateState(RagonState state)
     {
-      _room?.Dispose();
-      _room = room;
+      _state = state;
     }
 
-    internal void SetStatus(RagonStatus status)
-    {
-      _status = status;
-    }
-
-    internal void SetTimestamp(double time)
+    internal void UpdateTimestamp(double time)
     {
       _serverTimestamp = time;
     }
@@ -241,8 +189,8 @@ namespace Ragon.Client
 
       _writeBuffer.Clear();
       _writeBuffer.WriteOperation(RagonOperation.TIMESTAMP_SYNCHRONIZATION);
-      _writeBuffer.Write(value.Int0, 32);
-      _writeBuffer.Write(value.Int1, 32);
+      _writeBuffer.WriteInt((int)value.Int0);
+      _writeBuffer.WriteInt((int)value.Int1);
     }
 
     private void SendRoomUserData()
@@ -282,7 +230,7 @@ namespace Ragon.Client
       RagonLog.Trace("Connected");
 
       _listeners.OnConnected();
-      _status = RagonStatus.CONNECTED;
+      _state = RagonState.CONNECTED;
     }
 
     private void OnDisconnected(RagonDisconnect reason)
@@ -290,7 +238,7 @@ namespace Ragon.Client
       RagonLog.Trace($"Disconnected: {reason}");
 
       _listeners.OnDisconnected(reason);
-      _status = RagonStatus.DISCONNECTED;
+      _state = RagonState.DISCONNECTED;
     }
 
     private void OnData(byte[] data)

Ragon.Client/Sources/RagonEntityCache.cs

@@ -1,257 +0,0 @@
-/*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-using Ragon.Protocol;
-
-namespace Ragon.Client;
-
-public sealed class RagonEntityCache
-{
-  private readonly List<RagonEntity> _entityList = new();
-  private readonly Dictionary<uint, RagonEntity> _entityMap = new();
-  private readonly Dictionary<uint, RagonEntity> _pendingEntities = new();
-  private readonly Dictionary<uint, RagonEntity> _sceneEntities = new();
-
-  private readonly RagonClient _client;
-  private readonly IRagonSceneCollector _sceneCollector;
-  private readonly RagonPlayerCache _playerCache;
-
-  private int _localEntitiesCounter = 0;
-
-  public RagonEntityCache(
-    RagonClient client,
-    RagonPlayerCache playerCache,
-    IRagonSceneCollector sceneCollector
-  )
-  {
-    _client = client;
-    _sceneCollector = sceneCollector;
-    _playerCache = playerCache;
-  }
-
-  public bool TryGetEntity(ushort id, out RagonEntity entity)
-  {
-    return _entityMap.TryGetValue(id, out entity);
-  }
-
-  public void Create(RagonEntity entity, RagonPayload spawnPayload)
-  {
-    var attachId = (ushort)(_playerCache.Local.PeerId + _localEntitiesCounter++);
-    var buffer = _client.Buffer;
-
-    buffer.Clear();
-    buffer.WriteOperation(RagonOperation.CREATE_ENTITY);
-    buffer.WriteUShort(attachId);
-    buffer.WriteUShort(entity.Type);
-    buffer.WriteByte((byte)entity.Authority);
-
-    entity.State.WriteInfo(buffer);
-
-    spawnPayload?.Write(buffer);
-
-    _pendingEntities.Add(attachId, entity);
-
-    var sendData = buffer.ToArray();
-    _client.Reliable.Send(sendData);
-  }
-
-  public void Transfer(RagonEntity entity, RagonPlayer player)
-  {
-    var buffer = _client.Buffer;
-
-    buffer.Clear();
-    buffer.WriteOperation(RagonOperation.TRANSFER_ENTITY_OWNERSHIP);
-    buffer.WriteUShort(entity.Id);
-    buffer.WriteUShort(player.PeerId);
-
-    var sendData = buffer.ToArray();
-    _client.Reliable.Send(sendData);
-  }
-
-  public void Destroy(RagonEntity entity, RagonPayload destroyPayload)
-  {
-    if (!entity.IsAttached && !entity.HasAuthority)
-    {
-      RagonLog.Warn("Can't destroy object");
-      return;
-    }
-
-    entity.SetReplication(false);
-
-    var buffer = _client.Buffer;
-
-    buffer.Clear();
-    buffer.WriteOperation(RagonOperation.REMOVE_ENTITY);
-    buffer.WriteUShort(entity.Id);
-
-    destroyPayload?.Write(buffer);
-
-    var sendData = buffer.ToArray();
-    _client.Reliable.Send(sendData);
-  }
-
-  internal void WriteState(RagonBuffer buffer)
-  {
-    var changedEntities = 0u;
-
-    buffer.Clear();
-    buffer.WriteOperation(RagonOperation.REPLICATE_ENTITY_STATE);
-
-    var offset = buffer.WriteOffset;
-    buffer.Write(0, 16);
-
-    foreach (var ent in _entityList)
-    {
-      if (!ent.IsAttached ||
-          !ent.IsReplicated ||
-          !ent.PropertiesChanged) continue;
-
-      ent.Write(buffer);
-
-      changedEntities++;
-    }
-
-    if (changedEntities <= 0) return;
-
-    buffer.Write(changedEntities, 16, offset);
-
-    var data = buffer.ToArray();
-    _client.Unreliable.Send(data);
-  }
-
-  internal void WriteScene(RagonBuffer buffer)
-  {
-    _sceneEntities.Clear();
-
-    var entities = _sceneCollector.Collect();
-    buffer.WriteUShort((ushort)entities.Length);
-    foreach (var entity in entities)
-    {
-      buffer.WriteUShort(entity.Type);
-      buffer.WriteByte((byte)entity.Authority);
-      buffer.WriteUShort(entity.SceneId);
-
-      entity.State.WriteInfo(buffer);
-
-      _sceneEntities.Add(entity.SceneId, entity);
-    }
-  }
-
-  internal void CacheScene()
-  {
-    _sceneEntities.Clear();
-
-    var entities = _sceneCollector.Collect();
-    foreach (var entity in entities)
-      _sceneEntities.Add(entity.SceneId, entity);
-  }
-
-  internal void Cleanup()
-  {
-    var payload = new RagonPayload(0);
-    foreach (var ent in _entityList)
-      ent.Detach(payload);
-
-    _entityMap.Clear();
-    _entityList.Clear();
-  }
-
-  internal RagonEntity TryGetEntity(ushort attachId, ushort entityType, ushort sceneId, ushort entityId, bool hasAuthority, out bool hasCreated)
-  {
-    if (sceneId > 0)
-    {
-      if (_sceneEntities.TryGetValue(sceneId, out var sceneEntity))
-      {
-        _entityMap.Add(entityId, sceneEntity);
-
-        if (hasAuthority)
-          _entityList.Add(sceneEntity);
-
-        hasCreated = false;
-
-        return sceneEntity;
-      }
-    }
-
-    if (_pendingEntities.TryGetValue(attachId, out var pendingEntity) && hasAuthority)
-    {
-      _pendingEntities.Remove(attachId);
-      _entityMap.Add(entityId, pendingEntity);
-      _entityList.Add(pendingEntity);
-
-      hasCreated = false;
-
-      return pendingEntity;
-    }
-
-    var entity = new RagonEntity(entityType, sceneId);
-
-    _entityMap.Add(entityId, entity);
-
-    if (hasAuthority)
-      _entityList.Add(entity);
-
-    hasCreated = true;
-
-    return entity;
-  }
-
-
-  internal void OnDestroy(ushort entityId, RagonPayload payload)
-  {
-    if (_entityMap.TryGetValue(entityId, out var entity))
-    {
-      _entityMap.Remove(entityId);
-      _entityList.Remove(entity);
-
-      entity.Detach(payload);
-      entity.Dispose();
-    }
-  }
-
-  internal void OnState(ushort entityId, RagonBuffer buffer)
-  {
-    if (_entityMap.TryGetValue(entityId, out var entity))
-      entity.Read(buffer);
-    else
-      RagonLog.Warn($"Entity {entityId} not found!");
-  }
-
-  internal void OnEvent(RagonPlayer player, ushort entityId, ushort eventCode, RagonBuffer buffer)
-  {
-    if (_entityMap.TryGetValue(entityId, out var entity))
-      entity.Event(eventCode, player, buffer);
-    else
-      RagonLog.Warn($"Entity {entityId} not found!");
-  }
-
-  internal void OnOwnershipChanged(RagonPlayer player, ushort entityId)
-  {
-    if (_entityMap.TryGetValue(entityId, out var entity))
-    {
-      if (player.IsLocal)
-        _entityList.Add(entity);
-      else
-        _entityList.Remove(entity);
-
-      entity.OnOwnershipChanged(player);
-    }
-    else
-    {
-      RagonLog.Warn($"Entity {entityId} not found!");
-    }
-  }
-}

Ragon.Client/Sources/RagonEventCache.cs

@@ -1,5 +1,5 @@
 /*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
+ * Copyright 2023-2024 Eduard Kargin <kargin.eduard@gmail.com>
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -26,11 +26,13 @@ public class RagonEventCache
   public ushort GetEventCode<TEvent>(TEvent _) where TEvent : IRagonEvent
   {
     var type = typeof(TEvent);
+   
     if (!_eventsRegistryByType.TryGetValue(type, out var eventCode))
     {
       RagonLog.Error($"Event with type {type} not registered");
       return 0;
     }
+    
     return eventCode;
   }
 

Ragon.Client/Sources/RagonListenerList.cs

@@ -26,12 +26,9 @@ namespace Ragon.Client
     private readonly List<IRagonFailedListener> _failedListeners = new();
     private readonly List<IRagonJoinListener> _joinListeners = new();
     private readonly List<IRagonLeftListener> _leftListeners = new();
-    private readonly List<IRagonSceneListener> _sceneListeners = new();
-    private readonly List<IRagonSceneRequestListener> _sceneRequestListeners = new();
     private readonly List<IRagonOwnershipChangedListener> _ownershipChangedListeners = new();
     private readonly List<IRagonPlayerJoinListener> _playerJoinListeners = new();
     private readonly List<IRagonPlayerLeftListener> _playerLeftListeners = new();
-    private readonly List<IRagonDataListener> _dataListeners = new();
     private readonly List<IRagonRoomListListener> _roomListListeners = new();
     private readonly List<IRagonRoomUserDataListener> _roomUserDataListeners = new();
     private readonly List<IRagonPlayerUserDataListener> _playerUserDataListeners = new();
@@ -49,7 +46,6 @@ namespace Ragon.Client
       _failedListeners.Add(listener);
       _joinListeners.Add(listener);
       _leftListeners.Add(listener);
-      _sceneListeners.Add(listener);
       _ownershipChangedListeners.Add(listener);
       _playerJoinListeners.Add(listener);
       _playerLeftListeners.Add(listener);
@@ -66,7 +62,6 @@ namespace Ragon.Client
         _failedListeners.Remove(listener);
         _joinListeners.Remove(listener);
         _leftListeners.Remove(listener);
-        _sceneListeners.Remove(listener);
         _ownershipChangedListeners.Remove(listener);
         _playerJoinListeners.Remove(listener);
         _playerLeftListeners.Remove(listener);
@@ -83,21 +78,11 @@ namespace Ragon.Client
       _delayedActions.Clear();
     }
 
-    public void Add(IRagonDataListener dataListener)
-    {
-      _dataListeners.Add(dataListener);
-    }
-
     public void Add(IRagonAuthorizationListener listener)
     {
       _authorizationListeners.Add(listener);
     }
 
-    public void Add(IRagonSceneRequestListener listener)
-    {
-      _sceneRequestListeners.Add(listener);
-    }
-
     public void Add(IRagonConnectionListener listener)
     {
       _connectionListeners.Add(listener);
@@ -118,11 +103,6 @@ namespace Ragon.Client
       _leftListeners.Add(listener);
     }
 
-    public void Add(IRagonSceneListener listener)
-    {
-      _sceneListeners.Add(listener);
-    }
-
     public void Add(IRagonOwnershipChangedListener listener)
     {
       _ownershipChangedListeners.Add(listener);
@@ -153,16 +133,6 @@ namespace Ragon.Client
       _playerUserDataListeners.Add(listener);
     }
 
-    public void Remove(IRagonDataListener listener)
-    {
-      _delayedActions.Add(() => _dataListeners.Remove(listener));
-    }
-
-    public void Remove(IRagonSceneRequestListener listener)
-    {
-      _delayedActions.Add(() => _sceneRequestListeners.Remove(listener));
-    }
-
     public void Remove(IRagonAuthorizationListener listener)
     {
       _delayedActions.Add(() => _authorizationListeners.Remove(listener));
@@ -188,11 +158,6 @@ namespace Ragon.Client
       _delayedActions.Add(() => _leftListeners.Remove(listener));
     }
 
-    public void Remove(IRagonSceneListener listener)
-    {
-      _delayedActions.Add(() => _sceneListeners.Remove(listener));
-    }
-
     public void Remove(IRagonOwnershipChangedListener listener)
     {
       _delayedActions.Add(() => _ownershipChangedListeners.Remove(listener));
@@ -265,18 +230,6 @@ namespace Ragon.Client
         listener.OnPlayerJoined(_client, player);
     }
 
-    public void OnSceneLoaded()
-    {
-      foreach (var listener in _sceneListeners)
-        listener.OnSceneLoaded(_client);
-    }
-
-    public void OnSceneRequest(string sceneName)
-    {
-      foreach (var listener in _sceneRequestListeners)
-        listener.OnRequestScene(_client, sceneName);
-    }
-
     public void OnJoined()
     {
       foreach (var listener in _joinListeners)
@@ -295,28 +248,22 @@ namespace Ragon.Client
         listener.OnDisconnected(_client, disconnect);
     }
 
-    public void OnData(RagonPlayer player, byte[] data)
-    {
-      foreach (var listener in _dataListeners)
-        listener.OnData(player, data);
-    }
-
     public void OnRoomList(RagonRoomInformation[] roomInfos)
     {
       foreach (var listListener in _roomListListeners)
-        listListener.OnRoomListUpdate(roomInfos);
+        listListener.OnRoomListUpdate(_client, roomInfos);
     }
 
-    public void OnRoomUserData()
+    public void OnRoomUserData(IReadOnlyList<string> changes)
     {
       foreach (var userDataListener in _roomUserDataListeners)
-        userDataListener.OnUserDataUpdated(_client);
+        userDataListener.OnUserDataUpdated(_client, changes);
     }
 
-    public void OnPlayerUserData(RagonPlayer player)
+    public void OnPlayerUserData(RagonPlayer player, IReadOnlyList<string> changes)
     {
       foreach(var playerUserDataListener in _playerUserDataListeners)
-        playerUserDataListener.OnPlayerUserDataUpdated(_client, player);
+        playerUserDataListener.OnPlayerUserDataUpdated(_client, player, changes);
     }
   }
 }

Ragon.Client/Sources/RagonPlayerCache.cs

@@ -52,10 +52,10 @@ public sealed class RagonPlayerCache
     _localId = localId;
   }
 
-  public void AddPlayer(ushort peerId, string playerId, string playerName)
+  public RagonPlayer AddPlayer(ushort peerId, string playerId, string playerName)
   {
     if (_playersById.ContainsKey(playerId))
-      return;
+      return null;
 
     var isOwner = playerId == _ownerId;
     var isLocal = playerId == _localId;
@@ -73,6 +73,8 @@ public sealed class RagonPlayerCache
     _players.Add(player);
     _playersById.Add(player.Id, player);
     _playersByConnection.Add(player.PeerId, player);
+    
+    return player;
   }
 
   public void RemovePlayer(string playerId)

Ragon.Client/Sources/RagonRoom.cs

@@ -18,7 +18,7 @@ using Ragon.Protocol;
 
 namespace Ragon.Client
 {
-  public class RagonRoom : IDisposable
+  public class RagonRoom
   {
     private class EventSubscription : IDisposable
     {
@@ -47,77 +47,63 @@ namespace Ragon.Client
       }
     }
 
-    private delegate void OnEventDelegate(RagonPlayer player, RagonBuffer serializer);
+    private delegate void OnEventDelegate(RagonPlayer player, RagonStream serializer);
 
     private readonly RagonClient _client;
-    private readonly RagonScene _scene;
-    private readonly RagonEntityCache _entityCache;
     private readonly RagonPlayerCache _playerCache;
-    private readonly RoomParameters _parameters;
-    private readonly RagonUserData _userData;
+    private RoomParameters _parameters;
+    private RagonUserData _userData;
 
     public string Id => _parameters.RoomId;
     public int MinPlayers => _parameters.Min;
     public int MaxPlayers => _parameters.Max;
-    public string Scene => _scene.Name;
 
     public IReadOnlyList<RagonPlayer> Players => _playerCache.Players;
     public RagonPlayer Local => _playerCache.Local;
     public RagonPlayer Owner => _playerCache.Owner;
     public RagonUserData UserData => _userData;
 
-    private readonly Dictionary<int, OnEventDelegate> _events = new Dictionary<int, OnEventDelegate>();
+    private readonly Dictionary<int, OnEventDelegate> _events = new();
 
-    private readonly Dictionary<int, List<Action<RagonPlayer, IRagonEvent>>> _localListeners =
-      new Dictionary<int, List<Action<RagonPlayer, IRagonEvent>>>();
+    private readonly Dictionary<int, List<Action<RagonPlayer, IRagonEvent>>> _localListeners = new();
 
-    private readonly Dictionary<int, List<Action<RagonPlayer, IRagonEvent>>> _listeners =
-      new Dictionary<int, List<Action<RagonPlayer, IRagonEvent>>>();
-
-    public RagonRoom(RagonClient client,
-      RagonEntityCache entityCache,
-      RagonPlayerCache playerCache,
-      RoomParameters parameters,
-      RagonScene scene)
+    private readonly Dictionary<int, List<Action<RagonPlayer, IRagonEvent>>> _listeners = new();
+    
+    public RagonRoom(RagonClient client, RagonPlayerCache playerCache)
     {
       _client = client;
-      _parameters = parameters;
-      _entityCache = entityCache;
       _playerCache = playerCache;
-      _scene = scene;
-      _userData = new RagonUserData();
+      
     }
 
-    internal void Cleanup()
+    public void Reset(RoomParameters parameters)
     {
-      _entityCache.Cleanup();
+      Clear();
+    
+      _userData = new RagonUserData();
+      _parameters = parameters;
       _playerCache.Cleanup();
     }
-
-    internal void Update(string sceneName)
-    {
-      _scene.Update(sceneName);
-    }
-
-    internal void HandleEvent(ushort eventCode, RagonPlayer caller, RagonBuffer buffer)
+    
+    internal void HandleEvent(ushort eventCode, RagonPlayer caller, RagonStream buffer)
     {
       if (_events.TryGetValue(eventCode, out var evnt))
         evnt?.Invoke(caller, buffer);
       else
-        RagonLog.Warn($"Handler event on entity {Id} with eventCode {eventCode} not defined");
+        RagonLog.Warn($"Handler event {Id} with eventCode {eventCode} not defined");
     }
 
-    internal void HandleUserData(RagonBuffer buffer)
+    internal void HandleUserData(RagonStream buffer)
     {
       _userData.Read(buffer);
     }
-    
+
     public IDisposable OnEvent<TEvent>(Action<RagonPlayer, TEvent> callback) where TEvent : IRagonEvent, new()
     {
       var t = new TEvent();
       var eventCode = _client.Event.GetEventCode(t);
       var action = (RagonPlayer player, IRagonEvent eventData) => callback.Invoke(player, (TEvent)eventData);
-
+      
       if (!_listeners.TryGetValue(eventCode, out var callbacks))
       {
         callbacks = new List<Action<RagonPlayer, IRagonEvent>>();
@@ -147,28 +133,64 @@ namespace Ragon.Client
       return new EventSubscription(callbacks, localCallbacks, action);
     }
 
-    public void LoadScene(string sceneName) => _scene.Load(sceneName);
-    public void SceneLoaded() => _scene.SceneLoaded();
-
-    public void ReplicateEvent<TEvent>(TEvent evnt, RagonTarget target, RagonReplicationMode mode)
-      where TEvent : IRagonEvent, new() => _scene.ReplicateEvent(evnt, target, mode);
-
-    public void ReplicateEvent<TEvent>(TEvent evnt, RagonPlayer target, RagonReplicationMode mode)
-      where TEvent : IRagonEvent, new() => _scene.ReplicateEvent(evnt, target, mode);
-
-    public void ReplicateData(byte[] data, bool reliable = false) => _scene.ReplicateData(data, reliable);
-
-    public void CreateEntity(RagonEntity entity) => CreateEntity(entity, null);
-    public void CreateEntity(RagonEntity entity, RagonPayload payload) => _entityCache.Create(entity, payload);
-    public void TransferEntity(RagonEntity entity, RagonPlayer player) => _entityCache.Transfer(entity, player);
-
-    public void DestroyEntity(RagonEntity entityId) => DestroyEntity(entityId, null);
-    public void DestroyEntity(RagonEntity entityId, RagonPayload payload) => _entityCache.Destroy(entityId, payload);
-
-    public void Dispose()
+    public void ReplicateEvent<TEvent>(TEvent evnt, RagonTarget target, RagonReplicationMode replicationMode)
+      where TEvent : IRagonEvent, new()
     {
-      Cleanup();
+      var evntId = _client.Event.GetEventCode(evnt);
+      var buffer = _client.Buffer;
 
+      {
+        if (replicationMode == RagonReplicationMode.Local &&
+            _localListeners.TryGetValue(evntId, out var localListeners))
+        {
+          foreach (var listener in localListeners)
+            listener.Invoke(_client.Room.Local, evnt);
+          return;
+        }
+      }
+
+      {
+        if (replicationMode == RagonReplicationMode.LocalAndServer &&
+            _localListeners.TryGetValue(evntId, out var localListeners))
+        {
+          foreach (var listener in localListeners)
+            listener.Invoke(_client.Room.Local, evnt);
+        }
+      }
+
+      buffer.Clear();
+      buffer.WriteOperation(RagonOperation.REPLICATE_ROOM_EVENT);
+      buffer.WriteUShort(evntId);
+      buffer.WriteByte((byte)replicationMode);
+      buffer.WriteByte((byte)target);
+
+      evnt.Serialize(buffer);
+
+      var sendData = buffer.ToArray();
+      _client.Reliable.Send(sendData);
+    }
+
+    public void ReplicateEvent<TEvent>(TEvent evnt, RagonPlayer target, RagonReplicationMode replicationMode)
+      where TEvent : IRagonEvent, new()
+    {
+      var evntId = _client.Event.GetEventCode(evnt);
+      var buffer = _client.Buffer;
+
+      buffer.Clear();
+      buffer.WriteOperation(RagonOperation.REPLICATE_ROOM_EVENT);
+      buffer.WriteUShort(evntId);
+      buffer.WriteByte((byte)replicationMode);
+      buffer.WriteByte((byte)RagonTarget.Player);
+      buffer.WriteUShort(target.PeerId);
+
+      evnt.Serialize(buffer);
+
+      var sendData = buffer.ToArray();
+      _client.Reliable.Send(sendData);
+    }
+
+    public void Clear()
+    {
       _events.Clear();
       _listeners.Clear();
       _localListeners.Clear();

Ragon.Client/Sources/RagonScene.cs

@@ -1,117 +0,0 @@
-/*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-using Ragon.Protocol;
-
-namespace Ragon.Client;
-
-public class RagonScene
-{
-  public string Name { get; private set; }
-  
-  private readonly RagonClient _client;
-  private readonly RagonEntityCache _entityCache;
-  private readonly RagonPlayerCache _playerCache;
-  
-  public RagonScene(RagonClient client, RagonPlayerCache playerCache, RagonEntityCache entityCache, string sceneName)
-  {
-    Name = sceneName;
-    
-    _client = client;
-    _playerCache = playerCache;
-    _entityCache = entityCache;
-  }
-
-  internal void Update(string scene)
-  {
-    Name = scene;
-  }
-  
-  internal void Load(string sceneName)
-  {
-    var buffer = _client.Buffer;
-    
-    buffer.Clear();
-    buffer.WriteOperation(RagonOperation.LOAD_SCENE);
-    buffer.WriteString(sceneName);
-
-    var sendData = buffer.ToArray();
-    _client.Reliable.Send(sendData);
-  }
-
-  internal void SceneLoaded()
-  {
-    var buffer = _client.Buffer;
-    
-    buffer.Clear();
-    buffer.WriteOperation(RagonOperation.SCENE_LOADED);
-
-    if (_playerCache.IsRoomOwner)
-      _entityCache.WriteScene(buffer);
-    else
-      _entityCache.CacheScene();
-    
-    var sendData = buffer.ToArray();
-    _client.Reliable.Send(sendData);
-  }
-
-  internal void ReplicateEvent<TEvent>(TEvent evnt, RagonTarget target, RagonReplicationMode replicationMode)
-    where TEvent : IRagonEvent, new()
-  {
-    var evntId = _client.Event.GetEventCode(evnt);
-    var buffer = _client.Buffer;
-    
-    buffer.Clear();
-    buffer.WriteOperation(RagonOperation.REPLICATE_ROOM_EVENT);
-    buffer.WriteUShort(evntId);
-    buffer.WriteByte((byte)replicationMode);
-    buffer.WriteByte((byte)target);
-    
-    var sendData = buffer.ToArray();
-    _client.Reliable.Send(sendData);
-  }
-  
-  internal void ReplicateEvent<TEvent>(TEvent evnt, RagonPlayer target, RagonReplicationMode replicationMode)
-    where TEvent : IRagonEvent, new()
-  {
-    var evntId = _client.Event.GetEventCode(evnt);
-    var buffer = _client.Buffer;
-
-    buffer.Clear();
-    buffer.WriteOperation(RagonOperation.REPLICATE_ROOM_EVENT);
-    buffer.WriteUShort(evntId);
-    buffer.WriteByte((byte)replicationMode);
-    buffer.WriteByte((byte)RagonTarget.Player);
-    buffer.WriteUShort(target.PeerId);
-
-    evnt.Serialize(buffer);
-
-    var sendData = buffer.ToArray();
-    _client.Reliable.Send(sendData);
-  }
-
-  public void ReplicateData(byte[] data, bool reliable)
-  {
-    var sendData = new byte[data.Length + 1];
-    sendData[0] = (byte) RagonOperation.REPLICATE_RAW_DATA;
-    Array.Copy(data, 0, sendData, 1, data.Length);
-    
-    if (reliable)
-      _client.Reliable.Send(sendData);
-    else
-      _client.Unreliable.Send(sendData);
-  }
-}

Ragon.Client/Sources/RagonSession.cs

@@ -1,5 +1,5 @@
 /*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
+ * Copyright 2023-2024 Eduard Kargin <kargin.eduard@gmail.com>
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -21,21 +21,22 @@ namespace Ragon.Client
   public class RagonSession
   {
     private readonly RagonClient _client;
-    private readonly RagonBuffer _buffer;
     
-    public RagonSession(RagonClient client, RagonBuffer buffer)
+    private readonly RagonStream _buffer;
+
+    public RagonSession(RagonClient client, RagonStream buffer)
     {
       _client = client;
       _buffer = buffer;
     }
 
-    public void CreateOrJoin(string sceneName, int minPlayers, int maxPlayers)
+    public void CreateOrJoin(string sessionName, int minPlayers, int maxPlayers)
     {
-      var parameters = new RagonRoomPayload() {Scene = sceneName, Min = minPlayers, Max = maxPlayers};
+      var parameters = new RagonRoomParameters() { Min = minPlayers, Max = maxPlayers };
       CreateOrJoin(parameters);
     }
-    
-    public void CreateOrJoin(RagonRoomPayload parameters)
+
+    public void CreateOrJoin(RagonRoomParameters parameters)
     {
       _buffer.Clear();
       _buffer.WriteOperation(RagonOperation.JOIN_OR_CREATE_ROOM);
@@ -46,17 +47,17 @@ namespace Ragon.Client
       _client.Reliable.Send(sendData);
     }
 
-    public void Create(string sceneName, int minPlayers, int maxPlayers)
+    public void Create(string sessionName, int minPlayers, int maxPlayers)
     {
-      Create(null, new RagonRoomPayload() {Scene = sceneName, Min = minPlayers, Max = maxPlayers});
+      Create(null, new RagonRoomParameters() { Min = minPlayers, Max = maxPlayers });
     }
 
-    public void Create(string roomId, string sceneName, int minPlayers, int maxPlayers)
+    public void Create(string roomId, string sessionName, int minPlayers, int maxPlayers)
     {
-      Create(roomId, new RagonRoomPayload() {Scene = sceneName, Min = minPlayers, Max = maxPlayers});
+      Create(roomId, new RagonRoomParameters() { Min = minPlayers, Max = maxPlayers });
     }
-    
-    public  void Create(string roomId, RagonRoomPayload parameters)
+
+    public void Create(string roomId, RagonRoomParameters parameters)
     {
       _buffer.Clear();
       _buffer.WriteOperation(RagonOperation.CREATE_ROOM);
@@ -76,14 +77,14 @@ namespace Ragon.Client
       var sendData = _buffer.ToArray();
       _client.Reliable.Send(sendData);
     }
-    
-    public  void Leave()
+
+    public void Leave()
     {
-      var sendData = new[] {(byte) RagonOperation.LEAVE_ROOM};
+      var sendData = new[] { (byte)RagonOperation.LEAVE_ROOM };
       _client.Reliable.Send(sendData);
     }
 
-    public  void Join(string roomId)
+    public void Join(string roomId)
     {
       _buffer.Clear();
       _buffer.WriteOperation(RagonOperation.JOIN_ROOM);
@@ -93,7 +94,7 @@ namespace Ragon.Client
       _client.Reliable.Send(sendData);
     }
 
-    public  void AuthorizeWithKey(string key, string playerName, string payload = "")
+    public void AuthorizeWithKey(string key, string playerName, string payload = "")
     {
       _buffer.Clear();
       _buffer.WriteOperation(RagonOperation.AUTHORIZE);
@@ -104,6 +105,5 @@ namespace Ragon.Client
       var sendData = _buffer.ToArray();
       _client.Reliable.Send(sendData);
     }
-    
   }
 }

Ragon.Client/Sources/RagonState.cs

@@ -1,5 +1,5 @@
 /*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
+ * Copyright 2023-2024 Eduard Kargin <kargin.eduard@gmail.com>
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -16,7 +16,7 @@
 
 namespace Ragon.Client
 {
-  public enum RagonStatus
+  public enum RagonState
   {
     DISCONNECTED,
     CONNECTED,

Ragon.Client/Sources/RagonUserData.cs

@@ -18,7 +18,7 @@ using Ragon.Protocol;
 
 namespace Ragon.Client
 {
-  public class RagonUserData: IUserData
+  public class RagonUserData : IUserData
   {
     public byte[] this[string key]
     {
@@ -26,45 +26,79 @@ namespace Ragon.Client
       set
       {
         _properties[key] = value;
-        
-        _dirty = true;
+
+        if (!_changesCache.ContainsKey(key))
+        {
+          _localChanges.Add(key);
+          _changesCache.Add(key, true);
+        }
       }
     }
-    public bool Dirty => _dirty;
 
-    private bool _dirty = false;
+    public void Remove(string key)
+    {
+      if (_properties.Remove(key))
+      {
+        if (!_changesCache.ContainsKey(key))
+        {
+          _localChanges.Add(key);
+          _changesCache.Add(key, true);
+        }
+      }
+    }
+
+    public bool Dirty => _localChanges.Count > 0;
+
+    private readonly List<string> _localChanges = new();
+    private readonly Dictionary<string, bool> _changesCache = new();
     private readonly Dictionary<string, byte[]> _properties = new();
-    
+
     public RagonUserData()
     {
     }
 
-    public void Read(RagonBuffer buffer)
+    public IReadOnlyList<string> Read(RagonStream buffer)
     {
-      _properties.Clear();
-      
       var len = buffer.ReadUShort();
+      var changes = new List<string>(len);
       for (int i = 0; i < len; i++)
       {
         var key = buffer.ReadString();
         var valueSize = buffer.ReadUShort();
-        var value = buffer.ReadBytes(valueSize);
+        if (valueSize > 0)
+        {
+          var value = buffer.ReadBinary(valueSize);
+          _properties[key] = value;
+        }
+        else
+        {
+          _properties.Remove(key);
+        }
 
-        _properties[key] = value;
-      }  
+        changes.Add(key);
+      }
+
+      return changes;
     }
 
-    public void Write(RagonBuffer buffer)
+    public void Write(RagonStream buffer)
     {
-      buffer.WriteUShort((ushort)_properties.Count);
-      foreach (var property in _properties)
+      buffer.WriteUShort((ushort)_localChanges.Count);
+      foreach (var propertyChanged in _localChanges)
       {
-        buffer.WriteString(property.Key);
-        buffer.WriteUShort((ushort) property.Value.Length);
-        buffer.WriteBytes(property.Value);
+        buffer.WriteString(propertyChanged);
+        if (_properties.TryGetValue(propertyChanged, out var property))
+        {
+          buffer.WriteUShort((ushort)property.Length);
+          buffer.WriteBinary(property);
+        }
+        else
+        {
+          buffer.WriteUShort(0);
+        }
       }
-      
-      _dirty = false;
+
+      _localChanges.Clear();
     }
   }
 }

Ragon.Client/Sources/RagonUserDataReadOnly.cs

@@ -35,31 +35,33 @@ public class RagonUserDataReadOnly : IUserData
   {
   }
 
-  public void Write(RagonBuffer buffer)
+  public void Write(RagonStream buffer)
   {
-    buffer.WriteUShort((ushort)_properties.Count);
-    foreach (var property in _properties)
-    {
-      buffer.WriteString(property.Key);
-      buffer.WriteUShort((ushort)property.Value.Length);
-      buffer.WriteBytes(property.Value);
-    }
-
-    _dirty = false;
+  
   }
 
-  public void Read(RagonBuffer buffer)
+  public IReadOnlyList<string> Read(RagonStream buffer)
   {
-    _properties.Clear();
-
     var len = buffer.ReadUShort();
+    var changes = new List<string>(len);
     for (int i = 0; i < len; i++)
     {
       var key = buffer.ReadString();
-      var valueSize = buffer.ReadUShort();
-      var value = buffer.ReadBytes(valueSize);
-
-      _properties[key] = value;
+      var valueSize = buffer.ReadUShort();  
+      if (valueSize > 0)
+      {
+        var value = buffer.ReadBinary(valueSize);
+        _properties[key] = value;
+          
+      }
+      else
+      {
+        _properties.Remove(key);
+      }
+        
+      changes.Add(key);
     }
+
+    return changes;
   }
 }

Ragon.Client/Sources/Utils/CompressorExtension.cs

@@ -1,27 +0,0 @@
-using Ragon.Client.Compressor;
-using Ragon.Protocol;
-
-namespace Ragon.Client.Utils;
-
-public static class CompressorExtension
-{
-  public static float Read(this FloatCompressor compressor, RagonBuffer buffer)
-  {
-    return compressor.Decompress(buffer.Read(compressor.RequiredBits));
-  }
-
-  public static void Write(this FloatCompressor compressor, RagonBuffer buffer, float value)
-  {
-    buffer.Write(compressor.Compress(value), compressor.RequiredBits);
-  }
-  
-  public static float Read(this IntCompressor compressor, RagonBuffer buffer)
-  {
-    return compressor.Decompress(buffer.Read(compressor.RequiredBits));
-  }
-
-  public static void Write(this IntCompressor compressor, RagonBuffer buffer, int value)
-  {
-    buffer.Write(compressor.Compress(value), compressor.RequiredBits);
-  }
-}

Ragon.Protocol/Ragon.Protocol.csproj

@@ -8,7 +8,9 @@
         <GeneratePackageOnBuild>true</GeneratePackageOnBuild>
         <Title>Ragon.Protocol</Title>
         <Copyright>Eduard Kargin</Copyright>
-        <PackageProjectUrl>https://ragon-server.com</PackageProjectUrl>
+        <Version>1.4.0</Version>
+        <Authors>Eduard Kargin</Authors>
+        <PackageProjectUrl>https://ragon.io</PackageProjectUrl>
         <RepositoryUrl>https://github.com/edmand46/Ragon</RepositoryUrl>
         <RepositoryType>Source</RepositoryType>
         <PackageLicenseExpression>Apache-2.0</PackageLicenseExpression>

Ragon.Protocol/Sources/RagonAuthority.cs

@@ -1,5 +1,5 @@
 /*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
+ * Copyright 2023-2024 Eduard Kargin <kargin.eduard@gmail.com>
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.

Ragon.Protocol/Sources/RagonBuffer.cs

@@ -331,6 +331,9 @@ namespace Ragon.Protocol
       var limit = (size + 32 - 1) / 32;
       var capacity = size;
 
+      if (index + limit >= _buckets.Length)
+        Resize(size);
+      
       for (int i = 0; i < limit; i++)
       {
         var dataSize = capacity > 32 ? 32 : capacity;

Ragon.Protocol/Sources/RagonOperation.cs

@@ -1,5 +1,5 @@
 /*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
+ * Copyright 2023-2024 Eduard Kargin <kargin.eduard@gmail.com>
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -17,7 +17,7 @@
 
 namespace Ragon.Protocol
 {
-  public enum RagonOperation: byte
+  public enum RagonOperation : byte
   {
     AUTHORIZE = 1,
     AUTHORIZED_SUCCESS = 2,
@@ -26,23 +26,13 @@ namespace Ragon.Protocol
     CREATE_ROOM = 5,
     JOIN_ROOM = 6,
     LEAVE_ROOM = 7,
-    OWNERSHIP_ENTITY_CHANGED = 8,
-    OWNERSHIP_ROOM_CHANGED= 9,
+    OWNERSHIP_ROOM_CHANGED = 9,
     JOIN_SUCCESS = 10,
     JOIN_FAILED = 11,
-    LOAD_SCENE = 12,
-    SCENE_LOADED = 13,
     PLAYER_JOINED = 14,
     PLAYER_LEAVED = 15,
-    CREATE_ENTITY = 16,
-    REMOVE_ENTITY = 17,
-    SNAPSHOT = 18,
-    REPLICATE_ENTITY_STATE = 19,
-    REPLICATE_ENTITY_EVENT = 20,
-    REPLICATE_RAW_DATA = 21,
     REPLICATE_ROOM_EVENT = 22,
     TRANSFER_ROOM_OWNERSHIP = 23,
-    TRANSFER_ENTITY_OWNERSHIP = 24,
     TIMESTAMP_SYNCHRONIZATION = 25,
     ROOM_LIST_UPDATED = 26,
     PLAYER_DATA_UPDATED = 27,

Ragon.Protocol/Sources/RagonReplicationMode.cs

@@ -1,5 +1,5 @@
 /*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
+ * Copyright 2023-2024 Eduard Kargin <kargin.eduard@gmail.com>
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.

Ragon.Protocol/Sources/RagonRoomParameters.cs

@@ -1,5 +1,5 @@
 /*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
+ * Copyright 2023-2024 Eduard Kargin <kargin.eduard@gmail.com>
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -17,24 +17,21 @@
 
 namespace Ragon.Protocol
 {
-  public class RagonRoomPayload: IRagonSerializable
+  public class RagonRoomParameters
   {
-    public string Scene { get; set; }
     public int Min { get; set; } 
     public int Max { get; set; } 
     
-    public void Serialize(RagonBuffer buffer)
+    public void Serialize(RagonStream buffer)
     {
-      buffer.WriteString(Scene);
-      buffer.WriteInt(Min, 1, 32);
-      buffer.WriteInt(Max, 1, 32);
+      buffer.WriteInt(Min);
+      buffer.WriteInt(Max);
     }
 
-    public void Deserialize(RagonBuffer buffer)
+    public void Deserialize(RagonStream buffer)
     {
-      Scene = buffer.ReadString();
-      Min = buffer.ReadInt(1, 32);
-      Max = buffer.ReadInt(1, 32);
+      Min = buffer.ReadInt();
+      Max = buffer.ReadInt();
     }
   }
 }

Ragon.Protocol/Sources/RagonSerializable.cs

@@ -1,5 +1,5 @@
 /*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
+ * Copyright 2023-2024 Eduard Kargin <kargin.eduard@gmail.com>
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -19,7 +19,7 @@ namespace Ragon.Protocol
 {
   public interface IRagonSerializable
   {
-    public void Serialize(RagonBuffer buffer);
-    public void Deserialize(RagonBuffer buffer);
+    public void Serialize(RagonStream buffer);
+    public void Deserialize(RagonStream buffer);
   }
 }

Ragon.Protocol/Sources/RagonTarget.cs

@@ -1,5 +1,5 @@
 /*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
+ * Copyright 2023-2024 Eduard Kargin <kargin.eduard@gmail.com>
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.

Ragon.Protocol/Sources/RagonUtils.cs

@@ -1,5 +1,5 @@
 /*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
+ * Copyright 2023-2024 Eduard Kargin <kargin.eduard@gmail.com>
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.

Ragon.Protocol/Sources/RagonVersion.cs

@@ -1,5 +1,5 @@
 /*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
+ * Copyright 2023-2024 Eduard Kargin <kargin.eduard@gmail.com>
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.

Ragon.Relay/Program.cs

@@ -1,5 +1,5 @@
 /*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
+ * Copyright 2023-2024 Eduard Kargin <kargin.eduard@gmail.com>
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.

Ragon.Relay/Ragon.Relay.csproj

@@ -3,7 +3,7 @@
     <PropertyGroup>
         <OutputType>Exe</OutputType>
         <RootNamespace>Ragon.Relay</RootNamespace>
-        <TargetFrameworks>net7.0;net8.0</TargetFrameworks>
+        <TargetFramework>net8.0</TargetFramework>
     </PropertyGroup>
 
     <PropertyGroup Condition=" '$(Configuration)' == 'Release' ">
@@ -23,9 +23,15 @@
     </ItemGroup>
 
     <ItemGroup>
-      <ProjectReference Include="..\Ragon.Server.ENetServer\Ragon.Server.ENetServer.csproj" />
-      <ProjectReference Include="..\Ragon.Server.WebSocketServer\Ragon.Server.WebSocketServer.csproj" />
       <ProjectReference Include="..\Ragon.Server\Ragon.Server.csproj" />
     </ItemGroup>
 
+    <ItemGroup>
+      <PackageReference Include="ENet-CSharp" Version="2.4.8" />
+      <PackageReference Include="Google.Protobuf" Version="3.29.0" />
+      <PackageReference Include="MsgPack.Cli" Version="1.0.1" />
+      <PackageReference Include="Newtonsoft.Json" Version="13.0.3" />
+      <PackageReference Include="NLog" Version="5.3.2" />
+    </ItemGroup>
+
 </Project>

Ragon.Relay/Sources/Command/KickPlayerCommand.cs

@@ -1,6 +0,0 @@
-namespace Ragon.Relay;
-
-public class KickPlayerCommand
-{
-  public string Id;
-}

Ragon.Relay/Sources/Logger/RelayLogger.cs

@@ -0,0 +1,40 @@
+using System;
+using NLog;
+using Ragon.Server.Logging;
+
+namespace Ragon.Relay;
+
+public class RelayLogger: IRagonLogger
+{
+  private Logger _nlogger;
+  
+  public RelayLogger(string tag)
+  {
+    _nlogger = LogManager.GetLogger(tag);
+  }
+  
+  public void Warning(string message)
+  {
+    _nlogger.Warn(message);
+  }
+
+  public void Info(string message)
+  {
+    _nlogger.Info(message);
+  }
+
+  public void Error(string message)
+  {
+    _nlogger.Error(message);
+  }
+
+  public void Error(Exception ex)
+  {
+    _nlogger.Error(ex);
+  }
+
+  public void Trace(string message)
+  {
+    _nlogger.Trace(message);
+  }
+}

Ragon.Relay/Sources/Logger/RelayLoggerFactory.cs

@@ -0,0 +1,11 @@
+using Ragon.Server.Logging;
+
+namespace Ragon.Relay;
+
+public class RelayLoggerFactory: IRagonLoggerFactory
+{
+  public IRagonLogger GetLogger(string tag)
+  {
+    return new RelayLogger(tag);
+  }
+}

Ragon.Relay/Sources/Plugin/RelayRoomPlugin.cs

@@ -0,0 +1,23 @@
+using System;
+using Ragon.Server.Plugin;
+
+namespace Ragon.Relay;
+
+public class RelayRoomPlugin: BaseRoomPlugin
+{
+  public void Tick(float dt)
+  {
+    
+  }
+  public void OnAttached()
+  {
+    Console.WriteLine("Room attached");
+    
+    
+  }
+
+  public void OnDetached()
+  {
+    Console.WriteLine("Room detached");
+  }
+}

Ragon.Relay/Sources/Plugin/RelayServerPlugin.cs

@@ -0,0 +1,43 @@
+using Ragon.Server;
+using Ragon.Server.Lobby;
+using Ragon.Server.Plugin;
+using Ragon.Server.Time;
+
+namespace Ragon.Relay
+{
+  public class RelayServerPlugin : BaseServerPlugin
+  {
+    private RelayConfiguration _relayConfiguration;
+    private RagonScheduler _scheduler;
+    private RagonConnectionRegistry _connectionRegistry;
+    private IRagonLobby _lobby;
+    private Reporter _reporter;
+
+    public RelayServerPlugin(RelayConfiguration config)
+    {
+      _relayConfiguration = config;
+    }
+
+    public override void OnAttached(IRagonServer server)
+    {
+      base.OnAttached(server);
+      
+      _lobby = server.Lobby;
+      _connectionRegistry = server.ConnectionRegistry;
+      _scheduler = server.Scheduler;
+      _reporter = new Reporter(_relayConfiguration, server, "127.0.0.1", 5000);
+
+      server.Scheduler.Run(new RagonActionTimer(() => _reporter.Done(), 1, -1));
+    }
+
+    public override bool OnCommand(string command, string payload)
+    {
+      return true;
+    }
+
+    public override IRoomPlugin CreateRoomPlugin(RoomInformation information)
+    {
+      return new RelayRoomPlugin();
+    }
+  }
+}

Ragon.Relay/Sources/Relay.cs

@@ -1,5 +1,5 @@
 /*
- * Copyright 2023 Eduard Kargin <kargin.eduard@gmail.com>
+ * Copyright 2023-2024 Eduard Kargin <kargin.eduard@gmail.com>
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -14,39 +14,68 @@
  * limitations under the License.
  */
 
-using NLog;
+using System.IO;
+using System.Threading;
+using Newtonsoft.Json;
 using Ragon.Server;
-using Ragon.Server.ENetServer;
-using Ragon.Server.WebSocketServer;
 using Ragon.Server.IO;
+using Ragon.Server.Logging;
 using Ragon.Server.Plugin;
+using Ragon.Server.WebSocketServer;
+using Ragon.Transport;
 
-namespace Ragon.Relay;
-
-public class Relay
+namespace Ragon.Relay
 {
-  public void Start()
+  public class Relay
   {
-    var logger = LogManager.GetLogger("Ragon.Relay");
-    logger.Info("Relay Application");
-
-    var configuration = RagonServerConfiguration.Load("relay.config.json");
-    var serverType = RagonServerConfiguration.GetServerType(configuration.ServerType);
-
-    INetworkServer networkServer = new ENetServer();
-    IServerPlugin plugin = new RelayServerPlugin();
-    switch (serverType)
+    public void Start()
     {
-      case ServerType.ENET:
-        networkServer = new ENetServer();
-        break;
-      case ServerType.WEBSOCKET:
-        networkServer = new WebSocketServer();
-        break;
-    }
+      LoggerManager.SetLoggerFactory(new RelayLoggerFactory());
 
-    var relay = new RagonServer(networkServer, plugin, configuration);
-    logger.Info("Started");
-    relay.Start();
+      var logger = LoggerManager.GetLogger("Relay");
+      logger.Info("Relay Application");
+
+      var data = File.ReadAllText("relay.config.json");
+      var configuration = JsonConvert.DeserializeObject<RelayConfiguration>(data);
+      var serverType = RagonServerConfiguration.GetServerType(configuration.ServerType);
+
+      INetworkServer networkServer = new ENetServer();
+      IServerPlugin plugin = new RelayServerPlugin();
+      
+      switch (serverType)
+      {
+        case ServerType.ENET:
+          networkServer = new ENetServer();
+          break;
+        case ServerType.WEBSOCKET:
+          networkServer = new WebSocketServer();
+          break;
+      }
+
+      var serverConfiguration = new RagonServerConfiguration()
+      {
+        LimitConnections = configuration.LimitConnections,
+        LimitRooms = configuration.LimitRooms,
+        LimitBufferedEvents = configuration.LimitBufferedEvents,
+        LimitPlayersPerRoom = configuration.LimitPlayersPerRoom,
+        LimitUserDataSize = configuration.LimitUserDataSize,
+        LimitPropertySize = configuration.LimitPropertySize,
+        Port = configuration.Port,
+        Protocol = configuration.Protocol,
+        ServerKey = configuration.ServerKey,
+        ServerTickRate = configuration.ServerTickRate,
+        ServerAddress = configuration.ServerAddress,
+      };
+      
+      var relay = new RagonServer(networkServer, plugin, serverConfiguration);
+      relay.Listen();
+      while (relay.IsRunning)
+      {
+        relay.Tick();
+        Thread.Sleep(1);
+      }
+
+      relay.Dispose();
+    }
   }
 }

Ragon.Relay/Sources/RelayConfiguration.cs

@@ -0,0 +1,21 @@
+using System;
+
+namespace Ragon.Relay
+{
+  [Serializable]
+  public struct RelayConfiguration
+  {
+    public string ServerKey;
+    public string ServerType;
+    public string ServerAddress;
+    public ushort ServerTickRate;
+    public string Protocol;
+    public ushort Port;
+    public int LimitConnections;
+    public int LimitPlayersPerRoom;
+    public int LimitRooms;
+    public int LimitBufferedEvents;
+    public int LimitUserDataSize;
+    public int LimitPropertySize;
+  }
+}

Ragon.Relay/Sources/RelayRoomPlugin.cs

@@ -1,37 +0,0 @@
-using System;
-using Ragon.Server;
-using Ragon.Server.Entity;
-using Ragon.Server.Plugin;
-using Ragon.Server.Room;
-
-namespace Ragon.Relay;
-
-public class RelayRoomPlugin: BaseRoomPlugin
-{
-  public void Tick(float dt)
-  {
-    
-  }
-
-  public void OnAttached()
-  {
-    Console.WriteLine("Room attached");
-  }
-
-  public void OnDetached()
-  {
-    Console.WriteLine("Room detached");
-  }
-
-  public bool OnEntityCreate(RagonRoomPlayer creator, RagonEntity entity)
-  {
-    Console.WriteLine($"Entity created: {entity.Id}");
-    return true;
-  }
-
-  public bool OnEntityRemove(RagonRoomPlayer destroyer, RagonEntity entity)
-  {
-    Console.WriteLine($"Entity destroyed: {entity.Id}");
-    return true;
-  }
-}

Ragon.Relay/Sources/RelayServerPlugin.cs

@@ -1,30 +0,0 @@
-using System;
-using Newtonsoft.Json;
-using Ragon.Server;
-using Ragon.Server.Plugin;
-
-namespace Ragon.Relay;
-
-public class RelayServerPlugin: BaseServerPlugin
-{
-  public override bool OnCommand(string command, string payload)
-  {
-    Console.WriteLine(command);
-    if (command == "kick-player")
-    {
-      var commandPayload = JsonConvert.DeserializeObject<KickPlayerCommand>(payload);
-      var player = Server.GetPlayerById(commandPayload.Id);
-      if (player != null)
-        player.Connection.Close();
-      else
-        Console.WriteLine($"Player not found with Id {commandPayload.Id}");
-    }
-    
-    return true;
-  }
-
-  public override IRoomPlugin CreateRoomPlugin(RoomInformation information)
-  {
-    return new RelayRoomPlugin();
-  }
-}

Ragon.Relay/Sources/Reporter/Client.cs

@@ -0,0 +1,44 @@
+using System;
+using System.Net;
+using System.Net.Sockets;
+using Ragon.Server.Logging;
+
+namespace Ragon.Relay;
+
+public class Client
+{
+  private readonly UdpClient _udpClient;
+  private readonly IPEndPoint _endpoint;
+  private readonly IRagonLogger _logger;
+  
+  public Client(string host, int port)
+  {
+    _logger = LoggerManager.GetLogger("Client");
+    _udpClient = new UdpClient();
+    _endpoint = new IPEndPoint(IPAddress.Parse(host), port);
+  }
+  
+  public void Send(byte[] data)
+  {
+    try
+    {
+      _udpClient.BeginSend(data, data.Length, _endpoint, SendCallback, null);
+    }
+    catch (Exception ex)
+    {
+      _logger.Error(ex.Message);
+    }
+  }
+
+  private void SendCallback(IAsyncResult ar)
+  {
+    try
+    {
+      _udpClient.EndSend(ar);
+    }
+    catch (Exception ex)
+    {
+      _logger.Error(ex.Message);
+    }
+  }
+}

Ragon.Relay/Sources/Reporter/Reporter.cs

@@ -0,0 +1,56 @@
+using Google.Protobuf;
+using Google.Protobuf.Collections;
+using Ragon.Server;
+
+namespace Ragon.Relay;
+
+public class Reporter
+{
+  private readonly Client _client;
+  private readonly IRagonServer _server;
+  private readonly RelayConfiguration _configuration;
+
+  public Reporter(
+    RelayConfiguration relayConfiguration,
+    IRagonServer server,
+    string host,
+    int port
+  )
+  {
+    _client = new Client(host, port);
+    _server = server;
+    _configuration = relayConfiguration;
+  }
+
+  public void Done()
+  {
+    for (var i = 0; i < 10; i++)
+    {
+      var message = new Data();
+      message.Statistics = new Statistics()
+      {
+        Connections = _server.ConnectionRegistry.Contexts.Count,
+        ConnectionsLimit = _configuration.LimitConnections,
+        Rooms = _server.Lobby.Rooms.Count,
+        RoomsLimit = _configuration.LimitRooms,
+      };
+
+      var room = new Room()
+      {
+        Id = $"Room ID {i}",
+      };
+
+      for (var j = 0; j < 10; j++)
+      {
+        room.Players.Add(new Player()
+        {
+          Id = $"Player ID {i}",
+        });
+      }
+
+      message.Room = room;
+
+      _client.Send(message.ToByteArray());
+    }
+  }
+}