WIP: Dynamic entity spawn (only monsters rn)

Support unlocking Resonance Chains.

Core/Config/ConfigManager.cs

@@ -16,7 +16,12 @@ public class ConfigManager
         logger.LogInformation("Loaded {count} config collections", _collectionsByEnum.Count);
     }
 
-    public ConfigCollection GetCollection<TConfigType>()
+    public IEnumerable<TConfig> Enumerate<TConfig>() where TConfig : IConfig
+    {
+        return GetCollection<TConfig>().Enumerate<TConfig>();
+    }
+
+    public ConfigCollection GetCollection<TConfigType>() where TConfigType : IConfig
     {
         return _collectionsByType[typeof(TConfigType)];
     }

Core/Config/ConfigType.cs

@@ -5,5 +5,6 @@ public enum ConfigType
     Weapon,
     BaseProperty,
     LevelEntity,
-    Blueprint
+    Blueprint,
+    ItemInfo
 }

Core/Config/ItemInfoConfig.cs

@@ -0,0 +1,38 @@
+using Core.Config.Attributes;
+
+namespace Core.Config;
+
+[ConfigCollection("item/iteminfo.json")]
+public class ItemInfoConfig : IConfig
+{
+    public ConfigType Type => ConfigType.ItemInfo;
+    public int Identifier => Id;
+
+    public int Id { get; set; }
+    public int ItemType { get; set; }
+    public string Name { get; set; } = string.Empty;
+    public List<int> ShowTypes { get; set; } = [];
+    public string AttributesDescription { get; set; } = string.Empty;
+    public string BgDescription { get; set; } = string.Empty;
+    public string Mesh { get; set; } = string.Empty;
+    public int QualityId { get; set; }
+    public int MainTypeId { get; set; }
+    public int RedDotDisableRule { get; set; }
+    public int UseCountLimit { get; set; }
+    public int SortIndex { get; set; }
+    public int MaxCapcity { get; set; }
+    public int MaxStackableNum { get; set; }
+    public int UseLevel { get; set; }
+    public int BeginTimeStamp { get; set; }
+    public int DurationStamp { get; set; }
+    public bool ShowUseButton { get; set; }
+    public int ObtainedShow { get; set; }
+    public string ObtainedShowDescription { get; set; } = string.Empty;
+    public int EntityConfig { get; set; }
+    public int NumLimit { get; set; }
+    public bool ShowInBag { get; set; }
+    public bool Destructible { get; set; }
+    public int ItemBuffType { get; set; }
+    public bool SpecialItem { get; set; }
+    public bool UiPlayItem { get; set; }
+}

Core/Core.csproj

@@ -14,6 +14,7 @@
 
   <ItemGroup>
     <None Remove="data\config\blueprint\blueprintconfig.json" />
+    <None Remove="data\config\item\iteminfo.json" />
     <None Remove="data\config\property\baseproperty.json" />
     <None Remove="data\config\weapon\weaponconf.json" />
   </ItemGroup>

Core/data/config/weapon/weaponconf.json

@@ -10,14 +10,14 @@
     "ResonLevelLimit": 5,
     "FirstPropId": {
       "Id": 7,
-      "Value": 54,
+      "Value": 47,
       "IsRatio": false
     },
     "FirstCurve": 1,
     "SecondPropId": {
-      "Id": 11,
-      "Value": 432,
-      "IsRatio": false
+      "Id": 10007,
+      "Value": 0.08100000023841858,
+      "IsRatio": true
     },
     "SecondCurve": 2,
     "ResonId": 21010015,
@@ -26,7 +26,7 @@
     "Desc": "WeaponConf_21010015_Desc",
     "DescParams": [
       {
-        "ArrayString": [ "12%", "15%", "18%", "21%", "24%" ]
+        "ArrayString": [ "12.8%", "16%", "19.2%", "22.4%", "25.6%" ]
       },
       {
         "ArrayString": [ "8%", "10%", "12%", "14%", "16%" ]
@@ -35,7 +35,7 @@
         "ArrayString": [ "2", "2", "2", "2", "2" ]
       },
       {
-        "ArrayString": [ "8", "8", "8", "8", "8" ]
+        "ArrayString": [ "12", "12", "12", "12", "12" ]
       }
     ],
     "TypeDescription": "WeaponConf_21010015_TypeDescription",
@@ -84,16 +84,16 @@
     "Desc": "WeaponConf_21020015_Desc",
     "DescParams": [
       {
-        "ArrayString": [ "16%", "20%", "24%", "28%", "32%" ]
+        "ArrayString": [ "12.8%", "16%", "19.2%", "22.4%", "25.6%" ]
       },
       {
-        "ArrayString": [ "8%", "10%", "12%", "14%", "16%" ]
+        "ArrayString": [ "6%", "7.5%", "9%", "10.5%", "12%" ]
       },
       {
         "ArrayString": [ "2", "2", "2", "2", "2" ]
       },
       {
-        "ArrayString": [ "8", "8", "8", "8", "8" ]
+        "ArrayString": [ "10", "10", "10", "10", "10" ]
       }
     ],
     "TypeDescription": "WeaponConf_21020015_TypeDescription",
@@ -142,16 +142,16 @@
     "Desc": "WeaponConf_21030015_Desc",
     "DescParams": [
       {
-        "ArrayString": [ "12%", "15%", "18%", "21%", "24%" ]
+        "ArrayString": [ "12.8%", "16%", "19.2%", "22.4%", "25.6%" ]
       },
       {
-        "ArrayString": [ "2.4%", "3%", "3.6%", "4.2%", "4.8%" ]
+        "ArrayString": [ "10%", "12.5%", "15%", "17.5%", "20%" ]
       },
       {
-        "ArrayString": [ "5", "5", "5", "5", "5" ]
+        "ArrayString": [ "1", "1", "1", "1", "1" ]
       },
       {
-        "ArrayString": [ "8", "8", "8", "8", "8" ]
+        "ArrayString": [ "14", "14", "14", "14", "14" ]
       }
     ],
     "TypeDescription": "WeaponConf_21030015_TypeDescription",
@@ -189,9 +189,9 @@
     },
     "FirstCurve": 1,
     "SecondPropId": {
-      "Id": 11,
-      "Value": 864,
-      "IsRatio": false
+      "Id": 10007,
+      "Value": 0.08100000023841858,
+      "IsRatio": true
     },
     "SecondCurve": 2,
     "ResonId": 21040015,
@@ -200,7 +200,7 @@
     "Desc": "WeaponConf_21040015_Desc",
     "DescParams": [
       {
-        "ArrayString": [ "8%", "10%", "12%", "14%", "16%" ]
+        "ArrayString": [ "12.8%", "16%", "19.2%", "22.4%", "25.6%" ]
       },
       {
         "ArrayString": [ "10%", "12.5%", "15%", "17.5%", "20%" ]
@@ -250,9 +250,9 @@
     },
     "FirstCurve": 1,
     "SecondPropId": {
-      "Id": 11,
-      "Value": 1280,
-      "IsRatio": false
+      "Id": 10007,
+      "Value": 0.11999999731779099,
+      "IsRatio": true
     },
     "SecondCurve": 2,
     "ResonId": 21050015,
@@ -261,7 +261,7 @@
     "Desc": "WeaponConf_21050015_Desc",
     "DescParams": [
       {
-        "ArrayString": [ "16%", "20%", "24%", "28%", "32%" ]
+        "ArrayString": [ "12.8%", "16%", "19.2%", "22.4%", "25.6%" ]
       },
       {
         "ArrayString": [ "3.2%", "4%", "4.8%", "5.6%", "6.4%" ]
@@ -1670,13 +1670,13 @@
     "ResonLevelLimit": 5,
     "FirstPropId": {
       "Id": 7,
-      "Value": 31,
+      "Value": 27,
       "IsRatio": false
     },
     "FirstCurve": 1,
     "SecondPropId": {
       "Id": 10010,
-      "Value": 0.10260000079870224,
+      "Value": 0.13680000603199005,
       "IsRatio": true
     },
     "SecondCurve": 2,
@@ -1834,8 +1834,8 @@
     },
     "FirstCurve": 1,
     "SecondPropId": {
-      "Id": 10007,
-      "Value": 0.1080000028014183,
+      "Id": 10010,
+      "Value": 0.13680000603199005,
       "IsRatio": true
     },
     "SecondCurve": 2,
@@ -1886,7 +1886,7 @@
     },
     "FirstCurve": 1,
     "SecondPropId": {
-      "Id": 10002,
+      "Id": 10007,
       "Value": 0.08100000023841858,
       "IsRatio": true
     },
@@ -2248,13 +2248,13 @@
     "ResonLevelLimit": 5,
     "FirstPropId": {
       "Id": 7,
-      "Value": 26,
+      "Value": 24,
       "IsRatio": false
     },
     "FirstCurve": 1,
     "SecondPropId": {
       "Id": 10010,
-      "Value": 0.06840000301599503,
+      "Value": 0.08550000190734863,
       "IsRatio": true
     },
     "SecondCurve": 2,
@@ -3128,7 +3128,7 @@
         "ArrayString": [ "2", "2", "2", "2", "2" ]
       },
       {
-        "ArrayString": [ "10", "10", "10", "10", "10" ]
+        "ArrayString": [ "14", "14", "14", "14", "14" ]
       }
     ],
     "TypeDescription": "WeaponConf_21010016_TypeDescription",
@@ -3180,13 +3180,16 @@
         "ArrayString": [ "12%", "15%", "18%", "21%", "24%" ]
       },
       {
-        "ArrayString": [ "20%", "25%", "30%", "35%", "40%" ]
+        "ArrayString": [ "12%", "15%", "18%", "21%", "24%" ]
+      },
+      {
+        "ArrayString": [ "12%", "15%", "18%", "21%", "24%" ]
       },
       {
         "ArrayString": [ "2", "2", "2", "2", "2" ]
       },
       {
-        "ArrayString": [ "18", "18", "18", "18", "18" ]
+        "ArrayString": [ "5", "5", "5", "5", "5" ]
       }
     ],
     "TypeDescription": "WeaponConf_21050016_TypeDescription",

GameServer/Controllers/AchievementController.cs

@@ -1,6 +1,5 @@
 using GameServer.Controllers.Attributes;
 using GameServer.Network;
-using GameServer.Network.Messages;
 using Protocol;
 
 namespace GameServer.Controllers;
@@ -12,5 +11,5 @@ internal class AchievementController : Controller
     }
 
     [NetEvent(MessageId.AchievementInfoRequest)]
-    public ResponseMessage OnAchievementInfoRequest() => Response(MessageId.AchievementInfoResponse, new AchievementInfoResponse());
+    public RpcResult OnAchievementInfoRequest() => Response(MessageId.AchievementInfoResponse, new AchievementInfoResponse());
 }

GameServer/Controllers/ChatCommands/ChatPlayerCommandHandler.cs

@@ -0,0 +1,67 @@
+using GameServer.Controllers.Attributes;
+using GameServer.Models;
+using GameServer.Models.Chat;
+using GameServer.Network;
+using GameServer.Systems.Entity;
+using Protocol;
+
+namespace GameServer.Controllers.ChatCommands;
+
+[ChatCommandCategory("player")]
+internal class ChatPlayerCommandHandler
+{
+    private readonly ChatRoom _helperRoom;
+    private readonly PlayerSession _session;
+    private readonly CreatureController _creatureController;
+
+    public ChatPlayerCommandHandler(ModelManager modelManager, PlayerSession session, CreatureController creatureController)
+    {
+        _helperRoom = modelManager.Chat.GetChatRoom(1338);
+        _session = session;
+        _creatureController = creatureController;
+    }
+
+    [ChatCommand("getpos")]
+    [ChatCommandDesc("/player getpos - shows current player coordinates")]
+    public void OnPlayerGetPosCommand(string[] _)
+    {
+        PlayerEntity? entity = _creatureController.GetPlayerEntity();
+        if (entity == null) return;
+
+        _helperRoom.AddMessage(1338, 0, $"Your current position: ({entity.Pos.X / 100}, {entity.Pos.Y / 100}, {entity.Pos.Z / 100})");
+    }
+
+    [ChatCommand("teleport")]
+    [ChatCommandDesc("/player teleport [x] [y] [z] - performing fast travel to specified position")]
+    public async Task OnPlayerTeleportCommand(string[] args)
+    {
+        if (args.Length != 3 || !float.TryParse(args[0], out float x)
+            || !float.TryParse(args[1], out float y)
+            || !float.TryParse(args[2], out float z))
+        {
+            _helperRoom.AddMessage(1338, 0, $"Usage: /player teleport [x] [y] [z]");
+            return;
+        }
+
+        PlayerEntity? entity = _creatureController.GetPlayerEntity();
+
+        if (entity != null)
+        {
+            await _session.Push(MessageId.TeleportNotify, new TeleportNotify
+            {
+                PosX = x * 100,
+                PosY = y * 100,
+                PosZ = z * 100,
+                PosA = 0,
+                MapId = 8,
+                Reason = (int)TeleportReason.Gm,
+                TransitionOption = new TransitionOptionPb
+                {
+                    TransitionType = (int)TransitionType.Empty
+                }
+            });
+        }
+
+        _helperRoom.AddMessage(1338, 0, $"Successfully performed fast travel to ({x}, {y}, {z})");
+    }
+}

GameServer/Controllers/ChatCommands/ChatSpawnCommandHandler.cs

@@ -4,7 +4,6 @@ using GameServer.Models;
 using GameServer.Models.Chat;
 using GameServer.Network;
 using GameServer.Systems.Entity;
-using Protocol;
 
 namespace GameServer.Controllers.ChatCommands;
 
@@ -34,9 +33,9 @@ internal class ChatSpawnCommandHandler
     {
         if (args.Length != 4 ||
             !(int.TryParse(args[0], out int levelEntityId) &&
-            int.TryParse(args[1], out int x) &&
-            int.TryParse(args[2], out int y) &&
-            int.TryParse(args[3], out int z)))
+            float.TryParse(args[1], out float x) &&
+            float.TryParse(args[2], out float y) &&
+            float.TryParse(args[3], out float z)))
         {
             _helperRoom.AddMessage(1338, 0, "Usage: /spawn monster [id] [x] [y] [z]");
             return;
@@ -45,19 +44,13 @@ internal class ChatSpawnCommandHandler
         MonsterEntity monster = _entityFactory.CreateMonster(levelEntityId);
         monster.Pos = new()
         {
-            X = x,
-            Y = y,
-            Z = z
+            X = x * 100,
+            Y = y * 100,
+            Z = z * 100
         };
 
-        _entitySystem.Create(monster);
         monster.InitProps(_configManager.GetConfig<BasePropertyConfig>(600000100)!); // TODO: monster property config
-
-        await _session.Push(MessageId.EntityAddNotify, new EntityAddNotify
-        {
-            IsAdd = true,
-            EntityPbs = { monster.Pb }
-        });
+        _entitySystem.Add([monster]);
 
         await _creatureController.UpdateAiHate();
 

GameServer/Controllers/ChatController.cs

@@ -1,14 +1,14 @@
 using System.Text;
+using System.Text.RegularExpressions;
 using GameServer.Controllers.Attributes;
 using GameServer.Controllers.ChatCommands;
 using GameServer.Models;
 using GameServer.Models.Chat;
 using GameServer.Network;
-using GameServer.Network.Messages;
 using Protocol;
 
 namespace GameServer.Controllers;
-internal class ChatController : Controller
+internal partial class ChatController : Controller
 {
     private readonly ModelManager _modelManager;
 
@@ -18,7 +18,7 @@ internal class ChatController : Controller
     }
 
     [NetEvent(MessageId.PrivateChatDataRequest)]
-    public async Task<ResponseMessage> OnPrivateChatDataRequest()
+    public async Task<RpcResult> OnPrivateChatDataRequest()
     {
         if (!_modelManager.Chat.AllChatRooms.Any())
         {
@@ -31,7 +31,7 @@ internal class ChatController : Controller
     }
 
     [NetEvent(MessageId.PrivateChatRequest)]
-    public async Task<ResponseMessage> OnPrivateChatRequest(PrivateChatRequest request, ChatCommandManager chatCommandManager)
+    public async Task<RpcResult> OnPrivateChatRequest(PrivateChatRequest request, ChatCommandManager chatCommandManager)
     {
         ChatRoom chatRoom = _modelManager.Chat.GetChatRoom(1338);
 
@@ -42,7 +42,8 @@ internal class ChatController : Controller
         }
         else
         {
-            string[] split = request.Content[1..].Split(' ');
+            string content = MultipleSpacesRegex().Replace(request.Content, " ");
+            string[] split = content[1..].Split(' ');
             if (split.Length >= 2)
             {
                 await chatCommandManager.InvokeCommandAsync(split[0], split[1], split[2..]);
@@ -54,7 +55,7 @@ internal class ChatController : Controller
     }
 
     [NetEvent(MessageId.PrivateChatOperateRequest)]
-    public ResponseMessage OnPrivateChatOperateRequest() => Response(MessageId.PrivateChatOperateResponse, new PrivateChatOperateResponse());
+    public RpcResult OnPrivateChatOperateRequest() => Response(MessageId.PrivateChatOperateResponse, new PrivateChatOperateResponse());
 
     private async Task PushPrivateChatHistory()
     {
@@ -85,4 +86,7 @@ internal class ChatController : Controller
 
         return builder.ToString();
     }
+
+    [GeneratedRegex(@"\s+")]
+    private static partial Regex MultipleSpacesRegex();
 }

GameServer/Controllers/Combat/CombatManager.cs

@@ -1,7 +1,6 @@
 using System.Collections.Immutable;
 using System.Linq.Expressions;
 using System.Reflection;
-using System.Security.Cryptography;
 using GameServer.Controllers.Attributes;
 using GameServer.Network;
 using GameServer.Systems.Entity;
@@ -33,8 +32,57 @@ internal class CombatManager
         _creatureController = creatureController;
     }
 
+    [CombatRequest(CombatRequestData.MessageOneofCase.RTimeStopRequest)]
+    public CombatResponseData OnRTimeStopRequest(CombatRequestContext context) => new()
+    {
+        CombatCommon = context.Request.CombatCommon,
+        RTimeStopResponse = new()
+    };
+
+    [CombatRequest(CombatRequestData.MessageOneofCase.ActivateBuffRequest)]
+    public CombatResponseData OnActivateBuffRequest(CombatRequestContext context) => new()
+    {
+        CombatCommon = context.Request.CombatCommon,
+        ActivateBuffResponse = new()
+    };
+
+    [CombatRequest(CombatRequestData.MessageOneofCase.UseSkillRequest)]
+    public CombatResponseData OnUseSkillRequest(CombatRequestContext context) => new()
+    {
+        CombatCommon = context.Request.CombatCommon,
+        UseSkillResponse = new()
+        {
+            SkillSingleId = context.Request.UseSkillRequest.SkillSingleId,
+            UseSkillInfo = context.Request.UseSkillRequest.UseSkillInfo
+        }
+    };
+
+    [CombatRequest(CombatRequestData.MessageOneofCase.ApplyGameplayEffectRequest)]
+    public CombatResponseData OnApplyGameplayEffectRequest(CombatRequestContext context) => new()
+    {
+        CombatCommon = context.Request.CombatCommon,
+        ApplyGameplayEffectResponse = new ApplyGameplayEffectResponse()
+    };
+
+    [CombatRequest(CombatRequestData.MessageOneofCase.RemoveGameplayEffectRequest)]
+    public CombatResponseData OnRemoveGameplayEffectRequest(CombatRequestContext context) => new()
+    {
+        CombatCommon = context.Request.CombatCommon,
+        RemoveGameplayEffectResponse = new RemoveGameplayEffectResponse()
+    };
+
+    [CombatRequest(CombatRequestData.MessageOneofCase.CreateBulletRequest)]
+    public CombatResponseData OnCreateBulletRequest(CombatRequestContext context)
+    {
+        return new CombatResponseData
+        {
+            CombatCommon = context.Request.CombatCommon,
+            CreateBulletResponse = new()
+        };
+    }
+
     [CombatRequest(CombatRequestData.MessageOneofCase.DamageExecuteRequest)]
-    public async Task<CombatResponseData> OnDamageExecuteRequest(CombatRequestContext context)
+    public CombatResponseData OnDamageExecuteRequest(CombatRequestContext context)
     {
         DamageExecuteRequest request = context.Request.DamageExecuteRequest;
 
@@ -57,19 +105,7 @@ internal class CombatManager
 
         if (request.DamageId <= 0 && entity.Type != EEntityType.Player) // Player death not implemented
         {
-            _entitySystem.Destroy(entity);
-            await _session.Push(MessageId.EntityRemoveNotify, new EntityRemoveNotify
-            {
-                IsRemove = true,
-                RemoveInfos =
-                {
-                    new EntityRemoveInfo
-                    {
-                        EntityId = entity.Id,
-                        Type = (int)ERemoveEntityType.RemoveTypeNormal
-                    }
-                }
-            });
+            _entitySystem.Destroy([entity]);
         }
 
         return new CombatResponseData
@@ -199,12 +235,18 @@ internal class CombatManager
         if (entity.ComponentSystem.TryGet(out EntityFsmComponent? fsmComponent))
         {
             DFsm? dfsm = fsmComponent.Fsms.FirstOrDefault(fsm => fsm.FsmId == request.FsmId);
-            dfsm ??= new()
+
+            if (dfsm == null)
             {
-                FsmId = request.FsmId,
-                Status = 1,
-                Flag = (int)EFsmStateFlag.Confirmed
-            };
+                dfsm = new DFsm
+                {
+                    FsmId = request.FsmId,
+                    Status = 1,
+                    Flag = (int)EFsmStateFlag.Confirmed
+                };
+
+                fsmComponent.Fsms.Add(dfsm);
+            }
 
             dfsm.CurrentState = request.State;
             context.Notifies.Add(new CombatNotifyData

GameServer/Controllers/CombatMessageController.cs

@@ -1,19 +1,45 @@
 using GameServer.Controllers.Attributes;
 using GameServer.Controllers.Combat;
+using GameServer.Models;
 using GameServer.Network;
-using GameServer.Network.Messages;
+using GameServer.Systems.Entity;
+using GameServer.Systems.Event;
+using Microsoft.Extensions.Logging;
 using Protocol;
 
 namespace GameServer.Controllers;
 internal class CombatMessageController : Controller
 {
-    public CombatMessageController(PlayerSession session) : base(session)
+    private readonly ILogger _logger;
+
+    public CombatMessageController(PlayerSession session, ILogger<CombatMessageController> logger) : base(session)
     {
-        // CombatMessageController.
+        _logger = logger;
     }
 
-    [NetEvent(MessageId.CombatSendPackRequest)] // TODO: CombatSendPackRequest is important
-    public async Task<ResponseMessage> OnCombatSendPackRequest(CombatSendPackRequest request, CombatManager combatManager)
+    [NetEvent(MessageId.MovePackagePush)]
+    public async Task OnMovePackagePush(MovePackagePush push, EntitySystem entitySystem, EventSystem eventSystem, ModelManager modelManager)
+    {
+        foreach (MovingEntityData movingEntityData in push.MovingEntities)
+        {
+            EntityBase? entity = entitySystem.Get<EntityBase>(movingEntityData.EntityId);
+            if (entity == null)
+            {
+                _logger.LogWarning("OnMovePackagePush: moving entity not found! Id: {entityId}", movingEntityData.EntityId);
+                continue;
+            }
+
+            MoveReplaySample lastMoveReplay = movingEntityData.MoveInfos.Last();
+            entity.Pos.MergeFrom(lastMoveReplay.Location);
+            entity.Rot.MergeFrom(lastMoveReplay.Rotation);
+
+            if (entity.Id == modelManager.Creature.PlayerEntityId)
+                await eventSystem.Emit(GameEventType.PlayerPositionChanged);
+        }
+    }
+
+    [NetEvent(MessageId.CombatSendPackRequest)]
+    public async Task<RpcResult> OnCombatSendPackRequest(CombatSendPackRequest request, CombatManager combatManager)
     {
         CombatReceivePackNotify combatPackNotify = new();
 

GameServer/Controllers/Controller.cs

@@ -1,4 +1,5 @@
-using GameServer.Network;
+global using GameServer.Controllers.Result;
+using GameServer.Network;
 using GameServer.Network.Messages;
 using Google.Protobuf;
 using Protocol;
@@ -13,9 +14,9 @@ internal abstract class Controller
         Session = session;
     }
 
-    protected static ResponseMessage Response<TProtoBuf>(MessageId messageId, TProtoBuf protoBuf) where TProtoBuf : IMessage<TProtoBuf> => new()
+    protected static RpcResult Response<TProtoBuf>(MessageId messageId, TProtoBuf protoBuf) where TProtoBuf : IMessage<TProtoBuf> => new(new ResponseMessage
     {
         MessageId = messageId,
         Payload = protoBuf.ToByteArray()
-    };
+    });
 }

GameServer/Controllers/CreatureController.cs

@@ -1,27 +1,41 @@
 using Core.Config;
 using GameServer.Controllers.Attributes;
+using GameServer.Extensions.Logic;
 using GameServer.Models;
 using GameServer.Network;
-using GameServer.Network.Messages;
+using GameServer.Settings;
 using GameServer.Systems.Entity;
 using GameServer.Systems.Entity.Component;
 using GameServer.Systems.Event;
+using GameServer.Systems.Notify;
+using Microsoft.Extensions.Options;
 using Protocol;
 
 namespace GameServer.Controllers;
 internal class CreatureController : Controller
 {
+    private const float DynamicSpawnRadius = 5000;
+    private const float DynamicSpawnPositionDelta = 2500;
+    
     private readonly EntitySystem _entitySystem;
     private readonly EntityFactory _entityFactory;
     private readonly ModelManager _modelManager;
     private readonly ConfigManager _configManager;
+    private readonly IGameActionListener _listener;
 
-    public CreatureController(PlayerSession session, EntitySystem entitySystem, EntityFactory entityFactory, ModelManager modelManager, ConfigManager configManager) : base(session)
+    private readonly GameplayFeatureSettings _gameplayFeatures;
+    private readonly Vector _lastDynamicSpawnPos;
+
+    public CreatureController(PlayerSession session, EntitySystem entitySystem, EntityFactory entityFactory, ModelManager modelManager, ConfigManager configManager, IOptions<GameplayFeatureSettings> gameplayFeatures, IGameActionListener listener) : base(session)
     {
         _entitySystem = entitySystem;
         _entityFactory = entityFactory;
         _modelManager = modelManager;
         _configManager = configManager;
+        _listener = listener;
+        _gameplayFeatures = gameplayFeatures.Value;
+
+        _lastDynamicSpawnPos = new();
     }
 
     public async Task JoinScene(int instanceId)
@@ -30,19 +44,11 @@ internal class CreatureController : Controller
         CreateTeamPlayerEntities();
         CreateWorldEntities();
 
-        await Session.Push(MessageId.JoinSceneNotify, new JoinSceneNotify
-        {
-            MaxEntityId = 10000000,
-            TransitionOption = new TransitionOptionPb
-            {
-                TransitionType = (int)TransitionType.Empty
-            },
-            SceneInfo = CreateSceneInfo()
-        });
+        await _listener.OnJoinedScene(CreateSceneInfo(), TransitionType.Empty);
     }
 
     [NetEvent(MessageId.EntityActiveRequest)]
-    public async Task<ResponseMessage> OnEntityActiveRequest(EntityActiveRequest request)
+    public async Task<RpcResult> OnEntityActiveRequest(EntityActiveRequest request)
     {
         EntityActiveResponse response;
 
@@ -52,7 +58,8 @@ internal class CreatureController : Controller
             _entitySystem.Activate(entity);
             response = new EntityActiveResponse
             {
-                ErrorCode = (int)ErrorCode.Success
+                ErrorCode = (int)ErrorCode.Success,
+                IsVisible = entity.IsVisible
             };
 
             response.ComponentPbs.AddRange(entity.ComponentSystem.Pb);
@@ -67,7 +74,7 @@ internal class CreatureController : Controller
     }
 
     [NetEvent(MessageId.SceneLoadingFinishRequest)]
-    public async Task<ResponseMessage> OnSceneLoadingFinishRequest()
+    public async Task<RpcResult> OnSceneLoadingFinishRequest()
     {
         _modelManager.Creature.OnWorldDone();
         await UpdateAiHate();
@@ -78,51 +85,29 @@ internal class CreatureController : Controller
     [GameEvent(GameEventType.FormationUpdated)]
     public async Task OnFormationUpdated()
     {
-        // Remove old entities
-
-        IEnumerable<PlayerEntity> oldEntities = GetPlayerEntities().ToArray();
-        foreach (PlayerEntity oldEntity in oldEntities)
-        {
-            _entitySystem.Destroy(oldEntity);
-        }
-
-        await Session.Push(MessageId.EntityRemoveNotify, new EntityRemoveNotify
-        {
-            IsRemove = true,
-            RemoveInfos =
-            {
-                oldEntities.Select(entity => new EntityRemoveInfo
-                {
-                    EntityId = entity.Id,
-                    Type = (int)entity.Type
-                })
-            }
-        });
-
-        // Spawn new entities
-
+        _entitySystem.Destroy(GetPlayerEntities().ToArray());
         CreateTeamPlayerEntities();
 
-        IEnumerable<PlayerEntity> newEntities = GetPlayerEntities();
-        await Session.Push(MessageId.EntityAddNotify, new EntityAddNotify
-        {
-            IsAdd = true,
-            EntityPbs =
-            {
-                newEntities.Select(entity => entity.Pb)
-            }
-        });
-
-        _modelManager.Creature.PlayerEntityId = newEntities.First().Id;
-        await Session.Push(MessageId.UpdatePlayerAllFightRoleNotify, new UpdatePlayerAllFightRoleNotify
-        {
-            PlayerId = _modelManager.Player.Id,
-            FightRoleInfos = { GetFightRoleInfos() }
-        });
+        _modelManager.Creature.PlayerEntityId = GetPlayerEntities().First().Id;
+        await _listener.OnPlayerFightRoleInfoUpdated(_modelManager.Player.Id, GetFightRoleInfos());
 
         await UpdateAiHate();
     }
 
+    [GameEvent(GameEventType.PlayerPositionChanged)]
+    public void OnPlayerPositionChanged()
+    {
+        _modelManager.Player.Position.MergeFrom(GetPlayerEntity()!.Pos);
+
+        if (_lastDynamicSpawnPos.GetDistance(_modelManager.Player.Position) >= DynamicSpawnPositionDelta)
+        {
+            _lastDynamicSpawnPos.MergeFrom(_modelManager.Player.Position);
+
+            ClearInactiveEntities();
+            SpawnDynamicEntities();
+        }
+    }
+
     [GameEvent(GameEventType.VisionSkillChanged)]
     public async Task OnVisionSkillChanged()
     {
@@ -167,6 +152,9 @@ internal class CreatureController : Controller
         _modelManager.Creature.PlayerEntityId = newEntity.Id;
         newEntity.IsCurrentRole = true;
 
+        newEntity.Pos.MergeFrom(prevEntity.Pos);
+        newEntity.Rot.MergeFrom(prevEntity.Rot);
+
         await UpdateAiHate();
     }
 
@@ -240,24 +228,37 @@ internal class CreatureController : Controller
 
     private void CreateTeamPlayerEntities()
     {
+        PlayerEntity[] playerEntities = new PlayerEntity[_modelManager.Formation.RoleIds.Length];
+
         for (int i = 0; i < _modelManager.Formation.RoleIds.Length; i++)
         {
-            PlayerEntity entity = _entityFactory.CreatePlayer(_modelManager.Formation.RoleIds[i], _modelManager.Player.Id);
+            int roleId = _modelManager.Formation.RoleIds[i];
+
+            PlayerEntity entity = _entityFactory.CreatePlayer(roleId, _modelManager.Player.Id);
             entity.Pos = _modelManager.Player.Position.Clone();
             entity.IsCurrentRole = i == 0;
-
-            _entitySystem.Create(entity);
-            entity.InitProps(_configManager.GetConfig<BasePropertyConfig>(entity.ConfigId)!);
+            
+            entity.ComponentSystem.Get<EntityAttributeComponent>().SetAll(_modelManager.Roles.GetRoleById(roleId)!.GetAttributeList());
 
             CreateConcomitants(entity);
-
-            // Give weapon to entity
-            RoleInfoConfig roleConfig = _configManager.GetConfig<RoleInfoConfig>(entity.ConfigId)!;
-            WeaponConfig weaponConfig = _configManager.GetConfig<WeaponConfig>(roleConfig.InitWeaponItemId)!;
-            entity.WeaponId = weaponConfig.ItemId;
+            entity.WeaponId = _modelManager.Inventory.GetEquippedWeapon(roleId)?.Id ?? 0;
 
             if (i == 0) _modelManager.Creature.PlayerEntityId = entity.Id;
+
+            if (_gameplayFeatures.UnlimitedEnergy)
+            {
+                EntityAttributeComponent attr = entity.ComponentSystem.Get<EntityAttributeComponent>();
+                attr.SetAttribute(EAttributeType.EnergyMax, 0);
+                attr.SetAttribute(EAttributeType.SpecialEnergy1Max, 0);
+                attr.SetAttribute(EAttributeType.SpecialEnergy2Max, 0);
+                attr.SetAttribute(EAttributeType.SpecialEnergy3Max, 0);
+                attr.SetAttribute(EAttributeType.SpecialEnergy4Max, 0);
+            }
+
+            playerEntities[i] = entity;
         }
+
+        _entitySystem.Add(playerEntities);
     }
 
     private void CreateConcomitants(PlayerEntity entity)
@@ -271,10 +272,10 @@ internal class CreatureController : Controller
         if (roleId != -1)
         {
             PlayerEntity concomitant = _entityFactory.CreatePlayer(roleId, 0);
-            _entitySystem.Create(concomitant);
 
-            EntityConcomitantsComponent concomitants = entity.ComponentSystem.Get<EntityConcomitantsComponent>();
+            EntityConcomitantsComponent concomitants = entity.ComponentSystem.Create<EntityConcomitantsComponent>();
             concomitants.CustomEntityIds.Clear();
+            concomitants.VisionEntityId = concomitant.Id;
             concomitants.CustomEntityIds.Add(concomitant.Id);
 
             EntitySummonerComponent summoner = concomitant.ComponentSystem.Create<EntitySummonerComponent>();
@@ -282,24 +283,51 @@ internal class CreatureController : Controller
             summoner.SummonConfigId = summonConfigId;
             summoner.SummonType = ESummonType.ConcomitantCustom;
             summoner.PlayerId = _modelManager.Player.Id;
+
             concomitant.InitProps(_configManager.GetConfig<BasePropertyConfig>(roleId)!);
+            _entitySystem.Add([concomitant]);
         }
     }
 
     private void CreateWorldEntities()
+    {
+        _lastDynamicSpawnPos.MergeFrom(_modelManager.Player.Position.Clone());
+        SpawnDynamicEntities();
+    }
+
+    private void ClearInactiveEntities()
+    {
+        _entitySystem.Destroy(_entitySystem.EnumerateEntities()
+            .Where(e => e is MonsterEntity && e.DynamicId != 0 &&
+            e.Pos.GetDistance(_modelManager.Player.Position) > DynamicSpawnRadius).ToArray());
+    }
+
+    private void SpawnDynamicEntities()
     {
         Vector playerPos = _modelManager.Player.Position;
 
-        // Test monster
-        MonsterEntity monster = _entityFactory.CreateMonster(106003002); // Turtle.
-        monster.Pos = new()
-        {
-            X = playerPos.X + 250,
-            Y = playerPos.Y + 250,
-            Z = playerPos.Z
-        };
+        // Currently only monsters
+        IEnumerable<LevelEntityConfig> entitiesToSpawn = _configManager.Enumerate<LevelEntityConfig>()
+        .Where(config => config.MapId == 8 && Math.Abs(config.Transform[0].X / 100 - playerPos.X) < DynamicSpawnRadius && Math.Abs(config.Transform[0].Y / 100 - playerPos.Y) < DynamicSpawnRadius &&
+        config.BlueprintType.StartsWith("Monster"));
 
-        _entitySystem.Create(monster);
-        monster.InitProps(_configManager.GetConfig<BasePropertyConfig>(600000100)!);
+        List<MonsterEntity> spawnMonsters = [];
+        foreach (LevelEntityConfig levelEntity in entitiesToSpawn)
+        {
+            if (_entitySystem.HasDynamicEntity(levelEntity.EntityId)) continue;
+
+            MonsterEntity monster = _entityFactory.CreateMonster(levelEntity.EntityId);
+            monster.Pos = new()
+            {
+                X = levelEntity.Transform[0].X / 100,
+                Y = levelEntity.Transform[0].Y / 100,
+                Z = levelEntity.Transform[0].Z / 100
+            };
+
+            monster.InitProps(_configManager.GetConfig<BasePropertyConfig>(600000100)!);
+            spawnMonsters.Add(monster);
+        }
+
+        _entitySystem.Add(spawnMonsters);
     }
 }

GameServer/Controllers/DailyActivityController.cs

@@ -1,6 +1,5 @@
 using GameServer.Controllers.Attributes;
 using GameServer.Network;
-using GameServer.Network.Messages;
 using Protocol;
 
 namespace GameServer.Controllers;
@@ -12,8 +11,8 @@ internal class DailyActivityController : Controller
     }
 
     [NetEvent(MessageId.ActivityRequest)]
-    public ResponseMessage OnActivityRequest() => Response(MessageId.ActivityResponse, new ActivityResponse());
+    public RpcResult OnActivityRequest() => Response(MessageId.ActivityResponse, new ActivityResponse());
 
     [NetEvent(MessageId.LivenessRequest)]
-    public ResponseMessage OnLivenessRequest() => Response(MessageId.LivenessResponse, new LivenessResponse());
+    public RpcResult OnLivenessRequest() => Response(MessageId.LivenessResponse, new LivenessResponse());
 }

GameServer/Controllers/ExchangeRewardController.cs

@@ -1,6 +1,5 @@
 using GameServer.Controllers.Attributes;
 using GameServer.Network;
-using GameServer.Network.Messages;
 using Protocol;
 
 namespace GameServer.Controllers;
@@ -12,5 +11,5 @@ internal class ExchangeRewardController : Controller
     }
 
     [NetEvent(MessageId.ExchangeRewardInfoRequest)]
-    public ResponseMessage OnExchangeRewardInfoRequest() => Response(MessageId.ExchangeRewardInfoResponse, new ExchangeRewardInfoResponse());
+    public RpcResult OnExchangeRewardInfoRequest() => Response(MessageId.ExchangeRewardInfoResponse, new ExchangeRewardInfoResponse());
 }

GameServer/Controllers/ExploreProgressController.cs

@@ -1,21 +1,20 @@
 using GameServer.Controllers.Attributes;
 using GameServer.Network;
-using GameServer.Network.Messages;
 using Protocol;
 
 namespace GameServer.Controllers;
 internal class ExploreProgressController : Controller
 {
     private static readonly int[] s_areaIds = [1, 2, 3, 4, 5, 6, 7, 8, 10, 12, 100, 101, 102, 103, 107, 110, 113, 124, 122, 199, 301, 302, 303, 401, 402, 403, 404, 405, 406, 407, 408, 708, 601, 602, 603, 606, 607, 608, 609, 202, 203, 204, 501, 502, 503, 504, 508, 802, 803, 805, 807, 702, 703, 704, 705, 706, 709, 1201, 1202, 1203, 1204, 1001, 1002, 1003, 1004, 1005, 1006, 1007, 1301, 119, 120, 10001, 10002, 10003, 10004, 10005, 11001, 12001, 12002, 12003, 1500001, 1500002, 14001, 14002, 14003, 14004, 14005, 14006, 14007, 14008, 14011, 14012, 14013, 14021, 14022, 123, 125, 51, 804];
-    private static readonly (int, int)[] s_exploreIds = [(1, 2), (2, 2), (3, 2), (10, 3), (11, 4), (12, 4), (13, 4), (21, 6), (22, 6), (23, 6), (24, 6), (31, 8), (32, 8), (33, 8), (34, 8), (41, 10), (42, 10), (43, 10), (44, 10), (51, 12), (52, 12), (53, 12), (54, 12), (6, 3), (7, 3), (8, 3), (9, 3), (14, 4), (15, 4), (16, 5), (17, 5), (18, 5), (19, 5), (25, 6), (26, 7), (27, 7), (28, 7), (29, 7), (45, 10), (55, 12), (4, 2), (5, 2), (20, 5), (30, 7), (35, 8)];
-
+    private static readonly (int, int)[] s_exploreIds = [(1, 2), (2, 2), (3, 2), (11, 4), (12, 4), (13, 4), (21, 6), (22, 6), (23, 6), (24, 6), (31, 8), (32, 8), (33, 8), (34, 8), (41, 10), (42, 10), (43, 10), (44, 10), (51, 12), (52, 12), (53, 12), (54, 12), (6, 3), (7, 3), (8, 3), (9, 3), (14, 4), (15, 4), (16, 5), (17, 5), (18, 5), (19, 5), (25, 6), (26, 7), (27, 7), (28, 7), (29, 7), (45, 10), (55, 12), (4, 2), (5, 2), (20, 5), (30, 7), (35, 8)];
+    
     public ExploreProgressController(PlayerSession session) : base(session)
     {
         // ExploreProgressController.
     }
 
     [NetEvent(MessageId.ExploreProgressRequest)]
-    public ResponseMessage OnExploreProgressRequest()
+    public RpcResult OnExploreProgressRequest()
     {
         return Response(MessageId.ExploreProgressResponse, new ExploreProgressResponse
         {

GameServer/Controllers/Factory/EventHandlerFactory.cs

@@ -90,13 +90,13 @@ internal class EventHandlerFactory
         var builder = ImmutableDictionary.CreateBuilder<MessageId, RpcHandler>();
 
         MethodInfo getServiceMethod = typeof(ServiceProviderServiceExtensions).GetMethod(nameof(ServiceProviderServiceExtensions.GetRequiredService), [typeof(IServiceProvider)])!;
-        MethodInfo taskFromResultMethod = typeof(Task).GetMethod(nameof(Task.FromResult))!.MakeGenericMethod(typeof(ResponseMessage));
+        MethodInfo taskFromResultMethod = typeof(Task).GetMethod(nameof(Task.FromResult))!.MakeGenericMethod(typeof(RpcResult));
 
         foreach (Type type in controllerTypes)
         {
             IEnumerable<MethodInfo> methods = type.GetMethods()
                                    .Where(method => method.GetCustomAttribute<NetEventAttribute>() != null
-                                   && (method.ReturnType == typeof(Task<ResponseMessage>) || method.ReturnType == typeof(ResponseMessage)));
+                                   && (method.ReturnType == typeof(Task<RpcResult>) || method.ReturnType == typeof(RpcResult)));
 
             foreach (MethodInfo method in methods)
             {
@@ -108,7 +108,7 @@ internal class EventHandlerFactory
                 MethodCallExpression getServiceCall = Expression.Call(getServiceMethod.MakeGenericMethod(type), serviceProviderParam);
                 Expression handlerCall = Expression.Call(getServiceCall, method, FetchArgumentsForMethod(method, serviceProviderParam, getServiceMethod, dataParam));
 
-                if (method.ReturnType == typeof(ResponseMessage)) // Allow non-async methods as well
+                if (method.ReturnType == typeof(RpcResult)) // Allow non-async methods as well
                     handlerCall = Expression.Call(taskFromResultMethod, handlerCall);
 
                 Expression<RpcHandler> lambda = Expression.Lambda<RpcHandler>(handlerCall, serviceProviderParam, dataParam);

GameServer/Controllers/FormationAttributeController.cs

@@ -1,6 +1,5 @@
 using GameServer.Controllers.Attributes;
 using GameServer.Network;
-using GameServer.Network.Messages;
 using Protocol;
 
 namespace GameServer.Controllers;
@@ -12,8 +11,8 @@ internal class FormationAttributeController : Controller
     }
 
     [NetEvent(MessageId.TimeCheckRequest)]
-    public ResponseMessage OnTimeCheckRequest() => Response(MessageId.TimeCheckResponse, new TimeCheckResponse());
+    public RpcResult OnTimeCheckRequest() => Response(MessageId.TimeCheckResponse, new TimeCheckResponse());
 
     [NetEvent(MessageId.FormationAttrRequest)]
-    public ResponseMessage OnFormationAttrRequest() => Response(MessageId.FormationAttrResponse, new FormationAttrResponse());
+    public RpcResult OnFormationAttrRequest() => Response(MessageId.FormationAttrResponse, new FormationAttrResponse());
 }

GameServer/Controllers/FormationController.cs

@@ -1,8 +1,6 @@
 using GameServer.Controllers.Attributes;
 using GameServer.Models;
 using GameServer.Network;
-using GameServer.Network.Messages;
-using GameServer.Systems.Entity;
 using GameServer.Systems.Event;
 using Protocol;
 
@@ -17,7 +15,7 @@ internal class FormationController : Controller
     }
 
     [NetEvent(MessageId.GetFormationDataRequest)]
-    public ResponseMessage OnGetFormationDataRequest() => Response(MessageId.GetFormationDataResponse, new GetFormationDataResponse
+    public RpcResult OnGetFormationDataRequest() => Response(MessageId.GetFormationDataResponse, new GetFormationDataResponse
     {
         Formations =
             {
@@ -32,7 +30,7 @@ internal class FormationController : Controller
     });
 
     [NetEvent(MessageId.UpdateFormationRequest)]
-    public async Task<ResponseMessage> OnUpdateFormationRequest(UpdateFormationRequest request, EventSystem eventSystem)
+    public async Task<RpcResult> OnUpdateFormationRequest(UpdateFormationRequest request, EventSystem eventSystem)
     {
         _modelManager.Formation.Set([.. request.Formation.RoleIds]);
         await eventSystem.Emit(GameEventType.FormationUpdated);

GameServer/Controllers/FriendSystemController.cs

@@ -1,6 +1,5 @@
 using GameServer.Controllers.Attributes;
 using GameServer.Network;
-using GameServer.Network.Messages;
 using Protocol;
 
 namespace GameServer.Controllers;
@@ -12,11 +11,11 @@ internal class FriendSystemController : Controller
     }
 
     [NetEvent(MessageId.FriendAllRequest)]
-    public ResponseMessage OnFriendAllRequest() => Response(MessageId.FriendAllResponse, new FriendAllResponse
+    public RpcResult OnFriendAllRequest() => Response(MessageId.FriendAllResponse, new FriendAllResponse
     {
         FriendInfoList = 
         {
-            CreateDummyFriendInfo(1338, "Taoqi", "discord.gg/reversedrooms", 1601)
+            CreateDummyFriendInfo(1338, "Yangyang", "discord.gg/reversedrooms", 1402)
         }
     });
 

GameServer/Controllers/GachaController.cs

@@ -1,6 +1,5 @@
 using GameServer.Controllers.Attributes;
 using GameServer.Network;
-using GameServer.Network.Messages;
 using Protocol;
 
 namespace GameServer.Controllers;
@@ -12,5 +11,5 @@ internal class GachaController : Controller
     }
 
     [NetEvent(MessageId.GachaInfoRequest)]
-    public ResponseMessage OnGachaInfoRequest() => Response(MessageId.GachaInfoResponse, new GachaInfoResponse());
+    public RpcResult OnGachaInfoRequest() => Response(MessageId.GachaInfoResponse, new GachaInfoResponse());
 }

GameServer/Controllers/InfluenceReputationController.cs

@@ -1,6 +1,5 @@
 using GameServer.Controllers.Attributes;
 using GameServer.Network;
-using GameServer.Network.Messages;
 using Protocol;
 
 namespace GameServer.Controllers;
@@ -12,5 +11,5 @@ internal class InfluenceReputationController : Controller
     }
 
     [NetEvent(MessageId.InfluenceInfoRequest)]
-    public ResponseMessage OnInfluenceInfoRequest() => Response(MessageId.InfluenceInfoResponse, new InfluenceInfoResponse());
+    public RpcResult OnInfluenceInfoRequest() => Response(MessageId.InfluenceInfoResponse, new InfluenceInfoResponse());
 }

GameServer/Controllers/InventoryController.cs

@@ -1,6 +1,10 @@
-using GameServer.Controllers.Attributes;
+using Core.Config;
+using GameServer.Controllers.Attributes;
+using GameServer.Extensions.Logic;
+using GameServer.Models;
 using GameServer.Network;
-using GameServer.Network.Messages;
+using GameServer.Systems.Entity;
+using GameServer.Systems.Event;
 using Protocol;
 
 namespace GameServer.Controllers;
@@ -12,14 +16,101 @@ internal class InventoryController : Controller
     }
 
     [NetEvent(MessageId.NormalItemRequest)]
-    public ResponseMessage OnNormalItemRequest() => Response(MessageId.NormalItemResponse, new NormalItemResponse());
+    public RpcResult OnNormalItemRequest(ModelManager modelManager) => Response(MessageId.NormalItemResponse, new NormalItemResponse
+    {
+        NormalItemList = { modelManager.Inventory.ItemList }
+    });
 
     [NetEvent(MessageId.WeaponItemRequest)]
-    public ResponseMessage OnWeaponItemRequest() => Response(MessageId.WeaponItemResponse, new WeaponItemResponse());
+    public RpcResult OnWeaponItemRequest(ModelManager modelManager) => Response(MessageId.WeaponItemResponse, new WeaponItemResponse
+    {
+        WeaponItemList =
+        {
+            modelManager.Inventory.WeaponList
+        }
+    });
 
     [NetEvent(MessageId.PhantomItemRequest)]
-    public ResponseMessage OnPhantomItemRequest() => Response(MessageId.PhantomItemResponse, new PhantomItemResponse());
+    public RpcResult OnPhantomItemRequest() => Response(MessageId.PhantomItemResponse, new PhantomItemResponse());
 
     [NetEvent(MessageId.ItemExchangeInfoRequest)]
-    public ResponseMessage OnItemExchangeInfoRequest() => Response(MessageId.ItemExchangeInfoResponse, new ItemExchangeInfoResponse());
+    public RpcResult OnItemExchangeInfoRequest() => Response(MessageId.ItemExchangeInfoResponse, new ItemExchangeInfoResponse());
+
+    [NetEvent(MessageId.EquipTakeOnRequest)]
+    public RpcResult OnEquipTakeOnRequest(EquipTakeOnRequest request, ModelManager modelManager, CreatureController creatureController, RoleController roleController, ConfigManager configManager)
+    {
+        WeaponItem? weapon = modelManager.Inventory.GetWeaponById(request.Data.EquipIncId);
+        if (weapon == null) return Response(MessageId.EquipTakeOnResponse, new EquipTakeOnResponse
+        {
+            ErrorCode = (int)ErrorCode.ErrItemIdInvaild
+        });
+
+        WeaponConfig weaponConf = configManager.GetConfig<WeaponConfig>(weapon.Id)!;
+
+        roleInfo? role = modelManager.Roles.GetRoleById(request.Data.RoleId);
+        if (role == null) return Response(MessageId.EquipTakeOnResponse, new EquipTakeOnResponse
+        {
+            ErrorCode = (int)ErrorCode.NotValidRole
+        });
+
+        // Take off previous weapon
+        WeaponItem? prevWeapon = modelManager.Inventory.WeaponList.SingleOrDefault(weapon => weapon.RoleId == role.RoleId);
+        if (prevWeapon != null) prevWeapon.RoleId = 0;
+
+        // Set new weapon
+        weapon.RoleId = role.RoleId;
+        roleController.ApplyWeaponPropertiesToRole(role.RoleId, weaponConf);
+
+        // Update entity (if this role is currently active)
+        PlayerEntity? entity = creatureController.GetPlayerEntityByRoleId(request.Data.RoleId);
+        entity?.ChangeEquipment(weapon.Id);
+        entity?.ChangeGameplayAttributes(role.GetAttributeList());
+
+        // Response
+        EquipTakeOnResponse response = new()
+        {
+            DataList =
+            {
+                new RoleLoadEquipData
+                {
+                    RoleId = request.Data.RoleId,
+                    Pos = request.Data.Pos,
+                    EquipIncId = request.Data.EquipIncId
+                }
+            }
+        };
+
+        if (prevWeapon != null)
+        {
+            response.DataList.Add(new RoleLoadEquipData
+            {
+                EquipIncId = prevWeapon.IncrId
+            });
+        }
+
+        return Response(MessageId.EquipTakeOnResponse, response);
+    }
+
+    [GameEvent(GameEventType.EnterGame)]
+    public async Task OnEnterGame()
+    {
+        await Session.Push(MessageId.ItemPkgOpenNotify, new ItemPkgOpenNotify
+        {
+            OpenPkg = { 0, 2, 1, 3, 4, 5, 6, 7 }
+        });
+    }
+
+    [GameEvent(GameEventType.DebugUnlockAllItems)]
+    public void DebugUnlockAllWeapons(ConfigManager configManager, ModelManager modelManager)
+    {
+        foreach (WeaponConfig weaponConf in configManager.Enumerate<WeaponConfig>())
+        {
+            modelManager.Inventory.AddNewWeapon(weaponConf.ItemId);
+        }
+
+        foreach (ItemInfoConfig itemInfo in configManager.Enumerate<ItemInfoConfig>())
+        {
+            modelManager.Inventory.AddItem(itemInfo.Id, itemInfo.MaxStackableNum);
+        }
+    }
 }

GameServer/Controllers/LoginController.cs

@@ -1,8 +1,6 @@
 using GameServer.Controllers.Attributes;
 using GameServer.Network;
-using GameServer.Network.Messages;
 using GameServer.Systems.Event;
-using Microsoft.Extensions.Logging;
 using Protocol;
 
 namespace GameServer.Controllers;
@@ -14,29 +12,36 @@ internal class LoginController : Controller
     }
 
     [NetEvent(MessageId.LoginRequest)]
-    public async Task<ResponseMessage> OnLoginRequest(EventSystem eventSystem)
+    public async Task<RpcResult> OnLoginRequest(EventSystem eventSystem)
     {
         await eventSystem.Emit(GameEventType.Login);
 
+        // Debug
+        await eventSystem.Emit(GameEventType.DebugUnlockAllRoles);
+        await eventSystem.Emit(GameEventType.DebugUnlockAllItems);
+
         return Response(MessageId.LoginResponse, new LoginResponse
         {
             Code = 0,
-            Platform = "PC",
+            Platform = "CBT3_EU",
             Timestamp = DateTimeOffset.Now.ToUnixTimeSeconds()
         });
     }
 
     [NetEvent(MessageId.EnterGameRequest)]
-    public async Task<ResponseMessage> OnEnterGameRequest(EnterGameRequest request, ILogger<LoginController> logger, EventSystem eventSystem)
+    public RpcResult OnEnterGameRequest()
     {
-        logger.LogInformation("Enter Game Request:\n{req}", request);
+        return Response(MessageId.EnterGameResponse, new EnterGameResponse())
+                .AddPostEvent(GameEventType.EnterGame)
+                .AddPostEvent(GameEventType.PushDataDone);
+    }
 
-        await eventSystem.Emit(GameEventType.EnterGame);
+    [GameEvent(GameEventType.PushDataDone)]
+    public async Task OnPushDataDone()
+    {
         await Session.Push(MessageId.PushDataCompleteNotify, new PushDataCompleteNotify());
-
-        return Response(MessageId.EnterGameResponse, new EnterGameResponse());
     }
 
     [NetEvent(MessageId.HeartbeatRequest)]
-    public ResponseMessage OnHeartbeatRequest() => Response(MessageId.HeartbeatResponse, new HeartbeatResponse());
+    public RpcResult OnHeartbeatRequest() => Response(MessageId.HeartbeatResponse, new HeartbeatResponse());
 }

GameServer/Controllers/LordGymController.cs

@@ -1,6 +1,5 @@
 using GameServer.Controllers.Attributes;
 using GameServer.Network;
-using GameServer.Network.Messages;
 using Protocol;
 
 namespace GameServer.Controllers;
@@ -12,5 +11,5 @@ internal class LordGymController : Controller
     }
 
     [NetEvent(MessageId.LordGymInfoRequest)]
-    public ResponseMessage OnLordGymInfoRequest() => Response(MessageId.LordGymInfoResponse, new LordGymInfoResponse());
+    public RpcResult OnLordGymInfoRequest() => Response(MessageId.LordGymInfoResponse, new LordGymInfoResponse());
 }

GameServer/Controllers/PlayerInfoController.cs

@@ -1,7 +1,6 @@
 using GameServer.Controllers.Attributes;
 using GameServer.Models;
 using GameServer.Network;
-using GameServer.Network.Messages;
 using GameServer.Systems.Event;
 using Protocol;
 
@@ -22,52 +21,81 @@ internal class PlayerInfoController : Controller
         {
             RandomSeed = 1337,
             Id = player.Id,
-            Birthday = 0,
-            Attributes =
+            Birthday = player.BirthDay,
+            Attributes = { player.Attributes },
+            RoleShowList =
             {
-                new PlayerAttr
+                new RoleShowEntry
                 {
-                    Key = (int)PlayerAttrKey.Name,
-                    ValueType = (int)PlayerAttrType.String,
-                    StringValue = player.Name
-                },
-                new PlayerAttr
+                    Level = 1,
+                    RoleId = 1501 // Rover
+                }
+            },
+            CurCardId = 80060000,
+            CardUnlockList =
+            {
+                new CardShowEntry
                 {
-                    Key = (int)PlayerAttrKey.Level,
-                    ValueType = (int)PlayerAttrType.Int32,
-                    Int32Value = 10
-                },
-                new PlayerAttr
-                {
-                    Key = (int)PlayerAttrKey.HeadPhoto,
-                    ValueType = (int)PlayerAttrType.Int32,
-                    Int32Value = 1601
+                    CardId = 80060000,
+                    IsRead = true
                 }
             }
         };
-        
-        for (int i = 0; i < player.Characters.Length; i++)
-        {
-            basicInfo.RoleShowList.Add(new RoleShowEntry
-            {
-                Level = 1,
-                RoleId = player.Characters[i]
-            });
-        }
 
         await Session.Push(MessageId.BasicInfoNotify, basicInfo);
     }
 
+    [NetEvent(MessageId.ChangeHeadPhotoRequest)]
+    public RpcResult OnChangeHeadPhotoRequest(ChangeHeadPhotoRequest request, ModelManager modelManager)
+    {
+        modelManager.Player.SetAttribute(PlayerAttrKey.HeadPhoto, request.HeadPhotoId);
+
+        return Response(MessageId.ChangeHeadPhotoResponse, new ChangeHeadPhotoResponse
+        {
+            HeadPhotoId = request.HeadPhotoId
+        });
+    }
+
+    [NetEvent(MessageId.BirthdayInitRequest)]
+    public RpcResult OnBirthdayInitRequest(BirthdayInitRequest request, ModelManager modelManager)
+    {
+        modelManager.Player.BirthDay = request.Birthday;
+
+        return Response(MessageId.BirthdayInitResponse, new BirthdayInitResponse());
+    }
+
+    [NetEvent(MessageId.ModifySignatureRequest)]
+    public RpcResult OnModifySignatureRequest(ModifySignatureRequest request, ModelManager modelManager)
+    {
+        modelManager.Player.SetAttribute(PlayerAttrKey.Sign, request.Signature);
+
+        return Response(MessageId.ModifySignatureResponse, new ModifySignatureResponse
+        {
+            Signature = request.Signature
+        });
+    }
+
+    [NetEvent(MessageId.ModifyNameRequest)]
+    public RpcResult OnModifyNameRequest(ModifyNameRequest request, ModelManager modelManager)
+    {
+        modelManager.Player.SetAttribute(PlayerAttrKey.Name, request.Name);
+
+        return Response(MessageId.ModifyNameResponse, new ModifyNameResponse
+        {
+            Name = request.Name
+        });
+    }
+
     [NetEvent(MessageId.PlayerBasicInfoGetRequest)]
-    public ResponseMessage OnPlayerBasicInfoGetRequest()
+    public RpcResult OnPlayerBasicInfoGetRequest()
     {
         return Response(MessageId.PlayerBasicInfoGetResponse, new PlayerBasicInfoGetResponse
         {
             Info = new PlayerDetails
             {
-                Name = "Taoqi",
+                Name = "Yangyang",
                 Signature = "discord.gg/reversedrooms",
-                HeadId = 1601,
+                HeadId = 1402,
                 PlayerId = 1338,
                 IsOnline = true,
                 LastOfflineTime = -1,

GameServer/Controllers/Result/RpcResult.cs

@@ -0,0 +1,21 @@
+using GameServer.Network.Messages;
+using GameServer.Systems.Event;
+
+namespace GameServer.Controllers.Result;
+internal class RpcResult
+{
+    public ResponseMessage Response { get; }
+    public List<GameEventType> PostEvents { get; }
+
+    public RpcResult(ResponseMessage response)
+    {
+        Response = response;
+        PostEvents = [];
+    }
+
+    public RpcResult AddPostEvent(GameEventType type)
+    {
+        PostEvents.Add(type);
+        return this;
+    }
+}

GameServer/Controllers/RoguelikeController.cs

@@ -1,6 +1,5 @@
 using GameServer.Controllers.Attributes;
 using GameServer.Network;
-using GameServer.Network.Messages;
 using Protocol;
 
 namespace GameServer.Controllers;
@@ -12,5 +11,5 @@ internal class RoguelikeController : Controller
     }
 
     [NetEvent(MessageId.RoguelikeSeasonDataRequest)]
-    public ResponseMessage OnRoguelikeSeasonDataRequest() => Response(MessageId.RoguelikeSeasonDataResponse, new RoguelikeSeasonDataResponse());
+    public RpcResult OnRoguelikeSeasonDataRequest() => Response(MessageId.RoguelikeSeasonDataResponse, new RoguelikeSeasonDataResponse());
 }

GameServer/Controllers/RoleController.cs

@@ -1,41 +1,61 @@
 using Core.Config;
 using GameServer.Controllers.Attributes;
+using GameServer.Extensions.Logic;
 using GameServer.Models;
 using GameServer.Network;
-using GameServer.Network.Messages;
 using GameServer.Systems.Event;
+using GameServer.Systems.Notify;
 using Protocol;
 
 namespace GameServer.Controllers;
 internal class RoleController : Controller
 {
-    public RoleController(PlayerSession session) : base(session)
+    private readonly ModelManager _modelManager;
+    private readonly IGameActionListener _listener;
+
+    public RoleController(PlayerSession session, ModelManager modelManager, IGameActionListener listener) : base(session)
     {
-        // RoleController.
+        _modelManager = modelManager;
+        _listener = listener;
+    }
+
+    public void ApplyWeaponPropertiesToRole(int roleId, WeaponConfig weaponConfiguration)
+    {
+        roleInfo? role = _modelManager.Roles.GetRoleById(roleId) ?? throw new ArgumentException($"Role with id {roleId} doesn't exist");
+
+        role.ApplyWeaponProperties(weaponConfiguration);
+        _ = _listener.OnRolePropertiesUpdated(roleId, role.BaseProp, role.AddProp);
+    }
+
+    [GameEvent(GameEventType.DebugUnlockAllRoles)]
+    public void UnlockAllRoles(ConfigManager configManager)
+    {
+        foreach (RoleInfoConfig roleConfig in configManager.Enumerate<RoleInfoConfig>())
+        {
+            roleInfo role = _modelManager.Roles.Create(roleConfig.Id);
+            role.BaseProp.AddRange(CreateBasePropList(configManager.GetConfig<BasePropertyConfig>(roleConfig.Id)));
+
+            WeaponItem weapon = _modelManager.Inventory.AddNewWeapon(roleConfig.InitWeaponItemId);
+            weapon.RoleId = role.RoleId;
+
+            role.ApplyWeaponProperties(configManager.GetConfig<WeaponConfig>(weapon.Id)!);
+        }
     }
 
     [GameEvent(GameEventType.EnterGame)]
-    public async Task OnEnterGame(ModelManager modelManager, ConfigManager configManager)
+    public async Task OnEnterGame(ModelManager modelManager)
     {
-        PlayerModel player = modelManager.Player;
-
         await Session.Push(MessageId.PbGetRoleListNotify, new PbGetRoleListNotify
         {
             RoleList =
             {
-                configManager.GetCollection(ConfigType.RoleInfo)
-                .Enumerate<RoleInfoConfig>()
-                .Select(config => new roleInfo
-                {
-                    RoleId = config.Id,
-                    Level = 1
-                })
+                modelManager.Roles.Roles
             }
         });
     }
 
     [NetEvent(MessageId.SwitchRoleRequest)]
-    public async Task<ResponseMessage> OnSwitchRoleRequest(SwitchRoleRequest request, CreatureController creatureController)
+    public async Task<RpcResult> OnSwitchRoleRequest(SwitchRoleRequest request, CreatureController creatureController)
     {
         await creatureController.SwitchPlayerEntity(request.RoleId);
         return Response(MessageId.SwitchRoleResponse, new SwitchRoleResponse
@@ -45,5 +65,180 @@ internal class RoleController : Controller
     }
 
     [NetEvent(MessageId.RoleFavorListRequest)]
-    public ResponseMessage OnRoleFavorListRequest() => Response(MessageId.RoleFavorListResponse, new RoleFavorListResponse());
+    public RpcResult OnRoleFavorListRequest() => Response(MessageId.RoleFavorListResponse, new RoleFavorListResponse());
+
+    [NetEvent(MessageId.ResonantChainUnlockRequest)]
+    public RpcResult OnResonantChainUnlockRequest(ResonantChainUnlockRequest request, ModelManager modelManager, ConfigManager configManager)
+    {
+        roleInfo? role = modelManager.Roles.Roles.Find(r => r.RoleId == request.RoleId)!;
+    
+        if (role != null)
+        {
+            RoleInfoConfig roleConfig = configManager.GetConfig<RoleInfoConfig>(request.RoleId)!;
+    
+            int resonantChainGroupId = roleConfig.ResonantChainGroupId;
+    
+            // Todo: add buff by _resonantChainGroupId
+    
+            int curr = role.ResonantChainGroupIndex;
+            int next = Math.Min(curr + 1, 6);
+            role.ResonantChainGroupIndex = next;
+    
+            return Response(MessageId.ResonantChainUnlockResponse, new ResonantChainUnlockResponse
+            {
+                RoleId = request.RoleId,
+                ResonantChainGroupIndex = next
+            });
+        }
+    
+        return Response(MessageId.ResonantChainUnlockResponse, new ResonantChainUnlockResponse
+        {
+            ErrCode = (int)ErrorCode.ErrRoleResonNotActive
+        });
+    }
+
+    private static List<ArrayIntInt> CreateBasePropList(BasePropertyConfig? config)
+    {
+        List<ArrayIntInt> baseProp = [];
+        if (config == null) return baseProp;
+
+        baseProp.Add(new() { Key = (int)EAttributeType.Lv, Value = config.Lv });
+        baseProp.Add(new() { Key = (int)EAttributeType.LifeMax, Value = config.LifeMax });
+        baseProp.Add(new() { Key = (int)EAttributeType.Life, Value = config.Life });
+        baseProp.Add(new() { Key = (int)EAttributeType.Sheild, Value = config.Sheild });
+        baseProp.Add(new() { Key = (int)EAttributeType.SheildDamageChange, Value = config.SheildDamageChange });
+        baseProp.Add(new() { Key = (int)EAttributeType.SheildDamageReduce, Value = config.SheildDamageReduce });
+        baseProp.Add(new() { Key = (int)EAttributeType.Atk, Value = config.Atk });
+        baseProp.Add(new() { Key = (int)EAttributeType.Crit, Value = config.Crit });
+        baseProp.Add(new() { Key = (int)EAttributeType.CritDamage, Value = config.CritDamage });
+        baseProp.Add(new() { Key = (int)EAttributeType.Def, Value = config.Def });
+        baseProp.Add(new() { Key = (int)EAttributeType.EnergyEfficiency, Value = config.EnergyEfficiency });
+        baseProp.Add(new() { Key = (int)EAttributeType.CdReduse, Value = config.CdReduse });
+        baseProp.Add(new() { Key = (int)EAttributeType.ReactionEfficiency, Value = config.ReactionEfficiency });
+        baseProp.Add(new() { Key = (int)EAttributeType.DamageChangeNormalSkill, Value = config.DamageChangeNormalSkill });
+        baseProp.Add(new() { Key = (int)EAttributeType.DamageChange, Value = config.DamageChange });
+        baseProp.Add(new() { Key = (int)EAttributeType.DamageReduce, Value = config.DamageReduce });
+        baseProp.Add(new() { Key = (int)EAttributeType.DamageChangeAuto, Value = config.DamageChangeAuto });
+        baseProp.Add(new() { Key = (int)EAttributeType.DamageChangeCast, Value = config.DamageChangeCast });
+        baseProp.Add(new() { Key = (int)EAttributeType.DamageChangeUltra, Value = config.DamageChangeUltra });
+        baseProp.Add(new() { Key = (int)EAttributeType.DamageChangeQte, Value = config.DamageChangeQte });
+        baseProp.Add(new() { Key = (int)EAttributeType.DamageChangePhys, Value = config.DamageChangePhys });
+        baseProp.Add(new() { Key = (int)EAttributeType.DamageChangeElement1, Value = config.DamageChangeElement1 });
+        baseProp.Add(new() { Key = (int)EAttributeType.DamageChangeElement2, Value = config.DamageChangeElement2 });
+        baseProp.Add(new() { Key = (int)EAttributeType.DamageChangeElement3, Value = config.DamageChangeElement3 });
+        baseProp.Add(new() { Key = (int)EAttributeType.DamageChangeElement4, Value = config.DamageChangeElement4 });
+        baseProp.Add(new() { Key = (int)EAttributeType.DamageChangeElement5, Value = config.DamageChangeElement5 });
+        baseProp.Add(new() { Key = (int)EAttributeType.DamageChangeElement6, Value = config.DamageChangeElement6 });
+        baseProp.Add(new() { Key = (int)EAttributeType.DamageResistancePhys, Value = config.DamageResistancePhys });
+        baseProp.Add(new() { Key = (int)EAttributeType.DamageResistanceElement1, Value = config.DamageResistanceElement1 });
+        baseProp.Add(new() { Key = (int)EAttributeType.DamageResistanceElement2, Value = config.DamageResistanceElement2 });
+        baseProp.Add(new() { Key = (int)EAttributeType.DamageResistanceElement3, Value = config.DamageResistanceElement3 });
+        baseProp.Add(new() { Key = (int)EAttributeType.DamageResistanceElement4, Value = config.DamageResistanceElement4 });
+        baseProp.Add(new() { Key = (int)EAttributeType.DamageResistanceElement5, Value = config.DamageResistanceElement5 });
+        baseProp.Add(new() { Key = (int)EAttributeType.DamageResistanceElement6, Value = config.DamageResistanceElement6 });
+        baseProp.Add(new() { Key = (int)EAttributeType.HealChange, Value = config.HealChange });
+        baseProp.Add(new() { Key = (int)EAttributeType.HealedChange, Value = config.HealedChange });
+        baseProp.Add(new() { Key = (int)EAttributeType.DamageReducePhys, Value = config.DamageReducePhys });
+        baseProp.Add(new() { Key = (int)EAttributeType.DamageReduceElement1, Value = config.DamageReduceElement1 });
+        baseProp.Add(new() { Key = (int)EAttributeType.DamageReduceElement2, Value = config.DamageReduceElement2 });
+        baseProp.Add(new() { Key = (int)EAttributeType.DamageReduceElement3, Value = config.DamageReduceElement3 });
+        baseProp.Add(new() { Key = (int)EAttributeType.DamageReduceElement4, Value = config.DamageReduceElement4 });
+        baseProp.Add(new() { Key = (int)EAttributeType.DamageReduceElement5, Value = config.DamageReduceElement5 });
+        baseProp.Add(new() { Key = (int)EAttributeType.DamageReduceElement6, Value = config.DamageReduceElement6 });
+        baseProp.Add(new() { Key = (int)EAttributeType.ReactionChange1, Value = config.ReactionChange1 });
+        baseProp.Add(new() { Key = (int)EAttributeType.ReactionChange2, Value = config.ReactionChange2 });
+        baseProp.Add(new() { Key = (int)EAttributeType.ReactionChange3, Value = config.ReactionChange3 });
+        baseProp.Add(new() { Key = (int)EAttributeType.ReactionChange4, Value = config.ReactionChange4 });
+        baseProp.Add(new() { Key = (int)EAttributeType.ReactionChange5, Value = config.ReactionChange5 });
+        baseProp.Add(new() { Key = (int)EAttributeType.ReactionChange6, Value = config.ReactionChange6 });
+        baseProp.Add(new() { Key = (int)EAttributeType.ReactionChange7, Value = config.ReactionChange7 });
+        baseProp.Add(new() { Key = (int)EAttributeType.ReactionChange8, Value = config.ReactionChange8 });
+        baseProp.Add(new() { Key = (int)EAttributeType.ReactionChange9, Value = config.ReactionChange9 });
+        baseProp.Add(new() { Key = (int)EAttributeType.ReactionChange10, Value = config.ReactionChange10 });
+        baseProp.Add(new() { Key = (int)EAttributeType.ReactionChange11, Value = config.ReactionChange11 });
+        baseProp.Add(new() { Key = (int)EAttributeType.ReactionChange12, Value = config.ReactionChange12 });
+        baseProp.Add(new() { Key = (int)EAttributeType.ReactionChange13, Value = config.ReactionChange13 });
+        baseProp.Add(new() { Key = (int)EAttributeType.ReactionChange14, Value = config.ReactionChange14 });
+        baseProp.Add(new() { Key = (int)EAttributeType.ReactionChange15, Value = config.ReactionChange15 });
+        baseProp.Add(new() { Key = (int)EAttributeType.EnergyMax, Value = config.EnergyMax });
+        baseProp.Add(new() { Key = (int)EAttributeType.Energy, Value = config.Energy });
+        baseProp.Add(new() { Key = (int)EAttributeType.SpecialEnergy1Max, Value = config.SpecialEnergy1Max });
+        baseProp.Add(new() { Key = (int)EAttributeType.SpecialEnergy1, Value = config.SpecialEnergy1 });
+        baseProp.Add(new() { Key = (int)EAttributeType.SpecialEnergy2Max, Value = config.SpecialEnergy2Max });
+        baseProp.Add(new() { Key = (int)EAttributeType.SpecialEnergy2, Value = config.SpecialEnergy2 });
+        baseProp.Add(new() { Key = (int)EAttributeType.SpecialEnergy3Max, Value = config.SpecialEnergy3Max });
+        baseProp.Add(new() { Key = (int)EAttributeType.SpecialEnergy3, Value = config.SpecialEnergy3 });
+        baseProp.Add(new() { Key = (int)EAttributeType.SpecialEnergy4Max, Value = config.SpecialEnergy4Max });
+        baseProp.Add(new() { Key = (int)EAttributeType.SpecialEnergy4, Value = config.SpecialEnergy4 });
+        baseProp.Add(new() { Key = (int)EAttributeType.StrengthMax, Value = config.StrengthMax });
+        baseProp.Add(new() { Key = (int)EAttributeType.Strength, Value = config.Strength });
+        baseProp.Add(new() { Key = (int)EAttributeType.StrengthRecover, Value = config.StrengthRecover });
+        baseProp.Add(new() { Key = (int)EAttributeType.StrengthPunishTime, Value = config.StrengthPunishTime });
+        baseProp.Add(new() { Key = (int)EAttributeType.StrengthRun, Value = config.StrengthRun });
+        baseProp.Add(new() { Key = (int)EAttributeType.StrengthSwim, Value = config.StrengthSwim });
+        baseProp.Add(new() { Key = (int)EAttributeType.StrengthFastSwim, Value = config.StrengthFastSwim });
+        baseProp.Add(new() { Key = (int)EAttributeType.StrengthClimb, Value = config.StrengthClimb });
+        baseProp.Add(new() { Key = (int)EAttributeType.StrengthFastClimb, Value = config.StrengthFastClimb });
+        baseProp.Add(new() { Key = (int)EAttributeType.HardnessMax, Value = config.HardnessMax });
+        baseProp.Add(new() { Key = (int)EAttributeType.Hardness, Value = config.Hardness });
+        baseProp.Add(new() { Key = (int)EAttributeType.HardnessRecover, Value = config.HardnessRecover });
+        baseProp.Add(new() { Key = (int)EAttributeType.HardnessPunishTime, Value = config.HardnessPunishTime });
+        baseProp.Add(new() { Key = (int)EAttributeType.HardnessChange, Value = config.HardnessChange });
+        baseProp.Add(new() { Key = (int)EAttributeType.HardnessReduce, Value = config.HardnessReduce });
+        baseProp.Add(new() { Key = (int)EAttributeType.RageMax, Value = config.RageMax });
+        baseProp.Add(new() { Key = (int)EAttributeType.Rage, Value = config.Rage });
+        baseProp.Add(new() { Key = (int)EAttributeType.RageRecover, Value = config.RageRecover });
+        baseProp.Add(new() { Key = (int)EAttributeType.RagePunishTime, Value = config.RagePunishTime });
+        baseProp.Add(new() { Key = (int)EAttributeType.RageChange, Value = config.RageChange });
+        baseProp.Add(new() { Key = (int)EAttributeType.RageReduce, Value = config.RageReduce });
+        baseProp.Add(new() { Key = (int)EAttributeType.ToughMax, Value = config.ToughMax });
+        baseProp.Add(new() { Key = (int)EAttributeType.Tough, Value = config.Tough });
+        baseProp.Add(new() { Key = (int)EAttributeType.ToughRecover, Value = config.ToughRecover });
+        baseProp.Add(new() { Key = (int)EAttributeType.ToughChange, Value = config.ToughChange });
+        baseProp.Add(new() { Key = (int)EAttributeType.ToughReduce, Value = config.ToughReduce });
+        baseProp.Add(new() { Key = (int)EAttributeType.ToughRecoverDelayTime, Value = config.ToughRecoverDelayTime });
+        baseProp.Add(new() { Key = (int)EAttributeType.ElementPower1, Value = config.ElementPower1 });
+        baseProp.Add(new() { Key = (int)EAttributeType.ElementPower2, Value = config.ElementPower2 });
+        baseProp.Add(new() { Key = (int)EAttributeType.ElementPower3, Value = config.ElementPower3 });
+        baseProp.Add(new() { Key = (int)EAttributeType.ElementPower4, Value = config.ElementPower4 });
+        baseProp.Add(new() { Key = (int)EAttributeType.ElementPower5, Value = config.ElementPower5 });
+        baseProp.Add(new() { Key = (int)EAttributeType.ElementPower6, Value = config.ElementPower6 });
+        baseProp.Add(new() { Key = (int)EAttributeType.SpecialDamageChange, Value = config.SpecialDamageChange });
+        baseProp.Add(new() { Key = (int)EAttributeType.StrengthFastClimbCost, Value = config.StrengthFastClimbCost });
+        baseProp.Add(new() { Key = (int)EAttributeType.ElementPropertyType, Value = config.ElementPropertyType });
+        baseProp.Add(new() { Key = (int)EAttributeType.WeakTime, Value = config.WeakTime });
+        baseProp.Add(new() { Key = (int)EAttributeType.IgnoreDefRate, Value = config.IgnoreDefRate });
+        baseProp.Add(new() { Key = (int)EAttributeType.IgnoreDamageResistancePhys, Value = config.IgnoreDamageResistancePhys });
+        baseProp.Add(new() { Key = (int)EAttributeType.IgnoreDamageResistanceElement1, Value = config.IgnoreDamageResistanceElement1 });
+        baseProp.Add(new() { Key = (int)EAttributeType.IgnoreDamageResistanceElement2, Value = config.IgnoreDamageResistanceElement2 });
+        baseProp.Add(new() { Key = (int)EAttributeType.IgnoreDamageResistanceElement3, Value = config.IgnoreDamageResistanceElement3 });
+        baseProp.Add(new() { Key = (int)EAttributeType.IgnoreDamageResistanceElement4, Value = config.IgnoreDamageResistanceElement4 });
+        baseProp.Add(new() { Key = (int)EAttributeType.IgnoreDamageResistanceElement5, Value = config.IgnoreDamageResistanceElement5 });
+        baseProp.Add(new() { Key = (int)EAttributeType.IgnoreDamageResistanceElement6, Value = config.IgnoreDamageResistanceElement6 });
+        baseProp.Add(new() { Key = (int)EAttributeType.SkillToughRatio, Value = config.SkillToughRatio });
+        baseProp.Add(new() { Key = (int)EAttributeType.StrengthClimbJump, Value = config.StrengthClimbJump });
+        baseProp.Add(new() { Key = (int)EAttributeType.StrengthGliding, Value = config.StrengthGliding });
+        baseProp.Add(new() { Key = (int)EAttributeType.Mass, Value = config.Mass });
+        baseProp.Add(new() { Key = (int)EAttributeType.BrakingFrictionFactor, Value = config.BrakingFrictionFactor });
+        baseProp.Add(new() { Key = (int)EAttributeType.GravityScale, Value = config.GravityScale });
+        baseProp.Add(new() { Key = (int)EAttributeType.SpeedRatio, Value = config.SpeedRatio });
+        baseProp.Add(new() { Key = (int)EAttributeType.DamageChangePhantom, Value = config.DamageChangePhantom });
+        baseProp.Add(new() { Key = (int)EAttributeType.AutoAttackSpeed, Value = config.AutoAttackSpeed });
+        baseProp.Add(new() { Key = (int)EAttributeType.CastAttackSpeed, Value = config.CastAttackSpeed });
+        baseProp.Add(new() { Key = (int)EAttributeType.StatusBuildUp1Max, Value = config.StatusBuildUp1Max });
+        baseProp.Add(new() { Key = (int)EAttributeType.StatusBuildUp1, Value = config.StatusBuildUp1 });
+        baseProp.Add(new() { Key = (int)EAttributeType.StatusBuildUp2Max, Value = config.StatusBuildUp2Max });
+        baseProp.Add(new() { Key = (int)EAttributeType.StatusBuildUp2, Value = config.StatusBuildUp2 });
+        baseProp.Add(new() { Key = (int)EAttributeType.StatusBuildUp3Max, Value = config.StatusBuildUp3Max });
+        baseProp.Add(new() { Key = (int)EAttributeType.StatusBuildUp3, Value = config.StatusBuildUp3 });
+        baseProp.Add(new() { Key = (int)EAttributeType.StatusBuildUp4Max, Value = config.StatusBuildUp4Max });
+        baseProp.Add(new() { Key = (int)EAttributeType.StatusBuildUp4, Value = config.StatusBuildUp4 });
+        baseProp.Add(new() { Key = (int)EAttributeType.StatusBuildUp5Max, Value = config.StatusBuildUp5Max });
+        baseProp.Add(new() { Key = (int)EAttributeType.StatusBuildUp5, Value = config.StatusBuildUp5 });
+        baseProp.Add(new() { Key = (int)EAttributeType.ParalysisTimeMax, Value = config.ParalysisTimeMax });
+        baseProp.Add(new() { Key = (int)EAttributeType.ParalysisTime, Value = config.ParalysisTime });
+        baseProp.Add(new() { Key = (int)EAttributeType.ParalysisTimeRecover, Value = config.ParalysisTimeRecover });
+
+        return baseProp;
+    }
 }

GameServer/Controllers/RouletteController.cs

@@ -1,7 +1,5 @@
 using GameServer.Controllers.Attributes;
-using GameServer.Models;
 using GameServer.Network;
-using GameServer.Network.Messages;
 using GameServer.Systems.Entity;
 using GameServer.Systems.Entity.Component;
 using GameServer.Systems.Event;
@@ -20,7 +18,7 @@ internal class RouletteController : Controller
     {
         await Session.Push(MessageId.ExploreToolAllNotify, new ExploreToolAllNotify
         {
-            SkillList = { 1001, 1004, 1003 },
+            SkillList = { 3001, 3002, 1005, 1006, 1001, 1004, 1003, 1007, 1009 },
             ExploreSkill = 1001
         });
 
@@ -34,14 +32,14 @@ internal class RouletteController : Controller
                 },
                 new ExploreSkillRoulette
                 {
-                    SkillIds = {1001, 1004, 1003, 0, 0, 0, 0, 0},
+                    SkillIds = {10002, 10004, 0, 0, 0, 0, 0, 0},
                 }
             }
         });
     }
 
     [NetEvent(MessageId.VisionExploreSkillSetRequest)]
-    public async Task<ResponseMessage> OnVisionExploreSkillSetRequest(VisionExploreSkillSetRequest request, CreatureController creatureController, EventSystem eventSystem)
+    public async Task<RpcResult> OnVisionExploreSkillSetRequest(VisionExploreSkillSetRequest request, CreatureController creatureController, EventSystem eventSystem)
     {
         PlayerEntity? playerEntity = creatureController.GetPlayerEntity();
         if (playerEntity == null) return Response(MessageId.VisionExploreSkillSetResponse, new VisionExploreSkillSetResponse { ErrCode = (int)ErrorCode.PlayerNotInAnyScene });

GameServer/Controllers/ShopController.cs

@@ -1,6 +1,5 @@
 using GameServer.Controllers.Attributes;
 using GameServer.Network;
-using GameServer.Network.Messages;
 using Protocol;
 
 namespace GameServer.Controllers;
@@ -12,5 +11,5 @@ internal class ShopController : Controller
     }
 
     [NetEvent(MessageId.PayShopInfoRequest)]
-    public ResponseMessage OnPayShopInfoRequest() => Response(MessageId.PayShopInfoResponse, new PayShopInfoResponse());
+    public RpcResult OnPayShopInfoRequest() => Response(MessageId.PayShopInfoResponse, new PayShopInfoResponse());
 }

GameServer/Controllers/TeleportController.cs

@@ -1,6 +1,5 @@
 using GameServer.Controllers.Attributes;
 using GameServer.Network;
-using GameServer.Network.Messages;
 using Protocol;
 
 namespace GameServer.Controllers;
@@ -12,8 +11,8 @@ internal class TeleportController : Controller
     }
 
     [NetEvent(MessageId.TeleportFinishRequest)]
-    public ResponseMessage OnTeleportFinishRequest() => Response(MessageId.TeleportFinishResponse, new TeleportFinishResponse());
+    public RpcResult OnTeleportFinishRequest() => Response(MessageId.TeleportFinishResponse, new TeleportFinishResponse());
 
     [NetEvent(MessageId.TeleportDataRequest)]
-    public ResponseMessage OnTeleportDataRequest() => Response(MessageId.TeleportDataResponse, new TeleportDataResponse());
+    public RpcResult OnTeleportDataRequest() => Response(MessageId.TeleportDataResponse, new TeleportDataResponse());
 }

GameServer/Controllers/TowerController.cs

@@ -1,6 +1,5 @@
 using GameServer.Controllers.Attributes;
 using GameServer.Network;
-using GameServer.Network.Messages;
 using Protocol;
 
 namespace GameServer.Controllers;
@@ -12,8 +11,8 @@ internal class TowerController : Controller
     }
 
     [NetEvent(MessageId.TowerChallengeRequest)]
-    public ResponseMessage OnTowerChallengeRequest() => Response(MessageId.TowerChallengeResponse, new TowerChallengeResponse());
+    public RpcResult OnTowerChallengeRequest() => Response(MessageId.TowerChallengeResponse, new TowerChallengeResponse());
 
     [NetEvent(MessageId.CycleTowerChallengeRequest)]
-    public ResponseMessage OnCycleTowerChallengeRequest() => Response(MessageId.CycleTowerChallengeResponse, new CycleTowerChallengeResponse());
+    public RpcResult OnCycleTowerChallengeRequest() => Response(MessageId.CycleTowerChallengeResponse, new CycleTowerChallengeResponse());
 }

GameServer/Controllers/TutorialController.cs

@@ -1,6 +1,5 @@
 using GameServer.Controllers.Attributes;
 using GameServer.Network;
-using GameServer.Network.Messages;
 using Protocol;
 
 namespace GameServer.Controllers;
@@ -12,7 +11,7 @@ internal class TutorialController : Controller
     }
 
     [NetEvent(MessageId.TutorialInfoRequest)]
-    public ResponseMessage OnTutorialInfoRequest()
+    public RpcResult OnTutorialInfoRequest()
     {
         int[] tutorials = [30001, 30002, 30003, 30004, 30005, 30006, 30007, 30011, 30012, 30008, 30009, 30010, 30013, 30014, 30015, 30016, 30017, 30018, 30019, 30020, 30021, 30022, 30023, 30024, 40001, 30025, 30026, 30027, 30028, 30029, 30030, 30031, 30032, 30033, 30034, 30035, 30036, 50001, 50002, 50003, 50004, 50005, 50006, 50007, 50008, 50009, 50010, 50011, 33001, 34017, 34018, 32001, 32002, 32003, 32004, 32005, 32006, 32007, 32008, 32009, 32010, 32011, 32012, 32013, 32014, 32015, 32016, 32017, 32018, 32019, 32020, 32021, 33002, 33003, 33004, 33005, 34001, 34002, 34003, 34004, 34005, 34006, 34007, 34008, 34009, 34010, 34011, 34012, 34013, 34014, 34015, 34016, 34019, 34020, 34021, 34022, 34023, 34024, 34025, 34027, 34028, 34029, 34030, 34031, 34032, 34033];
         TutorialInfoResponse rsp = new();
@@ -30,7 +29,7 @@ internal class TutorialController : Controller
     }
 
     [NetEvent(MessageId.GetDetectionLabelInfoRequest)]
-    public ResponseMessage OnGetDetectionLabelInfoRequest()
+    public RpcResult OnGetDetectionLabelInfoRequest()
     {
         int[] guides = [0, 1, 2, 3, 14, 15, 16, 4, 21, 22, 7, 5, 18, 6, 61, 8, 9, 10, 11, 12, 13, 17, 19];
         int[] detectionTexts = [1, 2, 3, 4, 5, 6, 7, 0, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18, 21, 22, 61];
@@ -43,7 +42,7 @@ internal class TutorialController : Controller
     }
 
     [NetEvent(MessageId.GuideInfoRequest)]
-    public ResponseMessage OnGuideInfoRequest() => Response(MessageId.GuideInfoResponse, new GuideInfoResponse()
+    public RpcResult OnGuideInfoRequest() => Response(MessageId.GuideInfoResponse, new GuideInfoResponse()
     {
         GuideGroupFinishList = { 60001, 60002, 60003, 60004, 60005, 60006, 60007, 60008, 60009, 60010, 60011, 60012, 60013, 60014, 60015, 60016, 60017, 60018, 60019, 60020, 60021, 60101, 60102, 60103, 62002, 62004, 62005, 62006, 62007, 62009, 62010, 62011, 62012, 62013, 62014, 62015, 62016, 62017, 62022, 62027, 62028, 62029, 62030, 62031, 62032, 62033, 62034, 62036, 65001, 67001, 67002, 67003, 67004, 67005, 67006, 67007, 67008, 67009, 67010, 67011, 67012, 67013, 67014, 67015, 67016, 67017, 67018, 67019, 67022, 62001, 62008, 62018, 62019, 62020, 62021, 62023, 62024, 62025, 62026, 62035, 65002, 65003, 65004, 65005 }
     });

GameServer/Controllers/WorldController.cs

@@ -1,6 +1,5 @@
 using GameServer.Controllers.Attributes;
 using GameServer.Network;
-using GameServer.Network.Messages;
 using GameServer.Systems.Event;
 using Protocol;
 
@@ -19,14 +18,14 @@ internal class WorldController : Controller
     }
 
     [NetEvent(MessageId.EntityOnLandedRequest)]
-    public ResponseMessage OnEntityOnLandedRequest() => Response(MessageId.EntityOnLandedResponse, new EntityOnLandedResponse());
+    public RpcResult OnEntityOnLandedRequest() => Response(MessageId.EntityOnLandedResponse, new EntityOnLandedResponse());
 
     [NetEvent(MessageId.PlayerMotionRequest)]
-    public ResponseMessage OnPlayerMotionRequest() => Response(MessageId.PlayerMotionResponse, new PlayerMotionResponse());
+    public RpcResult OnPlayerMotionRequest() => Response(MessageId.PlayerMotionResponse, new PlayerMotionResponse());
 
     [NetEvent(MessageId.EntityLoadCompleteRequest)]
-    public ResponseMessage OnEntityLoadCompleteRequest() => Response(MessageId.EntityLoadCompleteResponse, new EntityLoadCompleteResponse());
+    public RpcResult OnEntityLoadCompleteRequest() => Response(MessageId.EntityLoadCompleteResponse, new EntityLoadCompleteResponse());
 
     [NetEvent(MessageId.UpdateSceneDateRequest)]
-    public ResponseMessage OnUpdateSceneDateRequest() => Response(MessageId.UpdateSceneDateResponse, new UpdateSceneDateResponse());
+    public RpcResult OnUpdateSceneDateRequest() => Response(MessageId.UpdateSceneDateResponse, new UpdateSceneDateResponse());
 }

GameServer/Controllers/WorldMapController.cs

@@ -1,6 +1,5 @@
 using GameServer.Controllers.Attributes;
 using GameServer.Network;
-using GameServer.Network.Messages;
 using GameServer.Settings;
 using GameServer.Systems.Entity;
 using Microsoft.Extensions.Options;
@@ -15,20 +14,20 @@ internal class WorldMapController : Controller
     }
 
     [NetEvent(MessageId.MapTraceInfoRequest)]
-    public ResponseMessage OnMapTraceInfoRequest() => Response(MessageId.MapTraceInfoResponse, new MapTraceInfoResponse()
+    public RpcResult OnMapTraceInfoRequest() => Response(MessageId.MapTraceInfoResponse, new MapTraceInfoResponse()
     {
         // Don't.
         //MarkIdList = { 1, 2, 3, 1000, 1001, 1002, 1003, 1004, 1005, 1007, 1008, 1009, 3000, 3002, 3003, 3005, 3010, 3011, 3012, 4020, 4021, 4022, 4023, 5001, 5002, 5003, 5004, 5005, 5006, 5007, 5021, 5022, 5023, 5025, 5026, 5027, 5028, 5029, 5030, 5031, 380000, 380002, 380003, 380004, 380006, 380007, 380015, 301203, 380013, 380014, 301204, 300201, 300202, 300203, 300301, 300302, 300303, 300304, 300306, 300309, 300310, 300311, 300312, 300313, 300401, 300402, 300403, 300404, 300405, 300406, 300407, 300408, 300410, 300413, 300501, 300502, 300506, 300507, 300508, 300509, 300510, 300511, 300601, 300603, 300604, 300605, 300606, 300607, 300608, 300701, 300703, 300704, 300707, 300708, 300711, 300712, 300713, 300901, 300902, 300911, 300912, 300914, 300915, 300918, 301001, 301003, 301004, 301005, 301006, 301007, 301008, 301009, 301010, 301012, 301013, 301014, 301015, 10000, 10001, 10002, 10003, 10005, 10006, 300801, 301201, 300412, 3015, 3016, 3017, 300411 }
     });
 
     [NetEvent(MessageId.MapUnlockFieldInfoRequest)]
-    public ResponseMessage OnMapUnlockFieldInfoRequest() => Response(MessageId.MapUnlockFieldInfoResponse, new MapUnlockFieldInfoResponse
+    public RpcResult OnMapUnlockFieldInfoRequest() => Response(MessageId.MapUnlockFieldInfoResponse, new MapUnlockFieldInfoResponse
     {
         FieldId = { Enumerable.Range(1, 12) }
     });
 
     [NetEvent(MessageId.MapMarkRequest)]
-    public async Task<ResponseMessage> OnMapMarkRequest(MapMarkRequest request, IOptions<GameplayFeatureSettings> gameplayFeatures, CreatureController creatureController)
+    public async Task<RpcResult> OnMapMarkRequest(MapMarkRequest request, IOptions<GameplayFeatureSettings> gameplayFeatures, CreatureController creatureController)
     {
         if (gameplayFeatures.Value.TeleportByMapMark)
         {

GameServer/Extensions/Logic/MathExtensions.cs

@@ -0,0 +1,13 @@
+using Protocol;
+
+namespace GameServer.Extensions.Logic;
+internal static class MathExtensions
+{
+    public static float GetDistance(this Vector self, Vector other)
+    {
+        float x = self.X - other.X;
+        float y = self.Y - other.Y;
+
+        return (float)Math.Sqrt(x * x + y * y);
+    }
+}

GameServer/Extensions/Logic/RoleInfoExtensions.cs

@@ -0,0 +1,39 @@
+using Core.Config;
+using Protocol;
+
+namespace GameServer.Extensions.Logic;
+internal static class RoleInfoExtensions
+{
+    public static IEnumerable<GameplayAttributeData> GetAttributeList(this roleInfo role)
+    {
+        return role.BaseProp.Select(prop => new GameplayAttributeData
+        {
+            AttributeType = prop.Key,
+            BaseValue = prop.Value,
+            CurrentValue = prop.Value + ((role.AddProp.SingleOrDefault(p => p.Key == prop.Key)?.Value) ?? 0),
+        });
+    }
+
+    public static void ApplyWeaponProperties(this roleInfo role, WeaponConfig weaponConf)
+    {
+        role.AddProp.Clear();
+
+        if (weaponConf.FirstPropId != null)
+        {
+            role.AddProp.Add(new ArrayIntInt
+            {
+                Key = weaponConf.FirstPropId.Id,
+                Value = (int)weaponConf.FirstPropId.Value
+            });
+        }
+
+        if (weaponConf.SecondPropId != null)
+        {
+            role.AddProp.Add(new ArrayIntInt
+            {
+                Key = weaponConf.SecondPropId.Id,
+                Value = (int)weaponConf.SecondPropId.Value
+            });
+        }
+    }
+}

GameServer/Models/Chat/ChatRoom.cs

@@ -1,5 +1,4 @@
-using Google.Protobuf;
-using Protocol;
+using Protocol;
 
 namespace GameServer.Models.Chat;
 internal class ChatRoom

GameServer/Models/FormationModel.cs

@@ -10,7 +10,7 @@ internal class FormationModel
 
     public void Set(int[] roleIds)
     {
-        for (int i = 0; i < RoleIds.Length; i++)
+        for (int i = 0; i < roleIds.Length; i++)
         {
             RoleIds[i] = roleIds[i];
         }

GameServer/Models/InventoryModel.cs

@@ -0,0 +1,55 @@
+using Protocol;
+
+namespace GameServer.Models;
+internal class InventoryModel
+{
+    private int _itemIncrId;
+
+    public List<NormalItem> ItemList { get; } = [];
+    public List<WeaponItem> WeaponList { get; } = [];
+
+    public WeaponItem? GetEquippedWeapon(int roleId) => WeaponList.SingleOrDefault(weapon => weapon.RoleId == roleId);
+
+    public WeaponItem? GetWeaponById(int incrId) => WeaponList.SingleOrDefault(weapon => weapon.IncrId == incrId);
+
+    public int GetItemCount(int itemId) => ItemList.SingleOrDefault(item => item.Id == itemId)?.Count ?? 0;
+
+    public bool TryUseItem(int itemId, int amount)
+    {
+        int currentAmount = GetItemCount(itemId);
+        if (amount > currentAmount) return false;
+
+        AddItem(itemId, -amount);
+        return true;
+    }
+
+    public void AddItem(int itemId, int amount)
+    {
+        NormalItem? item = ItemList.SingleOrDefault(item => item.Id == itemId);
+        if (item != null)
+        {
+            item.Count += amount;
+            return;
+        }
+
+        ItemList.Add(new NormalItem
+        {
+            Id = itemId,
+            Count = amount
+        });
+    }
+
+    public WeaponItem AddNewWeapon(int weaponId)
+    {
+        WeaponItem weapon = new()
+        {
+            Id = weaponId,
+            IncrId = ++_itemIncrId,
+            WeaponLevel = 1,
+            WeaponResonLevel = 1
+        };
+
+        WeaponList.Add(weapon);
+        return weapon;
+    }
+}

GameServer/Models/ModelManager.cs

@@ -1,4 +1,5 @@
-using GameServer.Controllers.Attributes;
+using Core.Config;
+using GameServer.Controllers.Attributes;
 using GameServer.Settings;
 using GameServer.Systems.Event;
 using Microsoft.Extensions.Options;
@@ -7,13 +8,15 @@ namespace GameServer.Models;
 internal class ModelManager
 {
     private readonly IOptions<PlayerStartingValues> _playerStartingValues;
+    private readonly ConfigManager _configManager;
 
     private PlayerModel? _playerModel;
     private CreatureModel? _creatureModel;
 
-    public ModelManager(IOptions<PlayerStartingValues> playerStartingValues)
+    public ModelManager(IOptions<PlayerStartingValues> playerStartingValues, ConfigManager configManager)
     {
         _playerStartingValues = playerStartingValues;
+        _configManager = configManager;
     }
 
     [GameEvent(GameEventType.Login)]
@@ -29,6 +32,8 @@ internal class ModelManager
 
     public CreatureModel Creature => _creatureModel ?? throw new InvalidOperationException($"Trying to access {nameof(CreatureModel)} instance before initialization!");
 
+    public RoleModel Roles { get; } = new();
     public FormationModel Formation { get; } = new();
+    public InventoryModel Inventory { get; } = new();
     public ChatModel Chat { get; } = new();
 }

GameServer/Models/PlayerModel.cs

@@ -1,29 +1,103 @@
-using Protocol;
-using GameServer.Settings;
+using GameServer.Settings;
+using Protocol;
 
 namespace GameServer.Models;
 internal class PlayerModel
 {
+    private const int MaxPlayerLevel = 80;
+
+    public List<PlayerAttr> Attributes { get; } = [];
+
     public int Id { get; private set; }
-    public string Name { get; private set; }
+    public int BirthDay { get; set; }
     public int[] Characters { get; private set; }
     public Vector Position { get; private set; }
 
+    public string Name => GetStringAttribute(PlayerAttrKey.Name);
+
     public PlayerModel()
     {
-        Name = string.Empty;
         Characters = [];
         Position = new Vector();
     }
 
+    public void SetAttribute(PlayerAttrKey key, int value)
+    {
+        SetAttribute(key, PlayerAttrType.Int32, value, null);
+    }
+
+    public void SetAttribute(PlayerAttrKey key, string value)
+    {
+        SetAttribute(key, PlayerAttrType.String, 0, value);
+    }
+
+    public int GetIntAttribute(PlayerAttrKey key)
+    {
+        return GetAttributeOfType(key, PlayerAttrType.Int32)?.Int32Value ?? 0;
+    }
+
+    public string GetStringAttribute(PlayerAttrKey key)
+    {
+        return GetAttributeOfType(key, PlayerAttrType.String)?.StringValue ?? string.Empty;
+    }
+
+    private void SetAttribute(PlayerAttrKey key, PlayerAttrType type, int intValue, string? stringValue)
+    {
+        PlayerAttr? attr = GetAttributeOfType(key, type);
+        if (attr == null)
+        {
+            attr = new PlayerAttr
+            {
+                Key = (int)key,
+                ValueType = (int)type,
+            };
+
+            Attributes.Add(attr);
+        }
+
+        switch (type)
+        {
+            case PlayerAttrType.Int32:
+                attr.Int32Value = intValue; break;
+            case PlayerAttrType.String:
+                attr.StringValue = stringValue; break;
+        }
+    }
+
+    private PlayerAttr? GetAttributeOfType(PlayerAttrKey key, PlayerAttrType type)
+    {
+        PlayerAttr? attr = Attributes.SingleOrDefault(attr => attr.Key == (int)key);
+        if (attr != null)
+        {
+            if (attr.ValueType != (int)type)
+                throw new ArgumentException($"PlayerAttr type mismatch! Key: {key}, type: {(PlayerAttrType)attr.ValueType}, argument type: {type}");
+        }
+
+        return attr;
+    }
+
+    public void LevelUp()
+    {
+        int level = GetIntAttribute(PlayerAttrKey.Level);
+
+        if (level == MaxPlayerLevel) return;
+        SetAttribute(PlayerAttrKey.Level, level + 1);
+    }
+
     public static PlayerModel CreateDefaultPlayer(PlayerStartingValues startingValues)
     {
-        return new PlayerModel
+        PlayerModel playerModel = new()
         {
             Id = 1337,
-            Name = startingValues.Name,
             Characters = startingValues.Characters,
             Position = startingValues.Position.Clone()
         };
+
+        playerModel.SetAttribute(PlayerAttrKey.Name, startingValues.Name);
+        playerModel.SetAttribute(PlayerAttrKey.Level, startingValues.PlayerLevel);
+        playerModel.SetAttribute(PlayerAttrKey.HeadPhoto, startingValues.HeadPhoto);
+        playerModel.SetAttribute(PlayerAttrKey.HeadFrame, startingValues.HeadFrame);
+
+        return playerModel;
     }
 }

GameServer/Models/RoleModel.cs

@@ -0,0 +1,24 @@
+using Protocol;
+
+namespace GameServer.Models;
+internal class RoleModel
+{
+    public List<roleInfo> Roles { get; } = [];
+
+    public roleInfo Create(int id)
+    {
+        roleInfo info = new()
+        {
+            RoleId = id,
+            Level = 1,
+        };
+
+        Roles.Add(info);
+        return info;
+    }
+
+    public roleInfo? GetRoleById(int roleId)
+    {
+        return Roles.SingleOrDefault(role => role.RoleId == roleId);
+    }
+}

GameServer/Network/Kcp/KcpConnection.cs

@@ -8,6 +8,7 @@ internal class KcpConnection : IConnection
 {
     private readonly byte[] _recvBuffer;
     private readonly KcpConversation _conv;
+    private readonly ManualResetEvent _sendEvent;
     private uint _upStreamSeqNo;
     private uint _downStreamSeqNo;
 
@@ -15,6 +16,7 @@ internal class KcpConnection : IConnection
     {
         _conv = conv;
         _recvBuffer = GC.AllocateUninitializedArray<byte>(8192);
+        _sendEvent = new ManualResetEvent(true);
     }
 
     public bool Active => !_conv.TransportClosed;
@@ -51,7 +53,16 @@ internal class KcpConnection : IConnection
         MessageManager.EncodeMessage(memory[BaseMessage.LengthFieldSize..], message);
 
         if (_conv == null) throw new InvalidOperationException("Trying to send message when conv is null");
+
+        if (!_sendEvent.WaitOne(0))
+        {
+            await Task.Yield();
+            _ = _sendEvent.WaitOne();
+        }
+
+        _sendEvent.Reset();
         await _conv.SendAsync(memoryOwner.Memory[..networkSize]);
+        _sendEvent.Set();
     }
 
     private uint NextUpStreamSeqNo()

GameServer/Network/Messages/MessageManager.cs

@@ -4,7 +4,7 @@ using Protocol;
 namespace GameServer.Network.Messages;
 
 internal delegate Task PushHandler(IServiceProvider serviceProvider, ReadOnlySpan<byte> data);
-internal delegate Task<ResponseMessage> RpcHandler(IServiceProvider serviceProvider, ReadOnlySpan<byte> data);
+internal delegate Task<RpcResult> RpcHandler(IServiceProvider serviceProvider, ReadOnlySpan<byte> data);
 internal class MessageManager
 {
     private readonly EventHandlerFactory _handlerFactory;
@@ -16,7 +16,7 @@ internal class MessageManager
         _serviceProvider = serviceProvider;
     }
 
-    public async Task<ResponseMessage?> ExecuteRpc(MessageId messageId, ReadOnlyMemory<byte> data)
+    public async Task<RpcResult?> ExecuteRpc(MessageId messageId, ReadOnlyMemory<byte> data)
     {
         RpcHandler? handler = _handlerFactory.GetRpcHandler(messageId);
         if (handler != null)

GameServer/Network/Rpc/RpcManager.cs

@@ -1,4 +1,5 @@
 using GameServer.Network.Messages;
+using GameServer.Systems.Event;
 using Microsoft.Extensions.Logging;
 
 namespace GameServer.Network.Rpc;
@@ -7,26 +8,33 @@ internal class RpcManager
     private readonly IRpcEndPoint _endPoint;
     private readonly ILogger _logger;
     private readonly MessageManager _messageManager;
+    private readonly EventSystem _eventSystem;
 
-    public RpcManager(MessageManager messageManager, IRpcEndPoint endPoint, ILogger<RpcManager> logger)
+    public RpcManager(MessageManager messageManager, IRpcEndPoint endPoint, ILogger<RpcManager> logger, EventSystem eventSystem)
     {
         _endPoint = endPoint;
         _logger = logger;
         _messageManager = messageManager;
+        _eventSystem = eventSystem;
     }
 
     public async Task Execute(RequestMessage request)
     {
-        ResponseMessage? response = await _messageManager.ExecuteRpc(request.MessageId, request.Payload);
-        if (response == null)
+        RpcResult? result = await _messageManager.ExecuteRpc(request.MessageId, request.Payload);
+        if (result == null)
         {
             _logger.LogWarning("Rpc was not handled properly (message: {msg_id}, id: {rpc_id})", request.MessageId, request.RpcID);
             return;
         }
 
-        response.RpcID = request.RpcID;
-        await _endPoint.SendRpcResult(response);
+        result.Response.RpcID = request.RpcID;
+        await _endPoint.SendRpcResult(result.Response);
 
-        _logger.LogInformation("Rpc with id {rpc_id} was handled, return message: {msg_id}", request.RpcID, response.MessageId);
+        foreach (GameEventType postEvent in result.PostEvents)
+        {
+            await _eventSystem.Emit(postEvent);
+        }
+
+        _logger.LogInformation("Rpc with id {rpc_id} was handled, return message: {msg_id}", request.RpcID, result.Response.MessageId);
     }
 }

GameServer/Program.cs

@@ -13,6 +13,7 @@ using GameServer.Network.Rpc;
 using GameServer.Settings;
 using GameServer.Systems.Entity;
 using GameServer.Systems.Event;
+using GameServer.Systems.Notify;
 using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Hosting;
@@ -25,8 +26,8 @@ internal static class Program
     private static async Task Main(string[] args)
     {
         Console.Title = "Wuthering Waves | Game Server";
-        Console.WriteLine(" __      __        __  .__                 .__                  __      __                            \r\n/  \\    /  \\__ ___/  |_|  |__   ___________|__| ____    ____   /  \\    /  \\_____ ___  __ ____   ______\r\n\\   \\/\\/   /  |  \\   __\\  |  \\_/ __ \\_  __ \\  |/    \\  / ___\\  \\   \\/\\/   /\\__  \\\\  \\/ // __ \\ /  ___/\r\n \\        /|  |  /|  | |   Y  \\  ___/|  | \\/  |   |  \\/ /_/  >  \\        /  / __ \\\\   /\\  ___/ \\___ \\ \r\n  \\__/\\  / |____/ |__| |___|  /\\___  >__|  |__|___|  /\\___  /    \\__/\\  /  (____  /\\_/  \\___  >____  >\r\n       \\/                   \\/     \\/              \\//_____/          \\/        \\/          \\/     \\/ \n");
-
+        Console.WriteLine(" __      __        __  .__                 .__                  __      __                            \r\n/  \\    /  \\__ ___/  |_|  |__   ___________|__| ____    ____   /  \\    /  \\_____ ___  __ ____   ______\r\n\\   \\/\\/   /  |  \\   __\\  |  \\_/ __ \\_  __ \\  |/    \\  / ___\\  \\   \\/\\/   /\\__  \\\\  \\/ // __ \\ /  ___/\r\n \\        /|  |  /|  | |   Y  \\  ___/|  | \\/  |   |  \\/ /_/  >  \\        /  / __ \\\\   /\\  ___/ \\___ \\ \r\n  \\__/\\  / |____/ |__| |___|  /\\___  >__|  |__|___|  /\\___  /    \\__/\\  /  (____  /\\_/  \\___  >____  >\r\n       \\/                   \\/     \\/              \\//_____/          \\/        \\/          \\/     \\/ \r\n\r\n\t\t\t\t\t\t\t\t\t\t\t\tGame Server\n");
+        
         HostApplicationBuilder builder = Host.CreateApplicationBuilder(args);
         builder.Logging.AddConsole();
 
@@ -39,7 +40,8 @@ internal static class Program
                         .AddScoped<MessageManager>().AddSingleton<EventHandlerFactory>()
                         .AddScoped<RpcManager>().AddScoped<IRpcEndPoint, RpcSessionEndPoint>()
                         .AddSingleton<SessionManager>()
-                        .AddScoped<EventSystem>().AddScoped<EntitySystem>().AddScoped<EntityFactory>()
+                        .AddScoped<EventSystem>().AddScoped<EntitySystem>().AddScoped<IGameActionListener, NotifySystem>()
+                        .AddScoped<EntityFactory>()
                         .AddScoped<ModelManager>().AddScoped<ControllerManager>()
                         .AddScoped<CombatManager>().AddScoped<ChatCommandManager>()
                         .AddHostedService<WWGameServer>();

GameServer/Settings/GameplayFeatureSettings.cs

@@ -2,4 +2,5 @@
 internal class GameplayFeatureSettings
 {
     public bool TeleportByMapMark { get; set; }
+    public bool UnlimitedEnergy { get; set; }
 }

GameServer/Settings/PlayerStartingValues.cs

@@ -4,6 +4,9 @@ namespace GameServer.Settings;
 internal class PlayerStartingValues
 {
     public required string Name { get; set; }
+    public required int PlayerLevel { get; set; }
+    public required int HeadPhoto { get; set; }
+    public required int HeadFrame { get; set; }
     public required int[] Characters { get; set; }
     public required Vector Position { get; set; }
 }

GameServer/Systems/Entity/Component/EntityAttributeComponent.cs

@@ -12,6 +12,14 @@ internal class EntityAttributeComponent : EntityComponentBase
         _gameplayAttributes = [];
     }
 
+    public void SetAll(IEnumerable<GameplayAttributeData> attributes)
+    {
+        foreach (GameplayAttributeData attr in attributes)
+        {
+            SetAttribute((EAttributeType)attr.AttributeType, attr.CurrentValue, attr.BaseValue);
+        }
+    }
+
     public void SetAttribute(EAttributeType type, int currentValue, int baseValue)
     {
         if (!_gameplayAttributes.TryGetValue(type, out GameplayAttributeData? attribute))

GameServer/Systems/Entity/Component/EntityConcomitantsComponent.cs

@@ -4,6 +4,8 @@ namespace GameServer.Systems.Entity.Component;
 internal class EntityConcomitantsComponent : EntityComponentBase
 {
     public List<long> CustomEntityIds { get; }
+    public long PhantomRoleEntityId { get; set; }
+    public long VisionEntityId { get; set; }
 
     public EntityConcomitantsComponent()
     {
@@ -19,6 +21,10 @@ internal class EntityConcomitantsComponent : EntityComponentBase
             EntityComponentPb pb = new()
             {
                 ConcomitantsComponentPb = new()
+                {
+                    PhantomRoleEid = PhantomRoleEntityId,
+                    VisionEntityId = VisionEntityId
+                }
             };
 
             pb.ConcomitantsComponentPb.CustomEntityIds.AddRange(CustomEntityIds);

GameServer/Systems/Entity/Component/EntityFightBuffComponent.cs

@@ -0,0 +1,20 @@
+using Protocol;
+
+namespace GameServer.Systems.Entity.Component;
+internal class EntityFightBuffComponent : EntityComponentBase
+{
+    public List<FightBuffInformation> BuffInfoList { get; } = [];
+
+    public override EntityComponentType Type => EntityComponentType.FightBuff;
+
+    public override EntityComponentPb Pb => new()
+    {
+        FightBuffComponent = new()
+        {
+            FightBuffInfos =
+            {
+                BuffInfoList
+            }
+        }
+    };
+}

GameServer/Systems/Entity/Component/EntityFsmComponent.cs

@@ -4,6 +4,7 @@ namespace GameServer.Systems.Entity.Component;
 internal class EntityFsmComponent : EntityComponentBase
 {
     public List<DFsm> Fsms { get; } = [];
+    public int CommonHashCode { get; set; }
 
     public override EntityComponentType Type => EntityComponentType.EntityFsm;
 
@@ -14,7 +15,8 @@ internal class EntityFsmComponent : EntityComponentBase
             Fsms =
             {
                 Fsms
-            }
+            },
+            CommonHashCode = CommonHashCode
         },
     };
 }

GameServer/Systems/Entity/Component/EntitySummonerComponent.cs

@@ -19,7 +19,7 @@ internal class EntitySummonerComponent : EntityComponentBase
             Type = (int)SummonType,
             SummonerId = SummonerId,
             PlayerId = PlayerId,
-            SummonSkillId = SummonSkillId
+            SummonSkillId = SummonSkillId,
         }
     };
 }

GameServer/Systems/Entity/EntityBase.cs

@@ -1,5 +1,6 @@
 using Core.Config;
 using GameServer.Systems.Entity.Component;
+using GameServer.Systems.Notify;
 using Protocol;
 
 namespace GameServer.Systems.Entity;
@@ -12,10 +13,15 @@ internal abstract class EntityBase
     public Rotator Rot { get; set; }
 
     public bool Active { get; set; }
+    public int DynamicId { get; protected set; }
 
     public EntityState State { get; protected set; }
 
-    public EntityBase(long id)
+    public bool IsConcomitant => ComponentSystem.TryGet<EntitySummonerComponent>(out _);
+
+    protected IGameActionListener ActionListener { get; }
+
+    public EntityBase(long id, IGameActionListener listener)
     {
         Id = id;
 
@@ -23,6 +29,7 @@ internal abstract class EntityBase
         Rot = new Rotator();
 
         ComponentSystem = new EntityComponentSystem();
+        ActionListener = listener;
     }
 
     public virtual void OnCreate()
@@ -30,6 +37,7 @@ internal abstract class EntityBase
         State = EntityState.Born;
 
         _ = ComponentSystem.Create<EntityLogicStateComponent>();
+        _ = ComponentSystem.Create<EntityFightBuffComponent>();
     }
 
     public virtual void Activate()
@@ -37,6 +45,24 @@ internal abstract class EntityBase
         // Activate.
     }
 
+    public void ChangeEquipment(int weaponId)
+    {
+        if (ComponentSystem.TryGet(out EntityEquipComponent? equipComponent))
+        {
+            equipComponent.WeaponId = weaponId;
+            _ = ActionListener.OnEntityEquipmentChanged(Id, equipComponent.Pb.EquipComponent);
+        }
+    }
+
+    public void ChangeGameplayAttributes(IEnumerable<GameplayAttributeData> attributes)
+    {
+        if (ComponentSystem.TryGet(out EntityAttributeComponent? attrComponent))
+        {
+            attrComponent.SetAll(attributes);
+            _ = ActionListener.OnEntityAttributesChanged(Id, attrComponent.Pb.AttributeComponent.GameAttributes);
+        }
+    }
+
     public virtual LivingStatus LivingStatus => LivingStatus.Alive;
     public virtual bool IsVisible => true;
 

GameServer/Systems/Entity/EntityFactory.cs

@@ -1,12 +1,40 @@
-namespace GameServer.Systems.Entity;
+using Microsoft.Extensions.DependencyInjection;
+
+namespace GameServer.Systems.Entity;
 internal class EntityFactory
 {
+    private static readonly ObjectFactory<PlayerEntity> s_createPlayerEntity;
+    private static readonly ObjectFactory<MonsterEntity> s_createMonsterEntity;
+
     private long _entityIdCounter;
+    private readonly IServiceProvider _serviceProvider;
+
+    static EntityFactory()
+    {
+        s_createPlayerEntity = ActivatorUtilities.CreateFactory<PlayerEntity>([typeof(long), typeof(int), typeof(int)]);
+        s_createMonsterEntity = ActivatorUtilities.CreateFactory<MonsterEntity>([typeof(long), typeof(int)]);
+    }
+
+    public EntityFactory(IServiceProvider serviceProvider)
+    {
+        _serviceProvider = serviceProvider;
+    }
 
     public PlayerEntity CreatePlayer(int characterConfigId, int playerId)
-        => new(NextId(), characterConfigId, playerId);
+    {
+        PlayerEntity entity = s_createPlayerEntity(_serviceProvider, [NextId(), characterConfigId, playerId]);
+        entity.OnCreate();
 
-    public MonsterEntity CreateMonster(int levelEntityId) => new(NextId(), levelEntityId);
+        return entity;
+    }
+
+    public MonsterEntity CreateMonster(int levelEntityId)
+    {
+        MonsterEntity monsterEntity = s_createMonsterEntity(_serviceProvider, [NextId(), levelEntityId]);
+        monsterEntity.OnCreate();
+
+        return monsterEntity;
+    }
 
     private long NextId() => Interlocked.Increment(ref _entityIdCounter);
 }

GameServer/Systems/Entity/EntitySystem.cs

@@ -1,13 +1,19 @@
-using Protocol;
+using GameServer.Systems.Notify;
+using Protocol;
 
 namespace GameServer.Systems.Entity;
 internal class EntitySystem
 {
     private readonly List<EntityBase> _entities;
+    private readonly List<int> _dynamicEntityIds;
 
-    public EntitySystem()
+    private readonly IGameActionListener _listener;
+
+    public EntitySystem(IGameActionListener listener)
     {
         _entities = [];
+        _dynamicEntityIds = [];
+        _listener = listener;
     }
 
     public IEnumerable<EntityBase> EnumerateEntities()
@@ -15,18 +21,36 @@ internal class EntitySystem
         return _entities;
     }
 
-    public void Create(EntityBase entity)
+    public void Add(IEnumerable<EntityBase> entities)
     {
-        if (_entities.Any(e => e.Id == entity.Id)) 
-            throw new InvalidOperationException($"EntitySystem::Create - entity with id {entity.Id} already exists");
+        foreach (EntityBase entity in entities)
+        {
+            if (_entities.Any(e => e.Id == entity.Id))
+                throw new InvalidOperationException($"EntitySystem::Create - entity with id {entity.Id} already exists");
 
-        entity.OnCreate();
-        _entities.Add(entity);
+            _entities.Add(entity);
+
+            if (entity.DynamicId != 0)
+                _dynamicEntityIds.Add(entity.DynamicId);
+        }
+
+        _ = _listener.OnEntitiesAdded(entities);
     }
 
-    public void Destroy(EntityBase entity)
+    public bool HasDynamicEntity(int dynamicId)
     {
-        _ = _entities.Remove(entity);
+        return _dynamicEntityIds.Contains(dynamicId);
+    }
+
+    public void Destroy(IEnumerable<EntityBase> entities)
+    {
+        foreach (EntityBase entity in entities)
+        {
+            _ = _entities.Remove(entity);
+            _ = _dynamicEntityIds.Remove(entity.DynamicId);
+        }
+
+        _ = _listener.OnEntitiesRemoved(entities);
     }
 
     public void Activate(EntityBase entity)

GameServer/Systems/Entity/MonsterEntity.cs

@@ -1,12 +1,14 @@
 using GameServer.Systems.Entity.Component;
+using GameServer.Systems.Notify;
 using Protocol;
 
 namespace GameServer.Systems.Entity;
 internal class MonsterEntity : EntityBase
 {
-    public MonsterEntity(long id, int configId) : base(id)
+    public MonsterEntity(long id, int configId, IGameActionListener listener) : base(id, listener)
     {
         ConfigId = configId;
+        DynamicId = configId;
     }
 
     public int ConfigId { get; }
@@ -32,17 +34,20 @@ internal class MonsterEntity : EntityBase
         fsm.Fsms.Add(new DFsm
         {
             FsmId = 10007, // Main State Machine
-            CurrentState = 10013, // Battle Branching
-            Status = 1, // ??
-            Flag = (int)EFsmStateFlag.Confirmed
+            CurrentState = 10013 // Battle Branching
         });
 
         fsm.Fsms.Add(new DFsm
         {
             FsmId = 10007, // Main State Machine
-            CurrentState = 10015, // Moving Combat
-            Status = 1, // ??
-            Flag = (int)EFsmStateFlag.Confirmed
+            CurrentState = 10015 // Moving Combat
+        });
+
+        // Some monsters need weapon
+        fsm.Fsms.Add(new DFsm
+        {
+            FsmId = 100,
+            CurrentState = 9 // [9 - Empty hand, 10 - Crowbar, 11 - flamethrower, 12 - chainsaw, 13 - electric blade, 14 - sniper rifle]
         });
     }
 

GameServer/Systems/Entity/PlayerEntity.cs

@@ -1,10 +1,11 @@
 using GameServer.Systems.Entity.Component;
+using GameServer.Systems.Notify;
 using Protocol;
 
 namespace GameServer.Systems.Entity;
 internal class PlayerEntity : EntityBase
 {
-    public PlayerEntity(long id, int configId, int playerId) : base(id)
+    public PlayerEntity(long id, int configId, int playerId, IGameActionListener listener) : base(id, listener)
     {
         ConfigId = configId;
         PlayerId = playerId;
@@ -37,15 +38,37 @@ internal class PlayerEntity : EntityBase
     {
         base.OnCreate();
 
-        // Should be created immediately
-        EntityConcomitantsComponent concomitantsComponent = ComponentSystem.Create<EntityConcomitantsComponent>();
-        concomitantsComponent.CustomEntityIds.Add(Id);
-
         EntityVisionSkillComponent visionSkillComponent = ComponentSystem.Create<EntityVisionSkillComponent>();
         visionSkillComponent.SetExploreTool(1001);
 
         _ = ComponentSystem.Create<EntityEquipComponent>();
         _ = ComponentSystem.Create<EntityAttributeComponent>();
+
+        // TODO: temporary solution to enable glider and wall run, should implement proper buff management.
+        EntityFightBuffComponent fightBuffComponent = ComponentSystem.Get<EntityFightBuffComponent>();
+        fightBuffComponent.BuffInfoList.Add(new FightBuffInformation
+        {
+            BuffId = 3004,
+            EntityId = Id,
+            InstigatorId = Id,
+            IsActive = true,
+            Duration = -1,
+            LeftDuration = -1,
+            Level = 1,
+            StackCount = 1
+        });
+
+        fightBuffComponent.BuffInfoList.Add(new FightBuffInformation
+        {
+            BuffId = 3003,
+            EntityId = Id,
+            InstigatorId = Id,
+            IsActive = true,
+            Duration = -1,
+            LeftDuration = -1,
+            Level = 1,
+            StackCount = 1
+        });
     }
 
     public override void Activate()
@@ -56,7 +79,7 @@ internal class PlayerEntity : EntityBase
     public override EEntityType Type => EEntityType.Player;
     public override EntityConfigType ConfigType => EntityConfigType.Character;
 
-    public override bool IsVisible => IsCurrentRole;
+    public override bool IsVisible => IsCurrentRole || IsConcomitant;
 
     public override EntityPb Pb
     {

GameServer/Systems/Event/GameEventType.cs

@@ -3,8 +3,14 @@ internal enum GameEventType
 {
     Login = 1,
     EnterGame,
+    PushDataDone,
 
     // Actions
+    PlayerPositionChanged,
     FormationUpdated,
-    VisionSkillChanged
+    VisionSkillChanged,
+
+    // Debug
+    DebugUnlockAllRoles,
+    DebugUnlockAllItems
 }

GameServer/Systems/Notify/IGameActionListener.cs

@@ -0,0 +1,14 @@
+using GameServer.Systems.Entity;
+using Protocol;
+
+namespace GameServer.Systems.Notify;
+internal interface IGameActionListener
+{
+    Task OnJoinedScene(SceneInformation sceneInformation, TransitionType transitionType);
+    Task OnEntitiesAdded(IEnumerable<EntityBase> entities);
+    Task OnEntitiesRemoved(IEnumerable<EntityBase> entities);
+    Task OnPlayerFightRoleInfoUpdated(int playerId, IEnumerable<FightRoleInformation> fightRoles);
+    Task OnRolePropertiesUpdated(int roleId, IEnumerable<ArrayIntInt> baseProp, IEnumerable<ArrayIntInt> addProp);
+    Task OnEntityEquipmentChanged(long entityId, EquipComponentPb componentPb);
+    Task OnEntityAttributesChanged(long entityId, IEnumerable<GameplayAttributeData> attributes);
+}

GameServer/Systems/Notify/NotifySystem.cs

@@ -0,0 +1,97 @@
+using GameServer.Models;
+using GameServer.Network;
+using GameServer.Systems.Entity;
+using Protocol;
+
+namespace GameServer.Systems.Notify;
+internal class NotifySystem : IGameActionListener
+{
+    private readonly PlayerSession _session;
+    private readonly ModelManager _modelManager;
+
+    public NotifySystem(PlayerSession session, ModelManager modelManager)
+    {
+        _session = session;
+        _modelManager = modelManager;
+    }
+
+    public Task OnJoinedScene(SceneInformation sceneInformation, TransitionType transitionType)
+    {
+        return _session.Push(MessageId.JoinSceneNotify, new JoinSceneNotify
+        {
+            SceneInfo = sceneInformation,
+            TransitionOption = new TransitionOptionPb
+            {
+                TransitionType = (int)transitionType
+            }
+        });
+    }
+
+    public Task OnEntitiesAdded(IEnumerable<EntityBase> entities)
+    {
+        if (_modelManager.Creature.LoadingWorld) return Task.CompletedTask;
+
+        return _session.Push(MessageId.EntityAddNotify, new EntityAddNotify
+        {
+            IsAdd = true,
+            EntityPbs = { entities.Select(e => e.Pb) }
+        });
+    }
+
+    public Task OnEntitiesRemoved(IEnumerable<EntityBase> entities)
+    {
+        if (_modelManager.Creature.LoadingWorld) return Task.CompletedTask;
+
+        return _session.Push(MessageId.EntityRemoveNotify, new EntityRemoveNotify
+        {
+            IsRemove = true,
+            RemoveInfos =
+            {
+                entities.Select(e => new EntityRemoveInfo
+                {
+                    EntityId = e.Id,
+                    Type = (int)ERemoveEntityType.RemoveTypeNormal
+                })
+            }
+        });
+    }
+
+    public Task OnPlayerFightRoleInfoUpdated(int playerId, IEnumerable<FightRoleInformation> fightRoles)
+    {
+        return _session.Push(MessageId.UpdatePlayerAllFightRoleNotify, new UpdatePlayerAllFightRoleNotify
+        {
+            PlayerId = playerId,
+            FightRoleInfos = { fightRoles }
+        });
+    }
+
+    public Task OnRolePropertiesUpdated(int roleId, IEnumerable<ArrayIntInt> baseProp, IEnumerable<ArrayIntInt> addProp)
+    {
+        if (_modelManager.Creature.LoadingWorld) return Task.CompletedTask;
+
+        return _session.Push(MessageId.PbRolePropsNotify, new PbRolePropsNotify
+        {
+            RoleId = roleId,
+            BaseProp = { baseProp },
+            AddProp = { addProp }
+        });
+    }
+
+    public Task OnEntityEquipmentChanged(long entityId, EquipComponentPb componentPb)
+    {
+        return _session.Push(MessageId.EntityEquipChangeNotify, new EntityEquipChangeNotify
+        {
+            EntityId = entityId,
+            EquipComponent = componentPb
+        });
+    }
+
+    public Task OnEntityAttributesChanged(long entityId, IEnumerable<GameplayAttributeData> attributes)
+    {
+        return _session.Push(MessageId.AttributeChangedNotify, new AttributeChangedNotify
+        {
+            Id = entityId,
+            Attributes = { attributes }
+        });
+    }
+}

GameServer/gameplay.json

@@ -1,14 +1,18 @@
 {
   "StartingValues": {
     "Name": "ReversedRooms",
-    "Characters": [ 1601, 1302, 1203 ],
+    "PlayerLevel": 8,
+    "HeadPhoto": 1402,
+    "HeadFrame": 80060009,
+    "Characters": [ 1402, 1302, 1203 ],
     "Position": {
-      "X": -84500,
-      "Y": 164500,
-      "Z": 2000
+      "X": -45000,
+      "Y": 67800,
+      "Z": 2600
     }
   },
   "Features": {
-    "TeleportByMapMark": true
+    "TeleportByMapMark": true,
+    "UnlimitedEnergy": false
   }
 }

Protocol/MessageId.cs

@@ -795,6 +795,8 @@ public enum MessageId
     NewBieCourseRewardResponse = 12153,
     NewJourneyRequest = 12214,
     NewJourneyResponse = 12215,
+    ClientCurrentRoleReportRequest = 12217,
+    ClientCurrentRoleReportResponse = 12218,
     NormalItemAddNotify = 5268,
     NormalItemRemoveNotify = 5269,
     NormalItemRequest = 5265,

Protocol/message.proto

@@ -1573,6 +1573,17 @@ message ClientBasicInfoRequest { // MessageId: 5165
 message ClientBasicInfoResponse { // MessageId: 3017
 }
 
+message ClientCurrentRoleReportRequest { // MessageId: 12217
+  int32 player_id = 1;
+  int32 current_role_id = 2;
+  int64 current_entity_id = 3;
+}
+
+message ClientCurrentRoleReportResponse { // MessageId: 12218
+  int32 player_id = 1;
+  int64 current_entity_id = 2;
+}
+
 message ClientDataComponentPb {
   bool is_static_init = 1;
   int64 owner_id = 2;
@@ -2633,6 +2644,7 @@ message EntityActiveRequest { // MessageId: 1541
 message EntityActiveResponse { // MessageId: 1542
   int32 error_code = 1;
   repeated EntityComponentPb component_pbs = 2;
+  bool is_visible = 3;
 }
 
 message EntityAddBubbleNotify { // MessageId: 12203
@@ -7900,6 +7912,7 @@ message SeasonData {
   int64 end_time = 3;
   repeated RoguelikeToken roguelike_token_list = 4;
   repeated SeasonReward season_reward_list = 5;
+  int32 token_item_count = 6;
 }
 
 message SeasonReward {
@@ -10931,6 +10944,7 @@ enum ErrorCode {
   ERROR_CODE_ERR_ENTITY_PATROL_COMPONENT_NOT_EXIST = 600088;
   ERROR_CODE_ERR_INTERACT_IS_NOT_PARTICIPANT = 600089;
   ERROR_CODE_ERR_VISION_ENTITY_INTERACT_FAIL = 600090;
+  ERROR_CODE_ERR_MAX_DROP_TIMES = 600091;
   ERROR_CODE_ERR_SCENE_WORLD_NOT_EXIST = 700000;
   ERROR_CODE_ERR_PLAYER_NOT_IN_SCENE = 700001;
   ERROR_CODE_ERR_DROP_ENTITY_NOT_EXIST = 700002;
@@ -11297,6 +11311,7 @@ enum ErrorCode {
   ERROR_CODE_ERR_ITEM_POS_INVAILD = 900058;
   ERROR_CODE_ERR_ITEM_ID_INVAILD = 900059;
   ERROR_CODE_ERR_ROULETTE_FUNC_ID_INVAILD = 900060;
+  ERROR_CODE_ERR_STATE_IS_RUNNING = 900061;
   ERROR_CODE_ERR_BUFF_ITEM_CONFIG = 1000000;
   ERROR_CODE_ERR_BUFF_ITEM_NOT_SHARE = 1000001;
   ERROR_CODE_ERR_BUFF_ITEM_SHARE_ROLE_ID = 1000002;
@@ -11755,6 +11770,9 @@ enum ErrorCode {
   ERROR_CODE_ERR_EXPLORE_SKILL_PULL_GIANT_NOT_EXIST = 1800027;
   ERROR_CODE_ERR_HTTP_RPC_PARAM = 1800028;
   ERROR_CODE_ERR_PLAYER_NOT_IN_GAME_NODE = 1800029;
+  ERROR_CODE_ERR_APPLY_JOIN_PLAYER_CUR_ROLE_IS_DEAD = 1800030;
+  ERROR_CODE_ERR_PLAYER_CUR_ROLE_IS_DEAD_NO_JOIN = 1800031;
+  ERROR_CODE_ERR_PLAYER_CUR_ROLE_IS_DEAD = 1800032;
   ERROR_CODE_ERR_CALABASH_LEVEL_REQUEST = 1900000;
   ERROR_CODE_ERR_CALABASH_LEVEL_REWARD_DONE = 1900001;
   ERROR_CODE_ERR_CALABASH_LEVEL_CONFIG = 1900002;
@@ -11793,6 +11811,7 @@ enum ErrorCode {
   ERROR_CODE_ERR_NEW_BIE_COURSE_CONFIG = 1900035;
   ERROR_CODE_ERR_NEW_BIE_COURSE_REWARD_HAD = 1900036;
   ERROR_CODE_ERR_NEW_BIE_COURSE_LEVEL = 1900037;
+  ERROR_CODE_ERR_DETECTION_TARGET_SILENCE = 1900038;
   ERROR_CODE_ERR_DO_COMMON_REWARD_CONFIG_ERROR = 2000000;
   ERROR_CODE_INST_PLAY_NOT_SETTLE = 2000001;
   ERROR_CODE_INST_PLAY_NOT_FINISH_EXECUTE = 2000002;
@@ -12290,6 +12309,7 @@ enum WorldTeamLeaveReason {
   WORLD_TEAM_LEAVE_REASON_BE_KICK = 1;
   WORLD_TEAM_LEAVE_REASON_DISSOLVE = 2;
   WORLD_TEAM_LEAVE_REASON_LOGOUT = 3;
+  WORLD_TEAM_LEAVE_REASON_TO_OWN_BIG_WORLD = 4;
 }
 
 enum WorldTeamPlayerChangeType {

README.md

@@ -1,12 +1,13 @@
 # WutheringWaves
 
-Wuthering Waves server emulator (0.8.2)
+Wuthering Waves server emulator (0.9.0)
 
 ## How to run
 - Compile and run SDKServer and GameServer using dotnet8 (Visual Studio 2022 recommended)
 
 ## Connecting
-- Download [Game Client](https://nogatekeep.ing/assets/ww/0.8.2/ww.7z), it's **pre-patched** and redirects http requests to `127.0.0.1:5500`
+- Get game client from somewhere. For example using official launcher (you can find it in our discord)
+- [Download and extract patch](https://nogatekeep.ing/assets/ww/0.9.0/WuWa-0.9-patch.zip) to the game folder, it will redirect all http requests to `127.0.0.1:5500`
 - Run game and connect to the server
 
 ## Need help?

SDKServer/Program.cs

@@ -1,4 +1,3 @@
-using Microsoft.AspNetCore.Builder;
 using SDKServer.Handlers;
 using SDKServer.Middleware;
 
@@ -8,11 +7,14 @@ internal static class Program
 {
     private static async Task Main(string[] args)
     {
-        var builder = WebApplication.CreateBuilder(args);
+        Console.Title = "Wuthering Waves | SDK Server";
+        Console.WriteLine(" __      __        __  .__                 .__                  __      __                            \r\n/  \\    /  \\__ ___/  |_|  |__   ___________|__| ____    ____   /  \\    /  \\_____ ___  __ ____   ______\r\n\\   \\/\\/   /  |  \\   __\\  |  \\_/ __ \\_  __ \\  |/    \\  / ___\\  \\   \\/\\/   /\\__  \\\\  \\/ // __ \\ /  ___/\r\n \\        /|  |  /|  | |   Y  \\  ___/|  | \\/  |   |  \\/ /_/  >  \\        /  / __ \\\\   /\\  ___/ \\___ \\ \r\n  \\__/\\  / |____/ |__| |___|  /\\___  >__|  |__|___|  /\\___  /    \\__/\\  /  (____  /\\_/  \\___  >____  >\r\n       \\/                   \\/     \\/              \\//_____/          \\/        \\/          \\/     \\/ \r\n\r\n\t\t\t\t\t\t\t\t\t\t\t\tSDK Server\n");
+
+        WebApplicationBuilder builder = WebApplication.CreateBuilder(args);
         builder.WebHost.UseUrls("http://*:5500");
         builder.Logging.AddSimpleConsole();
 
-        var app = builder.Build();
+        WebApplication app = builder.Build();
         app.UseMiddleware<NotFoundMiddleware>();
 
         app.MapGet("/api/login", LoginHandler.Login);

TrafficAnalyzer/Program.cs

@@ -0,0 +1,52 @@
+using Google.Protobuf;
+using Protocol;
+
+namespace TrafficAnalyzer;
+
+internal static class Program
+{
+    private const int StdInSize = 65535;
+    private const string ProtoAssembly = "Protocol";
+    private const string ProtoNamespace = "Protocol";
+    private const string MessageParserProperty = "Parser";
+
+    private static readonly DumpOptions s_objectDumperOpts = new() { DumpStyle = DumpStyle.CSharp, IndentSize = 4, IndentChar = ' ', IgnoreDefaultValues = true };
+
+    private static void Main(string[] args)
+    {
+        Console.SetIn(new StreamReader(Console.OpenStandardInput(StdInSize), Console.InputEncoding, false, StdInSize));
+
+        List<Tuple<int, byte[]>> inList = [];
+
+        string? idInput;
+        string? payloadInput;
+
+        while (!string.IsNullOrEmpty(idInput = Console.ReadLine()) && (payloadInput = Console.ReadLine()) != null)
+        {
+            int messageId = int.Parse(idInput);
+            byte[] payload = Convert.FromHexString(payloadInput);
+
+            inList.Add(Tuple.Create(messageId, payload));
+        }
+
+        foreach ((int messageId, byte[] payload) in inList)
+        {
+            string messageName = ((MessageId)messageId).ToString();
+
+            Type? type = Type.GetType($"{ProtoNamespace}.{messageName},{ProtoAssembly}");
+            if (type is null)
+            {
+                Console.WriteLine($"Message with id {messageName} wasn't found in proto definition.");
+                continue;
+            }
+
+            MessageParser parser = (MessageParser)type.GetProperty(MessageParserProperty)!.GetValue(null)!;
+            IMessage message = parser.ParseFrom(payload);
+
+            string outputInitializer = ObjectDumper.Dump(message, s_objectDumperOpts);
+
+            Console.WriteLine($"Message: {messageName}");
+            Console.WriteLine(outputInitializer);
+        }
+    }
+}

TrafficAnalyzer/TrafficAnalyzer.csproj

@@ -0,0 +1,18 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <OutputType>Exe</OutputType>
+    <TargetFramework>net8.0</TargetFramework>
+    <ImplicitUsings>enable</ImplicitUsings>
+    <Nullable>enable</Nullable>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <PackageReference Include="ObjectDumper.NET" Version="4.1.15" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\Protocol\Protocol.csproj" />
+  </ItemGroup>
+
+</Project>

WutheringWaves.sln

@@ -16,7 +16,9 @@ Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "KcpSharp", "KcpSharp\KcpSha
 EndProject
 Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Protocol", "Protocol\Protocol.csproj", "{9900A88C-7818-4335-84F7-1538ECC8B338}"
 EndProject
-Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Core", "Core\Core.csproj", "{C025BDED-6DC7-493D-8D10-05DCCB3072F3}"
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Core", "Core\Core.csproj", "{C025BDED-6DC7-493D-8D10-05DCCB3072F3}"
+EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "TrafficAnalyzer", "TrafficAnalyzer\TrafficAnalyzer.csproj", "{7DA57BA1-215F-4DD8-86A9-CAC62908A6F3}"
 EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
@@ -44,6 +46,10 @@ Global
 		{C025BDED-6DC7-493D-8D10-05DCCB3072F3}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{C025BDED-6DC7-493D-8D10-05DCCB3072F3}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{C025BDED-6DC7-493D-8D10-05DCCB3072F3}.Release|Any CPU.Build.0 = Release|Any CPU
+		{7DA57BA1-215F-4DD8-86A9-CAC62908A6F3}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{7DA57BA1-215F-4DD8-86A9-CAC62908A6F3}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{7DA57BA1-215F-4DD8-86A9-CAC62908A6F3}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{7DA57BA1-215F-4DD8-86A9-CAC62908A6F3}.Release|Any CPU.Build.0 = Release|Any CPU
 	EndGlobalSection
 	GlobalSection(SolutionProperties) = preSolution
 		HideSolutionNode = FALSE