using System.Text;
using Mine2d.engine.system.annotations;
using Mine2d.game;
using Mine2d.game.backend.network;
using Mine2d.game.backend.network.packets;
using Newtonsoft.Json;
using WatsonTcp;

namespace Mine2d.engine.networking;

public class Backend : IBackend
{
    private WatsonTcpServer server;
    private Publisher publisher;
    private readonly Queue<Packet> pendingPackets = new();
    private uint tick;

    public void Process(double dt)
    {
        this.ProcessPacket(new TickPacket
        {
            Tick = ++this.tick
        });
            
        var context = Context.Get();
        context.GameState.Tick = this.tick;
        context.GameState.DeltaTime = dt;
        while (this.pendingPackets.Count > 0)
        {
            this.publisher.Publish(this.pendingPackets.Dequeue());
        }
        this.SendGameState();
    }

    public void ProcessPacket(Packet packet)
    {
        this.pendingPackets.Enqueue(packet);
    }

    public void Init()
    {
        Task.Run(this.Run);
        this.publisher = new Publisher(InteractorKind.Hybrid);
        this.publisher.Dump();
    }

    public void Run()
    {
        this.server = new WatsonTcpServer("127.0.0.1", 42069);
        this.server.Events.ClientConnected += this.ClientConnected;
        this.server.Events.ClientDisconnected += this.ClientDisconnected;
        this.server.Events.MessageReceived += this.MessageReceived;
        this.server.Start();
    }

    private void ClientConnected(object sender, ConnectionEventArgs args)
    {
        Console.WriteLine("Client connected: " + args.IpPort);
        var gameState = Context.Get().GameState;
        var json = JsonConvert.SerializeObject(gameState);
        if (sender is WatsonTcpServer server)
        {
            server.Send(args.IpPort, Encoding.UTF8.GetBytes(json));
        }
    }

    private void ClientDisconnected(object sender, DisconnectionEventArgs args)
    {
        Console.WriteLine("Client disconnected: " + args.IpPort);
    }

    private void MessageReceived(object sender, MessageReceivedEventArgs args)
    {
        Console.WriteLine("Message Received: " + args.IpPort);
        
        var packet = Converter.ParsePacket(args.Data);
        Console.WriteLine($"Received packet: {packet.Type}");
        
        this.pendingPackets.Enqueue(packet);
    }

    private void SendGameState()
    {
        if (this.server == null)
        {
            return;
        }

        var clients = this.server.ListClients().ToArray();
        if (!clients.Any())
        {
            return;
        }

        var gameState = Context.Get().GameState;
        var json = JsonConvert.SerializeObject(gameState);
        var bytes = Encoding.UTF8.GetBytes(json);
        foreach (var client in clients)
        {
            this.server.Send(client, bytes);
        }
    }
}