/*******************************************************************************
 * Copyright (c) 2013 <Project SWG>
 * 
 * This File is part of NGECore2.
 * 
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU Lesser General Public License as published by
 * the Free Software Foundation, either version 3 of the License, or
 * (at your option) any later version.
 * 
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU Lesser General Public License for more details.
 * 
 * You should have received a copy of the GNU Lesser General Public License
 * along with this program.  If not, see <http://www.gnu.org/licenses/>.
 * 
 * Using NGEngine to work with NGECore2 is making a combined work based on NGEngine. 
 * Therefore all terms and conditions of the GNU Lesser General Public License cover the combination.
 ******************************************************************************/
package resources.objects.player;

import java.nio.ByteOrder;
import java.util.BitSet;
import java.util.Map.Entry;

import org.apache.mina.core.buffer.IoBuffer;

import engine.resources.common.CRC;

import resources.common.StringUtilities;
import resources.objects.ObjectMessageBuilder;
import resources.objects.waypoint.WaypointObject;

public class PlayerMessageBuilder extends ObjectMessageBuilder {
	
	public static final String SPY = "spy_1a";
	public static final String SMUGGLER = "smuggler_1a";
	public static final String OFFICER = "officer_1a";
	public static final String JEDI = "force_sensitive_1a";
	public static final String COMMANDO = "commando_1a";
	public static final String ENTERTAINER = "entertainer_1a";
	public static final String MEDIC = "medic_1a";
	public static final String BOUNTYHUNTER = "bounty_hunter_1a";

	
	public PlayerMessageBuilder(PlayerObject playerObject) {
		setObject(playerObject);
	}

	public IoBuffer buildBaseline3() {
		
		PlayerObject player = (PlayerObject) object;
		
		IoBuffer buffer = bufferPool.allocate(100, false).order(ByteOrder.LITTLE_ENDIAN);
		buffer.setAutoExpand(true);
		buffer.putShort((short) 0x14);
		buffer.putFloat(1);
		buffer.put(getAsciiString("string_id_table"));
		buffer.putInt(0);	// spacer
		buffer.putShort((short) 0);	
		buffer.putInt(0);	// custom name
		buffer.putInt(0);	// volume
		buffer.putInt(0);	// generic int
		
		buffer.putInt(4);	// flag bitmask list size
		buffer.putInt(0);	
		buffer.putInt(0);	
		buffer.putInt(0);	
		buffer.putInt(0);	

		buffer.putInt(4);	// profile bitmask list size
		buffer.putInt(0);	
		buffer.putInt(0);	
		buffer.putInt(0);	
		buffer.putInt(0);	

		if(player.getTitle() == null || player.getTitle().length() < 1)
			buffer.putShort((short) 0);
		else
			buffer.put(getAsciiString(player.getTitle()));	
		
		buffer.putInt(0); // born date?
		
		buffer.putInt(player.getTotalPlayTime()); // total play time?
		
		buffer.putInt(getProfData(player.getProfession())); // prof icon
		
		buffer.put(getAsciiString(player.getProfession()));	
		buffer.putInt(0); // GCW
		buffer.putInt(0); // PvP Kills
		buffer.putLong(0); // Lifetime GCW
		buffer.putInt(0); // Lifetime PvP Kills
		buffer.putInt(player.getCollections().length);
		buffer.putInt(player.getHighestSetBit());
		buffer.put(player.getCollections());
		buffer.putInt(0); // Unknown, part of one delta, maybe a list
		buffer.putInt(0); // Unknown, part of one delta, maybe a list
		buffer.put((byte) 0); // Unknown Boolean used in Tansarii
		buffer.put((byte) 0); // Unknown Boolean used in Tansarii
		
		int size = buffer.position();

		buffer = bufferPool.allocate(size, false).put(buffer.array(), 0, size);

		
		buffer.flip();
		buffer = createBaseline("PLAY", (byte) 3, buffer, size);

		return buffer;
		
	}
	
	public IoBuffer buildBaseline6() {
		
		PlayerObject player = (PlayerObject) object;
		
		IoBuffer buffer = bufferPool.allocate(100, false).order(ByteOrder.LITTLE_ENDIAN);
		buffer.setAutoExpand(true);
		buffer.putShort((short) 0x11);
		buffer.putInt((short) 0x8A);
		
		buffer.put(getAsciiString("string_id_table"));
		
		buffer.put((byte) 0);	// unk
		buffer.putShort((short) 0);	// unk
		buffer.putInt(0); // unk
		buffer.putInt(0); // unk
		buffer.putInt(0); // unk
		buffer.putInt(0); // unk
		buffer.putInt(0); // unk
		buffer.putInt(0); // unk
		if(player.getHome() == null || player.getHome().length() < 1) {
			buffer.putShort((short) 0);
		} else {
			buffer.put(getAsciiString(player.getHome()));
		}
		buffer.putInt(0); // unk
		buffer.put((byte) 0);	// unk
		buffer.putInt(0); // unk
		buffer.putInt(0); // unk
		buffer.putInt(0); // unk
		buffer.putInt(0); // unk
		buffer.putInt(0); // unk
		buffer.putInt(0); // unk

		int size = buffer.position();

		buffer = bufferPool.allocate(size, false).put(buffer.array(), 0, size);

		
		buffer.flip();
		buffer = createBaseline("PLAY", (byte) 6, buffer, size);

		return buffer;
		
	}

	public IoBuffer buildBaseline8() {
	
		PlayerObject player = (PlayerObject) object;
			
		IoBuffer buffer = bufferPool.allocate(100, false).order(ByteOrder.LITTLE_ENDIAN);
		buffer.setAutoExpand(true);
		buffer.putShort((short) 0x09);
		
		if(player.getXpList().isEmpty()) {
			buffer.putInt(0); 
			buffer.putInt(0); 
		} else {
			buffer.putInt(player.getXpList().size()); 
			buffer.putInt(0); 
			
			// no need for locking here, concurrent hash map iterator wont throw concurrency exceptions and multiple thread access at zone in is unlikely to occur for the PlayerObject
			for(Entry<String, Integer> entry : player.getXpList().entrySet()) {
					
				buffer.put((byte) 0);	
				buffer.put(getAsciiString(entry.getKey()));
				buffer.putInt(entry.getValue()); 

			}

		}
		
		if(player.getWaypoints().isEmpty()) {
			buffer.putInt(0); 
			buffer.putInt(0); 
		} else {
			buffer.putInt(player.getWaypoints().size()); 
			buffer.putInt(0); 

			synchronized(player.getWaypoints()) {
				
				for(WaypointObject waypoint : player.getWaypoints()) {
					
					buffer.put((byte) 0);	
					buffer.putLong(waypoint.getObjectID());
					buffer.putInt(waypoint.getCellId());
					buffer.putFloat(waypoint.getPosition().x);
					buffer.putFloat(waypoint.getPosition().y);
					buffer.putFloat(waypoint.getPosition().z);
					buffer.putLong(waypoint.getLocationNetworkId());
					buffer.putInt(waypoint.getPlanetCRC());
					buffer.put(getUnicodeString(waypoint.getName()));
					buffer.putLong(waypoint.getObjectID());
					buffer.put(waypoint.getColor());	
					buffer.put((byte) (waypoint.isActive() ? 1 : 0));	

				}
				
			}
		}
		
		buffer.putInt(100); // Current force power ?
		buffer.putInt(100); // Max force power ?
		buffer.putInt(0); // Current FS Quest List size ?
		buffer.putInt(0); // Current FS Quest List update counter ?
		
		buffer.putInt(0); // Completed FS Quest List size ?
		buffer.putInt(0); // Completed FS Quest List update counter ?
		
		buffer.putInt(0); // Quest Journal List size ?
		buffer.putInt(0); // Quest Journal List update counter ?

		buffer.putInt(0); // unk

		buffer.put(getAsciiString(player.getProfessionWheelPosition()));
		int size = buffer.position();
		buffer = bufferPool.allocate(size, false).put(buffer.array(), 0, size);

		buffer.flip();
		buffer = createBaseline("PLAY", (byte) 8, buffer, size);
	
		return buffer;
	
}

	public IoBuffer buildBaseline9() {
	
		PlayerObject player = (PlayerObject) object;
		
		IoBuffer buffer = bufferPool.allocate(100, false).order(ByteOrder.LITTLE_ENDIAN);
		buffer.setAutoExpand(true);
		
		buffer.putShort((short) 0x1F);
		
		buffer.putInt(0); // ExperimentationFlag?
		buffer.putInt(0); // CraftingStage?

		buffer.putLong(0); // Nearest Crafting Station id ?

		
		buffer.putInt(0); // Draft Schematic List Size
		buffer.putInt(0); // Draft Schematic List update counter
		
		buffer.putInt(0); // ExperimentationPoints?
		buffer.putInt(0); // CraftingStage?

		buffer.putInt(8); // unk
		
		buffer.putInt(0); // unk

		if(player.getFriendList().isEmpty()) {
			buffer.putInt(0); 
			buffer.putInt(0); 
		} else {
			buffer.putInt(player.getFriendList().size()); 
			buffer.putInt(player.getFriendListUpdateCounter()); 

			synchronized(player.getFriendList()) {
				
				for(String friend : player.getFriendList()) {
					buffer.put(getAsciiString(friend));
				}
				
			}
		}
		
		if(player.getIgnoreList().isEmpty()) {
			buffer.putInt(0); 
			buffer.putInt(0); 
		} else {
			buffer.putInt(player.getIgnoreList().size()); 
			buffer.putInt(player.getIgnoreListUpdateCounter()); 

			synchronized(player.getIgnoreList()) {
				
				for(String ignored : player.getIgnoreList()) {
					buffer.put(getAsciiString(ignored));
				}
				
			}
		}
		
		buffer.putInt(1);
		buffer.putInt(0);	// Current stomach unused in NGE
		buffer.putInt(0x64);	// Max stomach unused in NGE
		buffer.putInt(0);	// Current drink unused in NGE
		buffer.putInt(0x64);	// Max drink unused in NGE
		buffer.putInt(0);	// Current consumable unused in NGE
		buffer.putInt(0x64);	// Max consumable unused in NGE

		buffer.putInt(0);
		buffer.putInt(0);
		
		buffer.putInt(0);
		buffer.putInt(3);
		buffer.putInt(0);
		buffer.putInt(0);
		
		buffer.putInt(0);
		buffer.putInt(0);
		buffer.putInt(0);
		buffer.putInt(0);
		buffer.putInt(0);
		
		buffer.putInt(0);
		buffer.putInt(2);
		buffer.putInt(0);
		buffer.putInt(0);
		buffer.putInt(0);
		
		buffer.putInt(0);
		buffer.putInt(0);
		buffer.putInt(0);
		buffer.putInt(0);
		buffer.putInt(0);
		
		buffer.putInt(4); // jedi state???
		buffer.putShort((short) 0);
		int size = buffer.position();

		buffer = bufferPool.allocate(size, false).put(buffer.array(), 0, size);

		
		buffer.flip();
		buffer = createBaseline("PLAY", (byte) 9, buffer, size);
	
		return buffer;
	
	}
	
	public IoBuffer buildTitleDelta(String title) {
		IoBuffer buffer = bufferPool.allocate(4 + getAsciiString(title).length, false).order(ByteOrder.LITTLE_ENDIAN);
		buffer.put(getAsciiString(title));
		int size = buffer.position();
		buffer.flip();
		buffer = createDelta("PLAY", (byte) 3, (short) 1, (short) 0x07, buffer, size + 4);
		return buffer;
		
	}
	
	public IoBuffer buildCollectionsDelta(byte[] collections, int highestSetBit) {
		IoBuffer buffer = bufferPool.allocate(8 + collections.length, false).order(ByteOrder.LITTLE_ENDIAN);
		buffer.putInt(collections.length);
		buffer.putInt(highestSetBit);
		for (byte collection : collections) buffer.put(collection);
		int size = buffer.position();
		buffer.flip();
		buffer = createDelta("PLAY", (byte) 3, (short) 1, (short) 16, buffer, size + 4);
		System.out.println(StringUtilities.bytesToHex(buffer.array()));
		return buffer;		
	}
	
	public IoBuffer buildXPListDelta(String type, int amount, boolean alreadyExists) {
		PlayerObject player = (PlayerObject) object;
		player.setXpListUpdateCounter(player.getXpListUpdateCounter() + 1);

		// Some problem with createDelta()
		IoBuffer result = bufferPool.allocate(42 + type.length(), false).order(ByteOrder.LITTLE_ENDIAN);
		result.putShort((short) 5);
		result.putInt(CRC.StringtoCRC("BaselinesMessage"));
		result.putLong(object.getContainer().getObjectID());
		result.put("YALP".getBytes());
		result.put((byte) 8);
		result.putInt(19 + type.length());
		result.putShort((short) 1);
		result.putShort((short) 0);
		result.putInt(1);
		result.putInt(player.getXpListUpdateCounter());
		result.put((byte) ((alreadyExists) ? 2 : 0));
		result.putShort((short) type.length());
		result.put(type.getBytes());
		result.putInt(amount);
		
		return result.flip();
	}
	
	public IoBuffer buildWaypointAddDelta(WaypointObject waypoint) {
		
		PlayerObject player = (PlayerObject) object;
		IoBuffer buffer = bufferPool.allocate(59 + waypoint.getName().length() * 2, false).order(ByteOrder.LITTLE_ENDIAN);
		buffer.setAutoExpand(true);
		
		int nextCounter = player.getWaypointListUpdateCounter() + 1;
		player.setWaypointListUpdateCounter(nextCounter);
		buffer.putInt(1);
		buffer.putInt(player.getWaypointListUpdateCounter());
		
		buffer.put((byte) 0); // updateType (SubType)
		
		buffer.putLong(waypoint.getObjectID());
		buffer.putInt(waypoint.getCellId());
		
		buffer.putFloat(waypoint.getPosition().x);
		buffer.putFloat(waypoint.getPosition().y);
		buffer.putFloat(waypoint.getPosition().z);
		
		buffer.putLong(0); // networklocationId
		buffer.putInt(waypoint.getPlanetCRC());
		
		buffer.put(getUnicodeString(waypoint.getName()));
		buffer.putLong(waypoint.getObjectID());
		
		buffer.put((byte) waypoint.getColor());
		
		if (waypoint.isActive()) { buffer.put((byte) 1); } 
		else { buffer.put((byte) 0); }
		
		int size = buffer.position();
		buffer.flip();
		
		buffer = createDelta("PLAY", (byte) 8, (short) 1, (short) 1, buffer, size + 4);
		//System.out.println("WaypointAdd: " + buffer.getHexDump());
		return buffer;
		
	}
	
	public IoBuffer buildWaypointRemoveDelta(WaypointObject waypoint) {
		
		IoBuffer buffer = bufferPool.allocate(59 + waypoint.getName().length() * 2, false).order(ByteOrder.LITTLE_ENDIAN);
		PlayerObject player = (PlayerObject) object;
		
		int nextCounter = player.getWaypointListUpdateCounter() + 1;
		player.setWaypointListUpdateCounter(nextCounter);

		buffer.putInt(1);
		buffer.putInt(player.getWaypointListUpdateCounter());
		
		buffer.put((byte) 1); // updateType (SubType)
		
		buffer.putLong(waypoint.getObjectID());
		buffer.putInt(waypoint.getCellId());
		
		buffer.putFloat(waypoint.getPosition().x);
		buffer.putFloat(waypoint.getPosition().y);
		buffer.putFloat(waypoint.getPosition().z);
		
		buffer.putLong(0); // networklocationId
		buffer.putInt(waypoint.getPlanetCRC());
		
		buffer.put(getUnicodeString(waypoint.getName()));
		buffer.putLong(waypoint.getObjectID());
		
		buffer.put((byte) waypoint.getColor());
		
		if (waypoint.isActive()) { buffer.put((byte) 1); }
		else { buffer.put((byte) 0); }
		
		int size = buffer.position();
		buffer.flip();
		
		buffer = createDelta("PLAY", (byte) 8, (short) 1, (short) 1, buffer, size + 4);
		
		return buffer;
		
	}
	
	public IoBuffer buildWaypointUpdateDelta(WaypointObject waypoint) {
		
		IoBuffer buffer = bufferPool.allocate(59 + waypoint.getName().length() * 2, false).order(ByteOrder.LITTLE_ENDIAN);
		PlayerObject player = (PlayerObject) object;
		
		int nextCounter = player.getWaypointListUpdateCounter() + 1;
		player.setWaypointListUpdateCounter(nextCounter);

		buffer.putInt(1);
		buffer.putInt(player.getWaypointListUpdateCounter());
		
		buffer.put((byte) 2); // updateType (SubType)
		
		buffer.putLong(waypoint.getObjectID());
		buffer.putInt(waypoint.getCellId());
		
		buffer.putFloat(waypoint.getPosition().x);
		buffer.putFloat(waypoint.getPosition().y);
		buffer.putFloat(waypoint.getPosition().z);
		
		buffer.putLong(0); // networklocationId << cluster system I guess?
		buffer.putInt(waypoint.getPlanetCRC());
		
		buffer.put(getUnicodeString(waypoint.getName()));
		buffer.putLong(waypoint.getObjectID());
		
		buffer.put((byte) waypoint.getColor());
		
		if (waypoint.isActive()) { buffer.put((byte) 1); }
		else { buffer.put((byte) 0); } // isActive. Activates automatically when created.
		
		int size = buffer.position();
		buffer.flip();
		
		buffer = createDelta("PLAY", (byte) 8, (short) 1, (short) 1, buffer, size + 4);
		
		return buffer;
		
	}
	
	public IoBuffer buildTotalPlayTimeDelta(int totalPlayTime) {
		
		IoBuffer buffer = bufferPool.allocate(4, false).order(ByteOrder.LITTLE_ENDIAN);
		buffer.putInt(totalPlayTime);
		int size = buffer.position();
		buffer.flip();
		buffer = createDelta("PLAY", (byte) 3, (short) 1, (short) 0x09, buffer, size + 4);
		
		return buffer;
		
	}
	
	public IoBuffer buildFriendAddDelta(String friend) {
		
		IoBuffer buffer = bufferPool.allocate(13 + friend.length(), false).order(ByteOrder.LITTLE_ENDIAN);
		PlayerObject player = (PlayerObject) object;
		
		buffer.putInt(1);
		buffer.putInt(player.getFriendListUpdateCounter());
		
		buffer.put((byte) 1); // updateType (SubType)
		
		buffer.putShort((short) player.getFriendList().indexOf(friend));
		buffer.put(getAsciiString(friend));
		
		int size = buffer.position();
		buffer.flip();
		
		buffer = createDelta("PLAY", (byte) 9, (short) 1, (short) 7, buffer, size + 4);
		
		return buffer;
		
	}
	
	public IoBuffer buildFriendRemoveDelta(String friend) {
		
		IoBuffer buffer = bufferPool.allocate(11, false).order(ByteOrder.LITTLE_ENDIAN);
		PlayerObject player = (PlayerObject) object;
		
		buffer.putInt(1);
		buffer.putInt(player.getFriendListUpdateCounter());

		buffer.put((byte) 0); // updateType (SubType)
		
		buffer.putShort((short) player.getFriendList().indexOf(friend));
		
		int size = buffer.position();
		buffer.flip();
		
		buffer = createDelta("PLAY", (byte) 9, (short) 1, (short) 7, buffer, size + 4);
		
		return buffer;
		
	}
	
	public IoBuffer buildIgnoreAddDelta(String ignoreName) {
		IoBuffer buffer = bufferPool.allocate(30, false).order(ByteOrder.LITTLE_ENDIAN);
		PlayerObject player = (PlayerObject) object;
		
		buffer.putInt(1);
		buffer.putInt(player.getIgnoreListUpdateCounter());
		
		buffer.put((byte) 1); // updateType (SubType)
		
		buffer.putShort((short) player.getIgnoreList().indexOf(ignoreName));
		buffer.put(getAsciiString(ignoreName));
		
		int size = buffer.position();
		buffer.flip();
		
		buffer = createDelta("PLAY", (byte) 9, (short) 1, (short) 8, buffer, size + 4);
		
		return buffer;
	}
	
	public IoBuffer buildIgnoreRemoveDelta(String removeName) {
		IoBuffer buffer = bufferPool.allocate(30, false).order(ByteOrder.LITTLE_ENDIAN);
		PlayerObject player = (PlayerObject) object;
		
		buffer.putInt(1);
		buffer.putInt(player.getIgnoreListUpdateCounter());
		
		buffer.put((byte) 0);
		buffer.putShort((short) player.getIgnoreList().indexOf(removeName));
		
		int size = buffer.position();
		buffer.flip();
		
		buffer = createDelta("PLAY", (byte) 9, (short) 1, (short) 8, buffer, size + 4);
		
		return buffer;
	}
	
	public int getProfData(String profession) {
		
		switch (profession) {
		
			case SPY:
				return 0x23;
			case SMUGGLER:
				return 0x19;
			case OFFICER:
				return 0x0F;
			case JEDI:
				return 0x28;
			case COMMANDO:
				return 0x1E;
			case ENTERTAINER:
				return 0x05;
			case MEDIC:
				return 0x0A;
			case BOUNTYHUNTER:
				return 0x14;
			default:
				return 0x00;
				
		}
	}

	@Override
	public void sendListDelta(byte viewType, short updateType, IoBuffer buffer) {
		// TODO Auto-generated method stub
		
	}

	@Override
	public void sendBaselines() {
		// TODO Auto-generated method stub
		
	}

}