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>();
}
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)); });
}
@@ -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.20-rc";
private static readonly string _serverVersion = "1.0.21-rc";
private static void CopyrightInfo()
{
+1
View File
@@ -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; }
+14 -23
View File
@@ -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)
@@ -246,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);
}
}
}
@@ -347,6 +337,7 @@ namespace Ragon.Core
EventData = payload.ToArray(),
Target = targetMode,
EventId = eventId,
PeerId = peerId,
};
ent.BufferedEvents.Add(bufferedEvent);
}
+9 -2
View File
@@ -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}");
+1 -1
View File
@@ -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;