Horizon::Auth::AuthSession Class Reference

#include <AuthSession.hpp>

Inheritance diagram for Horizon::Auth::AuthSession:

Collaboration diagram for Horizon::Auth::AuthSession:

Public Member Functions
	AuthSession (uint64_t uid)
	~AuthSession ()
void	initialize () override
virtual void	update (uint32_t diff) override
std::unique_ptr< AuthClientInterface > &	clif ()
std::unique_ptr< ClientPacketLengthTable > &	pkt_tbl ()
void	transmit_buffer (ByteBuffer _buffer, std::size_t size)
Public Member Functions inherited from Horizon::Networking::Session< AuthSocket, AuthSession >
	Session (uint64_t uid)
virtual	~Session ()
std::shared_ptr< AuthSocket >	get_socket ()
	Get the socket. More...
void	set_socket (std::weak_ptr< AuthSocket > socket)
	Set the socket. More...
virtual void	update (uint32_t diff)=0
virtual void	initialize ()=0
bool	is_initialized ()
	Called to verify if the session is initialized. More...
void	set_initialized (bool initialized)
	Set whether the session is initialized or not. More...
uint64_t	get_session_id ()
	Get the unique id of the session. More...
ThreadSafeQueue< ByteBuffer > &	get_recv_queue ()
	Receive queue of the buffer received by the socket. More...

Private Attributes
std::unique_ptr< AuthClientInterface >	_clif
std::unique_ptr< ClientPacketLengthTable >	_pkt_tbl

Constructor & Destructor Documentation

AuthSession()

AuthSession::AuthSession

(

uint64_t

uid

)

: Networking::Session<AuthSocket, AuthSession>(uid)
{
}

~AuthSession()

AuthSession::~AuthSession

(

)

{
    //
}

Member Function Documentation

clif()

std::unique_ptr< AuthClientInterface > & Horizon::Auth::AuthSession::clif ( )

inline

{ return _clif; }

References _clif.

initialize()

void AuthSession::initialize ( )

overridevirtual

Called when the session is started. Virtual method that must be implmented by the derived class. Typically used to initialize the session.

Returns

void

Implements Horizon::Networking::Session< AuthSocket, AuthSession >.

{
    _pkt_tbl = std::make_unique<ClientPacketLengthTable>(shared_from_this());
    _clif = std::make_unique<AuthClientInterface>(shared_from_this());
    set_initialized(true);
}

References _clif, _pkt_tbl, and Horizon::Networking::Session< AuthSocket, AuthSession >::set_initialized().

Here is the call graph for this function:

pkt_tbl()

std::unique_ptr< ClientPacketLengthTable > & Horizon::Auth::AuthSession::pkt_tbl ( )

inline

{ return _pkt_tbl; }

References _pkt_tbl.

transmit_buffer()

void AuthSession::transmit_buffer	(	ByteBuffer	_buffer,
		std::size_t	size
	)

{
    if (get_socket() == nullptr || !get_socket()->is_open())
        return;
    
    if (!_buffer.is_empty()) {
        uint16_t packet_id = 0x0;
        int16_t packet_len = 0;
        
        memcpy(&packet_id, _buffer.get_read_pointer(), sizeof(int16_t));
 
        std::pair<int16_t, std::shared_ptr<Base::NetworkPacket<AuthSession>>> p;
        p = _pkt_tbl->get_tpacket_info(packet_id);
 
        if (p.first == 0) { // Check if packet sending is a handled packet.
            p = _pkt_tbl->get_hpacket_info(packet_id);
            if (p.first == 0) {
                HLog(warning) << "Trying to send packet 0x" << std::hex << packet_id << " which is unknown... ignoring.";
                return;
            }
        } 
 
        if (p.first == -1) {
            memcpy(&packet_len, _buffer.get_read_pointer() + 2, sizeof(int16_t));
        } else {
            packet_len = p.first;
        }
 
        if (packet_len != _buffer.active_length()) {
            HLog(warning) << "Packet 0x" << std::hex << packet_id << " has length len " << std::dec << packet_len << " but buffer has " << _buffer.active_length() << " bytes... ignoring.";
            return;
        }
 
        get_socket()->queue_buffer(std::move(_buffer));
    }
}

References _pkt_tbl, ByteBuffer::active_length(), ByteBuffer::get_read_pointer(), Horizon::Networking::Session< AuthSocket, AuthSession >::get_socket(), HLog, and ByteBuffer::is_empty().

Here is the call graph for this function:

update()

void AuthSession::update ( uint32_t  diff )

overridevirtual

Called when the session is started. Virtual method that must be implmented by the derived class. Typically used to update the session and process packets.

Returns

void

Implements Horizon::Networking::Session< AuthSocket, AuthSession >.

{
    std::shared_ptr<ByteBuffer> read_buf;
    while ((read_buf = get_recv_queue().try_pop())) {
        uint16_t packet_id = 0x0;
        memcpy(&packet_id, read_buf->get_read_pointer(), sizeof(uint16_t));
        HPacketTablePairType p = _pkt_tbl->get_hpacket_info(packet_id);
        p.second->handle(std::move(*read_buf));
    }
}

References _pkt_tbl, and Horizon::Networking::Session< AuthSocket, AuthSession >::get_recv_queue().

Here is the call graph for this function:

Member Data Documentation

_clif

std::unique_ptr<AuthClientInterface> Horizon::Auth::AuthSession::_clif

private

Referenced by clif(), and initialize().

_pkt_tbl

std::unique_ptr<ClientPacketLengthTable> Horizon::Auth::AuthSession::_pkt_tbl

private

Referenced by initialize(), pkt_tbl(), transmit_buffer(), and update().

---

The documentation for this class was generated from the following files:

• src/Server/Auth/Session/AuthSession.hpp
• src/Server/Auth/Session/AuthSession.cpp