Replicator.hpp

Go to the documentation of this file.

/*
** EPITECH PROJECT, 2025
** Created by samuelBleau on 26/11/2025.
** File description:
** Replicator.hpp
*/
 
#ifndef REPLICATOR_HPP
#define REPLICATOR_HPP
 
#include <atomic>
#include <cstdint>
#include <functional>
#include <iostream>
#include <memory>
#include <string>
#include <thread>
#include <vector>
#include "../common/Logger/Logger.hpp"
#include "Capnp/Messages/Messages.hpp"
#include "Capnp/NetworkMessages.hpp"
#include "Core/EventBus/EventBus.hpp"
#include "Events/InputEvent/InputEvent.hpp"
#include "Events/NetworkEvent/NetworkEvent.hpp"
#include "IHost.hpp"
#include "IPeer.hpp"
#include "NetworkFactory.hpp"
#include "ThreadSafeQueue.hpp"
 
class Replicator {
   public:
    explicit Replicator(EventBus &eventBus, bool isSpectator = false);
 
    ~Replicator();
 
    bool connect(const std::string &host, uint16_t port);
 
    void disconnect();
 
    bool isConnected() const;
 
    bool isAuthenticated() const;
 
    uint32_t getMyPlayerId() const { return _myPlayerId.load(); }
 
    void processMessages();
 
    void startNetworkThread();
 
    void stopNetworkThread();
 
    void sendPacket(NetworkMessageType type, const std::vector<uint8_t> &data);
 
    uint32_t getLatency() const;
 
    uint32_t getPacketLoss() const;
 
    bool isSpectator() const;
 
    bool sendConnectRequest(const std::string &playerName, const std::string &username,
                            const std::string &password);
 
    bool sendRegisterAccount(const std::string &username, const std::string &password);
 
    bool sendLoginAccount(const std::string &username, const std::string &password);
 
    bool sendListRooms();
 
    bool sendCreateRoom(const std::string &roomName, uint32_t maxPlayers, bool isPrivate,
                        float gameSpeedMultiplier = 1.0f);
 
    bool sendJoinRoom(const std::string &roomId);
 
    bool sendAutoMatchmaking();
 
    bool updateAutoMatchmakingPreference(bool enabled);
 
    bool sendStartGame();
 
    bool sendRequestRoomList();
 
    bool sendLeaveRoom();
 
    bool sendChatMessage(const std::string &message);
 
    bool getAutoMatchmakingPreference() const { return _autoMatchmakingPreference; }
 
   private:
    void networkThreadLoop(std::stop_token stopToken);
 
    void onInputEvent(const InputEvent &event);
    void processIncomingPacket(const std::vector<uint8_t> &packet);
 
    EventBus &_eventBus;
    std::atomic<bool> _connected{false};
    std::atomic<bool> _authenticated{false};
    std::atomic<uint32_t> _myPlayerId{0};
    std::string _lastLoginUsername;                       // Track username for AUTH_SUCCESS event
    std::atomic<bool> _autoMatchmakingPreference{false};  // User's auto-matchmaking preference from server
    bool _isSpectator;
    std::string _serverHost;
    uint16_t _serverPort = 0;
 
    std::atomic<uint32_t> _latency{0};
    uint32_t _packetLoss = 0;
 
    std::unique_ptr<IHost> _host;
    IPeer *_serverPeer = nullptr;
 
    // Multi-threading components
    std::jthread _networkThread;                      
    ThreadSafeQueue<NetworkEvent> _incomingMessages;  
 
    // Smoothed ping calculation (exponential moving average)
    static constexpr float PING_SMOOTHING_FACTOR = 0.3f;  // 30% new, 70% old
    std::atomic<float> _smoothedLatency{0.0f};
};
 
#endif