KartenServer.cpp 24 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062
  1. #include "KartenServer.h"
  2. #include <iostream>
  3. #include <Klient.h>
  4. #include <Globals.h>
  5. // Inhalt der KartenServer Klasse aus KartenServer.h
  6. // Konstruktor
  7. KartenServer::KartenServer(InitDatei* zIni)
  8. : Thread()
  9. {
  10. Network::Start(100);
  11. std::cout << "KS: Verbindung mit Datenbank wird hergestellt...\n";
  12. db = new KSDatenbank(zIni);
  13. klients = new RCArray< KSKlient >();
  14. empfangen = 0;
  15. gesendet = 0;
  16. fehler = new Text();
  17. ini = dynamic_cast<InitDatei*>(zIni->getThis());
  18. id = (int)*zIni->zWert("ServerId");
  19. server = new Server();
  20. aServer = new SSLServer();
  21. aServer->setPrivateKeyPassword(zIni->zWert("SSLPasswort")->getText());
  22. aServer->setCertificateFile(zIni->zWert("SSLCert")->getText());
  23. aServer->setPrivateKeyFile(zIni->zWert("SSLKey")->getText());
  24. std::cout << "KS: Starten des Admin Servers...\n";
  25. if (!aServer->verbinde((unsigned short)TextZuInt(ini->zWert("AdminServerPort")->getText(), 10), 10))
  26. {
  27. std::cout << "KS: Der Admin Server konnte nicht gestartet werden. Das Programm wird beendet.\n";
  28. exit(1);
  29. }
  30. db->setServerStatus(id, 2);
  31. end = 0;
  32. nichtPausiert = 0;
  33. updateKarte = 0;
  34. InitializeCriticalSection(&cs);
  35. if (zIni->zWert("Aktiv")->istGleich("TRUE"))
  36. {
  37. serverStarten();
  38. serverFortsetzen();
  39. }
  40. updater = new Updater(dynamic_cast<KartenServer*>(getThis()));
  41. }
  42. // Destruktor
  43. KartenServer::~KartenServer()
  44. {
  45. updater->release();
  46. fehler->release();
  47. server->trenne();
  48. server->release();
  49. aServer->trenne();
  50. aServer->release();
  51. if (klients)
  52. klients->release();
  53. ini->release();
  54. db->release();
  55. DeleteCriticalSection(&cs);
  56. }
  57. // nicht constant
  58. void KartenServer::runn()
  59. {
  60. while (!end && aServer->isConnected())
  61. {
  62. SSLSKlient* klient;
  63. klient = aServer->getKlient();
  64. if (end && klient)
  65. {
  66. klient->trenne();
  67. klient = (SSLSKlient*)klient->release();
  68. Sleep(1000);
  69. return;
  70. }
  71. if (!klient)
  72. continue;
  73. KSAKlient* clHandle = new KSAKlient(klient, dynamic_cast<KartenServer*>(getThis()));
  74. clHandle->start();
  75. }
  76. }
  77. void KartenServer::thread()
  78. {
  79. while (server->isConnected())
  80. {
  81. SKlient* klient;
  82. klient = server->getKlient();
  83. if (!klient)
  84. continue;
  85. Framework::getThreadRegister()->cleanUpClosedThreads();
  86. KSKlient* clHandle = new KSKlient(klient, dynamic_cast<KartenServer*>(getThis()));
  87. EnterCriticalSection(&cs);
  88. klients->add(clHandle);
  89. LeaveCriticalSection(&cs);
  90. clHandle->start();
  91. }
  92. }
  93. void KartenServer::close()
  94. {
  95. db->setServerStatus(id, 1);
  96. server->trenne();
  97. #ifdef WIN32
  98. warteAufThread(1000);
  99. #endif
  100. EnterCriticalSection(&cs);
  101. for (int i = 0; i < klients->getEintragAnzahl(); i++)
  102. klients->z(i)->absturz();
  103. klients = (RCArray < KSKlient > *)klients->release();
  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 KartenServer::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 KartenServer::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 KartenServer::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 KartenServer::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 KartenServer::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 KartenServer::absturzKlient(int klientId)
  197. {
  198. bool gefunden = 0;
  199. EnterCriticalSection(&cs);
  200. for (int i = 0; i < klients->getEintragAnzahl(); i++)
  201. {
  202. if (klients->z(i)->getKlientNummer() == klientId)
  203. {
  204. klients->z(i)->absturz();
  205. klients->remove(i);
  206. gefunden = 1;
  207. break;
  208. }
  209. }
  210. LeaveCriticalSection(&cs);
  211. return gefunden;
  212. }
  213. bool KartenServer::removeKlient(KSKlient* zKlient)
  214. {
  215. bool gefunden = 0;
  216. EnterCriticalSection(&cs);
  217. for (int i = 0; i < klients->getEintragAnzahl(); i++)
  218. {
  219. if (klients->z(i) == zKlient)
  220. {
  221. klients->remove(i);
  222. gefunden = 1;
  223. break;
  224. }
  225. }
  226. LeaveCriticalSection(&cs);
  227. return gefunden;
  228. }
  229. void KartenServer::addGesendet(int bytes)
  230. {
  231. gesendet += bytes;
  232. }
  233. void KartenServer::addEmpfangen(int bytes)
  234. {
  235. empfangen += bytes;
  236. }
  237. void KartenServer::karteUpdateStart(int karteId)
  238. {
  239. updateKarte = karteId;
  240. }
  241. void KartenServer::karteUpdateEnde()
  242. {
  243. updateKarte = 0;
  244. }
  245. // constant
  246. bool KartenServer::istAn() const
  247. {
  248. return db->serverIstNichtPausiert(id);
  249. }
  250. Server* KartenServer::zServer() const
  251. {
  252. return server;
  253. }
  254. KSDatenbank* KartenServer::zDB() const
  255. {
  256. return db;
  257. }
  258. InitDatei* KartenServer::zIni() const
  259. {
  260. return ini;
  261. }
  262. bool KartenServer::hatClients() const
  263. {
  264. return klients->hat(0);
  265. }
  266. int KartenServer::getId() const
  267. {
  268. return id;
  269. }
  270. const char* KartenServer::getLetzterFehler() const
  271. {
  272. return fehler->getText();
  273. }
  274. bool KartenServer::wirdKarteGeupdatet(int id) const
  275. {
  276. return id == updateKarte;
  277. }
  278. // Inhalt der KSAKlient Klasse aus KartenServer.h
  279. // Konstruktor
  280. KSAKlient::KSAKlient(SSLSKlient* klient, KartenServer* ks)
  281. : Thread()
  282. {
  283. this->klient = klient;
  284. name = new Text("");
  285. passwort = new Text("");
  286. adminId = 0;
  287. this->ks = ks;
  288. }
  289. // Destruktor
  290. KSAKlient::~KSAKlient()
  291. {
  292. klient->trenne();
  293. klient->release();
  294. ks->release();
  295. name->release();
  296. passwort->release();
  297. }
  298. // nicht constant
  299. void KSAKlient::thread()
  300. {
  301. while (1)
  302. {
  303. char c = 0;
  304. if (!klient->getNachricht(&c, 1))
  305. break;
  306. else
  307. {
  308. bool br = 0;
  309. switch (c)
  310. {
  311. case 1: // Login
  312. if (1)
  313. {
  314. klient->sende("\1", 1);
  315. unsigned char nLen = 0;
  316. klient->getNachricht((char*)&nLen, 1);
  317. char* n = new char[nLen + 1];
  318. n[(int)nLen] = 0;
  319. if (nLen)
  320. klient->getNachricht(n, nLen);
  321. unsigned char pLen = 0;
  322. klient->getNachricht((char*)&pLen, 1);
  323. char* p = new char[pLen + 1];
  324. p[(int)pLen] = 0;
  325. if (pLen)
  326. klient->getNachricht(p, pLen);
  327. int adminId = ks->zDB()->istAdministrator(n, p);
  328. if (adminId)
  329. {
  330. klient->sende("\1", 1);
  331. name->setText(n);
  332. passwort->setText(p);
  333. this->adminId = adminId;
  334. }
  335. else
  336. errorZuKlient("Falsche Kombination aus Name und Passwort.");
  337. delete[] n;
  338. delete[] p;
  339. }
  340. break;
  341. case 2: // Logout
  342. adminId = 0;
  343. name->setText("");
  344. passwort->setText("");
  345. klient->sende("\1", 1);
  346. break;
  347. case 3: // Trennen
  348. br = 1;
  349. klient->sende("\1", 1);
  350. break;
  351. case 4: // Server starten
  352. if (!adminId)
  353. errorZuKlient("Du musst dich einloggen.");
  354. else
  355. {
  356. if (ks->zDB()->adminHatRecht(adminId, Admin_Recht::KSStarten))
  357. {
  358. if (!ks->serverStarten())
  359. {
  360. Text* err = new Text();
  361. err->append(ks->getLetzterFehler());
  362. errorZuKlient(err->getText());
  363. err->release();
  364. }
  365. else
  366. klient->sende("\1", 1);
  367. }
  368. else
  369. errorZuKlient("Du bist nicht berechtigt den Server zu starten.");
  370. }
  371. break;
  372. case 5: // Server beenden
  373. if (!adminId)
  374. errorZuKlient("Du musst dich einloggen.");
  375. else
  376. {
  377. if (ks->zDB()->adminHatRecht(adminId, Admin_Recht::KSBeenden))
  378. {
  379. if (ks->serverBeenden())
  380. klient->sende("\1", 1);
  381. else
  382. {
  383. Text* err = new Text();
  384. err->append(ks->getLetzterFehler());
  385. errorZuKlient(err->getText());
  386. err->release();
  387. }
  388. }
  389. else
  390. errorZuKlient("Du bist nicht berechtigt den Server zu beenden.");
  391. }
  392. break;
  393. case 6: // Programm Schließen
  394. if (!adminId)
  395. errorZuKlient("Du musst dich einloggen.");
  396. else
  397. {
  398. bool ok = 0;
  399. if (ks->isRunning())
  400. {
  401. if (ks->zDB()->adminHatRecht(adminId, Admin_Recht::KSBeenden))
  402. {
  403. if (ks->serverBeenden())
  404. ok = 1;
  405. else
  406. {
  407. Text* err = new Text();
  408. err->append(ks->getLetzterFehler());
  409. errorZuKlient(err->getText());
  410. err->release();
  411. }
  412. }
  413. else
  414. errorZuKlient("Du bist nicht berechtigt den Server zu beenden.");
  415. }
  416. else
  417. ok = 1;
  418. if (ok && ks->hatClients())
  419. {
  420. errorZuKlient("Es sind noch Klients Online. Bitte versuche es später erneut.");
  421. break;
  422. }
  423. if (ok)
  424. {
  425. klient->sende("\1", 1);
  426. std::cout << "KS: Der Server wird von Benutzer " << adminId << " heruntergefahren.\n";
  427. ks->close();
  428. br = 1;
  429. }
  430. }
  431. break;
  432. case 7: // Progtamm abstürzen
  433. if (!adminId)
  434. errorZuKlient("Du musst dich einloggen.");
  435. else
  436. {
  437. bool ok = 0;
  438. if (ks->isRunning())
  439. {
  440. if (ks->zDB()->adminHatRecht(adminId, Admin_Recht::KSBeenden))
  441. {
  442. ks->serverBeenden();
  443. ok = 1;
  444. }
  445. else
  446. errorZuKlient("Du bist nicht berechtigt den Server zu beenden.");
  447. }
  448. else
  449. ok = 1;
  450. if (ok)
  451. {
  452. klient->sende("\1", 1);
  453. std::cout << "KS: Der Server wurde von Benutzer " << adminId << " terminiert.\n";
  454. ks->close();
  455. br = 1;
  456. }
  457. }
  458. break;
  459. case 8: // Status Frage
  460. if (1)
  461. {
  462. char status = 0;
  463. if (ks->isRunning())
  464. {
  465. status = 1;
  466. if (ks->istAn())
  467. status = 2;
  468. }
  469. klient->sende("\1", 1);
  470. klient->sende(&status, 1);
  471. }
  472. break;
  473. case 9: // Server pausieren
  474. if (!adminId)
  475. errorZuKlient("Du musst dich einloggen.");
  476. else
  477. {
  478. klient->sende("\1", 1);
  479. char pause = 0;
  480. klient->getNachricht(&pause, 1);
  481. if (ks->zDB()->adminHatRecht(adminId, Admin_Recht::KSPausieren))
  482. {
  483. bool ok = 0;
  484. if (pause)
  485. ok = ks->serverPause();
  486. else
  487. ok = ks->serverFortsetzen();
  488. if (ok)
  489. klient->sende("\1", 1);
  490. else
  491. {
  492. Text* err = new Text();
  493. err->append(ks->getLetzterFehler());
  494. errorZuKlient(err->getText());
  495. err->release();
  496. }
  497. }
  498. else
  499. {
  500. if (pause)
  501. errorZuKlient("Du bist nicht berechtigt den Server zu pausieren.");
  502. else
  503. errorZuKlient("Du bist nicht berechtigt den Server fortzusetzen.");
  504. }
  505. }
  506. break;
  507. case 0xA: // maximale Anzahl der Clients setzen
  508. if (!adminId)
  509. errorZuKlient("Du musst dich einloggen.");
  510. else
  511. {
  512. klient->sende("\1", 1);
  513. int maxK = 0;
  514. klient->getNachricht((char*)&maxK, 4);
  515. if (ks->zDB()->adminHatRecht(adminId, Admin_Recht::KSMKChange))
  516. {
  517. if (ks->setMaxKarten(maxK))
  518. klient->sende("\1", 1);
  519. else
  520. {
  521. Text* err = new Text();
  522. err->append(ks->getLetzterFehler());
  523. errorZuKlient(err->getText());
  524. err->release();
  525. }
  526. }
  527. else
  528. errorZuKlient("Du bist nicht berechtigt die maximale Anzahl der Karten zu verändern.");
  529. }
  530. break;
  531. case 0xC: // klient absturtz
  532. if (1)
  533. {
  534. klient->sende("\1", 1);
  535. int klientId = 0;
  536. klient->getNachricht((char*)&klientId, 4);
  537. if (klientId && ks->absturzKlient(klientId))
  538. klient->sende("\1", 1);
  539. else
  540. klient->sende("\0", 1);
  541. }
  542. break;
  543. default:
  544. errorZuKlient("Unbekannte Nachricht!");
  545. break;
  546. }
  547. if (br)
  548. break;
  549. ks->addEmpfangen(klient->getDownloadBytes(1));
  550. ks->addGesendet(klient->getUploadBytes(1));
  551. }
  552. }
  553. ks->addEmpfangen(klient->getDownloadBytes(1));
  554. ks->addGesendet(klient->getUploadBytes(1));
  555. delete this;
  556. }
  557. void KSAKlient::errorZuKlient(const char* nachricht) const // sendet eine Fehlernachricht zum Klient
  558. {
  559. klient->sende("\3", 1);
  560. char len = (char)textLength(nachricht);
  561. klient->sende(&len, 1);
  562. klient->sende(nachricht, len);
  563. }
  564. // Inhalt der KSKlient aus KartenServer.h
  565. // Konstruktor
  566. KSKlient::KSKlient(SKlient* klient, KartenServer* ks)
  567. : Thread()
  568. {
  569. this->klient = klient;
  570. unsigned char key[20] = { 24, 15, 53, 87, 38, 73, 154, 38, 246, 90, 39, 133, 11, 199, 22, 80, 26, 132, 95, 54 };
  571. klient->setSendeKey((char*)key, 20);
  572. klient->setEmpfangKey((char*)key, 20);
  573. klientNummer = 0;
  574. this->ks = ks;
  575. }
  576. // Destruktor
  577. KSKlient::~KSKlient()
  578. {
  579. klient->release();
  580. ks->release();
  581. }
  582. // privat
  583. void KSKlient::suchDateien(const char* pf, RCArray< Text >* zDL, const char* rem)
  584. {
  585. Datei d;
  586. d.setDatei(pf);
  587. if (d.istOrdner())
  588. {
  589. RCArray< Text >* list = d.getDateiListe();
  590. if (list)
  591. {
  592. int anz = list->getEintragAnzahl();
  593. for (int i = 0; i < anz; i++)
  594. {
  595. Text pfad = pf;
  596. pfad += "/";
  597. pfad += list->z(i)->getText();
  598. suchDateien(pfad, zDL, rem);
  599. }
  600. list->release();
  601. }
  602. }
  603. else
  604. {
  605. Text* pfad = new Text(pf);
  606. pfad->remove(0, textLength(rem));
  607. zDL->add(pfad);
  608. }
  609. }
  610. // nicht constant
  611. void KSKlient::absturz()
  612. {
  613. ende();
  614. klient->trenne();
  615. ks->zDB()->unregisterKlient(klientNummer, ks->getId());
  616. }
  617. void KSKlient::thread()
  618. {
  619. while (1)
  620. {
  621. char c = 0;
  622. if (!klient->getNachrichtEncrypted(&c, 1))
  623. break;
  624. else
  625. {
  626. bool br = 0;
  627. switch (c)
  628. {
  629. case 1: // Klient identifikation
  630. klient->getNachrichtEncrypted((char*)&klientNummer, 4);
  631. if (!ks->zDB()->proveKlient(klientNummer, ks->getId()))
  632. {
  633. klientNummer = 0;
  634. errorZuKlient("Du bist nicht für diesen Server eingetragen");
  635. }
  636. else
  637. {
  638. Text* key = ks->zDB()->getKlientKey(klientNummer);
  639. if (!key)
  640. errorZuKlient("Es konnte kein Schlüssel ermittelt werden.");
  641. else
  642. {
  643. klient->sendeEncrypted("\1", 1);
  644. klient->setEmpfangKey(*key, key->getLength());
  645. klient->setSendeKey(*key, key->getLength());
  646. key->release();
  647. }
  648. }
  649. break;
  650. case 2: // Main / Erhaltung Server message
  651. if (1)
  652. {
  653. char befehl = 0;
  654. klient->getNachrichtEncrypted(&befehl, 1);
  655. switch (befehl)
  656. {
  657. case 2: // klient absturtz
  658. if (1)
  659. {
  660. int klientId = 0;
  661. klient->getNachrichtEncrypted((char*)&klientId, 4);
  662. if (klientId && ks->absturzKlient(klientId))
  663. klient->sendeEncrypted("\1", 1);
  664. else
  665. klient->sendeEncrypted("\0", 1);
  666. }
  667. break;
  668. default:
  669. errorZuKlient("Befehl nicht bekannt!");
  670. break;
  671. }
  672. }
  673. break;
  674. case 3: // Verbindungsende
  675. br = 1;
  676. klient->sendeEncrypted("\1", 1);
  677. break;
  678. case 4: // unregister Klient
  679. if (!klientNummer)
  680. {
  681. errorZuKlient("Du bist nicht Identifiziert.");
  682. break;
  683. }
  684. ks->zDB()->unregisterKlient(klientNummer, ks->getId());
  685. klient->sendeEncrypted("\1", 1);
  686. break;
  687. case 5: // keep alive
  688. if (!klientNummer)
  689. {
  690. errorZuKlient("Du bist nicht Identifiziert.");
  691. break;
  692. }
  693. klient->sendeEncrypted("\1", 1);
  694. break;
  695. case 6: // download Karte (Klient)
  696. if (!klientNummer)
  697. {
  698. errorZuKlient("Du bist nicht Identifiziert.");
  699. break;
  700. }
  701. else
  702. {
  703. klient->sendeEncrypted("\1", 1);
  704. int id = 0;
  705. klient->getNachrichtEncrypted((char*)&id, 4);
  706. if (!ks->zDB()->proveKarte(id, ks->getId()))
  707. {
  708. errorZuKlient("Die Karte wurde nicht gefunden.");
  709. break;
  710. }
  711. if (ks->wirdKarteGeupdatet(id))
  712. {
  713. char c = 2;
  714. klient->sendeEncrypted(&c, 1);
  715. break;
  716. }
  717. klient->sendeEncrypted("\1", 1);
  718. Text pfad = ks->zIni()->zWert("KartenPfad")->getText();
  719. pfad += "/";
  720. pfad += id;
  721. pfad += "/client/map";
  722. RCArray< Text >* dList = new RCArray< Text >();
  723. suchDateien(pfad, dList, pfad);
  724. int anz = dList->getEintragAnzahl();
  725. klient->sendeEncrypted((char*)&anz, 4);
  726. for (int i = 0; i < anz; i++)
  727. {
  728. Text pf = dList->z(i)->getText();
  729. unsigned char len = (unsigned char)pf.getLength();
  730. Text dp = pf.getText();
  731. dp.insert(0, pfad);
  732. Datei d;
  733. d.setDatei(dp);
  734. if (!len || !d.open(Datei::Style::lesen))
  735. {
  736. klient->sendeEncrypted("\0", 1);
  737. continue;
  738. }
  739. klient->sendeEncrypted((char*)&len, 1);
  740. klient->sendeEncrypted(pf, len);
  741. __int64 size = d.getSize();
  742. klient->sendeEncrypted((char*)&size, 8);
  743. char* buffer = new char[2048];
  744. while (size)
  745. {
  746. int l = size >= 2048 ? 2048 : (int)size;
  747. d.lese(buffer, l);
  748. klient->sende(buffer, l);
  749. size -= l;
  750. }
  751. delete[] buffer;
  752. d.close();
  753. }
  754. dList->release();
  755. }
  756. break;
  757. case 7: // download Karte (Server)
  758. if (klientNummer)
  759. {
  760. errorZuKlient("Du bist nicht berechtigt.");
  761. break;
  762. }
  763. else
  764. {
  765. klient->sendeEncrypted("\1", 1);
  766. int id = 0;
  767. klient->getNachrichtEncrypted((char*)&id, 4);
  768. if (!ks->zDB()->proveKarte(id, ks->getId()))
  769. {
  770. errorZuKlient("Die Karte wurde nicht gefunden.");
  771. break;
  772. }
  773. if (ks->wirdKarteGeupdatet(id))
  774. {
  775. char c = 2;
  776. klient->sendeEncrypted(&c, 1);
  777. break;
  778. }
  779. klient->sendeEncrypted("\1", 1);
  780. Text pfad = ks->zIni()->zWert("KartenPfad")->getText();
  781. pfad += "/";
  782. pfad += id;
  783. pfad += "/server";
  784. RCArray< Text >* dList = new RCArray< Text >();
  785. suchDateien(pfad, dList, pfad);
  786. int anz = dList->getEintragAnzahl();
  787. klient->sendeEncrypted((char*)&anz, 4);
  788. for (int i = 0; i < anz; i++)
  789. {
  790. Text pf = dList->z(i)->getText();
  791. unsigned char len = (unsigned char)pf.getLength();
  792. Text dp = pf.getText();
  793. dp.insert(0, pfad);
  794. Datei d;
  795. d.setDatei(dp);
  796. if (!len || !d.open(Datei::Style::lesen))
  797. continue;
  798. klient->sendeEncrypted((char*)&len, 1);
  799. klient->sendeEncrypted(pf, len);
  800. __int64 size = d.getSize();
  801. klient->sendeEncrypted((char*)&size, 8);
  802. char* buffer = new char[2048];
  803. while (size)
  804. {
  805. int l = size >= 2048 ? 2048 : (int)size;
  806. d.lese(buffer, l);
  807. klient->sende(buffer, l);
  808. size -= l;
  809. }
  810. delete[] buffer;
  811. d.close();
  812. }
  813. dList->release();
  814. }
  815. break;
  816. case 8: // Karte Titel Bild laden
  817. if (!klientNummer)
  818. {
  819. errorZuKlient("Du bist nicht Identifiziert.");
  820. break;
  821. }
  822. else
  823. {
  824. klient->sendeEncrypted("\1", 1);
  825. int id = 0;
  826. klient->getNachrichtEncrypted((char*)&id, 4);
  827. if (!ks->zDB()->proveKarte(id, ks->getId()))
  828. {
  829. errorZuKlient("Die Karte wurde nicht gefunden.");
  830. break;
  831. }
  832. if (ks->wirdKarteGeupdatet(id))
  833. {
  834. char c = 2;
  835. klient->sendeEncrypted(&c, 1);
  836. break;
  837. }
  838. Text pfad = ks->zIni()->zWert("KartenPfad")->getText();
  839. pfad += "/";
  840. pfad += id;
  841. pfad += "/client/titel.ltdb";
  842. Datei d;
  843. d.setDatei(pfad);
  844. if (d.open(Datei::Style::lesen))
  845. klient->sendeEncrypted("\1", 1);
  846. else
  847. errorZuKlient("Fehler beim lesen der Datei.");
  848. __int64 size = d.getSize();
  849. klient->sendeEncrypted((char*)&size, 8);
  850. char* buffer = new char[2048];
  851. while (size)
  852. {
  853. int l = size >= 2048 ? 2048 : (int)size;
  854. d.lese(buffer, l);
  855. klient->sende(buffer, l);
  856. size -= l;
  857. }
  858. delete[] buffer;
  859. d.close();
  860. }
  861. break;
  862. case 9: // Karte Beschreibung
  863. if (!klientNummer)
  864. {
  865. errorZuKlient("Du bist nicht Identifiziert.");
  866. break;
  867. }
  868. else
  869. {
  870. klient->sendeEncrypted("\1", 1);
  871. int id = 0;
  872. klient->getNachrichtEncrypted((char*)&id, 4);
  873. if (!ks->zDB()->proveKarte(id, ks->getId()))
  874. {
  875. errorZuKlient("Die Karte wurde nicht gefunden.");
  876. break;
  877. }
  878. if (ks->wirdKarteGeupdatet(id))
  879. {
  880. char c = 2;
  881. klient->sendeEncrypted(&c, 1);
  882. break;
  883. }
  884. Text pfad = ks->zIni()->zWert("KartenPfad")->getText();
  885. pfad += "/";
  886. pfad += id;
  887. pfad += "/client/beschreibung.ksgs";
  888. Datei d;
  889. d.setDatei(pfad);
  890. if (d.open(Datei::Style::lesen))
  891. klient->sendeEncrypted("\1", 1);
  892. else
  893. errorZuKlient("Fehler beim lesen der Datei.");
  894. __int64 size = d.getSize();
  895. klient->sendeEncrypted((char*)&size, 8);
  896. char* buffer = new char[2048];
  897. while (size)
  898. {
  899. int l = size >= 2048 ? 2048 : (int)size;
  900. d.lese(buffer, l);
  901. klient->sende(buffer, l);
  902. size -= l;
  903. }
  904. delete[] buffer;
  905. d.close();
  906. }
  907. break;
  908. case 10: // Karte Minimap
  909. if (!klientNummer)
  910. {
  911. errorZuKlient("Du bist nicht Identifiziert.");
  912. break;
  913. }
  914. else
  915. {
  916. klient->sendeEncrypted("\1", 1);
  917. int id = 0;
  918. klient->getNachrichtEncrypted((char*)&id, 4);
  919. if (!ks->zDB()->proveKarte(id, ks->getId()))
  920. {
  921. errorZuKlient("Die Karte wurde nicht gefunden.");
  922. break;
  923. }
  924. if (ks->wirdKarteGeupdatet(id))
  925. {
  926. char c = 2;
  927. klient->sendeEncrypted(&c, 1);
  928. break;
  929. }
  930. Text pfad = ks->zIni()->zWert("KartenPfad")->getText();
  931. pfad += "/";
  932. pfad += id;
  933. pfad += "/client/minimap.ltdb";
  934. Datei d;
  935. d.setDatei(pfad);
  936. if (d.open(Datei::Style::lesen))
  937. klient->sendeEncrypted("\1", 1);
  938. else
  939. errorZuKlient("Fehler beim lesen der Datei.");
  940. __int64 size = d.getSize();
  941. klient->sendeEncrypted((char*)&size, 8);
  942. char* buffer = new char[2048];
  943. while (size)
  944. {
  945. int l = size >= 2048 ? 2048 : (int)size;
  946. d.lese(buffer, l);
  947. klient->sende(buffer, l);
  948. size -= l;
  949. }
  950. delete[] buffer;
  951. d.close();
  952. }
  953. break;
  954. case 11: // Karte Ladebild
  955. if (!klientNummer)
  956. {
  957. errorZuKlient("Du bist nicht Identifiziert.");
  958. break;
  959. }
  960. else
  961. {
  962. klient->sendeEncrypted("\1", 1);
  963. int id = 0;
  964. klient->getNachrichtEncrypted((char*)&id, 4);
  965. if (!ks->zDB()->proveKarte(id, ks->getId()))
  966. {
  967. errorZuKlient("Die Karte wurde nicht gefunden.");
  968. break;
  969. }
  970. if (ks->wirdKarteGeupdatet(id))
  971. {
  972. char c = 2;
  973. klient->sendeEncrypted(&c, 1);
  974. break;
  975. }
  976. Text pfad = ks->zIni()->zWert("KartenPfad")->getText();
  977. pfad += "/";
  978. pfad += id;
  979. pfad += "/client/ladebild.ltdb";
  980. Datei d;
  981. d.setDatei(pfad);
  982. if (d.open(Datei::Style::lesen))
  983. klient->sendeEncrypted("\1", 1);
  984. else
  985. errorZuKlient("Fehler beim lesen der Datei.");
  986. __int64 size = d.getSize();
  987. klient->sendeEncrypted((char*)&size, 8);
  988. char* buffer = new char[2048];
  989. while (size)
  990. {
  991. int l = size >= 2048 ? 2048 : (int)size;
  992. d.lese(buffer, l);
  993. klient->sende(buffer, l);
  994. size -= l;
  995. }
  996. delete[] buffer;
  997. d.close();
  998. }
  999. break;
  1000. default:
  1001. errorZuKlient("Unbekannte Nachricht!");
  1002. break;
  1003. }
  1004. if (br)
  1005. break;
  1006. ks->addEmpfangen(klient->getDownloadBytes(1));
  1007. ks->addGesendet(klient->getUploadBytes(1));
  1008. }
  1009. }
  1010. ks->addEmpfangen(klient->getDownloadBytes(1));
  1011. ks->addGesendet(klient->getUploadBytes(1));
  1012. ks->removeKlient(this); // delete this
  1013. }
  1014. // constant
  1015. void KSKlient::errorZuKlient(const char* nachricht) const // sendet eine Fehlernachricht zum Klient
  1016. {
  1017. klient->sendeEncrypted("\3", 1);
  1018. char len = (char)textLength(nachricht);
  1019. klient->sendeEncrypted(&len, 1);
  1020. klient->sendeEncrypted(nachricht, len);
  1021. }
  1022. int KSKlient::getKlientNummer() const // gibt die KlientId zurück
  1023. {
  1024. return klientNummer;
  1025. }