FactoryClient.cpp 12 KB

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