From 7e0a84fc2b7493670dc8167aafb83c3811272eb3 Mon Sep 17 00:00:00 2001 From: Andrei Karas Date: Fri, 28 Aug 2015 00:47:23 +0300 Subject: Move receive code from partyhandler into separate file. --- src/CMakeLists.txt | 6 + src/Makefile.am | 6 + src/net/ea/partyhandler.cpp | 186 ++-------------------- src/net/ea/partyhandler.h | 22 +-- src/net/ea/partyrecv.cpp | 229 +++++++++++++++++++++++++++ src/net/ea/partyrecv.h | 53 +++++++ src/net/eathena/partyhandler.cpp | 313 +++---------------------------------- src/net/eathena/partyhandler.h | 19 --- src/net/eathena/partyrecv.cpp | 327 +++++++++++++++++++++++++++++++++++++++ src/net/eathena/partyrecv.h | 45 ++++++ src/net/tmwa/partyhandler.cpp | 278 ++------------------------------- src/net/tmwa/partyhandler.h | 15 -- src/net/tmwa/partyrecv.cpp | 296 +++++++++++++++++++++++++++++++++++ src/net/tmwa/partyrecv.h | 43 +++++ 14 files changed, 1053 insertions(+), 785 deletions(-) create mode 100644 src/net/ea/partyrecv.cpp create mode 100644 src/net/ea/partyrecv.h create mode 100644 src/net/eathena/partyrecv.cpp create mode 100644 src/net/eathena/partyrecv.h create mode 100644 src/net/tmwa/partyrecv.cpp create mode 100644 src/net/tmwa/partyrecv.h diff --git a/src/CMakeLists.txt b/src/CMakeLists.txt index 3faaed6d1..9a1527cd6 100644 --- a/src/CMakeLists.txt +++ b/src/CMakeLists.txt @@ -1389,6 +1389,8 @@ SET(SRCS_EVOL net/ea/npcrecv.h net/ea/partyhandler.cpp net/ea/partyhandler.h + net/ea/partyrecv.cpp + net/ea/partyrecv.h net/ea/playerhandler.cpp net/ea/playerhandler.h net/ea/skillhandler.cpp @@ -1460,6 +1462,8 @@ SET(SRCS_TMWA net/tmwa/packets.h net/tmwa/partyhandler.cpp net/tmwa/partyhandler.h + net/tmwa/partyrecv.cpp + net/tmwa/partyrecv.h net/tmwa/pethandler.cpp net/tmwa/pethandler.h net/tmwa/playerhandler.cpp @@ -1671,6 +1675,8 @@ SET(SRCS_EATHENA net/eathena/packets.h net/eathena/partyhandler.cpp net/eathena/partyhandler.h + net/eathena/partyrecv.cpp + net/eathena/partyrecv.h net/eathena/pethandler.cpp net/eathena/pethandler.h net/eathena/playerhandler.cpp diff --git a/src/Makefile.am b/src/Makefile.am index 3ac6c0503..7e13324f1 100644 --- a/src/Makefile.am +++ b/src/Makefile.am @@ -1231,6 +1231,8 @@ manaplus_SOURCES += main.cpp \ net/ea/npcrecv.h \ net/ea/partyhandler.cpp \ net/ea/partyhandler.h \ + net/ea/partyrecv.cpp \ + net/ea/partyrecv.h \ net/ea/playerhandler.cpp \ net/ea/playerhandler.h \ net/ea/skillhandler.cpp \ @@ -1303,6 +1305,8 @@ manaplus_SOURCES += \ net/tmwa/packets.h \ net/tmwa/partyhandler.cpp \ net/tmwa/partyhandler.h \ + net/tmwa/partyrecv.cpp \ + net/tmwa/partyrecv.h \ net/tmwa/pethandler.cpp \ net/tmwa/pethandler.h \ net/tmwa/playerhandler.cpp \ @@ -1517,6 +1521,8 @@ manaplus_SOURCES += gui/windows/bankwindow.cpp \ net/eathena/packets.h \ net/eathena/partyhandler.cpp \ net/eathena/partyhandler.h \ + net/eathena/partyrecv.cpp \ + net/eathena/partyrecv.h \ net/eathena/pethandler.cpp \ net/eathena/pethandler.h \ net/eathena/playerhandler.cpp \ diff --git a/src/net/ea/partyhandler.cpp b/src/net/ea/partyhandler.cpp index 83d5f04b4..0797e6e55 100644 --- a/src/net/ea/partyhandler.cpp +++ b/src/net/ea/partyhandler.cpp @@ -35,6 +35,8 @@ #include "net/messagein.h" +#include "net/ea/partyrecv.h" + #include "gui/widgets/tabs/chat/partytab.h" #include "utils/delete2.h" @@ -44,15 +46,11 @@ namespace Ea { -Party *taParty = nullptr; -PartyShareT PartyHandler::mShareExp = PartyShare::UNKNOWN; -PartyShareT PartyHandler::mShareItems = PartyShare::UNKNOWN; - PartyHandler::PartyHandler() : Net::PartyHandler() { - mShareExp = PartyShare::UNKNOWN; - mShareItems = PartyShare::UNKNOWN; + PartyRecv::mShareExp = PartyShare::UNKNOWN; + PartyRecv::mShareItems = PartyShare::UNKNOWN; taParty = Party::getParty(1); } @@ -75,183 +73,19 @@ void PartyHandler::clear() const taParty = nullptr; } -void PartyHandler::processPartyCreate(Net::MessageIn &msg) -{ - if (msg.readUInt8("flag")) - NotifyManager::notify(NotifyTypes::PARTY_CREATE_FAILED); - else - NotifyManager::notify(NotifyTypes::PARTY_CREATED); -} - -void PartyHandler::processPartySettingsContinue(Net::MessageIn &msg, - const PartyShareT exp, - const PartyShareT item) -{ - switch (exp) - { - case PartyShare::YES: - if (mShareExp == PartyShare::YES) - break; - mShareExp = PartyShare::YES; - NotifyManager::notify(NotifyTypes::PARTY_EXP_SHARE_ON); - break; - case PartyShare::NO: - if (mShareExp == PartyShare::NO) - break; - mShareExp = PartyShare::NO; - NotifyManager::notify(NotifyTypes::PARTY_EXP_SHARE_OFF); - break; - case PartyShare::NOT_POSSIBLE: - if (mShareExp == PartyShare::NOT_POSSIBLE) - break; - mShareExp = PartyShare::NOT_POSSIBLE; - NotifyManager::notify(NotifyTypes::PARTY_EXP_SHARE_ERROR); - break; - default: - case PartyShare::UNKNOWN: - UNIMPLIMENTEDPACKET; - break; - } - - switch (item) - { - case PartyShare::YES: - if (mShareItems == PartyShare::YES) - break; - mShareItems = PartyShare::YES; - NotifyManager::notify(NotifyTypes::PARTY_ITEM_SHARE_ON); - break; - case PartyShare::NO: - if (mShareItems == PartyShare::NO) - break; - mShareItems = PartyShare::NO; - NotifyManager::notify(NotifyTypes::PARTY_ITEM_SHARE_OFF); - break; - case PartyShare::NOT_POSSIBLE: - if (mShareItems == PartyShare::NOT_POSSIBLE) - break; - mShareItems = PartyShare::NOT_POSSIBLE; - NotifyManager::notify(NotifyTypes::PARTY_ITEM_SHARE_ERROR); - break; - default: - case PartyShare::UNKNOWN: - UNIMPLIMENTEDPACKET; - break; - } -} - -void PartyHandler::processPartyLeave(Net::MessageIn &msg) -{ - const BeingId id = msg.readBeingId("account id"); - const std::string nick = msg.readString(24, "nick"); - const int reason = msg.readUInt8("flag"); - if (!localPlayer) - return; - - if (id == localPlayer->getId()) - { - switch (reason) - { - case 0: - default: - NotifyManager::notify(NotifyTypes::PARTY_LEFT); - break; - - case 1: - NotifyManager::notify(NotifyTypes::PARTY_KICKED); - break; - - case 2: - NotifyManager::notify(NotifyTypes::PARTY_LEFT_DENY); - break; - - case 3: - NotifyManager::notify(NotifyTypes::PARTY_KICK_DENY); - break; - } - - if (reason >= 2) - return; - - if (Ea::taParty) - { - Ea::taParty->removeFromMembers(); - Ea::taParty->clearMembers(); - } - - delete2(partyTab) - - if (socialWindow && Ea::taParty) - socialWindow->removeTab(Ea::taParty); - localPlayer->setPartyName(""); - } - else - { - switch (reason) - { - case 0: - default: - NotifyManager::notify(NotifyTypes::PARTY_USER_LEFT, nick); - break; - - case 1: - NotifyManager::notify(NotifyTypes::PARTY_USER_KICKED, nick); - break; - - case 2: - NotifyManager::notify(NotifyTypes::PARTY_USER_LEFT_DENY, nick); - break; - - case 3: - NotifyManager::notify(NotifyTypes::PARTY_USER_KICK_DENY, nick); - break; - } - - if (reason >= 2) - return; - - if (actorManager) - { - Being *const b = actorManager->findBeing(id); - if (b && b->getType() == ActorType::Player) - { - b->setParty(nullptr); - b->setPartyName(""); - } - } - if (Ea::taParty) - Ea::taParty->removeMember(id); - } -} - -void PartyHandler::processPartyUpdateCoords(Net::MessageIn &msg) +ChatTab *PartyHandler::getTab() const { - const BeingId id = msg.readBeingId("account id"); - PartyMember *m = nullptr; - if (Ea::taParty) - m = Ea::taParty->getMember(id); - if (m) - { - m->setX(msg.readInt16("x")); - m->setY(msg.readInt16("y")); - } - else - { - msg.readInt16("x"); - msg.readInt16("y"); - } + return partyTab; } -ChatTab *PartyHandler::getTab() const +PartyShareT PartyHandler::getShareExperience() const { - return partyTab; + return PartyRecv::mShareExp; } -void PartyHandler::createTab() +PartyShareT PartyHandler::getShareItems() const { - partyTab = new PartyTab(chatWindow); - if (config.getBoolValue("showChatHistory")) - partyTab->loadFromLogFile("#Party"); + return PartyRecv::mShareItems; } } // namespace Ea diff --git a/src/net/ea/partyhandler.h b/src/net/ea/partyhandler.h index 453aced1d..1848d5316 100644 --- a/src/net/ea/partyhandler.h +++ b/src/net/ea/partyhandler.h @@ -44,33 +44,15 @@ class PartyHandler notfinal : public Net::PartyHandler void join(const int partyId) const override final; - PartyShareT getShareExperience() const override final A_WARN_UNUSED - { return mShareExp; } + PartyShareT getShareExperience() const override final A_WARN_UNUSED; - PartyShareT getShareItems() const override final A_WARN_UNUSED - { return mShareItems; } + PartyShareT getShareItems() const override final A_WARN_UNUSED; static void reload(); void clear() const override final; ChatTab *getTab() const override final; - - protected: - static void createTab(); - - static void processPartyCreate(Net::MessageIn &msg); - - static void processPartyLeave(Net::MessageIn &msg); - - static void processPartyUpdateCoords(Net::MessageIn &msg); - - static void processPartySettingsContinue(Net::MessageIn &msg, - const PartyShareT exp, - const PartyShareT item); - - static PartyShareT mShareExp; - static PartyShareT mShareItems; }; extern Party *taParty; diff --git a/src/net/ea/partyrecv.cpp b/src/net/ea/partyrecv.cpp new file mode 100644 index 000000000..415129f41 --- /dev/null +++ b/src/net/ea/partyrecv.cpp @@ -0,0 +1,229 @@ +/* + * The ManaPlus Client + * Copyright (C) 2008 Lloyd Bryant + * 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 . + */ + +#include "net/ea/partyrecv.h" + +#include "actormanager.h" +#include "configuration.h" +#include "notifymanager.h" +#include "party.h" + +#include "being/localplayer.h" + +#include "enums/resources/notifytypes.h" + +#include "gui/windows/chatwindow.h" +#include "gui/windows/socialwindow.h" + +#include "net/messagein.h" + +#include "gui/widgets/tabs/chat/partytab.h" + +#include "utils/delete2.h" + +#include "debug.h" + +namespace Ea +{ + +Party *taParty = nullptr; + +namespace PartyRecv +{ + PartyShareT mShareExp = PartyShare::UNKNOWN; + PartyShareT mShareItems = PartyShare::UNKNOWN; +} // namespace PartyRecv + +void PartyRecv::processPartyCreate(Net::MessageIn &msg) +{ + if (msg.readUInt8("flag")) + NotifyManager::notify(NotifyTypes::PARTY_CREATE_FAILED); + else + NotifyManager::notify(NotifyTypes::PARTY_CREATED); +} + +void PartyRecv::processPartySettingsContinue(Net::MessageIn &msg, + const PartyShareT exp, + const PartyShareT item) +{ + switch (exp) + { + case PartyShare::YES: + if (mShareExp == PartyShare::YES) + break; + mShareExp = PartyShare::YES; + NotifyManager::notify(NotifyTypes::PARTY_EXP_SHARE_ON); + break; + case PartyShare::NO: + if (mShareExp == PartyShare::NO) + break; + mShareExp = PartyShare::NO; + NotifyManager::notify(NotifyTypes::PARTY_EXP_SHARE_OFF); + break; + case PartyShare::NOT_POSSIBLE: + if (mShareExp == PartyShare::NOT_POSSIBLE) + break; + mShareExp = PartyShare::NOT_POSSIBLE; + NotifyManager::notify(NotifyTypes::PARTY_EXP_SHARE_ERROR); + break; + default: + case PartyShare::UNKNOWN: + UNIMPLIMENTEDPACKET; + break; + } + + switch (item) + { + case PartyShare::YES: + if (mShareItems == PartyShare::YES) + break; + mShareItems = PartyShare::YES; + NotifyManager::notify(NotifyTypes::PARTY_ITEM_SHARE_ON); + break; + case PartyShare::NO: + if (mShareItems == PartyShare::NO) + break; + mShareItems = PartyShare::NO; + NotifyManager::notify(NotifyTypes::PARTY_ITEM_SHARE_OFF); + break; + case PartyShare::NOT_POSSIBLE: + if (mShareItems == PartyShare::NOT_POSSIBLE) + break; + mShareItems = PartyShare::NOT_POSSIBLE; + NotifyManager::notify(NotifyTypes::PARTY_ITEM_SHARE_ERROR); + break; + default: + case PartyShare::UNKNOWN: + UNIMPLIMENTEDPACKET; + break; + } +} + +void PartyRecv::processPartyLeave(Net::MessageIn &msg) +{ + const BeingId id = msg.readBeingId("account id"); + const std::string nick = msg.readString(24, "nick"); + const int reason = msg.readUInt8("flag"); + if (!localPlayer) + return; + + if (id == localPlayer->getId()) + { + switch (reason) + { + case 0: + default: + NotifyManager::notify(NotifyTypes::PARTY_LEFT); + break; + + case 1: + NotifyManager::notify(NotifyTypes::PARTY_KICKED); + break; + + case 2: + NotifyManager::notify(NotifyTypes::PARTY_LEFT_DENY); + break; + + case 3: + NotifyManager::notify(NotifyTypes::PARTY_KICK_DENY); + break; + } + + if (reason >= 2) + return; + + if (Ea::taParty) + { + Ea::taParty->removeFromMembers(); + Ea::taParty->clearMembers(); + } + + delete2(partyTab) + + if (socialWindow && Ea::taParty) + socialWindow->removeTab(Ea::taParty); + localPlayer->setPartyName(""); + } + else + { + switch (reason) + { + case 0: + default: + NotifyManager::notify(NotifyTypes::PARTY_USER_LEFT, nick); + break; + + case 1: + NotifyManager::notify(NotifyTypes::PARTY_USER_KICKED, nick); + break; + + case 2: + NotifyManager::notify(NotifyTypes::PARTY_USER_LEFT_DENY, nick); + break; + + case 3: + NotifyManager::notify(NotifyTypes::PARTY_USER_KICK_DENY, nick); + break; + } + + if (reason >= 2) + return; + + if (actorManager) + { + Being *const b = actorManager->findBeing(id); + if (b && b->getType() == ActorType::Player) + { + b->setParty(nullptr); + b->setPartyName(""); + } + } + if (Ea::taParty) + Ea::taParty->removeMember(id); + } +} + +void PartyRecv::processPartyUpdateCoords(Net::MessageIn &msg) +{ + const BeingId id = msg.readBeingId("account id"); + PartyMember *m = nullptr; + if (Ea::taParty) + m = Ea::taParty->getMember(id); + if (m) + { + m->setX(msg.readInt16("x")); + m->setY(msg.readInt16("y")); + } + else + { + msg.readInt16("x"); + msg.readInt16("y"); + } +} + +void PartyRecv::createTab() +{ + partyTab = new PartyTab(chatWindow); + if (config.getBoolValue("showChatHistory")) + partyTab->loadFromLogFile("#Party"); +} + +} // namespace Ea diff --git a/src/net/ea/partyrecv.h b/src/net/ea/partyrecv.h new file mode 100644 index 000000000..87452318f --- /dev/null +++ b/src/net/ea/partyrecv.h @@ -0,0 +1,53 @@ +/* + * The ManaPlus Client + * Copyright (C) 2008 Lloyd Bryant + * 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 . + */ + +#ifndef NET_EA_PARTYRECV_H +#define NET_EA_PARTYRECV_H + +#include "net/partyhandler.h" + +class Party; + +namespace Net +{ + class MessageIn; +} + +namespace Ea +{ + namespace PartyRecv + { + extern PartyShareT mShareExp; + extern PartyShareT mShareItems; + + void processPartyCreate(Net::MessageIn &msg); + void processPartyLeave(Net::MessageIn &msg); + void processPartyUpdateCoords(Net::MessageIn &msg); + void processPartySettingsContinue(Net::MessageIn &msg, + const PartyShareT exp, + const PartyShareT item); + + void createTab(); + } // namespace PartyRecv + extern Party *taParty; +} // namespace Ea + +#endif // NET_EA_PARTYRECV_H diff --git a/src/net/eathena/partyhandler.cpp b/src/net/eathena/partyhandler.cpp index 15c1c4940..0e0625b4c 100644 --- a/src/net/eathena/partyhandler.cpp +++ b/src/net/eathena/partyhandler.cpp @@ -34,7 +34,10 @@ #include "gui/widgets/tabs/chat/partytab.h" +#include "net/ea/partyrecv.h" + #include "net/eathena/messageout.h" +#include "net/eathena/partyrecv.h" #include "net/eathena/protocol.h" #include "debug.h" @@ -77,40 +80,40 @@ void PartyHandler::handleMessage(Net::MessageIn &msg) switch (msg.getId()) { case SMSG_PARTY_CREATE: - processPartyCreate(msg); + Ea::PartyRecv::processPartyCreate(msg); break; case SMSG_PARTY_INFO: - processPartyInfo(msg); + PartyRecv::processPartyInfo(msg); break; case SMSG_PARTY_INVITE_RESPONSE: - processPartyInviteResponse(msg); + PartyRecv::processPartyInviteResponse(msg); break; case SMSG_PARTY_INVITED: - processPartyInvited(msg); + PartyRecv::processPartyInvited(msg); break; case SMSG_PARTY_SETTINGS: - processPartySettings(msg); + PartyRecv::processPartySettings(msg); break; case SMSG_PARTY_LEAVE: - processPartyLeave(msg); + Ea::PartyRecv::processPartyLeave(msg); break; case SMSG_PARTY_UPDATE_COORDS: - processPartyUpdateCoords(msg); + Ea::PartyRecv::processPartyUpdateCoords(msg); break; case SMSG_PARTY_MESSAGE: - processPartyMessage(msg); + PartyRecv::processPartyMessage(msg); break; case SMSG_PARTY_INVITATION_STATS: - processPartyInvitationStats(msg); + PartyRecv::processPartyInvitationStats(msg); break; case SMSG_PARTY_MEMBER_INFO: - processPartyMemberInfo(msg); + PartyRecv::processPartyMemberInfo(msg); break; case SMSG_PARTY_ITEM_PICKUP: - processPartyItemPickup(msg); + PartyRecv::processPartyItemPickup(msg); break; case SMSG_PARTY_LEADER: - processPartyLeader(msg); + PartyRecv::processPartyLeader(msg); break; default: @@ -205,7 +208,8 @@ void PartyHandler::setShareExperience(const PartyShareT share) const createOutPacket(CMSG_PARTY_SETTINGS); outMsg.writeInt16(static_cast(share), "share exp"); - outMsg.writeInt16(static_cast(mShareItems), "share items"); + outMsg.writeInt16(static_cast(Ea::PartyRecv::mShareItems), + "share items"); } // +++ must be 3 types item, exp, pickup @@ -215,240 +219,11 @@ void PartyHandler::setShareItems(const PartyShareT share) const return; createOutPacket(CMSG_PARTY_SETTINGS); - outMsg.writeInt16(static_cast(mShareExp), "share exp"); + outMsg.writeInt16(static_cast(Ea::PartyRecv::mShareExp), + "share exp"); outMsg.writeInt16(static_cast(share), "share items"); } -void PartyHandler::processPartyInvitationStats(Net::MessageIn &msg) -{ - // +++ for now server allow only switch this option but not using it. - msg.readUInt8("allow party"); -} - -void PartyHandler::processPartyMemberInfo(Net::MessageIn &msg) -{ - const BeingId id = msg.readBeingId("account id"); - const bool leader = msg.readInt32("leader") == 0U; - const int x = msg.readInt16("x"); - const int y = msg.readInt16("y"); - const bool online = msg.readInt8("online") == 0U; - msg.readString(24, "party name"); - const std::string nick = msg.readString(24, "player name"); - const std::string map = msg.readString(16, "map name"); - msg.readInt8("party.item&1"); - msg.readInt8("party.item&2"); - - if (!Ea::taParty) - return; - - PartyMember *const member = Ea::taParty->addMember(id, nick); - if (member) - { - if (partyTab && member->getOnline() != online) - partyTab->showOnline(nick, fromBool(online, Online)); - member->setLeader(leader); - member->setOnline(online); - member->setMap(map); - member->setX(x); - member->setY(y); - } -} - -void PartyHandler::processPartySettings(Net::MessageIn &msg) -{ - if (!partyTab) - { - if (!chatWindow) - return; - - createTab(); - } - - msg.readInt32("party exp"); - const PartyShareT exp = static_cast( - msg.readInt8("share exp")); - const PartyShareT item = static_cast( - msg.readInt8("share item")); - processPartySettingsContinue(msg, exp, item); -} - -void PartyHandler::processPartyInfo(Net::MessageIn &msg) -{ - bool isOldParty = false; - std::set names; - std::set onlineNames; - if (!Ea::taParty) - { - logger->log1("error: party empty in SMSG_PARTY_INFO"); - Ea::taParty = Party::getParty(1); - } - if (!partyTab) - createTab(); - - if (Ea::taParty) - { - if (Ea::taParty->getNumberOfElements() > 1) - { - isOldParty = true; - Ea::taParty->getNamesSet(names); - const Party::MemberList *const members = Ea::taParty->getMembers(); - FOR_EACHP (Party::MemberList::const_iterator, it, members) - { - if ((*it)->getOnline()) - onlineNames.insert((*it)->getName()); - } - if (localPlayer) - onlineNames.insert(localPlayer->getName()); - } - } - - if (!localPlayer) - logger->log1("error: localPlayer==0 in SMSG_PARTY_INFO"); - - if (Ea::taParty) - Ea::taParty->clearMembers(); - - const int length = msg.readInt16("len"); - if (Ea::taParty) - Ea::taParty->setName(msg.readString(24, "party name")); - - const int count = (length - 28) / 46; - if (localPlayer && Ea::taParty) - { - localPlayer->setParty(Ea::taParty); - localPlayer->setPartyName(Ea::taParty->getName()); - } - - for (int i = 0; i < count; i++) - { - const BeingId id = msg.readBeingId("account id"); - std::string nick = msg.readString(24, "nick"); - std::string map = msg.readString(16, "map name"); - const bool leader = msg.readUInt8("leader") == 0U; - const bool online = msg.readUInt8("online") == 0U; - - if (Ea::taParty) - { - bool joined(false); - - if (isOldParty) - { - if (names.find(nick) == names.end()) - { - NotifyManager::notify(NotifyTypes::PARTY_USER_JOINED, - nick); - joined = true; - } - } - PartyMember *const member = Ea::taParty->addMember(id, nick); - if (member) - { - if (!joined && partyTab) - { - if (!names.empty() && ((onlineNames.find(nick) - == onlineNames.end() && online) - || (onlineNames.find(nick) != onlineNames.end() - && !online))) - { - partyTab->showOnline(nick, fromBool(online, Online)); - } - - member->setLeader(leader); - member->setOnline(online); - member->setMap(map); - } - else - { - member->setLeader(leader); - member->setOnline(online); - member->setMap(map); - } - } - } - } - - if (Ea::taParty) - Ea::taParty->sort(); - - if (localPlayer && Ea::taParty) - { - localPlayer->setParty(Ea::taParty); - localPlayer->setPartyName(Ea::taParty->getName()); - if (socialWindow) - socialWindow->updateParty(); - } -} - -void PartyHandler::processPartyMessage(Net::MessageIn &msg) -{ - const int msgLength = msg.readInt16("len") - 8; - if (msgLength <= 0) - return; - - const BeingId id = msg.readBeingId("id"); - std::string chatMsg = msg.readString(msgLength, "message"); - - const size_t pos = chatMsg.find(" : ", 0); - if (pos != std::string::npos) - chatMsg.erase(0, pos + 3); - - if (Ea::taParty && partyTab) - { - const PartyMember *const member = Ea::taParty->getMember(id); - if (member) - { - partyTab->chatLog(member->getName(), chatMsg); - } - else - { - NotifyManager::notify(NotifyTypes::PARTY_UNKNOWN_USER_MSG, - chatMsg); - } - } -} - -void PartyHandler::processPartyInviteResponse(Net::MessageIn &msg) -{ - if (!partyTab) - return; - - const std::string nick = msg.readString(24, "nick"); - - switch (msg.readInt32("result")) - { - case 0: - NotifyManager::notify(NotifyTypes::PARTY_INVITE_ALREADY_MEMBER, - nick); - break; - case 1: - NotifyManager::notify(NotifyTypes::PARTY_INVITE_REFUSED, nick); - break; - case 2: - NotifyManager::notify(NotifyTypes::PARTY_INVITE_DONE, nick); - break; - case 3: - NotifyManager::notify(NotifyTypes::PARTY_INVITE_PARTY_FULL, - nick); - break; - case 4: - NotifyManager::notify(NotifyTypes::PARTY_INVITE_PARTY_SAME_ACCOUNT, - nick); - break; - case 5: - NotifyManager::notify( - NotifyTypes::PARTY_INVITE_PARTY_BLOCKED_INVITE, - nick); - break; - case 7: - NotifyManager::notify(NotifyTypes::PARTY_INVITE_PARTY_NOT_ONLINE, - nick); - break; - default: - NotifyManager::notify(NotifyTypes::PARTY_INVITE_ERROR, nick); - break; - } -} - void PartyHandler::changeLeader(const std::string &name) const { const Being *const being = actorManager->findBeingByName( @@ -465,54 +240,4 @@ void PartyHandler::allowInvite(const bool allow) const outMsg.writeInt8(static_cast(allow ? 1 : 0), "allow"); } -void PartyHandler::processPartyItemPickup(Net::MessageIn &msg) -{ - UNIMPLIMENTEDPACKET; - // +++ probably need add option to show pickup notifications - // in party tab - msg.readBeingId("account id"); - msg.readInt16("item id"); - msg.readUInt8("identify"); - msg.readUInt8("attribute"); - msg.readUInt8("refine"); - for (int f = 0; f < 4; f++) - msg.readInt16("card"); - msg.readInt16("equip location"); - msg.readUInt8("item type"); - // for color can be used ItemColorManager -} - -void PartyHandler::processPartyLeader(Net::MessageIn &msg) -{ - PartyMember *const oldMember = Ea::taParty->getMember( - msg.readBeingId("old leder id")); - PartyMember *const newMember = Ea::taParty->getMember( - msg.readBeingId("new leder id")); - if (oldMember) - oldMember->setLeader(false); - if (newMember) - newMember->setLeader(true); -} - -void PartyHandler::processPartyInvited(Net::MessageIn &msg) -{ - const BeingId id = msg.readBeingId("account id"); - const std::string partyName = msg.readString(24, "party name"); - - std::string nick; - - if (actorManager) - { - const Being *const being = actorManager->findBeing(id); - if (being) - { - if (being->getType() == ActorType::Player) - nick = being->getName(); - } - } - - if (socialWindow) - socialWindow->showPartyInvite(partyName, nick, 0); -} - } // namespace EAthena diff --git a/src/net/eathena/partyhandler.h b/src/net/eathena/partyhandler.h index 80d85e6fb..c44b1eee9 100644 --- a/src/net/eathena/partyhandler.h +++ b/src/net/eathena/partyhandler.h @@ -62,25 +62,6 @@ class PartyHandler final : public MessageHandler, public Ea::PartyHandler void changeLeader(const std::string &name) const override final; void allowInvite(const bool allow) const override final; - - protected: - static void processPartySettings(Net::MessageIn &msg); - - static void processPartyInvitationStats(Net::MessageIn &msg); - - static void processPartyMemberInfo(Net::MessageIn &msg); - - static void processPartyInfo(Net::MessageIn &msg); - - static void processPartyMessage(Net::MessageIn &msg); - - static void processPartyInviteResponse(Net::MessageIn &msg); - - static void processPartyItemPickup(Net::MessageIn &msg); - - static void processPartyLeader(Net::MessageIn &msg); - - static void processPartyInvited(Net::MessageIn &msg); }; } // namespace EAthena diff --git a/src/net/eathena/partyrecv.cpp b/src/net/eathena/partyrecv.cpp new file mode 100644 index 000000000..479433690 --- /dev/null +++ b/src/net/eathena/partyrecv.cpp @@ -0,0 +1,327 @@ +/* + * The ManaPlus Client + * Copyright (C) 2008 Lloyd Bryant + * 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 . + */ + +#include "net/eathena/partyrecv.h" + +#include "actormanager.h" +#include "notifymanager.h" +#include "party.h" + +#include "being/localplayer.h" + +#include "enums/resources/notifytypes.h" + +#include "gui/windows/chatwindow.h" +#include "gui/windows/socialwindow.h" + +#include "gui/widgets/tabs/chat/partytab.h" + +#include "net/ea/partyrecv.h" + +#include "net/eathena/messageout.h" +#include "net/eathena/protocol.h" + +#include "debug.h" + +namespace EAthena +{ + +void PartyRecv::processPartyInvitationStats(Net::MessageIn &msg) +{ + // +++ for now server allow only switch this option but not using it. + msg.readUInt8("allow party"); +} + +void PartyRecv::processPartyMemberInfo(Net::MessageIn &msg) +{ + const BeingId id = msg.readBeingId("account id"); + const bool leader = msg.readInt32("leader") == 0U; + const int x = msg.readInt16("x"); + const int y = msg.readInt16("y"); + const bool online = msg.readInt8("online") == 0U; + msg.readString(24, "party name"); + const std::string nick = msg.readString(24, "player name"); + const std::string map = msg.readString(16, "map name"); + msg.readInt8("party.item&1"); + msg.readInt8("party.item&2"); + + if (!Ea::taParty) + return; + + PartyMember *const member = Ea::taParty->addMember(id, nick); + if (member) + { + if (partyTab && member->getOnline() != online) + partyTab->showOnline(nick, fromBool(online, Online)); + member->setLeader(leader); + member->setOnline(online); + member->setMap(map); + member->setX(x); + member->setY(y); + } +} + +void PartyRecv::processPartySettings(Net::MessageIn &msg) +{ + if (!partyTab) + { + if (!chatWindow) + return; + + Ea::PartyRecv::createTab(); + } + + msg.readInt32("party exp"); + const PartyShareT exp = static_cast( + msg.readInt8("share exp")); + const PartyShareT item = static_cast( + msg.readInt8("share item")); + Ea::PartyRecv::processPartySettingsContinue(msg, exp, item); +} + +void PartyRecv::processPartyInfo(Net::MessageIn &msg) +{ + bool isOldParty = false; + std::set names; + std::set onlineNames; + if (!Ea::taParty) + { + logger->log1("error: party empty in SMSG_PARTY_INFO"); + Ea::taParty = Party::getParty(1); + } + if (!partyTab) + Ea::PartyRecv::createTab(); + + if (Ea::taParty) + { + if (Ea::taParty->getNumberOfElements() > 1) + { + isOldParty = true; + Ea::taParty->getNamesSet(names); + const Party::MemberList *const members = Ea::taParty->getMembers(); + FOR_EACHP (Party::MemberList::const_iterator, it, members) + { + if ((*it)->getOnline()) + onlineNames.insert((*it)->getName()); + } + if (localPlayer) + onlineNames.insert(localPlayer->getName()); + } + } + + if (!localPlayer) + logger->log1("error: localPlayer==0 in SMSG_PARTY_INFO"); + + if (Ea::taParty) + Ea::taParty->clearMembers(); + + const int length = msg.readInt16("len"); + if (Ea::taParty) + Ea::taParty->setName(msg.readString(24, "party name")); + + const int count = (length - 28) / 46; + if (localPlayer && Ea::taParty) + { + localPlayer->setParty(Ea::taParty); + localPlayer->setPartyName(Ea::taParty->getName()); + } + + for (int i = 0; i < count; i++) + { + const BeingId id = msg.readBeingId("account id"); + std::string nick = msg.readString(24, "nick"); + std::string map = msg.readString(16, "map name"); + const bool leader = msg.readUInt8("leader") == 0U; + const bool online = msg.readUInt8("online") == 0U; + + if (Ea::taParty) + { + bool joined(false); + + if (isOldParty) + { + if (names.find(nick) == names.end()) + { + NotifyManager::notify(NotifyTypes::PARTY_USER_JOINED, + nick); + joined = true; + } + } + PartyMember *const member = Ea::taParty->addMember(id, nick); + if (member) + { + if (!joined && partyTab) + { + if (!names.empty() && ((onlineNames.find(nick) + == onlineNames.end() && online) + || (onlineNames.find(nick) != onlineNames.end() + && !online))) + { + partyTab->showOnline(nick, fromBool(online, Online)); + } + + member->setLeader(leader); + member->setOnline(online); + member->setMap(map); + } + else + { + member->setLeader(leader); + member->setOnline(online); + member->setMap(map); + } + } + } + } + + if (Ea::taParty) + Ea::taParty->sort(); + + if (localPlayer && Ea::taParty) + { + localPlayer->setParty(Ea::taParty); + localPlayer->setPartyName(Ea::taParty->getName()); + if (socialWindow) + socialWindow->updateParty(); + } +} + +void PartyRecv::processPartyMessage(Net::MessageIn &msg) +{ + const int msgLength = msg.readInt16("len") - 8; + if (msgLength <= 0) + return; + + const BeingId id = msg.readBeingId("id"); + std::string chatMsg = msg.readString(msgLength, "message"); + + const size_t pos = chatMsg.find(" : ", 0); + if (pos != std::string::npos) + chatMsg.erase(0, pos + 3); + + if (Ea::taParty && partyTab) + { + const PartyMember *const member = Ea::taParty->getMember(id); + if (member) + { + partyTab->chatLog(member->getName(), chatMsg); + } + else + { + NotifyManager::notify(NotifyTypes::PARTY_UNKNOWN_USER_MSG, + chatMsg); + } + } +} + +void PartyRecv::processPartyInviteResponse(Net::MessageIn &msg) +{ + if (!partyTab) + return; + + const std::string nick = msg.readString(24, "nick"); + + switch (msg.readInt32("result")) + { + case 0: + NotifyManager::notify(NotifyTypes::PARTY_INVITE_ALREADY_MEMBER, + nick); + break; + case 1: + NotifyManager::notify(NotifyTypes::PARTY_INVITE_REFUSED, nick); + break; + case 2: + NotifyManager::notify(NotifyTypes::PARTY_INVITE_DONE, nick); + break; + case 3: + NotifyManager::notify(NotifyTypes::PARTY_INVITE_PARTY_FULL, + nick); + break; + case 4: + NotifyManager::notify(NotifyTypes::PARTY_INVITE_PARTY_SAME_ACCOUNT, + nick); + break; + case 5: + NotifyManager::notify( + NotifyTypes::PARTY_INVITE_PARTY_BLOCKED_INVITE, + nick); + break; + case 7: + NotifyManager::notify(NotifyTypes::PARTY_INVITE_PARTY_NOT_ONLINE, + nick); + break; + default: + NotifyManager::notify(NotifyTypes::PARTY_INVITE_ERROR, nick); + break; + } +} + +void PartyRecv::processPartyItemPickup(Net::MessageIn &msg) +{ + UNIMPLIMENTEDPACKET; + // +++ probably need add option to show pickup notifications + // in party tab + msg.readBeingId("account id"); + msg.readInt16("item id"); + msg.readUInt8("identify"); + msg.readUInt8("attribute"); + msg.readUInt8("refine"); + for (int f = 0; f < 4; f++) + msg.readInt16("card"); + msg.readInt16("equip location"); + msg.readUInt8("item type"); + // for color can be used ItemColorManager +} + +void PartyRecv::processPartyLeader(Net::MessageIn &msg) +{ + PartyMember *const oldMember = Ea::taParty->getMember( + msg.readBeingId("old leder id")); + PartyMember *const newMember = Ea::taParty->getMember( + msg.readBeingId("new leder id")); + if (oldMember) + oldMember->setLeader(false); + if (newMember) + newMember->setLeader(true); +} + +void PartyRecv::processPartyInvited(Net::MessageIn &msg) +{ + const BeingId id = msg.readBeingId("account id"); + const std::string partyName = msg.readString(24, "party name"); + + std::string nick; + + if (actorManager) + { + const Being *const being = actorManager->findBeing(id); + if (being) + { + if (being->getType() == ActorType::Player) + nick = being->getName(); + } + } + + if (socialWindow) + socialWindow->showPartyInvite(partyName, nick, 0); +} + +} // namespace EAthena diff --git a/src/net/eathena/partyrecv.h b/src/net/eathena/partyrecv.h new file mode 100644 index 000000000..623051a4f --- /dev/null +++ b/src/net/eathena/partyrecv.h @@ -0,0 +1,45 @@ +/* + * The ManaPlus Client + * Copyright (C) 2008 Lloyd Bryant + * 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 . + */ + +#ifndef NET_EATHENA_PARTYRECV_H +#define NET_EATHENA_PARTYRECV_H + +#include "net/eathena/messagehandler.h" + +#include "net/ea/partyhandler.h" + +namespace EAthena +{ + namespace PartyRecv + { + void processPartySettings(Net::MessageIn &msg); + void processPartyInvitationStats(Net::MessageIn &msg); + void processPartyMemberInfo(Net::MessageIn &msg); + void processPartyInfo(Net::MessageIn &msg); + void processPartyMessage(Net::MessageIn &msg); + void processPartyInviteResponse(Net::MessageIn &msg); + void processPartyItemPickup(Net::MessageIn &msg); + void processPartyLeader(Net::MessageIn &msg); + void processPartyInvited(Net::MessageIn &msg); + } // namespace PartyRecv +} // namespace EAthena + +#endif // NET_EATHENA_PARTYRECV_H diff --git a/src/net/tmwa/partyhandler.cpp b/src/net/tmwa/partyhandler.cpp index 92e26ec81..90fbee9d3 100644 --- a/src/net/tmwa/partyhandler.cpp +++ b/src/net/tmwa/partyhandler.cpp @@ -34,7 +34,10 @@ #include "gui/widgets/tabs/chat/partytab.h" +#include "net/ea/partyrecv.h" + #include "net/tmwa/messageout.h" +#include "net/tmwa/partyrecv.h" #include "net/tmwa/protocol.h" #include "debug.h" @@ -76,34 +79,34 @@ void PartyHandler::handleMessage(Net::MessageIn &msg) switch (msg.getId()) { case SMSG_PARTY_CREATE: - processPartyCreate(msg); + Ea::PartyRecv::processPartyCreate(msg); break; case SMSG_PARTY_INFO: - processPartyInfo(msg); + PartyRecv::processPartyInfo(msg); break; case SMSG_PARTY_INVITE_RESPONSE: - processPartyInviteResponse(msg); + PartyRecv::processPartyInviteResponse(msg); break; case SMSG_PARTY_INVITED: - processPartyInvited(msg); + PartyRecv::processPartyInvited(msg); break; case SMSG_PARTY_SETTINGS: - processPartySettings(msg); + PartyRecv::processPartySettings(msg); break; case SMSG_PARTY_MOVE: - processPartyMove(msg); + PartyRecv::processPartyMove(msg); break; case SMSG_PARTY_LEAVE: - processPartyLeave(msg); + Ea::PartyRecv::processPartyLeave(msg); break; case SMSG_PARTY_UPDATE_HP: - processPartyUpdateHp(msg); + PartyRecv::processPartyUpdateHp(msg); break; case SMSG_PARTY_UPDATE_COORDS: - processPartyUpdateCoords(msg); + Ea::PartyRecv::processPartyUpdateCoords(msg); break; case SMSG_PARTY_MESSAGE: - processPartyMessage(msg); + PartyRecv::processPartyMessage(msg); break; default: @@ -189,7 +192,8 @@ void PartyHandler::setShareExperience(const PartyShareT share) const createOutPacket(CMSG_PARTY_SETTINGS); outMsg.writeInt16(static_cast(share), "share exp"); - outMsg.writeInt16(static_cast(mShareItems), "share items"); + outMsg.writeInt16(static_cast(Ea::PartyRecv::mShareItems), + "share items"); } void PartyHandler::setShareItems(const PartyShareT share) const @@ -198,185 +202,11 @@ void PartyHandler::setShareItems(const PartyShareT share) const return; createOutPacket(CMSG_PARTY_SETTINGS); - outMsg.writeInt16(static_cast(mShareExp), "share exp"); + outMsg.writeInt16(static_cast(Ea::PartyRecv::mShareExp), + "share exp"); outMsg.writeInt16(static_cast(share), "share items"); } -void PartyHandler::processPartySettings(Net::MessageIn &msg) -{ - if (!partyTab) - { - if (!chatWindow) - return; - - createTab(); - } - - // These seem to indicate the sharing mode for exp and items - const PartyShareT exp = static_cast( - msg.readInt16("share exp")); - const PartyShareT item = static_cast( - msg.readInt16("share items")); - processPartySettingsContinue(msg, exp, item); -} - -void PartyHandler::processPartyInfo(Net::MessageIn &msg) -{ - bool isOldParty = false; - std::set names; - std::set onlineNames; - if (!Ea::taParty) - { - logger->log1("error: party empty in SMSG_PARTY_INFO"); - Ea::taParty = Party::getParty(1); - } - if (Ea::taParty) - { - if (Ea::taParty->getNumberOfElements() > 1) - { - isOldParty = true; - Ea::taParty->getNamesSet(names); - const Party::MemberList *const members = Ea::taParty->getMembers(); - FOR_EACHP (Party::MemberList::const_iterator, it, members) - { - if ((*it)->getOnline()) - onlineNames.insert((*it)->getName()); - } - if (localPlayer) - onlineNames.insert(localPlayer->getName()); - } - } - - if (!localPlayer) - logger->log1("error: localPlayer==0 in SMSG_PARTY_INFO"); - - if (Ea::taParty) - Ea::taParty->clearMembers(); - - const int length = msg.readInt16("len"); - if (Ea::taParty) - Ea::taParty->setName(msg.readString(24, "party name")); - - const int count = (length - 28) / 46; - if (localPlayer && Ea::taParty) - { - localPlayer->setParty(Ea::taParty); - localPlayer->setPartyName(Ea::taParty->getName()); - } - - for (int i = 0; i < count; i++) - { - const BeingId id = msg.readBeingId("id"); - std::string nick = msg.readString(24, "nick"); - std::string map = msg.readString(16, "map"); - const bool leader = msg.readUInt8("leader") == 0U; - const bool online = msg.readUInt8("online") == 0U; - - if (Ea::taParty) - { - bool joined(false); - - if (isOldParty) - { - if (names.find(nick) == names.end()) - { - NotifyManager::notify(NotifyTypes::PARTY_USER_JOINED, - nick); - joined = true; - } - } - PartyMember *const member = Ea::taParty->addMember(id, nick); - if (member) - { - if (!joined && partyTab) - { - if (!names.empty() && ((onlineNames.find(nick) - == onlineNames.end() && online) - || (onlineNames.find(nick) != onlineNames.end() - && !online))) - { - partyTab->showOnline(nick, fromBool(online, Online)); - } - - member->setLeader(leader); - member->setOnline(online); - member->setMap(map); - } - else - { - member->setLeader(leader); - member->setOnline(online); - member->setMap(map); - } - } - } - } - - if (Ea::taParty) - Ea::taParty->sort(); - - if (localPlayer && Ea::taParty) - { - localPlayer->setParty(Ea::taParty); - localPlayer->setPartyName(Ea::taParty->getName()); - if (socialWindow) - socialWindow->updateParty(); - } -} - -void PartyHandler::processPartyMessage(Net::MessageIn &msg) -{ - const int msgLength = msg.readInt16("len") - 8; - if (msgLength <= 0) - return; - - const BeingId id = msg.readBeingId("id"); - const std::string chatMsg = msg.readString(msgLength, "message"); - - if (Ea::taParty && partyTab) - { - const PartyMember *const member = Ea::taParty->getMember(id); - if (member) - { - partyTab->chatLog(member->getName(), chatMsg); - } - else - { - NotifyManager::notify(NotifyTypes::PARTY_UNKNOWN_USER_MSG, - chatMsg); - } - } -} - -void PartyHandler::processPartyInviteResponse(Net::MessageIn &msg) -{ - if (!partyTab) - return; - - const std::string nick = msg.readString(24, "nick"); - - switch (msg.readUInt8("status")) - { - case 0: - NotifyManager::notify(NotifyTypes::PARTY_INVITE_ALREADY_MEMBER, - nick); - break; - case 1: - NotifyManager::notify(NotifyTypes::PARTY_INVITE_REFUSED, nick); - break; - case 2: - NotifyManager::notify(NotifyTypes::PARTY_INVITE_DONE, nick); - break; - case 3: - NotifyManager::notify(NotifyTypes::PARTY_INVITE_PARTY_FULL, - nick); - break; - default: - NotifyManager::notify(NotifyTypes::PARTY_INVITE_ERROR, nick); - break; - } -} - void PartyHandler::changeLeader(const std::string &name A_UNUSED) const { } @@ -385,78 +215,4 @@ void PartyHandler::allowInvite(const bool allow A_UNUSED) const { } -void PartyHandler::processPartyInvited(Net::MessageIn &msg) -{ - const BeingId id = msg.readBeingId("account id"); - const std::string partyName = msg.readString(24, "party name"); - std::string nick; - - if (actorManager) - { - const Being *const being = actorManager->findBeing(id); - if (being) - { - if (being->getType() == ActorType::Player) - nick = being->getName(); - } - } - - if (socialWindow) - socialWindow->showPartyInvite(partyName, nick, 0); -} - -void PartyHandler::processPartyMove(Net::MessageIn &msg) -{ - const BeingId id = msg.readBeingId("id"); - PartyMember *m = nullptr; - if (Ea::taParty) - m = Ea::taParty->getMember(id); - if (m) - { - msg.readInt32("unused"); - m->setX(msg.readInt16("x")); - m->setY(msg.readInt16("y")); - const bool online = msg.readUInt8("online") != 0; - if (m->getOnline() != online) - partyTab->showOnline(m->getName(), fromBool(online, Online)); - m->setOnline(online); - msg.readString(24, "party"); - msg.readString(24, "nick"); - m->setMap(msg.readString(16, "map")); - } - else - { - msg.readInt32("unused"); - msg.readInt16("x"); - msg.readInt16("y"); - msg.readUInt8("online"); - msg.readString(24, "party"); - msg.readString(24, "nick"); - msg.readString(16, "map"); - } -} - -void PartyHandler::processPartyUpdateHp(Net::MessageIn &msg) -{ - const BeingId id = msg.readBeingId("id"); - const int hp = msg.readInt16("hp"); - const int maxhp = msg.readInt16("max hp"); - PartyMember *m = nullptr; - if (Ea::taParty) - m = Ea::taParty->getMember(id); - if (m) - { - m->setHp(hp); - m->setMaxHp(maxhp); - } - - // The server only sends this when the member is in range, so - // lets make sure they get the party hilight. - if (actorManager && Ea::taParty) - { - if (Being *const b = actorManager->findBeing(id)) - b->setParty(Ea::taParty); - } -} - } // namespace TmwAthena diff --git a/src/net/tmwa/partyhandler.h b/src/net/tmwa/partyhandler.h index 30c837c37..47fe9c232 100644 --- a/src/net/tmwa/partyhandler.h +++ b/src/net/tmwa/partyhandler.h @@ -62,21 +62,6 @@ class PartyHandler final : public MessageHandler, public Ea::PartyHandler void changeLeader(const std::string &name) const override final; void allowInvite(const bool allow) const override final; - - protected: - static void processPartySettings(Net::MessageIn &msg); - - static void processPartyInfo(Net::MessageIn &msg); - - static void processPartyMessage(Net::MessageIn &msg); - - static void processPartyInviteResponse(Net::MessageIn &msg); - - static void processPartyInvited(Net::MessageIn &msg); - - static void processPartyMove(Net::MessageIn &msg); - - static void processPartyUpdateHp(Net::MessageIn &msg); }; } // namespace TmwAthena diff --git a/src/net/tmwa/partyrecv.cpp b/src/net/tmwa/partyrecv.cpp new file mode 100644 index 000000000..eaee64943 --- /dev/null +++ b/src/net/tmwa/partyrecv.cpp @@ -0,0 +1,296 @@ +/* + * The ManaPlus Client + * Copyright (C) 2008 Lloyd Bryant + * 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 . + */ + +#include "net/tmwa/partyrecv.h" + +#include "actormanager.h" +#include "notifymanager.h" +#include "party.h" + +#include "being/localplayer.h" + +#include "enums/resources/notifytypes.h" + +#include "gui/windows/chatwindow.h" +#include "gui/windows/socialwindow.h" + +#include "gui/widgets/tabs/chat/partytab.h" + +#include "net/ea/partyrecv.h" + +#include "net/tmwa/messageout.h" +#include "net/tmwa/protocol.h" + +#include "debug.h" + +namespace TmwAthena +{ + +void PartyRecv::processPartySettings(Net::MessageIn &msg) +{ + if (!partyTab) + { + if (!chatWindow) + return; + + Ea::PartyRecv::createTab(); + } + + // These seem to indicate the sharing mode for exp and items + const PartyShareT exp = static_cast( + msg.readInt16("share exp")); + const PartyShareT item = static_cast( + msg.readInt16("share items")); + Ea::PartyRecv::processPartySettingsContinue(msg, exp, item); +} + +void PartyRecv::processPartyInfo(Net::MessageIn &msg) +{ + bool isOldParty = false; + std::set names; + std::set onlineNames; + if (!Ea::taParty) + { + logger->log1("error: party empty in SMSG_PARTY_INFO"); + Ea::taParty = Party::getParty(1); + } + if (Ea::taParty) + { + if (Ea::taParty->getNumberOfElements() > 1) + { + isOldParty = true; + Ea::taParty->getNamesSet(names); + const Party::MemberList *const members = Ea::taParty->getMembers(); + FOR_EACHP (Party::MemberList::const_iterator, it, members) + { + if ((*it)->getOnline()) + onlineNames.insert((*it)->getName()); + } + if (localPlayer) + onlineNames.insert(localPlayer->getName()); + } + } + + if (!localPlayer) + logger->log1("error: localPlayer==0 in SMSG_PARTY_INFO"); + + if (Ea::taParty) + Ea::taParty->clearMembers(); + + const int length = msg.readInt16("len"); + if (Ea::taParty) + Ea::taParty->setName(msg.readString(24, "party name")); + + const int count = (length - 28) / 46; + if (localPlayer && Ea::taParty) + { + localPlayer->setParty(Ea::taParty); + localPlayer->setPartyName(Ea::taParty->getName()); + } + + for (int i = 0; i < count; i++) + { + const BeingId id = msg.readBeingId("id"); + std::string nick = msg.readString(24, "nick"); + std::string map = msg.readString(16, "map"); + const bool leader = msg.readUInt8("leader") == 0U; + const bool online = msg.readUInt8("online") == 0U; + + if (Ea::taParty) + { + bool joined(false); + + if (isOldParty) + { + if (names.find(nick) == names.end()) + { + NotifyManager::notify(NotifyTypes::PARTY_USER_JOINED, + nick); + joined = true; + } + } + PartyMember *const member = Ea::taParty->addMember(id, nick); + if (member) + { + if (!joined && partyTab) + { + if (!names.empty() && ((onlineNames.find(nick) + == onlineNames.end() && online) + || (onlineNames.find(nick) != onlineNames.end() + && !online))) + { + partyTab->showOnline(nick, fromBool(online, Online)); + } + + member->setLeader(leader); + member->setOnline(online); + member->setMap(map); + } + else + { + member->setLeader(leader); + member->setOnline(online); + member->setMap(map); + } + } + } + } + + if (Ea::taParty) + Ea::taParty->sort(); + + if (localPlayer && Ea::taParty) + { + localPlayer->setParty(Ea::taParty); + localPlayer->setPartyName(Ea::taParty->getName()); + if (socialWindow) + socialWindow->updateParty(); + } +} + +void PartyRecv::processPartyMessage(Net::MessageIn &msg) +{ + const int msgLength = msg.readInt16("len") - 8; + if (msgLength <= 0) + return; + + const BeingId id = msg.readBeingId("id"); + const std::string chatMsg = msg.readString(msgLength, "message"); + + if (Ea::taParty && partyTab) + { + const PartyMember *const member = Ea::taParty->getMember(id); + if (member) + { + partyTab->chatLog(member->getName(), chatMsg); + } + else + { + NotifyManager::notify(NotifyTypes::PARTY_UNKNOWN_USER_MSG, + chatMsg); + } + } +} + +void PartyRecv::processPartyInviteResponse(Net::MessageIn &msg) +{ + if (!partyTab) + return; + + const std::string nick = msg.readString(24, "nick"); + + switch (msg.readUInt8("status")) + { + case 0: + NotifyManager::notify(NotifyTypes::PARTY_INVITE_ALREADY_MEMBER, + nick); + break; + case 1: + NotifyManager::notify(NotifyTypes::PARTY_INVITE_REFUSED, nick); + break; + case 2: + NotifyManager::notify(NotifyTypes::PARTY_INVITE_DONE, nick); + break; + case 3: + NotifyManager::notify(NotifyTypes::PARTY_INVITE_PARTY_FULL, + nick); + break; + default: + NotifyManager::notify(NotifyTypes::PARTY_INVITE_ERROR, nick); + break; + } +} + +void PartyRecv::processPartyInvited(Net::MessageIn &msg) +{ + const BeingId id = msg.readBeingId("account id"); + const std::string partyName = msg.readString(24, "party name"); + std::string nick; + + if (actorManager) + { + const Being *const being = actorManager->findBeing(id); + if (being) + { + if (being->getType() == ActorType::Player) + nick = being->getName(); + } + } + + if (socialWindow) + socialWindow->showPartyInvite(partyName, nick, 0); +} + +void PartyRecv::processPartyMove(Net::MessageIn &msg) +{ + const BeingId id = msg.readBeingId("id"); + PartyMember *m = nullptr; + if (Ea::taParty) + m = Ea::taParty->getMember(id); + if (m) + { + msg.readInt32("unused"); + m->setX(msg.readInt16("x")); + m->setY(msg.readInt16("y")); + const bool online = msg.readUInt8("online") != 0; + if (m->getOnline() != online) + partyTab->showOnline(m->getName(), fromBool(online, Online)); + m->setOnline(online); + msg.readString(24, "party"); + msg.readString(24, "nick"); + m->setMap(msg.readString(16, "map")); + } + else + { + msg.readInt32("unused"); + msg.readInt16("x"); + msg.readInt16("y"); + msg.readUInt8("online"); + msg.readString(24, "party"); + msg.readString(24, "nick"); + msg.readString(16, "map"); + } +} + +void PartyRecv::processPartyUpdateHp(Net::MessageIn &msg) +{ + const BeingId id = msg.readBeingId("id"); + const int hp = msg.readInt16("hp"); + const int maxhp = msg.readInt16("max hp"); + PartyMember *m = nullptr; + if (Ea::taParty) + m = Ea::taParty->getMember(id); + if (m) + { + m->setHp(hp); + m->setMaxHp(maxhp); + } + + // The server only sends this when the member is in range, so + // lets make sure they get the party hilight. + if (actorManager && Ea::taParty) + { + if (Being *const b = actorManager->findBeing(id)) + b->setParty(Ea::taParty); + } +} + +} // namespace TmwAthena diff --git a/src/net/tmwa/partyrecv.h b/src/net/tmwa/partyrecv.h new file mode 100644 index 000000000..0d94cd738 --- /dev/null +++ b/src/net/tmwa/partyrecv.h @@ -0,0 +1,43 @@ +/* + * The ManaPlus Client + * Copyright (C) 2008 Lloyd Bryant + * 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 . + */ + +#ifndef NET_TMWA_PARTYRECV_H +#define NET_TMWA_PARTYRECV_H + +#include "net/tmwa/messagehandler.h" + +#include "net/ea/partyhandler.h" + +namespace TmwAthena +{ + namespace PartyRecv + { + void processPartySettings(Net::MessageIn &msg); + void processPartyInfo(Net::MessageIn &msg); + void processPartyMessage(Net::MessageIn &msg); + void processPartyInviteResponse(Net::MessageIn &msg); + void processPartyInvited(Net::MessageIn &msg); + void processPartyMove(Net::MessageIn &msg); + void processPartyUpdateHp(Net::MessageIn &msg); + } // namespace PartyRecv +} // namespace TmwAthena + +#endif // NET_TMWA_PARTYRECV_H -- cgit v1.2.3-60-g2f50