MinigameServer.cpp 33 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988
  1. #include "MinigameServer.h"
  2. #include <iostream>
  3. #include <Klient.h>
  4. #include <Globals.h>
  5. // Inhalt der LoginServer Klasse aus LoginServer.h
  6. // Konstruktor
  7. MinigameServer::MinigameServer( InitDatei *zIni )
  8. : Thread()
  9. {
  10. Network::Start( 100 );
  11. std::cout << "MS: Verbindung mit Datenbank wird hergestellt...\n";
  12. db = new MSDatenbank( zIni );
  13. klientAnzahl = 0;
  14. klients = new RCArray< MSKlient >();
  15. empfangen = 0;
  16. gesendet = 0;
  17. fehler = new Text();
  18. ini = zIni->getThis();
  19. id = *zIni->zWert( "ServerId" );
  20. server = new Server();
  21. aServer = new Server();
  22. std::cout << "MS: Starten des Admin Servers...\n";
  23. if( !aServer->verbinde( (unsigned short)TextZuInt( ini->zWert( "AdminServerPort" )->getText(), 10 ), 10 ) )
  24. {
  25. std::cout << "MS: Der Admin Server konnte nicht gestartet werden. Das Programm wird beendet.\n";
  26. exit( 1 );
  27. }
  28. db->setServerStatus( id, 2 );
  29. end = 0;
  30. nichtPausiert = 0;
  31. InitializeCriticalSection( &cs );
  32. ref = 1;
  33. if( zIni->zWert( "Aktiv" )->istGleich( "TRUE" ) )
  34. {
  35. serverStarten();
  36. serverFortsetzen();
  37. }
  38. }
  39. // Destruktor
  40. MinigameServer::~MinigameServer()
  41. {
  42. fehler->release();
  43. server->trenne();
  44. server->release();
  45. aServer->trenne();
  46. aServer->release();
  47. if( klients )
  48. klients->release();
  49. ini->release();
  50. db->release();
  51. DeleteCriticalSection( &cs );
  52. }
  53. // nicht constant
  54. void MinigameServer::runn()
  55. {
  56. while( !end )
  57. {
  58. SKlient *klient;
  59. klient = aServer->getKlient();
  60. if( end && klient )
  61. {
  62. klient->trenne();
  63. klient = klient->release();
  64. Sleep( 1000 );
  65. return;
  66. }
  67. if( !klient )
  68. return;
  69. MSAKlient *clHandle = new MSAKlient( klient, getThis() );
  70. clHandle->start();
  71. }
  72. }
  73. void MinigameServer::thread()
  74. {
  75. while( 1 )
  76. {
  77. SKlient *klient;
  78. klient = server->getKlient();
  79. if( !klient )
  80. break;
  81. Framework::getThreadRegister()->cleanUpClosedThreads();
  82. MSKlient *clHandle = new MSKlient( klient, getThis() );
  83. EnterCriticalSection( &cs );
  84. klients->set( clHandle, klientAnzahl );
  85. klientAnzahl++;
  86. LeaveCriticalSection( &cs );
  87. clHandle->start();
  88. }
  89. }
  90. void MinigameServer::close()
  91. {
  92. db->setServerStatus( id, 1 );
  93. server->trenne();
  94. #ifdef WIN32
  95. warteAufThread( 1000 );
  96. #endif
  97. EnterCriticalSection( &cs );
  98. for( int i = 0; i < klientAnzahl; i++ )
  99. klients->z( i )->absturz();
  100. klients = klients->release();
  101. klientAnzahl = 0;
  102. LeaveCriticalSection( &cs );
  103. ende();
  104. run = 0;
  105. end = 1;
  106. Klient *klient = new Klient();
  107. klient->verbinde( aServer->getPort(), "127.0.0.1" );
  108. Sleep( 500 );
  109. aServer->trenne();
  110. klient->release();
  111. }
  112. bool MinigameServer::serverStarten()
  113. {
  114. if( nichtPausiert )
  115. {
  116. fehler->setText( "Der Server konnte nicht gestartet werden: Der Server läuft bereits." );
  117. return 0;
  118. }
  119. if( server )
  120. server->release();
  121. server = new Server();
  122. if( server->verbinde( (unsigned short)TextZuInt( ini->zWert( "ServerPort" )->getText(), 10 ), 10 ) )
  123. {
  124. nichtPausiert = 1;
  125. start();
  126. return 1;
  127. }
  128. else
  129. {
  130. serverBeenden();
  131. fehler->setText( "Der Server konnte nicht gestartet werden: Eventuell ist der Port in benutzung." );
  132. return 0;
  133. }
  134. }
  135. bool MinigameServer::serverPause()
  136. {
  137. if( !nichtPausiert )
  138. {
  139. fehler->setText( "Der Server konnte nicht pausiert werden: Der Server läuft nicht." );
  140. return 0;
  141. }
  142. if( !db->setServerStatus( id, 2 ) )
  143. {
  144. fehler->setText( "Der Server konnte nicht pausiert werden: " );
  145. fehler->append( db->getLetzterFehler() );
  146. return 0;
  147. }
  148. return 1;
  149. }
  150. bool MinigameServer::serverFortsetzen()
  151. {
  152. if( !nichtPausiert )
  153. {
  154. fehler->setText( "Der Server konnte nicht fortgesetzt werden: Der Server läuft nicht." );
  155. return 0;
  156. }
  157. if( !db->setServerStatus( id, 3 ) )
  158. {
  159. fehler->setText( "Der Server konnte nicht fortgesetzt werden: " );
  160. fehler->append( db->getLetzterFehler() );
  161. return 0;
  162. }
  163. return 1;
  164. }
  165. bool MinigameServer::serverBeenden()
  166. {
  167. if( !nichtPausiert )
  168. {
  169. fehler->setText( "Der Server konnte nicht beendet werden: Der Server läuft nicht." );
  170. return 0;
  171. }
  172. if( db->serverIstNichtPausiert( id ) )
  173. {
  174. fehler->setText( "Der Server konnte nicht beendet werden: Der Server muss erst pausiert werden." );
  175. return 0;
  176. }
  177. nichtPausiert = 0;
  178. ende();
  179. if( server )
  180. server->trenne();
  181. return 1;
  182. }
  183. bool MinigameServer::setMaxKlients( int mc )
  184. {
  185. if( !db->setMaxClients( id, mc ) )
  186. {
  187. fehler->setText( "Die maximale Anzahl der Clients konnte nicht gesetzt werden:\n" );
  188. fehler->append( db->getLetzterFehler() );
  189. return 0;
  190. }
  191. ini->setWert( "MaxClients", Text() += mc );
  192. return 1;
  193. }
  194. bool MinigameServer::absturzKlient( int klientId )
  195. {
  196. bool gefunden = 0;
  197. EnterCriticalSection( &cs );
  198. for( int i = 0; i < klientAnzahl; i++ )
  199. {
  200. if( klients->z( i ) && klients->z( i )->getKlientNummer() == klientId )
  201. {
  202. klients->z( i )->absturz();
  203. klients->remove( i );
  204. klientAnzahl--;
  205. gefunden = 1;
  206. break;
  207. }
  208. }
  209. LeaveCriticalSection( &cs );
  210. return gefunden;
  211. }
  212. bool MinigameServer::removeKlient( MSKlient *zKlient )
  213. {
  214. bool gefunden = 0;
  215. EnterCriticalSection( &cs );
  216. for( int i = 0; i < klientAnzahl; i++ )
  217. {
  218. if( klients->z( i ) == zKlient )
  219. {
  220. klients->remove( i );
  221. klientAnzahl--;
  222. gefunden = 1;
  223. break;
  224. }
  225. }
  226. LeaveCriticalSection( &cs );
  227. return gefunden;
  228. }
  229. void MinigameServer::addGesendet( int bytes )
  230. {
  231. gesendet += bytes;
  232. }
  233. void MinigameServer::addEmpfangen( int bytes )
  234. {
  235. empfangen += bytes;
  236. }
  237. // constant
  238. bool MinigameServer::istAn() const
  239. {
  240. return db->serverIstNichtPausiert( id );
  241. }
  242. Server *MinigameServer::zServer() const
  243. {
  244. return server;
  245. }
  246. MSDatenbank *MinigameServer::zDB() const
  247. {
  248. return db;
  249. }
  250. bool MinigameServer::hatClients() const
  251. {
  252. return klientAnzahl > 0;
  253. }
  254. int MinigameServer::getId() const
  255. {
  256. return id;
  257. }
  258. char *MinigameServer::getLetzterFehler() const
  259. {
  260. return fehler->getText();
  261. }
  262. InitDatei *MinigameServer::zInit() const
  263. {
  264. return ini;
  265. }
  266. // Reference Counting
  267. MinigameServer *MinigameServer::getThis()
  268. {
  269. ref++;
  270. return this;
  271. }
  272. MinigameServer *MinigameServer::release()
  273. {
  274. ref--;
  275. if( !ref )
  276. delete this;
  277. return 0;
  278. }
  279. // Inhalt der LSAKlient Klasse aus LoginServer.h
  280. // Konstruktor
  281. MSAKlient::MSAKlient( SKlient *klient, MinigameServer *ls )
  282. : Thread()
  283. {
  284. this->klient = klient;
  285. unsigned char key[ 20 ] = { 168, 13, 57, 219, 1, 54, 176, 97, 163, 80, 63, 101, 137, 132, 45, 103, 204, 225, 53, 197 };
  286. klient->setSendeKey( (char*)key, 20 );
  287. klient->setEmpfangKey( (char*)key, 20 );
  288. name = new Text( "" );
  289. passwort = new Text( "" );
  290. adminId = 0;
  291. version = 0;
  292. this->ms = ls;
  293. }
  294. // Destruktor
  295. MSAKlient::~MSAKlient()
  296. {
  297. klient->trenne();
  298. klient->release();
  299. ms->release();
  300. name->release();
  301. passwort->release();
  302. }
  303. // nicht constant
  304. void MSAKlient::thread()
  305. {
  306. while( 1 )
  307. {
  308. char c = 0;
  309. if( !klient->getNachrichtEncrypted( &c, 1 ) )
  310. break;
  311. else
  312. {
  313. bool br = 0;
  314. switch( c )
  315. {
  316. case 1: // Login
  317. if( 1 )
  318. {
  319. klient->sendeEncrypted( "\1", 1 );
  320. unsigned char nLen = 0;
  321. klient->getNachrichtEncrypted( (char*)&nLen, 1 );
  322. char *n = new char[ nLen + 1 ];
  323. n[ (int)nLen ] = 0;
  324. if( nLen )
  325. klient->getNachrichtEncrypted( n, nLen );
  326. unsigned char pLen = 0;
  327. klient->getNachrichtEncrypted( (char*)&pLen, 1 );
  328. char *p = new char[ pLen + 1 ];
  329. p[ (int)pLen ] = 0;
  330. if( pLen )
  331. klient->getNachrichtEncrypted( p, pLen );
  332. int adminId = ms->zDB()->istAdministrator( n, p );
  333. if( adminId )
  334. {
  335. klient->sendeEncrypted( "\1", 1 );
  336. name->setText( n );
  337. passwort->setText( p );
  338. this->adminId = adminId;
  339. }
  340. else
  341. errorZuKlient( "Falsche Kombination aus Name und Passwort." );
  342. delete[] n;
  343. delete[] p;
  344. }
  345. break;
  346. case 2: // Logout
  347. adminId = 0;
  348. name->setText( "" );
  349. passwort->setText( "" );
  350. klient->sendeEncrypted( "\1", 1 );
  351. break;
  352. case 3: // Trennen
  353. br = 1;
  354. klient->sendeEncrypted( "\1", 1 );
  355. break;
  356. case 4: // Server starten
  357. if( !adminId )
  358. errorZuKlient( "Du musst dich einloggen." );
  359. else
  360. {
  361. if( ms->zDB()->adminHatRecht( adminId, Admin_Recht::MSStarten ) )
  362. {
  363. if( !ms->serverStarten() )
  364. {
  365. Text *err = new Text();
  366. err->append( ms->getLetzterFehler() );
  367. errorZuKlient( err->getText() );
  368. err->release();
  369. }
  370. else
  371. klient->sendeEncrypted( "\1", 1 );
  372. }
  373. else
  374. errorZuKlient( "Du bist nicht berechtigt den Server zu starten." );
  375. }
  376. break;
  377. case 5: // Server beenden
  378. if( !adminId )
  379. errorZuKlient( "Du musst dich einloggen." );
  380. else
  381. {
  382. if( ms->zDB()->adminHatRecht( adminId, Admin_Recht::MSBeenden ) )
  383. {
  384. if( ms->serverBeenden() )
  385. klient->sendeEncrypted( "\1", 1 );
  386. else
  387. {
  388. Text *err = new Text();
  389. err->append( ms->getLetzterFehler() );
  390. errorZuKlient( err->getText() );
  391. err->release();
  392. }
  393. }
  394. else
  395. errorZuKlient( "Du bist nicht berechtigt den Server zu beenden." );
  396. }
  397. break;
  398. case 6: // Programm Schließen
  399. if( !adminId )
  400. errorZuKlient( "Du musst dich einloggen." );
  401. else
  402. {
  403. bool ok = 0;
  404. if( ms->isRunning() )
  405. {
  406. if( ms->zDB()->adminHatRecht( adminId, Admin_Recht::MSBeenden ) )
  407. {
  408. if( ms->serverBeenden() )
  409. ok = 1;
  410. else
  411. {
  412. Text *err = new Text();
  413. err->append( ms->getLetzterFehler() );
  414. errorZuKlient( err->getText() );
  415. err->release();
  416. }
  417. }
  418. else
  419. errorZuKlient( "Du bist nicht berechtigt den Server zu beenden." );
  420. }
  421. else
  422. ok = 1;
  423. if( ok && ms->hatClients() )
  424. {
  425. errorZuKlient( "Es sind noch Klients Online. Bitte versuche es später erneut." );
  426. break;
  427. }
  428. if( ok )
  429. {
  430. klient->sendeEncrypted( "\1", 1 );
  431. std::cout << "MS: Der Server wird von Benutzer " << adminId << " heruntergefahren.\n";
  432. ms->close();
  433. br = 1;
  434. }
  435. }
  436. break;
  437. case 7: // Progtamm abstürzen
  438. if( !adminId )
  439. errorZuKlient( "Du musst dich einloggen." );
  440. else
  441. {
  442. bool ok = 0;
  443. if( ms->isRunning() )
  444. {
  445. if( ms->zDB()->adminHatRecht( adminId, Admin_Recht::MSBeenden ) )
  446. {
  447. ms->serverBeenden();
  448. ok = 1;
  449. }
  450. else
  451. errorZuKlient( "Du bist nicht berechtigt den Server zu beenden." );
  452. }
  453. else
  454. ok = 1;
  455. if( ok )
  456. {
  457. klient->sendeEncrypted( "\1", 1 );
  458. std::cout << "MS: Der Server wurde von Benutzer " << adminId << " terminiert.\n";
  459. ms->close();
  460. br = 1;
  461. }
  462. }
  463. break;
  464. case 8: // Status Frage
  465. if( 1 )
  466. {
  467. char status = 0;
  468. if( ms->isRunning() )
  469. {
  470. status = 1;
  471. if( ms->istAn() )
  472. status = 2;
  473. }
  474. klient->sendeEncrypted( "\1", 1 );
  475. klient->sendeEncrypted( &status, 1 );
  476. }
  477. break;
  478. case 9: // Server pausieren
  479. if( !adminId )
  480. errorZuKlient( "Du musst dich einloggen." );
  481. else
  482. {
  483. klient->sendeEncrypted( "\1", 1 );
  484. char pause = 0;
  485. klient->getNachrichtEncrypted( &pause, 1 );
  486. if( ms->zDB()->adminHatRecht( adminId, Admin_Recht::MSPausieren ) )
  487. {
  488. bool ok = 0;
  489. if( pause )
  490. ok = ms->serverPause();
  491. else
  492. ok = ms->serverFortsetzen();
  493. if( ok )
  494. klient->sendeEncrypted( "\1", 1 );
  495. else
  496. {
  497. Text *err = new Text();
  498. err->append( ms->getLetzterFehler() );
  499. errorZuKlient( err->getText() );
  500. err->release();
  501. }
  502. }
  503. else
  504. {
  505. if( pause )
  506. errorZuKlient( "Du bist nicht berechtigt den Server zu pausieren." );
  507. else
  508. errorZuKlient( "Du bist nicht berechtigt den Server fortzusetzen." );
  509. }
  510. }
  511. break;
  512. case 0xA: // maximale Anzahl der Clients setzen
  513. if( !adminId )
  514. errorZuKlient( "Du musst dich einloggen." );
  515. else
  516. {
  517. klient->sendeEncrypted( "\1", 1 );
  518. int maxC = 0;
  519. klient->getNachrichtEncrypted( (char*)&maxC, 4 );
  520. if( ms->zDB()->adminHatRecht( adminId, Admin_Recht::MSMCChange ) )
  521. {
  522. if( ms->setMaxKlients( maxC ) )
  523. klient->sendeEncrypted( "\1", 1 );
  524. else
  525. {
  526. Text *err = new Text();
  527. err->append( ms->getLetzterFehler() );
  528. errorZuKlient( err->getText() );
  529. err->release();
  530. }
  531. }
  532. else
  533. errorZuKlient( "Du bist nicht berechtigt die maximale Anzahl der Clients zu verändern." );
  534. }
  535. break;
  536. case 0xC: // klient absturtz
  537. if( 1 )
  538. {
  539. klient->sendeEncrypted( "\1", 1 );
  540. int klientId = 0;
  541. klient->getNachrichtEncrypted( (char*)&klientId, 4 );
  542. if( klientId && ms->absturzKlient( klientId ) )
  543. klient->sendeEncrypted( "\1", 1 );
  544. else
  545. klient->sendeEncrypted( "\0", 1 );
  546. }
  547. break;
  548. default:
  549. errorZuKlient( "Unbekannte Nachricht!" );
  550. break;
  551. }
  552. if( br )
  553. break;
  554. ms->addEmpfangen( klient->getDownloadBytes( 1 ) );
  555. ms->addGesendet( klient->getUploadBytes( 1 ) );
  556. }
  557. }
  558. ms->addEmpfangen( klient->getDownloadBytes( 1 ) );
  559. ms->addGesendet( klient->getUploadBytes( 1 ) );
  560. delete this;
  561. }
  562. void MSAKlient::errorZuKlient( const char *nachricht ) const // sendet eine Fehlernachricht zum Klient
  563. {
  564. klient->sendeEncrypted( "\3", 1 );
  565. char len = (char)textLength( nachricht );
  566. klient->sendeEncrypted( &len, 1 );
  567. klient->sendeEncrypted( nachricht, len );
  568. }
  569. // Inhalt der LSKlient aus LoginServer.h
  570. // Konstruktor
  571. MSKlient::MSKlient( SKlient *klient, MinigameServer *ls )
  572. : Thread()
  573. {
  574. this->klient = klient;
  575. unsigned char key[ 20 ] = { 88, 103, 192, 232, 69, 54, 57, 3, 239, 138, 234, 172, 126, 72, 81, 55, 205, 97, 59, 255 };
  576. klient->setSendeKey( (char*)key, 20 );
  577. klient->setEmpfangKey( (char*)key, 20 );
  578. klientNummer = 0;
  579. this->ms = ls;
  580. ref = 1;
  581. }
  582. // Destruktor
  583. MSKlient::~MSKlient()
  584. {
  585. klient->release();
  586. ms->release();
  587. }
  588. // nicht constant
  589. void MSKlient::absturz()
  590. {
  591. ende();
  592. klient->trenne();
  593. ms->zDB()->unregisterKlient( klientNummer, ms->getId() );
  594. }
  595. void MSKlient::thread()
  596. {
  597. while( 1 )
  598. {
  599. char c = 0;
  600. if( !klient->getNachrichtEncrypted( &c, 1 ) )
  601. break;
  602. else
  603. {
  604. bool br = 0;
  605. switch( c )
  606. {
  607. case 1: // Klient identifikation
  608. klient->getNachrichtEncrypted( (char*)&klientNummer, 4 );
  609. if( !ms->zDB()->proveKlient( klientNummer, ms->getId() ) )
  610. {
  611. klientNummer = 0;
  612. errorZuKlient( "Du bist nicht für diesen Server eingetragen" );
  613. }
  614. else
  615. {
  616. Text *key = ms->zDB()->getKlientKey( klientNummer );
  617. if( !key )
  618. errorZuKlient( "Es konnte kein Schlüssel ermittelt werden." );
  619. else
  620. {
  621. klient->sendeEncrypted( "\1", 1 );
  622. klient->setEmpfangKey( *key, key->getLength() );
  623. klient->setSendeKey( *key, key->getLength() );
  624. key->release();
  625. }
  626. }
  627. break;
  628. case 2: // Main / Erhaltung Server message
  629. if( 1 )
  630. {
  631. char befehl = 0;
  632. klient->getNachrichtEncrypted( &befehl, 1 );
  633. switch( befehl )
  634. {
  635. case 2: // klient absturtz
  636. if( 1 )
  637. {
  638. int klientId = 0;
  639. klient->getNachrichtEncrypted( (char*)&klientId, 4 );
  640. if( klientId && ms->absturzKlient( klientId ) )
  641. klient->sendeEncrypted( "\1", 1 );
  642. else
  643. klient->sendeEncrypted( "\0", 1 );
  644. }
  645. break;
  646. default:
  647. errorZuKlient( "Befehl nicht bekannt!" );
  648. break;
  649. }
  650. }
  651. break;
  652. case 3: // Verbindungsende
  653. br = 1;
  654. klient->sendeEncrypted( "\1", 1 );
  655. break;
  656. case 4: // unregister Klient
  657. if( !klientNummer )
  658. {
  659. errorZuKlient( "Du bist nicht Identifiziert." );
  660. break;
  661. }
  662. ms->zDB()->unregisterKlient( klientNummer, ms->getId() );
  663. klient->sendeEncrypted( "\1", 1 );
  664. break;
  665. case 0x5: // ping
  666. if( !klientNummer )
  667. {
  668. errorZuKlient( "Du bist nicht Identifiziert." );
  669. break;
  670. }
  671. klient->sendeEncrypted( "\1", 1 );
  672. break;
  673. case 0x6: // Get Minigame Option List
  674. {
  675. klient->sendeEncrypted( "\1", 1 );
  676. unsigned char l = 0;
  677. klient->getNachrichtEncrypted( (char*)&l, 1 );
  678. char *mName = new char[ l ];
  679. mName[ (int)l ] = 0;
  680. klient->getNachrichtEncrypted( mName, l );
  681. RCArray< Text > oList;
  682. int anz = ms->zDB()->getMinigameOptionList( mName, &oList );
  683. delete[] mName;
  684. klient->sendeEncrypted( (char*)&anz, 4 );
  685. for( auto t = oList.getArray(); t.set && t.var; t++ )
  686. {
  687. l = (char)t.var->getLength();
  688. klient->sendeEncrypted( &l, 1 );
  689. klient->sendeEncrypted( t.var->getText(), l );
  690. }
  691. break;
  692. }
  693. case 0x7: // Get Minigame Bestscore List
  694. {
  695. klient->sendeEncrypted( "\1", 1 );
  696. unsigned char l = 0;
  697. klient->getNachrichtEncrypted( (char*)&l, 1 );
  698. char *mName = new char[ l ];
  699. mName[ (int)l ] = 0;
  700. klient->getNachrichtEncrypted( mName, l );
  701. Array< int > sList;
  702. RCArray< Text > pList;
  703. RCArray< Text > oList;
  704. int anz = ms->zDB()->getMinigameBestscore( mName, &sList, &pList, &oList );
  705. delete[] mName;
  706. klient->sendeEncrypted( (char*)&anz, 4 );
  707. for( int i = 0; i < anz; i++ )
  708. {
  709. int s = sList.get( i );
  710. klient->sendeEncrypted( (char*)&s, 4 );
  711. l = (char)pList.z( i )->getLength();
  712. klient->sendeEncrypted( &l, 1 );
  713. klient->sendeEncrypted( pList.z( i )->getText(), l );
  714. l = (char)oList.z( i )->getLength();
  715. klient->sendeEncrypted( &l, 1 );
  716. klient->sendeEncrypted( oList.z( i )->getText(), l );
  717. }
  718. break;
  719. }
  720. case 0x8: // Get Minigame Option Bestscore
  721. {
  722. klient->sendeEncrypted( "\1", 1 );
  723. unsigned char l = 0;
  724. klient->getNachrichtEncrypted( (char*)&l, 1 );
  725. char *mName = new char[ l ];
  726. mName[ (int)l ] = 0;
  727. klient->getNachrichtEncrypted( mName, l );
  728. klient->getNachrichtEncrypted( (char*)&l, 1 );
  729. char *oName = new char[ l ];
  730. oName[ (int)l ] = 0;
  731. klient->getNachrichtEncrypted( oName, l );
  732. Text player;
  733. int score = ms->zDB()->getMinigameBestscore( oName, mName, &player );
  734. delete[] mName;
  735. delete[] oName;
  736. klient->sendeEncrypted( (char*)&score, 4 );
  737. if( score )
  738. {
  739. l = (char)player.getLength();
  740. klient->sendeEncrypted( &l, 1 );
  741. klient->sendeEncrypted( player.getText(), l );
  742. }
  743. break;
  744. }
  745. case 0x9: // Report End of Game
  746. {
  747. if( !klientNummer )
  748. {
  749. errorZuKlient( "Du bist nicht Identifiziert." );
  750. break;
  751. }
  752. klient->sendeEncrypted( "\1", 1 );
  753. unsigned char l = 0;
  754. klient->getNachrichtEncrypted( (char*)&l, 1 );
  755. char *mName = new char[ l ];
  756. mName[ (int)l ] = 0;
  757. klient->getNachrichtEncrypted( mName, l );
  758. klient->getNachrichtEncrypted( (char*)&l, 1 );
  759. char *oName = new char[ l ];
  760. oName[ (int)l ] = 0;
  761. klient->getNachrichtEncrypted( oName, l );
  762. int score;
  763. klient->getNachrichtEncrypted( (char*)&score, 4 );
  764. Text fName;
  765. if( ms->zDB()->updateMinigameScore( score, oName, klientNummer, mName, ms->getId(), &fName ) )
  766. {
  767. ms->zDB()->lock();
  768. Text path = ms->zInit()->zWert( "MGC_Pfad" )->getText();
  769. if( path.getText()[ path.getLength() - 1 ] != '/' )
  770. path += "/";
  771. path += (char*)fName;
  772. Datei d;
  773. d.setDatei( path );
  774. d.erstellen();
  775. if( d.open( Datei::Style::schreiben ) )
  776. {
  777. klient->sendeEncrypted( "\1", 1 );
  778. int size;
  779. klient->getNachrichtEncrypted( (char*)&size, 4 );
  780. char *buffer = new char[ 2048 ];
  781. while( size > 0 )
  782. {
  783. int l = size > 2048 ? 2048 : size;
  784. klient->getNachrichtEncrypted( buffer, l );
  785. d.schreibe( buffer, l );
  786. size -= l;
  787. }
  788. delete[] buffer;
  789. d.close();
  790. }
  791. else
  792. errorZuKlient( "Fehler beim speichern des Spielverlaufs" );
  793. ms->zDB()->unlock();
  794. }
  795. else
  796. klient->sendeEncrypted( "\0", 1 );
  797. delete[] mName;
  798. delete[] oName;
  799. break;
  800. }
  801. case 0xA: // Get Minigame Capture
  802. {
  803. klient->sendeEncrypted( "\1", 1 );
  804. unsigned char l = 0;
  805. klient->getNachrichtEncrypted( (char*)&l, 1 );
  806. char *mName = new char[ l ];
  807. mName[ (int)l ] = 0;
  808. klient->getNachrichtEncrypted( mName, l );
  809. klient->getNachrichtEncrypted( (char*)&l, 1 );
  810. char *oName = new char[ l ];
  811. oName[ (int)l ] = 0;
  812. klient->getNachrichtEncrypted( oName, l );
  813. int serverId = ms->zDB()->getMinigameServer( mName, oName );
  814. if( serverId && serverId == ms->getId() )
  815. {
  816. ms->zDB()->lock();
  817. Text *fileName = ms->zDB()->getMinigameCaptureFileName( oName, mName );
  818. Text path = ms->zInit()->zWert( "MGC_Pfad" )->getText();
  819. if( path.getText()[ path.getLength() - 1 ] != '/' )
  820. path += "/";
  821. path += fileName->getText();
  822. fileName->release();
  823. Datei d;
  824. d.setDatei( path );
  825. if( d.open( Datei::Style::lesen ) )
  826. {
  827. klient->sendeEncrypted( "\1", 1 );
  828. int size = (int)d.getSize();
  829. klient->sendeEncrypted( (char*)&size, 4 );
  830. char *buffer = new char[ 2048 ];
  831. while( size > 0 )
  832. {
  833. int l = size > 2048 ? 2048 : size;
  834. d.lese( buffer, l );
  835. klient->sendeEncrypted( buffer, l );
  836. size -= l;
  837. }
  838. delete[] buffer;
  839. d.close();
  840. }
  841. errorZuKlient( "Aufzeichnung konnte nicht gelesen werden." );
  842. ms->zDB()->unlock();
  843. }
  844. else if( serverId )
  845. {
  846. Text ip;
  847. Text port;
  848. if( ms->zDB()->getMinigameServer( mName, oName, &ip, &port ) )
  849. {
  850. Klient *k = new Klient();
  851. unsigned char key[ 20 ] = { 88, 103, 192, 232, 69, 54, 57, 3, 239, 138, 234, 172, 126, 72, 81, 55, 205, 97, 59, 255 };
  852. k->setSendeKey( (char*)key, 20 );
  853. k->setEmpfangKey( (char*)key, 20 );
  854. if( k->verbinde( (unsigned short)(int)port, (char*)ip ) )
  855. {
  856. k->sendeEncrypted( "\xA", 1 );
  857. char ret;
  858. k->getNachrichtEncrypted( &ret, 1 );
  859. if( ret == 1 )
  860. {
  861. l = (char)textLength( mName );
  862. k->sendeEncrypted( &l, 1 );
  863. k->sendeEncrypted( mName, l );
  864. l = (char)textLength( oName );
  865. k->sendeEncrypted( &l, 1 );
  866. k->sendeEncrypted( oName, l );
  867. k->getNachrichtEncrypted( &ret, 1 );
  868. if( ret == 1 )
  869. {
  870. klient->sendeEncrypted( "\1", 1 );
  871. int size;
  872. k->getNachrichtEncrypted( (char*)&size, 4 );
  873. klient->sendeEncrypted( (char*)&size, 4 );
  874. char *buffer = new char[ 2048 ];
  875. while( size > 0 )
  876. {
  877. int l = size > 2048 ? 2048 : size;
  878. k->getNachrichtEncrypted( buffer, l );
  879. klient->sendeEncrypted( buffer, l );
  880. size -= l;
  881. }
  882. delete[] buffer;
  883. }
  884. }
  885. if( ret == 3 )
  886. {
  887. k->getNachrichtEncrypted( (char*)&l, 1 );
  888. char *error = new char[ l + 1 ];
  889. error[ (int)l ] = 0;
  890. k->getNachrichtEncrypted( error, l );
  891. errorZuKlient( error );
  892. delete[] error;
  893. }
  894. else if( ret != 1 )
  895. errorZuKlient( "Umbekannter Fehler während der Kommunikation mit dem Aufzeichnungs Server." );
  896. k->sendeEncrypted( "\3", 1 );
  897. k->getNachrichtEncrypted( &ret, 1 );
  898. k->trenne();
  899. k->release();
  900. }
  901. else
  902. errorZuKlient( "Aufzeichnungs Server konnte nicht kontaktiert werden." );
  903. }
  904. else
  905. errorZuKlient( "Aufzeichnungs Server wurde nicht gefunden." );
  906. }
  907. else
  908. errorZuKlient( "Aufzeichnung wurde nicht gefunden." );
  909. delete[] mName;
  910. delete[] oName;
  911. break;
  912. }
  913. default:
  914. errorZuKlient( "Unbekannte Nachricht!" );
  915. break;
  916. }
  917. if( br )
  918. break;
  919. ms->addEmpfangen( klient->getDownloadBytes( 1 ) );
  920. ms->addGesendet( klient->getUploadBytes( 1 ) );
  921. }
  922. }
  923. ms->addEmpfangen( klient->getDownloadBytes( 1 ) );
  924. ms->addGesendet( klient->getUploadBytes( 1 ) );
  925. ms->removeKlient( this ); // delete this
  926. }
  927. // constant
  928. void MSKlient::errorZuKlient( const char *nachricht ) const // sendet eine Fehlernachricht zum Klient
  929. {
  930. klient->sendeEncrypted( "\3", 1 );
  931. char len = (char)textLength( nachricht );
  932. klient->sendeEncrypted( &len, 1 );
  933. klient->sendeEncrypted( nachricht, len );
  934. }
  935. int MSKlient::getKlientNummer() const // gibt die KlientId zurück
  936. {
  937. return klientNummer;
  938. }
  939. // Reference Counting
  940. MSKlient *MSKlient::getThis()
  941. {
  942. ref++;
  943. return this;
  944. }
  945. MSKlient *MSKlient::release()
  946. {
  947. ref--;
  948. if( !ref )
  949. delete this;
  950. return 0;
  951. }