EditorServer.cpp 29 KB

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