|
@@ -0,0 +1,494 @@
|
|
|
+#include "MinigameClient.h"
|
|
|
+#include <Klient.h>
|
|
|
+#include "Keys.h"
|
|
|
+#include <Datei.h>
|
|
|
+
|
|
|
+using namespace KSGClient;
|
|
|
+
|
|
|
+// Inhalt der MinigameClient Klasse
|
|
|
+
|
|
|
+// Konstruktor
|
|
|
+MinigameClient::MinigameClient( int klientId, unsigned short port, char *ip, char *key, unsigned char keyLen )
|
|
|
+{
|
|
|
+ ref = 1;
|
|
|
+ this->ip = ip;
|
|
|
+ this->port = port;
|
|
|
+ cId = klientId;
|
|
|
+ k = 0;
|
|
|
+ this->key = new char[ keyLen ];
|
|
|
+ memcpy( this->key, key, keyLen );
|
|
|
+ this->keyLen = keyLen;
|
|
|
+}
|
|
|
+
|
|
|
+// Destruktor
|
|
|
+MinigameClient::~MinigameClient()
|
|
|
+{
|
|
|
+ trenne( 1 );
|
|
|
+ delete[] key;
|
|
|
+}
|
|
|
+
|
|
|
+// verbindet sich mit dem zugewiesenen Minigame Server
|
|
|
+// Gibt 1 zurück, falls der Vorgang erfolgreich ist, 0 sonnst
|
|
|
+bool MinigameClient::verbinde()
|
|
|
+{
|
|
|
+ cs.lock();
|
|
|
+ if( k )
|
|
|
+ {
|
|
|
+ cs.unlock();
|
|
|
+ return 1;
|
|
|
+ }
|
|
|
+ k = new Network::Klient();
|
|
|
+ int l = 0;
|
|
|
+ char *key;
|
|
|
+ Keys::getServerKey( &key, l, Keys::MINIGAME, Keys::SENDEN );
|
|
|
+ k->setSendeKey( key, l );
|
|
|
+ delete[] key;
|
|
|
+ Keys::getServerKey( &key, l, Keys::MINIGAME, Keys::EMPFANGEN );
|
|
|
+ k->setEmpfangKey( key, l );
|
|
|
+ delete[] key;
|
|
|
+ if( k->verbinde( port, ip ) )
|
|
|
+ {
|
|
|
+ if( k->sendeEncrypted( "\1", 1 ) )
|
|
|
+ {
|
|
|
+ k->sendeEncrypted( (char*)&cId, 4 );
|
|
|
+ char serverReturn = 0;
|
|
|
+ k->getNachrichtEncrypted( &serverReturn, 1 );
|
|
|
+ if( serverReturn == 3 )
|
|
|
+ {
|
|
|
+ char byte = 0;
|
|
|
+ k->getNachrichtEncrypted( &byte, 1 );
|
|
|
+ char *f = new char[ byte + 1 ];
|
|
|
+ f[ byte ] = 0;
|
|
|
+ k->getNachrichtEncrypted( f, byte );
|
|
|
+ err = "error while identifying client Minigame Server returned: ";
|
|
|
+ err += f;
|
|
|
+ delete[]f;
|
|
|
+ trenne( 0 );
|
|
|
+ cs.unlock();
|
|
|
+ return 0;
|
|
|
+ }
|
|
|
+ k->setSendeKey( this->key, this->keyLen );
|
|
|
+ k->setEmpfangKey( this->key, this->keyLen );
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ err = "network error while sending to Minigame Server";
|
|
|
+ k = k->release();
|
|
|
+ cs.unlock();
|
|
|
+ return 0;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ err = "network error while connecting to Minigame Server";
|
|
|
+ k = k->release();
|
|
|
+ cs.unlock();
|
|
|
+ return 0;
|
|
|
+ }
|
|
|
+ cs.unlock();
|
|
|
+ return 1;
|
|
|
+}
|
|
|
+
|
|
|
+// Ermittelt die liste mit allen Optionen zu einem Minigame zurück, zu denen es Welt beste Scores gibt
|
|
|
+// mName: Der Name des Minigames
|
|
|
+// zOptionList: Enthält nach erfolgreichem Aufruf eine Liste mit Optionen
|
|
|
+// Gibt die Anzahl der Optionen zurück
|
|
|
+int MinigameClient::getMinigameOptionList( char *mName, Framework::RCArray< Framework::Text > *zOptionList )
|
|
|
+{
|
|
|
+ cs.lock();
|
|
|
+ if( !k )
|
|
|
+ {
|
|
|
+ err = "Der Client ist nicht verbunden.";
|
|
|
+ cs.unlock();
|
|
|
+ return 0;
|
|
|
+ }
|
|
|
+ k->sendeEncrypted( "\x6", 1 );
|
|
|
+ char ret = 0;
|
|
|
+ k->getNachrichtEncrypted( &ret, 1 );
|
|
|
+ if( ret == 1 )
|
|
|
+ {
|
|
|
+ char l = (char)textLength( mName );
|
|
|
+ k->sendeEncrypted( &l, 1 );
|
|
|
+ k->sendeEncrypted( mName, l );
|
|
|
+ int anz = 0;
|
|
|
+ k->getNachrichtEncrypted( (char*)&anz, 4 );
|
|
|
+ for( int i = 0; i < anz; i++ )
|
|
|
+ {
|
|
|
+ k->getNachrichtEncrypted( &l, 1 );
|
|
|
+ char *option = new char[ l + 1 ];
|
|
|
+ option[ l ] = 0;
|
|
|
+ k->getNachrichtEncrypted( option, l );
|
|
|
+ zOptionList->add( new Text( option ) );
|
|
|
+ delete[] option;
|
|
|
+ }
|
|
|
+ cs.unlock();
|
|
|
+ return anz;
|
|
|
+ }
|
|
|
+ if( ret == 3 )
|
|
|
+ {
|
|
|
+ char l = 0;
|
|
|
+ k->getNachrichtEncrypted( &l, 1 );
|
|
|
+ char *fehler = new char[ l + 1 ];
|
|
|
+ fehler[ l ] = 0;
|
|
|
+ k->getNachrichtEncrypted( fehler, l );
|
|
|
+ err = fehler;
|
|
|
+ delete[] fehler;
|
|
|
+ cs.unlock();
|
|
|
+ return 0;
|
|
|
+ }
|
|
|
+ err = "Unbekannter Fehler";
|
|
|
+ cs.unlock();
|
|
|
+ return 0;
|
|
|
+}
|
|
|
+
|
|
|
+// Ermittelt eine Liste mit den Weltbesten Scores zurück
|
|
|
+// mName: Der Name des Minigames
|
|
|
+// zScore: Enthält nach erfolgreichem Aufruf eine Liste mit Scores
|
|
|
+// zPlayerList: Enthält nach erfolgreichem Aufruf eine Liste mit angezeigten Account Namen, die die Scores erreicht haben.
|
|
|
+// zOptionList: Enthält nach erfolgreichem Aufruf eine Liste mit Optionen, die beim erreichen der Scores aktiv waren.
|
|
|
+// Gibt die Anzahl der Bestscores zurück
|
|
|
+int MinigameClient::getMinigameBestscoreList( char *mName, Framework::Array< int > *zScore, Framework::RCArray< Framework::Text > *zPlayerList, Framework::RCArray< Framework::Text > *zOptionList )
|
|
|
+{
|
|
|
+ cs.lock();
|
|
|
+ if( !k )
|
|
|
+ {
|
|
|
+ err = "Der Client ist nicht verbunden.";
|
|
|
+ cs.unlock();
|
|
|
+ return 0;
|
|
|
+ }
|
|
|
+ k->sendeEncrypted( "\x7", 1 );
|
|
|
+ char ret = 0;
|
|
|
+ k->getNachrichtEncrypted( &ret, 1 );
|
|
|
+ if( ret == 1 )
|
|
|
+ {
|
|
|
+ char l = (char)textLength( mName );
|
|
|
+ k->sendeEncrypted( &l, 1 );
|
|
|
+ k->sendeEncrypted( mName, l );
|
|
|
+ int anz = 0;
|
|
|
+ k->getNachrichtEncrypted( (char*)&anz, 4 );
|
|
|
+ for( int i = 0; i < anz; i++ )
|
|
|
+ {
|
|
|
+ int score = 0;
|
|
|
+ k->getNachrichtEncrypted( (char*)&score, 4 );
|
|
|
+ zScore->add( score );
|
|
|
+ k->getNachrichtEncrypted( &l, 1 );
|
|
|
+ char *player = new char[ l + 1 ];
|
|
|
+ player[ l ] = 0;
|
|
|
+ k->getNachrichtEncrypted( player, l );
|
|
|
+ zPlayerList->add( new Text( player ) );
|
|
|
+ delete[] player;
|
|
|
+ k->getNachrichtEncrypted( &l, 1 );
|
|
|
+ char *option = new char[ l + 1 ];
|
|
|
+ option[ l ] = 0;
|
|
|
+ k->getNachrichtEncrypted( option, l );
|
|
|
+ zOptionList->add( new Text( option ) );
|
|
|
+ delete[] option;
|
|
|
+ }
|
|
|
+ cs.unlock();
|
|
|
+ return anz;
|
|
|
+ }
|
|
|
+ if( ret == 3 )
|
|
|
+ {
|
|
|
+ char l = 0;
|
|
|
+ k->getNachrichtEncrypted( &l, 1 );
|
|
|
+ char *fehler = new char[ l + 1 ];
|
|
|
+ fehler[ l ] = 0;
|
|
|
+ k->getNachrichtEncrypted( fehler, l );
|
|
|
+ err = fehler;
|
|
|
+ delete[] fehler;
|
|
|
+ cs.unlock();
|
|
|
+ return 0;
|
|
|
+ }
|
|
|
+ err = "Unbekannter Fehler";
|
|
|
+ cs.unlock();
|
|
|
+ return 0;
|
|
|
+}
|
|
|
+
|
|
|
+// Gibt den Welt bestscore zu einem Bestimmten Minigame mit bestimmten Optionen zurück.
|
|
|
+// mName: Der Name des Minigames
|
|
|
+// oName: Die Optionen
|
|
|
+// zPlayer: Enthält nach erfolgreichem Aufruf den Angezeigten Namen des Accounts, der den Score erreicht hat
|
|
|
+int MinigameClient::getMinigameOptionBestscore( char *mName, char *oName, Framework::Text *zPlayer )
|
|
|
+{
|
|
|
+ cs.lock();
|
|
|
+ if( !k )
|
|
|
+ {
|
|
|
+ err = "Der Client ist nicht verbunden.";
|
|
|
+ cs.unlock();
|
|
|
+ return 0;
|
|
|
+ }
|
|
|
+ k->sendeEncrypted( "\x8", 1 );
|
|
|
+ char ret = 0;
|
|
|
+ k->getNachrichtEncrypted( &ret, 1 );
|
|
|
+ if( ret == 1 )
|
|
|
+ {
|
|
|
+ char l = (char)textLength( mName );
|
|
|
+ k->sendeEncrypted( &l, 1 );
|
|
|
+ k->sendeEncrypted( mName, l );
|
|
|
+ l = (char)textLength( oName );
|
|
|
+ k->sendeEncrypted( &l, 1 );
|
|
|
+ k->sendeEncrypted( oName, l );
|
|
|
+ int score = 0;
|
|
|
+ k->getNachrichtEncrypted( (char*)&score, 4 );
|
|
|
+ k->getNachrichtEncrypted( &l, 1 );
|
|
|
+ char *player = new char[ l + 1 ];
|
|
|
+ player[ l ] = 0;
|
|
|
+ k->getNachrichtEncrypted( player, l );
|
|
|
+ zPlayer->setText( player );
|
|
|
+ delete[] player;
|
|
|
+ cs.unlock();
|
|
|
+ return score;
|
|
|
+ }
|
|
|
+ if( ret == 3 )
|
|
|
+ {
|
|
|
+ char l = 0;
|
|
|
+ k->getNachrichtEncrypted( &l, 1 );
|
|
|
+ char *fehler = new char[ l + 1 ];
|
|
|
+ fehler[ l ] = 0;
|
|
|
+ k->getNachrichtEncrypted( fehler, l );
|
|
|
+ err = fehler;
|
|
|
+ delete[] fehler;
|
|
|
+ cs.unlock();
|
|
|
+ return 0;
|
|
|
+ }
|
|
|
+ err = "Unbekannter Fehler";
|
|
|
+ cs.unlock();
|
|
|
+ return 0;
|
|
|
+}
|
|
|
+
|
|
|
+// Meldet die Beendigung eines Minigames
|
|
|
+// mName: Der Name des Minigames
|
|
|
+// oName: Die Optionen mit denen gespielt wurde
|
|
|
+// score: Der Erreichte Score
|
|
|
+// zCapture: Ein Zeiger auf eine Datei mit der Spielaufzeichnung
|
|
|
+// Gibt 0 zurück wenn eines Fehler aufgetreten ist, 1 wenn der Forgang erfolgreich war
|
|
|
+bool MinigameClient::reportEndOfGame( char *mName, char *oName, int score, Framework::Datei *zCapture )
|
|
|
+{
|
|
|
+ cs.lock();
|
|
|
+ if( !k )
|
|
|
+ {
|
|
|
+ err = "Der Client ist nicht verbunden.";
|
|
|
+ cs.unlock();
|
|
|
+ return 0;
|
|
|
+ }
|
|
|
+ k->sendeEncrypted( "\x9", 1 );
|
|
|
+ char ret = 0;
|
|
|
+ k->getNachrichtEncrypted( &ret, 1 );
|
|
|
+ if( ret == 1 )
|
|
|
+ {
|
|
|
+ char l = (char)textLength( mName );
|
|
|
+ k->sendeEncrypted( &l, 1 );
|
|
|
+ k->sendeEncrypted( mName, l );
|
|
|
+ l = (char)textLength( oName );
|
|
|
+ k->sendeEncrypted( &l, 1 );
|
|
|
+ k->sendeEncrypted( oName, l );
|
|
|
+ k->sendeEncrypted( (char*)&score, 4 );
|
|
|
+ k->getNachrichtEncrypted( &ret, 1 );
|
|
|
+ if( ret == 1 )
|
|
|
+ {
|
|
|
+ int size = (int)zCapture->getSize();
|
|
|
+ if( !zCapture->istOffen() )
|
|
|
+ zCapture->open( Datei::Style::lesen );
|
|
|
+ k->sendeEncrypted( (char*)&size, 4 );
|
|
|
+ char *buffer = new char[ 2048 ];
|
|
|
+ while( size > 0 )
|
|
|
+ {
|
|
|
+ int l = size > 2048 ? 2048 : size;
|
|
|
+ zCapture->lese( buffer, l );
|
|
|
+ k->sendeEncrypted( buffer, l );
|
|
|
+ size -= l;
|
|
|
+ }
|
|
|
+ delete[] buffer;
|
|
|
+ zCapture->close();
|
|
|
+ cs.unlock();
|
|
|
+ return 1;
|
|
|
+ }
|
|
|
+ else if( ret == 0 )
|
|
|
+ {
|
|
|
+ cs.unlock();
|
|
|
+ return 1;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if( ret == 3 )
|
|
|
+ {
|
|
|
+ char l = 0;
|
|
|
+ k->getNachrichtEncrypted( &l, 1 );
|
|
|
+ char *fehler = new char[ l + 1 ];
|
|
|
+ fehler[ l ] = 0;
|
|
|
+ k->getNachrichtEncrypted( fehler, l );
|
|
|
+ err = fehler;
|
|
|
+ delete[] fehler;
|
|
|
+ cs.unlock();
|
|
|
+ return 0;
|
|
|
+ }
|
|
|
+ err = "Unbekannter Fehler";
|
|
|
+ cs.unlock();
|
|
|
+ return 0;
|
|
|
+}
|
|
|
+
|
|
|
+// Lädt ein Game Capture herunter und speichert sie unter data/tmp/minigames/wb.mgc
|
|
|
+// mName: Der Name des Minigames
|
|
|
+// oName: Die Optionen
|
|
|
+// Gibt die Datei mit dem Capture zurück
|
|
|
+Framework::Datei *MinigameClient::downloadGameCapture( char *mName, char *oName )
|
|
|
+{
|
|
|
+ cs.lock();
|
|
|
+ if( !k )
|
|
|
+ {
|
|
|
+ err = "Der Client ist nicht verbunden.";
|
|
|
+ cs.unlock();
|
|
|
+ return 0;
|
|
|
+ }
|
|
|
+ k->sendeEncrypted( "\xA", 1 );
|
|
|
+ char ret = 0;
|
|
|
+ k->getNachrichtEncrypted( &ret, 1 );
|
|
|
+ if( ret == 1 )
|
|
|
+ {
|
|
|
+ char l = (char)textLength( mName );
|
|
|
+ k->sendeEncrypted( &l, 1 );
|
|
|
+ k->sendeEncrypted( mName, l );
|
|
|
+ l = (char)textLength( oName );
|
|
|
+ k->sendeEncrypted( &l, 1 );
|
|
|
+ k->sendeEncrypted( oName, l );
|
|
|
+ k->getNachrichtEncrypted( &ret, 1 );
|
|
|
+ if( ret == 1 )
|
|
|
+ {
|
|
|
+ Datei *capture = new Datei();
|
|
|
+ capture->setDatei( "data/tmp/minigames/wb.mgc" );
|
|
|
+ capture->erstellen();
|
|
|
+ capture->open( Datei::Style::schreiben );
|
|
|
+ int size = 0;
|
|
|
+ k->getNachrichtEncrypted( (char*)&size, 4 );
|
|
|
+ char *buffer = new char[ 2048 ];
|
|
|
+ while( size > 0 )
|
|
|
+ {
|
|
|
+ int l = size > 2048 ? 2048 : size;
|
|
|
+ k->getNachrichtEncrypted( buffer, l );
|
|
|
+ capture->schreibe( buffer, l );
|
|
|
+ size -= l;
|
|
|
+ }
|
|
|
+ delete[] buffer;
|
|
|
+ capture->close();
|
|
|
+ cs.unlock();
|
|
|
+ return capture;
|
|
|
+ }
|
|
|
+ err = "Unbekannter Fehler";
|
|
|
+ cs.unlock();
|
|
|
+ return 0;
|
|
|
+ }
|
|
|
+ if( ret == 3 )
|
|
|
+ {
|
|
|
+ char l = 0;
|
|
|
+ k->getNachrichtEncrypted( &l, 1 );
|
|
|
+ char *fehler = new char[ l + 1 ];
|
|
|
+ fehler[ l ] = 0;
|
|
|
+ k->getNachrichtEncrypted( fehler, l );
|
|
|
+ err = fehler;
|
|
|
+ delete[] fehler;
|
|
|
+ cs.unlock();
|
|
|
+ return 0;
|
|
|
+ }
|
|
|
+ err = "Unbekannter Fehler";
|
|
|
+ cs.unlock();
|
|
|
+ return 0;
|
|
|
+}
|
|
|
+
|
|
|
+// Erhält die Verbindung aufrecht
|
|
|
+// Gibt 1 zurück, falls der Vorgang erfolgreich ist, 0 sonnst
|
|
|
+// Sollte während einer bestehenden Verbindung etwa einmal alle 60 Sekunden aufgerufen werden, da sonst der Router die Verbindung automatisch trennt
|
|
|
+bool MinigameClient::keepAlive()
|
|
|
+{
|
|
|
+ char res = 0;
|
|
|
+ if( !cs.tryLock() )
|
|
|
+ return 1;
|
|
|
+ if( !k )
|
|
|
+ {
|
|
|
+ err = "Der Client ist nicht verbunden.";
|
|
|
+ cs.unlock();
|
|
|
+ return 0;
|
|
|
+ }
|
|
|
+ bool ok = k->sendeEncrypted( "\x5", 1 );
|
|
|
+ ok &= k->getNachrichtEncrypted( &res, 1 );
|
|
|
+ cs.unlock();
|
|
|
+ if( res != 1 || !ok )
|
|
|
+ trenne( 0 );
|
|
|
+ return res == 1;
|
|
|
+}
|
|
|
+
|
|
|
+// Trennt die Verbindung zum Server
|
|
|
+// Gibt 1 zurück, falls der Vorgang erfolgreich ist, 0 sonnst
|
|
|
+// Sollte erst nach einem erfolgreichen Aufruf von verbinde aufgerufen werden
|
|
|
+bool MinigameClient::trenne( bool abmelden )
|
|
|
+{
|
|
|
+ cs.lock();
|
|
|
+ verbinde();
|
|
|
+ if( !k )
|
|
|
+ {
|
|
|
+ cs.unlock();
|
|
|
+ return 1;
|
|
|
+ }
|
|
|
+ if( abmelden )
|
|
|
+ {
|
|
|
+ k->sendeEncrypted( "\4", 1 );
|
|
|
+ char ret = 0;
|
|
|
+ k->getNachrichtEncrypted( &ret, 1 );
|
|
|
+ if( ret == 3 )
|
|
|
+ { // error
|
|
|
+ k->getNachrichtEncrypted( &ret, 1 );
|
|
|
+ char *msg = new char[ ret + 1 ];
|
|
|
+ msg[ ret ] = 0;
|
|
|
+ if( ret )
|
|
|
+ k->getNachrichtEncrypted( msg, ret );
|
|
|
+ err = "error while unregister Client Minigame Server returned: ";
|
|
|
+ err += msg;
|
|
|
+ delete[] msg;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ k->sendeEncrypted( "\3", 1 );
|
|
|
+ char ret = 0;
|
|
|
+ k->getNachrichtEncrypted( &ret, 1 );
|
|
|
+ if( ret == 3 )
|
|
|
+ { // error
|
|
|
+ k->getNachrichtEncrypted( &ret, 1 );
|
|
|
+ char *msg = new char[ ret + 1 ];
|
|
|
+ msg[ ret ] = 0;
|
|
|
+ if( ret )
|
|
|
+ k->getNachrichtEncrypted( msg, ret );
|
|
|
+ err = "error while trenne Minigame Server returned: ";
|
|
|
+ err += msg;
|
|
|
+ delete[] msg;
|
|
|
+ }
|
|
|
+ k->trenne();
|
|
|
+ k = k->release();
|
|
|
+ cs.unlock();
|
|
|
+ return 1;
|
|
|
+}
|
|
|
+
|
|
|
+// Gibt 1 zurück, falls der Client verbunden ist, 0 sonst
|
|
|
+bool MinigameClient::istVerbunden() const
|
|
|
+{
|
|
|
+ return k != 0;
|
|
|
+}
|
|
|
+
|
|
|
+// gibt den Letzten Fehlertext zuück
|
|
|
+// sollte erst aufgerufen werden, nachdem eine andere aufgerufene Methode fehlgeschlagen ist
|
|
|
+char *MinigameClient::getLetzterFehler() const
|
|
|
+{
|
|
|
+ return err;
|
|
|
+}
|
|
|
+
|
|
|
+// Erhöht den Reference Counter um 1 un gibt this zurück
|
|
|
+MinigameServerClient *MinigameClient::getThis()
|
|
|
+{
|
|
|
+ ref++;
|
|
|
+ return this;
|
|
|
+}
|
|
|
+
|
|
|
+// Verringert den Reference Counter um 1 und gibt 0 zurück.
|
|
|
+// Falls der Reference Counter nach dem Aufruf auf 0 ist löscht sich das Objekt selbst
|
|
|
+MinigameServerClient *MinigameClient::release()
|
|
|
+{
|
|
|
+ if( !--ref )
|
|
|
+ delete this;
|
|
|
+ return 0;
|
|
|
+}
|