using Cysharp.Threading.Tasks;
using System;
using UnityEngine;

/// <summary>
/// ClientSocket 适配器 - 将 ClientSocket 适配为 INetworkService 接口
/// （不修改已验证的 ClientSocket 代码）
/// </summary>
public class ClientSocketAdapter : INetworkService
{
    private ClientSocket clientSocket;
    private NetworkState _state = NetworkState.Disconnected;
    
    public NetworkState State
    {
        get => _state;
        private set
        {
            if (_state != value)
            {
                _state = value;
                OnStateChanged?.Invoke(value);
            }
        }
    }
    
    /// <summary>
    /// 是否已连接（适配 ClientSocket.connected）
    /// </summary>
    public bool IsConnected => clientSocket != null && clientSocket.connected;
    
    /// <summary>
    /// 最后收包时间（适配 ClientSocket.lastPackageTime）
    /// </summary>
    public DateTime LastPackageTime => clientSocket?.lastPackageTime ?? DateTime.MinValue;
    
    public event Action<NetworkState> OnStateChanged;
    
    /// <summary>
    /// 构造函数
    /// </summary>
    public ClientSocketAdapter(ServerType type)
    {
        clientSocket = new ClientSocket(type);
        Debug.Log($"[ClientSocketAdapter] 初始化 TCP Socket（{type}）");
    }
    
    /// <summary>
    /// 连接到 TCP 服务器（适配 ClientSocket.Connect）
    /// </summary>
    public async UniTask<bool> ConnectAsync(string url)
    {
        try
        {
            State = NetworkState.Connecting;
            
            // 解析 URL（支持 "ip:port" 或 "tcp://ip:port"）
            string ip;
            int port;
            ParseUrl(url, out ip, out port);
            
            Debug.Log($"[ClientSocketAdapter] 连接 {ip}:{port}");
            
            // 使用 UniTask 包装回调
            var tcs = new UniTaskCompletionSource<bool>();
            
            clientSocket.Connect(ip, port, (success) =>
            {
                if (success)
                {
                    State = NetworkState.Connected;
                    Debug.Log("[ClientSocketAdapter] 连接成功");
                }
                else
                {
                    State = NetworkState.Disconnected;
                    Debug.LogError("[ClientSocketAdapter] 连接失败");
                }
                
                tcs.TrySetResult(success);
            });
            
            return await tcs.Task;
        }
        catch (Exception ex)
        {
            Debug.LogError($"[ClientSocketAdapter] 连接异常: {ex.Message}");
            State = NetworkState.Disconnected;
            return false;
        }
    }
    
    /// <summary>
    /// 断开连接（异步）
    /// </summary>
    public async UniTask DisconnectAsync()
    {
        if (clientSocket != null)
        {
            clientSocket.CloseConnect();
            State = NetworkState.Disconnected;
        }
        await UniTask.CompletedTask;
    }
    
    /// <summary>
    /// 断开连接（同步，适配 ClientSocket.CloseConnect）
    /// </summary>
    public void Disconnect()
    {
        if (clientSocket != null)
        {
            clientSocket.CloseConnect();
            State = NetworkState.Disconnected;
        }
    }
    
    /// <summary>
    /// 发送协议包（适配 ClientSocket.SendInfo）
    /// </summary>
    public void SendInfo(GameNetPackBasic protocol)
    {
        if (!IsConnected)
        {
            Debug.LogError("[ClientSocketAdapter] 未连接，无法发送协议包");
            return;
        }
        
        clientSocket.SendInfo(protocol);
    }
    
    /// <summary>
    /// 发送二进制数据（适配 ClientSocket.SendInfo）
    /// </summary>
    public void SendInfo(byte[] data)
    {
        if (!IsConnected)
        {
            Debug.LogError("[ClientSocketAdapter] 未连接，无法发送数据");
            return;
        }
        
        clientSocket.SendInfo(data);
    }
    
    /// <summary>
    /// 发送二进制数据（异步）
    /// </summary>
    public async UniTask SendAsync(byte[] data)
    {
        SendInfo(data);
        await UniTask.CompletedTask;
    }
    
    /// <summary>
    /// 获取内部的 ClientSocket（兼容性访问）
    /// </summary>
    public ClientSocket GetClientSocket()
    {
        return clientSocket;
    }
    
    /// <summary>
    /// 解析 URL
    /// </summary>
    private void ParseUrl(string url, out string ip, out int port)
    {
        // 默认端口
        port = 8080;
        
        // 移除协议前缀
        if (url.StartsWith("tcp://"))
        {
            url = url.Substring(6);
        }
        
        // 分割 IP 和端口
        var parts = url.Split(':');
        ip = parts[0];
        
        if (parts.Length > 1 && int.TryParse(parts[1], out int parsedPort))
        {
            port = parsedPort;
        }
    }
}