MainServer.cpp 41 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520
  1. #include "MainServer.h"
  2. #include "Datenbank.h"
  3. #include <Text.h>
  4. #include <iostream>
  5. #include <Klient.h>
  6. #include <Globals.h>
  7. // Inhalt der MainServer Klasse aus MainServer.h
  8. // Konstruktor
  9. MainServer::MainServer( InitDatei *zDat )
  10. : Thread()
  11. {
  12. Network::Start( 100 );
  13. std::cout << "MS: Verbindung mit Datenbank wird hergestellt...\n";
  14. db = new MSDatenbank( zDat );
  15. clients = 0;
  16. empfangen = 0;
  17. gesendet = 0;
  18. dat = zDat->getThis();
  19. if( !zDat->wertExistiert( "MSPort" ) )
  20. zDat->addWert( "MSPort", "4253" );
  21. if( !zDat->wertExistiert( "MSAPort" ) )
  22. zDat->addWert( "MSAPort", "4252" );
  23. server = new Server();
  24. aServer = new Server();
  25. std::cout << "MS: Starten des Admin Servers...\n";
  26. if( !aServer->verbinde( (unsigned short)TextZuInt( zDat->zWert( "MSAPort" )->getText(), 10 ), 10 ) )
  27. {
  28. std::cout << "MS: Der Admin Server konnte nicht gestartet werden. Das Programm wird beendet.\n";
  29. exit( 1 );
  30. }
  31. end = 0;
  32. InitializeCriticalSection( &cs );
  33. ref = 1;
  34. if( zDat->wertExistiert( "Aktiv" ) && zDat->zWert( "Aktiv" )->istGleich( "TRUE" ) )
  35. serverStarten();
  36. }
  37. // Destruktor
  38. MainServer::~MainServer()
  39. {
  40. ende();
  41. server->trenne();
  42. server->release();
  43. aServer->trenne();
  44. aServer->release();
  45. dat->release();
  46. db->release();
  47. Network::Exit();
  48. DeleteCriticalSection( &cs );
  49. }
  50. // nicht constant
  51. void MainServer::runn()
  52. {
  53. while( !end )
  54. {
  55. SKlient *klient;
  56. klient = aServer->getKlient();
  57. if( end && klient )
  58. {
  59. klient->trenne();
  60. klient = klient->release();
  61. Sleep( 1000 );
  62. return;
  63. }
  64. if( !klient )
  65. return;
  66. MSAKlient *clHandle = new MSAKlient( klient, getThis() );
  67. clHandle->start();
  68. }
  69. }
  70. void MainServer::thread()
  71. {
  72. while( 1 )
  73. {
  74. SKlient *klient;
  75. klient = server->getKlient();
  76. if( !klient )
  77. break;
  78. Framework::getThreadRegister()->cleanUpClosedThreads();
  79. MSKlient *clHandle = new MSKlient( klient, getThis() );
  80. clHandle->start();
  81. clients++;
  82. }
  83. run = 0;
  84. }
  85. void MainServer::close()
  86. {
  87. server->trenne();
  88. #ifdef WIN32
  89. warteAufThread( 1000 );
  90. #endif
  91. ende();
  92. run = 0;
  93. end = 1;
  94. Klient *klient = new Klient();
  95. klient->verbinde( aServer->getPort(), "127.0.0.1" );
  96. Sleep( 500 );
  97. aServer->trenne();
  98. klient->release();
  99. }
  100. bool MainServer::serverStarten()
  101. {
  102. if( run )
  103. return 1;
  104. bool ret = server->verbinde( (unsigned short)TextZuInt( dat->zWert( "MSPort" )->getText(), 10 ), 10 );
  105. start();
  106. return ret;
  107. }
  108. void MainServer::serverBeenden()
  109. {
  110. if( !run )
  111. return;
  112. server->trenne();
  113. #ifdef WIN32
  114. warteAufThread( 1000 );
  115. #endif
  116. ende();
  117. server->release();
  118. server = new Server();
  119. run = 0;
  120. }
  121. void MainServer::addGesendet( int bytes )
  122. {
  123. gesendet += bytes;
  124. }
  125. void MainServer::addEmpfangen( int bytes )
  126. {
  127. empfangen += empfangen;
  128. }
  129. void MainServer::clientTrennung()
  130. {
  131. clients--;
  132. }
  133. // constant
  134. Server *MainServer::zServer() const
  135. {
  136. return server;
  137. }
  138. MSDatenbank *MainServer::zDB() const
  139. {
  140. return db;
  141. }
  142. bool MainServer::hatClients() const
  143. {
  144. return clients > 0;
  145. }
  146. // Reference Counting
  147. MainServer *MainServer::getThis()
  148. {
  149. EnterCriticalSection( &cs );
  150. ref++;
  151. LeaveCriticalSection( &cs );
  152. return this;
  153. }
  154. MainServer *MainServer::release()
  155. {
  156. EnterCriticalSection( &cs );
  157. ref--;
  158. LeaveCriticalSection( &cs );
  159. if( !ref )
  160. delete this;
  161. return 0;
  162. }
  163. // Inhalt der MSKlient Klasse aus MainServer.h
  164. // Konstruktor
  165. MSAKlient::MSAKlient( SKlient *klient, MainServer *ms )
  166. : Thread()
  167. {
  168. this->klient = klient;
  169. unsigned char key[ 20 ] = { 103, 112, 161, 152, 241, 81, 192, 29, 85, 160, 151, 68, 120, 164, 145, 208, 65, 241, 234, 219 };
  170. klient->setSendeKey( (char*)key, 20 );
  171. klient->setEmpfangKey( (char*)key, 20 );
  172. name = new Text( "" );
  173. passwort = new Text( "" );
  174. adminId = 0;
  175. this->ms = ms;
  176. }
  177. // Destruktor
  178. MSAKlient::~MSAKlient()
  179. {
  180. klient->trenne();
  181. klient->release();
  182. ms->release();
  183. name->release();
  184. passwort->release();
  185. }
  186. // nicht constant
  187. void MSAKlient::thread()
  188. {
  189. while( 1 )
  190. {
  191. char c = 0;
  192. if( !klient->getNachrichtEncrypted( &c, 1 ) )
  193. break;
  194. else
  195. {
  196. bool br = 0;
  197. switch( c )
  198. {
  199. case 1: // Login
  200. if( 1 )
  201. {
  202. klient->sendeEncrypted( "\1", 1 );
  203. char nLen = 0;
  204. klient->getNachrichtEncrypted( &nLen, 1 );
  205. char *n = new char[ nLen + 1 ];
  206. n[ (int)nLen ] = 0;
  207. if( nLen )
  208. klient->getNachrichtEncrypted( n, nLen );
  209. char pLen = 0;
  210. klient->getNachrichtEncrypted( &pLen, 1 );
  211. char *p = new char[ pLen + 1 ];
  212. p[ (int)pLen ] = 0;
  213. if( pLen )
  214. klient->getNachrichtEncrypted( p, pLen );
  215. int adminId = ms->zDB()->istAdministrator( n, p );
  216. if( adminId )
  217. {
  218. klient->sendeEncrypted( "\1", 1 );
  219. name->setText( n );
  220. passwort->setText( p );
  221. this->adminId = adminId;
  222. }
  223. else
  224. errorZuKlient( "Falsche Kombination aus Name und Passwort." );
  225. delete[] n;
  226. delete[] p;
  227. }
  228. break;
  229. case 2: // Logout
  230. adminId = 0;
  231. name->setText( "" );
  232. passwort->setText( "" );
  233. klient->sendeEncrypted( "\1", 1 );
  234. break;
  235. case 3: // Trennen
  236. br = 1;
  237. klient->sendeEncrypted( "\1", 1 );
  238. break;
  239. case 4: // Server starten
  240. if( !adminId )
  241. errorZuKlient( "Du musst dich einloggen." );
  242. else
  243. {
  244. if( ms->zDB()->adminHatRecht( adminId, Admin_Recht::MSStarten ) )
  245. {
  246. if( !ms->serverStarten() )
  247. errorZuKlient( "Beim starten des Servers ist ein Fehler aufgetreten." );
  248. else
  249. klient->sendeEncrypted( "\1", 1 );
  250. }
  251. else
  252. errorZuKlient( "Du bist nicht berechtigt den Server zu starten." );
  253. }
  254. break;
  255. case 5: // Server beenden
  256. if( !adminId )
  257. errorZuKlient( "Du musst dich einloggen." );
  258. else
  259. {
  260. if( ms->zDB()->adminHatRecht( adminId, Admin_Recht::MSBeenden ) )
  261. {
  262. ms->serverBeenden();
  263. klient->sendeEncrypted( "\1", 1 );
  264. }
  265. else
  266. errorZuKlient( "Du bist nicht berechtigt den Server zu beenden." );
  267. }
  268. break;
  269. case 6: // Programm Schließen
  270. if( !adminId )
  271. errorZuKlient( "Du musst dich einloggen." );
  272. else
  273. {
  274. bool ok = 0;
  275. if( ms->isRunning() )
  276. {
  277. if( ms->zDB()->adminHatRecht( adminId, Admin_Recht::MSBeenden ) )
  278. {
  279. ms->serverBeenden();
  280. ok = 1;
  281. }
  282. else
  283. errorZuKlient( "Du bist nicht berechtigt den Server zu beenden." );
  284. }
  285. else
  286. ok = 1;
  287. if( ok && ms->hatClients() )
  288. {
  289. errorZuKlient( "Es sind noch Klients Online. Bitte versuche es später erneut." );
  290. break;
  291. }
  292. if( ok )
  293. {
  294. klient->sendeEncrypted( "\1", 1 );
  295. std::cout << "MS: Der Server wird von Benutzer " << adminId << " heruntergefahren.\n";
  296. ms->close();
  297. br = 1;
  298. }
  299. }
  300. break;
  301. case 7: // Progtamm abstürzen
  302. if( !adminId )
  303. errorZuKlient( "Du musst dich einloggen." );
  304. else
  305. {
  306. bool ok = 0;
  307. if( ms->isRunning() )
  308. {
  309. if( ms->zDB()->adminHatRecht( adminId, Admin_Recht::MSBeenden ) )
  310. {
  311. ms->serverBeenden();
  312. ok = 1;
  313. }
  314. else
  315. errorZuKlient( "Du bist nicht berechtigt den Server zu beenden." );
  316. }
  317. else
  318. ok = 1;
  319. if( ok )
  320. {
  321. klient->sendeEncrypted( "\1", 1 );
  322. std::cout << "MS: Der Server wurde von Benutzer " << adminId << " terminiert.\n";
  323. ms->close();
  324. br = 1;
  325. }
  326. }
  327. break;
  328. case 8: // Status Frage
  329. if( 1 )
  330. {
  331. klient->sendeEncrypted( "\1", 1 );
  332. char status = (int)ms->isRunning();
  333. klient->sendeEncrypted( &status, 1 );
  334. }
  335. break;
  336. default:
  337. errorZuKlient( "Unbekannte Nachricht!" );
  338. break;
  339. }
  340. if( br )
  341. break;
  342. ms->addEmpfangen( klient->getDownloadBytes( 1 ) );
  343. ms->addGesendet( klient->getUploadBytes( 1 ) );
  344. }
  345. }
  346. ms->addEmpfangen( klient->getDownloadBytes( 1 ) );
  347. ms->addGesendet( klient->getUploadBytes( 1 ) );
  348. delete this;
  349. }
  350. void MSAKlient::errorZuKlient( const char *nachricht ) const // sendet eine Fehlernachricht zum Klient
  351. {
  352. klient->sendeEncrypted( "\3", 1 );
  353. char len = (char)textLength( nachricht );
  354. klient->sendeEncrypted( &len, 1 );
  355. klient->sendeEncrypted( nachricht, len );
  356. }
  357. // Inhalt der MSKlient Klasse aus MainServer.h
  358. // Konstruktor
  359. MSKlient::MSKlient( SKlient *klient, MainServer *ms )
  360. : Thread()
  361. {
  362. this->klient = klient;
  363. unsigned char key[ 20 ] = { 199, 164, 172, 55, 246, 16, 155, 8, 151, 176, 250, 181, 227, 133, 30, 41, 200, 26, 7, 151 };
  364. klient->setSendeKey( (char*)key, 20 );
  365. klient->setEmpfangKey( (char*)key, 20 );
  366. klientNummer = 0;
  367. this->ms = ms;
  368. encrypted = 0;
  369. }
  370. // Destruktor
  371. MSKlient::~MSKlient()
  372. {
  373. ms->clientTrennung();
  374. ms->release();
  375. klient->release();
  376. }
  377. // nicht constant
  378. void MSKlient::thread()
  379. {
  380. while( 1 )
  381. {
  382. char c = 0;
  383. if( ( !encrypted && !klient->getNachricht( &c, 1 ) ) || ( encrypted && !klient->getNachrichtEncrypted( &c, 1 ) ) )
  384. break;
  385. else
  386. {
  387. bool br = 0;
  388. switch( c )
  389. {
  390. case 0:
  391. encrypted = 1;
  392. break;
  393. case 1: // Client Identifikation
  394. if( 1 )
  395. {
  396. if( encrypted )
  397. klient->getNachrichtEncrypted( (char*)&klientNummer, 4 );
  398. else
  399. klient->getNachricht( (char*)&klientNummer, 4 );
  400. bool ret1 = 0;
  401. if( !klientNummer )
  402. {
  403. klientNummer = ms->zDB()->getNextClientId();
  404. if( encrypted )
  405. {
  406. Text *key = ms->zDB()->getKlientKey( klientNummer );
  407. if( key )
  408. {
  409. klient->sendeEncrypted( "\1", 1 );
  410. klient->sendeEncrypted( (char*)&klientNummer, 4 );
  411. char len = (char)key->getLength();
  412. klient->sendeEncrypted( &len, 1 );
  413. if( len )
  414. klient->sendeEncrypted( key->getText(), len );
  415. klient->setEmpfangKey( *key, len );
  416. klient->setSendeKey( *key, len );
  417. key->release();
  418. }
  419. else
  420. errorZuKlient( "Es konnte kein Schlüssel ermittelt werden." );
  421. }
  422. else
  423. {
  424. klient->sende( "\1", 1 );
  425. klient->sende( (char*)&klientNummer, 4 );
  426. }
  427. ret1 = 1;
  428. }
  429. if( !ms->zDB()->proveRegisteredClient( klientNummer ) )
  430. errorZuKlient( "Deine Client Nummer ist nicht aktiv!\0" );
  431. else if( !ret1 )
  432. {
  433. if( encrypted )
  434. {
  435. Text *key = ms->zDB()->getKlientKey( klientNummer );
  436. if( !key )
  437. errorZuKlient( "Es konnte kein Schlüssel ermittelt werden." );
  438. else
  439. {
  440. klient->sendeEncrypted( "\1", 1 );
  441. klient->setEmpfangKey( *key, key->getLength() );
  442. klient->setSendeKey( *key, key->getLength() );
  443. key->release();
  444. }
  445. }
  446. else
  447. klient->sende( "\1", 1 );
  448. }
  449. }
  450. break;
  451. case 3: // Verbindungsende
  452. br = 1;
  453. if( encrypted )
  454. klient->sendeEncrypted( "\1", 1 );
  455. else
  456. klient->sende( "\1", 1 );
  457. break;
  458. case 6: // frage nach Server
  459. if( 1 )
  460. {
  461. char serverTyp = 0;
  462. if( encrypted )
  463. klient->getNachrichtEncrypted( &serverTyp, 1 );
  464. else
  465. klient->getNachricht( &serverTyp, 1 );
  466. switch( serverTyp )
  467. {
  468. case 1: // Register Server
  469. if( klientNummer )
  470. {
  471. int sNum = ms->zDB()->suchRegisterServer( klientNummer );
  472. if( sNum )
  473. {
  474. unsigned char *msg = ms->zDB()->getRegisterServerPortIp( sNum );
  475. if( msg )
  476. {
  477. if( encrypted )
  478. {
  479. klient->sendeEncrypted( "\2", 1 );
  480. klient->sendeEncrypted( (char*)msg, 6 );
  481. }
  482. else
  483. {
  484. klient->sende( "\2", 1 );
  485. klient->sende( (char*)msg, 6 );
  486. }
  487. }
  488. else
  489. errorZuKlient( "Aufgrund eines unerwarteten Fehlers konnte dir kein\nRegistrierungsserver zugewiesen werden!\0" );
  490. delete[]msg;
  491. }
  492. else
  493. errorZuKlient( "Der Server ist derzeit ausgelastet!\0" );
  494. }
  495. else
  496. errorZuKlient( "Du besitzt noch keine Client Nummer!\0" );
  497. break;
  498. case 2: // Patch Server
  499. if( klientNummer )
  500. {
  501. int sNum = ms->zDB()->suchPatchServer( klientNummer );
  502. if( sNum )
  503. {
  504. unsigned char *msg = ms->zDB()->getPatchServerPortIp( sNum );
  505. if( msg )
  506. {
  507. if( encrypted )
  508. {
  509. klient->sendeEncrypted( "\2", 1 );
  510. klient->sendeEncrypted( (char*)msg, 6 );
  511. }
  512. else
  513. {
  514. klient->sende( "\2", 1 );
  515. klient->sende( (char*)msg, 6 );
  516. }
  517. }
  518. else
  519. errorZuKlient( "Aufgrund eines unerwarteten Fehlers konnte dir kein\nPatchserver zugewiesen werden!\0" );
  520. delete[]msg;
  521. }
  522. else
  523. errorZuKlient( "Der Server ist derzeit ausgelastet!\0" );
  524. }
  525. else
  526. errorZuKlient( "Du besitzt noch keine Client Nummer!\0" );
  527. break;
  528. case 3: // Login Server
  529. if( klientNummer )
  530. {
  531. int sNum = ms->zDB()->suchLoginServer( klientNummer );
  532. if( sNum )
  533. {
  534. unsigned char *msg = ms->zDB()->getLoginServerPortIp( sNum );
  535. if( msg )
  536. {
  537. if( encrypted )
  538. {
  539. klient->sendeEncrypted( "\2", 1 );
  540. klient->sendeEncrypted( (char*)msg, 6 );
  541. }
  542. else
  543. {
  544. klient->sende( "\2", 1 );
  545. klient->sende( (char*)msg, 6 );
  546. }
  547. }
  548. else
  549. errorZuKlient( "Aufgrund eines unerwarteten Fehlers konnte dir kein\nLoginserver zugewiesen werden!\0" );
  550. delete[]msg;
  551. }
  552. else
  553. errorZuKlient( "Der Server ist derzeit ausgelastet!\0" );
  554. }
  555. else
  556. errorZuKlient( "Du besitzt noch keine Client Nummer!\0" );
  557. break;
  558. case 4: // Informations Server
  559. if( klientNummer )
  560. {
  561. int sNum = ms->zDB()->suchInformationServer( klientNummer );
  562. if( sNum )
  563. {
  564. unsigned char *msg = ms->zDB()->getInformationServerPortIp( sNum );
  565. if( msg )
  566. {
  567. if( encrypted )
  568. {
  569. klient->sendeEncrypted( "\2", 1 );
  570. klient->sendeEncrypted( (char*)msg, 6 );
  571. }
  572. else
  573. {
  574. klient->sende( "\2", 1 );
  575. klient->sende( (char*)msg, 6 );
  576. }
  577. }
  578. else
  579. errorZuKlient( "Aufgrund eines unerwarteten Fehlers konnte dir kein\nInformationserver zugewiesen werden!\0" );
  580. delete[]msg;
  581. }
  582. else
  583. errorZuKlient( "Der Server ist derzeit ausgelastet!\0" );
  584. }
  585. else
  586. errorZuKlient( "Du besitzt noch keine Client Nummer!\0" );
  587. break;
  588. case 5: // Chat Server
  589. if( klientNummer )
  590. {
  591. int sNum = ms->zDB()->suchChatServer( klientNummer );
  592. if( sNum )
  593. {
  594. unsigned char *msg = ms->zDB()->getChatServerPortIp( sNum );
  595. if( msg )
  596. {
  597. if( encrypted )
  598. {
  599. klient->sendeEncrypted( "\2", 1 );
  600. klient->sendeEncrypted( (char*)msg, 6 );
  601. }
  602. else
  603. {
  604. klient->sende( "\2", 1 );
  605. klient->sende( (char*)msg, 6 );
  606. }
  607. }
  608. else
  609. errorZuKlient( "Aufgrund eines unerwarteten Fehlers konnte dir kein\nChatserver zugewiesen werden!\0" );
  610. delete[]msg;
  611. }
  612. else
  613. errorZuKlient( "Der Server ist derzeit ausgelastet!\0" );
  614. }
  615. else
  616. errorZuKlient( "Du besitzt noch keine Client Nummer!\0" );
  617. break;
  618. case 6: // Anmeldung Server
  619. if( klientNummer )
  620. {
  621. int sNum = ms->zDB()->suchAnmeldungServer( klientNummer );
  622. if( sNum )
  623. {
  624. unsigned char *msg = ms->zDB()->getAnmeldungServerPortIp( sNum );
  625. if( msg )
  626. {
  627. if( encrypted )
  628. {
  629. klient->sendeEncrypted( "\2", 1 );
  630. klient->sendeEncrypted( (char*)msg, 6 );
  631. }
  632. else
  633. {
  634. klient->sende( "\2", 1 );
  635. klient->sende( (char*)msg, 6 );
  636. }
  637. }
  638. else
  639. errorZuKlient( "Aufgrund eines unerwarteten Fehlers konnte dir kein\nAnmeldungserver zugewiesen werden!\0" );
  640. delete[]msg;
  641. }
  642. else
  643. errorZuKlient( "Der Server ist derzeit ausgelastet!\0" );
  644. }
  645. else
  646. errorZuKlient( "Du besitzt noch keine Client Nummer!\0" );
  647. break;
  648. case 7: // Shop Server
  649. if( klientNummer )
  650. {
  651. int sNum = ms->zDB()->suchShopServer( klientNummer );
  652. if( sNum )
  653. {
  654. unsigned char *msg = ms->zDB()->getShopServerPortIp( sNum );
  655. if( msg )
  656. {
  657. if( encrypted )
  658. {
  659. klient->sendeEncrypted( "\2", 1 );
  660. klient->sendeEncrypted( (char*)msg, 6 );
  661. }
  662. else
  663. {
  664. klient->sende( "\2", 1 );
  665. klient->sende( (char*)msg, 6 );
  666. }
  667. }
  668. else
  669. errorZuKlient( "Aufgrund eines unerwarteten Fehlers konnte dir kein\nShopserver zugewiesen werden!\0" );
  670. delete[]msg;
  671. }
  672. else
  673. errorZuKlient( "Der Server ist derzeit ausgelastet!\0" );
  674. }
  675. else
  676. errorZuKlient( "Du besitzt noch keine Client Nummer!\0" );
  677. break;
  678. case 8: // Erhaltung Server
  679. if( klientNummer )
  680. {
  681. int sNum = ms->zDB()->suchErhaltungServer( klientNummer );
  682. if( sNum )
  683. {
  684. unsigned char *msg = ms->zDB()->getErhaltungServerPortIp( sNum );
  685. if( msg )
  686. {
  687. if( encrypted )
  688. {
  689. klient->sendeEncrypted( "\2", 1 );
  690. klient->sendeEncrypted( (char*)msg, 6 );
  691. }
  692. else
  693. {
  694. klient->sende( "\2", 1 );
  695. klient->sende( (char*)msg, 6 );
  696. }
  697. }
  698. else
  699. errorZuKlient( "Aufgrund eines unerwarteten Fehlers konnte dir kein\nPatchserver zugewiesen werden!\0" );
  700. delete[]msg;
  701. }
  702. else
  703. errorZuKlient( "Der Server ist derzeit ausgelastet!\0" );
  704. }
  705. else
  706. errorZuKlient( "Du besitzt noch keine Client Nummer!\0" );
  707. break;
  708. case 9: // News Server
  709. if( klientNummer )
  710. {
  711. int sNum = ms->zDB()->suchNewsServer( klientNummer );
  712. if( sNum )
  713. {
  714. unsigned char *msg = ms->zDB()->getNewsServerPortIp( sNum );
  715. if( msg )
  716. {
  717. if( encrypted )
  718. {
  719. klient->sendeEncrypted( "\2", 1 );
  720. klient->sendeEncrypted( (char*)msg, 6 );
  721. }
  722. else
  723. {
  724. klient->sende( "\2", 1 );
  725. klient->sende( (char*)msg, 6 );
  726. }
  727. }
  728. else
  729. errorZuKlient( "Aufgrund eines unerwarteten Fehlers konnte dir kein\nNewsserver zugewiesen werden!\0" );
  730. delete[]msg;
  731. }
  732. else
  733. errorZuKlient( "Der Server ist derzeit ausgelastet!\0" );
  734. }
  735. else
  736. errorZuKlient( "Du besitzt noch keine Client Nummer!\0" );
  737. break;
  738. default:
  739. errorZuKlient( "Die Art des Servers ist nicht bekannt!\0" );
  740. break;
  741. }
  742. }
  743. break;
  744. case 7: // client unregistrierung
  745. if( klientNummer )
  746. {
  747. int accountId = ms->zDB()->clientistEingeloggt( klientNummer );
  748. if( accountId )
  749. {
  750. Array< int > *ret = new Array< int >();
  751. int anzahl = ms->zDB()->logoutKlient( klientNummer, ret );
  752. if( anzahl > 0 )
  753. {
  754. int jetzt = 0;
  755. int chAnz = ret->get( jetzt );
  756. jetzt++;
  757. for( int i = 0; i < chAnz; i++ )
  758. {
  759. int chatroomId = ret->get( jetzt );
  760. jetzt++;
  761. if( chatroomId )
  762. {
  763. MSGWeiterleitung *weiter = new MSGWeiterleitung( ms->getThis() );
  764. weiter->spielerLeavesChatroom( chatroomId, accountId );
  765. weiter->release();
  766. if( ret->get( jetzt ) )
  767. {
  768. MSGWeiterleitung *weiter = new MSGWeiterleitung( ms->getThis() );
  769. weiter->setChatroomAdmin( chatroomId, ms->zDB()->getChatroomAdmin( chatroomId ) );
  770. weiter->release();
  771. }
  772. jetzt++;
  773. }
  774. }
  775. if( ret->get( jetzt ) == 1 )
  776. {
  777. jetzt++;
  778. MSGWeiterleitung *weiter = new MSGWeiterleitung( ms->getThis() );
  779. weiter->spielErstelltAbbrechen( ret->get( jetzt ) );
  780. weiter->release();
  781. }
  782. jetzt++;
  783. if( ret->get( jetzt ) == 1 )
  784. {
  785. jetzt++;
  786. int gruppeId = ret->get( jetzt );
  787. MSGWeiterleitung *weiter = new MSGWeiterleitung( ms->getThis() );
  788. weiter->spielerLeavesGruppe( gruppeId, accountId );
  789. weiter->release();
  790. jetzt++;
  791. if( ret->get( jetzt ) )
  792. {
  793. MSGWeiterleitung *weiter = new MSGWeiterleitung( ms->getThis() );
  794. weiter->setGruppeAdmin( gruppeId, ms->zDB()->getGruppeAdmin( gruppeId ) );
  795. weiter->release();
  796. }
  797. }
  798. else if( ret->get( jetzt ) == 2 )
  799. {
  800. jetzt++;
  801. int gruppeId = ret->get( jetzt );
  802. MSGWeiterleitung *weiter = new MSGWeiterleitung( ms->getThis() );
  803. weiter->kickSpielerAusGruppe( gruppeId );
  804. weiter->release();
  805. }
  806. }
  807. }
  808. MSGWeiterleitung *weiter = new MSGWeiterleitung( ms->getThis() );
  809. weiter->patchServerKlientAbsturz( klientNummer );
  810. weiter->registerServerKlientAbsturz( klientNummer );
  811. weiter->loginServerKlientAbsturz( klientNummer );
  812. weiter->informationServerKlientAbsturz( klientNummer );
  813. weiter->chatServerKlientAbsturz( klientNummer );
  814. weiter->anmeldungServerKlientAbsturz( klientNummer );
  815. weiter->spielServerKlientAbsturz( klientNummer );
  816. weiter->shopServerKlientAbsturz( klientNummer );
  817. weiter->newsServerKlientAbsturz( klientNummer );
  818. weiter->historieServerKlientAbsturz( klientNummer );
  819. weiter->kartenServerKlientAbsturz( klientNummer );
  820. weiter->editorServerKlientAbsturz( klientNummer );
  821. weiter->release();
  822. int *treffer = ms->zDB()->unregisterClient( klientNummer );
  823. if( !treffer[ 12 ] )
  824. errorZuKlient( "Du bist nicht registriert!\0" );
  825. else
  826. {
  827. if( encrypted )
  828. klient->sendeEncrypted( "\1", 1 );
  829. else
  830. klient->sende( "\1", 1 );
  831. }
  832. delete[]treffer;
  833. }
  834. else
  835. errorZuKlient( "Du besitzt noch keine Client Nummer!\0" );
  836. break;
  837. default:
  838. errorZuKlient( "Unbekannte Nachricht!\0" );
  839. break;
  840. }
  841. if( br )
  842. break;
  843. ms->addEmpfangen( klient->getDownloadBytes( 1 ) );
  844. ms->addGesendet( klient->getUploadBytes( 1 ) );
  845. }
  846. }
  847. ms->addEmpfangen( klient->getDownloadBytes( 1 ) );
  848. ms->addGesendet( klient->getUploadBytes( 1 ) );
  849. delete this;
  850. }
  851. void MSKlient::errorZuKlient( const char *nachricht ) const // sendet eine Fehlernachricht zum Klient
  852. {
  853. if( encrypted )
  854. {
  855. klient->sendeEncrypted( "\3", 1 );
  856. char len = (char)textLength( nachricht );
  857. klient->sendeEncrypted( &len, 1 );
  858. klient->sendeEncrypted( nachricht, len );
  859. }
  860. else
  861. {
  862. klient->sende( "\3", 1 );
  863. char len = (char)textLength( nachricht );
  864. klient->sende( &len, 1 );
  865. klient->sende( nachricht, len );
  866. }
  867. }
  868. // Inhalt der MSGWeiterleitung Klasse aus LoginServer.h
  869. // Konstruktor
  870. MSGWeiterleitung::MSGWeiterleitung( MainServer *ms )
  871. {
  872. this->ms = ms;
  873. ref = 1;
  874. }
  875. // Destruktor
  876. MSGWeiterleitung::~MSGWeiterleitung()
  877. {
  878. ms->release();
  879. }
  880. // nicht constant
  881. bool MSGWeiterleitung::patchServerKlientAbsturz( int klientId )
  882. {
  883. Text *ip = new Text();
  884. int port = 0;
  885. if( !ms->zDB()->getPatchServer( klientId, ip, &port ) )
  886. {
  887. ip->release();
  888. return 0;
  889. }
  890. Klient *k = new Klient();
  891. unsigned char key[ 20 ] = { 102, 139, 140, 143, 52, 52, 194, 167, 97, 106, 23, 72, 170, 121, 213, 178, 28, 28, 124, 185 };
  892. k->setSendeKey( (char*)key, 20 );
  893. k->setEmpfangKey( (char*)key, 20 );
  894. k->verbinde( (unsigned short)port, ip->getText() );
  895. ip->release();
  896. char ret = 0;
  897. k->sende( "\0", 1 ); // Verkeyung aktivieren
  898. k->sendeEncrypted( "\2\2", 2 );
  899. k->sendeEncrypted( (char*)&klientId, 4 );
  900. k->getNachrichtEncrypted( &ret, 1 );
  901. bool erf = ret == 1;
  902. k->sendeEncrypted( "\3", 1 );
  903. k->getNachrichtEncrypted( &ret, 1 );
  904. ms->addEmpfangen( k->getDownloadBytes( 1 ) );
  905. ms->addGesendet( k->getUploadBytes( 1 ) );
  906. k->trenne();
  907. k->release();
  908. return erf;
  909. }
  910. bool MSGWeiterleitung::registerServerKlientAbsturz( int klientId )
  911. {
  912. Text *ip = new Text();
  913. int port = 0;
  914. if( !ms->zDB()->getRegisterServer( klientId, ip, &port ) )
  915. {
  916. ip->release();
  917. return 0;
  918. }
  919. Klient *k = new Klient();
  920. unsigned char key[ 20 ] = { 186, 186, 179, 126, 216, 207, 123, 154, 168, 149, 51, 221, 6, 193, 160, 141, 164, 126, 44, 242 };
  921. k->setSendeKey( (char*)key, 20 );
  922. k->setEmpfangKey( (char*)key, 20 );
  923. k->verbinde( (unsigned short)port, ip->getText() );
  924. ip->release();
  925. char ret = 0;
  926. k->sendeEncrypted( "\2\2", 2 );
  927. k->sendeEncrypted( (char*)&klientId, 4 );
  928. k->getNachrichtEncrypted( &ret, 1 );
  929. bool erf = ret == 1;
  930. k->sendeEncrypted( "\3", 1 );
  931. k->getNachrichtEncrypted( &ret, 1 );
  932. ms->addEmpfangen( k->getDownloadBytes( 1 ) );
  933. ms->addGesendet( k->getUploadBytes( 1 ) );
  934. k->trenne();
  935. k->release();
  936. return erf;
  937. }
  938. bool MSGWeiterleitung::loginServerKlientAbsturz( int klientId )
  939. {
  940. Text *ip = new Text();
  941. int port = 0;
  942. if( !ms->zDB()->getLoginServer( klientId, ip, &port ) )
  943. {
  944. ip->release();
  945. return 0;
  946. }
  947. Klient *k = new Klient();
  948. unsigned char key[ 20 ] = { 143, 166, 245, 235, 76, 75, 116, 80, 26, 178, 142, 176, 109, 53, 106, 222, 223, 55, 139, 111 };
  949. k->setSendeKey( (char*)key, 20 );
  950. k->setEmpfangKey( (char*)key, 20 );
  951. k->verbinde( (unsigned short)port, ip->getText() );
  952. ip->release();
  953. char ret = 0;
  954. k->sendeEncrypted( "\2\2", 2 );
  955. k->sendeEncrypted( (char*)&klientId, 4 );
  956. k->getNachrichtEncrypted( &ret, 1 );
  957. bool erf = ret == 1;
  958. k->sendeEncrypted( "\3", 1 );
  959. k->getNachrichtEncrypted( &ret, 1 );
  960. ms->addEmpfangen( k->getDownloadBytes( 1 ) );
  961. ms->addGesendet( k->getUploadBytes( 1 ) );
  962. k->trenne();
  963. k->release();
  964. return erf;
  965. }
  966. bool MSGWeiterleitung::informationServerKlientAbsturz( int klientId )
  967. {
  968. Text *ip = new Text();
  969. int port = 0;
  970. if( !ms->zDB()->getInformationServer( klientId, ip, &port ) )
  971. {
  972. ip->release();
  973. return 0;
  974. }
  975. Klient *k = new Klient();
  976. unsigned char key[ 20 ] = { 231, 246, 125, 32, 88, 172, 229, 223, 246, 138, 74, 64, 142, 245, 217, 218, 162, 62, 103, 50 };
  977. k->setSendeKey( (char*)key, 20 );
  978. k->setEmpfangKey( (char*)key, 20 );
  979. k->verbinde( (unsigned short)port, ip->getText() );
  980. ip->release();
  981. char ret = 0;
  982. k->sendeEncrypted( "\2\2", 2 );
  983. k->sendeEncrypted( (char*)&klientId, 4 );
  984. k->getNachrichtEncrypted( &ret, 1 );
  985. bool erf = ret == 1;
  986. k->sendeEncrypted( "\3", 1 );
  987. k->getNachrichtEncrypted( &ret, 1 );
  988. ms->addEmpfangen( k->getDownloadBytes( 1 ) );
  989. ms->addGesendet( k->getUploadBytes( 1 ) );
  990. k->trenne();
  991. k->release();
  992. return erf;
  993. }
  994. bool MSGWeiterleitung::chatServerKlientAbsturz( int klientId )
  995. {
  996. Text *ip = new Text();
  997. int port = 0;
  998. if( !ms->zDB()->getChatServer( klientId, ip, &port ) )
  999. {
  1000. ip->release();
  1001. return 0;
  1002. }
  1003. Klient *k = new Klient();
  1004. unsigned char key[ 20 ] = { 79, 20, 190, 133, 10, 175, 51, 96, 62, 1, 180, 194, 126, 50, 211, 154, 105, 227, 22, 101 };
  1005. k->setSendeKey( (char*)key, 20 );
  1006. k->setEmpfangKey( (char*)key, 20 );
  1007. k->verbinde( (unsigned short)port, ip->getText() );
  1008. ip->release();
  1009. char ret = 0;
  1010. k->sendeEncrypted( "\2\2", 2 );
  1011. k->sendeEncrypted( (char*)&klientId, 4 );
  1012. k->getNachrichtEncrypted( &ret, 1 );
  1013. bool erf = ret == 1;
  1014. k->sendeEncrypted( "\3", 1 );
  1015. k->getNachrichtEncrypted( &ret, 1 );
  1016. ms->addEmpfangen( k->getDownloadBytes( 1 ) );
  1017. ms->addGesendet( k->getUploadBytes( 1 ) );
  1018. k->trenne();
  1019. k->release();
  1020. return erf;
  1021. }
  1022. bool MSGWeiterleitung::anmeldungServerKlientAbsturz( int klientId )
  1023. {
  1024. Text *ip = new Text();
  1025. int port = 0;
  1026. if( !ms->zDB()->getAnmeldungServer( klientId, ip, &port ) )
  1027. {
  1028. ip->release();
  1029. return 0;
  1030. }
  1031. Klient *k = new Klient();
  1032. unsigned char key[ 20 ] = { 158, 10, 37, 155, 117, 58, 28, 197, 132, 76, 252, 83, 84, 222, 11, 125, 240, 218, 25, 201 };
  1033. k->setSendeKey( (char*)key, 20 );
  1034. k->setEmpfangKey( (char*)key, 20 );
  1035. k->verbinde( (unsigned short)port, ip->getText() );
  1036. ip->release();
  1037. char ret = 0;
  1038. k->sendeEncrypted( "\2\2", 2 );
  1039. k->sendeEncrypted( (char*)&klientId, 4 );
  1040. k->getNachrichtEncrypted( &ret, 1 );
  1041. bool erf = ret == 1;
  1042. k->sendeEncrypted( "\3", 1 );
  1043. k->getNachrichtEncrypted( &ret, 1 );
  1044. ms->addEmpfangen( k->getDownloadBytes( 1 ) );
  1045. ms->addGesendet( k->getUploadBytes( 1 ) );
  1046. k->trenne();
  1047. k->release();
  1048. return erf;
  1049. }
  1050. bool MSGWeiterleitung::spielServerKlientAbsturz( int klientId )
  1051. {
  1052. Text *ip = new Text();
  1053. int port = 0;
  1054. if( !ms->zDB()->getSpielServer( klientId, ip, &port ) )
  1055. {
  1056. ip->release();
  1057. return 0;
  1058. }
  1059. Klient *k = new Klient();
  1060. unsigned char key[ 20 ] = { 253, 234, 211, 132, 121, 230, 95, 145, 201, 13, 43, 77, 153, 223, 253, 69, 234, 43, 52, 99 };
  1061. k->setSendeKey( (char*)key, 20 );
  1062. k->setEmpfangKey( (char*)key, 20 );
  1063. k->verbinde( (unsigned short)port, ip->getText() );
  1064. ip->release();
  1065. char ret = 0;
  1066. k->sendeEncrypted( "\2\2", 2 );
  1067. k->sendeEncrypted( (char*)&klientId, 4 );
  1068. k->getNachrichtEncrypted( &ret, 1 );
  1069. bool erf = ret == 1;
  1070. k->sendeEncrypted( "\3", 1 );
  1071. k->getNachrichtEncrypted( &ret, 1 );
  1072. ms->addEmpfangen( k->getDownloadBytes( 1 ) );
  1073. ms->addGesendet( k->getUploadBytes( 1 ) );
  1074. k->trenne();
  1075. k->release();
  1076. return erf;
  1077. }
  1078. bool MSGWeiterleitung::shopServerKlientAbsturz( int klientId )
  1079. {
  1080. Text *ip = new Text();
  1081. int port = 0;
  1082. if( !ms->zDB()->getShopServer( klientId, ip, &port ) )
  1083. {
  1084. ip->release();
  1085. return 0;
  1086. }
  1087. Klient *k = new Klient();
  1088. unsigned char key[ 20 ] = { 218, 226, 231, 216, 68, 63, 132, 155, 49, 235, 239, 0, 19, 23, 116, 244, 235, 21, 189, 53 };
  1089. k->setSendeKey( (char*)key, 20 );
  1090. k->setEmpfangKey( (char*)key, 20 );
  1091. k->verbinde( (unsigned short)port, ip->getText() );
  1092. ip->release();
  1093. char ret = 0;
  1094. k->sendeEncrypted( "\2\2", 2 );
  1095. k->sendeEncrypted( (char*)&klientId, 4 );
  1096. k->getNachrichtEncrypted( &ret, 1 );
  1097. bool erf = ret == 1;
  1098. k->sendeEncrypted( "\3", 1 );
  1099. k->getNachrichtEncrypted( &ret, 1 );
  1100. ms->addEmpfangen( k->getDownloadBytes( 1 ) );
  1101. ms->addGesendet( k->getUploadBytes( 1 ) );
  1102. k->trenne();
  1103. k->release();
  1104. return erf;
  1105. }
  1106. bool MSGWeiterleitung::newsServerKlientAbsturz( int klientId )
  1107. {
  1108. Text *ip = new Text();
  1109. int port = 0;
  1110. if( !ms->zDB()->getNewsServer( klientId, ip, &port ) )
  1111. {
  1112. ip->release();
  1113. return 0;
  1114. }
  1115. Klient *k = new Klient();
  1116. unsigned char key[ 20 ] = { 4, 150, 243, 145, 204, 71, 253, 88, 4, 51, 189, 207, 189, 248, 231, 40, 106, 7, 182, 5 };
  1117. k->setSendeKey( (char*)key, 20 );
  1118. k->setEmpfangKey( (char*)key, 20 );
  1119. k->verbinde( (unsigned short)port, ip->getText() );
  1120. ip->release();
  1121. char ret = 0;
  1122. k->sendeEncrypted( "\2\2", 2 );
  1123. k->sendeEncrypted( (char*)&klientId, 4 );
  1124. k->getNachrichtEncrypted( &ret, 1 );
  1125. bool erf = ret == 1;
  1126. k->sendeEncrypted( "\3", 1 );
  1127. k->getNachrichtEncrypted( &ret, 1 );
  1128. ms->addEmpfangen( k->getDownloadBytes( 1 ) );
  1129. ms->addGesendet( k->getUploadBytes( 1 ) );
  1130. k->trenne();
  1131. k->release();
  1132. return erf;
  1133. }
  1134. bool MSGWeiterleitung::historieServerKlientAbsturz( int klientId )
  1135. {
  1136. Text *ip = new Text();
  1137. int port = 0;
  1138. if( !ms->zDB()->getHistorieServer( klientId, ip, &port ) )
  1139. {
  1140. ip->release();
  1141. return 0;
  1142. }
  1143. Klient *k = new Klient();
  1144. unsigned char key[ 20 ] = { 207, 30, 72, 46, 30, 50, 56, 213, 82, 107, 14, 201, 149, 58, 110, 138, 228, 241, 52, 54 };
  1145. k->setSendeKey( (char*)key, 20 );
  1146. k->setEmpfangKey( (char*)key, 20 );
  1147. k->verbinde( (unsigned short)port, ip->getText() );
  1148. ip->release();
  1149. char ret = 0;
  1150. k->sendeEncrypted( "\2\2", 2 );
  1151. k->sendeEncrypted( (char*)&klientId, 4 );
  1152. k->getNachrichtEncrypted( &ret, 1 );
  1153. bool erf = ret == 1;
  1154. k->sendeEncrypted( "\3", 1 );
  1155. k->getNachrichtEncrypted( &ret, 1 );
  1156. ms->addEmpfangen( k->getDownloadBytes( 1 ) );
  1157. ms->addGesendet( k->getUploadBytes( 1 ) );
  1158. k->trenne();
  1159. k->release();
  1160. return erf;
  1161. }
  1162. bool MSGWeiterleitung::kartenServerKlientAbsturz( int klientId )
  1163. {
  1164. Text *ip = new Text();
  1165. int port = 0;
  1166. if( !ms->zDB()->getKartenServer( klientId, ip, &port ) )
  1167. {
  1168. ip->release();
  1169. return 0;
  1170. }
  1171. Klient *k = new Klient();
  1172. unsigned char key[ 20 ] = { 24, 15, 53, 87, 38, 73, 154, 38, 246, 90, 39, 133, 11, 199, 22, 80, 26, 132, 95, 54 };
  1173. k->setSendeKey( (char*)key, 20 );
  1174. k->setEmpfangKey( (char*)key, 20 );
  1175. k->verbinde( (unsigned short)port, ip->getText() );
  1176. ip->release();
  1177. char ret = 0;
  1178. k->sendeEncrypted( "\2\2", 2 );
  1179. k->sendeEncrypted( (char*)&klientId, 4 );
  1180. k->getNachrichtEncrypted( &ret, 1 );
  1181. bool erf = ret == 1;
  1182. k->sendeEncrypted( "\3", 1 );
  1183. k->getNachrichtEncrypted( &ret, 1 );
  1184. ms->addEmpfangen( k->getDownloadBytes( 1 ) );
  1185. ms->addGesendet( k->getUploadBytes( 1 ) );
  1186. k->trenne();
  1187. k->release();
  1188. return erf;
  1189. }
  1190. bool MSGWeiterleitung::editorServerKlientAbsturz( int klientId )
  1191. {
  1192. Text *ip = new Text();
  1193. int port = 0;
  1194. if( !ms->zDB()->getEditorServer( klientId, ip, &port ) )
  1195. {
  1196. ip->release();
  1197. return 0;
  1198. }
  1199. Klient *k = new Klient();
  1200. unsigned char key[ 20 ] = { 55, 124, 19, 204, 23, 5, 59, 75, 247, 138, 119, 111, 57, 250, 206, 187, 165, 6, 247, 151 };
  1201. k->setSendeKey( (char*)key, 20 );
  1202. k->setEmpfangKey( (char*)key, 20 );
  1203. k->verbinde( (unsigned short)port, ip->getText() );
  1204. ip->release();
  1205. char ret = 0;
  1206. k->sendeEncrypted( "\2\2", 2 );
  1207. k->sendeEncrypted( (char*)&klientId, 4 );
  1208. k->getNachrichtEncrypted( &ret, 1 );
  1209. bool erf = ret == 1;
  1210. k->sendeEncrypted( "\3", 1 );
  1211. k->getNachrichtEncrypted( &ret, 1 );
  1212. ms->addEmpfangen( k->getDownloadBytes( 1 ) );
  1213. ms->addGesendet( k->getUploadBytes( 1 ) );
  1214. k->trenne();
  1215. k->release();
  1216. return erf;
  1217. }
  1218. bool MSGWeiterleitung::spielErstelltAbbrechen( int spielErstelltId )
  1219. {
  1220. bool ret = 1;
  1221. Text *ip = new Text( "" );
  1222. unsigned short port = 0;
  1223. ret = ret & ms->zDB()->getSpielServerPortIp( spielErstelltId, &port, ip );
  1224. if( ip->getLength() )
  1225. {
  1226. Klient *klient = new Klient();
  1227. unsigned char key[ 20 ] = { 253, 234, 211, 132, 121, 230, 95, 145, 201, 13, 43, 77, 153, 223, 253, 69, 234, 43, 52, 99 };
  1228. klient->setSendeKey( (char*)key, 20 );
  1229. klient->setEmpfangKey( (char*)key, 20 );
  1230. ret = ret & klient->verbinde( port, ip->getText() );
  1231. ret = ret & klient->sendeEncrypted( "\x8\x1", 2 );
  1232. char res = 0;
  1233. ret = ret & klient->getNachrichtEncrypted( &res, 1 );
  1234. if( res )
  1235. {
  1236. ret = ret & klient->sendeEncrypted( (char*)&spielErstelltId, 4 );
  1237. ret = ret & klient->getNachrichtEncrypted( &res, 1 );
  1238. }
  1239. ret = (char)ret & res;
  1240. ret = ret & klient->sendeEncrypted( "\x8\x0", 2 );
  1241. ret = ret & klient->getNachrichtEncrypted( &res, 1 );
  1242. ret = (char)ret & res;
  1243. ms->addEmpfangen( klient->getDownloadBytes( 1 ) );
  1244. ms->addGesendet( klient->getUploadBytes( 1 ) );
  1245. klient->trenne();
  1246. klient = klient->release();
  1247. ip->release();
  1248. }
  1249. return ret;
  1250. }
  1251. bool MSGWeiterleitung::spielerLeavesGruppe( int gruppeId, int accountId )
  1252. {
  1253. bool ret = 1;
  1254. Array< int > *accId = new Array< int >();
  1255. int anzahl = ms->zDB()->getSpielerAusGruppe( gruppeId, accId );
  1256. for( int i = 0; i < anzahl; i++ )
  1257. {
  1258. int account = accId->get( i );
  1259. if( account == accountId )
  1260. continue;
  1261. Text *ip = new Text( "" );
  1262. unsigned short port = 0;
  1263. ret = ret & ms->zDB()->getChatServerPortIp( account, &port, ip );
  1264. if( ip->getLength() )
  1265. {
  1266. Klient *klient = new Klient();
  1267. unsigned char key[ 20 ] = { 79, 20, 190, 133, 10, 175, 51, 96, 62, 1, 180, 194, 126, 50, 211, 154, 105, 227, 22, 101 };
  1268. klient->setSendeKey( (char*)key, 20 );
  1269. klient->setEmpfangKey( (char*)key, 20 );
  1270. ret = ret & klient->verbinde( port, ip->getText() );
  1271. ret = ret & klient->sendeEncrypted( "\5\x15", 2 );
  1272. char res = 0;
  1273. ret = ret & klient->getNachrichtEncrypted( &res, 1 );
  1274. if( res )
  1275. {
  1276. ret = ret & klient->sendeEncrypted( (char*)&account, 4 );
  1277. ret = ret & klient->sendeEncrypted( (char*)&accountId, 4 );
  1278. ret = ret & klient->sendeEncrypted( (char*)&gruppeId, 4 );
  1279. ret = ret & klient->getNachrichtEncrypted( &res, 1 );
  1280. }
  1281. ret = (char)ret & res;
  1282. ret = ret & klient->sendeEncrypted( "\5\x18", 2 );
  1283. res = 0;
  1284. ret = ret & klient->getNachrichtEncrypted( &res, 1 );
  1285. if( res )
  1286. {
  1287. ret = ret & klient->sendeEncrypted( (char*)&account, 4 );
  1288. ret = ret & klient->sendeEncrypted( (char*)&gruppeId, 4 );
  1289. ret = ret & klient->getNachrichtEncrypted( &res, 1 );
  1290. }
  1291. ret = (char)ret & res;
  1292. ms->addEmpfangen( klient->getDownloadBytes( 1 ) );
  1293. ms->addGesendet( klient->getUploadBytes( 1 ) );
  1294. klient->trenne();
  1295. klient = klient->release();
  1296. }
  1297. ip->release();
  1298. }
  1299. accId->release();
  1300. return ret;
  1301. }
  1302. bool MSGWeiterleitung::setGruppeAdmin( int gruppeId, int adminId )
  1303. {
  1304. if( !adminId || !gruppeId )
  1305. return 0;
  1306. bool ret = 1;
  1307. Array< int > *accId = new Array< int >();
  1308. int anzahl = ms->zDB()->getSpielerAusGruppe( gruppeId, accId );
  1309. for( int i = 0; i < anzahl; i++ )
  1310. {
  1311. int account = accId->get( i );
  1312. Text *ip = new Text( "" );
  1313. unsigned short port = 0;
  1314. ret = ret & ms->zDB()->getChatServerPortIp( account, &port, ip );
  1315. if( ip->getLength() )
  1316. {
  1317. Klient *klient = new Klient();
  1318. unsigned char key[ 20 ] = { 79, 20, 190, 133, 10, 175, 51, 96, 62, 1, 180, 194, 126, 50, 211, 154, 105, 227, 22, 101 };
  1319. klient->setSendeKey( (char*)key, 20 );
  1320. klient->setEmpfangKey( (char*)key, 20 );
  1321. ret = ret & klient->verbinde( port, ip->getText() );
  1322. ret = ret & klient->sendeEncrypted( "\5\x1B", 2 );
  1323. char res = 0;
  1324. ret = ret & klient->getNachrichtEncrypted( &res, 1 );
  1325. if( res )
  1326. {
  1327. ret = ret & klient->sendeEncrypted( (char*)&account, 4 );
  1328. ret = ret & klient->sendeEncrypted( (char*)&adminId, 4 );
  1329. ret = ret & klient->sendeEncrypted( (char*)&gruppeId, 4 );
  1330. ret = ret & klient->getNachrichtEncrypted( &res, 1 );
  1331. }
  1332. ret = (char)ret & res;
  1333. ms->addEmpfangen( klient->getDownloadBytes( 1 ) );
  1334. ms->addGesendet( klient->getUploadBytes( 1 ) );
  1335. klient->trenne();
  1336. klient = klient->release();
  1337. }
  1338. ip->release();
  1339. }
  1340. accId->release();
  1341. return ret;
  1342. }
  1343. bool MSGWeiterleitung::spielerLeavesChatroom( int chatroomId, int accountId )
  1344. {
  1345. bool ret = 1;
  1346. Array< int > *accId = new Array< int >();
  1347. int anzahl = ms->zDB()->getSpielerAusChatroom( chatroomId, accId );
  1348. for( int i = 0; i < anzahl; i++ )
  1349. {
  1350. int account = accId->get( i );
  1351. if( account == accountId )
  1352. continue;
  1353. Text *ip = new Text( "" );
  1354. unsigned short port = 0;
  1355. ret = ret & ms->zDB()->getChatServerPortIp( account, &port, ip );
  1356. if( ip->getLength() )
  1357. {
  1358. Klient *klient = new Klient();
  1359. unsigned char key[ 20 ] = { 79, 20, 190, 133, 10, 175, 51, 96, 62, 1, 180, 194, 126, 50, 211, 154, 105, 227, 22, 101 };
  1360. klient->setSendeKey( (char*)key, 20 );
  1361. klient->setEmpfangKey( (char*)key, 20 );
  1362. ret = ret & klient->verbinde( port, ip->getText() );
  1363. ret = ret & klient->sendeEncrypted( "\5\xE", 2 );
  1364. char res = 0;
  1365. ret = ret & klient->getNachrichtEncrypted( &res, 1 );
  1366. if( res )
  1367. {
  1368. ret = ret & klient->sendeEncrypted( (char*)&accountId, 4 );
  1369. ret = ret & klient->sendeEncrypted( (char*)&account, 4 );
  1370. ret = ret & klient->sendeEncrypted( (char*)&chatroomId, 4 );
  1371. ret = ret & klient->getNachrichtEncrypted( &res, 1 );
  1372. }
  1373. ret = (char)ret & res;
  1374. ms->addEmpfangen( klient->getDownloadBytes( 1 ) );
  1375. ms->addGesendet( klient->getUploadBytes( 1 ) );
  1376. klient->trenne();
  1377. klient = klient->release();
  1378. }
  1379. ip->release();
  1380. }
  1381. accId->release();
  1382. return ret;
  1383. }
  1384. bool MSGWeiterleitung::setChatroomAdmin( int chatroomId, int adminId )
  1385. {
  1386. if( !adminId || !chatroomId )
  1387. return 0;
  1388. bool ret = 1;
  1389. Text *ip = new Text( "" );
  1390. unsigned short port = 0;
  1391. ret = ret & ms->zDB()->getChatServerPortIp( adminId, &port, ip );
  1392. if( ip->getLength() )
  1393. {
  1394. Klient *klient = new Klient();
  1395. unsigned char key[ 20 ] = { 79, 20, 190, 133, 10, 175, 51, 96, 62, 1, 180, 194, 126, 50, 211, 154, 105, 227, 22, 101 };
  1396. klient->setSendeKey( (char*)key, 20 );
  1397. klient->setEmpfangKey( (char*)key, 20 );
  1398. ret = ret & klient->verbinde( port, ip->getText() );
  1399. ret = ret & klient->sendeEncrypted( "\5\x12", 2 );
  1400. char res = 0;
  1401. ret = ret & klient->getNachrichtEncrypted( &res, 1 );
  1402. if( res )
  1403. {
  1404. ret = ret & klient->sendeEncrypted( (char*)&adminId, 4 );
  1405. ret = ret & klient->sendeEncrypted( (char*)&chatroomId, 4 );
  1406. ret = ret & klient->getNachrichtEncrypted( &res, 1 );
  1407. }
  1408. ret = (char)ret & res;
  1409. ms->addEmpfangen( klient->getDownloadBytes( 1 ) );
  1410. ms->addGesendet( klient->getUploadBytes( 1 ) );
  1411. klient->trenne();
  1412. klient = klient->release();
  1413. }
  1414. ip->release();
  1415. return ret;
  1416. }
  1417. bool MSGWeiterleitung::kickSpielerAusGruppe( int gruppeId )
  1418. {
  1419. if( !gruppeId )
  1420. return 0;
  1421. bool ret = 1;
  1422. Array< int > *accId = new Array< int >();
  1423. int anzahl = ms->zDB()->getSpielerAusGruppe( gruppeId, accId );
  1424. for( int i = 0; i < anzahl; i++ )
  1425. {
  1426. int account = accId->get( i );
  1427. Text *ip = new Text( "" );
  1428. unsigned short port = 0;
  1429. ret = ret & ms->zDB()->getChatServerPortIp( account, &port, ip );
  1430. if( ip->getLength() )
  1431. {
  1432. Klient *klient = new Klient();
  1433. unsigned char key[ 20 ] = { 79, 20, 190, 133, 10, 175, 51, 96, 62, 1, 180, 194, 126, 50, 211, 154, 105, 227, 22, 101 };
  1434. klient->setSendeKey( (char*)key, 20 );
  1435. klient->setEmpfangKey( (char*)key, 20 );
  1436. ret = ret & klient->verbinde( port, ip->getText() );
  1437. ret = ret & klient->sendeEncrypted( "\5\x16", 2 );
  1438. char res = 0;
  1439. ret = ret & klient->getNachrichtEncrypted( &res, 1 );
  1440. if( res )
  1441. {
  1442. ret = ret & klient->sendeEncrypted( (char*)&account, 4 );
  1443. ret = ret & klient->sendeEncrypted( (char*)&gruppeId, 4 );
  1444. ret = ret & klient->getNachrichtEncrypted( &res, 1 );
  1445. }
  1446. ret = (char)ret & res;
  1447. ms->addEmpfangen( klient->getDownloadBytes( 1 ) );
  1448. ms->addGesendet( klient->getUploadBytes( 1 ) );
  1449. klient->trenne();
  1450. klient = klient->release();
  1451. }
  1452. ms->zDB()->kickSpielerAusGruppe( gruppeId, account );
  1453. ip->release();
  1454. }
  1455. accId->release();
  1456. return ret;
  1457. }
  1458. // constant
  1459. // Reference Counting
  1460. MSGWeiterleitung *MSGWeiterleitung::getThis()
  1461. {
  1462. ref++;
  1463. return this;
  1464. }
  1465. MSGWeiterleitung *MSGWeiterleitung::release()
  1466. {
  1467. ref--;
  1468. if( !ref )
  1469. delete this;
  1470. return 0;
  1471. }