diff options
author | Andrei Karas <akaras@inbox.ru> | 2015-08-30 15:11:45 +0300 |
---|---|---|
committer | Andrei Karas <akaras@inbox.ru> | 2015-08-30 15:11:45 +0300 |
commit | 7c8e0e0454f2e9acfde62faf669a1628e3935a58 (patch) | |
tree | 5beb7c7506fcea774c2102a16a1886e923ad0891 /src/net/eathena | |
parent | a0157bd0f1909af5758adc32370125bdb76ccc5a (diff) | |
download | mv-7c8e0e0454f2e9acfde62faf669a1628e3935a58.tar.gz mv-7c8e0e0454f2e9acfde62faf669a1628e3935a58.tar.bz2 mv-7c8e0e0454f2e9acfde62faf669a1628e3935a58.tar.xz mv-7c8e0e0454f2e9acfde62faf669a1628e3935a58.zip |
Move receive code from playerhandler into separate file.
Diffstat (limited to 'src/net/eathena')
-rw-r--r-- | src/net/eathena/playerhandler.cpp | 442 | ||||
-rw-r--r-- | src/net/eathena/playerhandler.h | 41 | ||||
-rw-r--r-- | src/net/eathena/playerrecv.cpp | 436 | ||||
-rw-r--r-- | src/net/eathena/playerrecv.h | 57 |
4 files changed, 524 insertions, 452 deletions
diff --git a/src/net/eathena/playerhandler.cpp b/src/net/eathena/playerhandler.cpp index 2988bf21b..4779cee4b 100644 --- a/src/net/eathena/playerhandler.cpp +++ b/src/net/eathena/playerhandler.cpp @@ -39,7 +39,10 @@ #include "input/inputmanager.h" +#include "net/ea/playerrecv.h" + #include "net/eathena/messageout.h" +#include "net/eathena/playerrecv.h" #include "net/eathena/protocol.h" #include "net/eathena/inventoryhandler.h" @@ -97,116 +100,116 @@ void PlayerHandler::handleMessage(Net::MessageIn &msg) switch (msg.getId()) { case SMSG_WALK_RESPONSE: - processWalkResponse(msg); + PlayerRecv::processWalkResponse(msg); break; case SMSG_PLAYER_WARP: - processPlayerWarp(msg); + Ea::PlayerRecv::processPlayerWarp(msg); break; case SMSG_PLAYER_STAT_UPDATE_1: - processPlayerStatUpdate1(msg); + Ea::PlayerRecv::processPlayerStatUpdate1(msg); break; case SMSG_PLAYER_STAT_UPDATE_2: - processPlayerStatUpdate2(msg); + Ea::PlayerRecv::processPlayerStatUpdate2(msg); break; case SMSG_PLAYER_STAT_UPDATE_3: // Update a base attribute - processPlayerStatUpdate3(msg); + Ea::PlayerRecv::processPlayerStatUpdate3(msg); break; case SMSG_PLAYER_STAT_UPDATE_4: // Attribute increase ack - processPlayerStatUpdate4(msg); + Ea::PlayerRecv::processPlayerStatUpdate4(msg); break; // Updates stats and status points case SMSG_PLAYER_STAT_UPDATE_5: - processPlayerStatUpdate5(msg); + PlayerRecv::processPlayerStatUpdate5(msg); break; case SMSG_PLAYER_STAT_UPDATE_6: - processPlayerStatUpdate6(msg); + Ea::PlayerRecv::processPlayerStatUpdate6(msg); break; case SMSG_PLAYER_ARROW_MESSAGE: - processPlayerArrowMessage(msg); + Ea::PlayerRecv::processPlayerArrowMessage(msg); break; case SMSG_PLAYER_SHORTCUTS: - processPlayerShortcuts(msg); + PlayerRecv::processPlayerShortcuts(msg); break; case SMSG_PLAYER_SHOW_EQUIP: - processPlayerShowEquip(msg); + PlayerRecv::processPlayerShowEquip(msg); break; case SMSG_PLAYER_GET_EXP: - processPlayerGetExp(msg); + PlayerRecv::processPlayerGetExp(msg); break; case SMSG_PVP_INFO: - processPvpInfo(msg); + PlayerRecv::processPvpInfo(msg); break; case SMSG_PLAYER_HEAL: - processPlayerHeal(msg); + PlayerRecv::processPlayerHeal(msg); break; case SMSG_PLAYER_SKILL_MESSAGE: - processPlayerSkillMessage(msg); + PlayerRecv::processPlayerSkillMessage(msg); break; case SMSG_MAP_MASK: - processMapMask(msg); + PlayerRecv::processMapMask(msg); break; case SMSG_MAP_MUSIC: - processMapMusic(msg); + Ea::PlayerRecv::processMapMusic(msg); break; case SMSG_ONLINE_LIST: - processOnlineList(msg); + PlayerRecv::processOnlineList(msg); break; case SMSG_PLAYER_NOTIFY_MAPINFO: - processNotifyMapInfo(msg); + PlayerRecv::processNotifyMapInfo(msg); break; case SMSG_PLAYER_FAME_BLACKSMITH: - processPlayerFameBlacksmith(msg); + PlayerRecv::processPlayerFameBlacksmith(msg); break; case SMSG_PLAYER_FAME_ALCHEMIST: - processPlayerFameAlchemist(msg); + PlayerRecv::processPlayerFameAlchemist(msg); break; case SMSG_PLAYER_UPGRADE_MESSAGE: - processPlayerUpgradeMessage(msg); + PlayerRecv::processPlayerUpgradeMessage(msg); break; case SMSG_PLAYER_FAME_TAEKWON: - processPlayerFameTaekwon(msg); + PlayerRecv::processPlayerFameTaekwon(msg); break; case SMSG_PLAYER_READ_BOOK: - processPlayerReadBook(msg); + PlayerRecv::processPlayerReadBook(msg); break; case SMSG_PLAYER_EQUIP_TICK_ACK: - processPlayerEquipTickAck(msg); + PlayerRecv::processPlayerEquipTickAck(msg); break; case SMSG_AUTOSHADOW_SPELL_LIST: - processPlayerAutoShadowSpellList(msg); + PlayerRecv::processPlayerAutoShadowSpellList(msg); break; case SMSG_PLAYER_RANK_POINTS: - processPlayerRankPoints(msg); + PlayerRecv::processPlayerRankPoints(msg); break; case SMSG_PLAYER_CLIENT_COMMAND: - processPlayerClientCommand(msg); + PlayerRecv::processPlayerClientCommand(msg); break; default: @@ -358,175 +361,6 @@ void PlayerHandler::setMemo() const createOutPacket(CMSG_PLAYER_SET_MEMO); } -void PlayerHandler::processPlayerShortcuts(Net::MessageIn &msg) -{ - // +++ player shortcuts ignored. It also disabled on server side. - // may be in future better use it? - msg.readUInt8("unused?"); - for (int f = 0; f < 27; f ++) - { - msg.readUInt8("type 0: item, 1: skill"); - msg.readInt32("item or skill id"); - msg.readInt16("skill level"); - } - msg.skip(77, "unused"); -} - -void PlayerHandler::processPlayerShowEquip(Net::MessageIn &msg) -{ - // +++ for now server allow only switch this option but not using it. - msg.readUInt8("show equip"); // 1 mean need open "equipment" window -} - -void PlayerHandler::processPlayerStatUpdate5(Net::MessageIn &msg) -{ - BLOCK_START("PlayerHandler::processPlayerStatUpdate5") - PlayerInfo::setAttribute(Attributes::CHAR_POINTS, - msg.readInt16("char points")); - - unsigned int val = msg.readUInt8("str"); - PlayerInfo::setStatBase(Attributes::STR, val); - if (statusWindow) - { - statusWindow->setPointsNeeded(Attributes::STR, - msg.readUInt8("str cost")); - } - else - { - msg.readUInt8("str need"); - } - - val = msg.readUInt8("agi"); - PlayerInfo::setStatBase(Attributes::AGI, val); - if (statusWindow) - { - statusWindow->setPointsNeeded(Attributes::AGI, - msg.readUInt8("agi cost")); - } - else - { - msg.readUInt8("agi cost"); - } - - val = msg.readUInt8("vit"); - PlayerInfo::setStatBase(Attributes::VIT, val); - if (statusWindow) - { - statusWindow->setPointsNeeded(Attributes::VIT, - msg.readUInt8("vit cost")); - } - else - { - msg.readUInt8("vit cost"); - } - - val = msg.readUInt8("int"); - PlayerInfo::setStatBase(Attributes::INT, val); - if (statusWindow) - { - statusWindow->setPointsNeeded(Attributes::INT, - msg.readUInt8("int cost")); - } - else - { - msg.readUInt8("int cost"); - } - - val = msg.readUInt8("dex"); - PlayerInfo::setStatBase(Attributes::DEX, val); - if (statusWindow) - { - statusWindow->setPointsNeeded(Attributes::DEX, - msg.readUInt8("dex cost")); - } - else - { - msg.readUInt8("dex cost"); - } - - val = msg.readUInt8("luk"); - PlayerInfo::setStatBase(Attributes::LUK, val); - if (statusWindow) - { - statusWindow->setPointsNeeded(Attributes::LUK, - msg.readUInt8("luk cost")); - } - else - { - msg.readUInt8("luk cost"); - } - - PlayerInfo::setStatBase(Attributes::ATK, - msg.readInt16("left atk"), Notify_false); - PlayerInfo::setStatMod(Attributes::ATK, msg.readInt16("right atk")); - PlayerInfo::updateAttrs(); - - val = msg.readInt16("right matk"); - PlayerInfo::setStatBase(Attributes::MATK, val, Notify_false); - - val = msg.readInt16("left matk"); - PlayerInfo::setStatMod(Attributes::MATK, val); - - PlayerInfo::setStatBase(Attributes::DEF, - msg.readInt16("left def"), Notify_false); - PlayerInfo::setStatMod(Attributes::DEF, msg.readInt16("right def")); - - PlayerInfo::setStatBase(Attributes::MDEF, - msg.readInt16("left mdef"), Notify_false); - PlayerInfo::setStatMod(Attributes::MDEF, msg.readInt16("right mdef")); - - PlayerInfo::setStatBase(Attributes::HIT, msg.readInt16("hit")); - - PlayerInfo::setStatBase(Attributes::FLEE, - msg.readInt16("flee"), Notify_false); - PlayerInfo::setStatMod(Attributes::FLEE, msg.readInt16("flee2/10")); - - PlayerInfo::setStatBase(Attributes::CRIT, msg.readInt16("crit/10")); - - PlayerInfo::setAttribute(Attributes::ATTACK_DELAY, - msg.readInt16("attack speed")); - msg.readInt16("plus speed = 0"); - - BLOCK_END("PlayerHandler::processPlayerStatUpdate5") -} - -void PlayerHandler::processPlayerGetExp(Net::MessageIn &msg) -{ - if (!localPlayer) - return; - const BeingId id = msg.readBeingId("player id"); - const int exp = msg.readInt32("exp amount"); - const int stat = msg.readInt16("exp type"); - const bool fromQuest = msg.readInt16("is from quest"); - if (!fromQuest && id == localPlayer->getId()) - { - if (stat == 1) - localPlayer->addXpMessage(exp); - else if (stat == 2) - localPlayer->addJobMessage(exp); - else - UNIMPLIMENTEDPACKET; - } - // need show particle depend on isQuest flag, for now ignored -} - -void PlayerHandler::processWalkResponse(Net::MessageIn &msg) -{ - BLOCK_START("PlayerHandler::processWalkResponse") - /* - * This client assumes that all walk messages succeed, - * and that the server will send a correction notice - * otherwise. - */ - uint16_t srcX, srcY, dstX, dstY; - msg.readInt32("tick"); - msg.readCoordinatePair(srcX, srcY, dstX, dstY, "move path"); - msg.readUInt8("(sx<<4) | (sy&0x0f)"); - if (localPlayer) - localPlayer->setRealPos(dstX, dstY); - BLOCK_END("PlayerHandler::processWalkResponse") -} - void PlayerHandler::doriDori() const { createOutPacket(CMSG_DORI_DORI); @@ -544,16 +378,6 @@ void PlayerHandler::requestPvpInfo() const outMsg.writeInt32(0, "account id"); } -void PlayerHandler::processPvpInfo(Net::MessageIn &msg) -{ - UNIMPLIMENTEDPACKET; - msg.readInt32("char id"); - msg.readBeingId("account id"); - msg.readInt32("pvp won"); - msg.readInt32("pvp lost"); - msg.readInt32("pvp point"); -} - void PlayerHandler::revive() const { createOutPacket(CMSG_PLAYER_AUTO_REVIVE); @@ -566,63 +390,6 @@ void PlayerHandler::setViewEquipment(const bool allow) const outMsg.writeInt32(allow ? 1 : 0, "allow"); } -void PlayerHandler::processPlayerHeal(Net::MessageIn &msg) -{ - if (!localPlayer) - return; - - const int type = msg.readInt16("var id"); - const int amount = msg.readInt16("value"); - if (type == 5) - localPlayer->addHpMessage(amount); - else if (type == 7) - localPlayer->addSpMessage(amount); -} - -void PlayerHandler::processPlayerSkillMessage(Net::MessageIn &msg) -{ - const int message = msg.readInt32("type"); - switch (message) - { - case 0x15: - NotifyManager::notify(NotifyTypes::SKILL_END_ALL_NEGATIVE_STATUS); - break; - case 0x16: - NotifyManager::notify(NotifyTypes::SKILL_IMMUNITY_TO_ALL_STATUSES); - break; - case 0x17: - NotifyManager::notify(NotifyTypes::SKILL_MAX_HP); - break; - case 0x18: - NotifyManager::notify(NotifyTypes::SKILL_MAX_SP); - break; - case 0x19: - NotifyManager::notify(NotifyTypes::SKILL_ALL_STATUS_PLUS_20); - break; - case 0x1c: - NotifyManager::notify(NotifyTypes::SKILL_ENCHANT_WEAPON_HOLY); - break; - case 0x1d: - NotifyManager::notify(NotifyTypes::SKILL_ENCHANT_ARMOR_HOLY); - break; - case 0x1e: - NotifyManager::notify(NotifyTypes::SKILL_DEF_PLUS_25); - break; - case 0x1f: - NotifyManager::notify(NotifyTypes::SKILL_ATTACK_PLUS_100); - break; - case 0x20: - NotifyManager::notify(NotifyTypes::SKILL_FLEE_PLUS_50); - break; - case 0x28: - NotifyManager::notify(NotifyTypes::SKILL_FULL_STRIP_FAILED); - break; - default: - NotifyManager::notify(NotifyTypes::SKILL_MESSAGE_UNKNOWN); - break; - } -} - void PlayerHandler::setStat(Net::MessageIn &msg, const int type, const int base, @@ -632,151 +399,4 @@ void PlayerHandler::setStat(Net::MessageIn &msg, Ea::PlayerHandler::setStat(msg, type, base, mod, notify); } -void PlayerHandler::processNotifyMapInfo(Net::MessageIn &msg) -{ - UNIMPLIMENTEDPACKET; - msg.readInt16("type"); -} - -void PlayerHandler::processPlayerFameBlacksmith(Net::MessageIn &msg) -{ - UNIMPLIMENTEDPACKET; - msg.readInt32("points"); - msg.readInt32("total points"); -} - -void PlayerHandler::processPlayerFameAlchemist(Net::MessageIn &msg) -{ - UNIMPLIMENTEDPACKET; - msg.readInt32("points"); - msg.readInt32("total points"); -} - -void PlayerHandler::processPlayerUpgradeMessage(Net::MessageIn &msg) -{ - UNIMPLIMENTEDPACKET; - msg.readInt32("result"); - msg.readInt16("item id"); -} - -void PlayerHandler::processPlayerFameTaekwon(Net::MessageIn &msg) -{ - UNIMPLIMENTEDPACKET; - msg.readInt32("points"); - msg.readInt32("total points"); -} - -void PlayerHandler::processPlayerReadBook(Net::MessageIn &msg) -{ - UNIMPLIMENTEDPACKET; - msg.readInt32("book id"); - msg.readInt32("page"); -} - -void PlayerHandler::processPlayerEquipTickAck(Net::MessageIn &msg) -{ - UNIMPLIMENTEDPACKET; - msg.readInt32("unused"); - msg.readInt32("flag"); -} - -void PlayerHandler::processPlayerAutoShadowSpellList(Net::MessageIn &msg) -{ - UNIMPLIMENTEDPACKET; - const int count = (msg.readInt16("len") - 8) / 2; - for (int f = 0; f < count; f ++) - msg.readInt16("skill id"); -} - -void PlayerHandler::processPlayerRankPoints(Net::MessageIn &msg) -{ - UNIMPLIMENTEDPACKET; - msg.readInt16("type"); - msg.readInt32("points"); - msg.readInt32("fame"); -} - -void PlayerHandler::processPlayerClientCommand(Net::MessageIn &msg) -{ - const int sz = msg.readInt16("len") - 4; - std::string command = msg.readString(sz, "command"); - std::string cmd; - std::string args; - - if (!parse2Str(command, cmd, args)) - { - cmd = command; - args.clear(); - } - inputManager.executeChatCommand(cmd, args, nullptr); -} - -void PlayerHandler::processOnlineList(Net::MessageIn &msg) -{ - if (!whoIsOnline) - return; - - BLOCK_START("PlayerHandler::processOnlineList") - const int size = msg.readInt16("len") - 4; - std::vector<OnlinePlayer*> arr; - - if (!size) - { - if (whoIsOnline) - whoIsOnline->loadList(arr); - BLOCK_END("PlayerHandler::processOnlineList") - return; - } - - char *const start = reinterpret_cast<char*>(msg.readBytes(size, "nicks")); - if (!start) - { - BLOCK_END("PlayerHandler::processOnlineList") - return; - } - - const char *buf = start; - - int addVal = 3; - - while (buf - start + 1 < size - && *(buf + static_cast<size_t>(addVal))) - { - unsigned char status = *buf; - buf ++; - unsigned char level = *buf; - buf ++; - unsigned char ver = *buf; - buf ++; - - GenderT gender = Gender::UNSPECIFIED; - if (config.getBoolValue("showgender")) - { - if (status & BeingFlag::GENDER_MALE) - gender = Gender::MALE; - else if (status & BeingFlag::GENDER_OTHER) - gender = Gender::OTHER; - else - gender = Gender::FEMALE; - } - arr.push_back(new OnlinePlayer(static_cast<const char*>(buf), - status, level, gender, ver)); - buf += strlen(buf) + 1; - } - - if (whoIsOnline) - whoIsOnline->loadList(arr); - delete [] start; - BLOCK_END("PlayerHandler::processOnlineList") -} - -void PlayerHandler::processMapMask(Net::MessageIn &msg) -{ - const int mask = msg.readInt32("mask"); - msg.readInt32("unused"); - Map *const map = Game::instance()->getCurrentMap(); - if (map) - map->setMask(mask); -} - } // namespace EAthena diff --git a/src/net/eathena/playerhandler.h b/src/net/eathena/playerhandler.h index d32d06ab9..82a060d04 100644 --- a/src/net/eathena/playerhandler.h +++ b/src/net/eathena/playerhandler.h @@ -70,52 +70,11 @@ class PlayerHandler final : public MessageHandler, public Ea::PlayerHandler void revive() const override final; void setViewEquipment(const bool allow) const override final; - protected: void setStat(Net::MessageIn &msg, const int type, const int base, const int mod, const Notify notify) const override final; - - static void processPlayerShortcuts(Net::MessageIn &msg); - - static void processPlayerShowEquip(Net::MessageIn &msg); - - static void processPlayerStatUpdate5(Net::MessageIn &msg); - - static void processPlayerGetExp(Net::MessageIn &msg); - - static void processPvpInfo(Net::MessageIn &msg); - - static void processPlayerHeal(Net::MessageIn &msg); - - static void processPlayerSkillMessage(Net::MessageIn &msg); - - static void processWalkResponse(Net::MessageIn &msg); - - static void processNotifyMapInfo(Net::MessageIn &msg); - - static void processPlayerFameBlacksmith(Net::MessageIn &msg); - - static void processPlayerFameAlchemist(Net::MessageIn &msg); - - static void processPlayerUpgradeMessage(Net::MessageIn &msg); - - static void processPlayerFameTaekwon(Net::MessageIn &msg); - - static void processPlayerReadBook(Net::MessageIn &msg); - - static void processPlayerEquipTickAck(Net::MessageIn &msg); - - static void processPlayerAutoShadowSpellList(Net::MessageIn &msg); - - static void processPlayerRankPoints(Net::MessageIn &msg); - - static void processPlayerClientCommand(Net::MessageIn &msg); - - static void processOnlineList(Net::MessageIn &msg); - - static void processMapMask(Net::MessageIn &msg); }; } // namespace EAthena diff --git a/src/net/eathena/playerrecv.cpp b/src/net/eathena/playerrecv.cpp new file mode 100644 index 000000000..778cb7579 --- /dev/null +++ b/src/net/eathena/playerrecv.cpp @@ -0,0 +1,436 @@ +/* + * The ManaPlus Client + * Copyright (C) 2004-2009 The Mana World Development Team + * Copyright (C) 2009-2010 The Mana Developers + * Copyright (C) 2011-2015 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 <http://www.gnu.org/licenses/>. + */ + +#include "net/eathena/playerrecv.h" + +#include "configuration.h" +#include "game.h" +#include "notifymanager.h" + +#include "being/beingflag.h" +#include "being/localplayer.h" +#include "being/playerinfo.h" + +#include "enums/resources/notifytypes.h" + +#include "gui/onlineplayer.h" + +#include "gui/windows/statuswindow.h" +#include "gui/windows/whoisonline.h" + +#include "input/inputmanager.h" + +#include "net/eathena/messageout.h" +#include "net/eathena/protocol.h" +#include "net/eathena/inventoryhandler.h" + +#include "resources/map/map.h" + +#include "debug.h" + +namespace EAthena +{ + +void PlayerRecv::processPlayerShortcuts(Net::MessageIn &msg) +{ + // +++ player shortcuts ignored. It also disabled on server side. + // may be in future better use it? + msg.readUInt8("unused?"); + for (int f = 0; f < 27; f ++) + { + msg.readUInt8("type 0: item, 1: skill"); + msg.readInt32("item or skill id"); + msg.readInt16("skill level"); + } + msg.skip(77, "unused"); +} + +void PlayerRecv::processPlayerShowEquip(Net::MessageIn &msg) +{ + // +++ for now server allow only switch this option but not using it. + msg.readUInt8("show equip"); // 1 mean need open "equipment" window +} + +void PlayerRecv::processPlayerStatUpdate5(Net::MessageIn &msg) +{ + BLOCK_START("PlayerRecv::processPlayerStatUpdate5") + PlayerInfo::setAttribute(Attributes::CHAR_POINTS, + msg.readInt16("char points")); + + unsigned int val = msg.readUInt8("str"); + PlayerInfo::setStatBase(Attributes::STR, val); + if (statusWindow) + { + statusWindow->setPointsNeeded(Attributes::STR, + msg.readUInt8("str cost")); + } + else + { + msg.readUInt8("str need"); + } + + val = msg.readUInt8("agi"); + PlayerInfo::setStatBase(Attributes::AGI, val); + if (statusWindow) + { + statusWindow->setPointsNeeded(Attributes::AGI, + msg.readUInt8("agi cost")); + } + else + { + msg.readUInt8("agi cost"); + } + + val = msg.readUInt8("vit"); + PlayerInfo::setStatBase(Attributes::VIT, val); + if (statusWindow) + { + statusWindow->setPointsNeeded(Attributes::VIT, + msg.readUInt8("vit cost")); + } + else + { + msg.readUInt8("vit cost"); + } + + val = msg.readUInt8("int"); + PlayerInfo::setStatBase(Attributes::INT, val); + if (statusWindow) + { + statusWindow->setPointsNeeded(Attributes::INT, + msg.readUInt8("int cost")); + } + else + { + msg.readUInt8("int cost"); + } + + val = msg.readUInt8("dex"); + PlayerInfo::setStatBase(Attributes::DEX, val); + if (statusWindow) + { + statusWindow->setPointsNeeded(Attributes::DEX, + msg.readUInt8("dex cost")); + } + else + { + msg.readUInt8("dex cost"); + } + + val = msg.readUInt8("luk"); + PlayerInfo::setStatBase(Attributes::LUK, val); + if (statusWindow) + { + statusWindow->setPointsNeeded(Attributes::LUK, + msg.readUInt8("luk cost")); + } + else + { + msg.readUInt8("luk cost"); + } + + PlayerInfo::setStatBase(Attributes::ATK, + msg.readInt16("left atk"), Notify_false); + PlayerInfo::setStatMod(Attributes::ATK, msg.readInt16("right atk")); + PlayerInfo::updateAttrs(); + + val = msg.readInt16("right matk"); + PlayerInfo::setStatBase(Attributes::MATK, val, Notify_false); + + val = msg.readInt16("left matk"); + PlayerInfo::setStatMod(Attributes::MATK, val); + + PlayerInfo::setStatBase(Attributes::DEF, + msg.readInt16("left def"), Notify_false); + PlayerInfo::setStatMod(Attributes::DEF, msg.readInt16("right def")); + + PlayerInfo::setStatBase(Attributes::MDEF, + msg.readInt16("left mdef"), Notify_false); + PlayerInfo::setStatMod(Attributes::MDEF, msg.readInt16("right mdef")); + + PlayerInfo::setStatBase(Attributes::HIT, msg.readInt16("hit")); + + PlayerInfo::setStatBase(Attributes::FLEE, + msg.readInt16("flee"), Notify_false); + PlayerInfo::setStatMod(Attributes::FLEE, msg.readInt16("flee2/10")); + + PlayerInfo::setStatBase(Attributes::CRIT, msg.readInt16("crit/10")); + + PlayerInfo::setAttribute(Attributes::ATTACK_DELAY, + msg.readInt16("attack speed")); + msg.readInt16("plus speed = 0"); + + BLOCK_END("PlayerRecv::processPlayerStatUpdate5") +} + +void PlayerRecv::processPlayerGetExp(Net::MessageIn &msg) +{ + if (!localPlayer) + return; + const BeingId id = msg.readBeingId("player id"); + const int exp = msg.readInt32("exp amount"); + const int stat = msg.readInt16("exp type"); + const bool fromQuest = msg.readInt16("is from quest"); + if (!fromQuest && id == localPlayer->getId()) + { + if (stat == 1) + localPlayer->addXpMessage(exp); + else if (stat == 2) + localPlayer->addJobMessage(exp); + else + UNIMPLIMENTEDPACKET; + } + // need show particle depend on isQuest flag, for now ignored +} + +void PlayerRecv::processWalkResponse(Net::MessageIn &msg) +{ + BLOCK_START("PlayerRecv::processWalkResponse") + /* + * This client assumes that all walk messages succeed, + * and that the server will send a correction notice + * otherwise. + */ + uint16_t srcX, srcY, dstX, dstY; + msg.readInt32("tick"); + msg.readCoordinatePair(srcX, srcY, dstX, dstY, "move path"); + msg.readUInt8("(sx<<4) | (sy&0x0f)"); + if (localPlayer) + localPlayer->setRealPos(dstX, dstY); + BLOCK_END("PlayerRecv::processWalkResponse") +} + +void PlayerRecv::processPvpInfo(Net::MessageIn &msg) +{ + UNIMPLIMENTEDPACKET; + msg.readInt32("char id"); + msg.readBeingId("account id"); + msg.readInt32("pvp won"); + msg.readInt32("pvp lost"); + msg.readInt32("pvp point"); +} + +void PlayerRecv::processPlayerHeal(Net::MessageIn &msg) +{ + if (!localPlayer) + return; + + const int type = msg.readInt16("var id"); + const int amount = msg.readInt16("value"); + if (type == 5) + localPlayer->addHpMessage(amount); + else if (type == 7) + localPlayer->addSpMessage(amount); +} + +void PlayerRecv::processPlayerSkillMessage(Net::MessageIn &msg) +{ + const int message = msg.readInt32("type"); + switch (message) + { + case 0x15: + NotifyManager::notify(NotifyTypes::SKILL_END_ALL_NEGATIVE_STATUS); + break; + case 0x16: + NotifyManager::notify(NotifyTypes::SKILL_IMMUNITY_TO_ALL_STATUSES); + break; + case 0x17: + NotifyManager::notify(NotifyTypes::SKILL_MAX_HP); + break; + case 0x18: + NotifyManager::notify(NotifyTypes::SKILL_MAX_SP); + break; + case 0x19: + NotifyManager::notify(NotifyTypes::SKILL_ALL_STATUS_PLUS_20); + break; + case 0x1c: + NotifyManager::notify(NotifyTypes::SKILL_ENCHANT_WEAPON_HOLY); + break; + case 0x1d: + NotifyManager::notify(NotifyTypes::SKILL_ENCHANT_ARMOR_HOLY); + break; + case 0x1e: + NotifyManager::notify(NotifyTypes::SKILL_DEF_PLUS_25); + break; + case 0x1f: + NotifyManager::notify(NotifyTypes::SKILL_ATTACK_PLUS_100); + break; + case 0x20: + NotifyManager::notify(NotifyTypes::SKILL_FLEE_PLUS_50); + break; + case 0x28: + NotifyManager::notify(NotifyTypes::SKILL_FULL_STRIP_FAILED); + break; + default: + NotifyManager::notify(NotifyTypes::SKILL_MESSAGE_UNKNOWN); + break; + } +} + +void PlayerRecv::processNotifyMapInfo(Net::MessageIn &msg) +{ + UNIMPLIMENTEDPACKET; + msg.readInt16("type"); +} + +void PlayerRecv::processPlayerFameBlacksmith(Net::MessageIn &msg) +{ + UNIMPLIMENTEDPACKET; + msg.readInt32("points"); + msg.readInt32("total points"); +} + +void PlayerRecv::processPlayerFameAlchemist(Net::MessageIn &msg) +{ + UNIMPLIMENTEDPACKET; + msg.readInt32("points"); + msg.readInt32("total points"); +} + +void PlayerRecv::processPlayerUpgradeMessage(Net::MessageIn &msg) +{ + UNIMPLIMENTEDPACKET; + msg.readInt32("result"); + msg.readInt16("item id"); +} + +void PlayerRecv::processPlayerFameTaekwon(Net::MessageIn &msg) +{ + UNIMPLIMENTEDPACKET; + msg.readInt32("points"); + msg.readInt32("total points"); +} + +void PlayerRecv::processPlayerReadBook(Net::MessageIn &msg) +{ + UNIMPLIMENTEDPACKET; + msg.readInt32("book id"); + msg.readInt32("page"); +} + +void PlayerRecv::processPlayerEquipTickAck(Net::MessageIn &msg) +{ + UNIMPLIMENTEDPACKET; + msg.readInt32("unused"); + msg.readInt32("flag"); +} + +void PlayerRecv::processPlayerAutoShadowSpellList(Net::MessageIn &msg) +{ + UNIMPLIMENTEDPACKET; + const int count = (msg.readInt16("len") - 8) / 2; + for (int f = 0; f < count; f ++) + msg.readInt16("skill id"); +} + +void PlayerRecv::processPlayerRankPoints(Net::MessageIn &msg) +{ + UNIMPLIMENTEDPACKET; + msg.readInt16("type"); + msg.readInt32("points"); + msg.readInt32("fame"); +} + +void PlayerRecv::processPlayerClientCommand(Net::MessageIn &msg) +{ + const int sz = msg.readInt16("len") - 4; + std::string command = msg.readString(sz, "command"); + std::string cmd; + std::string args; + + if (!parse2Str(command, cmd, args)) + { + cmd = command; + args.clear(); + } + inputManager.executeChatCommand(cmd, args, nullptr); +} + +void PlayerRecv::processOnlineList(Net::MessageIn &msg) +{ + if (!whoIsOnline) + return; + + BLOCK_START("PlayerRecv::processOnlineList") + const int size = msg.readInt16("len") - 4; + std::vector<OnlinePlayer*> arr; + + if (!size) + { + if (whoIsOnline) + whoIsOnline->loadList(arr); + BLOCK_END("PlayerRecv::processOnlineList") + return; + } + + char *const start = reinterpret_cast<char*>(msg.readBytes(size, "nicks")); + if (!start) + { + BLOCK_END("PlayerRecv::processOnlineList") + return; + } + + const char *buf = start; + + int addVal = 3; + + while (buf - start + 1 < size + && *(buf + static_cast<size_t>(addVal))) + { + unsigned char status = *buf; + buf ++; + unsigned char level = *buf; + buf ++; + unsigned char ver = *buf; + buf ++; + + GenderT gender = Gender::UNSPECIFIED; + if (config.getBoolValue("showgender")) + { + if (status & BeingFlag::GENDER_MALE) + gender = Gender::MALE; + else if (status & BeingFlag::GENDER_OTHER) + gender = Gender::OTHER; + else + gender = Gender::FEMALE; + } + arr.push_back(new OnlinePlayer(static_cast<const char*>(buf), + status, level, gender, ver)); + buf += strlen(buf) + 1; + } + + if (whoIsOnline) + whoIsOnline->loadList(arr); + delete [] start; + BLOCK_END("PlayerRecv::processOnlineList") +} + +void PlayerRecv::processMapMask(Net::MessageIn &msg) +{ + const int mask = msg.readInt32("mask"); + msg.readInt32("unused"); + Map *const map = Game::instance()->getCurrentMap(); + if (map) + map->setMask(mask); +} + +} // namespace EAthena diff --git a/src/net/eathena/playerrecv.h b/src/net/eathena/playerrecv.h new file mode 100644 index 000000000..78ada4d92 --- /dev/null +++ b/src/net/eathena/playerrecv.h @@ -0,0 +1,57 @@ +/* + * The ManaPlus Client + * Copyright (C) 2004-2009 The Mana World Development Team + * Copyright (C) 2009-2010 The Mana Developers + * Copyright (C) 2011-2015 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 <http://www.gnu.org/licenses/>. + */ + +#ifndef NET_EATHENA_PLAYERRECV_H +#define NET_EATHENA_PLAYERRECV_H + +#include "net/ea/playerhandler.h" + +#include "net/eathena/messagehandler.h" + +namespace EAthena +{ + namespace PlayerRecv + { + void processPlayerShortcuts(Net::MessageIn &msg); + void processPlayerShowEquip(Net::MessageIn &msg); + void processPlayerStatUpdate5(Net::MessageIn &msg); + void processPlayerGetExp(Net::MessageIn &msg); + void processPvpInfo(Net::MessageIn &msg); + void processPlayerHeal(Net::MessageIn &msg); + void processPlayerSkillMessage(Net::MessageIn &msg); + void processWalkResponse(Net::MessageIn &msg); + void processNotifyMapInfo(Net::MessageIn &msg); + void processPlayerFameBlacksmith(Net::MessageIn &msg); + void processPlayerFameAlchemist(Net::MessageIn &msg); + void processPlayerUpgradeMessage(Net::MessageIn &msg); + void processPlayerFameTaekwon(Net::MessageIn &msg); + void processPlayerReadBook(Net::MessageIn &msg); + void processPlayerEquipTickAck(Net::MessageIn &msg); + void processPlayerAutoShadowSpellList(Net::MessageIn &msg); + void processPlayerRankPoints(Net::MessageIn &msg); + void processPlayerClientCommand(Net::MessageIn &msg); + void processOnlineList(Net::MessageIn &msg); + void processMapMask(Net::MessageIn &msg); + } // namespace PlayerRecv +} // namespace EAthena + +#endif // NET_EATHENA_PLAYERRECV_H |