NetPacksClient.cpp 33 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976
  1. /*
  2. * NetPacksClient.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 "ClientNetPackVisitors.h"
  12. #include "Client.h"
  13. #include "CPlayerInterface.h"
  14. #include "CGameInfo.h"
  15. #include "windows/GUIClasses.h"
  16. #include "mapView/mapHandler.h"
  17. #include "adventureMap/CInGameConsole.h"
  18. #include "battle/BattleInterface.h"
  19. #include "gui/CGuiHandler.h"
  20. #include "widgets/MiscWidgets.h"
  21. #include "CMT.h"
  22. #include "CServerHandler.h"
  23. #include "../CCallback.h"
  24. #include "../lib/filesystem/Filesystem.h"
  25. #include "../lib/filesystem/FileInfo.h"
  26. #include "../lib/serializer/Connection.h"
  27. #include "../lib/serializer/BinarySerializer.h"
  28. #include "../lib/CGeneralTextHandler.h"
  29. #include "../lib/CHeroHandler.h"
  30. #include "../lib/VCMI_Lib.h"
  31. #include "../lib/mapping/CMap.h"
  32. #include "../lib/VCMIDirs.h"
  33. #include "../lib/spells/CSpellHandler.h"
  34. #include "../lib/CSoundBase.h"
  35. #include "../lib/StartInfo.h"
  36. #include "../lib/CConfigHandler.h"
  37. #include "../lib/mapping/CCampaignHandler.h"
  38. #include "../lib/CGameState.h"
  39. #include "../lib/CStack.h"
  40. #include "../lib/battle/BattleInfo.h"
  41. #include "../lib/GameConstants.h"
  42. #include "../lib/CPlayerState.h"
  43. // TODO: as Tow suggested these template should all be part of CClient
  44. // This will require rework spectator interface properly though
  45. template<typename T, typename ... Args, typename ... Args2>
  46. bool callOnlyThatInterface(CClient & cl, PlayerColor player, void (T::*ptr)(Args...), Args2 && ...args)
  47. {
  48. if(vstd::contains(cl.playerint, player))
  49. {
  50. ((*cl.playerint[player]).*ptr)(std::forward<Args2>(args)...);
  51. return true;
  52. }
  53. return false;
  54. }
  55. template<typename T, typename ... Args, typename ... Args2>
  56. bool callInterfaceIfPresent(CClient & cl, PlayerColor player, void (T::*ptr)(Args...), Args2 && ...args)
  57. {
  58. bool called = callOnlyThatInterface(cl, player, ptr, std::forward<Args2>(args)...);
  59. return called;
  60. }
  61. template<typename T, typename ... Args, typename ... Args2>
  62. void callOnlyThatBattleInterface(CClient & cl, PlayerColor player, void (T::*ptr)(Args...), Args2 && ...args)
  63. {
  64. if(vstd::contains(cl.battleints,player))
  65. ((*cl.battleints[player]).*ptr)(std::forward<Args2>(args)...);
  66. if(cl.additionalBattleInts.count(player))
  67. {
  68. for(auto bInt : cl.additionalBattleInts[player])
  69. ((*bInt).*ptr)(std::forward<Args2>(args)...);
  70. }
  71. }
  72. template<typename T, typename ... Args, typename ... Args2>
  73. void callBattleInterfaceIfPresent(CClient & cl, PlayerColor player, void (T::*ptr)(Args...), Args2 && ...args)
  74. {
  75. callOnlyThatInterface(cl, player, ptr, std::forward<Args2>(args)...);
  76. }
  77. //calls all normal interfaces and privileged ones, playerints may be updated when iterating over it, so we need a copy
  78. template<typename T, typename ... Args, typename ... Args2>
  79. void callAllInterfaces(CClient & cl, void (T::*ptr)(Args...), Args2 && ...args)
  80. {
  81. for(auto pInt : cl.playerint)
  82. ((*pInt.second).*ptr)(std::forward<Args2>(args)...);
  83. }
  84. //calls all normal interfaces and privileged ones, playerints may be updated when iterating over it, so we need a copy
  85. template<typename T, typename ... Args, typename ... Args2>
  86. void callBattleInterfaceIfPresentForBothSides(CClient & cl, void (T::*ptr)(Args...), Args2 && ...args)
  87. {
  88. callOnlyThatBattleInterface(cl, cl.gameState()->curB->sides[0].color, ptr, std::forward<Args2>(args)...);
  89. callOnlyThatBattleInterface(cl, cl.gameState()->curB->sides[1].color, ptr, std::forward<Args2>(args)...);
  90. if(settings["session"]["spectate"].Bool() && !settings["session"]["spectate-skip-battle"].Bool() && LOCPLINT->battleInt)
  91. {
  92. callOnlyThatBattleInterface(cl, PlayerColor::SPECTATOR, ptr, std::forward<Args2>(args)...);
  93. }
  94. }
  95. void ApplyClientNetPackVisitor::visitSetResources(SetResources & pack)
  96. {
  97. //todo: inform on actual resource set transfered
  98. callInterfaceIfPresent(cl, pack.player, &IGameEventsReceiver::receivedResource);
  99. }
  100. void ApplyClientNetPackVisitor::visitSetPrimSkill(SetPrimSkill & pack)
  101. {
  102. const CGHeroInstance * h = cl.getHero(pack.id);
  103. if(!h)
  104. {
  105. logNetwork->error("Cannot find hero with pack.id %d", pack.id.getNum());
  106. return;
  107. }
  108. callInterfaceIfPresent(cl, h->tempOwner, &IGameEventsReceiver::heroPrimarySkillChanged, h, pack.which, pack.val);
  109. }
  110. void ApplyClientNetPackVisitor::visitSetSecSkill(SetSecSkill & pack)
  111. {
  112. const CGHeroInstance *h = cl.getHero(pack.id);
  113. if(!h)
  114. {
  115. logNetwork->error("Cannot find hero with pack.id %d", pack.id.getNum());
  116. return;
  117. }
  118. callInterfaceIfPresent(cl, h->tempOwner, &IGameEventsReceiver::heroSecondarySkillChanged, h, pack.which, pack.val);
  119. }
  120. void ApplyClientNetPackVisitor::visitHeroVisitCastle(HeroVisitCastle & pack)
  121. {
  122. const CGHeroInstance *h = cl.getHero(pack.hid);
  123. if(pack.start())
  124. {
  125. callInterfaceIfPresent(cl, h->tempOwner, &IGameEventsReceiver::heroVisitsTown, h, gs.getTown(pack.tid));
  126. }
  127. }
  128. void ApplyClientNetPackVisitor::visitSetMana(SetMana & pack)
  129. {
  130. const CGHeroInstance *h = cl.getHero(pack.hid);
  131. callInterfaceIfPresent(cl, h->tempOwner, &IGameEventsReceiver::heroManaPointsChanged, h);
  132. }
  133. void ApplyClientNetPackVisitor::visitSetMovePoints(SetMovePoints & pack)
  134. {
  135. const CGHeroInstance *h = cl.getHero(pack.hid);
  136. cl.invalidatePaths();
  137. callInterfaceIfPresent(cl, h->tempOwner, &IGameEventsReceiver::heroMovePointsChanged, h);
  138. }
  139. void ApplyClientNetPackVisitor::visitFoWChange(FoWChange & pack)
  140. {
  141. for(auto &i : cl.playerint)
  142. {
  143. if(cl.getPlayerRelations(i.first, pack.player) == PlayerRelations::SAME_PLAYER && pack.waitForDialogs && LOCPLINT == i.second.get())
  144. {
  145. LOCPLINT->waitWhileDialog();
  146. }
  147. if(cl.getPlayerRelations(i.first, pack.player) != PlayerRelations::ENEMIES)
  148. {
  149. if(pack.mode)
  150. i.second->tileRevealed(pack.tiles);
  151. else
  152. i.second->tileHidden(pack.tiles);
  153. }
  154. }
  155. cl.invalidatePaths();
  156. }
  157. static void dispatchGarrisonChange(CClient & cl, ObjectInstanceID army1, ObjectInstanceID army2)
  158. {
  159. auto obj1 = cl.getObj(army1);
  160. if(!obj1)
  161. {
  162. logNetwork->error("Cannot find army with pack.id %d", army1.getNum());
  163. return;
  164. }
  165. callInterfaceIfPresent(cl, obj1->tempOwner, &IGameEventsReceiver::garrisonsChanged, army1, army2);
  166. if(army2 != ObjectInstanceID() && army2 != army1)
  167. {
  168. auto obj2 = cl.getObj(army2);
  169. if(!obj2)
  170. {
  171. logNetwork->error("Cannot find army with pack.id %d", army2.getNum());
  172. return;
  173. }
  174. if(obj1->tempOwner != obj2->tempOwner)
  175. callInterfaceIfPresent(cl, obj2->tempOwner, &IGameEventsReceiver::garrisonsChanged, army1, army2);
  176. }
  177. }
  178. void ApplyClientNetPackVisitor::visitChangeStackCount(ChangeStackCount & pack)
  179. {
  180. dispatchGarrisonChange(cl, pack.army, ObjectInstanceID());
  181. }
  182. void ApplyClientNetPackVisitor::visitSetStackType(SetStackType & pack)
  183. {
  184. dispatchGarrisonChange(cl, pack.army, ObjectInstanceID());
  185. }
  186. void ApplyClientNetPackVisitor::visitEraseStack(EraseStack & pack)
  187. {
  188. dispatchGarrisonChange(cl, pack.army, ObjectInstanceID());
  189. }
  190. void ApplyClientNetPackVisitor::visitSwapStacks(SwapStacks & pack)
  191. {
  192. dispatchGarrisonChange(cl, pack.srcArmy, pack.dstArmy);
  193. }
  194. void ApplyClientNetPackVisitor::visitInsertNewStack(InsertNewStack & pack)
  195. {
  196. dispatchGarrisonChange(cl, pack.army, ObjectInstanceID());
  197. }
  198. void ApplyClientNetPackVisitor::visitRebalanceStacks(RebalanceStacks & pack)
  199. {
  200. dispatchGarrisonChange(cl, pack.srcArmy, pack.dstArmy);
  201. }
  202. void ApplyClientNetPackVisitor::visitBulkRebalanceStacks(BulkRebalanceStacks & pack)
  203. {
  204. if(!pack.moves.empty())
  205. {
  206. auto destArmy = pack.moves[0].srcArmy == pack.moves[0].dstArmy
  207. ? ObjectInstanceID()
  208. : pack.moves[0].dstArmy;
  209. dispatchGarrisonChange(cl, pack.moves[0].srcArmy, destArmy);
  210. }
  211. }
  212. void ApplyClientNetPackVisitor::visitBulkSmartRebalanceStacks(BulkSmartRebalanceStacks & pack)
  213. {
  214. if(!pack.moves.empty())
  215. {
  216. assert(pack.moves[0].srcArmy == pack.moves[0].dstArmy);
  217. dispatchGarrisonChange(cl, pack.moves[0].srcArmy, ObjectInstanceID());
  218. }
  219. else if(!pack.changes.empty())
  220. {
  221. dispatchGarrisonChange(cl, pack.changes[0].army, ObjectInstanceID());
  222. }
  223. }
  224. void ApplyClientNetPackVisitor::visitPutArtifact(PutArtifact & pack)
  225. {
  226. callInterfaceIfPresent(cl, pack.al.owningPlayer(), &IGameEventsReceiver::artifactPut, pack.al);
  227. }
  228. void ApplyClientNetPackVisitor::visitEraseArtifact(EraseArtifact & pack)
  229. {
  230. callInterfaceIfPresent(cl, pack.al.owningPlayer(), &IGameEventsReceiver::artifactRemoved, pack.al);
  231. }
  232. void ApplyClientNetPackVisitor::visitMoveArtifact(MoveArtifact & pack)
  233. {
  234. auto moveArtifact = [this, &pack](PlayerColor player) -> void
  235. {
  236. callInterfaceIfPresent(cl, player, &IGameEventsReceiver::artifactMoved, pack.src, pack.dst);
  237. if(pack.askAssemble)
  238. callInterfaceIfPresent(cl, player, &IGameEventsReceiver::askToAssembleArtifact, pack.dst);
  239. };
  240. moveArtifact(pack.src.owningPlayer());
  241. if(pack.src.owningPlayer() != pack.dst.owningPlayer())
  242. moveArtifact(pack.dst.owningPlayer());
  243. }
  244. void ApplyClientNetPackVisitor::visitBulkMoveArtifacts(BulkMoveArtifacts & pack)
  245. {
  246. auto applyMove = [this, &pack](std::vector<BulkMoveArtifacts::LinkedSlots> & artsPack) -> void
  247. {
  248. for(auto & slotToMove : artsPack)
  249. {
  250. auto srcLoc = ArtifactLocation(pack.srcArtHolder, slotToMove.srcPos);
  251. auto dstLoc = ArtifactLocation(pack.dstArtHolder, slotToMove.dstPos);
  252. MoveArtifact ma(&srcLoc, &dstLoc, false);
  253. visitMoveArtifact(ma);
  254. }
  255. };
  256. // Begin a session of bulk movement of arts. It is not necessary but useful for the client optimization.
  257. callInterfaceIfPresent(cl, cl.getCurrentPlayer(), &IGameEventsReceiver::bulkArtMovementStart,
  258. pack.artsPack0.size() + pack.artsPack1.size());
  259. applyMove(pack.artsPack0);
  260. if(pack.swap)
  261. applyMove(pack.artsPack1);
  262. }
  263. void ApplyClientNetPackVisitor::visitAssembledArtifact(AssembledArtifact & pack)
  264. {
  265. callInterfaceIfPresent(cl, pack.al.owningPlayer(), &IGameEventsReceiver::artifactAssembled, pack.al);
  266. }
  267. void ApplyClientNetPackVisitor::visitDisassembledArtifact(DisassembledArtifact & pack)
  268. {
  269. callInterfaceIfPresent(cl, pack.al.owningPlayer(), &IGameEventsReceiver::artifactDisassembled, pack.al);
  270. }
  271. void ApplyClientNetPackVisitor::visitHeroVisit(HeroVisit & pack)
  272. {
  273. auto hero = cl.getHero(pack.heroId);
  274. auto obj = cl.getObj(pack.objId, false);
  275. callInterfaceIfPresent(cl, pack.player, &IGameEventsReceiver::heroVisit, hero, obj, pack.starting);
  276. }
  277. void ApplyClientNetPackVisitor::visitNewTurn(NewTurn & pack)
  278. {
  279. cl.invalidatePaths();
  280. }
  281. void ApplyClientNetPackVisitor::visitGiveBonus(GiveBonus & pack)
  282. {
  283. cl.invalidatePaths();
  284. switch(pack.who)
  285. {
  286. case GiveBonus::HERO:
  287. {
  288. const CGHeroInstance *h = gs.getHero(ObjectInstanceID(pack.id));
  289. callInterfaceIfPresent(cl, h->tempOwner, &IGameEventsReceiver::heroBonusChanged, h, *h->getBonusList().back(), true);
  290. }
  291. break;
  292. case GiveBonus::PLAYER:
  293. {
  294. const PlayerState *p = gs.getPlayerState(PlayerColor(pack.id));
  295. callInterfaceIfPresent(cl, PlayerColor(pack.id), &IGameEventsReceiver::playerBonusChanged, *p->getBonusList().back(), true);
  296. }
  297. break;
  298. }
  299. }
  300. void ApplyFirstClientNetPackVisitor::visitChangeObjPos(ChangeObjPos & pack)
  301. {
  302. CGObjectInstance *obj = gs.getObjInstance(pack.objid);
  303. if(CGI->mh)
  304. CGI->mh->onObjectFadeOut(obj);
  305. CGI->mh->waitForOngoingAnimations();
  306. }
  307. void ApplyClientNetPackVisitor::visitChangeObjPos(ChangeObjPos & pack)
  308. {
  309. CGObjectInstance *obj = gs.getObjInstance(pack.objid);
  310. if(CGI->mh)
  311. CGI->mh->onObjectFadeIn(obj);
  312. CGI->mh->waitForOngoingAnimations();
  313. cl.invalidatePaths();
  314. }
  315. void ApplyClientNetPackVisitor::visitPlayerEndsGame(PlayerEndsGame & pack)
  316. {
  317. callAllInterfaces(cl, &IGameEventsReceiver::gameOver, pack.player, pack.victoryLossCheckResult);
  318. // In auto testing pack.mode we always close client if red pack.player won or lose
  319. if(!settings["session"]["testmap"].isNull() && pack.player == PlayerColor(0))
  320. handleQuit(settings["session"]["spectate"].Bool()); // if spectator is active ask to close client or not
  321. }
  322. void ApplyClientNetPackVisitor::visitPlayerReinitInterface(PlayerReinitInterface & pack)
  323. {
  324. auto initInterfaces = [this]()
  325. {
  326. cl.initPlayerInterfaces();
  327. auto currentPlayer = cl.gameState()->currentPlayer;
  328. callAllInterfaces(cl, &IGameEventsReceiver::playerStartsTurn, currentPlayer);
  329. callOnlyThatInterface(cl, currentPlayer, &CGameInterface::yourTurn);
  330. };
  331. for(auto player : pack.players)
  332. {
  333. auto & plSettings = CSH->si->getIthPlayersSettings(player);
  334. if(pack.playerConnectionId == PlayerSettings::PLAYER_AI)
  335. {
  336. plSettings.connectedPlayerIDs.clear();
  337. cl.initPlayerEnvironments();
  338. initInterfaces();
  339. }
  340. else if(pack.playerConnectionId == CSH->c->connectionID)
  341. {
  342. plSettings.connectedPlayerIDs.insert(pack.playerConnectionId);
  343. cl.playerint.clear();
  344. initInterfaces();
  345. }
  346. }
  347. }
  348. void ApplyClientNetPackVisitor::visitRemoveBonus(RemoveBonus & pack)
  349. {
  350. cl.invalidatePaths();
  351. switch(pack.who)
  352. {
  353. case RemoveBonus::HERO:
  354. {
  355. const CGHeroInstance *h = gs.getHero(ObjectInstanceID(pack.id));
  356. callInterfaceIfPresent(cl, h->tempOwner, &IGameEventsReceiver::heroBonusChanged, h, pack.bonus, false);
  357. }
  358. break;
  359. case RemoveBonus::PLAYER:
  360. {
  361. //const PlayerState *p = gs.getPlayerState(pack.id);
  362. callInterfaceIfPresent(cl, PlayerColor(pack.id), &IGameEventsReceiver::playerBonusChanged, pack.bonus, false);
  363. }
  364. break;
  365. }
  366. }
  367. void ApplyFirstClientNetPackVisitor::visitRemoveObject(RemoveObject & pack)
  368. {
  369. const CGObjectInstance *o = cl.getObj(pack.id);
  370. if(CGI->mh)
  371. CGI->mh->onObjectFadeOut(o);
  372. //notify interfaces about removal
  373. for(auto i=cl.playerint.begin(); i!=cl.playerint.end(); i++)
  374. {
  375. //below line contains little cheat for AI so it will be aware of deletion of enemy heroes that moved or got re-covered by FoW
  376. //TODO: loose requirements as next AI related crashes appear, for example another pack.player collects object that got re-covered by FoW, unsure if AI code workarounds this
  377. if(gs.isVisible(o, i->first) || (!cl.getPlayerState(i->first)->human && o->ID == Obj::HERO && o->tempOwner != i->first))
  378. i->second->objectRemoved(o);
  379. }
  380. CGI->mh->waitForOngoingAnimations();
  381. }
  382. void ApplyClientNetPackVisitor::visitRemoveObject(RemoveObject & pack)
  383. {
  384. cl.invalidatePaths();
  385. for(auto i=cl.playerint.begin(); i!=cl.playerint.end(); i++)
  386. i->second->objectRemovedAfter();
  387. }
  388. void ApplyFirstClientNetPackVisitor::visitTryMoveHero(TryMoveHero & pack)
  389. {
  390. CGHeroInstance *h = gs.getHero(pack.id);
  391. if(CGI->mh)
  392. {
  393. switch (pack.result)
  394. {
  395. case TryMoveHero::EMBARK:
  396. CGI->mh->onBeforeHeroEmbark(h, pack.start, pack.end);
  397. break;
  398. case TryMoveHero::TELEPORTATION:
  399. CGI->mh->onBeforeHeroTeleported(h, pack.start, pack.end);
  400. break;
  401. case TryMoveHero::DISEMBARK:
  402. CGI->mh->onBeforeHeroDisembark(h, pack.start, pack.end);
  403. break;
  404. }
  405. CGI->mh->waitForOngoingAnimations();
  406. }
  407. }
  408. void ApplyClientNetPackVisitor::visitTryMoveHero(TryMoveHero & pack)
  409. {
  410. const CGHeroInstance *h = cl.getHero(pack.id);
  411. cl.invalidatePaths();
  412. if(CGI->mh)
  413. {
  414. switch(pack.result)
  415. {
  416. case TryMoveHero::SUCCESS:
  417. CGI->mh->onHeroMoved(h, pack.start, pack.end);
  418. break;
  419. case TryMoveHero::EMBARK:
  420. CGI->mh->onAfterHeroEmbark(h, pack.start, pack.end);
  421. break;
  422. case TryMoveHero::TELEPORTATION:
  423. CGI->mh->onAfterHeroTeleported(h, pack.start, pack.end);
  424. break;
  425. case TryMoveHero::DISEMBARK:
  426. CGI->mh->onAfterHeroDisembark(h, pack.start, pack.end);
  427. break;
  428. }
  429. }
  430. PlayerColor player = h->tempOwner;
  431. for(auto &i : cl.playerint)
  432. if(cl.getPlayerRelations(i.first, player) != PlayerRelations::ENEMIES)
  433. i.second->tileRevealed(pack.fowRevealed);
  434. for(auto i=cl.playerint.begin(); i!=cl.playerint.end(); i++)
  435. {
  436. if(i->first != PlayerColor::SPECTATOR && gs.checkForStandardLoss(i->first)) // Do not notify vanquished pack.player's interface
  437. continue;
  438. if(gs.isVisible(h->convertToVisitablePos(pack.start), i->first)
  439. || gs.isVisible(h->convertToVisitablePos(pack.end), i->first))
  440. {
  441. // pack.src and pack.dst of enemy hero move may be not visible => 'verbose' should be false
  442. const bool verbose = cl.getPlayerRelations(i->first, player) != PlayerRelations::ENEMIES;
  443. i->second->heroMoved(pack, verbose);
  444. }
  445. }
  446. }
  447. void ApplyClientNetPackVisitor::visitNewStructures(NewStructures & pack)
  448. {
  449. CGTownInstance *town = gs.getTown(pack.tid);
  450. for(const auto & id : pack.bid)
  451. {
  452. callInterfaceIfPresent(cl, town->tempOwner, &IGameEventsReceiver::buildChanged, town, id, 1);
  453. }
  454. }
  455. void ApplyClientNetPackVisitor::visitRazeStructures(RazeStructures & pack)
  456. {
  457. CGTownInstance * town = gs.getTown(pack.tid);
  458. for(const auto & id : pack.bid)
  459. {
  460. callInterfaceIfPresent(cl, town->tempOwner, &IGameEventsReceiver::buildChanged, town, id, 2);
  461. }
  462. }
  463. void ApplyClientNetPackVisitor::visitSetAvailableCreatures(SetAvailableCreatures & pack)
  464. {
  465. const CGDwelling * dw = static_cast<const CGDwelling*>(cl.getObj(pack.tid));
  466. PlayerColor p;
  467. if(dw->ID == Obj::WAR_MACHINE_FACTORY) //War Machines Factory is not flaggable, it's "owned" by visitor
  468. p = cl.getTile(dw->visitablePos())->visitableObjects.back()->tempOwner;
  469. else
  470. p = dw->tempOwner;
  471. callInterfaceIfPresent(cl, p, &IGameEventsReceiver::availableCreaturesChanged, dw);
  472. }
  473. void ApplyClientNetPackVisitor::visitSetHeroesInTown(SetHeroesInTown & pack)
  474. {
  475. CGTownInstance * t = gs.getTown(pack.tid);
  476. CGHeroInstance * hGarr = gs.getHero(pack.garrison);
  477. CGHeroInstance * hVisit = gs.getHero(pack.visiting);
  478. //inform all players that see this object
  479. for(auto i = cl.playerint.cbegin(); i != cl.playerint.cend(); ++i)
  480. {
  481. if(i->first >= PlayerColor::PLAYER_LIMIT)
  482. continue;
  483. if(gs.isVisible(t, i->first) ||
  484. (hGarr && gs.isVisible(hGarr, i->first)) ||
  485. (hVisit && gs.isVisible(hVisit, i->first)))
  486. {
  487. cl.playerint[i->first]->heroInGarrisonChange(t);
  488. }
  489. }
  490. }
  491. void ApplyClientNetPackVisitor::visitHeroRecruited(HeroRecruited & pack)
  492. {
  493. CGHeroInstance *h = gs.map->heroesOnMap.back();
  494. if(h->subID != pack.hid)
  495. {
  496. logNetwork->error("Something wrong with hero recruited!");
  497. }
  498. if(callInterfaceIfPresent(cl, h->tempOwner, &IGameEventsReceiver::heroCreated, h))
  499. {
  500. if(const CGTownInstance *t = gs.getTown(pack.tid))
  501. callInterfaceIfPresent(cl, h->tempOwner, &IGameEventsReceiver::heroInGarrisonChange, t);
  502. }
  503. if(CGI->mh)
  504. CGI->mh->onObjectInstantAdd(h);
  505. }
  506. void ApplyClientNetPackVisitor::visitGiveHero(GiveHero & pack)
  507. {
  508. CGHeroInstance *h = gs.getHero(pack.id);
  509. if(CGI->mh)
  510. CGI->mh->onObjectInstantAdd(h);
  511. callInterfaceIfPresent(cl, h->tempOwner, &IGameEventsReceiver::heroCreated, h);
  512. }
  513. void ApplyFirstClientNetPackVisitor::visitGiveHero(GiveHero & pack)
  514. {
  515. }
  516. void ApplyClientNetPackVisitor::visitInfoWindow(InfoWindow & pack)
  517. {
  518. std::string str;
  519. pack.text.toString(str);
  520. if(!callInterfaceIfPresent(cl, pack.player, &CGameInterface::showInfoDialog, pack.type, str, pack.components,(soundBase::soundID)pack.soundID))
  521. logNetwork->warn("We received InfoWindow for not our player...");
  522. }
  523. void ApplyClientNetPackVisitor::visitSetObjectProperty(SetObjectProperty & pack)
  524. {
  525. //inform all players that see this object
  526. for(auto it = cl.playerint.cbegin(); it != cl.playerint.cend(); ++it)
  527. {
  528. if(gs.isVisible(gs.getObjInstance(pack.id), it->first))
  529. callInterfaceIfPresent(cl, it->first, &IGameEventsReceiver::objectPropertyChanged, &pack);
  530. }
  531. }
  532. void ApplyClientNetPackVisitor::visitHeroLevelUp(HeroLevelUp & pack)
  533. {
  534. const CGHeroInstance * hero = cl.getHero(pack.heroId);
  535. assert(hero);
  536. callOnlyThatInterface(cl, pack.player, &CGameInterface::heroGotLevel, hero, pack.primskill, pack.skills, pack.queryID);
  537. }
  538. void ApplyClientNetPackVisitor::visitCommanderLevelUp(CommanderLevelUp & pack)
  539. {
  540. const CGHeroInstance * hero = cl.getHero(pack.heroId);
  541. assert(hero);
  542. const CCommanderInstance * commander = hero->commander;
  543. assert(commander);
  544. assert(commander->armyObj); //is it possible for Commander to exist beyond armed instance?
  545. callOnlyThatInterface(cl, pack.player, &CGameInterface::commanderGotLevel, commander, pack.skills, pack.queryID);
  546. }
  547. void ApplyClientNetPackVisitor::visitBlockingDialog(BlockingDialog & pack)
  548. {
  549. std::string str;
  550. pack.text.toString(str);
  551. if(!callOnlyThatInterface(cl, pack.player, &CGameInterface::showBlockingDialog, str, pack.components, pack.queryID, (soundBase::soundID)pack.soundID, pack.selection(), pack.cancel()))
  552. logNetwork->warn("We received YesNoDialog for not our player...");
  553. }
  554. void ApplyClientNetPackVisitor::visitGarrisonDialog(GarrisonDialog & pack)
  555. {
  556. const CGHeroInstance *h = cl.getHero(pack.hid);
  557. const CArmedInstance *obj = static_cast<const CArmedInstance*>(cl.getObj(pack.objid));
  558. callOnlyThatInterface(cl, h->getOwner(), &CGameInterface::showGarrisonDialog, obj, h, pack.removableUnits, pack.queryID);
  559. }
  560. void ApplyClientNetPackVisitor::visitExchangeDialog(ExchangeDialog & pack)
  561. {
  562. callInterfaceIfPresent(cl, pack.player, &IGameEventsReceiver::heroExchangeStarted, pack.hero1, pack.hero2, pack.queryID);
  563. }
  564. void ApplyClientNetPackVisitor::visitTeleportDialog(TeleportDialog & pack)
  565. {
  566. callOnlyThatInterface(cl, pack.player, &CGameInterface::showTeleportDialog, pack.channel, pack.exits, pack.impassable, pack.queryID);
  567. }
  568. void ApplyClientNetPackVisitor::visitMapObjectSelectDialog(MapObjectSelectDialog & pack)
  569. {
  570. callOnlyThatInterface(cl, pack.player, &CGameInterface::showMapObjectSelectDialog, pack.queryID, pack.icon, pack.title, pack.description, pack.objects);
  571. }
  572. void ApplyFirstClientNetPackVisitor::visitBattleStart(BattleStart & pack)
  573. {
  574. // Cannot use the usual code because curB is not set yet
  575. callOnlyThatBattleInterface(cl, pack.info->sides[0].color, &IBattleEventsReceiver::battleStartBefore, pack.info->sides[0].armyObject, pack.info->sides[1].armyObject,
  576. pack.info->tile, pack.info->sides[0].hero, pack.info->sides[1].hero);
  577. callOnlyThatBattleInterface(cl, pack.info->sides[1].color, &IBattleEventsReceiver::battleStartBefore, pack.info->sides[0].armyObject, pack.info->sides[1].armyObject,
  578. pack.info->tile, pack.info->sides[0].hero, pack.info->sides[1].hero);
  579. callOnlyThatBattleInterface(cl, PlayerColor::SPECTATOR, &IBattleEventsReceiver::battleStartBefore, pack.info->sides[0].armyObject, pack.info->sides[1].armyObject,
  580. pack.info->tile, pack.info->sides[0].hero, pack.info->sides[1].hero);
  581. }
  582. void ApplyClientNetPackVisitor::visitBattleStart(BattleStart & pack)
  583. {
  584. cl.battleStarted(pack.info);
  585. }
  586. void ApplyFirstClientNetPackVisitor::visitBattleNextRound(BattleNextRound & pack)
  587. {
  588. callBattleInterfaceIfPresentForBothSides(cl, &IBattleEventsReceiver::battleNewRoundFirst, pack.round);
  589. }
  590. void ApplyClientNetPackVisitor::visitBattleNextRound(BattleNextRound & pack)
  591. {
  592. callBattleInterfaceIfPresentForBothSides(cl, &IBattleEventsReceiver::battleNewRound, pack.round);
  593. }
  594. void ApplyClientNetPackVisitor::visitBattleSetActiveStack(BattleSetActiveStack & pack)
  595. {
  596. if(!pack.askPlayerInterface)
  597. return;
  598. const CStack *activated = gs.curB->battleGetStackByID(pack.stack);
  599. PlayerColor playerToCall; //pack.player that will move activated stack
  600. if (activated->hasBonusOfType(Bonus::HYPNOTIZED))
  601. {
  602. playerToCall = (gs.curB->sides[0].color == activated->owner
  603. ? gs.curB->sides[1].color
  604. : gs.curB->sides[0].color);
  605. }
  606. else
  607. {
  608. playerToCall = activated->owner;
  609. }
  610. cl.startPlayerBattleAction(playerToCall);
  611. }
  612. void ApplyClientNetPackVisitor::visitBattleLogMessage(BattleLogMessage & pack)
  613. {
  614. callBattleInterfaceIfPresentForBothSides(cl, &IBattleEventsReceiver::battleLogMessage, pack.lines);
  615. }
  616. void ApplyClientNetPackVisitor::visitBattleTriggerEffect(BattleTriggerEffect & pack)
  617. {
  618. callBattleInterfaceIfPresentForBothSides(cl, &IBattleEventsReceiver::battleTriggerEffect, pack);
  619. }
  620. void ApplyFirstClientNetPackVisitor::visitBattleUpdateGateState(BattleUpdateGateState & pack)
  621. {
  622. callBattleInterfaceIfPresentForBothSides(cl, &IBattleEventsReceiver::battleGateStateChanged, pack.state);
  623. }
  624. void ApplyFirstClientNetPackVisitor::visitBattleResult(BattleResult & pack)
  625. {
  626. callBattleInterfaceIfPresentForBothSides(cl, &IBattleEventsReceiver::battleEnd, &pack);
  627. cl.battleFinished();
  628. }
  629. void ApplyFirstClientNetPackVisitor::visitBattleStackMoved(BattleStackMoved & pack)
  630. {
  631. const CStack * movedStack = gs.curB->battleGetStackByID(pack.stack);
  632. callBattleInterfaceIfPresentForBothSides(cl, &IBattleEventsReceiver::battleStackMoved, movedStack, pack.tilesToMove, pack.distance, pack.teleporting);
  633. }
  634. void ApplyFirstClientNetPackVisitor::visitBattleAttack(BattleAttack & pack)
  635. {
  636. callBattleInterfaceIfPresentForBothSides(cl, &IBattleEventsReceiver::battleAttack, &pack);
  637. }
  638. void ApplyClientNetPackVisitor::visitBattleAttack(BattleAttack & pack)
  639. {
  640. callBattleInterfaceIfPresentForBothSides(cl, &IBattleEventsReceiver::battleStacksAttacked, pack.bsa, pack.shot());
  641. }
  642. void ApplyFirstClientNetPackVisitor::visitStartAction(StartAction & pack)
  643. {
  644. cl.curbaction = boost::make_optional(pack.ba);
  645. callBattleInterfaceIfPresentForBothSides(cl, &IBattleEventsReceiver::actionStarted, pack.ba);
  646. }
  647. void ApplyClientNetPackVisitor::visitBattleSpellCast(BattleSpellCast & pack)
  648. {
  649. callBattleInterfaceIfPresentForBothSides(cl, &IBattleEventsReceiver::battleSpellCast, &pack);
  650. }
  651. void ApplyClientNetPackVisitor::visitSetStackEffect(SetStackEffect & pack)
  652. {
  653. //informing about effects
  654. callBattleInterfaceIfPresentForBothSides(cl, &IBattleEventsReceiver::battleStacksEffectsSet, pack);
  655. }
  656. void ApplyClientNetPackVisitor::visitStacksInjured(StacksInjured & pack)
  657. {
  658. callBattleInterfaceIfPresentForBothSides(cl, &IBattleEventsReceiver::battleStacksAttacked, pack.stacks, false);
  659. }
  660. void ApplyClientNetPackVisitor::visitBattleResultsApplied(BattleResultsApplied & pack)
  661. {
  662. callInterfaceIfPresent(cl, pack.player1, &IGameEventsReceiver::battleResultsApplied);
  663. callInterfaceIfPresent(cl, pack.player2, &IGameEventsReceiver::battleResultsApplied);
  664. callInterfaceIfPresent(cl, PlayerColor::SPECTATOR, &IGameEventsReceiver::battleResultsApplied);
  665. }
  666. void ApplyClientNetPackVisitor::visitBattleUnitsChanged(BattleUnitsChanged & pack)
  667. {
  668. callBattleInterfaceIfPresentForBothSides(cl, &IBattleEventsReceiver::battleUnitsChanged, pack.changedStacks);
  669. }
  670. void ApplyClientNetPackVisitor::visitBattleObstaclesChanged(BattleObstaclesChanged & pack)
  671. {
  672. //inform interfaces about removed obstacles
  673. callBattleInterfaceIfPresentForBothSides(cl, &IBattleEventsReceiver::battleObstaclesChanged, pack.changes);
  674. }
  675. void ApplyClientNetPackVisitor::visitCatapultAttack(CatapultAttack & pack)
  676. {
  677. //inform interfaces about catapult attack
  678. callBattleInterfaceIfPresentForBothSides(cl, &IBattleEventsReceiver::battleCatapultAttacked, pack);
  679. }
  680. void ApplyClientNetPackVisitor::visitEndAction(EndAction & pack)
  681. {
  682. callBattleInterfaceIfPresentForBothSides(cl, &IBattleEventsReceiver::actionFinished, *cl.curbaction);
  683. cl.curbaction.reset();
  684. }
  685. void ApplyClientNetPackVisitor::visitPackageApplied(PackageApplied & pack)
  686. {
  687. callInterfaceIfPresent(cl, pack.player, &IGameEventsReceiver::requestRealized, &pack);
  688. if(!CClient::waitingRequest.tryRemovingElement(pack.requestID))
  689. logNetwork->warn("Surprising server message! PackageApplied for unknown requestID!");
  690. }
  691. void ApplyClientNetPackVisitor::visitSystemMessage(SystemMessage & pack)
  692. {
  693. std::ostringstream str;
  694. str << "System message: " << pack.text;
  695. logNetwork->error(str.str()); // usually used to receive error messages from server
  696. if(LOCPLINT && !settings["session"]["hideSystemMessages"].Bool())
  697. LOCPLINT->cingconsole->print(str.str());
  698. }
  699. void ApplyClientNetPackVisitor::visitPlayerBlocked(PlayerBlocked & pack)
  700. {
  701. callInterfaceIfPresent(cl, pack.player, &IGameEventsReceiver::playerBlocked, pack.reason, pack.startOrEnd == PlayerBlocked::BLOCKADE_STARTED);
  702. }
  703. void ApplyClientNetPackVisitor::visitYourTurn(YourTurn & pack)
  704. {
  705. logNetwork->debug("Server gives turn to %s", pack.player.getStr());
  706. callAllInterfaces(cl, &IGameEventsReceiver::playerStartsTurn, pack.player);
  707. callOnlyThatInterface(cl, pack.player, &CGameInterface::yourTurn);
  708. }
  709. void ApplyClientNetPackVisitor::visitSaveGameClient(SaveGameClient & pack)
  710. {
  711. const auto stem = FileInfo::GetPathStem(pack.fname);
  712. if(!CResourceHandler::get("local")->createResource(stem.to_string() + ".vcgm1"))
  713. {
  714. logNetwork->error("Failed to create resource %s", stem.to_string() + ".vcgm1");
  715. return;
  716. }
  717. try
  718. {
  719. CSaveFile save(*CResourceHandler::get()->getResourceName(ResourceID(stem.to_string(), EResType::CLIENT_SAVEGAME)));
  720. cl.saveCommonState(save);
  721. save << cl;
  722. }
  723. catch(std::exception &e)
  724. {
  725. logNetwork->error("Failed to save game:%s", e.what());
  726. }
  727. }
  728. void ApplyClientNetPackVisitor::visitPlayerMessageClient(PlayerMessageClient & pack)
  729. {
  730. logNetwork->debug("pack.player %s sends a message: %s", pack.player.getStr(), pack.text);
  731. std::ostringstream str;
  732. if(pack.player.isSpectator())
  733. str << "Spectator: " << pack.text;
  734. else
  735. str << cl.getPlayerState(pack.player)->nodeName() <<": " << pack.text;
  736. if(LOCPLINT)
  737. LOCPLINT->cingconsole->print(str.str());
  738. }
  739. void ApplyClientNetPackVisitor::visitAdvmapSpellCast(AdvmapSpellCast & pack)
  740. {
  741. cl.invalidatePaths();
  742. auto caster = cl.getHero(pack.casterID);
  743. if(caster)
  744. //consider notifying other interfaces that see hero?
  745. callInterfaceIfPresent(cl, caster->getOwner(), &IGameEventsReceiver::advmapSpellCast, caster, pack.spellID);
  746. else
  747. logNetwork->error("Invalid hero instance");
  748. }
  749. void ApplyClientNetPackVisitor::visitShowWorldViewEx(ShowWorldViewEx & pack)
  750. {
  751. callOnlyThatInterface(cl, pack.player, &CGameInterface::showWorldViewEx, pack.objectPositions, pack.showTerrain);
  752. }
  753. void ApplyClientNetPackVisitor::visitOpenWindow(OpenWindow & pack)
  754. {
  755. switch(pack.window)
  756. {
  757. case EOpenWindowMode::RECRUITMENT_FIRST:
  758. case EOpenWindowMode::RECRUITMENT_ALL:
  759. {
  760. const CGDwelling *dw = dynamic_cast<const CGDwelling*>(cl.getObj(ObjectInstanceID(pack.id1)));
  761. const CArmedInstance *dst = dynamic_cast<const CArmedInstance*>(cl.getObj(ObjectInstanceID(pack.id2)));
  762. callInterfaceIfPresent(cl, dst->tempOwner, &IGameEventsReceiver::showRecruitmentDialog, dw, dst, pack.window == EOpenWindowMode::RECRUITMENT_FIRST ? 0 : -1);
  763. }
  764. break;
  765. case EOpenWindowMode::SHIPYARD_WINDOW:
  766. {
  767. const IShipyard *sy = IShipyard::castFrom(cl.getObj(ObjectInstanceID(pack.id1)));
  768. callInterfaceIfPresent(cl, sy->o->tempOwner, &IGameEventsReceiver::showShipyardDialog, sy);
  769. }
  770. break;
  771. case EOpenWindowMode::THIEVES_GUILD:
  772. {
  773. //displays Thieves' Guild window (when hero enters Den of Thieves)
  774. const CGObjectInstance *obj = cl.getObj(ObjectInstanceID(pack.id2));
  775. callInterfaceIfPresent(cl, PlayerColor(pack.id1), &IGameEventsReceiver::showThievesGuildWindow, obj);
  776. }
  777. break;
  778. case EOpenWindowMode::UNIVERSITY_WINDOW:
  779. {
  780. //displays University window (when hero enters University on adventure map)
  781. const IMarket *market = IMarket::castFrom(cl.getObj(ObjectInstanceID(pack.id1)));
  782. const CGHeroInstance *hero = cl.getHero(ObjectInstanceID(pack.id2));
  783. callInterfaceIfPresent(cl, hero->tempOwner, &IGameEventsReceiver::showUniversityWindow, market, hero);
  784. }
  785. break;
  786. case EOpenWindowMode::MARKET_WINDOW:
  787. {
  788. //displays Thieves' Guild window (when hero enters Den of Thieves)
  789. const CGObjectInstance *obj = cl.getObj(ObjectInstanceID(pack.id1));
  790. const CGHeroInstance *hero = cl.getHero(ObjectInstanceID(pack.id2));
  791. const IMarket *market = IMarket::castFrom(obj);
  792. callInterfaceIfPresent(cl, cl.getTile(obj->visitablePos())->visitableObjects.back()->tempOwner, &IGameEventsReceiver::showMarketWindow, market, hero);
  793. }
  794. break;
  795. case EOpenWindowMode::HILL_FORT_WINDOW:
  796. {
  797. //displays Hill fort window
  798. const CGObjectInstance *obj = cl.getObj(ObjectInstanceID(pack.id1));
  799. const CGHeroInstance *hero = cl.getHero(ObjectInstanceID(pack.id2));
  800. callInterfaceIfPresent(cl, cl.getTile(obj->visitablePos())->visitableObjects.back()->tempOwner, &IGameEventsReceiver::showHillFortWindow, obj, hero);
  801. }
  802. break;
  803. case EOpenWindowMode::PUZZLE_MAP:
  804. {
  805. callInterfaceIfPresent(cl, PlayerColor(pack.id1), &IGameEventsReceiver::showPuzzleMap);
  806. }
  807. break;
  808. case EOpenWindowMode::TAVERN_WINDOW:
  809. const CGObjectInstance *obj1 = cl.getObj(ObjectInstanceID(pack.id1)),
  810. *obj2 = cl.getObj(ObjectInstanceID(pack.id2));
  811. callInterfaceIfPresent(cl, obj1->tempOwner, &IGameEventsReceiver::showTavernWindow, obj2);
  812. break;
  813. }
  814. }
  815. void ApplyClientNetPackVisitor::visitCenterView(CenterView & pack)
  816. {
  817. callInterfaceIfPresent(cl, pack.player, &IGameEventsReceiver::centerView, pack.pos, pack.focusTime);
  818. }
  819. void ApplyClientNetPackVisitor::visitNewObject(NewObject & pack)
  820. {
  821. cl.invalidatePaths();
  822. const CGObjectInstance *obj = cl.getObj(pack.id);
  823. if(CGI->mh)
  824. CGI->mh->onObjectFadeIn(obj);
  825. for(auto i=cl.playerint.begin(); i!=cl.playerint.end(); i++)
  826. {
  827. if(gs.isVisible(obj, i->first))
  828. i->second->newObject(obj);
  829. }
  830. CGI->mh->waitForOngoingAnimations();
  831. }
  832. void ApplyClientNetPackVisitor::visitSetAvailableArtifacts(SetAvailableArtifacts & pack)
  833. {
  834. if(pack.id < 0) //artifact merchants globally
  835. {
  836. callAllInterfaces(cl, &IGameEventsReceiver::availableArtifactsChanged, nullptr);
  837. }
  838. else
  839. {
  840. const CGBlackMarket *bm = dynamic_cast<const CGBlackMarket *>(cl.getObj(ObjectInstanceID(pack.id)));
  841. assert(bm);
  842. callInterfaceIfPresent(cl, cl.getTile(bm->visitablePos())->visitableObjects.back()->tempOwner, &IGameEventsReceiver::availableArtifactsChanged, bm);
  843. }
  844. }
  845. void ApplyClientNetPackVisitor::visitEntitiesChanged(EntitiesChanged & pack)
  846. {
  847. cl.invalidatePaths();
  848. }