refactor: add game listener

include/game/BaseGame.h

@@ -12,11 +12,25 @@ enum class GameState : std::uint8_t {
     Game,
     EndGame,
     Disconnected,
+    Closed
 };
 
 typedef std::map<std::uint8_t, Player> PlayerList;
 
-class Game {
+class GameListener {
+public:
+    virtual void OnPlayerJoin(PlayerID player) {}
+    virtual void OnPlayerLeave(PlayerID player) {}
+
+    virtual void OnGameStateUpdate(GameState newState) {}
+    virtual void OnGameBegin() {}
+    virtual void OnGameEnd() {}
+    virtual void OnGameClose() {}
+};
+
+typedef utils::ObjectNotifier<GameListener> GameNotifier;
+
+class Game : public GameNotifier {
 protected:
     World* m_World;
     TeamList m_Teams = { Team{TeamColor::Red}, Team{TeamColor::Blue} };

include/game/World.h

@@ -125,8 +125,6 @@ class WorldListener {
 public:
     WorldListener() {}
 
-    virtual void OnGameEnd() {}
-
     virtual void OnTowerAdd(TowerPtr tower) {}
     virtual void OnTowerRemove(TowerPtr tower) {}
 
@@ -231,8 +229,6 @@ public:
     virtual void OnArrowShot(MobPtr target, bool fire, Tower* shooter);
     virtual void OnExplosion(utils::shape::Circle explosion, float centerDamage, Tower* shooter);
 
-    virtual void OnGameEnd();
-
     // MobListener
 
     virtual void OnMobDamage(Mob* target, float damage, Tower* source);

include/game/server/ServerGame.h

@@ -9,7 +9,7 @@ namespace server {
 
 class Server;
 
-class ServerGame : public game::Game {
+class ServerGame : public game::Game, public game::GameListener {
 private:
     Server* m_Server;
     ServerWorld m_ServerWorld;
@@ -22,6 +22,13 @@ public:
 
     virtual void tick(std::uint64_t delta);
     void startGame();
+
+    // GameListener
+
+    virtual void OnGameStateUpdate(game::GameState newState);
+    virtual void OnGameBegin();
+    virtual void OnGameEnd();
+    virtual void OnGameClose();
 private:
     void balanceTeams();
     void updateGoldMines();

src/game/World.cpp

@@ -106,7 +106,7 @@ bool World::saveMap(const std::string& fileName) const {
 }
 
 void World::tick(std::uint64_t delta) {
-    if(m_Game->getGameState() != GameState::Game) return;
+    if (m_Game->getGameState() != GameState::Game) return;
 
     tickMobs(delta);
     for (TowerPtr tower : m_Towers) {
@@ -295,7 +295,7 @@ void World::OnExplosion(utils::shape::Circle explosion, float centerDamage, Towe
 void World::OnMobCastleDamage(Mob* damager, TeamCastle* enemyCastle, float damage) {
     enemyCastle->damage(damage);
     if (enemyCastle->getLife() <= 0) {
-        getWorldNotifier().notifyListeners(&WorldListener::OnGameEnd);
+        m_Game->notifyListeners(&GameListener::OnGameEnd);
     }
 }
 
@@ -306,10 +306,6 @@ void World::OnMobDamage(Mob* target, float damage, Tower* source) {
     }
 }
 
-void World::OnGameEnd(){
-    m_Game->setGameState(GameState::EndGame);
-}
-
 Team& World::getRedTeam() {
     return m_Game->getRedTeam();
 }

src/game/server/Lobby.cpp

@@ -37,10 +37,8 @@ void Lobby::tick() {
         return;
 
     if (utils::getTime() - m_StartTimerTime >= LobbyWaitingTime) {
-        protocol::UpdateGameStatePacket packet(game::GameState::Game);
-        m_Server->broadcastPacket(&packet);
+        m_Server->getGame().notifyListeners(&game::GameListener::OnGameBegin);
         m_GameStarted = true;
-        m_Server->lauchGame();
         return;
     }
 

src/game/server/ServerGame.cpp

@@ -5,7 +5,7 @@ namespace td {
 namespace server {
 
 ServerGame::ServerGame(server::Server* server) : game::Game(&m_ServerWorld), m_Server(server), m_ServerWorld(server, this) {
-
+    bindListener(this);
 }
 
 void ServerGame::tick(std::uint64_t delta) {
@@ -70,5 +70,24 @@ void ServerGame::balanceTeams() {
     }
 }
 
+void ServerGame::OnGameStateUpdate(game::GameState newState) {
+    setGameState(newState);
+    protocol::UpdateGameStatePacket packet(newState);
+    m_Server->broadcastPacket(&packet);
+}
+
+void ServerGame::OnGameEnd() {
+    notifyListeners(&game::GameListener::OnGameStateUpdate, game::GameState::EndGame);
+}
+
+void ServerGame::OnGameClose() {
+    notifyListeners(&game::GameListener::OnGameStateUpdate, game::GameState::Closed);
+}
+
+void ServerGame::OnGameBegin() {
+    notifyListeners(&game::GameListener::OnGameStateUpdate, game::GameState::Game);
+    startGame();
+}
+
 } // namespace game
 } // namespace td