FactoryClient.cpp 11 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394
  1. #include "FactoryClient.h"
  2. #include <Bild.h>
  3. #include <Textur.h>
  4. #include "Globals.h"
  5. using namespace Network;
  6. using namespace Framework;
  7. FactoryClient::FactoryClient()
  8. {
  9. client = 0;
  10. background = 0;
  11. foreground = 0;
  12. backgroundReader = 0;
  13. foregroundReader = 0;
  14. bgReaderUsage = 0;
  15. fgReaderUsage = 0;
  16. }
  17. FactoryClient::~FactoryClient()
  18. {
  19. if (client) disconnect();
  20. }
  21. void FactoryClient::loadServerInfo()
  22. {
  23. std::cout << "downloading server type information\n";
  24. // receive type information
  25. for (int i = 0; i < blockTypeCount; i++)
  26. blockTypes[i]->release();
  27. delete[] blockTypes;
  28. for (int i = 0; i < itemTypeCount; i++)
  29. itemTypes[i]->release();
  30. delete[] itemTypes;
  31. for (int i = 0; i < entityTypeCount; i++)
  32. entityTypes[i]->release();
  33. delete[] entityTypes;
  34. foregroundReader->lese((char*)&blockTypeCount, 4);
  35. blockTypes = new BlockType*[blockTypeCount];
  36. for (int i = 0; i < blockTypeCount; i++)
  37. {
  38. int id;
  39. foregroundReader->lese((char*)&id, 4);
  40. bool needsInstance;
  41. foregroundReader->lese((char*)&needsInstance, 1);
  42. int maxHp;
  43. foregroundReader->lese((char*)&maxHp, 4);
  44. blockTypes[i] = new BlockType(
  45. id, needsInstance, ModelInfo(foregroundReader), maxHp);
  46. }
  47. foregroundReader->lese((char*)&itemTypeCount, 4);
  48. itemTypes = new ItemType*[itemTypeCount];
  49. for (int i = 0; i < itemTypeCount; i++)
  50. {
  51. int id;
  52. foregroundReader->lese((char*)&id, 4);
  53. itemTypes[i] = new ItemType(id, ModelInfo(foregroundReader));
  54. }
  55. foregroundReader->lese((char*)&entityTypeCount, 4);
  56. entityTypes = new EntityType*[entityTypeCount];
  57. for (int i = 0; i < entityTypeCount; i++)
  58. {
  59. int id;
  60. foregroundReader->lese((char*)&id, 4);
  61. entityTypes[i] = new EntityType(id, ModelInfo(foregroundReader));
  62. }
  63. // pre rendering item models
  64. Kam3D* kam = new Kam3D();
  65. Welt3D* w = new Welt3D();
  66. w->addDiffuseLight(DiffuseLight{
  67. Vec3<float>(0.5f, 0.5f, -1.f), Vec3<float>(1.f, 1.f, 1.f)});
  68. kam->setWelt(w);
  69. kam->setBildschirmPosition(0, 0);
  70. kam->setBildschirmSize(50, 50);
  71. kam->setPosition(Vec3<float>(0, 0, 0));
  72. kam->setRotation({(float)PI / 2.f, 0.f, std::atan2(0.f, -1.f) + (float)PI / 2});
  73. Bild* b = new Bild();
  74. b->neuBild(50, 50, 0);
  75. for (int i = 0; i < itemTypeCount; i++)
  76. {
  77. Model3D* mdl = new Model3D();
  78. Model3DData* data = itemTypes[i]->getItemModel();
  79. if (data)
  80. {
  81. Vec3<float> min = data->getMinPos();
  82. Vec3<float> max = data->getMaxPos();
  83. float maxX = MAX(MAX(MAX(abs(min.x), abs(max.x)), MAX(abs(min.y), abs(max.y))), MAX(abs(min.z), abs(max.z)));
  84. kam->setPosition(Vec3<float>(maxX * 5, 0.f, 0.f));
  85. }
  86. mdl->setModelDaten(data);
  87. mdl->setModelTextur(itemTypes[i]->getItemTextur());
  88. mdl->setPosition(Vec3<float>(0.f, 0.f, 0.f));
  89. mdl->setDrehung(0.25f, 0.25f, 0.55f);
  90. w->addZeichnung(mdl);
  91. w->tick(0);
  92. window->zBildschirm()->lock();
  93. DX11Textur* t = (DX11Textur*)window->zBildschirm()
  94. ->zGraphicsApi()
  95. ->createOrGetTextur(
  96. Text("rendered/items/") + itemTypes[i]->getId(),
  97. dynamic_cast<Bild*>(b->getThis()));
  98. window->zBildschirm()->zGraphicsApi()->renderKamera(kam, t);
  99. Bild* result = new Bild();
  100. t->copyToImage(result);
  101. itemTypes[i]->setBild(result);
  102. t->release();
  103. window->zBildschirm()->unlock();
  104. w->removeZeichnung(mdl);
  105. }
  106. b->release();
  107. kam->release();
  108. }
  109. bool FactoryClient::connect(Text ip, unsigned short sslPort)
  110. {
  111. if (client) disconnect();
  112. client = new SSLKlient();
  113. if (!client->verbinde(sslPort, ip)) return false;
  114. this->ip = ip;
  115. return 1;
  116. }
  117. int FactoryClient::ping()
  118. {
  119. ZeitMesser zm;
  120. zm.messungStart();
  121. if (!client->sende("\3", 1)) return -1;
  122. char c;
  123. client->getNachricht(&c, 1);
  124. zm.messungEnde();
  125. return (int)(zm.getSekunden() * 1000);
  126. }
  127. int FactoryClient::status(Framework::Text name, Framework::Text secret)
  128. {
  129. if (!client->sende("\4", 1)) return 404;
  130. char c;
  131. client->getNachricht(&c, 1);
  132. if (c == 1)
  133. {
  134. char len = (char)name.getLength();
  135. client->sende(&len, 1);
  136. client->sende(name, len);
  137. short sLen = (short)secret.getLength();
  138. client->sende((char*)&sLen, 2);
  139. client->sende(secret, sLen);
  140. char res;
  141. client->getNachricht(&res, 1);
  142. if (res == 1) return 200;
  143. if (res == 0) return 403;
  144. }
  145. return 404;
  146. }
  147. int FactoryClient::join(
  148. Framework::Text name, Framework::Text& secret, unsigned short port)
  149. {
  150. client->sende("\1", 1);
  151. char len = (char)name.getLength();
  152. client->sende(&len, 1);
  153. client->sende(name, len);
  154. short sLen = (short)secret.getLength();
  155. client->sende((char*)&sLen, 2);
  156. client->sende(secret, sLen);
  157. char res;
  158. client->getNachricht(&res, 1);
  159. if (res == 1 || res == 2)
  160. {
  161. if (res == 2)
  162. {
  163. client->getNachricht((char*)&sLen, 2);
  164. char* buffer = new char[sLen + 1];
  165. client->getNachricht(buffer, sLen);
  166. buffer[sLen] = 0;
  167. secret = buffer;
  168. delete[] buffer;
  169. }
  170. short keyLen;
  171. client->getNachricht((char*)&keyLen, 2);
  172. char* key = new char[keyLen];
  173. client->getNachricht(key, keyLen);
  174. foreground = new Klient();
  175. if (!foreground->verbinde(port, ip))
  176. {
  177. delete[] key;
  178. return false;
  179. }
  180. if (!foreground->sende((char*)&keyLen, 2))
  181. {
  182. delete[] key;
  183. return false;
  184. }
  185. if (!foreground->sende(key, keyLen))
  186. {
  187. delete[] key;
  188. return false;
  189. }
  190. background = new Klient();
  191. if (!background->verbinde(port, ip))
  192. {
  193. delete[] key;
  194. foreground->release();
  195. foreground = 0;
  196. background->release();
  197. background = 0;
  198. return false;
  199. }
  200. if (!background->sende((char*)&keyLen, 2))
  201. {
  202. delete[] key;
  203. foreground->release();
  204. foreground = 0;
  205. background->release();
  206. background = 0;
  207. return false;
  208. }
  209. if (!background->sende(key, keyLen))
  210. {
  211. delete[] key;
  212. foreground->release();
  213. foreground = 0;
  214. background->release();
  215. background = 0;
  216. return false;
  217. }
  218. delete[] key;
  219. bool bg = 0;
  220. if (!foreground->sende((char*)&bg, 1))
  221. {
  222. delete[] key;
  223. return 201;
  224. }
  225. foregroundReader = new NetworkReader(foreground);
  226. bg = 1;
  227. if (!background->sende((char*)&bg, 1)) return 201;
  228. backgroundReader = new NetworkReader(background);
  229. char res;
  230. foregroundReader->lese(&res, 1);
  231. if (res != 1) return 403;
  232. backgroundReader->lese(&res, 1);
  233. if (res != 1) return 403;
  234. client->trenne();
  235. loadServerInfo();
  236. return 200;
  237. }
  238. if (res == 0) return 403;
  239. return 500;
  240. }
  241. void FactoryClient::disconnect()
  242. {
  243. if (client)
  244. {
  245. NetworkReader* fgReader = foregroundReader;
  246. NetworkReader* bgReader = backgroundReader;
  247. backgroundReader = 0;
  248. foregroundReader = 0;
  249. if (foreground) foreground->trenne();
  250. if (background) background->trenne();
  251. while (fgReaderUsage > 0 || bgReaderUsage > 0)
  252. Sleep(100);
  253. delete fgReader;
  254. delete bgReader;
  255. client->release();
  256. client = 0;
  257. if (foreground) foreground->release();
  258. foreground = 0;
  259. if (background) background->release();
  260. background = 0;
  261. }
  262. }
  263. NetworkReader* FactoryClient::getNextForegroundMessage()
  264. {
  265. fgReaderUsage++;
  266. if (!foreground) return 0;
  267. if (!foreground->hatNachricht(0)) return 0;
  268. return foregroundReader;
  269. }
  270. NetworkReader* FactoryClient::getNextBackgroundMessage()
  271. {
  272. bgReaderUsage++;
  273. if (!background) return 0;
  274. if (!background->hatNachricht(0)) return 0;
  275. return backgroundReader;
  276. }
  277. void FactoryClient::endMessageReading(bool bg)
  278. {
  279. if (bg)
  280. bgReaderUsage--;
  281. else
  282. fgReaderUsage--;
  283. }
  284. void FactoryClient::sendPlayerAction(char* data, unsigned short length)
  285. {
  286. if (!foreground) return;
  287. cs.lock();
  288. length += 1;
  289. foreground->sende((char*)&length, 2);
  290. char msgId = 2;
  291. foreground->sende(&msgId, 1);
  292. foreground->sende((char*)data, length - 1);
  293. cs.unlock();
  294. }
  295. void FactoryClient::sendPlayerMovement(MovementFrame& frame)
  296. {
  297. if (!foreground) return;
  298. cs.lock();
  299. short length = 38;
  300. foreground->sende((char*)&length, 2);
  301. char msgId = 2; // player message
  302. foreground->sende(&msgId, 1);
  303. foreground->sende(&msgId, 1); // set movement
  304. foreground->sende((char*)&frame.direction.x, 4);
  305. foreground->sende((char*)&frame.direction.y, 4);
  306. foreground->sende((char*)&frame.direction.z, 4);
  307. foreground->sende((char*)&frame.targetPosition.x, 4);
  308. foreground->sende((char*)&frame.targetPosition.y, 4);
  309. foreground->sende((char*)&frame.targetPosition.z, 4);
  310. foreground->sende((char*)&frame.movementFlags, 4);
  311. foreground->sende((char*)&frame.duration, 8);
  312. cs.unlock();
  313. }
  314. void FactoryClient::entityAPIRequest(
  315. int entityId, char* message, unsigned short length)
  316. {
  317. if (!foreground) return;
  318. cs.lock();
  319. length += 5;
  320. foreground->sende((char*)&length, 2);
  321. char msgId = 3;
  322. foreground->sende(&msgId, 1);
  323. foreground->sende((char*)&entityId, 4);
  324. foreground->sende(message, length - 5);
  325. cs.unlock();
  326. }
  327. void FactoryClient::chunkAPIRequest(
  328. Punkt center, char* message, unsigned short length)
  329. {
  330. length += 10;
  331. cs.lock();
  332. foreground->sende((char*)&length, 2);
  333. char type = 1;
  334. foreground->sende(&type, 1);
  335. type = 0;
  336. foreground->sende(&type, 1);
  337. foreground->sende((char*)&center.x, 4);
  338. foreground->sende((char*)&center.y, 4);
  339. foreground->sende(message, length - 10);
  340. cs.unlock();
  341. }
  342. void FactoryClient::inventoryAPIRequest(
  343. Framework::Either<int, Framework::VecN<int, 4>> target,
  344. char* message,
  345. unsigned short length)
  346. {
  347. if (!foreground) return;
  348. cs.lock();
  349. length += target.isA() ? 6 : 18;
  350. foreground->sende((char*)&length, 2);
  351. char msgId = 4;
  352. foreground->sende(&msgId, 1);
  353. bool isEntity = target.isA();
  354. foreground->sende((char*)&isEntity, 1);
  355. if (target.isA())
  356. {
  357. int id = target.getA();
  358. foreground->sende((char*)&id, 4);
  359. }
  360. else
  361. {
  362. for (int i = 0; i < 4; i++)
  363. {
  364. int v = target.getB()[i];
  365. foreground->sende((char*)&v, 4);
  366. }
  367. }
  368. foreground->sende(message, length - (target.isA() ? 6 : 18));
  369. cs.unlock();
  370. }
  371. bool FactoryClient::isConnected()
  372. {
  373. return foreground->isConnected() && background->isConnected();
  374. }