ChatServer.h

Go to the documentation of this file.

/*
* Chat Server - This chat server will handle all chat related stuff, 
*               i.e. a mapping of playerIDs - chatGroups etc
*
* @Author Michael Matzen <mim@informatik.uni-kiel.de>
*
* 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 (at your option)
* 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, write to the Free Software Foundation, Inc., 51
* Franklin St, Fifth Floor, Boston, MA 02110, USA
* 
*/
#pragma once

#include <stdio.h>
#include <hash_map>
#include <vector>
#include <concurrent_hash_map.h>
#include "RakPeerInterface.h"

#include "SraNetworkShared.h"
#include "SraPacket.h"

using namespace RakNet;
namespace SraNetwork {
    
    //Hash-Map compare function for system addresses.
    struct SystemAddressCompare {
        //Simple 'hash', we're simply using the binaryaddress, maybe we need somthing better.
        static size_t hash( const SystemAddress& a)
        {
            return 1;
        }
        //Since the SystemAddress class has a compare function, use this to compare addresses
        static bool equal( const SystemAddress& a, const SystemAddress& b)
        {
            return a.EqualsExcludingPort(b);
        }
    };

    class ChatServer
    {

    public:
        ChatServer(void);
        ~ChatServer(void);

        static void ServerConnectionThread();
        static void ClientConnectionThread();

    private:
        // A mapping of client adresses to a unique int identifier
        static tbb::concurrent_hash_map<SystemAddress, unsigned int, SystemAddressCompare> m_vChatUserRegister;

        // Every client has a list of pending messages.
        // This is a map of [indexInUserRegister->listOfMessages]
        static tbb::concurrent_hash_map<unsigned int, std::vector<RakString>> m_mPendingUserMessages; //Buffered messages for a user

        // Every client has a list of chat groups that he is assigned to, basically
        // the sole use of this list is to keep track of the number of chatgroups
        // a user has joined.
        // This is a map of [indexInUserRegister->listOfChatGroups]
        static tbb::concurrent_hash_map<unsigned int, std::vector<int>> m_mUserChatGroupMap; 

        // A list of all the existing chat groups with all the user ids
        // This is a map of [chatGroupID->indexInUserRegister]
        static tbb::concurrent_hash_map<unsigned int, std::vector<int>> m_mChatGroupMap; 

        // The last client ID that has been used to assign a SystemAddress to a userListIndex
        static unsigned int lastUsedClientId;

        // The maximum number of chat groups, this is just for avoiding a group creation spam
        static const int MAX_NUMBER_OF_CHAT_GROUPS = 2048;

        // The maximum number of chats a single user is allowed to join.
        static const int MAX_NUMBER_OF_CHAT_GROUPS_PER_USER = 16;

        // The maximum number of users per chat group
        static const int MAX_NUMBER_OF_USERS_PER_GROUP = 2048;
    };
}