JoinChannelMessage.cpp

Go to the documentation of this file.

#include "JoinChannelMessage.h"
#include "ClientRegister.h"
#include "WorldServer.h"
#include "ReplyPacket.h"
#include "JoinChannelPacket.h"

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


    JoinChannelMessage::~JoinChannelMessage(void)
    {
    }

    SraPacket* JoinChannelMessage::createPacketFromData(const unsigned char* data)
    {
        return (JoinChannelPacket*)data;
    }

    void JoinChannelMessage::process(MessageData* message)
    {
        //Client has sent login data
        std::cout << "Processing join 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 JoinChannelMessage::process\n");
            return;
        }

        JoinChannelPacket 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 = "JoinChannel 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

            // Add the client address to the forwarded packet.
            packet.clientAddress =  message->address;
            BitStream fwdClientStream;
            packet.Serialize(&fwdClientStream);
            chatInterface->Send(&fwdClientStream, MEDIUM_PRIORITY, RELIABLE_ORDERED, 0, UNASSIGNED_SYSTEM_ADDRESS, true);           
        }
    }
}