ClientRegister.cpp

Go to the documentation of this file.

#include "ClientRegister.h"
namespace SraNetwork {

    ClientRegister* SraNetwork::ClientRegister::instance = new ClientRegister();

    ClientRegister::ClientRegister(void)
    {
        //Initalize db connection
        //SraData::DbConnectionFactory factory( "tcp://127.0.0.1:3306", "root", "SRA_Dev", "sra_dev");
        nextID = 42;
    }

    ClientRegister::~ClientRegister(void)
    {
    }

    ClientRegister* ClientRegister::getInstance()
    {
        return instance;
    }

    void ClientRegister::addClient( SystemAddress address, SraClientData client) 
    {
        printf("New client !\n");
        SystemAddress s = address;
        tbb::concurrent_hash_map<SystemAddress, SraClientData, SystemAddressCompare>::accessor acc;
        clientAddressRegister.insert(acc,s);
        acc->second = client;
    }

    const SystemAddress* ClientRegister::getAddressFromClientID( const int clientID)
    {
        tbb::concurrent_hash_map<SystemAddress, SraClientData, SystemAddressCompare>::const_iterator it;
        for (  it = clientAddressRegister.begin(); it != clientAddressRegister.end(); ++it)
        {
            if ( it->second.clientID == clientID ) 
            {
                return &it->first;
            }
        }
        return NULL;
    }
    const SraClientData* ClientRegister::getClientFromAddress( SystemAddress address)
    {
        tbb::concurrent_hash_map<SystemAddress, SraClientData, SystemAddressCompare>::const_accessor acc;
        clientAddressRegister.find(acc,address);
        return &(acc->second);
    }

    const SystemAddress*  ClientRegister::getAddressFromClient( const SraClientData* client)
    {
        tbb::concurrent_hash_map<SystemAddress, SraClientData, SystemAddressCompare>::const_iterator it;
        for (  it = clientAddressRegister.begin(); it != clientAddressRegister.end(); ++it)
        {
            if ( it->second == *client ) 
            {
                return &it->first;
            }
        }
        return NULL;
    }


    void  ClientRegister::removeClient(const SystemAddress address)
    {
        tbb::concurrent_hash_map<SystemAddress, SraClientData, SystemAddressCompare>::accessor acc;
        if (clientAddressRegister.find(acc, address) ) {
            clientAddressRegister.erase(acc);
        }
    }

    void  ClientRegister::removeClient( const SraClientData* data)
    {
        const SystemAddress* addr = getAddressFromClient(data);
        if (addr != NULL) 
        {
            removeClient(*addr);
        }
    }

    int ClientRegister::loginClient( wchar_t* data, SystemAddress address, int userLen)
    {
        if (userLen >= PACKAGE_DATA_SIZE) 
        {
            printf("Client login corrupted, length of user name >= PACKAGE_DATA_SIZE!\n");
            return -1;
        }
        //Split user & pw
        wchar_t *user = new wchar_t[userLen+1];
        //Since we have used a 
        wcsncpy_s(user, userLen+1, data, _TRUNCATE);
        int rLen = wcslen(data)-(userLen);
        wchar_t *pw = new wchar_t[rLen+1];
        wcsncpy_s(pw, rLen+1, data+userLen, _TRUNCATE);
        printf("Check login for u:%ls ; p:%ls",user, pw); 
        int pID;
        //Check login
        //There seems to be a bug here:
        //dbManager.loginPlayer(user, pw, &pID);
        pID = nextID++;
        if ( pID != -1 ) {
            //if it has been successfull, we will add the client now:
            SraClientData client = {0};
            client.clientID = pID;
            //client.lastKeepAlive = keepAlive.sec;
            //Read additional character data from DB, e.g. current zone etc.
            client.zoneID = 124;
            addClient( address, client);
        }
        return pID;

    }
}