Merge pull request #5 from edmand46/dev

Target of replication event

Ragon.Common/Sources/RagonTarget.cs

@@ -0,0 +1,9 @@
+namespace Ragon.Common
+{
+  public enum RagonTarget: byte
+  {
+    OWNER,
+    EXCEPT_OWNER,
+    ALL,
+  }
+}

Ragon/Sources/Game/GameRoom.cs

@@ -28,6 +28,7 @@ namespace Ragon.Core
     private uint[] _readyPlayers = Array.Empty<uint>();
     private uint[] _allPlayers = Array.Empty<uint>();
     private Entity[] _entitiesAll = Array.Empty<Entity>();
+    private List<uint> _peersCache = new List<uint>();
 
     public GameRoom(IGameThread gameThread, PluginBase pluginBase, string roomId, string map, int min, int max)
     {
@@ -141,6 +142,7 @@ namespace Ragon.Core
         {
           var evntId = _serializer.ReadUShort();
           var evntMode = _serializer.ReadByte();
+          var targetMode = (RagonTarget) _serializer.ReadByte();
           var entityId = _serializer.ReadInt();
     
           if (!_entities.TryGetValue(entityId, out var ent))
@@ -166,9 +168,31 @@ namespace Ragon.Core
           _serializer.WriteData(ref payload);
           var sendData = _serializer.ToArray();
 
+          switch (targetMode)
+          {
+            case RagonTarget.OWNER:
+            {
+              Send(ent.OwnerId, sendData, DeliveryType.Reliable);
+              break;
+            }
+            case RagonTarget.EXCEPT_OWNER:
+            {
+              _peersCache.Clear();
+              foreach (var playerPeerId in _readyPlayers)
+                if (playerPeerId != ent.OwnerId)
+                  _peersCache.Add(playerPeerId);
+
+              Broadcast(_peersCache.ToArray(), sendData, DeliveryType.Reliable);
+              break;
+            }
+            case RagonTarget.ALL:
+            {
               Broadcast(_readyPlayers, sendData, DeliveryType.Reliable);
               break;
             }
+          }
+          break;
+        }
         case RagonOperation.LOAD_SCENE:
         {
           var sceneName = _serializer.ReadString();
@@ -188,6 +212,8 @@ namespace Ragon.Core
         {
           var evntId = _serializer.ReadUShort();
           var evntMode = _serializer.ReadByte();
+          var targetMode = (RagonTarget) _serializer.ReadByte();
+
           Span<byte> payloadRaw = stackalloc byte[_serializer.Size];
           var payloadData = _serializer.ReadData(_serializer.Size);
           payloadData.CopyTo(payloadRaw);
@@ -204,9 +230,31 @@ namespace Ragon.Core
           _serializer.WriteData(ref payload);
 
           var sendData = _serializer.ToArray();
+          switch (targetMode)
+          {
+            case RagonTarget.OWNER:
+            {
+              Send(_owner, sendData, DeliveryType.Reliable);
+              break;
+            }
+            case RagonTarget.EXCEPT_OWNER:
+            {
+              _peersCache.Clear();
+              foreach (var playerPeerId in _readyPlayers)
+                if (playerPeerId != _owner)
+                  _peersCache.Add(playerPeerId);
+              
+              Broadcast(_peersCache.ToArray(), sendData, DeliveryType.Reliable);
+              break;
+            }
+            case RagonTarget.ALL:
+            {
               Broadcast(_readyPlayers, sendData, DeliveryType.Reliable);
               break;
             }
+          }
+          break;
+        }
         case RagonOperation.CREATE_STATIC_ENTITY:
         {
           var entityType = _serializer.ReadUShort();
@@ -374,7 +422,6 @@ namespace Ragon.Core
 
           _players[peerId].IsLoaded = true;
           _readyPlayers = _players.Where(p => p.Value.IsLoaded).Select(p => p.Key).ToArray();
-
           _plugin.OnPlayerJoined(_players[peerId]);
           break;
         }