Client.cpp 23 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809
  1. /*
  2. * Client.cpp, part of VCMI engine
  3. *
  4. * Authors: listed in file AUTHORS in main folder
  5. *
  6. * License: GNU General Public License v2.0 or later
  7. * Full text of license available in license.txt file, in main folder
  8. *
  9. */
  10. #include "StdInc.h"
  11. #include "Client.h"
  12. #include <SDL.h>
  13. #include "CMusicHandler.h"
  14. #include "../lib/mapping/CCampaignHandler.h"
  15. #include "../CCallback.h"
  16. #include "../lib/CConsoleHandler.h"
  17. #include "CGameInfo.h"
  18. #include "../lib/CGameState.h"
  19. #include "CPlayerInterface.h"
  20. #include "../lib/StartInfo.h"
  21. #include "../lib/battle/BattleInfo.h"
  22. #include "../lib/CModHandler.h"
  23. #include "../lib/CArtHandler.h"
  24. #include "../lib/CGeneralTextHandler.h"
  25. #include "../lib/CHeroHandler.h"
  26. #include "../lib/CTownHandler.h"
  27. #include "../lib/CBuildingHandler.h"
  28. #include "../lib/spells/CSpellHandler.h"
  29. #include "../lib/serializer/CTypeList.h"
  30. #include "../lib/serializer/Connection.h"
  31. #include "../lib/serializer/CLoadIntegrityValidator.h"
  32. #include "../lib/NetPacks.h"
  33. #include "../lib/VCMI_Lib.h"
  34. #include "../lib/VCMIDirs.h"
  35. #include "../lib/mapping/CMap.h"
  36. #include "../lib/mapping/CMapService.h"
  37. #include "../lib/JsonNode.h"
  38. #include "mapHandler.h"
  39. #include "../lib/CConfigHandler.h"
  40. #include "mainmenu/CMainMenu.h"
  41. #include "mainmenu/CCampaignScreen.h"
  42. #include "lobby/CBonusSelection.h"
  43. #include "battle/CBattleInterface.h"
  44. #include "../lib/CThreadHelper.h"
  45. #include "../lib/registerTypes/RegisterTypes.h"
  46. #include "gui/CGuiHandler.h"
  47. #include "CMT.h"
  48. #include "CServerHandler.h"
  49. #include "../lib/ScriptHandler.h"
  50. #include <vcmi/events/EventBus.h>
  51. #ifdef VCMI_ANDROID
  52. #include "lib/CAndroidVMHelper.h"
  53. #endif
  54. #ifdef VCMI_ANDROID
  55. std::atomic_bool androidTestServerReadyFlag;
  56. #endif
  57. ThreadSafeVector<int> CClient::waitingRequest;
  58. template<typename T> class CApplyOnCL;
  59. class CBaseForCLApply
  60. {
  61. public:
  62. virtual void applyOnClAfter(CClient * cl, void * pack) const =0;
  63. virtual void applyOnClBefore(CClient * cl, void * pack) const =0;
  64. virtual ~CBaseForCLApply(){}
  65. template<typename U> static CBaseForCLApply * getApplier(const U * t = nullptr)
  66. {
  67. return new CApplyOnCL<U>();
  68. }
  69. };
  70. template<typename T> class CApplyOnCL : public CBaseForCLApply
  71. {
  72. public:
  73. void applyOnClAfter(CClient * cl, void * pack) const override
  74. {
  75. T * ptr = static_cast<T *>(pack);
  76. ptr->applyCl(cl);
  77. }
  78. void applyOnClBefore(CClient * cl, void * pack) const override
  79. {
  80. T * ptr = static_cast<T *>(pack);
  81. ptr->applyFirstCl(cl);
  82. }
  83. };
  84. template<> class CApplyOnCL<CPack>: public CBaseForCLApply
  85. {
  86. public:
  87. void applyOnClAfter(CClient * cl, void * pack) const override
  88. {
  89. logGlobal->error("Cannot apply on CL plain CPack!");
  90. assert(0);
  91. }
  92. void applyOnClBefore(CClient * cl, void * pack) const override
  93. {
  94. logGlobal->error("Cannot apply on CL plain CPack!");
  95. assert(0);
  96. }
  97. };
  98. CPlayerEnvironment::CPlayerEnvironment(PlayerColor player_, CClient * cl_, std::shared_ptr<CCallback> mainCallback_)
  99. : player(player_),
  100. cl(cl_),
  101. mainCallback(mainCallback_)
  102. {
  103. }
  104. const Services * CPlayerEnvironment::services() const
  105. {
  106. return VLC;
  107. }
  108. vstd::CLoggerBase * CPlayerEnvironment::logger() const
  109. {
  110. return logGlobal;
  111. }
  112. events::EventBus * CPlayerEnvironment::eventBus() const
  113. {
  114. return cl->eventBus();//always get actual value
  115. }
  116. const CPlayerEnvironment::BattleCb * CPlayerEnvironment::battle() const
  117. {
  118. return mainCallback.get();
  119. }
  120. const CPlayerEnvironment::GameCb * CPlayerEnvironment::game() const
  121. {
  122. return mainCallback.get();
  123. }
  124. CClient::CClient()
  125. {
  126. waitingRequest.clear();
  127. applier = std::make_shared<CApplier<CBaseForCLApply>>();
  128. registerTypesClientPacks1(*applier);
  129. registerTypesClientPacks2(*applier);
  130. IObjectInterface::cb = this;
  131. gs = nullptr;
  132. }
  133. CClient::~CClient()
  134. {
  135. IObjectInterface::cb = nullptr;
  136. }
  137. const Services * CClient::services() const
  138. {
  139. return VLC; //todo: this should be CGI
  140. }
  141. const CClient::BattleCb * CClient::battle() const
  142. {
  143. return this;
  144. }
  145. const CClient::GameCb * CClient::game() const
  146. {
  147. return this;
  148. }
  149. vstd::CLoggerBase * CClient::logger() const
  150. {
  151. return logGlobal;
  152. }
  153. events::EventBus * CClient::eventBus() const
  154. {
  155. return clientEventBus.get();
  156. }
  157. void CClient::newGame(CGameState * initializedGameState)
  158. {
  159. CSH->th->update();
  160. CMapService mapService;
  161. gs = initializedGameState ? initializedGameState : new CGameState();
  162. gs->preInit(VLC);
  163. logNetwork->trace("\tCreating gamestate: %i", CSH->th->getDiff());
  164. if(!initializedGameState)
  165. gs->init(&mapService, CSH->si.get(), settings["general"]["saveRandomMaps"].Bool());
  166. logNetwork->trace("Initializing GameState (together): %d ms", CSH->th->getDiff());
  167. initMapHandler();
  168. reinitScripting();
  169. initPlayerEnvironments();
  170. initPlayerInterfaces();
  171. }
  172. void CClient::loadGame(CGameState * initializedGameState)
  173. {
  174. logNetwork->info("Loading procedure started!");
  175. std::unique_ptr<CLoadFile> loader;
  176. if(initializedGameState)
  177. {
  178. logNetwork->info("Game state was transferred over network, loading.");
  179. gs = initializedGameState;
  180. }
  181. else
  182. {
  183. try
  184. {
  185. boost::filesystem::path clientSaveName = *CResourceHandler::get("local")->getResourceName(ResourceID(CSH->si->mapname, EResType::CLIENT_SAVEGAME));
  186. boost::filesystem::path controlServerSaveName;
  187. if(CResourceHandler::get("local")->existsResource(ResourceID(CSH->si->mapname, EResType::SERVER_SAVEGAME)))
  188. {
  189. controlServerSaveName = *CResourceHandler::get("local")->getResourceName(ResourceID(CSH->si->mapname, EResType::SERVER_SAVEGAME));
  190. }
  191. else // create entry for server savegame. Triggered if save was made after launch and not yet present in res handler
  192. {
  193. controlServerSaveName = boost::filesystem::path(clientSaveName).replace_extension(".vsgm1");
  194. CResourceHandler::get("local")->createResource(controlServerSaveName.string(), true);
  195. }
  196. if(clientSaveName.empty())
  197. throw std::runtime_error("Cannot open client part of " + CSH->si->mapname);
  198. if(controlServerSaveName.empty() || !boost::filesystem::exists(controlServerSaveName))
  199. throw std::runtime_error("Cannot open server part of " + CSH->si->mapname);
  200. {
  201. CLoadIntegrityValidator checkingLoader(clientSaveName, controlServerSaveName, MINIMAL_SERIALIZATION_VERSION);
  202. loadCommonState(checkingLoader);
  203. loader = checkingLoader.decay();
  204. }
  205. }
  206. catch(std::exception & e)
  207. {
  208. logGlobal->error("Cannot load game %s. Error: %s", CSH->si->mapname, e.what());
  209. throw; //obviously we cannot continue here
  210. }
  211. logNetwork->trace("Loaded common part of save %d ms", CSH->th->getDiff());
  212. }
  213. gs->preInit(VLC);
  214. gs->updateOnLoad(CSH->si.get());
  215. logNetwork->info("Game loaded, initialize interfaces.");
  216. initMapHandler();
  217. reinitScripting();
  218. initPlayerEnvironments();
  219. if(loader)
  220. serialize(loader->serializer, loader->serializer.fileVersion);
  221. initPlayerInterfaces();
  222. }
  223. void CClient::serialize(BinarySerializer & h, const int version)
  224. {
  225. assert(h.saving);
  226. ui8 players = static_cast<ui8>(playerint.size());
  227. h & players;
  228. for(auto i = playerint.begin(); i != playerint.end(); i++)
  229. {
  230. logGlobal->trace("Saving player %s interface", i->first);
  231. assert(i->first == i->second->playerID);
  232. h & i->first;
  233. h & i->second->dllName;
  234. h & i->second->human;
  235. i->second->saveGame(h, version);
  236. }
  237. #if SCRIPTING_ENABLED
  238. if(version >= 800)
  239. {
  240. JsonNode scriptsState;
  241. clientScripts->serializeState(h.saving, scriptsState);
  242. h & scriptsState;
  243. }
  244. #endif
  245. }
  246. void CClient::serialize(BinaryDeserializer & h, const int version)
  247. {
  248. assert(!h.saving);
  249. ui8 players = 0;
  250. h & players;
  251. for(int i = 0; i < players; i++)
  252. {
  253. std::string dllname;
  254. PlayerColor pid;
  255. bool isHuman = false;
  256. auto prevInt = LOCPLINT;
  257. h & pid;
  258. h & dllname;
  259. h & isHuman;
  260. assert(dllname.length() == 0 || !isHuman);
  261. if(pid == PlayerColor::NEUTRAL)
  262. {
  263. logGlobal->trace("Neutral battle interfaces are not serialized.");
  264. continue;
  265. }
  266. logGlobal->trace("Loading player %s interface", pid);
  267. std::shared_ptr<CGameInterface> nInt;
  268. if(dllname.length())
  269. nInt = CDynLibHandler::getNewAI(dllname);
  270. else
  271. nInt = std::make_shared<CPlayerInterface>(pid);
  272. nInt->dllName = dllname;
  273. nInt->human = isHuman;
  274. nInt->playerID = pid;
  275. nInt->loadGame(h, version);
  276. // Client no longer handle this player at all
  277. if(!vstd::contains(CSH->getAllClientPlayers(CSH->c->connectionID), pid))
  278. {
  279. logGlobal->trace("Player %s is not belong to this client. Destroying interface", pid);
  280. }
  281. else if(isHuman && !vstd::contains(CSH->getHumanColors(), pid))
  282. {
  283. logGlobal->trace("Player %s is no longer controlled by human. Destroying interface", pid);
  284. }
  285. else if(!isHuman && vstd::contains(CSH->getHumanColors(), pid))
  286. {
  287. logGlobal->trace("Player %s is no longer controlled by AI. Destroying interface", pid);
  288. }
  289. else
  290. {
  291. installNewPlayerInterface(nInt, pid);
  292. continue;
  293. }
  294. nInt.reset();
  295. LOCPLINT = prevInt;
  296. }
  297. #if SCRIPTING_ENABLED
  298. {
  299. JsonNode scriptsState;
  300. h & scriptsState;
  301. clientScripts->serializeState(h.saving, scriptsState);
  302. }
  303. #endif
  304. logNetwork->trace("Loaded client part of save %d ms", CSH->th->getDiff());
  305. }
  306. void CClient::save(const std::string & fname)
  307. {
  308. if(gs->curB)
  309. {
  310. logNetwork->error("Game cannot be saved during battle!");
  311. return;
  312. }
  313. SaveGame save_game(fname);
  314. sendRequest(&save_game, PlayerColor::NEUTRAL);
  315. }
  316. void CClient::endGame()
  317. {
  318. #if SCRIPTING_ENABLED
  319. clientScripts.reset();
  320. #endif
  321. //suggest interfaces to finish their stuff (AI should interrupt any bg working threads)
  322. for(auto & i : playerint)
  323. i.second->finish();
  324. GH.curInt = nullptr;
  325. {
  326. boost::unique_lock<boost::recursive_mutex> un(*CPlayerInterface::pim);
  327. logNetwork->info("Ending current game!");
  328. if(GH.topInt())
  329. {
  330. GH.topInt()->deactivate();
  331. }
  332. GH.listInt.clear();
  333. GH.objsToBlit.clear();
  334. GH.statusbar = nullptr;
  335. logNetwork->info("Removed GUI.");
  336. vstd::clear_pointer(const_cast<CGameInfo *>(CGI)->mh);
  337. vstd::clear_pointer(gs);
  338. logNetwork->info("Deleted mapHandler and gameState.");
  339. LOCPLINT = nullptr;
  340. }
  341. playerint.clear();
  342. battleints.clear();
  343. battleCallbacks.clear();
  344. playerEnvironments.clear();
  345. logNetwork->info("Deleted playerInts.");
  346. logNetwork->info("Client stopped.");
  347. }
  348. void CClient::processDisconnectedPlayers()
  349. {
  350. if(!gs || !disconnectedPlayers.count(gs->currentPlayer))
  351. return;
  352. LOCPLINT->showYesNoDialog("Waiting for player. Press Ok to save & end, cancel to kick that player",
  353. [](){}, [](){});
  354. }
  355. void CClient::initMapHandler()
  356. {
  357. // TODO: CMapHandler initialization can probably go somewhere else
  358. // It's can't be before initialization of interfaces
  359. // During loading CPlayerInterface from serialized state it's depend on MH
  360. if(!settings["session"]["headless"].Bool())
  361. {
  362. const_cast<CGameInfo *>(CGI)->mh = new CMapHandler();
  363. CGI->mh->map = gs->map;
  364. logNetwork->trace("Creating mapHandler: %d ms", CSH->th->getDiff());
  365. CGI->mh->init();
  366. logNetwork->trace("Initializing mapHandler (together): %d ms", CSH->th->getDiff());
  367. }
  368. pathCache.clear();
  369. }
  370. void CClient::initPlayerEnvironments()
  371. {
  372. playerEnvironments.clear();
  373. auto allPlayers = CSH->getAllClientPlayers(CSH->c->connectionID);
  374. for(auto & color : allPlayers)
  375. {
  376. logNetwork->info("Preparing environment for player %s", color.getStr());
  377. playerEnvironments[color] = std::make_shared<CPlayerEnvironment>(color, this, std::make_shared<CCallback>(gs, color, this));
  378. }
  379. if(settings["session"]["spectate"].Bool())
  380. {
  381. playerEnvironments[PlayerColor::SPECTATOR] = std::make_shared<CPlayerEnvironment>(PlayerColor::SPECTATOR, this, std::make_shared<CCallback>(gs, boost::none, this));
  382. }
  383. }
  384. void CClient::initPlayerInterfaces()
  385. {
  386. for(auto & elem : gs->scenarioOps->playerInfos)
  387. {
  388. PlayerColor color = elem.first;
  389. if(!vstd::contains(CSH->getAllClientPlayers(CSH->c->connectionID), color))
  390. continue;
  391. if(!vstd::contains(playerint, color))
  392. {
  393. logNetwork->info("Preparing interface for player %s", color.getStr());
  394. if(elem.second.isControlledByAI())
  395. {
  396. auto AiToGive = aiNameForPlayer(elem.second, false);
  397. logNetwork->info("Player %s will be lead by %s", color.getStr(), AiToGive);
  398. installNewPlayerInterface(CDynLibHandler::getNewAI(AiToGive), color);
  399. }
  400. else
  401. {
  402. logNetwork->info("Player %s will be lead by human", color.getStr());
  403. installNewPlayerInterface(std::make_shared<CPlayerInterface>(color), color);
  404. }
  405. }
  406. }
  407. if(settings["session"]["spectate"].Bool())
  408. {
  409. installNewPlayerInterface(std::make_shared<CPlayerInterface>(PlayerColor::SPECTATOR), PlayerColor::SPECTATOR, true);
  410. }
  411. if(CSH->getAllClientPlayers(CSH->c->connectionID).count(PlayerColor::NEUTRAL))
  412. installNewBattleInterface(CDynLibHandler::getNewBattleAI(settings["server"]["neutralAI"].String()), PlayerColor::NEUTRAL);
  413. logNetwork->trace("Initialized player interfaces %d ms", CSH->th->getDiff());
  414. }
  415. std::string CClient::aiNameForPlayer(const PlayerSettings & ps, bool battleAI)
  416. {
  417. if(ps.name.size())
  418. {
  419. const boost::filesystem::path aiPath = VCMIDirs::get().fullLibraryPath("AI", ps.name);
  420. if(boost::filesystem::exists(aiPath))
  421. return ps.name;
  422. }
  423. return aiNameForPlayer(battleAI);
  424. }
  425. std::string CClient::aiNameForPlayer(bool battleAI)
  426. {
  427. const int sensibleAILimit = settings["session"]["oneGoodAI"].Bool() ? 1 : PlayerColor::PLAYER_LIMIT_I;
  428. std::string goodAI = battleAI ? settings["server"]["neutralAI"].String() : settings["server"]["playerAI"].String();
  429. std::string badAI = battleAI ? "StupidAI" : "EmptyAI";
  430. //TODO what about human players
  431. if(battleints.size() >= sensibleAILimit)
  432. return badAI;
  433. return goodAI;
  434. }
  435. void CClient::installNewPlayerInterface(std::shared_ptr<CGameInterface> gameInterface, PlayerColor color, bool battlecb)
  436. {
  437. boost::unique_lock<boost::recursive_mutex> un(*CPlayerInterface::pim);
  438. playerint[color] = gameInterface;
  439. logGlobal->trace("\tInitializing the interface for player %s", color.getStr());
  440. auto cb = std::make_shared<CCallback>(gs, color, this);
  441. battleCallbacks[color] = cb;
  442. gameInterface->init(playerEnvironments.at(color), cb);
  443. installNewBattleInterface(gameInterface, color, battlecb);
  444. }
  445. void CClient::installNewBattleInterface(std::shared_ptr<CBattleGameInterface> battleInterface, PlayerColor color, bool needCallback)
  446. {
  447. boost::unique_lock<boost::recursive_mutex> un(*CPlayerInterface::pim);
  448. battleints[color] = battleInterface;
  449. if(needCallback)
  450. {
  451. logGlobal->trace("\tInitializing the battle interface for player %s", color.getStr());
  452. auto cbc = std::make_shared<CBattleCallback>(color, this);
  453. battleCallbacks[color] = cbc;
  454. battleInterface->init(playerEnvironments.at(color), cbc);
  455. }
  456. }
  457. void CClient::handlePack(CPack * pack)
  458. {
  459. CBaseForCLApply * apply = applier->getApplier(typeList.getTypeID(pack)); //find the applier
  460. if(apply)
  461. {
  462. boost::unique_lock<boost::recursive_mutex> guiLock(*CPlayerInterface::pim);
  463. apply->applyOnClBefore(this, pack);
  464. logNetwork->trace("\tMade first apply on cl: %s", typeList.getTypeInfo(pack)->name());
  465. gs->apply(pack);
  466. logNetwork->trace("\tApplied on gs: %s", typeList.getTypeInfo(pack)->name());
  467. apply->applyOnClAfter(this, pack);
  468. logNetwork->trace("\tMade second apply on cl: %s", typeList.getTypeInfo(pack)->name());
  469. }
  470. else
  471. {
  472. logNetwork->error("Message %s cannot be applied, cannot find applier!", typeList.getTypeInfo(pack)->name());
  473. }
  474. delete pack;
  475. }
  476. int CClient::sendRequest(const CPackForServer * request, PlayerColor player)
  477. {
  478. static ui32 requestCounter = 0;
  479. ui32 requestID = requestCounter++;
  480. logNetwork->trace("Sending a request \"%s\". It'll have an ID=%d.", typeid(*request).name(), requestID);
  481. waitingRequest.pushBack(requestID);
  482. request->requestID = requestID;
  483. request->player = player;
  484. CSH->c->sendPack(request);
  485. if(vstd::contains(playerint, player))
  486. playerint[player]->requestSent(request, requestID);
  487. return requestID;
  488. }
  489. void CClient::battleStarted(const BattleInfo * info)
  490. {
  491. setBattle(info);
  492. for(auto & battleCb : battleCallbacks)
  493. {
  494. if(vstd::contains_if(info->sides, [&](const SideInBattle& side) {return side.color == battleCb.first; })
  495. || battleCb.first >= PlayerColor::PLAYER_LIMIT)
  496. {
  497. battleCb.second->setBattle(info);
  498. }
  499. }
  500. std::shared_ptr<CPlayerInterface> att, def;
  501. auto & leftSide = info->sides[0], & rightSide = info->sides[1];
  502. //If quick combat is not, do not prepare interfaces for battleint
  503. if(!settings["adventure"]["quickCombat"].Bool())
  504. {
  505. if(vstd::contains(playerint, leftSide.color) && playerint[leftSide.color]->human)
  506. att = std::dynamic_pointer_cast<CPlayerInterface>(playerint[leftSide.color]);
  507. if(vstd::contains(playerint, rightSide.color) && playerint[rightSide.color]->human)
  508. def = std::dynamic_pointer_cast<CPlayerInterface>(playerint[rightSide.color]);
  509. }
  510. if(!settings["session"]["headless"].Bool())
  511. {
  512. Rect battleIntRect((screen->w - 800)/2, (screen->h - 600)/2, 800, 600);
  513. if(!!att || !!def)
  514. {
  515. boost::unique_lock<boost::recursive_mutex> un(*CPlayerInterface::pim);
  516. GH.pushIntT<CBattleInterface>(leftSide.armyObject, rightSide.armyObject, leftSide.hero, rightSide.hero, battleIntRect, att, def);
  517. }
  518. else if(settings["session"]["spectate"].Bool() && !settings["session"]["spectate-skip-battle"].Bool())
  519. {
  520. //TODO: This certainly need improvement
  521. auto spectratorInt = std::dynamic_pointer_cast<CPlayerInterface>(playerint[PlayerColor::SPECTATOR]);
  522. spectratorInt->cb->setBattle(info);
  523. boost::unique_lock<boost::recursive_mutex> un(*CPlayerInterface::pim);
  524. GH.pushIntT<CBattleInterface>(leftSide.armyObject, rightSide.armyObject, leftSide.hero, rightSide.hero, battleIntRect, att, def, spectratorInt);
  525. }
  526. }
  527. auto callBattleStart = [&](PlayerColor color, ui8 side)
  528. {
  529. if(vstd::contains(battleints, color))
  530. battleints[color]->battleStart(leftSide.armyObject, rightSide.armyObject, info->tile, leftSide.hero, rightSide.hero, side);
  531. };
  532. callBattleStart(leftSide.color, 0);
  533. callBattleStart(rightSide.color, 1);
  534. callBattleStart(PlayerColor::UNFLAGGABLE, 1);
  535. if(settings["session"]["spectate"].Bool() && !settings["session"]["spectate-skip-battle"].Bool())
  536. callBattleStart(PlayerColor::SPECTATOR, 1);
  537. if(info->tacticDistance && vstd::contains(battleints, info->sides[info->tacticsSide].color))
  538. {
  539. boost::thread(&CClient::commenceTacticPhaseForInt, this, battleints[info->sides[info->tacticsSide].color]);
  540. }
  541. }
  542. void CClient::commenceTacticPhaseForInt(std::shared_ptr<CBattleGameInterface> battleInt)
  543. {
  544. setThreadName("CClient::commenceTacticPhaseForInt");
  545. try
  546. {
  547. battleInt->yourTacticPhase(gs->curB->tacticDistance);
  548. if(gs && !!gs->curB && gs->curB->tacticDistance) //while awaiting for end of tactics phase, many things can happen (end of battle... or game)
  549. {
  550. MakeAction ma(BattleAction::makeEndOFTacticPhase(gs->curB->playerToSide(battleInt->playerID).get()));
  551. sendRequest(&ma, battleInt->playerID);
  552. }
  553. }
  554. catch(...)
  555. {
  556. handleException();
  557. }
  558. }
  559. void CClient::battleFinished()
  560. {
  561. stopAllBattleActions();
  562. for(auto & side : gs->curB->sides)
  563. if(battleCallbacks.count(side.color))
  564. battleCallbacks[side.color]->setBattle(nullptr);
  565. if(settings["session"]["spectate"].Bool() && !settings["session"]["spectate-skip-battle"].Bool())
  566. battleCallbacks[PlayerColor::SPECTATOR]->setBattle(nullptr);
  567. setBattle(nullptr);
  568. }
  569. void CClient::startPlayerBattleAction(PlayerColor color)
  570. {
  571. stopPlayerBattleAction(color);
  572. if(vstd::contains(battleints, color))
  573. {
  574. auto thread = std::make_shared<boost::thread>(std::bind(&CClient::waitForMoveAndSend, this, color));
  575. playerActionThreads[color] = thread;
  576. }
  577. }
  578. void CClient::stopPlayerBattleAction(PlayerColor color)
  579. {
  580. if(vstd::contains(playerActionThreads, color))
  581. {
  582. auto thread = playerActionThreads.at(color);
  583. if(thread->joinable())
  584. {
  585. thread->interrupt();
  586. thread->join();
  587. }
  588. playerActionThreads.erase(color);
  589. }
  590. }
  591. void CClient::stopAllBattleActions()
  592. {
  593. while(!playerActionThreads.empty())
  594. stopPlayerBattleAction(playerActionThreads.begin()->first);
  595. }
  596. void CClient::waitForMoveAndSend(PlayerColor color)
  597. {
  598. try
  599. {
  600. setThreadName("CClient::waitForMoveAndSend");
  601. assert(vstd::contains(battleints, color));
  602. BattleAction ba = battleints[color]->activeStack(gs->curB->battleGetStackByID(gs->curB->activeStack, false));
  603. if(ba.actionType != EActionType::CANCEL)
  604. {
  605. logNetwork->trace("Send battle action to server: %s", ba.toString());
  606. MakeAction temp_action(ba);
  607. sendRequest(&temp_action, color);
  608. }
  609. }
  610. catch(boost::thread_interrupted &)
  611. {
  612. logNetwork->debug("Wait for move thread was interrupted and no action will be send. Was a battle ended by spell?");
  613. }
  614. catch(...)
  615. {
  616. handleException();
  617. }
  618. }
  619. void CClient::invalidatePaths()
  620. {
  621. boost::unique_lock<boost::mutex> pathLock(pathCacheMutex);
  622. pathCache.clear();
  623. }
  624. std::shared_ptr<const CPathsInfo> CClient::getPathsInfo(const CGHeroInstance * h)
  625. {
  626. assert(h);
  627. boost::unique_lock<boost::mutex> pathLock(pathCacheMutex);
  628. auto iter = pathCache.find(h);
  629. if(iter == std::end(pathCache))
  630. {
  631. std::shared_ptr<CPathsInfo> paths = std::make_shared<CPathsInfo>(getMapSize(), h);
  632. gs->calculatePaths(h, *paths.get());
  633. pathCache[h] = paths;
  634. return paths;
  635. }
  636. else
  637. {
  638. return iter->second;
  639. }
  640. }
  641. PlayerColor CClient::getLocalPlayer() const
  642. {
  643. if(LOCPLINT)
  644. return LOCPLINT->playerID;
  645. return getCurrentPlayer();
  646. }
  647. #if SCRIPTING_ENABLED
  648. scripting::Pool * CClient::getGlobalContextPool() const
  649. {
  650. return clientScripts.get();
  651. }
  652. scripting::Pool * CClient::getContextPool() const
  653. {
  654. return clientScripts.get();
  655. }
  656. #endif
  657. void CClient::reinitScripting()
  658. {
  659. clientEventBus = make_unique<events::EventBus>();
  660. #if SCRIPTING_ENABLED
  661. clientScripts.reset(new scripting::PoolImpl(this));
  662. #endif
  663. }
  664. #ifdef VCMI_ANDROID
  665. extern "C" JNIEXPORT void JNICALL Java_eu_vcmi_vcmi_NativeMethods_notifyServerClosed(JNIEnv * env, jobject cls)
  666. {
  667. logNetwork->info("Received server closed signal");
  668. if (CSH) {
  669. CSH->campaignServerRestartLock.setn(false);
  670. }
  671. }
  672. extern "C" JNIEXPORT void JNICALL Java_eu_vcmi_vcmi_NativeMethods_notifyServerReady(JNIEnv * env, jobject cls)
  673. {
  674. logNetwork->info("Received server ready signal");
  675. androidTestServerReadyFlag.store(true);
  676. }
  677. extern "C" JNIEXPORT bool JNICALL Java_eu_vcmi_vcmi_NativeMethods_tryToSaveTheGame(JNIEnv * env, jobject cls)
  678. {
  679. logGlobal->info("Received emergency save game request");
  680. if(!LOCPLINT || !LOCPLINT->cb)
  681. {
  682. return false;
  683. }
  684. LOCPLINT->cb->save("Saves/_Android_Autosave");
  685. return true;
  686. }
  687. #endif