/*
* 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() != Being::STAND)
player_node->imitateAction(dstBeing, Being::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(Being::STAND, 0);
player_node->imitateAction(dstBeing, Being::STAND);
break;
case 1:
if (dstBeing->getCurrentAction() != Being::DEAD)
{
dstBeing->setAction(Being::DEAD, 0);
dstBeing->recalcSpritesOrder();
}
break;
case 2:
dstBeing->setAction(Being::SIT, 0);
player_node->imitateAction(dstBeing, Being::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