MatchmakingService.hpp

Go to the documentation of this file.

/*
** EPITECH PROJECT, 2025
** Created by hugo on 06/12/2025
** File description:
** MatchmakingService.hpp
*/
 
#pragma once
 
#include <chrono>
#include <cstdint>
#include <memory>
#include <mutex>
#include <unordered_map>
#include <vector>
#include "server/Rooms/Matchmaking/IMatchmakingService.hpp"
 
namespace server {
    class EventBus;  // Forward declaration
 
    struct PlayerQueueInfo {
        uint32_t playerId;
        std::chrono::steady_clock::time_point joinTime;
    };
 
    class MatchmakingService : public IMatchmakingService {
       public:
        explicit MatchmakingService(size_t minPlayers = 2, size_t maxPlayers = 4,
                                    std::shared_ptr<server::EventBus> eventBus = nullptr);
        ~MatchmakingService() override = default;
 
        void addPlayer(uint32_t playerId) override;
        void removePlayer(uint32_t playerId) override;
        void tick() override;
        size_t getQueueSize() const override;
        void setMatchCreatedCallback(MatchCreatedCallback callback) override;
        std::pair<std::shared_ptr<Room>, bool> findOrCreateMatch(
            uint32_t playerId, const std::vector<std::shared_ptr<Room>> &availableRooms,
            bool allowSpectator = true) override;
 
        std::vector<PlayerQueueInfo> getWaitingPlayers() const;
 
        void setMinPlayers(size_t min);
 
        void setMaxPlayers(size_t max);
 
        std::string getStatistics() const;
 
       private:
        bool _tryCreateMatch();
 
        std::string _generateRoomId();
 
        size_t _minPlayers;
        size_t _maxPlayers;
        std::shared_ptr<server::EventBus> _eventBus;
 
        std::vector<PlayerQueueInfo> _waitingPlayers;
        mutable std::mutex _mutex;
 
        MatchCreatedCallback _matchCreatedCallback;
 
        // Statistics
        uint32_t _totalMatchesCreated{0};
        uint32_t _totalPlayersMatched{0};
    };
 
}  // namespace server