Compare commits

..

4 Commits

Author SHA1 Message Date
edmand46 545ec02ecc chore: update version 2022-10-21 00:05:01 +04:00
edmand46 73feb77169 fixed: wrong peerId in restored events 2022-10-21 00:04:33 +04:00
edmand46 c2c75cb513 fixed: double authorization request 2022-10-15 18:48:59 +04:00
edmand46 9a22566f79 fixed: additional data missed 2022-10-15 18:48:48 +04:00
6 changed files with 30 additions and 31 deletions
@@ -25,7 +25,7 @@ public class AuthorizationManager : IAuthorizationManager
_playersByPeers = new Dictionary<uint, Player>(); _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)) if (_playersByPeers.ContainsKey(peerId))
{ {
@@ -35,7 +35,7 @@ public class AuthorizationManager : IAuthorizationManager
var dispatcher = _gameThread.ThreadDispatcher; 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)); }, (playerId, playerName) => { dispatcher.Dispatch(() => Accepted(peerId, playerId, playerName)); },
(errorCode) => { dispatcher.Dispatch(() => Rejected(peerId, errorCode)); }); (errorCode) => { dispatcher.Dispatch(() => Rejected(peerId, errorCode)); });
} }
@@ -9,7 +9,7 @@ namespace Ragon.Core
public static class ConfigurationLoader public static class ConfigurationLoader
{ {
private static readonly Logger _logger = LogManager.GetCurrentClassLogger(); private static readonly Logger _logger = LogManager.GetCurrentClassLogger();
private static readonly string _serverVersion = "1.0.20-rc"; private static readonly string _serverVersion = "1.0.21-rc";
private static void CopyrightInfo() private static void CopyrightInfo()
{ {
+1
View File
@@ -4,6 +4,7 @@ namespace Ragon.Core;
public class EntityEvent public class EntityEvent
{ {
public ushort PeerId { get; set; }
public ushort EventId { get; set; } public ushort EventId { get; set; }
public byte[] EventData { get; set; } public byte[] EventData { get; set; }
public RagonTarget Target { set; get; } public RagonTarget Target { set; get; }
+4 -13
View File
@@ -61,7 +61,6 @@ namespace Ragon.Core
_players.Add(player.PeerId, player); _players.Add(player.PeerId, player);
_allPlayers = _players.Select(p => p.Key).ToArray(); _allPlayers = _players.Select(p => p.Key).ToArray();
{
_serializer.Clear(); _serializer.Clear();
_serializer.WriteOperation(RagonOperation.JOIN_SUCCESS); _serializer.WriteOperation(RagonOperation.JOIN_SUCCESS);
_serializer.WriteString(Id); _serializer.WriteString(Id);
@@ -69,20 +68,10 @@ namespace Ragon.Core
_serializer.WriteString(GetOwner().Id); _serializer.WriteString(GetOwner().Id);
_serializer.WriteUShort((ushort) PlayersMin); _serializer.WriteUShort((ushort) PlayersMin);
_serializer.WriteUShort((ushort) PlayersMax); _serializer.WriteUShort((ushort) PlayersMax);
var sendData = _serializer.ToArray();
Send(player.PeerId, sendData, DeliveryType.Reliable);
}
{
_serializer.Clear();
_serializer.WriteOperation(RagonOperation.LOAD_SCENE);
_serializer.WriteString(Map); _serializer.WriteString(Map);
var sendData = _serializer.ToArray(); var sendData = _serializer.ToArray();
Send(player.PeerId, sendData, DeliveryType.Reliable); Send(player.PeerId, sendData, DeliveryType.Reliable);
} }
}
public void RemovePlayer(uint peerId) public void RemovePlayer(uint peerId)
{ {
@@ -246,15 +235,16 @@ namespace Ragon.Core
_serializer.Clear(); _serializer.Clear();
_serializer.WriteOperation(RagonOperation.REPLICATE_ENTITY_EVENT); _serializer.WriteOperation(RagonOperation.REPLICATE_ENTITY_EVENT);
_serializer.WriteUShort(bufferedEvent.EventId); _serializer.WriteUShort(bufferedEvent.EventId);
_serializer.WriteUShort(peerId); _serializer.WriteUShort(bufferedEvent.PeerId);
_serializer.WriteByte((byte) RagonReplicationMode.Server); _serializer.WriteByte((byte) RagonReplicationMode.Server);
_serializer.WriteUShort(value.EntityId); _serializer.WriteUShort(value.EntityId);
ReadOnlySpan<byte> data = bufferedEvent.EventData.AsSpan(); ReadOnlySpan<byte> data = bufferedEvent.EventData.AsSpan();
_serializer.WriteData(ref data); _serializer.WriteData(ref data);
_logger.Trace($"[{peerId}] Restored buffered event {bufferedEvent.EventId}");
var sendData = _serializer.ToArray(); var sendData = _serializer.ToArray();
SendEvent(value, bufferedEvent.Target, sendData); Send(peerId, sendData, DeliveryType.Reliable);
} }
} }
} }
@@ -347,6 +337,7 @@ namespace Ragon.Core
EventData = payload.ToArray(), EventData = payload.ToArray(),
Target = targetMode, Target = targetMode,
EventId = eventId, EventId = eventId,
PeerId = peerId,
}; };
ent.BufferedEvents.Add(bufferedEvent); ent.BufferedEvents.Add(bufferedEvent);
} }
+11 -4
View File
@@ -28,15 +28,22 @@ public class Lobby
_serializer.Clear(); _serializer.Clear();
_serializer.FromSpan(ref payload); _serializer.FromSpan(ref payload);
var player = _authorizationManager.GetPlayer(peerId);
if (op == RagonOperation.AUTHORIZE) if (op == RagonOperation.AUTHORIZE)
{ {
var key = _serializer.ReadString(); if (player != null)
var playerName = _serializer.ReadString(); {
_authorizationManager.OnAuthorization(peerId, key, playerName); _logger.Warn("Player already authorized");
return;
}
var key = _serializer.ReadString();
var playerName = _serializer.ReadString();
var additionalData = _serializer.ReadData(_serializer.Size);
_authorizationManager.OnAuthorization(peerId, key, playerName, additionalData);
return; return;
} }
var player = _authorizationManager.GetPlayer(peerId);
if (player == null) if (player == null)
{ {
_logger.Warn($"Peer not authorized {peerId} trying to {op}"); _logger.Warn($"Peer not authorized {peerId} trying to {op}");
+1 -1
View File
@@ -6,8 +6,8 @@ namespace Ragon.Core
public class Player public class Player
{ {
public string Id { get; set; } public string Id { get; set; }
public uint PeerId { get; set; }
public string PlayerName { get; set; } public string PlayerName { get; set; }
public uint PeerId { get; set; }
public bool IsLoaded { get; set; } public bool IsLoaded { get; set; }
public List<Entity> Entities; public List<Entity> Entities;