/*
* The ManaPlus Client
* Copyright (C) 2004-2009 The Mana World Development Team
* Copyright (C) 2009-2010 The Mana Developers
* Copyright (C) 2011-2012 The ManaPlus Developers
*
* This file is part of The ManaPlus Client.
*
* This program is free software; you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation; either version 2 of the License, or
* any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see .
*/
#include "net/eathena/chathandler.h"
#include "actorspritemanager.h"
#include "configuration.h"
#include "depricatedevent.h"
#include "game.h"
#include "localplayer.h"
#include "playerrelations.h"
#include "gui/chatwindow.h"
#include "gui/shopwindow.h"
#include "gui/widgets/chattab.h"
#include "net/eathena/protocol.h"
#include
#include "debug.h"
extern Net::ChatHandler *chatHandler;
namespace EAthena
{
ChatHandler::ChatHandler()
{
static const uint16_t _messages[] =
{
SMSG_BEING_CHAT,
SMSG_PLAYER_CHAT,
SMSG_WHISPER,
SMSG_WHISPER_RESPONSE,
SMSG_GM_CHAT,
SMSG_MVP, // MVP
SMSG_IGNORE_ALL_RESPONSE,
0
};
handledMessages = _messages;
chatHandler = this;
}
void ChatHandler::handleMessage(Net::MessageIn &msg)
{
if (!localChatTab)
return;
switch (msg.getId())
{
case SMSG_WHISPER_RESPONSE:
processWhisperResponse(msg);
break;
// Received whisper
case SMSG_WHISPER:
processWhisper(msg);
break;
// Received speech from being
case SMSG_BEING_CHAT:
processBeingChat(msg);
break;
case SMSG_PLAYER_CHAT:
case SMSG_GM_CHAT:
processChat(msg, msg.getId() == SMSG_PLAYER_CHAT);
break;
case SMSG_MVP:
processMVP(msg);
break;
case SMSG_IGNORE_ALL_RESPONSE:
processIgnoreAllResponse(msg);
default:
break;
}
}
void ChatHandler::talk(const std::string &text)
{
if (!player_node)
return;
std::string mes = player_node->getName() + " : " + text;
MessageOut outMsg(CMSG_CHAT_MESSAGE);
// Added + 1 in order to let eAthena parse admin commands correctly
outMsg.writeInt16(static_cast(mes.length() + 4 + 1));
outMsg.writeString(mes, static_cast(mes.length() + 1));
}
void ChatHandler::talkRaw(const std::string &mes)
{
MessageOut outMsg(CMSG_CHAT_MESSAGE);
// Added + 1 in order to let eAthena parse admin commands correctly
outMsg.writeInt16(static_cast(mes.length() + 4 + 1));
outMsg.writeString(mes, static_cast(mes.length() + 1));
}
void ChatHandler::privateMessage(const std::string &recipient,
const std::string &text)
{
MessageOut outMsg(CMSG_CHAT_WHISPER);
outMsg.writeInt16(static_cast(text.length() + 28));
outMsg.writeString(recipient, 24);
outMsg.writeString(text, static_cast(text.length()));
mSentWhispers.push(recipient);
}
void ChatHandler::who()
{
MessageOut outMsg(CMSG_WHO_REQUEST);
}
void ChatHandler::sendRaw(const std::string &args)
{
std::string line = args;
std::string str;
MessageOut *outMsg = nullptr;
if (line == "")
return;
size_t pos = line.find(" ");
if (pos != std::string::npos)
{
str = line.substr(0, pos);
outMsg = new MessageOut(static_cast(atoi(str.c_str())));
line = line.substr(pos + 1);
pos = line.find(" ");
}
else
{
outMsg = new MessageOut(static_cast(atoi(line.c_str())));
delete outMsg;
return;
}
while (pos != std::string::npos)
{
str = line.substr(0, pos);
processRaw(*outMsg, str);
line = line.substr(pos + 1);
pos = line.find(" ");
}
if (line != "")
processRaw(*outMsg, line);
delete outMsg;
}
void ChatHandler::processRaw(MessageOut &outMsg, std::string &line)
{
size_t pos = line.find(":");
if (pos == std::string::npos)
{
const int i = atoi(line.c_str());
if (line.length() <= 3)
outMsg.writeInt8(static_cast(i));
else if (line.length() <= 5)
outMsg.writeInt16(static_cast(i));
else
outMsg.writeInt32(i);
}
else
{
std::string header = line.substr(0, pos);
std::string data = line.substr(pos + 1);
if (header.length() != 1)
return;
int i = 0;
switch (header[0])
{
case '1':
case '2':
case '4':
i = atoi(data.c_str());
break;
default:
break;
}
switch (header[0])
{
case '1':
outMsg.writeInt8(static_cast(i));
break;
case '2':
outMsg.writeInt16(static_cast(i));
break;
case '4':
outMsg.writeInt32(i);
break;
case 'c':
{
pos = line.find(",");
if (pos != std::string::npos)
{
const unsigned short x = static_cast(
atoi(data.substr(0, pos).c_str()));
data = data.substr(pos + 1);
pos = line.find(",");
if (pos == std::string::npos)
break;
const unsigned short y = static_cast(
atoi(data.substr(0, pos).c_str()));
const int dir = atoi(data.substr(pos + 1).c_str());
outMsg.writeCoordinates(x, y,
static_cast(dir));
}
break;
}
case 't':
outMsg.writeString(data, static_cast(data.length()));
break;
default:
break;
}
}
}
void ChatHandler::ignoreAll()
{
MessageOut outMsg(CMSG_IGNORE_ALL);
outMsg.writeInt8(0);
}
void ChatHandler::unIgnoreAll()
{
MessageOut outMsg(CMSG_IGNORE_ALL);
outMsg.writeInt8(1);
}
} // namespace EAthena