using LiteNetLib;
using Serilog;

namespace ClientTester.DummyService;

public class DummyClientService
{
    private readonly List<DummyClients> clients;
    private readonly int sendInterval;

    // 모든거 강종
    public event Action? OnAllDisconnected;

    public DummyClientService(int count, string ip, int port, string key, int sendIntervalMs = 1000)
    {
        sendInterval = sendIntervalMs;
        clients = Enumerable.Range(1, count + 1).Select(i => new DummyClients(i, ip, port, key)).ToList();

        Log.Information("[SERVICE] {Count}개 클라이언트 생성 → {Ip}:{Port}", count, ip, port);
    }

    public async Task RunAsync(CancellationToken ct)
    {
        await Task.WhenAll(PollLoopAsync(ct), SendLoopAsync(ct));
    }

    private async Task PollLoopAsync(CancellationToken ct)
    {
        while (!ct.IsCancellationRequested)
        {
            foreach (DummyClients c in clients)
            {
                c.PollEvents();
            }

            try
            {
                await Task.Delay(10, ct);
            }
            catch (OperationCanceledException)
            {
                break;
            }
        }
    }

    private async Task SendLoopAsync(CancellationToken ct)
    {
        try
        {
            await Task.Delay(500, ct);
        }
        catch (OperationCanceledException)
        {
            return;
        }

        int tick = 0;

        while (!ct.IsCancellationRequested)
        {
            int sent = 0;
            int total = clients.Count;

            foreach (DummyClients client in clients)
            {
                client.SendTransform();
                if (client.peer != null)
                {
                    sent++;
                }
                else
                {
                    total--;
                }
            }

            if (total == 0)
            {
                Log.Information("All Disconnect Clients");
                OnAllDisconnected?.Invoke();
                break;
            }

            Log.Debug("[TICK {Tick:000}] {Sent}/{Total} 전송", tick, sent, total);
            tick++;

            try
            {
                await Task.Delay(sendInterval, ct);
            }
            catch (OperationCanceledException)
            {
                break;
            }
        }
    }

    public void PrintStats()
    {
        int totalSent = 0, totalRecv = 0;
        int connected = 0;

        Log.Information("───────────── Performance Report ─────────────");

        foreach (DummyClients c in clients)
        {
            NetStatistics? stats = c.peer?.Statistics;
            long loss = stats?.PacketLoss ?? 0;
            float lossPct = stats?.PacketLossPercent ?? 0f;

            Log.Information(
                "[Client {ClientId:00}] Sent={Sent} Recv={Recv} | Loss={Loss}({LossPct:F1}%)",
                c.clientId, c.SentCount, c.ReceivedCount, loss, lossPct);

            totalSent += c.SentCount;
            totalRecv += c.ReceivedCount;

            if (c.peer != null)
            {
                connected++;
            }
        }

        Log.Information("────────────────────────────────────────────");
        Log.Information(
            "[TOTAL] Sent={Sent} Recv={Recv} Connected={Connected}/{Total}",
            totalSent, totalRecv, connected, clients.Count);
        Log.Information("────────────────────────────────────────────");
    }

    public void Stop()
    {
        foreach (DummyClients c in clients)
        {
            c.Stop();
        }

        Log.Information("[SERVICE] 모든 클라이언트 종료됨.");
    }
}