#include "Server.h"
#include <iostream>
#include <Klient.h>
#include <Globals.h>
#include <HttpRequest.h>
#include <JSON.h>
#include <AsynchronCall.h>

// Inhalt der LoginServer Klasse aus LoginServer.h
// Konstruktor 
FactoryCraftServer::FactoryCraftServer( InitDatei* zIni )
    : ReferenceCounter()
{
    Network::Start( 100 );
    runningThreads = 0;
    klients = new RCArray< FCKlient >();
    ini = dynamic_cast<InitDatei*>(zIni->getThis());
    id = *zIni->zWert( "ServerId" );
    sslServer = new SSLServer();
    sslServer->setPrivateKeyPassword( zIni->zWert( "SSLPasswort" )->getText() );
    sslServer->setCertificateFile( zIni->zWert( "SSLCert" )->getText() );
    std::cout << "using cert file " << zIni->zWert( "SSLCert" )->getText() << "\n";
    sslServer->setPrivateKeyFile( zIni->zWert( "SSLKey" )->getText() );
    std::cout << "using private key " << zIni->zWert( "SSLKey" )->getText() << "\n";
    server = new Server();
    std::cout << "Server Port: " << ini->zWert( "Port" )->getText() << "\n";
    if( !server->verbinde( (unsigned short)TextZuInt( ini->zWert( "Port" )->getText(), 10 ), 10 ) )
    {
        std::cout << "Der Server konnte nicht gestartet werden.\n";
        exit( 1 );
    }
    std::cout << "SSL Server Port: " << ini->zWert( "SSLPort" )->getText() << "\n";
    if( !sslServer->verbinde( (unsigned short)TextZuInt( ini->zWert( "SSLPort" )->getText(), 10 ), 10 ) )
    {
        std::cout << "Der SSL Server konnte nicht gestartet werden.\n";
        exit( 2 );
    }
    Game::initialize( zIni->zWert( "World" )->getText(), zIni->zWert( "SaveDir" )->getText() );
    new Framework::AsynchronCall( "Server", [this]() {
        runningThreads++;
        while( server->isConnected() )
        {
            SKlient* klient = server->getKlient();
            if( !klient )
                continue;
            unsigned short len;
            klient->setEmpfangTimeout( 5000 );
            klient->getNachricht( (char*)&len, 2 );
            char* key = new char[ len ];
            klient->getNachricht( (char*)key, len );
            bool bg;
            klient->getNachricht( (char*)&bg, 1 );
            klient->setEmpfangTimeout( 0 );
            bool found = 0;
            EnterCriticalSection( &cs );
            for( FCKlient* client : *klients )
            {
                if( client->matchAuthKey( key, len ) )
                {
                    if( bg )
                        client->setBackgroundClient( klient );
                    else
                        client->setForegroundClient( klient );
                    found = 1;
                    break;
                }
            }
            LeaveCriticalSection( &cs );
            if( !found )
                klient->release();
        }
        runningThreads--;
    } );
    InitializeCriticalSection( &cs );
}

// Destruktor 
FactoryCraftServer::~FactoryCraftServer()
{
    sslServer->trenne();
    server->trenne();
    while( runningThreads > 0 )
        Sleep( 100 );
    sslServer->release();
    server->release();
    if( klients )
        klients->release();
    ini->release();
    Game::INSTANCE->requestStop();
    Game::INSTANCE->release();
    DeleteCriticalSection( &cs );
}

// nicht constant 
void FactoryCraftServer::run()
{
    runningThreads++;
    while( sslServer->isConnected() )
    {
        SSLSKlient* klient = sslServer->getKlient();
        if( !klient )
            continue;
        Framework::getThreadRegister()->cleanUpClosedThreads();
        FCKlient* clHandle = new FCKlient( klient, dynamic_cast<FactoryCraftServer*>(getThis()) );
        EnterCriticalSection( &cs );
        klients->add( clHandle );
        LeaveCriticalSection( &cs );
        clHandle->start();
    }
    runningThreads--;
}

void FactoryCraftServer::close()
{
    sslServer->trenne();
    EnterCriticalSection( &cs );
    for( int i = 0; i < klients->getEintragAnzahl(); i++ )
        klients->z( i )->absturz();
    klients = (RCArray< FCKlient > *)klients->release();
    Game::INSTANCE->save();
    LeaveCriticalSection( &cs );
}

bool FactoryCraftServer::absturzKlient( int accountId )
{
    bool gefunden = 0;
    EnterCriticalSection( &cs );
    for( int i = 0; i < klients->getEintragAnzahl(); i++ )
    {
        if( klients->z( i ) && klients->z( i )->getAccountId() == accountId )
        {
            klients->z( i )->absturz();
            klients->remove( i );
            gefunden = 1;
            break;
        }
    }
    LeaveCriticalSection( &cs );
    return gefunden;
}

bool FactoryCraftServer::removeKlient( FCKlient* zKlient )
{
    bool gefunden = 0;
    EnterCriticalSection( &cs );
    for( int i = 0; i < klients->getEintragAnzahl(); i++ )
    {
        if( klients->z( i ) == zKlient )
        {
            klients->remove( i );
            gefunden = 1;
            break;
        }
    }
    LeaveCriticalSection( &cs );
    return gefunden;
}

bool FactoryCraftServer::hatClients() const
{
    return klients->hat( 0 );
}

int FactoryCraftServer::getUnencryptedPort() const
{
    return server->getPort();
}

char* randomKey( int& len )
{
    len = 1024 + (int)(((double)rand() / RAND_MAX - 0.5) * 512);
    char* key = new char[ len ];
    for( int i = 0; i < len; i++ )
        key[ i ] = (char)(((double)rand() / RAND_MAX) * 256);
    return key;
}

// Inhalt der LSKlient aus LoginServer.h
// Konstruktor
FCKlient::FCKlient( SSLSKlient* klient, FactoryCraftServer* ls )
    : Thread()
{
    this->klient = klient;
    background = 0;
    foreground = 0;
    accountId = 0;
    this->ls = ls;
    zGameClient = 0;
    backgroundReader = 0;
    foregroundReader = 0;
    backgroundWriter = 0;
    foregroundWriter = 0;
    authKey = randomKey( authKeyLen );
}

// Destruktor 
FCKlient::~FCKlient()
{
    if( zGameClient )
    {
        zGameClient->logout();
        zGameClient = (GameClient*)zGameClient->release();
    }
    if( background )
        background->release();
    if( foreground )
        foreground->release();
    delete backgroundReader;
    delete foregroundReader;
    delete backgroundWriter;
    delete foregroundWriter;
    klient->release();
    ls->release();
    delete[] authKey;
}

// nicht constant 
void FCKlient::setForegroundClient( SKlient* foreground )
{
    this->foreground = foreground;
    foregroundReader = new NetworkReader( foreground );
    foregroundWriter = new NetworkWriter( foreground );
    if( foreground && background )
        zGameClient = Game::INSTANCE->addPlayer( dynamic_cast<FCKlient*>(getThis()), Framework::Text( (int)accountId ) );
    new AsynchronCall( [this]() {
        while( this->foreground->waitForNextMessage() )
        {
            if( zGameClient )
                zGameClient->addMessage( foregroundReader );
            if( !zGameClient )
                Sleep( 100 );
        }
        zGameClient->logout();
        ls->removeKlient( this );
    } );
}

void FCKlient::setBackgroundClient( SKlient* background )
{
    this->background = background;
    backgroundReader = new NetworkReader( background );
    backgroundWriter = new NetworkWriter( background );
    if( foreground && background )
        zGameClient = Game::INSTANCE->addPlayer( dynamic_cast<FCKlient*>(getThis()), Framework::Text( (int)accountId ) );
    new AsynchronCall( [this]() {
        while( this->background->waitForNextMessage() )
        {
            if( zGameClient )
                zGameClient->addMessage( backgroundReader );
            if( !zGameClient )
                Sleep( 100 );
        }
        zGameClient->logout();
        ls->removeKlient( this );
    } );
}

void FCKlient::absturz()
{
    ende();
    klient->trenne();
}

void FCKlient::thread()
{
    while( 1 )
    {
        char c = 0;
        if( !klient->getNachricht( &c, 1 ) )
            break;
        else
        {
            bool br = 0;
            switch( c )
            {
            case 1: // Klient identifikation
            {
                int accountId = 0;
                klient->getNachricht( (char*)&accountId, 4 );
                unsigned char secretLength = 0;
                klient->getNachricht( (char*)&secretLength, 1 );
                char* secret = new char[ secretLength + 1 ];
                klient->getNachricht( secret, (int)secretLength );
                secret[ secretLength ] = 0;
                Text data = "{\"account_id\":";
                data += accountId;
                data += ", \"secret\": \"";
                data += secret;
                data += "\"}";
                bool ok = false;
                HTTP::Answer* answer = HTTP::PostRequest( "/game_client/api/verify_client.php", "koljastrohm-games.com", data, "application/json", 443, true ).execute();
                if( answer->getStatusCode() == 200 )
                {
                    JSON::JSONObject obj( answer->getData() );
                    if( obj.hasValue( "verified" ) )
                    {
                        JSON::JSONValue* value = obj.getValue( "verified" );
                        if( value->getType() == JSON::JSONType::BOOLEAN )
                        {
                            if( ((JSON::JSONBool*)value)->getBool() )
                            {
                                this->accountId = accountId;
                                if( zGameClient )
                                {
                                    zGameClient->logout();
                                    zGameClient = (GameClient*)zGameClient->release();
                                }
                                klient->sende( "\1", 1 );
                                klient->sende( (char*)&authKeyLen, 4 );
                                klient->sende( authKey, authKeyLen );
                                int port = ls->getUnencryptedPort();
                                klient->sende( (char*)&port, 4 );
                                ok = true;
                            }
                        }
                        value->release();
                    }
                }
                answer->release();
                delete[]secret;
                if( !ok )
                    klient->sende( "\0", 1 );
                break;
            }
            case 2: // Verbindungsende
                br = 1;
                if( zGameClient )
                {
                    zGameClient->logout();
                    zGameClient = (GameClient*)zGameClient->release();
                }
                klient->sende( "\1", 1 );
                break;
            default:
                br = 1;
                break;
            }
            if( br )
                break;
        }
    }
}

int FCKlient::getAccountId() const // gibt die KlientId zurück
{
    return accountId;
}

NetworkWriter* FCKlient::zBackgroundWriter() const
{
    return backgroundWriter;
}

NetworkWriter* FCKlient::zForegroundWriter() const
{
    return foregroundWriter;
}

bool FCKlient::matchAuthKey( char* key, int len ) const
{
    if( foreground && background )
        return 0;
    if( len != authKeyLen )
        return 0;
    for( int i = 0; i < len; i++ )
    {
        if( key[ i ] != authKey[ i ] )
            return 0;
    }
    return 1;
}