ClientNetwork.hpp

Go to the documentation of this file.

 
#ifndef RTYPE_NETWORK_NETWORK_HPP_
    #define RTYPE_NETWORK_NETWORK_HPP_
 
    #include "RType/Network/INetwork.hpp"
    #include "RType/Network/Packet.hpp"
    #include "RType/Network/IEventPublisher.hpp"
 
    #include <memory>
    #include <optional>
    #include <deque>
    #include <mutex>
    #include <asio.hpp>
    #include <thread>
    #include <array>
 
namespace rtp::client {
 
     class ClientNetwork: public net::INetwork, public net::IEventPublisher {
        public:
            ClientNetwork(const std::string &serverIp, uint16_t serverPort);
 
            ~ClientNetwork() override;
 
            void start(void) override;
 
            void stop(void) override;
 
            void sendPacket(const net::Packet &packet, net::NetworkMode mode);
 
            std::optional<net::NetworkEvent> pollEvent(void) override;
 
            void publishEvent(net::NetworkEvent event);
 
            std::vector<net::Packet> hasPendingPackets(void);
 
            net::Packet popPacket(void);
 
            void readTcpHeader(void);
 
            void readTcpBody(void);
 
            void readUdp(void);
 
            void sendUdpHandshake(void);
 
            bool isUdpReady(void) const;
 
        private:
            uint16_t _serverPort;                       
            std::string _serverIp;                      
            asio::io_context _ioContext;                
            asio::ip::tcp::socket _tcpSocket;           
            asio::ip::udp::socket _udpSocket;           
            asio::ip::udp::endpoint _serverEndpoint;    
            std::thread _ioThread;                      
            std::mutex _eventQueueMutex;                
            std::deque<net::NetworkEvent> _eventQueue;  
            net::Header _tcpHeader;                     
            net::Header _udpHeader;                     
            std::vector<uint8_t> _tcpBody;              
            uint32_t _sessionId = 0;                    
            bool _udpBound = false;                     
            std::array<char, 65536> _udpBuffer;         
            asio::ip::udp::endpoint _udpSenderEndpoint; 
     };
}; // namespace rtp::client
 
#endif /* !RTYPE_NETWORK_NETWORK_HPP_ */