feat(bot): 添加好友场景测试流程

- Bot 客户端支持 friend 场景，自动执行加好友、列表、删好友流程
- BotRunOptions 新增 Scenario 参数，支持逗号分隔多场景
- 添加在线玩家注册表用于好友配对
- 预热好友相关 Proto 序列化类型

Author: AlianBlank

GameFrameX.Client/Bot/BotClient.cs

@@ -30,6 +30,7 @@
 using GameFrameX.NetWork.Messages;
 using GameFrameX.Proto.Proto;
 using GameFrameX.Foundation.Logger;
+using System.Collections.Concurrent;
 using ErrorEventArgs = GameFrameX.SuperSocket.ClientEngine.ErrorEventArgs;
 
 namespace GameFrameX.Client.Bot;
@@ -39,17 +40,34 @@ namespace GameFrameX.Client.Bot;
 /// </summary>
 public sealed class BotClient
 {
+    private static readonly ConcurrentDictionary<string, long> OnlinePlayerIds = new(StringComparer.Ordinal);
+
+    private enum FriendScenarioStage
+    {
+        None = 0,
+        WaitAdd = 1,
+        WaitListAfterAdd = 2,
+        WaitDelete = 3,
+        WaitListAfterDelete = 4,
+        Completed = 5,
+    }
+
     private readonly BotTcpClient m_TcpClient;
     private readonly string m_BotName;
     private readonly BotTcpClientEvent m_BotTcpClientEvent;
     private readonly BotRunOptions _options;
     private int _disconnectScheduled;
     private long _accountId;
+    private long _playerId;
+    private long _friendTargetPlayerId;
+    private int _friendTargetResolveAttempts;
+    private FriendScenarioStage _friendScenarioStage;
 
     /// <summary>
     /// 初始化机器人客户端
     /// </summary>
     /// <param name="botName">机器人名称</param>
+    /// <param name="options">运行参数</param>
     public BotClient(string botName, BotRunOptions options)
     {
         m_BotName = botName;
@@ -97,6 +115,15 @@ private void OnReceiveMsg(MessageObject messageObject)
             case RespPlayerLogin msg:
                 OnPlayerLoginSuccess(msg);
                 break;
+            case RespFriendByAdd msg:
+                OnFriendAddSuccess(msg);
+                break;
+            case RespDeleteFriend msg:
+                OnDeleteFriendSuccess(msg);
+                break;
+            case RespFriendList msg:
+                OnFriendListSuccess(msg);
+                break;
         }
     }
 
@@ -115,6 +142,10 @@ private void ClientConnectedCallback()
     /// </summary>
     private void ClientClosedCallback()
     {
+        if (!string.IsNullOrWhiteSpace(m_BotName))
+        {
+            OnlinePlayerIds.TryRemove(m_BotName, out _);
+        }
     }
 
     /// <summary>
@@ -220,10 +251,135 @@ private void OnPlayerCreateSuccess(RespPlayerCreate msg)
     /// <param name="msg">登录成功的响应消息</param>
     private void OnPlayerLoginSuccess(RespPlayerLogin msg)
     {
-        LogHelper.Info($"机器人-{m_BotName}登录成功,id:{msg.PlayerInfo.Id}");
+        _playerId = msg.PlayerInfo.Id;
+        OnlinePlayerIds[m_BotName] = _playerId;
+        LogHelper.Info($"机器人-{m_BotName}登录成功,id:{_playerId}");
+        if (_options.HasScenario("friend"))
+        {
+            StartFriendScenario();
+            return;
+        }
+
         ScheduleDisconnectIfNeeded();
     }
 
+    private void StartFriendScenario()
+    {
+        if (_playerId <= 0)
+        {
+            LogHelper.Error($"机器人-{m_BotName}好友场景启动失败，玩家ID非法:{_playerId}");
+            ScheduleDisconnectIfNeeded();
+            return;
+        }
+
+        if (!TryResolveFriendTargetPlayerId())
+        {
+            _friendTargetResolveAttempts++;
+            if (_friendTargetResolveAttempts > 5)
+            {
+                LogHelper.Error($"机器人-{m_BotName}好友场景启动失败，未找到可用好友目标。");
+                ScheduleDisconnectIfNeeded();
+                return;
+            }
+
+            _ = Task.Run(async () =>
+            {
+                await Task.Delay(1000);
+                StartFriendScenario();
+            });
+            return;
+        }
+
+        _friendScenarioStage = FriendScenarioStage.WaitAdd;
+        LogHelper.Info($"机器人-{m_BotName}开始执行好友场景，目标玩家:{_friendTargetPlayerId}");
+        m_TcpClient.SendToServer(new ReqFriendByAdd { PlayerId = _friendTargetPlayerId });
+    }
+
+    private void OnFriendAddSuccess(RespFriendByAdd msg)
+    {
+        if (_friendScenarioStage != FriendScenarioStage.WaitAdd)
+        {
+            return;
+        }
+
+        if (!msg.Success || msg.ErrorCode != 0)
+        {
+            LogHelper.Error($"机器人-{m_BotName}好友场景-加好友失败，Success:{msg.Success}, ErrorCode:{msg.ErrorCode}");
+            ScheduleDisconnectIfNeeded();
+            return;
+        }
+
+        _friendScenarioStage = FriendScenarioStage.WaitListAfterAdd;
+        LogHelper.Info($"机器人-{m_BotName}好友场景-加好友成功，开始拉取好友列表。");
+        m_TcpClient.SendToServer(new ReqFriendList());
+    }
+
+    private void OnDeleteFriendSuccess(RespDeleteFriend msg)
+    {
+        if (_friendScenarioStage != FriendScenarioStage.WaitDelete)
+        {
+            return;
+        }
+
+        if (!msg.Success || msg.ErrorCode != 0)
+        {
+            LogHelper.Error($"机器人-{m_BotName}好友场景-删好友失败，Success:{msg.Success}, ErrorCode:{msg.ErrorCode}");
+            ScheduleDisconnectIfNeeded();
+            return;
+        }
+
+        _friendScenarioStage = FriendScenarioStage.WaitListAfterDelete;
+        LogHelper.Info($"机器人-{m_BotName}好友场景-删好友成功，开始二次拉取好友列表。");
+        m_TcpClient.SendToServer(new ReqFriendList());
+    }
+
+    private void OnFriendListSuccess(RespFriendList msg)
+    {
+        if (_friendScenarioStage != FriendScenarioStage.WaitListAfterAdd
+            && _friendScenarioStage != FriendScenarioStage.WaitListAfterDelete)
+        {
+            return;
+        }
+
+        if (msg.ErrorCode != 0)
+        {
+            LogHelper.Error($"机器人-{m_BotName}好友场景-拉取列表失败，ErrorCode:{msg.ErrorCode}");
+            ScheduleDisconnectIfNeeded();
+            return;
+        }
+
+        if (_friendScenarioStage == FriendScenarioStage.WaitListAfterAdd)
+        {
+            _friendScenarioStage = FriendScenarioStage.WaitDelete;
+            LogHelper.Info($"机器人-{m_BotName}好友场景-首次列表成功，数量:{msg.Friends?.Count ?? 0}，开始删好友。");
+            m_TcpClient.SendToServer(new ReqDeleteFriend { PlayerId = _friendTargetPlayerId });
+            return;
+        }
+
+        _friendScenarioStage = FriendScenarioStage.Completed;
+        LogHelper.Info($"机器人-{m_BotName}好友场景执行完成，二次列表数量:{msg.Friends?.Count ?? 0}。");
+        ScheduleDisconnectIfNeeded();
+    }
+
+    private bool TryResolveFriendTargetPlayerId()
+    {
+        foreach (var entry in OnlinePlayerIds)
+        {
+            if (entry.Key == m_BotName)
+            {
+                continue;
+            }
+
+            if (entry.Value > 0 && entry.Value != _playerId)
+            {
+                _friendTargetPlayerId = entry.Value;
+                return true;
+            }
+        }
+
+        return false;
+    }
+
     private void ScheduleDisconnectIfNeeded()
     {
         if (!_options.EnableDisconnectLoop || _options.DisconnectAfterLoginSeconds <= 0)

GameFrameX.Client/Bot/BotRunOptions.cs

@@ -14,6 +14,7 @@ public sealed class BotRunOptions
     public bool EnableDisconnectLoop { get; init; } = true;
     public int DisconnectAfterLoginSeconds { get; init; } = 15;
     public int RunSeconds { get; init; } = 0;
+    public string Scenario { get; init; } = "login";
 
     public static BotRunOptions Parse(string[] args)
     {
@@ -51,9 +52,29 @@ public static BotRunOptions Parse(string[] args)
             EnableDisconnectLoop = ReadBool(values, "disconnect-loop", true),
             DisconnectAfterLoginSeconds = ReadInt(values, "disconnect-after-login-seconds", 15),
             RunSeconds = ReadInt(values, "run-seconds", 0),
+            Scenario = ReadString(values, "scenario", "login"),
         };
     }
 
+    public bool HasScenario(string scenarioName)
+    {
+        if (string.IsNullOrWhiteSpace(Scenario) || string.IsNullOrWhiteSpace(scenarioName))
+        {
+            return false;
+        }
+
+        var parts = Scenario.Split(',', StringSplitOptions.RemoveEmptyEntries | StringSplitOptions.TrimEntries);
+        foreach (var part in parts)
+        {
+            if (string.Equals(part, scenarioName, StringComparison.OrdinalIgnoreCase))
+            {
+                return true;
+            }
+        }
+
+        return false;
+    }
+
     private static string ReadString(IDictionary<string, string> values, string key, string defaultValue)
     {
         return values.TryGetValue(key, out var value) ? value : defaultValue;

GameFrameX.Client/Program.cs

@@ -48,8 +48,8 @@ static async Task Main(string[] args)
         WarmUpProtoSerializer();
 
         LogHelper.Info(
-            "Bot options: bot-count={botCount}, tcp={tcpHost}:{tcpPort}, disconnect-loop={disconnectLoop}, disconnect-after-login-seconds={disconnectAfterLoginSeconds}, run-seconds={runSeconds}",
-            options.BotCount, options.TcpHost, options.TcpPort, options.EnableDisconnectLoop, options.DisconnectAfterLoginSeconds, options.RunSeconds);
+            "Bot options: bot-count={botCount}, tcp={tcpHost}:{tcpPort}, scenario={scenario}, disconnect-loop={disconnectLoop}, disconnect-after-login-seconds={disconnectAfterLoginSeconds}, run-seconds={runSeconds}",
+            options.BotCount, options.TcpHost, options.TcpPort, options.Scenario, options.EnableDisconnectLoop, options.DisconnectAfterLoginSeconds, options.RunSeconds);
 
         var cts = new CancellationTokenSource();
         var botTasks = new List<Task>(options.BotCount);
@@ -89,5 +89,11 @@ private static void WarmUpProtoSerializer()
         _ = ProtoBufSerializerHelper.Serialize(new RespPlayerList());
         _ = ProtoBufSerializerHelper.Serialize(new RespPlayerCreate());
         _ = ProtoBufSerializerHelper.Serialize(new RespPlayerLogin());
+        _ = ProtoBufSerializerHelper.Serialize(new ReqFriendByAdd());
+        _ = ProtoBufSerializerHelper.Serialize(new RespFriendByAdd());
+        _ = ProtoBufSerializerHelper.Serialize(new ReqDeleteFriend());
+        _ = ProtoBufSerializerHelper.Serialize(new RespDeleteFriend());
+        _ = ProtoBufSerializerHelper.Serialize(new ReqFriendList());
+        _ = ProtoBufSerializerHelper.Serialize(new RespFriendList());
     }
 }