package dev.plex.player;

import com.google.common.collect.Lists;
import com.google.common.collect.Maps;
import dev.plex.Plex;
import dev.plex.PlexBase;
import dev.plex.event.PunishedPlayerFreezeEvent;
import dev.plex.event.PunishedPlayerMuteEvent;
import dev.plex.punishment.Punishment;
import dev.plex.util.PlexLog;
import lombok.AccessLevel;
import lombok.Getter;
import lombok.Setter;
import lombok.SneakyThrows;
import org.apache.commons.io.FileUtils;
import org.bukkit.Bukkit;
import org.json.JSONArray;
import org.json.JSONObject;
import org.json.JSONTokener;

import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.nio.charset.StandardCharsets;
import java.util.List;
import java.util.Map;
import java.util.UUID;
import java.util.stream.Collectors;

@Getter
public class PunishedPlayer extends PlexBase
{
    //everything in here will be stored in redis
    @Setter(AccessLevel.NONE)
    private String uuid;

    private boolean muted;
    private boolean frozen;

    public PunishedPlayer(UUID playerUUID)
    {
        this.uuid = playerUUID.toString();
        this.muted = false;
        this.frozen = false;
    }

    public void setFrozen(boolean frozen)
    {
        PunishedPlayerFreezeEvent e = new PunishedPlayerFreezeEvent(this, this.frozen);
        Bukkit.getServer().getPluginManager().callEvent(e);
        if (!e.isCancelled())
        {
            this.frozen = frozen;
        }
    }

    public void setMuted(boolean muted)
    {
        PunishedPlayerMuteEvent e = new PunishedPlayerMuteEvent(this, this.muted);
        Bukkit.getServer().getPluginManager().callEvent(e);
        if (!e.isCancelled())
        {
            this.muted = muted;
        }
    }

    public File getPunishmentsFile()
    {
        File folder = new File(Plex.get().getDataFolder() + File.separator + "punishments");
        if (!folder.exists())
        {
            folder.mkdir();
        }

        File file = new File(folder, getUuid() + ".json");
        if (!file.exists())
        {
            try
            {
                file.createNewFile();
            } catch (IOException e)
            {
                e.printStackTrace();
            }
        }
        return file;

    }

    @SneakyThrows
    public void convertPunishments()
    {
        if (!plugin.getRedisConnection().isEnabled()) return;
        List<Punishment> punishments = Lists.newArrayList();

        File file = getPunishmentsFile();
        //Converting from File to Redis
        if (isNotEmpty(file))
        {
            PlexLog.debug("Starting converting punishments from file to redis for " + uuid + "...");
            JSONTokener tokener = new JSONTokener(new FileInputStream(file));
            JSONObject object = new JSONObject(tokener);
            JSONArray array = object.getJSONObject(getUuid()).getJSONArray("punishments");
            for (int i = 0; i < array.toList().size(); i++)
            {
                Punishment punishment = Punishment.fromJson(array.get(i).toString());
                punishments.add(punishment);
            }
            PlexLog.debug("Successfully converted all file punishments into array (" + punishments.size() + ")");
            if (!punishments.isEmpty())
            {
                Map<String, List<String>> filesList = Maps.newHashMap();
                filesList.put("punishments", punishments.stream().map(Punishment::toJSON).collect(Collectors.toList()));
                JSONObject obj = new JSONObject().put(uuid, filesList);
                if (plugin.getRedisConnection().getJedis().exists(uuid))
                {
                    PlexLog.debug("File and Redis Matches? " + plugin.getRedisConnection().getJedis().get(uuid).equalsIgnoreCase(obj.toString()));
                    if (!plugin.getRedisConnection().getJedis().get(uuid).equalsIgnoreCase(obj.toString()))
                    {
                        plugin.getRedisConnection().getJedis().set(uuid, obj.toString());
                        PlexLog.debug("Updated Redis Punishments to match with file");
                    }
                } else
                {
                    plugin.getRedisConnection().getJedis().set(uuid, obj.toString());
                }
            }
        }
    }

    @SneakyThrows
    public List<Punishment> getPunishments()
    {
        List<Punishment> punishments = Lists.newArrayList();

        if (plugin.getRedisConnection().isEnabled())
        {
            PlexLog.debug("Getting punishments from Redis...");
            if (!plugin.getRedisConnection().getJedis().exists(uuid)) return punishments;
            String strObj = plugin.getRedisConnection().getJedis().get(uuid);
            if (strObj.isEmpty() || !strObj.startsWith("{")) return punishments;
            JSONObject object = new JSONObject(strObj);
            object.getJSONObject(uuid).getJSONArray("punishments").forEach(obj ->
            {
                JSONObject converted = new JSONObject(obj.toString());
                if (converted.isNull("active"))
                {
                    converted.put("active", false);
                }
                Punishment punishment = Punishment.fromJson(converted.toString());
                punishments.add(punishment);
            });
            plugin.getRedisConnection().getJedis().close();
            return punishments;
        }

        File file = getPunishmentsFile();

        if (isNotEmpty(file))
        {
            try
            {
                PlexLog.debug("Getting punishments from locally stored JSON files...");
                JSONTokener tokener = new JSONTokener(new FileInputStream(file));
                JSONObject object = new JSONObject(tokener);
                object.getJSONObject(getUuid()).getJSONArray("punishments").forEach(obj ->
                {
                    Punishment punishment = Punishment.fromJson(obj.toString());
                    punishments.add(punishment);
                });
            } catch (FileNotFoundException e)
            {
                e.printStackTrace();
            }
        }
        return punishments;
    }

    private boolean isNotEmpty(File file)
    {
        try
        {
            return !FileUtils.readFileToString(file, StandardCharsets.UTF_8).trim().isEmpty();
        } catch (IOException e)
        {
            e.printStackTrace();
        }
        return false;
    }
}