/* * The ManaPlus Client * Copyright (C) 2004-2009 The Mana World Development Team * Copyright (C) 2009-2010 The Mana Developers * Copyright (C) 2011-2014 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/beinghandler.h" #include "actormanager.h" #include "guild.h" #include "guildmanager.h" #include "party.h" #include "position.h" #include "being/localplayer.h" #include "net/tmwa/messageout.h" #include "net/tmwa/protocol.h" #include "resources/iteminfo.h" #include "resources/db/itemdb.h" #include "utils/stringutils.h" #include "utils/timer.h" #include "debug.h" extern Net::BeingHandler *beingHandler; extern int serverVersion; namespace TmwAthena { BeingHandler::BeingHandler(const bool enableSync) : MessageHandler(), Ea::BeingHandler(enableSync) { static const uint16_t _messages[] = { SMSG_BEING_VISIBLE, SMSG_BEING_MOVE, SMSG_BEING_MOVE2, SMSG_BEING_REMOVE, SMSG_SKILL_DAMAGE, SMSG_BEING_ACTION, SMSG_BEING_SELFEFFECT, SMSG_BEING_EMOTION, SMSG_BEING_CHANGE_LOOKS, SMSG_BEING_CHANGE_LOOKS2, SMSG_BEING_NAME_RESPONSE, SMSG_BEING_NAME_RESPONSE2, SMSG_PLAYER_GUILD_PARTY_INFO, SMSG_BEING_CHANGE_DIRECTION, SMSG_PLAYER_UPDATE_1, SMSG_PLAYER_UPDATE_2, SMSG_PLAYER_MOVE, SMSG_PLAYER_STOP, SMSG_PLAYER_MOVE_TO_ATTACK, SMSG_PLAYER_STATUS_CHANGE, SMSG_BEING_STATUS_CHANGE, SMSG_BEING_RESURRECT, SMSG_SOLVE_CHAR_NAME, SMSG_BEING_SPAWN, SMSG_SKILL_CASTING, SMSG_SKILL_CAST_CANCEL, SMSG_SKILL_NO_DAMAGE, SMSG_BEING_IP_RESPONSE, SMSG_PVP_MAP_MODE, SMSG_PVP_SET, SMSG_BEING_MOVE3, 0 }; handledMessages = _messages; beingHandler = this; } void BeingHandler::requestNameById(const int id) const { MessageOut outMsg(0x0094); outMsg.writeInt32(id); // readLong(2)); } void BeingHandler::handleMessage(Net::MessageIn &msg) { BLOCK_START("BeingHandler::handleMessage") switch (msg.getId()) { case SMSG_BEING_VISIBLE: case SMSG_BEING_MOVE: processBeingVisibleOrMove(msg, msg.getId() == SMSG_BEING_VISIBLE); break; case SMSG_BEING_MOVE2: processBeingMove2(msg); break; case SMSG_BEING_MOVE3: processBeingMove3(msg); break; case SMSG_BEING_SPAWN: processBeingSpawn(msg); break; case SMSG_BEING_REMOVE: processBeingRemove(msg); break; case SMSG_BEING_RESURRECT: processBeingResurrect(msg); break; case SMSG_SKILL_DAMAGE: processSkillDamage(msg); break; case SMSG_BEING_ACTION: processBeingAction(msg); break; case SMSG_BEING_SELFEFFECT: processBeingSelfEffect(msg); break; case SMSG_BEING_EMOTION: processBeingEmotion(msg); break; case SMSG_BEING_CHANGE_LOOKS: case SMSG_BEING_CHANGE_LOOKS2: processBeingChangeLook(msg, msg.getId() == SMSG_BEING_CHANGE_LOOKS2); break; case SMSG_BEING_NAME_RESPONSE: processNameResponse(msg); break; case SMSG_BEING_NAME_RESPONSE2: processNameResponse2(msg); break; case SMSG_BEING_IP_RESPONSE: processIpResponse(msg); break; case SMSG_SOLVE_CHAR_NAME: break; case SMSG_PLAYER_GUILD_PARTY_INFO: processPlayerGuilPartyInfo(msg); break; case SMSG_BEING_CHANGE_DIRECTION: processBeingChangeDirection(msg); break; case SMSG_PLAYER_UPDATE_1: case SMSG_PLAYER_UPDATE_2: case SMSG_PLAYER_MOVE: int type; switch (msg.getId()) { case SMSG_PLAYER_UPDATE_1: type = 1; break; case SMSG_PLAYER_UPDATE_2: type = 2; break; case SMSG_PLAYER_MOVE: type = 3; break; default: return; } processPlayerMoveUpdate(msg, type); break; case SMSG_PLAYER_STOP: processPlayerStop(msg); break; case SMSG_PLAYER_MOVE_TO_ATTACK: processPlayerMoveToAttack(msg); break; case SMSG_PLAYER_STATUS_CHANGE: processPlaterStatusChange(msg); break; case SMSG_BEING_STATUS_CHANGE: processBeingStatusChange(msg); break; case SMSG_SKILL_CASTING: processSkilCasting(msg); break; case SMSG_SKILL_CAST_CANCEL: msg.readInt32(); // id break; case SMSG_SKILL_NO_DAMAGE: processSkillNoDamage(msg); break; case SMSG_PVP_MAP_MODE: processPvpMapMode(msg); break; case SMSG_PVP_SET: processPvpSet(msg); break; default: break; } BLOCK_END("BeingHandler::handleMessage") } void BeingHandler::undress(Being *const being) const { being->setSprite(SPRITE_BOTTOMCLOTHES, 0); being->setSprite(SPRITE_TOPCLOTHES, 0); being->setSprite(SPRITE_HAT, 0); being->setSprite(SPRITE_SHOE, 0); being->setSprite(SPRITE_GLOVES, 0); // being->setSprite(SPRITE_WEAPON, 0, "", true); } void BeingHandler::processBeingChangeLook(Net::MessageIn &msg, const bool look2) const { if (!actorManager) return; /* * SMSG_BEING_CHANGE_LOOKS (0x00c3) and * SMSG_BEING_CHANGE_LOOKS2 (0x01d7) do basically the same * thing. The difference is that ...LOOKS carries a single * 8 bit value, where ...LOOKS2 carries two 16 bit values. * * If type = 2, then the first 16 bit value is the weapon ID, * and the second 16 bit value is the shield ID. If no * shield is equipped, or type is not 2, then the second * 16 bit value will be 0. */ Being *const dstBeing = actorManager->findBeing(msg.readInt32()); if (!dstBeing) return; const int type = msg.readInt8(); int id = 0; int id2 = 0; const std::string color; if (!look2) { id = msg.readInt8(); id2 = 1; // default color } else { // SMSG_BEING_CHANGE_LOOKS2 id = msg.readInt16(); if (type == 2 || serverVersion > 0) id2 = msg.readInt16(); else id2 = 1; } if (dstBeing->getType() == Being::PLAYER) dstBeing->setOtherTime(); if (!player_node) return; switch (type) { case 0: // change race dstBeing->setSubtype(static_cast(id), dstBeing->getLook()); break; case 1: // eAthena LOOK_HAIR { const uint8_t look = static_cast(id / 256U); const int hair = id % 256; dstBeing->setHairStyle(SPRITE_HAIR, hair * -1); dstBeing->setLook(look); break; } case 2: // Weapon ID in id, Shield ID in id2 dstBeing->setSprite(SPRITE_WEAPON, id, "", 1, true); if (!mHideShield) dstBeing->setSprite(SPRITE_SHIELD, id2); player_node->imitateOutfit(dstBeing, SPRITE_SHIELD); break; case 3: // Change lower headgear for eAthena, pants for us dstBeing->setSprite(SPRITE_BOTTOMCLOTHES, id, color, static_cast(id2)); player_node->imitateOutfit(dstBeing, SPRITE_BOTTOMCLOTHES); break; case 4: // Change upper headgear for eAthena, hat for us dstBeing->setSprite(SPRITE_HAT, id, color, static_cast(id2)); player_node->imitateOutfit(dstBeing, SPRITE_HAT); break; case 5: // Change middle headgear for eathena, armor for us dstBeing->setSprite(SPRITE_TOPCLOTHES, id, color, static_cast(id2)); player_node->imitateOutfit(dstBeing, SPRITE_TOPCLOTHES); break; case 6: // eAthena LOOK_HAIR_COLOR dstBeing->setHairColor(SPRITE_HAIR, id); break; case 7: // Clothes color // ignoring it break; case 8: // eAthena LOOK_SHIELD if (!mHideShield) { dstBeing->setSprite(SPRITE_SHIELD, id, color, static_cast(id2)); } player_node->imitateOutfit(dstBeing, SPRITE_SHIELD); break; case 9: // eAthena LOOK_SHOES dstBeing->setSprite(SPRITE_SHOE, id, color, static_cast(id2)); player_node->imitateOutfit(dstBeing, SPRITE_SHOE); break; case 10: // LOOK_GLOVES dstBeing->setSprite(SPRITE_GLOVES, id, color, static_cast(id2)); player_node->imitateOutfit(dstBeing, SPRITE_GLOVES); break; case 11: // LOOK_CAPE dstBeing->setSprite(SPRITE_CAPE, id, color, static_cast(id2)); player_node->imitateOutfit(dstBeing, SPRITE_CAPE); break; case 12: dstBeing->setSprite(SPRITE_MISC1, id, color, static_cast(id2)); player_node->imitateOutfit(dstBeing, SPRITE_MISC1); break; case 13: dstBeing->setSprite(SPRITE_MISC2, id, color, static_cast(id2)); player_node->imitateOutfit(dstBeing, SPRITE_MISC2); break; case 14: dstBeing->setSprite(SPRITE_EVOL1, id, color, static_cast(id2)); player_node->imitateOutfit(dstBeing, SPRITE_EVOL1); break; case 15: dstBeing->setSprite(SPRITE_EVOL2, id, color, static_cast(id2)); player_node->imitateOutfit(dstBeing, SPRITE_EVOL2); break; case 16: dstBeing->setLook(static_cast(id)); break; default: logger->log("QQQ3 CHANGE_LOOKS: unsupported type: " "%d, id: %d", type, id); logger->log("ID: " + toString(dstBeing->getId())); logger->log("name: " + toString(dstBeing->getName())); break; } } void BeingHandler::processNameResponse2(Net::MessageIn &msg) { if (!actorManager || !player_node) return; const int len = msg.readInt16(); const int beingId = msg.readInt32(); const std::string str = msg.readString(len - 8); Being *const dstBeing = actorManager->findBeing(beingId); if (dstBeing) { if (beingId == player_node->getId()) { player_node->pingResponse(); } else { dstBeing->setName(str); dstBeing->updateGuild(); dstBeing->addToCache(); if (dstBeing->getType() == Being::PLAYER) dstBeing->updateColors(); if (player_node) { const Party *const party = player_node->getParty(); if (party && party->isMember(dstBeing->getId())) { PartyMember *const member = party->getMember( dstBeing->getId()); if (member) member->setName(dstBeing->getName()); } player_node->checkNewName(dstBeing); } } } } void BeingHandler::processPlayerMoveUpdate(Net::MessageIn &msg, const int msgType) const { if (!actorManager || !player_node) return; // An update about a player, potentially including movement. const int id = msg.readInt32(); const int16_t speed = msg.readInt16(); const uint16_t stunMode = msg.readInt16(); // opt1; uint32_t statusEffects = msg.readInt16(); // opt2; statusEffects |= (static_cast(msg.readInt16())) << 16; // status.options; Aethyra uses this as misc2 const int16_t job = msg.readInt16(); int disguiseId = 0; if (id < 110000000 && job >= 1000) disguiseId = job; Being *dstBeing = actorManager->findBeing(id); if (!dstBeing) { if (actorManager->isBlocked(id) == true) return; dstBeing = createBeing(id, job); if (!dstBeing) return; } else if (disguiseId) { actorManager->undelete(dstBeing); if (serverVersion < 1) requestNameById(id); } uint8_t dir = dstBeing->getDirectionDelayed(); if (dir) { if (dir != dstBeing->getDirection()) dstBeing->setDirection(dir); } if (Party *const party = player_node->getParty()) { if (party->isMember(id)) dstBeing->setParty(party); } dstBeing->setWalkSpeed(Vector(speed, speed, 0)); const int hairStyle = msg.readInt8(); const uint8_t look = msg.readInt8(); dstBeing->setSubtype(job, look); const uint16_t weapon = msg.readInt16(); const uint16_t shield = msg.readInt16(); const uint16_t headBottom = msg.readInt16(); if (msgType == 3) msg.readInt32(); // server tick const uint16_t headTop = msg.readInt16(); const uint16_t headMid = msg.readInt16(); const int hairColor = msg.readInt8(); msg.readInt8(); // free unsigned char colors[9]; colors[0] = msg.readInt8(); colors[1] = msg.readInt8(); colors[2] = msg.readInt8(); msg.readInt8(); // unused const int guild = msg.readInt32(); // guild if (!guildManager || !GuildManager::getEnableGuildBot()) { if (guild == 0) dstBeing->clearGuilds(); else dstBeing->setGuild(Guild::getGuild(static_cast(guild))); } msg.readInt16(); // emblem msg.readInt16(); // manner dstBeing->setStatusEffectBlock(32, msg.readInt16()); // opt3 msg.readInt8(); // karma // reserving bit for future usage dstBeing->setGender(Being::intToGender( static_cast(msg.readInt8() & 3))); if (!disguiseId) { // Set these after the gender, as the sprites may be gender-specific dstBeing->updateSprite(SPRITE_WEAPON, weapon, "", 1, true); if (!mHideShield) dstBeing->updateSprite(SPRITE_SHIELD, shield); if (serverVersion > 0) { dstBeing->updateSprite(SPRITE_BOTTOMCLOTHES, headBottom, "", colors[0]); dstBeing->updateSprite(SPRITE_TOPCLOTHES, headMid, "", colors[2]); dstBeing->updateSprite(SPRITE_HAT, headTop, "", colors[1]); } else { dstBeing->updateSprite(SPRITE_BOTTOMCLOTHES, headBottom); dstBeing->updateSprite(SPRITE_TOPCLOTHES, headMid); dstBeing->updateSprite(SPRITE_HAT, headTop); } dstBeing->updateSprite(SPRITE_HAIR, hairStyle * -1, ItemDB::get(-hairStyle).getDyeColorsString(hairColor)); dstBeing->setHairColor(hairColor); } player_node->imitateOutfit(dstBeing); if (msgType == 3) { uint16_t srcX, srcY, dstX, dstY; msg.readCoordinatePair(srcX, srcY, dstX, dstY); player_node->followMoveTo(dstBeing, srcX, srcY, dstX, dstY); dstBeing->setTileCoords(srcX, srcY); dstBeing->setDestination(dstX, dstY); // because server don't send direction in move packet, // we fixing it if (srcX != dstX || srcY != dstY) { const int d = dstBeing->calcDirection(dstX, dstY); if (d && dstBeing->getDirection() != d) dstBeing->setDirectionDelayed(static_cast(d)); } if (player_node->getCurrentAction() != BeingAction::STAND) player_node->imitateAction(dstBeing, BeingAction::STAND); if (player_node->getDirection() != dstBeing->getDirection()) { player_node->imitateDirection(dstBeing, dstBeing->getDirection()); } } else { // uint8_t dir; uint16_t x, y; msg.readCoordinates(x, y, dir); dstBeing->setTileCoords(x, y); dstBeing->setDirection(dir); player_node->imitateDirection(dstBeing, dir); } const uint16_t gmstatus = msg.readInt16(); if (gmstatus & 0x80) dstBeing->setGM(true); if (msgType == 1 || msgType == 2) { const int type = msg.readInt8(); switch (type) { case 0: dstBeing->setAction(BeingAction::STAND, 0); player_node->imitateAction(dstBeing, BeingAction::STAND); break; case 1: if (dstBeing->getCurrentAction() != BeingAction::DEAD) { dstBeing->setAction(BeingAction::DEAD, 0); dstBeing->recalcSpritesOrder(); } break; case 2: dstBeing->setAction(BeingAction::SIT, 0); player_node->imitateAction(dstBeing, BeingAction::SIT); break; default: // need set stand state? logger->log("QQQ2 SMSG_PLAYER_UPDATE_1:" + toString(id) + " " + toString(type)); logger->log("dstBeing id:" + toString(dstBeing->getId())); logger->log("dstBeing name:" + dstBeing->getName()); break; } } else if (msgType == 3) { msg.readInt8(); // unknown } const int level = msg.readInt8(); // Lv if (level) dstBeing->setLevel(level); msg.readInt8(); // unknown if (dstBeing->getType() != Being::PLAYER || msgType != 3) { dstBeing->setActionTime(tick_time); } dstBeing->setStunMode(stunMode); dstBeing->setStatusEffectBlock(0, static_cast( (statusEffects >> 16) & 0xffff)); dstBeing->setStatusEffectBlock(16, static_cast( statusEffects & 0xffff)); if (msgType == 3 && dstBeing->getType() == Being::PLAYER) dstBeing->setMoveTime(); } void BeingHandler::processBeingMove3(Net::MessageIn &msg) { if (serverVersion < 10) return; static const int16_t dirx[8] = {0, -1, -1, -1, 0, 1, 1, 1}; static const int16_t diry[8] = {1, 1, 0, -1, -1, -1, 0, 1}; const int len = msg.readInt16() - 14; Being *const dstBeing = actorManager->findBeing(msg.readInt32()); if (!dstBeing) return; const int16_t speed = msg.readInt16(); dstBeing->setWalkSpeed(Vector(speed, speed, 0)); int16_t x = msg.readInt16(); int16_t y = msg.readInt16(); const unsigned char *moves = msg.readBytes(len); Path path; if (moves) { for (int f = 0; f < len; f ++) { const unsigned char dir = moves[f]; if (dir <= 7) { x += dirx[dir]; y += diry[dir]; path.push_back(Position(x, y)); } else { logger->log("bad move packet: %d", dir); } } delete [] moves; } dstBeing->setPath(path); } } // namespace TmwAthena