using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using Lidgren.Network;
using RageCoop.Core;
using RageCoop.Core.Scripting;
using RageCoop.Server.Scripting;

namespace RageCoop.Server
{
    public partial class Server
    {
        private void PedSync(Packets.PedSync packet, Client client)
        {
            _worker.QueueJob(() => Entities.Update(packet, client));

            bool isPlayer = packet.ID==client.Player.ID;
            if (isPlayer)
            {
                _worker.QueueJob(() => API.Events.InvokePlayerUpdate(client));
            }

            if (Settings.UseP2P) { return; }
            foreach (var c in ClientsByNetHandle.Values)
            {

                // Don't send data back
                if (c.NetHandle==client.NetHandle) { continue; }

                // Check streaming distance
                if (isPlayer)
                {
                    if ((Settings.PlayerStreamingDistance!=-1)&&(packet.Position.DistanceTo(c.Player.Position)>Settings.PlayerStreamingDistance))
                    {
                        continue;
                    }
                }
                else if ((Settings.NpcStreamingDistance!=-1)&&(packet.Position.DistanceTo(c.Player.Position)>Settings.NpcStreamingDistance))
                {
                    continue;
                }

                NetOutgoingMessage outgoingMessage = MainNetServer.CreateMessage();
                packet.Pack(outgoingMessage);
                MainNetServer.SendMessage(outgoingMessage, c.Connection, NetDeliveryMethod.UnreliableSequenced, (byte)ConnectionChannel.PedSync);
            }
        }
        private void VehicleSync(Packets.VehicleSync packet, Client client)
        {
            _worker.QueueJob(() => Entities.Update(packet, client));
            bool isPlayer = packet.ID==client.Player?.LastVehicle?.ID;


            if (Settings.UseP2P) { return; }
            foreach (var c in ClientsByNetHandle.Values)
            {
                if (c.NetHandle==client.NetHandle) { continue; }
                if (isPlayer)
                {
                    // Player's vehicle
                    if ((Settings.PlayerStreamingDistance!=-1)&&(packet.Position.DistanceTo(c.Player.Position)>Settings.PlayerStreamingDistance))
                    {
                        continue;
                    }

                }
                else if ((Settings.NpcStreamingDistance!=-1)&&(packet.Position.DistanceTo(c.Player.Position)>Settings.NpcStreamingDistance))
                {
                    continue;
                }
                NetOutgoingMessage outgoingMessage = MainNetServer.CreateMessage();
                packet.Pack(outgoingMessage);
                MainNetServer.SendMessage(outgoingMessage, c.Connection, NetDeliveryMethod.UnreliableSequenced, (byte)ConnectionChannel.PedSync);
            }
        }
        private void ProjectileSync(Packets.ProjectileSync packet, Client client)
        {

            if (Settings.UseP2P) { return; }
            Forward(packet, client, ConnectionChannel.ProjectileSync);
        }

    }
}