RoomManager.hpp

Go to the documentation of this file.

/*
** EPITECH PROJECT, 2025
** Created by hugo on 06/12/2025
** File description:
** RoomManager.hpp
*/
 
#pragma once
 
#include <memory>
#include <mutex>
#include <unordered_map>
#include "server/Rooms/Matchmaking/MatchmakingService.hpp"
#include "server/Rooms/RoomManager/IRoomManager.hpp"
 
namespace server {
 
    // Callback type for when a match is created and players should be notified
    using RoomCreatedCallback = std::function<void(std::shared_ptr<Room>)>;
 
    class RoomManager : public IRoomManager {
       public:
        RoomManager();
        explicit RoomManager(std::shared_ptr<MatchmakingService> matchmaking,
                             std::shared_ptr<EventBus> eventBus = nullptr);
        ~RoomManager() override = default;
 
        std::shared_ptr<Room> createRoom(const std::string &id, const std::string &name = "",
                                         size_t maxPlayers = 4, bool isPrivate = false,
                                         float gameSpeedMultiplier = 1.0f) override;
        std::shared_ptr<Room> getRoom(const std::string &id) override;
        bool removeRoom(const std::string &id) override;
        std::vector<std::shared_ptr<Room>> getAllRooms() override;
        std::vector<std::shared_ptr<Room>> getPublicRooms() override;
        size_t getRoomCount() const override;
        bool update(float deltaTime) override;
 
        void addPlayerToMatchmaking(uint32_t playerId);
 
        void removePlayerFromMatchmaking(uint32_t playerId);
 
        std::shared_ptr<MatchmakingService> getMatchmaking() { return _matchmaking; }
 
        void setRoomCreatedCallback(RoomCreatedCallback callback) { _roomCreatedCallback = callback; }
 
        std::shared_ptr<Room> getRoomByPlayer(uint32_t playerId);
 
        void cleanupFinishedRooms();
 
       private:
        void _onMatchCreated(std::shared_ptr<Room> room);
 
        std::unordered_map<std::string, std::shared_ptr<Room>> _rooms;
        std::shared_ptr<MatchmakingService> _matchmaking;
        std::shared_ptr<EventBus> _eventBus;
        RoomCreatedCallback _roomCreatedCallback;
        mutable std::recursive_mutex
            _mutex;  // Recursive to allow getAllRooms() from event handlers during update()
    };
 
}  // namespace server