using GameFrameX.NetWork.HTTP;

[HttpMessageMapping(typeof(TestHttpHandler))]
[HttpMessageResponse(typeof(HttpTestResponse))]
[Description("Hello World 示例接口")]
public sealed class TestHttpHandler : BaseHttpHandler
{
    public override Task<string> Action(string ip, string url, Dictionary<string, object> parameters)
    {
        var response = new HttpTestResponse
        {
            Message = "Hello World From GameFrameX",
            Time = DateTime.Now
        };
        // 返回标准 JSON 格式
        return Task.FromResult(HttpJsonResult.SuccessString(response));
    }
}

public sealed class HttpTestResponse : HttpMessageResponseBase
{
    public string Message { get; set; }
    public DateTime Time { get; set; }
}

public class BagState : CacheState
{
    public List<ItemData> Items { get; set; } = new();
    public int MaxSlots { get; set; } = 50;
}

public class BagComponent : StateComponent<BagState>
{
    // 组件初始化逻辑
    protected override async Task OnInit()
    {
        await base.OnInit();
        // 初始化组件状态
    }
}

public class BagComponentAgent : StateComponentAgent<BagComponent, BagState>
{
    public async Task<bool> AddItem(int itemId, int count)
    {
        if (State.Items.Count >= State.MaxSlots)
            return false;

        var item = new ItemData { Id = itemId, Count = count };
        State.Items.Add(item);

        await Save();
        return true;
    }
}

[HttpMessageMapping(typeof(GetPlayerInventoryHttpHandler))]
[Description("获取玩家背包物品")]
public sealed class GetPlayerInventoryHttpHandler : BaseHttpHandler
{
    public override async Task<MessageObject> Action(string ip, string url, Dictionary<string, object> parameters, MessageObject messageObject)
    {
        var request = (GetPlayerInventoryRequest)messageObject;
        var response = new GetPlayerInventoryResponse();

        // 从参数中获取玩家ID
        if (!parameters.TryGetValue("playerId", out var playerIdObj))
        {
            response.ErrorCode = (int)ResultCode.InvalidParameter;
            return response;
        }

        var playerId = Convert.ToInt64(playerIdObj);
        var bagAgent = await ActorManager.GetComponentAgent<BagComponentAgent>(playerId);

        if (bagAgent == null)
        {
            response.ErrorCode = (int)ResultCode.PlayerNotFound;
            return response;
        }

        var items = await bagAgent.GetItems();
        response.Items = items;
        return response;
    }
}

[MessageMapping(typeof(ReqAddItem))]
internal sealed class AddItemHandler : PlayerRpcComponentHandler<BagComponentAgent, ReqAddItem, RespAddItem>
{
    protected override async Task ActionAsync(ReqAddItem request, RespAddItem response)
    {
        try
        {
            // ComponentAgent 由基类自动注入,无需手动获取
            await ComponentAgent.AddItem(request, response);
        }
        catch (Exception e)
        {
            LogHelper.Fatal(e);
            response.ErrorCode = (int)OperationStatusCode.InternalServerError;
        }
    }
}

[Event(EventId.PlayerLogin)]
internal sealed class PlayerLoginEventHandler : EventListener<PlayerComponentAgent>
{
    protected override Task HandleEvent(PlayerComponentAgent agent, GameEventArgs gameEventArgs)
    {
        if (agent == null)
        {
            LogHelper.Error("代理对象为空");
            return Task.CompletedTask;
        }

        // 处理登录事件逻辑
        return agent.OnLogin();
    }
}