package server.model.players;

import java.net.InetSocketAddress;

import server.Server;
import server.Config;
import server.model.npcs.NPCHandler;
import server.util.Misc;
import server.util.Stream;

public class PlayerHandler {

	public static Player players[] = new Player[Config.MAX_PLAYERS];
	public static String messageToAll = "";
	public static int playerCount = 0;
	public static String playersCurrentlyOn[] = new String[Config.MAX_PLAYERS];
	public static boolean updateAnnounced;
	public static boolean updateRunning;
	public static int updateSeconds;
	public static long updateStartTime;
	private boolean kickAllPlayers = false;

	static {
		for (int i = 0; i < Config.MAX_PLAYERS; i++) {
			players[i] = null;
		}
	}

	public static int getPlayerCount() {
		return playerCount;
	}

	public static Player[] getPlayers() {
		// TODO Auto-generated method stub
		return players;
	}

	public static boolean isPlayerOn(String playerName) {
		synchronized (PlayerHandler.players) {
			for (int i = 0; i < Config.MAX_PLAYERS; i++) {
				if (playersCurrentlyOn[i] != null) {
					if (playersCurrentlyOn[i].equalsIgnoreCase(playerName)) {
						return true;
					}
				}
			}
			return false;
		}
	}

	private final Stream updateBlock = new Stream(new byte[Config.BUFFER_SIZE]);

	public void destruct() {
		for (int i = 0; i < Config.MAX_PLAYERS; i++) {
			if (players[i] == null) {
				continue;
			}
			players[i].destruct();
			players[i] = null;
		}
	}

	public boolean newPlayerClient(Client client1) {
		int slot = -1;
		for (int i = 1; i < Config.MAX_PLAYERS; i++) {
			if ((players[i] == null) || players[i].disconnected) {
				slot = i;
				break;
			}
		}
		if (slot == -1) {
			return false;
		}
		client1.handler = this;
		client1.playerId = slot;
		players[slot] = client1;
		players[slot].isActive = true;
		players[slot].connectedFrom = ((InetSocketAddress) client1.getSession()
				.getRemoteAddress()).getAddress().getHostAddress();
		if (Config.SERVER_DEBUG) {
			Misc.println("Player Slot " + slot + " slot 0 " + players[0]
					+ " Player Hit " + players[slot]);
		}
		return true;
	}

	public void process() {
		synchronized (PlayerHandler.players) {

			updatePlayerNames();

			if (kickAllPlayers) {
				for (int i = 1; i < Config.MAX_PLAYERS; i++) {
					if (players[i] != null) {
						players[i].disconnected = true;
					}
				}
			}

			for (int i = 0; i < Config.MAX_PLAYERS; i++) {
				if (players[i] == null || !players[i].isActive) {
					continue;
				}
				try {

					if (players[i].disconnected
							&& (System.currentTimeMillis()
									- players[i].logoutDelay > 10000
									|| players[i].properLogout || kickAllPlayers)) {
						if (players[i].inTrade) {
							final Client o = (Client) PlayerHandler.players[players[i].tradeWith];
							if (o != null) {
								o.getTradeAndDuel().declineTrade();
							}
						}
						if (players[i].duelStatus == 5) {
							final Client o = (Client) PlayerHandler.players[players[i].duelingWith];
							if (o != null) {
								o.getTradeAndDuel().duelVictory();
							}
						} else if (players[i].duelStatus <= 4
								&& players[i].duelStatus >= 1) {
							final Client o = (Client) PlayerHandler.players[players[i].duelingWith];
							if (o != null) {
								o.getTradeAndDuel().declineDuel();
							}
						}
						final Client o = (Client) PlayerHandler.players[i];
						if (PlayerSave.saveGame(o)) {
							System.out
									.println("Game saved for player: "
											+ Misc.properPlayerName(players[i].playerName));
						} else {
							System.out
									.println("Could not save for "
											+ Misc.properPlayerName(players[i].playerName));
						}
						removePlayer(players[i]);
						players[i] = null;
						continue;
					}

					players[i].preProcessing();
					while (players[i].processQueuedPackets()) {
						;
					}
					players[i].process();
					players[i].postProcessing();
					players[i].getNextPlayerMovement();

				} catch (final Exception e) {
					e.printStackTrace();
				}
			}

			for (int i = 0; i < Config.MAX_PLAYERS; i++) {
				if (players[i] == null || !players[i].isActive) {
					continue;
				}
				try {
					if (players[i].disconnected
							&& (System.currentTimeMillis()
									- players[i].logoutDelay > 10000
									|| players[i].properLogout || kickAllPlayers)) {
						if (players[i].inTrade) {
							final Client o = (Client) PlayerHandler.players[players[i].tradeWith];
							if (o != null) {
								o.getTradeAndDuel().declineTrade();
							}
						}
						if (players[i].duelStatus == 5) {
							final Client o1 = (Client) PlayerHandler.players[players[i].duelingWith];
							if (o1 != null) {
								o1.getTradeAndDuel().duelVictory();
							}
						} else if (players[i].duelStatus <= 4
								&& players[i].duelStatus >= 1) {
							final Client o1 = (Client) PlayerHandler.players[players[i].duelingWith];
							if (o1 != null) {
								o1.getTradeAndDuel().declineDuel();
							}
						}

						final Client o1 = (Client) PlayerHandler.players[i];
						if (PlayerSave.saveGame(o1)) {
							System.out
									.println("Game saved for player "
											+ Misc.properPlayerName(players[i].playerName));
						} else {
							System.out
									.println("Could not save for "
											+ Misc.properPlayerName(players[i].playerName));
						}
						removePlayer(players[i]);
						players[i] = null;
					} else {
						// if(o.g) {
						if (!players[i].initialized) {
							players[i].initialize();
							players[i].initialized = true;
						} else {
							players[i].update();
						}
						// }
					}
				} catch (final Exception e) {
					e.printStackTrace();
				}
			}

			if (updateRunning && !updateAnnounced) {
				updateAnnounced = true;
				Server.UpdateServer = true;
			}
			if (updateRunning
					&& (System.currentTimeMillis() - updateStartTime > (updateSeconds * 1000))) {
				kickAllPlayers = true;
			}

			for (int i = 0; i < Config.MAX_PLAYERS; i++) {
				if (players[i] == null || !players[i].isActive) {
					continue;
				}
				try {
					players[i].clearUpdateFlags();
				} catch (final Exception e) {
					e.printStackTrace();
				}
			}
		}
	}

	private void removePlayer(Player plr) {
		if (plr.privateChat != 2) {
			for (int i = 1; i < Config.MAX_PLAYERS; i++) {
				if (players[i] == null || players[i].isActive == false) {
					continue;
				}
				final Client o = (Client) PlayerHandler.players[i];
				if (o != null) {
					o.getPA().updatePM(plr.playerId, 0);
				}
			}
		}
		plr.destruct();
	}

	public void updateNPC(Player plr, Stream str) {
		synchronized (plr) {
			updateBlock.currentOffset = 0;

			str.createFrameVarSizeWord(65);
			str.initBitAccess();

			str.writeBits(8, plr.npcListSize);
			final int size = plr.npcListSize;
			plr.npcListSize = 0;
			for (int i = 0; i < size; i++) {
				if (plr.RebuildNPCList == false
						&& plr.withinDistance(plr.npcList[i]) == true) {
					plr.npcList[i].updateNPCMovement(str);
					plr.npcList[i].appendNPCUpdateBlock(updateBlock);
					plr.npcList[plr.npcListSize++] = plr.npcList[i];
				} else {
					final int id = plr.npcList[i].npcId;
					plr.npcInListBitmap[id >> 3] &= ~(1 << (id & 7));
					str.writeBits(1, 1);
					str.writeBits(2, 3);
				}
			}

			for (int i = 0; i < NPCHandler.maxNPCs; i++) {
				if (NPCHandler.npcs[i] != null) {
					final int id = NPCHandler.npcs[i].npcId;
					if (plr.RebuildNPCList == false
							&& (plr.npcInListBitmap[id >> 3] & (1 << (id & 7))) != 0) {

					} else if (plr.withinDistance(NPCHandler.npcs[i]) == false) {

					} else {
						plr.addNewNPC(NPCHandler.npcs[i], str, updateBlock);
					}
				}
			}

			plr.RebuildNPCList = false;

			if (updateBlock.currentOffset > 0) {
				str.writeBits(14, 16383);
				str.finishBitAccess();
				str.writeBytes(updateBlock.buffer, updateBlock.currentOffset, 0);
			} else {
				str.finishBitAccess();
			}
			str.endFrameVarSizeWord();
		}
	}

	public void updatePlayer(Player plr, Stream str) {
		synchronized (plr) {
			updateBlock.currentOffset = 0;
			if (updateRunning && !updateAnnounced) {
				str.createFrame(114);
				str.writeWordBigEndian(updateSeconds * 50 / 30);
			}
			plr.updateThisPlayerMovement(str);
			final boolean saveChatTextUpdate = plr.isChatTextUpdateRequired();
			plr.setChatTextUpdateRequired(false);
			plr.appendPlayerUpdateBlock(updateBlock);
			plr.setChatTextUpdateRequired(saveChatTextUpdate);
			str.writeBits(8, plr.playerListSize);
			int size = plr.playerListSize;
			if (size > 255) {
				size = 255;
			}
			plr.playerListSize = 0;
			for (int i = 0; i < size; i++) {
				if (!plr.didTeleport && !plr.playerList[i].didTeleport
						&& plr.withinDistance(plr.playerList[i])) {
					plr.playerList[i].updatePlayerMovement(str);
					plr.playerList[i].appendPlayerUpdateBlock(updateBlock);
					plr.playerList[plr.playerListSize++] = plr.playerList[i];
				} else {
					final int id = plr.playerList[i].playerId;
					plr.playerInListBitmap[id >> 3] &= ~(1 << (id & 7));
					str.writeBits(1, 1);
					str.writeBits(2, 3);
				}
			}

			for (int i = 0; i < Config.MAX_PLAYERS; i++) {
				if (players[i] == null || !players[i].isActive
						|| players[i] == plr) {
					continue;
				}
				final int id = players[i].playerId;
				if ((plr.playerInListBitmap[id >> 3] & (1 << (id & 7))) != 0) {
					continue;
				}
				if (!plr.withinDistance(players[i])) {
					continue;
				}
				plr.addNewPlayer(players[i], str, updateBlock);
			}

			if (updateBlock.currentOffset > 0) {
				str.writeBits(11, 2047);
				str.finishBitAccess();
				str.writeBytes(updateBlock.buffer, updateBlock.currentOffset, 0);
			} else {
				str.finishBitAccess();
			}

			str.endFrameVarSizeWord();
		}
	}

	public void updatePlayerNames() {
		playerCount = 0;
		for (int i = 0; i < Config.MAX_PLAYERS; i++) {
			if (players[i] != null) {
				playersCurrentlyOn[i] = players[i].playerName;
				playerCount++;
			} else {
				playersCurrentlyOn[i] = "";
			}
		}
	}

}