LeaveChannelMessage.cpp

Go to the documentation of this file.

#include "LeaveChannelMessage.h"
#include "LeaveChannelPacket.h"
#include "ClientRegister.h"
#include "WorldServer.h"
#include "ReplyPacket.h"

namespace SraNetwork
{
    LeaveChannelMessage::LeaveChannelMessage(void)
    {
    }


    LeaveChannelMessage::~LeaveChannelMessage(void)
    {
    }


    SraPacket* LeaveChannelMessage::createPacketFromData(const unsigned char* data)
    {
        return (LeaveChannelPacket*)data;
    }

    void LeaveChannelMessage::process(MessageData* message)
    {
        //Client has sent login data
        std::cout << "Processing leave channel message" << std::endl;
        
        ClientRegister* reg = ClientRegister::getInstance();
        const SraClientData* client = reg->getClientFromAddress( message->address );
        if (client == NULL)
        {
            printf("Error: A non existing client is used in LeaveChannelMeesage::process\n");
            return;
        }

        LeaveChannelPacket packet;
        packet.Deserialize( &message->stream );
        
        // Send a join message to the chat server
        RakPeerInterface* chatInterface = WorldServer::getChatinterface(packet.channelId);
        if (chatInterface == NULL)
        {
            //If the channel join failed, send a reply to the client
            RakNet::RakPeerInterface *clientI = SraNetwork::WorldServer::getClientInterface();

            BitStream stream;

            ReplyPacket rp;
            rp.replyCode = ReplyPacket::FAIL;
            rp.messageOpCode = ID_CHAT_CHANNEL_REGISTER;
            rp.replyMessage = "LeaveChannel failed, please check the channel name.";
            rp.Serialize(&stream);
            clientI->Send( &stream, 
                MEDIUM_PRIORITY, RELIABLE_ORDERED, 0, message->address, false);
        }
        else
        {
            printf("Forwarding request to the chat server\n");
            // We will simply forward the request to the chat server now.
            // The chat server will check if the requested channel exists and
            // if the player is allowed to join it.
            // We don't need to send a client answer either, because the chat
            // server will send it's own IP
            chatInterface->Send(&message->stream, MEDIUM_PRIORITY, RELIABLE_ORDERED, 0, message->address, false);
        }
    }
}