game_server.hpp

Go to the documentation of this file.

#pragma once
 
#include <atomic>
#include <cstdint>
#include <map>
#include <memory>
#include <mutex>
#include <queue>
#include <sockpp/tcp_acceptor.h>
#include <thread>
 
#include "protocol/protocol.hpp"
#include "server/connection.hpp"
#include "server/game_session.hpp"
#include "server/session_manager.hpp"
 
class GameServer
{
public:
    explicit GameServer(uint16_t port = Protocol::DEFAULT_PORT);
    ~GameServer();
 
    void start();
 
    void stop();
 
    bool isRunning() const { return running_; }
 
private:
    void acceptConnections();
 
    void handleConnection(std::shared_ptr<Connection> conn);
 
    void onMessage(std::shared_ptr<Connection> conn, const std::string &data);
 
    void onDisconnect(uint32_t connection_id);
 
    // Message handlers
    void handleConnectRequest(std::shared_ptr<Connection> conn, const std::string &payload);
    void handleJoinGame(std::shared_ptr<Connection> conn, const std::string &payload);
    void handleListGames(std::shared_ptr<Connection> conn, const std::string &payload);
    void handleDisconnect(std::shared_ptr<Connection> conn, const std::string &payload);
    void handleMakeMove(std::shared_ptr<Connection> conn, const std::string &payload);
    void handleCreateGame(std::shared_ptr<Connection> conn, const std::string &payload);
 
    // Helper functions
    void sendError(std::shared_ptr<Connection> conn, uint16_t error_code,
                   const std::string &message);
    void sendWrappedMessage(std::shared_ptr<Connection> conn,
                            MessageType type, const std::string &payload);
    void broadcastGameState(uint32_t game_id);
    uint32_t createGame(uint8_t rows, uint8_t cols, uint8_t num_players,
                        uint8_t connect_length, std::string game_name = "");
    GameInfo getGameInfo(uint32_t game_id, const GameSession &game);
    GameStateUpdate createGameStateUpdate(const GameSession &game);
    void skipAbandonedPlayers(const std::shared_ptr<GameSession> &game);
 
    uint16_t port_;
 
    sockpp::tcp_acceptor acceptor_;
    SessionManager session_manager_;
 
    std::map<uint32_t, std::shared_ptr<Connection>> connections_;
    std::map<uint32_t, std::shared_ptr<GameSession>> games_;
 
    std::atomic<bool> running_;
    std::queue<uint32_t> free_connection_ids_;
    std::queue<uint32_t> free_game_ids_;
 
    std::mutex connections_mutex_;
    std::mutex games_mutex_;
};