Session.hpp

Go to the documentation of this file.

 
#ifndef RTYPE_NETWORK_SESSION_HPP_
    #define RTYPE_NETWORK_SESSION_HPP_
 
    #include <asio.hpp>
    #include <cstdint>
    #include <memory>
    #include <deque>
    #include <mutex>
    #include "RType/Network/Packet.hpp"
    #include "RType/Network/INetwork.hpp"
    #include "RType/Network/IEventPublisher.hpp"
 
namespace rtp::net
{
    class Session : public std::enable_shared_from_this<Session> {
        public:
            Session(uint32_t id, 
                    asio::ip::tcp::socket socket, 
                    asio::ip::udp::socket& serverUdpSocket,
                    IEventPublisher &publisher);
            
            ~Session();
 
            void start(void);
 
            void stop(void);
 
            void send(const Packet& packet, NetworkMode mode);
 
            void setId(uint32_t id);
 
            uint32_t getId() const;
 
            asio::ip::tcp::endpoint getTcpEndpoint() const;
 
            void setUdpEndpoint(const asio::ip::udp::endpoint& endpoint);
 
            asio::ip::udp::endpoint getUdpEndpoint() const { return _udpEndpoint; }
 
        private:
            asio::awaitable<void> reader(void);
 
            asio::awaitable<void> writer(void);
 
        private:
            uint32_t _id;                             
            bool _stopped = false;                    
            asio::ip::tcp::socket _socket;            
            asio::ip::udp::socket& _serverUdpSocket;  
            IEventPublisher& _publisher;              
            asio::ip::udp::endpoint _udpEndpoint{};   
            bool _hasUdp = false;                     
            std::mutex _writeMutex;                   
            asio::steady_timer _timer;                
            std::deque<Packet> _writeQueue{};         
    };
}
 
#endif /* !RTYPE_NETWORK_SESSION_HPP_ */