using DeviceService.Service;
using DeviceService.Service.NamePipe;
using System.Collections.ObjectModel;
using System.IO.Pipes;
using System.Text;
using System.Windows;
using System.Windows.Input;

namespace DeviceService;

/// <summary>
/// Interaction logic for DebugWindow.xaml
/// </summary>
public partial class DebugWindow : Window
{
    private const string PipeName = "DeviceService";

    private class ClientItem
    {
        public ClientItem(IClient client, string name)
        {
            Client = client;
            Name = name;
        }

        public IClient Client { get; }

        public string Name { get; }

        public override string ToString() => Name;
    }

    private NamePipeService? _pipeService;
    private readonly ObservableCollection<ClientItem> _clients = new ObservableCollection<ClientItem>();

    public DebugWindow()
    {
        InitializeComponent();
        ClientList.ItemsSource = _clients;
        Loaded += DebugWindow_Loaded;
        Closed += DebugWindow_Closed;
    }

    private void DebugWindow_Loaded(object sender, RoutedEventArgs e)
    {
    }

    

    private string FindClientName(IClient client)
    {
        ClientItem? item = _clients.FirstOrDefault(c => ReferenceEquals(c.Client, client));
        return item?.Name ?? "未知客户端";
    }

    private async void SendTestButton_Click(object sender, RoutedEventArgs e)
    {
        string text = SendBox.Text;
        if (string.IsNullOrEmpty(text))
        {
            return;
        }

        SendTestButton.IsEnabled = false;
        try
        {
            string error = await Task.Run(() => SendViaPipe(text + "\r\n"));
            AppendLine(string.IsNullOrEmpty(error)
                ? $"[测试] 已发送：{text}"
                : $"[测试] 发送失败：{error}");
        }
        finally
        {
            SendTestButton.IsEnabled = true;
        }
    }

    private async void SendToClientButton_Click(object sender, RoutedEventArgs e)
    {
        if (ClientList.SelectedItem is not ClientItem item)
        {
            AppendLine("[发送] 请先在左侧列表中选择一个客户端。");
            return;
        }

        string text = SendBox.Text;
        if (string.IsNullOrEmpty(text))
        {
            return;
        }

        string name = item.Name;
        IClient client = item.Client;

        SendToClientButton.IsEnabled = false;
        try
        {
            string error = await Task.Run(() => client.Send(text, out string err) ? string.Empty : err);
            AppendLine(string.IsNullOrEmpty(error)
                ? $"[发送→{name}] {text}"
                : $"[发送失败→{name}] {error}");
        }
        finally
        {
            SendToClientButton.IsEnabled = true;
        }
    }

    private void SendBox_KeyDown(object sender, KeyEventArgs e)
    {
        if (e.Key == Key.Enter)
        {
            // 已选中客户端则定向发送，否则走测试通道
            if (ClientList.SelectedItem is ClientItem)
            {
                SendToClientButton_Click(sender, e);
            }
            else
            {
                SendTestButton_Click(sender, e);
            }
        }
    }

    /// <summary>
    /// 以客户端身份连接本进程的管道，按行协议写入一条 UTF8 消息（以 \n 结尾）。
    /// 返回空字符串表示成功，否则为错误信息。
    /// </summary>
    private static string SendViaPipe(string text)
    {
        try
        {
            using var pipe = new NamedPipeClientStream(".", PipeName, PipeDirection.InOut);
            pipe.Connect(2000);

            byte[] payload = Encoding.UTF8.GetBytes(text + "\n");
            pipe.Write(payload, 0, payload.Length);
            pipe.Flush();
            return string.Empty;
        }
        catch (Exception ex)
        {
            return ex.Message;
        }
    }

    private void AppendLine(string text)
    {
        ReceiveBox.AppendText(text + Environment.NewLine);
        ReceiveBox.ScrollToEnd();
    }

    private void DebugWindow_Closed(object? sender, EventArgs e)
    {
    }
}