l2j-server-game/L2_GameServer/java/com/l2jserver/gameserver/network/L2GamePacketHandler.java

/*
 * This program is free software: you can redistribute it and/or modify it under
 * the terms of the GNU 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 General Public License for more
 * details.
 * 
 * You should have received a copy of the GNU General Public License along with
 * this program. If not, see <http://www.gnu.org/licenses/>.
 */
package com.l2jserver.gameserver.network;

import java.nio.ByteBuffer;
import java.util.concurrent.RejectedExecutionException;
import java.util.logging.Logger;


import org.mmocore.network.IClientFactory;
import org.mmocore.network.IMMOExecutor;
import org.mmocore.network.IPacketHandler;
import org.mmocore.network.MMOConnection;
import org.mmocore.network.ReceivablePacket;

import com.l2jserver.Config;
import com.l2jserver.gameserver.ThreadPoolManager;
import com.l2jserver.gameserver.network.L2GameClient.GameClientState;
import com.l2jserver.gameserver.network.clientpackets.*;
import com.l2jserver.util.Util;

/**
 * Stateful Packet Handler<BR>
 * The Stateful approach prevents the server from handling inconsistent packets, examples:<BR>
 * <li>Clients sends a MoveToLocation packet without having a character attached. (Potential errors handling the packet).</li>
 * <li>Clients sends a RequestAuthLogin being already authed. (Potential exploit).</li>
 * <BR><BR>
 * Note: If for a given exception a packet needs to be handled on more then one state, then it should be added to all these states.
 * @author  KenM
 */
public final class L2GamePacketHandler implements IPacketHandler<L2GameClient>, IClientFactory<L2GameClient>, IMMOExecutor<L2GameClient>
{
    private static final Logger _log = Logger.getLogger(L2GamePacketHandler.class.getName());

	// implementation
	public ReceivablePacket<L2GameClient> handlePacket(ByteBuffer buf, L2GameClient client)
	{
		if (client.isDetached())
			return null;

		int opcode = buf.get() & 0xFF;
		int id3;

		ReceivablePacket<L2GameClient> msg = null;
		GameClientState state = client.getState();

		switch (state)
		{
			case CONNECTED:
                switch (opcode)
                {
                	case 0x0e:
                        msg = new ProtocolVersion();
                        break;
                    case 0x2b:
                        msg = new AuthLogin();
                        break;
                    default:
                        printDebug(opcode, buf, state, client);
                        break;
                }
				break;
			case AUTHED:
				switch (opcode)
				{
					case 0x00:
						msg = new Logout();
						break;
                    case 0x0c:
                        msg = new CharacterCreate();
                        break;
                    case 0x0d:
                        msg = new CharacterDelete();
                        break;
                    case 0x12:
                        msg = new CharacterSelect();
                        break;
                    case 0x13:
                        msg = new NewCharacter();
                        break;
					case 0x7b:
						msg = new CharacterRestore();
						break;
					case 0xd0:
						int id2 = -1;
		            	if (buf.remaining() >= 2)
		            	{
		            		id2 = buf.getShort() & 0xffff;
		            	}
		            	else
		            	{
		            		if (Config.PACKET_HANDLER_DEBUG)
		            			_log.warning("Client: "+client.toString()+" sent a 0xd0 without the second opcode.");
		            		break;
		            	}
		            	
		            	switch (id2)
		            	{
		            		case 0x36:
		            			msg = new RequestGotoLobby();
		            			break;
		            		/*
		            		 * case 0x3d:
		            		 *
                             *  msg = new RequestAllFortressInfo();
                             *  break;
                             */
		            		case 0x5a:
		                    	id3 = 0;
		                        if (buf.remaining() >= 4)
		                        {
								    id3 = buf.getInt() & 0xffffffff;
		                        }
		                        else
		                        {
		                        	_log.warning("Client: "+client.toString()+" sent a 0xd0:0x5a without the third opcode.");
		                        	break;
		                        }
		                        switch (id3)
		                        {
		                        	case 0x00:
		                        		msg = new RequestExCubeGameChangeTeam();
		                        		break;
		                        }
		                    	break;
                            default:
                            	printDebugDoubleOpcode(opcode, id2, buf, state, client);
		            	}
		            	break;
					default:
						printDebug(opcode, buf, state, client);
						break;
				}
				break;
			case IN_GAME:
				switch(opcode)
				{
                    case 0x00:
                        msg = new Logout();
                        break;
                    case 0x01:
                        msg = new AttackRequest();
                        break;
                    case 0x03:
                        msg = new RequestStartPledgeWar();
                        break;
                    case 0x04:
                        msg = new RequestReplyStartPledgeWar();
                        break;
                    case 0x05:
                        msg = new RequestStopPledgeWar();
                        break;
                    case 0x06: // RequestSCCheck
                        msg = new RequestReplyStopPledgeWar();
                        break;
                    case 0x07:
                        msg = new RequestSurrenderPledgeWar();
                        break;
                    case 0x08:
                        msg = new RequestReplySurrenderPledgeWar();
                        break;
                    case 0x09:
                        msg = new RequestSetPledgeCrest();
                        break;
                    case 0x0b:
                        msg = new RequestGiveNickName();
                        break;
					case 0x0f:
						msg = new MoveBackwardToLocation();
						break;
					case 0x10:
						// Say
						break;
					case 0x11:
						msg = new EnterWorld();
						break;
                    case 0x14:
                        msg = new RequestItemList();
                        break;
                    case 0x15:
                    	// RequestEquipItem
                    	break;
                    case 0x16:
                        msg = new RequestUnEquipItem();
                        break;
                    case 0x17:
                        msg = new RequestDropItem();
                        break;
                    case 0x19:
                        msg = new UseItem();
                        break;
                    case 0x1a:
                        msg = new TradeRequest();
                        break;
                    case 0x1b:
                        msg = new AddTradeItem();
                        break;
                    case 0x1c:
                        msg = new TradeDone();
                        break;
					case 0x1f:
						msg = new Action();
						break;
                    case 0x22:
                        msg = new RequestLinkHtml();
                        break;
                    case 0x23:
                        msg = new RequestBypassToServer();
                        break;
                    case 0x24:
                        msg = new RequestBBSwrite();
                        break;
                    case 0x25:
                    	// RequestCreatePledge
                    	break;
                    case 0x26:
                        msg = new RequestJoinPledge();
                        break;
                    case 0x27:
                        msg = new RequestAnswerJoinPledge();
                        break;
                    case 0x28:
                        msg = new RequestWithdrawalPledge();
                        break;
                    case 0x29:
                        msg = new RequestOustPledgeMember();
                        break;
                    case 0x2c:
                        msg = new RequestGetItemFromPet();
                        break;
                    case 0x2e:
                        msg = new RequestAllyInfo();
                        break;
                    case 0x2f:
                        msg = new RequestCrystallizeItem();
                        break;
                    case 0x30:
                        msg = new RequestPrivateStoreManageSell();
                        break;
                    case 0x31:
                        msg = new SetPrivateStoreListSell();
                        break;
                    case 0x32:
                        msg = new AttackRequest();
                        break;
                    case 0x33:
                    	// RequestTeleportPacket
                    	break;
					case 0x34:
						//msg = new RequestSocialAction();
						client.handleCheat("Used obsolete RequestSocialAction packet");
						break;
					case 0x35:
						//msg = new ChangeMoveType2();
						client.handleCheat("Used obsolete ChangeMoveType packet");
						break;
					case 0x36:
						//msg = new ChangeWaitType2();
						client.handleCheat("Used obsolete ChangeWaitType packet");
						break;
					case 0x37:
						msg = new RequestSellItem();
						break;
					case 0x38:
						// RequestMagicSkillList
						break;
                    case 0x39:
                        msg = new RequestMagicSkillUse();
                        break;
                    case 0x3a: // SendApperingPacket
                        msg = new Appearing();
                        break;
                    case 0x3b:
                        if (Config.ALLOW_WAREHOUSE)
                            msg = new SendWareHouseDepositList();
                        break;
                    case 0x3c:
                        msg = new SendWareHouseWithDrawList();
                        break;
                    case 0x3d:
                        msg = new RequestShortCutReg();
                        break;
                    case 0x3f:
                        msg = new RequestShortCutDel();
                        break;
					case 0x40:
						msg = new RequestBuyItem();
						break;
					case 0x41:
						// RequestDismissPledge
						break;
					case 0x42:
						msg = new RequestJoinParty();
						break;
					case 0x43:
						msg = new RequestAnswerJoinParty();
						break;
					case 0x44:
						msg = new RequestWithDrawalParty();
						break;
					case 0x45:
						msg = new RequestOustPartyMember();
						break;
					case 0x46:
						// RequestDismissParty
						break;
					case 0x47:
						msg = new CannotMoveAnymore();
						break;
					case 0x48:
						msg = new RequestTargetCanceld();
						break;
					case 0x49:
						msg = new Say2();
						break;
					case 0x4a:
						int id_2 = -1;
		            	if (buf.remaining() >= 2)
		            	{
		            		id_2 = buf.getShort() & 0xffff;
		            	}
		            	else
		            	{
		            		if (Config.PACKET_HANDLER_DEBUG)
		            			_log.warning("Client: "+client.toString()+" sent a 0x4a without the second opcode.");
		            		break;
		            	}
                        switch (id_2)
                        {
                        	case 0x00:
                        		// SuperCmdCharacterInfo
                        		break;
                        	case 0x01:
                        		// SuperCmdSummonCmd
                        		break;
                        	case 0x02:
                        		// SuperCmdServerStatus
                        		break;
                        	case 0x03:
                        		// SendL2ParamSetting
                        		break;
                        default:
                        	this.printDebugDoubleOpcode(opcode, id_2, buf, state, client);
                            break;
                        }
                        break;
					case 0x4d:
						msg = new RequestPledgeMemberList();
						break;
					case 0x4f:
						//RequestMagicList
						break;
					case 0x50:
						msg = new RequestSkillList();
						break;
					case 0x52:
						msg = new MoveWithDelta(); 
						break;
					case 0x53:
						msg = new RequestGetOnVehicle();  
						break;
					case 0x54:
						msg = new RequestGetOffVehicle();
						break;
					case 0x55:
						msg = new AnswerTradeRequest();
						break;
					case 0x56:
						msg = new RequestActionUse();
						break;
					case 0x57:
						msg = new RequestRestart();
						break;
					case 0x58:
						msg = new RequestSiegeInfo();   
						break;
					case 0x59:
						msg = new ValidatePosition();
						break;
					case 0x5a:
						// RequestSEKCustom
						break;
					case 0x5b:
						// StartRotating
						break;
					case 0x5c:
						// FinishRotating
						break;
					case 0x5e:
						msg = new RequestShowBoard();
						break;
					case 0x5f:
						msg = new RequestEnchantItem();
						break;
					case 0x60:
						msg = new RequestDestroyItem();
						break;
                    case 0x62:
                        msg = new RequestQuestList();
                        break;
                    case 0x63: // RequestDestroyQuest
                        msg = new RequestQuestAbort();  
                        break;              
                    case 0x65:
                        msg = new RequestPledgeInfo();
                        break;
                    case 0x66:
                        msg = new RequestPledgeExtendedInfo();   
                        break;
                    case 0x67:
                        msg = new RequestPledgeCrest();
                        break;
		            case 0x6b:
		            	msg = new RequestSendFriendMsg();
		            	break;
		            case 0x6c:
		                msg = new RequestShowMiniMap();
		                break;
		            case 0x6d:
		            	// RequestSendMsnChatLog
						break;
		            case 0x6e: //RequestReload
		            	msg = new RequestRecordInfo();
		                break;
                    case 0x6f:
                        msg = new RequestHennaEquip();
                        break;
                    case 0x70:
                    	msg = new RequestHennaRemoveList();
                    	break;
                    case 0x71:
                    	msg = new RequestHennaItemRemoveInfo();
                    	break;
                    case 0x72:
                    	msg = new RequestHennaRemove();
                    	break;
                    case 0x73:
                        msg = new RequestAquireSkillInfo();
                        break;
					case 0x74:
						msg = new SendBypassBuildCmd();
						break;
					case 0x75:
						msg = new RequestMoveToLocationInVehicle();
						break;
					case 0x76:
						msg = new CannotMoveAnymoreInVehicle();
						break;
					case 0x77:
						msg = new RequestFriendInvite();
						break;
					case 0x78: // RequestFriendAddReply
						msg = new RequestAnswerFriendInvite();
						break;
					case 0x79:
						msg = new RequestFriendList();
						break;
					case 0x7a:
						msg = new RequestFriendDel();
						break;
					case 0x7c:
						msg = new RequestAquireSkill();
						break;
					case 0x7d:
						msg = new RequestRestartPoint();
						break;
					case 0x7e:
						msg = new RequestGMCommand();
						break;
                    case 0x7f:
                        msg = new RequestPartyMatchConfig();
                        break;
					case 0x80:
						msg = new RequestPartyMatchList();
						break;
					case 0x81:
						msg = new RequestPartyMatchDetail();
						break;
                    case 0x83:
                        msg = new RequestPrivateStoreBuy();
                        break;
                    case 0x85:
                        msg = new RequestTutorialLinkHtml();
                        break;
                    case 0x86:
                       	msg = new RequestTutorialPassCmdToServer();
                      	break;
                    case 0x87:
                        msg = new RequestTutorialQuestionMark();
                        break;
                    case 0x88:
                       	msg = new RequestTutorialClientEvent();
                      	break;
                    case 0x89:
                        msg = new RequestPetition();
                        break;
                    case 0x8a:
                        msg = new RequestPetitionCancel();
                        break;
                    case 0x8b:
                        msg = new RequestGmList();
                        break;
                    case 0x8c:
                        msg = new RequestJoinAlly();
                        break;
                    case 0x8d:
                        msg = new RequestAnswerJoinAlly();
                        break;
                    case 0x8e: // RequestWithdrawAlly
                        msg = new AllyLeave();
                        break;
                    case 0x8f: // RequestOustAlly
                        msg = new AllyDismiss();
                        break;
                    case 0x90:
                        msg = new RequestDismissAlly();
                        break;
                    case 0x91:
                        msg = new RequestSetAllyCrest();
                        break;
                    case 0x92:
                        msg = new RequestAllyCrest();
                        break;
                    case 0x93:
                        msg = new RequestChangePetName();
                        break;
                    case 0x94:
                        msg = new RequestPetUseItem();
                        break;
                    case 0x95:
                        msg = new RequestGiveItemToPet();
                        break;
					case 0x96:
						msg = new RequestPrivateStoreQuitSell();
						break;
					case 0x97:
						msg = new SetPrivateStoreMsgSell();
						break;
					case 0x98:
						msg = new RequestPetGetItem();
						break;
					case 0x99:
						msg = new RequestPrivateStoreManageBuy();
						break;
					case 0x9a:
						msg = new SetPrivateStoreListBuy ();
						break;
					case 0x9c:
						msg = new RequestPrivateStoreQuitBuy();
						break;
					case 0x9d:
						msg = new SetPrivateStoreMsgBuy();
						break;
					case 0x9f: // SendPrivateStoreBuyList
						msg = new RequestPrivateStoreSell();
						break;
					case 0xa0:
						//SendTimeCheckPacket
						break;
					case 0xa6:
						// RequestSkillCoolTime
						break;
					case 0xa7:
						//msg = new RequestPackageSendableItemList();
						break;
					case 0xa8:
						// msg = new RequestPackageSend();
						break;
					case 0xa9:
						msg = new RequestBlock();
						break;
					case 0xaa:
						msg = new RequestSiegeInfo();
						break;
					case 0xab:
		                msg = new RequestSiegeAttackerList();
		                break;
					case 0xac:
		                msg = new RequestSiegeDefenderList();
		                break;
					case 0xad:
		                msg = new RequestJoinSiege();
		                break;
					case 0xae:
					    msg = new RequestConfirmSiegeWaitingList();
					    break;
					case 0xaf:
						// RequestSetCastleSiegeTime
						break;
					case 0xb0:
						msg = new MultiSellChoose();
						break;
					case 0xb1:
						// NetPing
						break;
					case 0xb2:
						// RequestRemainTime
						break;
		            case 0xb3:
		            	msg = new BypassUserCmd();
		                break;
		            case 0xb4:
		            	msg = new SnoopQuit();
		            	break;
		            case 0xb5:
		                msg = new RequestRecipeBookOpen();
		                break;
		            case 0xb6: // RequestRecipeItemDelete
		                msg = new RequestRecipeBookDestroy();
		                break;
					case 0xb7:
						msg = new RequestRecipeItemMakeInfo();
					    break;
					case 0xb8:
						msg = new RequestRecipeItemMakeSelf();
					    break;
					case 0xb9:
						// RequestRecipeShopManageList
					    break;
		            case 0xba:
		            	msg = new RequestRecipeShopMessageSet();
		                break;
					case 0xbb:
						msg = new RequestRecipeShopListSet();
					    break;
					case 0xbc:
						msg = new RequestRecipeShopManageQuit();
					    break;
					case 0xbd:
						// RequestRecipeShopManageCancel
						break;
					case 0xbe:
						msg = new RequestRecipeShopMakeInfo();
					    break;
					case 0xbf:
						msg = new RequestRecipeShopMakeItem();
					    break;
					case 0xc0: // RequestRecipeShopSellList
						msg = new RequestRecipeShopManagePrev();
					    break;
					case 0xc1: // RequestObserverEndPacket
						msg = new ObserverReturn();
					    break;
					case 0xc2: // VoteSociality
						msg = new RequestEvaluate();
					    break;
					case 0xc3: // RequestHennaItemList
						msg = new RequestHennaDrawList();
					    break;
					case 0xc4:
						msg = new RequestHennaItemDrawInfo();
						break;
					case 0xc5:
		            	msg = new RequestBuySeed();
		            	break;
		            case 0xc6: // ConfirmDlg
						msg = new DlgAnswer();
						break;
		            case 0xc7: // RequestPreviewItem
						msg = new RequestWearItem();
						break;
		            case 0xc8:
		            	msg = new RequestSSQStatus();
		            	break;
		            case 0xc9:
		            	// PetitionVote
		            	break;
		            case 0xcb:
		                msg = new GameGuardReply();
		                break;
					case 0xcc:
						msg = new RequestPledgePower();
						break;
		            case 0xcd:
		                msg = new RequestMakeMacro();
		                break;
		            case 0xce:
						msg = new RequestDeleteMacro();
						break;
		            case 0xcf: // RequestProcureCrop
		            	msg = new RequestBuyProcure();
		            	break;
		            
		            case 0xd0:
		            	int id2 = -1;
		            	if (buf.remaining() >= 2)
		            	{
		            		id2 = buf.getShort() & 0xffff;
		            	}
		            	else
		            	{
		            		if (Config.PACKET_HANDLER_DEBUG)
		            			_log.warning("Client: "+client.toString()+" sent a 0xd0 without the second opcode.");
		            		break;
		            	}

		                switch (id2)
		                {
                            case 0x01:
                                msg = new RequestManorList();
                                break;
                            case 0x02:
                                msg = new RequestProcureCropList();
                                break;
                            case 0x03:
                                msg = new RequestSetSeed();
                                break;
                            case 0x04:
                                msg = new RequestSetCrop();
                                break;
                            case 0x05:
                                msg = new RequestWriteHeroWords();
                                break;
                            case 0x06:
                                msg = new RequestExAskJoinMPCC();
                                break;
                            case 0x07:
                                msg = new RequestExAcceptJoinMPCC();
                                break;
                            case 0x08:
                                msg = new RequestExOustFromMPCC();
                                break;
		                	case 0x09:
		                		msg = new RequestOustFromPartyRoom();
		                		break;
		                	case 0x0a:
		                		msg = new RequestDismissPartyRoom();
		                		break;
		                	case 0x0b:
		                		msg = new RequestWithdrawPartyRoom();
		                		break;
		                    case 0x0c: // RequestHandOverPartyMaster
		                        msg = new RequestChangePartyLeader();
		                        break;
		                    case 0x0d:
		                        msg = new RequestAutoSoulShot();
		                        break;
		                    case 0x0e:
		                        msg = new RequestExEnchantSkillInfo();
		                        break;
		                    case 0x0f:
		                    	msg = new RequestExEnchantSkill();
		                    	break;
		                    case 0x10:
		                    	msg = new RequestExPledgeCrestLarge();
		                    	break;
		                    case 0x11:
		                    	msg = new RequestExSetPledgeCrestLarge();
		                    	break;
                            case 0x12:
                                msg = new RequestPledgeSetAcademyMaster();
                                break;
                            case 0x13:
                                msg = new RequestPledgePowerGradeList();
                                break;
                            case 0x14:
                                msg = new RequestPledgeMemberPowerInfo();
                                break;
                            case 0x15:
                                msg = new RequestPledgeSetMemberPowerGrade();
                                break;
                            case 0x16:
                                msg = new RequestPledgeMemberInfo();
                                break;
                            case 0x17:
                                msg = new RequestPledgeWarList();
                                break;
                            case 0x18:
                                msg = new RequestExFishRanking();
                                break;
                            case 0x19:
                                msg = new RequestPCCafeCouponUse();
                                break;
                            case 0x1b:
                                msg = new RequestDuelStart();
                                break;
                            case 0x1c:
                                msg = new RequestDuelAnswerStart();
                                break;
                            case 0x1d:
                            	// RequestExSetTutorial
                            	break;
                            case 0x1e:
                                msg = new RequestExRqItemLink();
                                break;
                            case 0x1f:
                            	// CanNotMoveAnymoreAirShip
                            	break;
                            case 0x20:
                            	msg = new MoveToLocationInAirShip();
                            	break;
                            case 0x21:
                                msg = new RequestKeyMapping(); 
                                break;
                            case 0x22:
                            	// RequestSaveKeyMapping
                                break;
		                    case 0x23: 
		                     	msg = new RequestExRemoveItemAttribute(); 
		                     	break; 
                            case 0x24:
                                msg = new RequestSaveInventoryOrder();
                                break;
                            case 0x25:
                                msg = new RequestExitPartyMatchingWaitingRoom();
                                break;
                            case 0x26:
                                msg = new RequestConfirmTargetItem();
                                break;
                            case 0x27:
                                msg = new RequestConfirmRefinerItem();
                                break;
                            case 0x28:
                                msg = new RequestConfirmGemStone();
                                break;
		                    case 0x29:
		                    	msg = new RequestOlympiadObserverEnd();
		                    	break;
                            case 0x2a:
                                msg = new RequestCursedWeaponList();
                                break;
                            case 0x2b:
                                msg = new RequestCursedWeaponLocation();
                                break;
                            case 0x2c:
                                msg = new RequestPledgeReorganizeMember();
                                break;
                            case 0x2d:
                            	msg = new RequestExMPCCShowPartyMembersInfo();
                            	break;
                            case 0x2e:
                                msg = new RequestOlympiadMatchList();
                                break;
		                    case 0x2f:
		                    	msg = new RequestAskJoinPartyRoom();
		                    	break;
		                    case 0x30:
		                        msg = new AnswerJoinPartyRoom();
		                        break;
		                    case 0x31:
		                        msg = new RequestListPartyMatchingWaitingRoom();
		                        break;
                            case 0x32: // test me
                                msg = new RequestExEnchantSkillSafe();
                                break;
                            case 0x33: // test me
                                msg = new RequestExEnchantSkillUntrain();
                                break;
                            case 0x34: // test me
                            	msg = new RequestExEnchantSkillRouteChange();
                            	break;
                            case 0x35:
                                msg = new RequestExEnchantItemAttribute();
                                break;
                            case 0x36:
                                msg = new ExGetOnAirShip();
                                break;
                            case 0x38:
                            	// MoveToLocationAirShip
                            	break;
                            case 0x39:
                            	// RequestBidItemAuction
                            	break;
                            case 0x3a:
                            	// RequestInfoItemAuction
                            	break;
                            case 0x3b:
                            	// RequestExChangeName
                            	break;
                            case 0x3c:
                                msg = new RequestAllCastleInfo();
                                break;
                            case 0x3d:
                                msg = new RequestAllFortressInfo();
                                break;
                            case 0x3e:
                                msg = new RequestAllAgitInfo();
                                break;
		                    case 0x3f:
		                    	msg = new RequestFortressSiegeInfo();
		                    	break;
                            case 0x40:
                                msg = new RequestGetBossRecord();
                                break;
                            case 0x41:
                            	msg = new RequestRefine();
                                break;
                            case 0x42:
                                msg = new RequestConfirmCancelItem();
                                break;
		                    case 0x43:
		                    	msg = new RequestRefineCancel();
		                        break;
		                    case 0x44:
		                    	msg = new RequestExMagicSkillUseGround();
		                    	break;
		                    case 0x45:
		                    	msg = new RequestDuelSurrender();
		                    	break;
                            case 0x46:
                            	msg = new RequestExEnchantSkillInfoDetail();
                            	break;
		                    case 0x48:
		                    	msg = new RequestFortressMapInfo();
		                    	break;
		                    case 0x49:
		                    	// RequestPVPMatchRecord
		                    	break;
		                    case 0x4a:
		                    	msg = new SetPrivateStoreWholeMsg();
		                    	break;
		                    case 0x4b:
		                    	msg = new RequestDispel();
		                    	break;
		                    case 0x4c:
		                    	msg = new RequestExTryToPutEnchantTargetItem();
		                    	break;
		                    case 0x4d:
		                    	msg = new RequestExTryToPutEnchantSupportItem();
		                    	break;
		                    case 0x4e:
		                    	msg = new RequestExCancelEnchantItem();
		                    	break;
		                    case 0x4f:
		                    	msg = new RequestChangeNicknameColor();
		                    	break;
		                    case 0x50:
		                    	msg = new RequestResetNickname();
		                    	break;
		                    case 0x51:
		                        id3 = 0;
		                        if (buf.remaining() >= 2)
		                        {
								    id3 = buf.getShort() & 0xffff;
		                        }
		                        else
		                        {
		                        	_log.warning("Client: "+client.toString()+" sent a 0xd0:0x51 without the third opcode.");
		                        	break;
		                        }
		                        switch (id3)
		                        {
		                        	case 0x00:
		                        		msg = new RequestBookMarkSlotInfo();
		                        		break;
		                        	case 0x01:
		                        		msg = new RequestSaveBookMarkSlot();
		                        		break;
		                        	case 0x02:
		                        		msg = new RequestModifyBookMarkSlot();
		                        		break;
		                        	case 0x03:
		                        		msg = new RequestDeleteBookMarkSlot();
		                        		break;
		                        	case 0x04:
		                        		msg = new RequestTeleportBookMark();
		                        		break;
		                        	case 0x05:
		                        		// RequestChangeBookMarkSlot
		                        		break;
		                        default:
		                        	this.printDebugDoubleOpcode(opcode, id3, buf, state, client);
		                            break;
		                        }
		                        break;
		                    case 0x52:
		                    	//RequestWithDrawPremiumItem
		                    	break;
		                    case 0x53:
		                    	// RequestJump
		                    	break;
		                    case 0x54:
		                    	// RequestStartShowCrataeCubeRank
		                    	break;
		                    case 0x55:
		                    	// RequestStopShowCrataeCubeRank
		                    	break;
		                    case 0x56:
		                    	// NotifyStartMiniGame
		                    	break;
		                    case 0x57:
		                    	// RequestJoinDominionWar
		                    	break;
		                    case 0x58:
		                    	msg = new RequestDominionInfo();
		                    	break;
		                    case 0x59:
		                    	// RequestExCleftEnter
		                    	break;
		                    case 0x5a:
		                    	id3 = 0;
		                        if (buf.remaining() >= 4)
		                        {
								    id3 = buf.getInt() & 0xffffffff;
		                        }
		                        else
		                        {
		                        	_log.warning("Client: "+client.toString()+" sent a 0xd0:0x5a without the third opcode.");
		                        	break;
		                        }
		                        switch (id3)
		                        {
		                        	case 0x00:
		                        		msg = new RequestExCubeGameChangeTeam();
		                        		break;
		                        }
		                    	break;
		                    case 0x5b:
		                    	// EndScenePlayer
		                    	break;
		                    case 0x5c:
		                    	// RequestExBlockGameVote
		                    	break;
		                    case 0x63:
		                    	// RequestSeedPhase
		                    	break;
		                    case 0x65:
		                    	msg = new RequestPostItemList();
		                    	break;
		                    case 0x66:
		                    	msg = new RequestSendPost();
		                    	break;
		                    case 0x67:
		                    	msg = new RequestReceivedPostList();
		                    	break;
		                    case 0x68:
		                    	msg = new RequestDeleteReceivedPost();
		                    	break;
		                    case 0x69:
		                    	msg = new RequestReceivedPost();
		                    	break;
		                    case 0x6A:
		                    	msg = new RequestPostAttachment();
		                    	break;
		                    case 0x6B:
		                    	msg = new RequestRejectPostAttachment();
		                    	break;
		                    case 0x6C:
		                    	msg = new RequestSentPostList();
		                    	break;
		                    case 0x6D:
		                    	msg = new RequestDeleteSentPost();
		                    	break;
		                    case 0x6E:
		                    	msg = new RequestSentPost();
		                    	break;
		                    case 0x6F:
		                    	msg = new RequestCancelPost();
		                    	break;
		                    case 0x75:
		                    	msg = new RequestRefundItem();
		                    	break;
		                    case 0x76:
		                    	msg = new RequestBuySellUIClose();
		                    	break;
		                    default: 
		                     	this.printDebugDoubleOpcode(opcode, id2, buf, state, client);
		                    	break;
		                }
						break;
		            /*case 0xee:
						msg = new RequestChangePartyLeader(data, _client);
						break;*/
					default:
						this.printDebug(opcode, buf, state, client);
						break;
				}
				break;
		}
		return msg;
	}

	private void printDebug(int opcode, ByteBuffer buf, GameClientState state, L2GameClient client)
	{
		if (!Config.PACKET_HANDLER_DEBUG)
			return;
		
		int size = buf.remaining();
		_log.warning("Unknown Packet: 0x"+Integer.toHexString(opcode)+" on State: "+state.name()+" Client: "+client.toString());
     	byte[] array = new byte[size];
     	buf.get(array);
     	_log.warning(Util.printData(array, size));
	}

	private void printDebugDoubleOpcode(int opcode, int id2, ByteBuffer buf, GameClientState state, L2GameClient client)
	{
		if (!Config.PACKET_HANDLER_DEBUG)
			return;
		int size = buf.remaining();
		_log.warning("Unknown Packet: 0x"+Integer.toHexString(opcode)+":0x" + Integer.toHexString(id2)+" on State: "+state.name()+" Client: "+client.toString());
     	byte[] array = new byte[size];
     	buf.get(array);
     	_log.warning(Util.printData(array, size));
	}

	// impl
	public L2GameClient create(MMOConnection<L2GameClient> con)
	{
		return new L2GameClient(con);
	}

	public void execute(ReceivablePacket<L2GameClient> rp)
	{
		try
		{
			if (rp.getClient().getState() == GameClientState.IN_GAME)
			{
				ThreadPoolManager.getInstance().executePacket(rp);
			}
			else
			{
				ThreadPoolManager.getInstance().executeIOPacket(rp);
			}
		}
		catch (RejectedExecutionException e)
		{
			// if the server is shutdown we ignore
			if (!ThreadPoolManager.getInstance().isShutdown())
			{
				_log.severe("Failed executing: "+rp.getClass().getSimpleName()+" for Client: "+rp.getClient().toString());
			}
		}
	}
}