CCallback.cpp 9.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391
  1. #include "StdInc.h"
  2. #include "CCallback.h"
  3. #include "lib/CCreatureHandler.h"
  4. #include "client/CGameInfo.h"
  5. #include "lib/CGameState.h"
  6. #include "lib/BattleState.h"
  7. #include "client/CPlayerInterface.h"
  8. #include "client/Client.h"
  9. #include "lib/Mapping/CMap.h"
  10. #include "lib/CBuildingHandler.h"
  11. #include "lib/CDefObjInfoHandler.h"
  12. #include "lib/CGeneralTextHandler.h"
  13. #include "lib/CHeroHandler.h"
  14. #include "lib/CObjectHandler.h"
  15. #include "lib/Connection.h"
  16. #include "lib/NetPacks.h"
  17. #include "client/mapHandler.h"
  18. #include "lib/CSpellHandler.h"
  19. #include "lib/CArtHandler.h"
  20. #include "lib/GameConstants.h"
  21. #ifdef min
  22. #undef min
  23. #endif
  24. #ifdef max
  25. #undef max
  26. #endif
  27. #include "lib/UnlockGuard.h"
  28. /*
  29. * CCallback.cpp, part of VCMI engine
  30. *
  31. * Authors: listed in file AUTHORS in main folder
  32. *
  33. * License: GNU General Public License v2.0 or later
  34. * Full text of license available in license.txt file, in main folder
  35. *
  36. */
  37. template <ui16 N> bool isType(CPack *pack)
  38. {
  39. return pack->getType() == N;
  40. }
  41. bool CCallback::teleportHero(const CGHeroInstance *who, const CGTownInstance *where)
  42. {
  43. CastleTeleportHero pack(who->id, where->id, 1);
  44. sendRequest(&pack);
  45. return true;
  46. }
  47. bool CCallback::moveHero(const CGHeroInstance *h, int3 dst)
  48. {
  49. MoveHero pack(dst,h->id);
  50. sendRequest(&pack);
  51. return true;
  52. }
  53. int CCallback::selectionMade(int selection, int queryID)
  54. {
  55. ASSERT_IF_CALLED_WITH_PLAYER
  56. if(queryID == -1)
  57. {
  58. tlog1 << "Cannot answer the query -1!\n";
  59. return false;
  60. }
  61. QueryReply pack(queryID,selection);
  62. pack.player = *player;
  63. return sendRequest(&pack);
  64. }
  65. void CCallback::recruitCreatures(const CGObjectInstance *obj, CreatureID ID, ui32 amount, si32 level/*=-1*/)
  66. {
  67. if(player!=obj->tempOwner && obj->ID != Obj::WAR_MACHINE_FACTORY)
  68. return;
  69. RecruitCreatures pack(obj->id,ID,amount,level);
  70. sendRequest(&pack);
  71. }
  72. bool CCallback::dismissCreature(const CArmedInstance *obj, int stackPos)
  73. {
  74. if(((player>=0) && obj->tempOwner != player) || (obj->stacksCount()<2 && obj->needsLastStack()))
  75. return false;
  76. DisbandCreature pack(stackPos,obj->id);
  77. sendRequest(&pack);
  78. return true;
  79. }
  80. bool CCallback::upgradeCreature(const CArmedInstance *obj, int stackPos, CreatureID newID)
  81. {
  82. UpgradeCreature pack(stackPos,obj->id,newID);
  83. sendRequest(&pack);
  84. return false;
  85. }
  86. void CCallback::endTurn()
  87. {
  88. tlog5 << "Player " << (unsigned)*player << " ended his turn." << std::endl;
  89. EndTurn pack;
  90. sendRequest(&pack); //report that we ended turn
  91. }
  92. int CCallback::swapCreatures(const CArmedInstance *s1, const CArmedInstance *s2, int p1, int p2)
  93. {
  94. ArrangeStacks pack(1,p1,p2,s1->id,s2->id,0);
  95. sendRequest(&pack);
  96. return 0;
  97. }
  98. int CCallback::mergeStacks(const CArmedInstance *s1, const CArmedInstance *s2, int p1, int p2)
  99. {
  100. ArrangeStacks pack(2,p1,p2,s1->id,s2->id,0);
  101. sendRequest(&pack);
  102. return 0;
  103. }
  104. int CCallback::splitStack(const CArmedInstance *s1, const CArmedInstance *s2, int p1, int p2, int val)
  105. {
  106. ArrangeStacks pack(3,p1,p2,s1->id,s2->id,val);
  107. sendRequest(&pack);
  108. return 0;
  109. }
  110. bool CCallback::dismissHero(const CGHeroInstance *hero)
  111. {
  112. if(player!=hero->tempOwner) return false;
  113. DismissHero pack(hero->id);
  114. sendRequest(&pack);
  115. return true;
  116. }
  117. // int CCallback::getMySerial() const
  118. // {
  119. // boost::shared_lock<boost::shared_mutex> lock(*gs->mx);
  120. // return gs->players[player].serial;
  121. // }
  122. bool CCallback::swapArtifacts(const ArtifactLocation &l1, const ArtifactLocation &l2)
  123. {
  124. ExchangeArtifacts ea;
  125. ea.src = l1;
  126. ea.dst = l2;
  127. sendRequest(&ea);
  128. return true;
  129. }
  130. /**
  131. * Assembles or disassembles a combination artifact.
  132. * @param hero Hero holding the artifact(s).
  133. * @param artifactSlot The worn slot ID of the combination- or constituent artifact.
  134. * @param assemble True for assembly operation, false for disassembly.
  135. * @param assembleTo If assemble is true, this represents the artifact ID of the combination
  136. * artifact to assemble to. Otherwise it's not used.
  137. */
  138. bool CCallback::assembleArtifacts (const CGHeroInstance * hero, ArtifactPosition artifactSlot, bool assemble, ui32 assembleTo)
  139. {
  140. if (player != hero->tempOwner)
  141. return false;
  142. AssembleArtifacts aa(hero->id, artifactSlot, assemble, assembleTo);
  143. sendRequest(&aa);
  144. return true;
  145. }
  146. bool CCallback::buildBuilding(const CGTownInstance *town, BuildingID buildingID)
  147. {
  148. if(town->tempOwner!=player)
  149. return false;
  150. if(!canBuildStructure(town, buildingID))
  151. return false;
  152. BuildStructure pack(town->id,buildingID);
  153. sendRequest(&pack);
  154. return true;
  155. }
  156. int CBattleCallback::battleMakeAction(BattleAction* action)
  157. {
  158. assert(action->actionType == Battle::HERO_SPELL);
  159. MakeCustomAction mca(*action);
  160. sendRequest(&mca);
  161. return 0;
  162. }
  163. int CBattleCallback::sendRequest(const CPack *request)
  164. {
  165. int requestID = cl->sendRequest(request, *player);
  166. if(waitTillRealize)
  167. {
  168. tlog5 << boost::format("We'll wait till request %d is answered.\n") % requestID;
  169. auto gsUnlocker = vstd::makeUnlockSharedGuardIf(getGsMutex(), unlockGsWhenWaiting);
  170. cl->waitingRequest.waitWhileContains(requestID);
  171. }
  172. return requestID;
  173. }
  174. void CCallback::swapGarrisonHero( const CGTownInstance *town )
  175. {
  176. if(town->tempOwner != *player) return;
  177. GarrisonHeroSwap pack(town->id);
  178. sendRequest(&pack);
  179. }
  180. void CCallback::buyArtifact(const CGHeroInstance *hero, ArtifactID aid)
  181. {
  182. if(hero->tempOwner != player) return;
  183. BuyArtifact pack(hero->id,aid);
  184. sendRequest(&pack);
  185. }
  186. void CCallback::trade(const CGObjectInstance *market, EMarketMode::EMarketMode mode, int id1, int id2, int val1, const CGHeroInstance *hero/* = NULL*/)
  187. {
  188. TradeOnMarketplace pack;
  189. pack.market = market;
  190. pack.hero = hero;
  191. pack.mode = mode;
  192. pack.r1 = id1;
  193. pack.r2 = id2;
  194. pack.val = val1;
  195. sendRequest(&pack);
  196. }
  197. void CCallback::setFormation(const CGHeroInstance * hero, bool tight)
  198. {
  199. const_cast<CGHeroInstance*>(hero)-> formation = tight;
  200. SetFormation pack(hero->id,tight);
  201. sendRequest(&pack);
  202. }
  203. void CCallback::setSelection(const CArmedInstance * obj)
  204. {
  205. SetSelection ss;
  206. ss.player = *player;
  207. ss.id = obj->id;
  208. sendRequest(&(CPackForClient&)ss);
  209. if(obj->ID == Obj::HERO)
  210. {
  211. if(cl->pathInfo->hero != obj) //calculate new paths only if we selected a different hero
  212. cl->calculatePaths(static_cast<const CGHeroInstance *>(obj));
  213. //nasty workaround. TODO: nice workaround
  214. cl->gs->getPlayer(*player)->currentSelection = obj->id;
  215. }
  216. }
  217. void CCallback::recruitHero(const CGObjectInstance *townOrTavern, const CGHeroInstance *hero)
  218. {
  219. assert(townOrTavern);
  220. assert(hero);
  221. ui8 i=0;
  222. for(; i<gs->players[*player].availableHeroes.size(); i++)
  223. {
  224. if(gs->players[*player].availableHeroes[i] == hero)
  225. {
  226. HireHero pack(i, townOrTavern->id);
  227. pack.player = *player;
  228. sendRequest(&pack);
  229. return;
  230. }
  231. }
  232. }
  233. void CCallback::save( const std::string &fname )
  234. {
  235. cl->save(fname);
  236. }
  237. void CCallback::sendMessage(const std::string &mess)
  238. {
  239. ASSERT_IF_CALLED_WITH_PLAYER
  240. PlayerMessage pm(*player, mess);
  241. sendRequest(&(CPackForClient&)pm);
  242. }
  243. void CCallback::buildBoat( const IShipyard *obj )
  244. {
  245. BuildBoat bb;
  246. bb.objid = obj->o->id;
  247. sendRequest(&bb);
  248. }
  249. CCallback::CCallback( CGameState * GS, boost::optional<TPlayerColor> Player, CClient *C )
  250. :CBattleCallback(GS, Player, C)
  251. {
  252. waitTillRealize = false;
  253. unlockGsWhenWaiting = false;
  254. }
  255. CCallback::~CCallback()
  256. {
  257. //trivial, but required. Don`t remove.
  258. }
  259. const CGPathNode * CCallback::getPathInfo( int3 tile )
  260. {
  261. if (!gs->map->isInTheMap(tile))
  262. return nullptr;
  263. validatePaths();
  264. return &cl->pathInfo->nodes[tile.x][tile.y][tile.z];
  265. }
  266. bool CCallback::getPath2( int3 dest, CGPath &ret )
  267. {
  268. if (!gs->map->isInTheMap(dest))
  269. return false;
  270. validatePaths();
  271. boost::unique_lock<boost::mutex> pathLock(cl->pathMx);
  272. return cl->pathInfo->getPath(dest, ret);
  273. }
  274. void CCallback::recalculatePaths()
  275. {
  276. cl->calculatePaths(cl->IGameCallback::getSelectedHero(*player));
  277. }
  278. void CCallback::calculatePaths( const CGHeroInstance *hero, CPathsInfo &out, int3 src /*= int3(-1,-1,-1)*/, int movement /*= -1*/ )
  279. {
  280. gs->calculatePaths(hero, out, src, movement);
  281. }
  282. void CCallback::dig( const CGObjectInstance *hero )
  283. {
  284. DigWithHero dwh;
  285. dwh.id = hero->id;
  286. sendRequest(&dwh);
  287. }
  288. void CCallback::castSpell(const CGHeroInstance *hero, SpellID spellID, const int3 &pos)
  289. {
  290. CastAdvSpell cas;
  291. cas.hid = hero->id;
  292. cas.sid = spellID;
  293. cas.pos = pos;
  294. sendRequest(&cas);
  295. }
  296. void CCallback::unregisterMyInterface()
  297. {
  298. ASSERT_IF_CALLED_WITH_PLAYER
  299. cl->playerint.erase(*player);
  300. cl->battleints.erase(*player);
  301. //TODO? should callback be disabled as well?
  302. }
  303. void CCallback::validatePaths()
  304. {
  305. ASSERT_IF_CALLED_WITH_PLAYER
  306. const CGHeroInstance *h = cl->IGameCallback::getSelectedHero(*player);
  307. if(h && ( cl->pathInfo->hero != h //wrong hero
  308. || cl->pathInfo->hpos != h->getPosition(false) //wrong hero positoin
  309. || !cl->pathInfo->isValid)) //paths invalidated by game event
  310. {
  311. recalculatePaths();
  312. }
  313. }
  314. int CCallback::mergeOrSwapStacks(const CArmedInstance *s1, const CArmedInstance *s2, int p1, int p2)
  315. {
  316. if(s1->getCreature(p1) == s2->getCreature(p2))
  317. return mergeStacks(s1, s2, p1, p2);
  318. else
  319. return swapCreatures(s1, s2, p1, p2);
  320. }
  321. CBattleCallback::CBattleCallback(CGameState *GS, boost::optional<TPlayerColor> Player, CClient *C )
  322. {
  323. gs = GS;
  324. player = Player;
  325. cl = C;
  326. }
  327. bool CBattleCallback::battleMakeTacticAction( BattleAction * action )
  328. {
  329. assert(cl->gs->curB->tacticDistance);
  330. MakeAction ma;
  331. ma.ba = *action;
  332. sendRequest(&ma);
  333. return true;
  334. }