ThreadCapsule.hpp

Go to the documentation of this file.

/*
** EPITECH PROJECT, 2024
** rtype (Workspace)
** File description:
** ThreadCapsule.hpp
*/
 
#pragma once
 
#include <string>
#include <vector>
#include <memory>
#include <atomic>
#include <thread>
#include <cstdint>
 
#include "GUI/Network/NetworkManager.hpp"
 
#define ENSURE_THREAD_ALIVE(method)                          \
    if (!isThreadAlive()) {                                  \
        PRETTY_ERROR << "No active thread for " << method << std::endl;                          \
        throw CustomExceptions::NoActiveNetworkThread("<No running thread for " + std::string(method) + ">"); \
    }
 
namespace GUI
{
    namespace Network
    {
        class ThreadCapsule : public GUI::ECS::EntityNode {
            public:
            ThreadCapsule(const std::uint32_t nodeId = 0);
            ~ThreadCapsule();
 
            void initialize();
 
            void startThread();
            void stopThread();
 
            void startGame();
 
            void sendMessage(const MessageNode &message);
            const std::vector<GUI::Network::MessageNode> getReceivedMessages();
 
            void setPort(const unsigned int port);
            void setIp(const std::string &ip);
            void setPlayerName(const std::string &name);
            void setAddress(const std::string &ip, const unsigned int port);
 
            const bool isConnected() const;
            const bool isThreadAlive() const;
 
            const float bytesToFloat(const uint8_t *bytes);
            const std::string bytesToHex(const std::vector<uint8_t> &bytes);
            const GUI::Network::MessageNode translateMessage(const std::vector<uint8_t> &message);
            void receiveMessage();
 
            private:
 
            void _spawnChild();
 
            void _killChild();
 
            std::thread _childThread;                                           
            unsigned int _port = 9000;                                          
            mutable std::mutex _mutex;                                          
            std::string _ip = "127.0.0.1";                                      
            std::string _playerName = "Player";                                 
            std::atomic<bool> _childAlive = false;                              
            std::shared_ptr<NetworkManager> _childNode;                         
        };
    }
}