/* * The ManaPlus Client * Copyright (C) 2004-2009 The Mana World Development Team * Copyright (C) 2009-2010 The Mana Developers * Copyright (C) 2011-2012 The ManaPlus Developers * * This file is part of The ManaPlus Client. * * 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 2 of the License, or * 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 . */ #include "net/eathena/npchandler.h" #include "localplayer.h" #include "gui/npcdialog.h" #include "gui/viewport.h" #include "net/messagein.h" #include "net/net.h" #include "net/npchandler.h" #include "net/eathena/protocol.h" #include "net/ea/eaprotocol.h" #include "utils/langs.h" #include "debug.h" extern Net::NpcHandler *npcHandler; namespace EAthena { NpcHandler::NpcHandler() { static const uint16_t _messages[] = { SMSG_NPC_CHOICE, SMSG_NPC_MESSAGE, SMSG_NPC_NEXT, SMSG_NPC_CLOSE, SMSG_NPC_INT_INPUT, SMSG_NPC_STR_INPUT, SMSG_NPC_CUTIN, SMSG_NPC_VIEWPOINT, 0 }; handledMessages = _messages; npcHandler = this; } void NpcHandler::handleMessage(Net::MessageIn &msg) { int npcId = 0; switch (msg.getId()) { case SMSG_NPC_CHOICE: npcId = getNpc(msg, true); processNpcChoice(msg); break; case SMSG_NPC_MESSAGE: npcId = getNpc(msg, true); processNpcMessage(msg); break; case SMSG_NPC_CLOSE: npcId = getNpc(msg, false); processNpcClose(msg); break; case SMSG_NPC_NEXT: npcId = getNpc(msg, false); processNpcNext(msg); break; case SMSG_NPC_INT_INPUT: npcId = getNpc(msg, false); processNpcIntInput(msg); break; case SMSG_NPC_STR_INPUT: npcId = getNpc(msg, false); processNpcStrInput(msg); break; case SMSG_NPC_CUTIN: processNpcCutin(msg, npcId); break; case SMSG_NPC_VIEWPOINT: npcId = getNpc(msg, true); processNpcViewPoint(msg, npcId); break; default: break; } mDialog = nullptr; } void NpcHandler::talk(int npcId) { MessageOut outMsg(CMSG_NPC_TALK); outMsg.writeInt32(npcId); outMsg.writeInt8(0); // Unused } void NpcHandler::nextDialog(int npcId) { MessageOut outMsg(CMSG_NPC_NEXT_REQUEST); outMsg.writeInt32(npcId); } void NpcHandler::closeDialog(int npcId) { MessageOut outMsg(CMSG_NPC_CLOSE); outMsg.writeInt32(npcId); NpcDialogs::iterator it = mNpcDialogs.find(npcId); if (it != mNpcDialogs.end()) { if ((*it).second.dialog) (*it).second.dialog->close(); if ((*it).second.dialog == mDialog) mDialog = nullptr; mNpcDialogs.erase(it); } } void NpcHandler::listInput(int npcId, unsigned char value) { MessageOut outMsg(CMSG_NPC_LIST_CHOICE); outMsg.writeInt32(npcId); outMsg.writeInt8(value); } void NpcHandler::integerInput(int npcId, int value) { MessageOut outMsg(CMSG_NPC_INT_RESPONSE); outMsg.writeInt32(npcId); outMsg.writeInt32(value); } void NpcHandler::stringInput(int npcId, const std::string &value) { MessageOut outMsg(CMSG_NPC_STR_RESPONSE); outMsg.writeInt16(static_cast(value.length() + 9)); outMsg.writeInt32(npcId); outMsg.writeString(value, static_cast(value.length())); outMsg.writeInt8(0); // Prevent problems with string reading } void NpcHandler::buy(int beingId) { MessageOut outMsg(CMSG_NPC_BUY_SELL_REQUEST); outMsg.writeInt32(beingId); outMsg.writeInt8(0); // Buy } void NpcHandler::sell(int beingId) { MessageOut outMsg(CMSG_NPC_BUY_SELL_REQUEST); outMsg.writeInt32(beingId); outMsg.writeInt8(1); // Sell } void NpcHandler::buyItem(int beingId A_UNUSED, int itemId, unsigned char color, int amount) { MessageOut outMsg(CMSG_NPC_BUY_REQUEST); outMsg.writeInt16(8); // One item (length of packet) outMsg.writeInt16(static_cast(amount)); outMsg.writeInt16(static_cast(itemId)); } void NpcHandler::sellItem(int beingId A_UNUSED, int itemId, int amount) { MessageOut outMsg(CMSG_NPC_SELL_REQUEST); outMsg.writeInt16(8); // One item (length of packet) outMsg.writeInt16(static_cast(itemId + INVENTORY_OFFSET)); outMsg.writeInt16(static_cast(amount)); } int NpcHandler::getNpc(Net::MessageIn &msg, bool haveLength) { if (haveLength) msg.readInt16(); // length const int npcId = msg.readInt32(); NpcDialogs::const_iterator diag = mNpcDialogs.find(npcId); mDialog = nullptr; if (diag == mNpcDialogs.end()) { // Empty dialogs don't help if (msg.getId() == SMSG_NPC_CLOSE) { closeDialog(npcId); return npcId; } else if (msg.getId() == SMSG_NPC_NEXT) { nextDialog(npcId); return npcId; } else { mDialog = new NpcDialog(npcId); mDialog->saveCamera(); if (player_node) player_node->stopWalking(false); Wrapper wrap; wrap.dialog = mDialog; mNpcDialogs[npcId] = wrap; } } else { if (mDialog && mDialog != diag->second.dialog) mDialog->restoreCamera(); mDialog = diag->second.dialog; if (mDialog) mDialog->saveCamera(); } return npcId; } void NpcHandler::processNpcCutin(Net::MessageIn &msg A_UNUSED, int npcId A_UNUSED) { msg.readString(64); // image name msg.readInt8(); // type } void NpcHandler::processNpcViewPoint(Net::MessageIn &msg A_UNUSED, int npcId A_UNUSED) { msg.readInt32(); // type msg.readInt32(); // x msg.readInt32(); // y msg.readInt8(); // byte msg.readInt32(); // color } } // namespace EAthena