package com.massivecraft.factions.cmd;


import com.massivecraft.factions.*;
import com.massivecraft.factions.struct.Permission;
import com.massivecraft.factions.struct.Relation;
import com.massivecraft.factions.util.Particles.ParticleEffect;
import com.massivecraft.factions.util.WarmUpUtil;
import com.massivecraft.factions.zcore.fperms.Access;
import com.massivecraft.factions.zcore.fperms.PermissableAction;
import com.massivecraft.factions.zcore.util.TL;
import org.bukkit.Bukkit;
import org.bukkit.GameMode;
import org.bukkit.Particle;
import org.bukkit.entity.Entity;
import org.bukkit.entity.Player;

import java.util.ConcurrentModificationException;
import java.util.List;
import java.util.concurrent.ConcurrentHashMap;

public class CmdFly extends FCommand {


    public static ConcurrentHashMap<String, Boolean> flyMap = new ConcurrentHashMap<String, Boolean>();
    public static int id = -1;
    public static int flyid = -1;

    public CmdFly() {
        super();
        this.aliases.add("fly");

        this.optionalArgs.put("on/off", "flip");

        this.permission = Permission.FLY.node;
        this.senderMustBeMember = true;
        this.senderMustBeModerator = false;
    }

    public static void startParticles() {
        // Just a secondary check.
        if (!P.p.getConfig().getBoolean("ffly.Particles.Enabled")) {
            return;
        }

        id = Bukkit.getScheduler().scheduleSyncRepeatingTask(P.p, new Runnable() {
            @Override
            public void run() {
                for (String name : flyMap.keySet()) {
                    Player player = Bukkit.getPlayer(name);
                    if (player == null) {
                        continue;
                    }
                    if (!player.isFlying()) {
                        continue;
                    }
                    if (!P.p.mc17) {
                        if (player.getGameMode() == GameMode.SPECTATOR) {
                            continue;
                        }
                    }

                    if (FPlayers.getInstance().getByPlayer(player).isVanished()) {
                        // Actually, vanished players (such as admins) should not display particles to prevent others from knowing their vanished assistance for moderation.
                        // But we can keep it as a config.
                        if (P.p.getConfig().getBoolean("ffly.Particles.Enable-While-Vanished")) {
                            return;
                        }
                        continue;
                    }
                    if (P.p.useNonPacketParticles) {
                        // 1.9+ based servers will use the built in particleAPI instead of packet based.
                        // any particle amount higher than 0 made them go everywhere, and the offset at 0 was not working.
                        // So setting the amount to 0 spawns 1 in the precise location
                        player.getWorld().spawnParticle(Particle.CLOUD, player.getLocation().add(0, -0.35, 0), 0);
                    } else {
                        ParticleEffect.CLOUD.display((float) 0, (float) 0, (float) 0, (float) 0, 3, player.getLocation().add(0, -0.35, 0), 16);
                    }

                }
                if (flyMap.keySet().size() == 0) {
                    Bukkit.getScheduler().cancelTask(id);
                    id = -1;
                }
            }
        }, 10L, 3L);
    }

    public static void startFlyCheck() {
        flyid = Bukkit.getScheduler().scheduleSyncRepeatingTask(P.p, new Runnable() {
            @Override
            public void run() throws ConcurrentModificationException { //threw the exception for now, until I recode fly :( Cringe.
                checkTaskState();
                if (flyMap.keySet().size() != 0) {
                    for (String name : flyMap.keySet()) {
                        if (name == null) {
                            continue;
                        }
                        Player player = Bukkit.getPlayer(name);
                        if (player == null) {
                            continue;
                        }
                        if (!player.isFlying()) {
                            continue;
                        }
                        FPlayer fPlayer = FPlayers.getInstance().getByPlayer(player);
                        if (fPlayer == null) {
                            continue;
                        }
                        if (player.getGameMode() == GameMode.CREATIVE || player.getGameMode() == GameMode.SPECTATOR) {
                            continue;
                        }
                        Faction myFaction = fPlayer.getFaction();
                        if (myFaction.isWilderness()) {
                            fPlayer.setFlying(false);
                            flyMap.remove(name);
                            continue;
                        }
                        if (fPlayer.checkIfNearbyEnemies()) {
                            continue;
                        }
                        FLocation myFloc = new FLocation(player.getLocation());
                        Faction toFac = Board.getInstance().getFactionAt(myFloc);
                        if (Board.getInstance().getFactionAt(myFloc) != myFaction) {
                            if (!checkBypassPerms(fPlayer, player, toFac)) {
                                fPlayer.setFlying(false);
                                flyMap.remove(name);
                                continue;
                            }
                        }

                    }
                }

            }
        }, 20L, 20L);
    }

    private static boolean checkBypassPerms(FPlayer fme, Player me, Faction toFac) {
        if (toFac != fme.getFaction()) {
            if (!me.hasPermission("factions.fly.wilderness") && toFac.isWilderness() || !me.hasPermission("factions.fly.safezone") && toFac.isSafeZone() || !me.hasPermission("factions.fly.warzone") && toFac.isWarZone()) {
                fme.msg(TL.COMMAND_FLY_NO_ACCESS, toFac.getTag(fme));
                return false;
            }
            Access access = toFac.getAccess(fme, PermissableAction.FLY);
            if ((!(me.hasPermission("factions.fly.enemy") || access == Access.ALLOW)) && toFac.getRelationTo(fme.getFaction()) == Relation.ENEMY) {
                fme.msg(TL.COMMAND_FLY_NO_ACCESS, toFac.getTag(fme));
                return false;
            }
            if (!(me.hasPermission("factions.fly.ally") || access == Access.ALLOW) && toFac.getRelationTo(fme.getFaction()) == Relation.ALLY) {
                fme.msg(TL.COMMAND_FLY_NO_ACCESS, toFac.getTag(fme));
                return false;
            }
            if (!(me.hasPermission("factions.fly.truce") || access == Access.ALLOW) && toFac.getRelationTo(fme.getFaction()) == Relation.TRUCE) {
                fme.msg(TL.COMMAND_FLY_NO_ACCESS, toFac.getTag(fme));
                return false;
            }

            if (!(me.hasPermission("factions.fly.neutral") || access == Access.ALLOW) && toFac.getRelationTo(fme.getFaction()) == Relation.NEUTRAL && !isSystemFaction(toFac)) {
                fme.msg(TL.COMMAND_FLY_NO_ACCESS, toFac.getTag(fme));
                return false;
            }
            return me.hasPermission("factions.fly") && access != Access.DENY;
        }
        return true;
    }

    public static Boolean isSystemFaction(Faction faction) {
        return faction.isSafeZone() ||
                faction.isWarZone() ||
                faction.isWilderness();
    }

    public static void checkTaskState() {
        if (flyMap.keySet().size() == 0) {
            Bukkit.getScheduler().cancelTask(flyid);
            flyid = -1;
        }
    }

    public boolean isInFlightChecker(Player player) {
        return flyMap.containsKey(player.getName());
    }

    @Override
    public void perform() {
        // Disabled by default.
        if (!P.p.getConfig().getBoolean("enable-faction-flight", false)) {
            fme.msg(TL.COMMAND_FLY_DISABLED);
            return;
        }

        FLocation myfloc = new FLocation(me.getLocation());
        Faction toFac = Board.getInstance().getFactionAt(myfloc);
        if (!checkBypassPerms(fme, me, toFac)) return;
        List<Entity> entities = me.getNearbyEntities(16, 256, 16);
        for (int i = 0; i <= entities.size() - 1; i++) {
            if (entities.get(i) instanceof Player) {
                Player eplayer = (Player) entities.get(i);
                FPlayer efplayer = FPlayers.getInstance().getByPlayer(eplayer);
                if (efplayer.getRelationTo(fme) == Relation.ENEMY && !efplayer.isStealthEnabled()) {
                    fme.msg(TL.COMMAND_FLY_CHECK_ENEMY);
                    return;
                }
            }
        }


        if (args.size() == 0) {
            toggleFlight(!fme.isFlying(), me);
        } else if (args.size() == 1) {
            toggleFlight(argAsBool(0), me);
        }
    }

    private void toggleFlight(final boolean toggle, final Player player) {
        if (!toggle) {
            fme.setFlying(false);
            flyMap.remove(player.getName());
            return;
        }

        if (fme.canFlyAtLocation())

            this.doWarmUp(WarmUpUtil.Warmup.FLIGHT, TL.WARMUPS_NOTIFY_FLIGHT, "Fly", new Runnable() {
                @Override
                public void run() {
                    fme.setFlying(true);
                    flyMap.put(player.getName(), true);
                    if (id == -1) {
                        if (P.p.getConfig().getBoolean("ffly.Particles.Enabled")) {
                            startParticles();
                        }
                    }
                    if (flyid == -1) {
                        startFlyCheck();
                    }
                }
            }, this.p.getConfig().getLong("warmups.f-fly", 0));
    }

    @Override
    public TL getUsageTranslation() {
        return TL.COMMAND_FLY_DESCRIPTION;
    }

}