chore: update version

Ragon/Sources/Authorization/AuthorizationManager.cs

@@ -25,7 +25,7 @@ public class AuthorizationManager : IAuthorizationManager
     _playersByPeers = new Dictionary<uint, Player>();
   }
 
-  public void OnAuthorization(uint peerId, string key, string name)
+  public void OnAuthorization(uint peerId, string key, string name, ReadOnlySpan<byte> additionalData)
   {
     if (_playersByPeers.ContainsKey(peerId))
     {
@@ -35,7 +35,7 @@ public class AuthorizationManager : IAuthorizationManager
     
     var dispatcher = _gameThread.ThreadDispatcher;
     
-    _provider.OnAuthorizationRequest(key, name, Array.Empty<byte>(),
+    _provider.OnAuthorizationRequest(key, name, additionalData.ToArray(),
       (playerId, playerName) => { dispatcher.Dispatch(() => Accepted(peerId, playerId, playerName)); },
       (errorCode) => { dispatcher.Dispatch(() => Rejected(peerId, errorCode)); });
   }

Ragon/Sources/Configuration/ConfigurationLoader.cs

@@ -9,7 +9,7 @@ namespace Ragon.Core
   public static class ConfigurationLoader
   {
     private static readonly Logger _logger = LogManager.GetCurrentClassLogger();
-    private static readonly string _serverVersion = "1.0.18-rc";
+    private static readonly string _serverVersion = "1.0.21-rc";
 
     private static void CopyrightInfo()
     {

Ragon/Sources/Entity/Entity.cs

@@ -28,6 +28,8 @@ public class Entity
     Authority = eventAuthority;
   }
 
+  public void UpdateOwner(ushort ownerId) => OwnerId = ownerId;
+
   public void ReplicateProperties(RagonSerializer serializer)
   {
     serializer.WriteUShort(EntityId);

Ragon/Sources/Entity/EntityEvent.cs

@@ -4,6 +4,7 @@ namespace Ragon.Core;
 
 public class EntityEvent
 {
+  public ushort PeerId { get; set; }
   public ushort EventId { get; set; }
   public byte[] EventData { get; set; }
   public RagonTarget Target { set; get; }

Ragon/Sources/Game/GameRoom.cs

@@ -61,27 +61,16 @@ namespace Ragon.Core
       _players.Add(player.PeerId, player);
       _allPlayers = _players.Select(p => p.Key).ToArray();
 
-      {
-        _serializer.Clear();
-        _serializer.WriteOperation(RagonOperation.JOIN_SUCCESS);
-        _serializer.WriteString(Id);
-        _serializer.WriteString(player.Id);
-        _serializer.WriteString(GetOwner().Id);
-        _serializer.WriteUShort((ushort) PlayersMin);
-        _serializer.WriteUShort((ushort) PlayersMax);
-
-        var sendData = _serializer.ToArray();
-        Send(player.PeerId, sendData, DeliveryType.Reliable);
-      }
-
-      {
-        _serializer.Clear();
-        _serializer.WriteOperation(RagonOperation.LOAD_SCENE);
-        _serializer.WriteString(Map);
-
-        var sendData = _serializer.ToArray();
-        Send(player.PeerId, sendData, DeliveryType.Reliable);
-      }
+      _serializer.Clear();
+      _serializer.WriteOperation(RagonOperation.JOIN_SUCCESS);
+      _serializer.WriteString(Id);
+      _serializer.WriteString(player.Id);
+      _serializer.WriteString(GetOwner().Id);
+      _serializer.WriteUShort((ushort) PlayersMin);
+      _serializer.WriteUShort((ushort) PlayersMax);
+      _serializer.WriteString(Map);
+      var sendData = _serializer.ToArray();
+      Send(player.PeerId, sendData, DeliveryType.Reliable);
     }
 
     public void RemovePlayer(uint peerId)
@@ -116,9 +105,17 @@ namespace Ragon.Core
           _owner = nextOwnerId;
           var nextOwner = _players[nextOwnerId];
 
+          var entitiesToUpdate = player.Entities.Where(e => e.StaticId > 0).ToArray();
+
           _serializer.Clear();
           _serializer.WriteOperation(RagonOperation.OWNERSHIP_CHANGED);
           _serializer.WriteString(nextOwner.Id);
+          _serializer.WriteUShort((ushort) entitiesToUpdate.Length);
+          foreach (var entity in entitiesToUpdate)
+          {
+            _serializer.WriteUShort(entity.EntityId);
+            entity.UpdateOwner((ushort) nextOwnerId);
+          }
 
           var sendData = _serializer.ToArray();
           Broadcast(_readyPlayers, sendData);
@@ -127,7 +124,7 @@ namespace Ragon.Core
         _entitiesAll = _entities.Values.ToArray();
       }
     }
-    
+
     // TODO: Move this processing to specialized classes with structures
     public void ProcessEvent(ushort peerId, RagonOperation operation, ReadOnlySpan<byte> payloadRawData)
     {
@@ -200,20 +197,20 @@ namespace Ragon.Core
                 Broadcast(readyPlayersWithExcludedPeer, sendData, DeliveryType.Reliable);
               }
             }
-            
+
             _readyPlayers = _players.Where(p => p.Value.IsLoaded).Select(p => p.Key).ToArray();
             foreach (var peer in _awaitingPeers)
             {
-              ReplicateSnapshot(peer);  
+              ReplicateSnapshot(peer);
             }
-            
+
             _awaitingPeers.Clear();
           }
           else if (GetOwner().IsLoaded)
           {
             _logger.Trace($"[{_owner}][{peerId}] Player {player.Id} restored instantly");
             player.IsLoaded = true;
-            
+ 
             {
               _serializer.Clear();
               _serializer.WriteOperation(RagonOperation.PLAYER_JOINED);
@@ -225,12 +222,12 @@ namespace Ragon.Core
               var readyPlayersWithExcludedPeer = _readyPlayers.Where(p => p != peerId).ToArray();
               Broadcast(readyPlayersWithExcludedPeer, sendData, DeliveryType.Reliable);
             }
-            
+
             _readyPlayers = _players.Where(p => p.Value.IsLoaded).Select(p => p.Key).ToArray();
             _plugin.OnPlayerJoined(player);
 
             ReplicateSnapshot(peerId);
-            
+
             foreach (var (key, value) in _entities)
             {
               foreach (var bufferedEvent in value.BufferedEvents)
@@ -238,15 +235,16 @@ namespace Ragon.Core
                 _serializer.Clear();
                 _serializer.WriteOperation(RagonOperation.REPLICATE_ENTITY_EVENT);
                 _serializer.WriteUShort(bufferedEvent.EventId);
-                _serializer.WriteUShort(peerId);
+                _serializer.WriteUShort(bufferedEvent.PeerId);
                 _serializer.WriteByte((byte) RagonReplicationMode.Server);
                 _serializer.WriteUShort(value.EntityId);
-                
+
                 ReadOnlySpan<byte> data = bufferedEvent.EventData.AsSpan();
                 _serializer.WriteData(ref data);
 
+                _logger.Trace($"[{peerId}] Restored buffered event {bufferedEvent.EventId}");
                 var sendData = _serializer.ToArray();
-                SendEvent(value, bufferedEvent.Target, sendData);
+                Send(peerId, sendData, DeliveryType.Reliable);
               }
             }
           }
@@ -311,7 +309,7 @@ namespace Ragon.Core
           var eventMode = (RagonReplicationMode) _serializer.ReadByte();
           var targetMode = (RagonTarget) _serializer.ReadByte();
           var entityId = _serializer.ReadUShort();
-          
+
           if (!_entities.TryGetValue(entityId, out var ent))
           {
             _logger.Warn($"Entity not found for event with Id {eventId}");
@@ -339,6 +337,7 @@ namespace Ragon.Core
               EventData = payload.ToArray(),
               Target = targetMode,
               EventId = eventId,
+              PeerId = peerId,
             };
             ent.BufferedEvents.Add(bufferedEvent);
           }
@@ -360,9 +359,9 @@ namespace Ragon.Core
           var entityType = _serializer.ReadUShort();
           var eventAuthority = (RagonAuthority) _serializer.ReadByte();
           var propertiesCount = _serializer.ReadUShort();
-          
+
           _logger.Trace($"[{peerId}] Create Entity {entityType}");
-          
+
           var entity = new Entity(peerId, entityType, 0, eventAuthority, propertiesCount);
           for (var i = 0; i < propertiesCount; i++)
           {
@@ -431,6 +430,7 @@ namespace Ragon.Core
             var sendData = _serializer.ToArray();
             Broadcast(_readyPlayers, sendData, DeliveryType.Reliable);
           }
+
           break;
         }
       }
@@ -442,7 +442,7 @@ namespace Ragon.Core
 
       ReplicateProperties();
     }
-    
+
     // TODO: Move this to specialized class
     void ReplicateSnapshot(uint peerId)
     {
@@ -537,7 +537,7 @@ namespace Ragon.Core
 
     public IScheduler GetScheduler() => _scheduler;
 
-    
+
     // TODO: Move this to Entity Event Manager
     public void SendEvent(Entity ent, RagonTarget targetMode, byte[] sendData)
     {

Ragon/Sources/Lobby/Lobby.cs

@@ -28,15 +28,22 @@ public class Lobby
     _serializer.Clear();
     _serializer.FromSpan(ref payload);
 
+    var player = _authorizationManager.GetPlayer(peerId);
     if (op == RagonOperation.AUTHORIZE)
     {
+      if (player != null)
+      {
+        _logger.Warn("Player already authorized");
+        return;
+      }
+      
       var key = _serializer.ReadString();
       var playerName = _serializer.ReadString();
-      _authorizationManager.OnAuthorization(peerId, key, playerName);
+      var additionalData = _serializer.ReadData(_serializer.Size);
+      _authorizationManager.OnAuthorization(peerId, key, playerName, additionalData);
       return;
     }
-
-    var player = _authorizationManager.GetPlayer(peerId);
+    
     if (player == null)
     {
       _logger.Warn($"Peer not authorized {peerId} trying to {op}");

Ragon/Sources/Player/Player.cs

@@ -6,8 +6,8 @@ namespace Ragon.Core
   public class Player
   {
     public string Id { get; set; }
-    public uint PeerId { get; set; }
     public string PlayerName { get; set; }
+    public uint PeerId { get; set; }
     public bool IsLoaded { get; set; }
     
     public List<Entity> Entities;