/*
* The Mana Server
* Copyright (C) 2008 The Mana World Development Team
*
* This file is part of The Mana Server.
*
* The Mana Server 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.
*
* The Mana Server 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 The Mana Server. If not, see .
*/
#include "chathandler.hpp"
#include "chatclient.hpp"
#include "party.hpp"
#include "account-server/storage.hpp"
#include "account-server/serverhandler.hpp"
#include "net/messagein.hpp"
#include "net/messageout.hpp"
#include "protocol.h"
#include
void updateInfo(ChatClient *client, int partyId)
{
Character *character = storage->getCharacter(client->characterName);
GameServerHandler::sendPartyChange(character, partyId);
}
bool ChatHandler::handlePartyJoin(const std::string &invited, const std::string &inviter)
{
MessageOut out(CPMSG_PARTY_INVITE_RESPONSE);
// Get inviting client
ChatClient *c1 = getClient(inviter);
if (c1)
{
// if party doesnt exist, create it
if (!c1->party)
{
c1->party = new Party();
// tell game server to update info
updateInfo(c1, c1->party->getId());
}
// add inviter to the party
c1->party->addUser(inviter);
// Get invited client
ChatClient *c2 = getClient(invited);
if (c2)
{
// add invited to the party
c1->party->addUser(invited);
c2->party = c1->party;
// was successful so return success to inviter
out.writeString(invited);
out.writeByte(ERRMSG_OK);
c1->send(out);
// tell everyone a player joined
informPartyMemberJoined(*c2);
// tell game server to update info
updateInfo(c2, c2->party->getId());
return true;
}
}
// there was an error, return false
return false;
}
void ChatHandler::handlePartyInvite(ChatClient &client, MessageIn &msg)
{
//TODO: Handle errors
MessageOut out(CPMSG_PARTY_INVITED);
out.writeString(client.characterName);
std::string invited = msg.readString();
if (invited == client.characterName)
{
return;
}
if (invited != "")
{
// Get client and send it the invite
ChatClient *c = getClient(invited);
if (c)
{
++client.numInvites;
// TODO: Check number of invites
// and do something if too many in a short time
// store the invite
PartyInvite invite;
invite.mInvited = invited;
invite.mInviter = client.characterName;
if (client.party)
invite.mPartyId = client.party->getId();
else
invite.mPartyId = 0;
mPartyInvitedUsers.push_back(invite);
c->send(out);
}
}
}
void ChatHandler::handlePartyAcceptInvite(ChatClient &client, MessageIn &msg)
{
MessageOut out(CPMSG_PARTY_ACCEPT_INVITE_RESPONSE);
std::string inviter = msg.readString();
// Check that the player was invited
std::vector::iterator itr, itr_end;
itr = mPartyInvitedUsers.begin();
itr_end = mPartyInvitedUsers.end();
bool found = false;
while (itr != itr_end)
{
if ((*itr).mInvited == client.characterName &&
(*itr).mInviter == inviter)
{
// make them join the party
if (handlePartyJoin(client.characterName, inviter))
{
out.writeByte(ERRMSG_OK);
mPartyInvitedUsers.erase(itr);
found = true;
break;
}
}
++itr;
}
if (!found)
{
out.writeByte(ERRMSG_FAILURE);
}
client.send(out);
}
void ChatHandler::handlePartyQuit(ChatClient &client)
{
removeUserFromParty(client);
MessageOut out(CPMSG_PARTY_QUIT_RESPONSE);
out.writeByte(ERRMSG_OK);
client.send(out);
// tell game server to update info
updateInfo(&client, 0);
}
void ChatHandler::handlePartyRejection(ChatClient &client, MessageIn &msg)
{
MessageOut out(CPMSG_PARTY_REJECTED);
std::string inviter = msg.readString();
std::vector::iterator itr, itr_end;
itr = mPartyInvitedUsers.begin();
itr_end = mPartyInvitedUsers.end();
bool found = false;
while (itr != itr_end)
{
// Check that the player was invited
if ((*itr).mInvited == client.characterName &&
(*itr).mInviter == inviter)
{
// remove them from invited users list
mPartyInvitedUsers.erase(itr);
found = true;
break;
}
++itr;
}
if (!found)
{
out.writeByte(ERRMSG_FAILURE);
}
// send rejection to inviter
ChatClient *inviterClient = getClient(inviter);
inviterClient->send(out);
}
void ChatHandler::removeUserFromParty(ChatClient &client)
{
if (client.party)
{
client.party->removeUser(client.characterName);
informPartyMemberQuit(client);
// if theres less than 1 member left, remove the party
if (client.party->numUsers() < 1)
{
delete client.party;
client.party = 0;
}
}
}
void ChatHandler::informPartyMemberQuit(ChatClient &client)
{
std::map::iterator itr;
std::map::const_iterator itr_end = mPlayerMap.end();
for (itr = mPlayerMap.begin(); itr != itr_end; ++itr)
{
if (itr->second->party == client.party)
{
MessageOut out(CPMSG_PARTY_MEMBER_LEFT);
out.writeShort(client.characterId);
itr->second->send(out);
}
}
}
void ChatHandler::informPartyMemberJoined(ChatClient &client)
{
std::map::iterator itr;
std::map::const_iterator itr_end = mPlayerMap.end();
for (itr = mPlayerMap.begin(); itr != itr_end; ++itr)
{
if (itr->second->party == client.party)
{
MessageOut out(CPMSG_PARTY_NEW_MEMBER);
out.writeShort(client.characterId);
out.writeString(client.characterName);
itr->second->send(out);
}
}
}