ServerSelection.cpp 19 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535
  1. #include "ServerSelection.h"
  2. #include <AlphaFeld.h>
  3. #include <AsynchronCall.h>
  4. #include <Base64.h>
  5. #include <Bild.h>
  6. #include <Datei.h>
  7. #include <JSON.h>
  8. #include <Knopf.h>
  9. #include <Schrift.h>
  10. #include "FactoryClient.h"
  11. #include "Globals.h"
  12. #include "Initialisierung.h"
  13. using namespace Framework;
  14. ServerStatus::ServerStatus(Framework::Text name,
  15. Framework::Text ip,
  16. unsigned short sslPort,
  17. unsigned short port,
  18. Framework::HashMap<Framework::Text, Framework::Text>* secrets)
  19. : ZeichnungHintergrund(),
  20. name(name),
  21. ip(ip),
  22. sslPort(sslPort),
  23. port(port),
  24. playerName(""),
  25. ping(-1),
  26. status("..."),
  27. statusId(0),
  28. requestId(0),
  29. secrets(secrets),
  30. closeAF(new AlphaFeld()),
  31. join(initKnopf(0, 0, 55, 20, Knopf::Style::Normal, "join"))
  32. {
  33. closeAF->setSize(20, 20);
  34. closeAF->setFarbe(0x00FF0000);
  35. setMausEreignis(_ret1ME);
  36. setStyle(Style::Erlaubt | Style::Sichtbar | Style::Rahmen);
  37. setRahmenBreite(1);
  38. setRahmenFarbe(0xFF3d3d3d);
  39. join->setMausEreignis([this](void* p, void* o, MausEreignis me) {
  40. if (me.id == ME_RLinks)
  41. {
  42. FactoryClient* client = new FactoryClient();
  43. if (!client->connect(getIp(), getSSLPort()))
  44. {
  45. lockZeichnung();
  46. status = "The Server is currently not reachable";
  47. statusId = 404;
  48. ping = -1;
  49. rend = 1;
  50. unlockZeichnung();
  51. client->release();
  52. }
  53. else
  54. {
  55. Text secret = "";
  56. if (this->secrets->has(playerName))
  57. secret = this->secrets->get(playerName);
  58. bool isNew = secret.getLength() == 0;
  59. int stId = client->join(playerName, secret, getPort());
  60. lockZeichnung();
  61. statusId = stId;
  62. if (statusId == 403) status = "The name is already in use";
  63. if (statusId == 500) status = "Unknown Server message received";
  64. if (statusId == 201) status = "Please try again";
  65. unlockZeichnung();
  66. if (statusId == 200 || statusId == 201)
  67. {
  68. if (statusId == 200)
  69. ((ServerSelectionMenu*)(Menu*)menuRegister->get(
  70. "serverSelection"))
  71. ->hide();
  72. if (isNew)
  73. {
  74. this->secrets->put(playerName, secret);
  75. ((ServerSelectionMenu*)(Menu*)menuRegister->get(
  76. "serverSelection"))
  77. ->saveServers();
  78. }
  79. if (statusId == 200)
  80. {
  81. World::INSTANCE = new World(
  82. dynamic_cast<Bildschirm3D*>(window->zBildschirm()),
  83. client);
  84. ((ServerSelectionMenu*)(Menu*)menuRegister->get("game"))
  85. ->show();
  86. }
  87. }
  88. else
  89. client->release();
  90. }
  91. }
  92. return 1;
  93. });
  94. }
  95. ServerStatus::~ServerStatus()
  96. {
  97. secrets->release();
  98. closeAF->release();
  99. join->release();
  100. }
  101. void ServerStatus::updatePlayerName(Framework::Text playerName)
  102. {
  103. lockZeichnung();
  104. status = "";
  105. this->playerName = playerName;
  106. ServerStatus* tmp = dynamic_cast<ServerStatus*>(getThis());
  107. int id = ++requestId;
  108. unlockZeichnung();
  109. new AsynchronCall([tmp, id]() {
  110. FactoryClient* client = new FactoryClient();
  111. if (!client->connect(tmp->getIp(), tmp->getSSLPort()))
  112. {
  113. tmp->lockZeichnung();
  114. if (tmp->requestId == id)
  115. {
  116. tmp->status = "The Server is currently not reachable";
  117. tmp->statusId = 404;
  118. tmp->ping = -1;
  119. tmp->rend = 1;
  120. }
  121. tmp->unlockZeichnung();
  122. }
  123. else
  124. {
  125. tmp->lockZeichnung();
  126. if (tmp->requestId == id)
  127. {
  128. Text secret = "";
  129. if (tmp->secrets->has(tmp->playerName))
  130. secret = tmp->secrets->get(tmp->playerName);
  131. tmp->unlockZeichnung();
  132. int ping = client->ping();
  133. int statusId = client->status(tmp->playerName, secret);
  134. tmp->lockZeichnung();
  135. if (tmp->requestId == id)
  136. {
  137. tmp->ping = ping;
  138. tmp->statusId = statusId;
  139. if (tmp->statusId == 200)
  140. tmp->status = "The Server is reachable";
  141. if (tmp->statusId == 403)
  142. tmp->status = "The name is already in use";
  143. tmp->rend = 1;
  144. }
  145. }
  146. tmp->unlockZeichnung();
  147. }
  148. client->release();
  149. tmp->release();
  150. });
  151. }
  152. void ServerStatus::doMausEreignis(Framework::MausEreignis& me, bool userRet)
  153. {
  154. if (me.id == ME_Leaves)
  155. {
  156. closeAF->setStrength(0);
  157. closeAF->setFarbe(0x00FF0000);
  158. }
  159. else if (me.id == ME_Bewegung)
  160. {
  161. if (me.mx >= gr.x - 20 && me.mx < gr.x && me.my >= 0 && me.my <= 20)
  162. {
  163. if (closeAF->getStrength() == 0)
  164. {
  165. closeAF->setStrength(-5);
  166. closeAF->setFarbe(0x30FF0000);
  167. }
  168. }
  169. else
  170. {
  171. if (closeAF->getStrength() != 0)
  172. {
  173. closeAF->setStrength(0);
  174. closeAF->setFarbe(0x00FF0000);
  175. }
  176. }
  177. }
  178. if (me.id == ME_RLinks)
  179. {
  180. if (me.mx >= gr.x - 20 && me.mx < gr.x && me.my >= 0 && me.my <= 20)
  181. {
  182. ((ServerSelectionMenu*)(Menu*)menuRegister->get("serverSelection"))
  183. ->removeServer(name);
  184. return;
  185. }
  186. }
  187. if (canConnect()) join->doPublicMausEreignis(me);
  188. }
  189. bool ServerStatus::tick(double time)
  190. {
  191. join->setPosition(gr.x - 60, gr.y - 25);
  192. closeAF->setPosition(gr.x - 20, 0);
  193. return ZeichnungHintergrund::tick(time) || join->tick(time)
  194. || closeAF->tick(time);
  195. }
  196. void ServerStatus::render(Framework::Bild& rObj)
  197. {
  198. ZeichnungHintergrund::render(rObj);
  199. if (rObj.setDrawOptions(pos, gr))
  200. {
  201. TextRenderer tr(
  202. dynamic_cast<Schrift*>(uiFactory.initParam.schrift->getThis()));
  203. tr.setSchriftSize(12);
  204. tr.renderText(5, 5, name, rObj, 0xFFFFFFFF);
  205. tr.renderText(
  206. 5, 25, ip + ":" + sslPort + " (" + port + ")", rObj, 0xFF808080);
  207. if (requestId && requestId != 404)
  208. {
  209. int tbr = tr.getTextBreite(Text("ping: ") + ping);
  210. if (ping >= 0)
  211. {
  212. tr.renderText(getBreite() - 25 - tbr,
  213. 5,
  214. Text("ping: ") + ping,
  215. rObj,
  216. 0xFFFFFFFF);
  217. }
  218. }
  219. if (statusId == 404 || statusId == 500)
  220. tr.renderText(5, 45, status, rObj, 0xFFFF0000);
  221. if (statusId == 403 || statusId == 201)
  222. tr.renderText(5, 45, status, rObj, 0xFFFFA500);
  223. if (statusId == 200) tr.renderText(5, 45, status, rObj, 0xFF00FF00);
  224. closeAF->render(rObj);
  225. rObj.drawLinie(Punkt(gr.x - 20, 0), Punkt(gr.x, 20), 0xFFFF0000);
  226. rObj.drawLinie(Punkt(gr.x - 20, 20), Punkt(gr.x, 0), 0xFFFF0000);
  227. if (canConnect()) join->render(rObj);
  228. rObj.releaseDrawOptions();
  229. }
  230. }
  231. Framework::Text ServerStatus::getName() const
  232. {
  233. return name;
  234. }
  235. Framework::Text ServerStatus::getIp() const
  236. {
  237. return ip;
  238. }
  239. unsigned short ServerStatus::getSSLPort() const
  240. {
  241. return sslPort;
  242. }
  243. unsigned short ServerStatus::getPort() const
  244. {
  245. return port;
  246. }
  247. Framework::HashMap<Framework::Text, Framework::Text>*
  248. ServerStatus::zSecrets() const
  249. {
  250. return secrets;
  251. }
  252. bool ServerStatus::canConnect() const
  253. {
  254. return statusId == 200 || statusId == 201;
  255. }
  256. ServerSelectionMenu::ServerSelectionMenu(Bildschirm* zScreen)
  257. : Menu(zScreen)
  258. {
  259. playerNameLabel = initTextFeld(zScreen->getBackBufferSize().x / 2 - 150,
  260. zScreen->getBackBufferSize().y / 2 - 300,
  261. 85,
  262. 20,
  263. TextFeld::Style::Text | TextFeld::Style::VCenter,
  264. "Player Name:");
  265. elements.add(playerNameLabel);
  266. playerName = initTextFeld(zScreen->getBackBufferSize().x / 2 - 150 + 85,
  267. zScreen->getBackBufferSize().y / 2 - 300,
  268. 215,
  269. 20,
  270. TextFeld::Style::TextFeld,
  271. "");
  272. playerName->setNTastaturEreignis(
  273. [this](void* p, void* o, TastaturEreignis te) {
  274. // set player names of each server
  275. for (int i = 0; i < serverList->getEintragAnzahl(); i++)
  276. ((ServerStatus*)serverList->zEintrag(i))
  277. ->updatePlayerName(playerName->zText()->getText());
  278. saveServers();
  279. return 1;
  280. });
  281. elements.add(playerName);
  282. serverLabel = initTextFeld(zScreen->getBackBufferSize().x / 2 - 150,
  283. zScreen->getBackBufferSize().y / 2 - 275,
  284. 100,
  285. 20,
  286. TextFeld::Style::Text | TextFeld::Style::VCenter,
  287. "Server:");
  288. elements.add(serverLabel);
  289. refresh = initKnopf(zScreen->getBackBufferSize().x / 2 + 80,
  290. zScreen->getBackBufferSize().y / 2 - 275,
  291. 70,
  292. 20,
  293. Knopf::Style::Normal,
  294. "Refresh");
  295. refresh->setMausEreignis(
  296. [this](void* p, void* o, Framework::MausEreignis me) {
  297. if (me.id == ME_RLinks)
  298. {
  299. if (playerName->zText()->getLength() > 0)
  300. {
  301. for (int i = 0; i < serverList->getEintragAnzahl(); i++)
  302. ((ServerStatus*)serverList->zEintrag(i))
  303. ->updatePlayerName(playerName->zText()->getText());
  304. }
  305. }
  306. return 1;
  307. });
  308. elements.add(refresh);
  309. serverList = new ZListe();
  310. serverList->setSize(300, 480);
  311. serverList->setRahmenBreite(1);
  312. serverList->setRahmenFarbe(0xFF6d6d6d);
  313. serverList->setPosition(zScreen->getBackBufferSize().x / 2 - 150,
  314. zScreen->getBackBufferSize().y / 2 - 250);
  315. serverList->setStyle(ZListe::Style::Normal | ZListe::Style::VScroll);
  316. serverList->setMausEreignis(_ret1ME);
  317. serverList->setVertikalScrollPos(0);
  318. serverList->setEntrySeperatorSize(1);
  319. serverList->setEntrySeperatorColor(0xFF6d6d6d);
  320. elements.add(serverList);
  321. add = initKnopf(zScreen->getBackBufferSize().x / 2 - 50,
  322. zScreen->getBackBufferSize().y / 2 + 235,
  323. 100,
  324. 20,
  325. Knopf::Style::Normal,
  326. "Add Server");
  327. elements.add(add);
  328. add->setMausEreignis([this](void* p, void* o, Framework::MausEreignis me) {
  329. if (me.id == ME_RLinks)
  330. {
  331. hide();
  332. menuRegister->get("addServer")->show();
  333. }
  334. return 1;
  335. });
  336. // load server json
  337. JSON::JSONValue* json = JSON::loadJSONFromFile("data/server.json");
  338. if (json)
  339. {
  340. // build validator
  341. JSON::Validator::JSONValidator* validator
  342. = JSON::Validator::JSONValidator::buildForObject()
  343. ->withRequiredString("playerName")
  344. ->withDefault("")
  345. ->finishString()
  346. ->withRequiredAttribute("server",
  347. JSON::Validator::JSONValidator::buildForArray()
  348. ->withDefault(new JSON::JSONArray())
  349. ->removeInvalidEntries()
  350. ->addAcceptedTypeInArray(
  351. JSON::Validator::JSONValidator::buildForObject()
  352. ->withRequiredString("name")
  353. ->finishString()
  354. ->withRequiredString("ip")
  355. ->finishString()
  356. ->withRequiredNumber("sslPort")
  357. ->whichIsGreaterOrEqual(0)
  358. ->whichIsLessOrEqual((double)0xFFFF)
  359. ->finishNumber()
  360. ->withRequiredNumber("port")
  361. ->whichIsGreaterOrEqual(0)
  362. ->whichIsLessOrEqual((double)0xFFFF)
  363. ->finishNumber()
  364. ->withRequiredAttribute("secrets",
  365. JSON::Validator::JSONValidator::
  366. buildForArray()
  367. ->addAcceptedObjectInArray()
  368. ->withRequiredString("secret")
  369. ->finishString()
  370. ->withRequiredString("playerName")
  371. ->finishString()
  372. ->finishObject()
  373. ->finishArray())
  374. ->finishObject())
  375. ->finishArray())
  376. ->finishObject();
  377. JSON::JSONValue* validJson = validator->getValidParts(json);
  378. json->release();
  379. if (validJson)
  380. {
  381. JSON::JSONArray* arr
  382. = validJson->asObject()->zValue("server")->asArray();
  383. for (int i = 0; i < arr->getLength(); i++)
  384. {
  385. JSON::JSONObject* obj = arr->zValue(i)->asObject();
  386. Framework::HashMap<Framework::Text, Framework::Text>* secrets
  387. = new Framework::HashMap<Framework::Text, Framework::Text>(
  388. 10, [](Text t) { return t.hashCode(); });
  389. JSON::JSONArray* secretsJson
  390. = obj->zValue("secrets")->asArray();
  391. for (int j = 0; j < secretsJson->getLength(); j++)
  392. {
  393. JSON::JSONObject* obj2 = secretsJson->zValue(j)->asObject();
  394. // decode base64 secret
  395. char* secretBuffer = 0;
  396. int length;
  397. Framework::base64Decode(
  398. obj2->zValue("secret")->asString()->getString(),
  399. &secretBuffer,
  400. &length);
  401. secrets->put(
  402. obj2->zValue("playerName")->asString()->getString(),
  403. Framework::Text(secretBuffer));
  404. delete[] secretBuffer;
  405. }
  406. ServerStatus* s = new ServerStatus(
  407. obj->zValue("name")->asString()->getString(),
  408. obj->zValue("ip")->asString()->getString(),
  409. (unsigned short)obj->zValue("sslPort")
  410. ->asNumber()
  411. ->getNumber(),
  412. (unsigned short)obj->zValue("port")
  413. ->asNumber()
  414. ->getNumber(),
  415. secrets);
  416. s->setSize(300, 65);
  417. serverList->addEintrag(s);
  418. }
  419. playerName->setText(validJson->asObject()
  420. ->zValue("playerName")
  421. ->asString()
  422. ->getString());
  423. if (playerName->zText()->getLength() > 0)
  424. {
  425. for (int i = 0; i < serverList->getEintragAnzahl(); i++)
  426. ((ServerStatus*)serverList->zEintrag(i))
  427. ->updatePlayerName(playerName->zText()->getText());
  428. }
  429. serverList->updateVScroll();
  430. validJson->release();
  431. }
  432. validator->release();
  433. }
  434. }
  435. void ServerSelectionMenu::addServer(Framework::Text name,
  436. Framework::Text ip,
  437. unsigned short sslPort,
  438. unsigned short port)
  439. {
  440. ServerStatus* tmp = new ServerStatus(name,
  441. ip,
  442. sslPort,
  443. port,
  444. new HashMap<Framework::Text, Framework::Text>(
  445. 10, [](Text t) { return t.hashCode(); }));
  446. tmp->setSize(300, 65);
  447. serverList->addEintrag(tmp);
  448. tmp->updatePlayerName(playerName->zText()->getText());
  449. serverList->updateVScroll();
  450. saveServers();
  451. }
  452. bool ServerSelectionMenu::hasServer(Framework::Text name) const
  453. {
  454. for (int i = 0; i < serverList->getEintragAnzahl(); i++)
  455. {
  456. if (((ServerStatus*)serverList->zEintrag(i))->getName() == name)
  457. return 1;
  458. }
  459. return 0;
  460. }
  461. void ServerSelectionMenu::removeServer(Framework::Text name) const
  462. {
  463. for (int i = 0; i < serverList->getEintragAnzahl(); i++)
  464. {
  465. if (((ServerStatus*)serverList->zEintrag(i))->getName() == name)
  466. serverList->removeEintrag(i);
  467. }
  468. serverList->updateVScroll();
  469. saveServers();
  470. }
  471. void ServerSelectionMenu::saveServers() const
  472. {
  473. Datei file;
  474. file.setDatei("data/server.json");
  475. file.open(Datei::Style::schreiben);
  476. JSON::JSONObject root;
  477. JSON::JSONArray* servers = new JSON::JSONArray();
  478. for (int i = 0; i < serverList->getEintragAnzahl(); i++)
  479. {
  480. JSON::JSONObject* server = new JSON::JSONObject();
  481. server->addValue("name",
  482. new JSON::JSONString(
  483. ((ServerStatus*)serverList->zEintrag(i))->getName()));
  484. server->addValue("ip",
  485. new JSON::JSONString(
  486. ((ServerStatus*)serverList->zEintrag(i))->getIp()));
  487. server->addValue("sslPort",
  488. new JSON::JSONNumber(
  489. ((ServerStatus*)serverList->zEintrag(i))->getSSLPort()));
  490. server->addValue("port",
  491. new JSON::JSONNumber(
  492. ((ServerStatus*)serverList->zEintrag(i))->getPort()));
  493. JSON::JSONArray* secrets = new JSON::JSONArray();
  494. for (auto secretEntry :
  495. *((ServerStatus*)serverList->zEintrag(i))->zSecrets())
  496. {
  497. JSON::JSONObject* secret = new JSON::JSONObject();
  498. secret->addValue(
  499. "playerName", new JSON::JSONString(secretEntry.getKey()));
  500. // base64 encode secret
  501. Framework::Text secretBase64 = Framework::base64Encode(
  502. secretEntry.getValue(), secretEntry.getValue().getLength());
  503. secret->addValue("secret", new JSON::JSONString(secretBase64));
  504. secrets->addValue(secret);
  505. }
  506. server->addValue("secrets", secrets);
  507. servers->addValue(server);
  508. }
  509. root.addValue("server", servers);
  510. root.addValue(
  511. "playerName", new JSON::JSONString(playerName->zText()->getText()));
  512. Framework::Text json = root.toString();
  513. file.schreibe(json, json.getLength());
  514. file.close();
  515. }