package me.mrCookieSlime.Slimefun.api;

import java.io.File;
import java.io.FileNotFoundException;
import java.io.PrintStream;
import java.util.*;

import me.mrCookieSlime.CSCoreLibPlugin.CSCoreLib;
import org.bukkit.*;
import org.bukkit.block.Block;
import org.bukkit.command.CommandSender;
import org.bukkit.entity.Player;
import org.bukkit.plugin.Plugin;

import me.mrCookieSlime.CSCoreLibPlugin.general.Clock;
import me.mrCookieSlime.CSCoreLibPlugin.general.Chat.TellRawMessage;
import me.mrCookieSlime.CSCoreLibPlugin.general.Chat.TellRawMessage.HoverAction;
import me.mrCookieSlime.Slimefun.SlimefunStartup;
import me.mrCookieSlime.Slimefun.Objects.SlimefunItem.SlimefunItem;
import me.mrCookieSlime.Slimefun.Objects.SlimefunItem.handlers.BlockTicker;

public class TickerTask implements Runnable {
	
	public boolean HALTED = false;
	
	public Map<Block, Block> move = new HashMap<Block, Block>();
	public Map<Location, Boolean> delete = new HashMap<Location, Boolean>();
	
	private Set<BlockTicker> tickers = new HashSet<BlockTicker>();
	
	private int skipped = 0, chunks = 0, machines = 0;
	private long time = 0;
	private Map<String, Integer> map_chunk = new HashMap<String, Integer>();
	private Map<String, Integer> map_machine = new HashMap<String, Integer>();
	private Map<String, Long> map_machinetime = new HashMap<String, Long>();
	private Map<String, Long> map_chunktime = new HashMap<String, Long>();
	private Set<String> skipped_chunks = new HashSet<String>();

	public static Map<Location, Long> block_timings = new HashMap<Location, Long>();
	
	public static Map<Location, Integer> bugged_blocks = new HashMap<Location, Integer>();
	
	@Override
	public void run() {
		
		long timestamp = System.currentTimeMillis();
		
		skipped = 0;
		chunks = 0;
		machines = 0;
		map_chunk.clear();
		map_machine.clear();
		time = 0;
		map_chunktime.clear();
		skipped_chunks.clear();
		map_machinetime.clear();
		block_timings.clear();

		final Map<Location, Integer> bugged = new HashMap<Location, Integer>(bugged_blocks);
		bugged_blocks.clear();
		
		Map<Location, Boolean> remove = new HashMap<Location, Boolean>(delete);

		for (Map.Entry<Location, Boolean> entry: remove.entrySet()) {
			BlockStorage._integrated_removeBlockInfo(entry.getKey(), entry.getValue());
			delete.remove(entry.getKey());
		}
		
		if (!HALTED) {
			for (final String c: BlockStorage.getTickingChunks()) {
				long timestamp2 = System.currentTimeMillis();
				chunks++;
				
				blocks:
				for (final Block b: BlockStorage.getTickingBlocks(c)) {
					if (b.getChunk().isLoaded()) {
						final Location l = b.getLocation();
						final SlimefunItem item = BlockStorage.check(l);
						if (item != null) {
							machines++;
							try {
								item.getTicker().update();
								if (item.getTicker().isSynchronized()) {
									Bukkit.getScheduler().scheduleSyncDelayedTask(SlimefunStartup.instance, new Runnable() {
										
										@Override
										public void run() {
											try {
												long timestamp3 = System.currentTimeMillis();
												item.getTicker().tick(b, item, BlockStorage.getBlockInfo(l));
												
												map_machinetime.put(item.getName(), (map_machinetime.containsKey(item.getName()) ? map_machinetime.get(item.getName()): 0) + (System.currentTimeMillis() - timestamp3));
												map_chunk.put(c, (map_chunk.containsKey(c) ? map_chunk.get(c): 0) + 1);
												map_machine.put(item.getName(), (map_machine.containsKey(item.getName()) ? map_machine.get(item.getName()): 0) + 1);
												block_timings.put(l, System.currentTimeMillis() - timestamp3);
											} catch(Exception x) {
												int errors = 0;
												if (bugged.containsKey(l)) errors = bugged.get(l);
												errors++;
												
												if (errors == 1) {
													File file = new File("plugins/Slimefun/error-reports/" + Clock.getFormattedTime() + ".err");
													if (file.exists()) {
														file = new File("plugins/Slimefun/error-reports/" + Clock.getFormattedTime() + "(2).err");
														if (file.exists()) {
															file = new File("plugins/Slimefun/error-reports/" + Clock.getFormattedTime() + "(3).err");
															if (file.exists()) {
																file = new File("plugins/Slimefun/error-reports/" + Clock.getFormattedTime() + "(4).err");
																if (file.exists()) {
																	file = new File("plugins/Slimefun/error-reports/" + Clock.getFormattedTime() + "(5).err");
																	if (file.exists()) {
																		file = new File("plugins/Slimefun/error-reports/" + Clock.getFormattedTime() + "(6).err");
																		if (file.exists()) {
																			file = new File("plugins/Slimefun/error-reports/" + Clock.getFormattedTime() + "(7).err");
																			if (file.exists()) {
																				file = new File("plugins/Slimefun/error-reports/" + Clock.getFormattedTime() + "(8).err");
																				if (file.exists()) {
																					file = new File("plugins/Slimefun/error-reports/" + Clock.getFormattedTime() + "(9).err");
																					if (file.exists()) {
																						file = new File("plugins/Slimefun/error-reports/" + Clock.getFormattedTime() + "(10).err");
																					}
																				}
																			}
																		}
																	}
																}
															}
														}
													}
													try {
														PrintStream stream = new PrintStream(file);
														stream.println();
														stream.println("Server Software: " + Bukkit.getName());
														stream.println("  Build: " + Bukkit.getVersion());
														stream.println("  Minecraft: " + Bukkit.getBukkitVersion());
														stream.println();
														stream.println("Slimefun Environment:");
														stream.println("  CS-CoreLib v" + CSCoreLib.getLib().getDescription().getVersion());
														stream.println("  Slimefun v" + SlimefunStartup.instance.getDescription().getVersion());
														stream.println();

														List<String> plugins = new ArrayList<>();
														List<String> addons = new ArrayList<>();
														for (Plugin p: Bukkit.getPluginManager().getPlugins()) {
															if (Bukkit.getPluginManager().isPluginEnabled(p)) {
																plugins.add("  + " + p.getName() + " " + p.getDescription().getVersion());
																if (p.getDescription().getDepend().contains("Slimefun") || p.getDescription().getSoftDepend().contains("Slimefun"))
																	addons.add("  + " + p.getName() + " " + p.getDescription().getVersion());
															}
															else {
																plugins.add("  - " + p.getName() + " " + p.getDescription().getVersion());
																if (p.getDescription().getDepend().contains("Slimefun") || p.getDescription().getSoftDepend().contains("Slimefun"))
																	addons.add("  - " + p.getName() + " " + p.getDescription().getVersion());
															}
														}

														stream.println(" Installed Addons (" + addons.size() + ")");
														for (String addon : addons) stream.println(addon);
														stream.println();
														stream.println("Installed Plugins (" + plugins.size() + "):");
														for (String plugin : plugins) stream.println(plugin);
														stream.println();
														stream.println("Ticked Block:");
														stream.println("  World: " + l.getWorld().getName());
														stream.println("  X: " + l.getBlockX());
														stream.println("  Y: " + l.getBlockY());
														stream.println("  Z: " + l.getBlockZ());
														stream.println();
														stream.println("Slimefun Data:");
														stream.println("  ID: " + item.getName());
														stream.println("  Inventory: " + BlockStorage.getStorage(l.getWorld()).hasInventory(l));
														stream.println("  Data: " + BlockStorage.getBlockInfoAsJson(l));
														stream.println();
														stream.println("Stacktrace:");
														stream.println();
														x.printStackTrace(stream);
														
														stream.close();
													} catch (FileNotFoundException e) {
														e.printStackTrace();
													}
													
													System.err.println("[Slimefun] Exception caught while ticking a Block:" + x.getClass().getName());
													System.err.println("[Slimefun] X: " + l.getBlockX() + " Y: " + l.getBlockY() + " Z: " + l.getBlockZ());
													System.err.println("[Slimefun] Saved as: ");
													System.err.println("[Slimefun] /plugins/Slimefun/error-reports/" + file.getName());
													System.err.println("[Slimefun] Please consider sending this File to the developer(s) of Slimefun, sending this Error won't get you any help though.");
													System.err.println("[Slimefun] ");
													
													bugged_blocks.put(l, errors);
												}
												else if (errors == 4) {
													System.err.println("[Slimefun] X: " + l.getBlockX() + " Y: " + l.getBlockY() + " Z: " + l.getBlockZ() + "(" + item.getName() + ")");
													System.err.println("[Slimefun] has thrown 4 Exceptions in the last 4 Ticks, the Block has been terminated.");
													System.err.println("[Slimefun] Check your /plugins/Slimefun/error-reports/ folder for details.");
													System.err.println("[Slimefun] ");
													
													BlockStorage._integrated_removeBlockInfo(l, true);
													
													Bukkit.getScheduler().scheduleSyncDelayedTask(SlimefunStartup.instance, new Runnable() {

														@Override
														public void run() {
															l.getBlock().setType(Material.AIR);
														}
														
													});
												}
												else {
													bugged_blocks.put(l, errors);
												}
											}
										}
									});
								}
								else {
									long timestamp3 = System.currentTimeMillis();
									item.getTicker().tick(b, item, BlockStorage.getBlockInfo(l));
									
									map_machinetime.put(item.getName(), (map_machinetime.containsKey(item.getName()) ? map_machinetime.get(item.getName()): 0) + (System.currentTimeMillis() - timestamp3));
									map_chunk.put(c, (map_chunk.containsKey(c) ? map_chunk.get(c): 0) + 1);
									map_machine.put(item.getName(), (map_machine.containsKey(item.getName()) ? map_machine.get(item.getName()): 0) + 1);
									block_timings.put(l, System.currentTimeMillis() - timestamp3);
								}
								tickers.add(item.getTicker());
							} catch(Exception x) {
								
								int errors = 0;
								if (bugged.containsKey(l)) errors = bugged.get(l);
								errors++;
								
								if (errors == 1) {
									File file = new File("plugins/Slimefun/error-reports/" + Clock.getFormattedTime() + ".err");
									if (file.exists()) {
										file = new File("plugins/Slimefun/error-reports/" + Clock.getFormattedTime() + "(2).err");
										if (file.exists()) {
											file = new File("plugins/Slimefun/error-reports/" + Clock.getFormattedTime() + "(3).err");
											if (file.exists()) {
												file = new File("plugins/Slimefun/error-reports/" + Clock.getFormattedTime() + "(4).err");
												if (file.exists()) {
													file = new File("plugins/Slimefun/error-reports/" + Clock.getFormattedTime() + "(5).err");
													if (file.exists()) {
														file = new File("plugins/Slimefun/error-reports/" + Clock.getFormattedTime() + "(6).err");
														if (file.exists()) {
															file = new File("plugins/Slimefun/error-reports/" + Clock.getFormattedTime() + "(7).err");
															if (file.exists()) {
																file = new File("plugins/Slimefun/error-reports/" + Clock.getFormattedTime() + "(8).err");
																if (file.exists()) {
																	file = new File("plugins/Slimefun/error-reports/" + Clock.getFormattedTime() + "(9).err");
																	if (file.exists()) {
																		file = new File("plugins/Slimefun/error-reports/" + Clock.getFormattedTime() + "(10).err");
																	}
																}
															}
														}
													}
												}
											}
										}
									}
									try {
										PrintStream stream = new PrintStream(file);
										stream.println();
										stream.println("Server Software: " + Bukkit.getName());
										stream.println("  Build: " + Bukkit.getVersion());
										stream.println("  Minecraft: " + Bukkit.getBukkitVersion());
										stream.println();
										stream.println("Installed Plugins (" + Bukkit.getPluginManager().getPlugins().length + ")");
										for (Plugin p: Bukkit.getPluginManager().getPlugins()) {
											if (Bukkit.getPluginManager().isPluginEnabled(p)) {
												stream.println("  + " + p.getName() + " " + p.getDescription().getVersion());
											}
											else {
												stream.println("  - " + p.getName() + " " + p.getDescription().getVersion());
											}
										}
										stream.println();
										stream.println("Ticked Block:");
										stream.println("  World: " + l.getWorld().getName());
										stream.println("  X: " + l.getBlockX());
										stream.println("  Y: " + l.getBlockY());
										stream.println("  Z: " + l.getBlockZ());
										stream.println();
										stream.println("Slimefun Data:");
										stream.println("  ID: " + item.getName());
										stream.println("  Inventory: " + BlockStorage.getStorage(l.getWorld()).hasInventory(l));
										stream.println("  Data: " + BlockStorage.getBlockInfoAsJson(l));
										stream.println();
										stream.println("Stacktrace:");
										stream.println();
										x.printStackTrace(stream);
										
										stream.close();
									} catch (FileNotFoundException e) {
										e.printStackTrace();
									}
									
									System.err.println("[Slimefun] Exception caught while ticking a Block:" + x.getClass().getName());
									System.err.println("[Slimefun] X: " + l.getBlockX() + " Y: " + l.getBlockY() + " Z: " + l.getBlockZ());
									System.err.println("[Slimefun] Saved as: ");
									System.err.println("[Slimefun] /plugins/Slimefun/error-reports/" + file.getName());
									System.err.println("[Slimefun] Please consider sending this File to the developer(s) of Slimefun, sending this Error won't get you any help though.");
									System.err.println("[Slimefun] ");
									
									bugged_blocks.put(l, errors);
								}
								else if (errors == 4) {
									System.err.println("[Slimefun] X: " + l.getBlockX() + " Y: " + l.getBlockY() + " Z: " + l.getBlockZ() + "(" + item.getName() + ")");
									System.err.println("[Slimefun] has thrown 4 Exceptions in the last 4 Ticks, the Block has been terminated.");
									System.err.println("[Slimefun] Check your /plugins/Slimefun/error-reports/ folder for details.");
									System.err.println("[Slimefun] ");
									
									BlockStorage._integrated_removeBlockInfo(l, true);
									
									Bukkit.getScheduler().scheduleSyncDelayedTask(SlimefunStartup.instance, new Runnable() {

										@Override
										public void run() {
											l.getBlock().setType(Material.AIR);
										}
										
									});
								}
								else {
									bugged_blocks.put(l, errors);
								}
							}
						}
						else skipped++;
					}
					else {
						skipped += BlockStorage.getTickingBlocks(c).size();
						skipped_chunks.add(c);
						chunks--;
						break blocks;
					}
				}
				
				map_chunktime.put(c, System.currentTimeMillis() - timestamp2);
			}
		}
		
		for (Map.Entry<Block, Block> entry: move.entrySet()) {
			BlockStorage._integrated_moveBlockInfo(entry.getKey(), entry.getValue());
		}
		move.clear();
		
		for (BlockTicker ticker: tickers) {
			ticker.unique = true;
		}
		tickers.clear();
		
		time = System.currentTimeMillis() - timestamp;
	}

	public void info(CommandSender sender) {
		sender.sendMessage(ChatColor.translateAlternateColorCodes('&', "&2== &aSlimefun Diagnostic Tool &2=="));
		sender.sendMessage(ChatColor.translateAlternateColorCodes('&', "&6Halted: &e&l" + String.valueOf(HALTED).toUpperCase()));
		sender.sendMessage("");
		sender.sendMessage(ChatColor.translateAlternateColorCodes('&', "&6Impact: &e" + time + "ms / 50-750ms"));
		sender.sendMessage(ChatColor.translateAlternateColorCodes('&', "&6Ticked Chunks: &e" + chunks));
		sender.sendMessage(ChatColor.translateAlternateColorCodes('&', "&6Ticked Machines: &e" + machines));
		sender.sendMessage(ChatColor.translateAlternateColorCodes('&', "&6Skipped Machines: &e" + skipped));
		sender.sendMessage("");
		sender.sendMessage(ChatColor.translateAlternateColorCodes('&', "&6Ticking Machines:"));
		if (sender instanceof Player) {
			TellRawMessage tellraw = new TellRawMessage();
			tellraw.addText("   &7&oHover for more Info");
			StringBuilder hover = new StringBuilder();
			int hidden = 0;
			for (String item: map_machine.keySet()) {
				if (map_machinetime.get(item) > 0) hover.append("\n&c" + item + " - " + map_machine.get(item) + "x &7(" + map_machinetime.get(item) + "ms)");
				else hidden++;
			}
			hover.append("\n\n&c+ &4" + hidden + " Hidden");
			tellraw.addHoverEvent(HoverAction.SHOW_TEXT, hover.toString());
			try {
				tellraw.send((Player) sender);
			} catch (Exception e) {
				e.printStackTrace();
			}
		}
		else {
			int hidden = 0;
			for (String item: map_machine.keySet()) {
				if (map_machinetime.get(item) > 0) sender.sendMessage(ChatColor.translateAlternateColorCodes('&', "  &e" + item + " - " + map_machine.get(item) + "x &7(" + map_machinetime.get(item) + "ms)"));
				else hidden++;
			}
			sender.sendMessage(ChatColor.translateAlternateColorCodes('&', "&c+ &4" + hidden + " Hidden"));
		}
		sender.sendMessage("");
		sender.sendMessage(ChatColor.translateAlternateColorCodes('&', "&6Ticking Chunks:"));
		if (sender instanceof Player) {
			TellRawMessage tellraw = new TellRawMessage();
			tellraw.addText("   &7&oHover for more Info");
			StringBuilder hover = new StringBuilder();
			int hidden = 0;
			for (String c: map_chunktime.keySet()) {
				if (!skipped_chunks.contains(c)) {
					if (map_chunktime.get(c) > 0) hover.append("\n&c" + c.replace("CraftChunk", "") + " - " + (map_chunk.containsKey(c) ? map_chunk.get(c): 0) + "x &7(" + map_chunktime.get(c) + "ms)");
					else hidden++;
				}
			}
			hover.append("\n\n&c+ &4" + hidden + " Hidden");
			tellraw.addHoverEvent(HoverAction.SHOW_TEXT, hover.toString());
			try {
				tellraw.send((Player) sender);
			} catch (Exception e) {
				e.printStackTrace();
			}
		}
		else {

			int hidden = 0;
			for (String c: map_chunktime.keySet()) {
				if (!skipped_chunks.contains(c)) {
					if (map_chunktime.get(c) > 0) sender.sendMessage("  &c" + c.replace("CraftChunk", "") + " - " + (map_chunk.containsKey(c) ? map_chunk.get(c): 0) + "x &7(" + map_chunktime.get(c) + "ms)");
					else hidden++;
				}
			}
			sender.sendMessage(ChatColor.translateAlternateColorCodes('&', "&c+ &4" + hidden + " Hidden"));
		}
	}
	
	public long getTimings(Block b) {
		return block_timings.containsKey(b.getLocation()) ? block_timings.get(b.getLocation()): 0L;
	}
	
	public long getTimings(String item) {
		return map_machinetime.containsKey(item) ? map_machinetime.get(item): 0L;
	}
	
	public long getTimings(Chunk c) {
		return map_chunktime.containsKey(c.toString()) ? map_chunktime.get(c.toString()): 0L;
	}

}