#include <SubProtocol.h>

Inheritance diagram for iot::mqtt::SubProtocol< WSSubProtocolRoleT >:

Collaboration diagram for iot::mqtt::SubProtocol< WSSubProtocolRoleT >:

Public Member Functions
	SubProtocol (web::websocket::SubProtocolContext subProtocolContext, const std::string &name, iot::mqtt::Mqtt mqtt)

	~SubProtocol () override=default

std::size_t	recv (char *chunk, std::size_t chunklen) override

void	send (const char *chunk, std::size_t chunklen) override

void	end (bool fatal=false) override

void	close () override

Private Types
using	WSSubProtocolRole = WSSubProtocolRoleT

Private Member Functions
void	onConnected () override

void	onMessageStart (int opCode) override

void	onMessageData (const char *chunk, std::size_t chunkLen) override

void	onMessageEnd () override

void	onMessageError (uint16_t errnum) override

void	onDisconnected () override

bool	onSignal (int sig) override

core::socket::stream::SocketConnection *	getSocketConnection () const override

Private Member Functions inherited from iot::mqtt::MqttContext
	MqttContext (Mqtt *mqtt)

	MqttContext (const MqttContext &)=default

MqttContext &	operator= (const MqttContext &)=default

virtual	~MqttContext ()

void	onConnected ()

std::size_t	onReceivedFromPeer ()

void	onDisconnected ()

bool	onSignal (int sig)

Private Attributes
OnReceivedFromPeerEvent	onReceivedFromPeerEvent

std::string	data

std::vector< char >	buffer

std::size_t	cursor = 0

std::size_t	size = 0

Private Attributes inherited from iot::mqtt::MqttContext
Mqtt *	mqtt

Detailed Description

template<typename WSSubProtocolRoleT>
class iot::mqtt::SubProtocol< WSSubProtocolRoleT >

Definition at line 83 of file SubProtocol.h.

Member Typedef Documentation

◆ WSSubProtocolRole

template<typename WSSubProtocolRoleT >

using iot::mqtt::SubProtocol< WSSubProtocolRoleT >::WSSubProtocolRole = WSSubProtocolRoleT

private

Definition at line 87 of file SubProtocol.h.

Constructor & Destructor Documentation

◆ SubProtocol()

template<typename WSSubProtocolRole >

iot::mqtt::SubProtocol< WSSubProtocolRole >::SubProtocol	(	web::websocket::SubProtocolContext *	subProtocolContext,
		const std::string &	name,
		iot::mqtt::Mqtt *	mqtt )

Definition at line 59 of file SubProtocol.hpp.

        : WSSubProtocolRole(subProtocolContext, name, 0)
        , iot::mqtt::MqttContext(mqtt)
        , onReceivedFromPeerEvent([this]([[maybe_unused]] const utils::Timeval& currentTime) {
            iot::mqtt::MqttContext::onReceivedFromPeer();
 
            if (size > 0) {
                onReceivedFromPeerEvent.span();
            } else {
                buffer.clear();
                cursor = 0;
            }
        }) {
    }

◆ ~SubProtocol()

template<typename WSSubProtocolRoleT >

iot::mqtt::SubProtocol< WSSubProtocolRoleT >::~SubProtocol ( )

overridedefault

Member Function Documentation

◆ close()

template<typename WSSubProtocolRole >

void iot::mqtt::SubProtocol< WSSubProtocolRole >::close ( )

overridevirtual

Implements iot::mqtt::MqttContext.

Definition at line 99 of file SubProtocol.hpp.

                                               {
        WSSubProtocolRole::sendClose();
    }

◆ end()

template<typename WSSubProtocolRole >

void iot::mqtt::SubProtocol< WSSubProtocolRole >::end ( bool fatal = false )

overridevirtual

Implements iot::mqtt::MqttContext.

Definition at line 94 of file SubProtocol.hpp.

                                                                        {
        WSSubProtocolRole::sendClose();
    }

◆ getSocketConnection()

template<typename WSSubProtocolRole >

core::socket::stream::SocketConnection * iot::mqtt::SubProtocol< WSSubProtocolRole >::getSocketConnection ( ) const

overrideprivatevirtual

Implements iot::mqtt::MqttContext.

Definition at line 168 of file SubProtocol.hpp.

                                                                                                {
        return WSSubProtocolRole::subProtocolContext->getSocketConnection();
    }

◆ onConnected()

template<typename WSSubProtocolRole >

void iot::mqtt::SubProtocol< WSSubProtocolRole >::onConnected ( )

overrideprivate

Definition at line 104 of file SubProtocol.hpp.

                                                     {
        LOG(INFO) << getSocketConnection()->getConnectionName() << " WSMQTT: connected:";
        iot::mqtt::MqttContext::onConnected();
    }

◆ onDisconnected()

template<typename WSSubProtocolRole >

void iot::mqtt::SubProtocol< WSSubProtocolRole >::onDisconnected ( )

overrideprivate

Definition at line 151 of file SubProtocol.hpp.

                                                        {
        iot::mqtt::MqttContext::onDisconnected();
        LOG(DEBUG) << getSocketConnection()->getConnectionName() << " WSMQTT: disconnected:";
    }

◆ onMessageData()

template<typename WSSubProtocolRole >

void iot::mqtt::SubProtocol< WSSubProtocolRole >::onMessageData	(	const char *	chunk,
		std::size_t	chunkLen )

overrideprivate

Definition at line 120 of file SubProtocol.hpp.

                                                                                            {
        data.append(std::string(chunk, chunkLen));
 
        LOG(DEBUG) << getSocketConnection()->getConnectionName() << " WebSocket: Frame Data:\n"
                   << std::string(32, ' ').append(utils::hexDump(std::vector<char>(chunk, chunk + chunkLen), 32));
    }

◆ onMessageEnd()

template<typename WSSubProtocolRole >

void iot::mqtt::SubProtocol< WSSubProtocolRole >::onMessageEnd ( )

overrideprivate

Definition at line 128 of file SubProtocol.hpp.

                                                      {
        LOG(DEBUG) << getSocketConnection()->getConnectionName() << " WSMQTT: Message END";
 
        buffer.insert(buffer.end(), data.begin(), data.end());
        size += data.size();
        data.clear();
 
        iot::mqtt::MqttContext::onReceivedFromPeer();
 
        if (size > 0) {
            onReceivedFromPeerEvent.span();
        } else {
            buffer.clear();
            cursor = 0;
        }
    }

◆ onMessageError()

template<typename WSSubProtocolRole >

void iot::mqtt::SubProtocol< WSSubProtocolRole >::onMessageError ( uint16_t errnum )

overrideprivate

Definition at line 146 of file SubProtocol.hpp.

                                                                       {
        LOG(ERROR) << getSocketConnection()->getConnectionName() << " WSMQTT: Message error: " << errnum;
    }

◆ onMessageStart()

template<typename WSSubProtocolRole >

void iot::mqtt::SubProtocol< WSSubProtocolRole >::onMessageStart ( int opCode )

overrideprivate

Definition at line 110 of file SubProtocol.hpp.

                                                                  {
        if (opCode == web::websocket::SubProtocolContext::OpCode::TEXT) {
            LOG(ERROR) << getSocketConnection()->getConnectionName() << " WSMQTT: Wrong Opcode: " << opCode;
            this->end(true);
        } else {
            LOG(DEBUG) << getSocketConnection()->getConnectionName() << " WSMQTT: Message START: " << opCode;
        }
    }

◆ onSignal()

template<typename WSSubProtocolRole >

bool iot::mqtt::SubProtocol< WSSubProtocolRole >::onSignal ( int sig )

overrideprivate

Definition at line 157 of file SubProtocol.hpp.

                                                         {
        bool ret = iot::mqtt::MqttContext::onSignal(sig);
        LOG(INFO) << getSocketConnection()->getConnectionName() << " WSMQTT: exit due to '" << strsignal(sig) << "' (SIG"
                  << utils::system::sigabbrev_np(sig) << " = " << sig << ")";
 
        this->sendClose();
 
        return ret;
    }

◆ recv()

template<typename WSSubProtocolRole >

std::size_t iot::mqtt::SubProtocol< WSSubProtocolRole >::recv	(	char *	chunk,
		std::size_t	chunklen )

overridevirtual

Implements iot::mqtt::MqttContext.

Definition at line 77 of file SubProtocol.hpp.

                                                                                  {
        std::size_t maxReturn = std::min(chunklen, size);
 
        std::copy(buffer.data() + cursor, buffer.data() + cursor + maxReturn, chunk);
 
        cursor += maxReturn;
        size -= maxReturn;
 
        return maxReturn;
    }

◆ send()

template<typename WSSubProtocolRole >

void iot::mqtt::SubProtocol< WSSubProtocolRole >::send	(	const char *	chunk,
		std::size_t	chunklen )

overridevirtual

Implements iot::mqtt::MqttContext.

Definition at line 89 of file SubProtocol.hpp.

                                                                                   {
        WSSubProtocolRole::sendMessage(chunk, chunklen);
    }

Member Data Documentation

◆ buffer

template<typename WSSubProtocolRoleT >

std::vector<char> iot::mqtt::SubProtocol< WSSubProtocolRoleT >::buffer

private

Definition at line 113 of file SubProtocol.h.

◆ cursor

template<typename WSSubProtocolRoleT >

std::size_t iot::mqtt::SubProtocol< WSSubProtocolRoleT >::cursor = 0

private

Definition at line 114 of file SubProtocol.h.

◆ data

template<typename WSSubProtocolRoleT >

std::string iot::mqtt::SubProtocol< WSSubProtocolRoleT >::data

private

Definition at line 112 of file SubProtocol.h.

◆ onReceivedFromPeerEvent

template<typename WSSubProtocolRoleT >

OnReceivedFromPeerEvent iot::mqtt::SubProtocol< WSSubProtocolRoleT >::onReceivedFromPeerEvent

private

Definition at line 110 of file SubProtocol.h.

◆ size

template<typename WSSubProtocolRoleT >

std::size_t iot::mqtt::SubProtocol< WSSubProtocolRoleT >::size = 0

private

Definition at line 115 of file SubProtocol.h.

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

iot/mqtt/SubProtocol.h
iot/mqtt/SubProtocol.hpp

Public Member Functions

Private Types

Private Member Functions

Private Attributes

Detailed Description

Member Typedef Documentation

◆ WSSubProtocolRole

Constructor & Destructor Documentation

◆ SubProtocol()

◆ ~SubProtocol()

Member Function Documentation

◆ close()

◆ end()

◆ getSocketConnection()

◆ onConnected()

◆ onDisconnected()

◆ onMessageData()

◆ onMessageEnd()

◆ onMessageError()

◆ onMessageStart()

◆ onSignal()

◆ recv()

◆ send()

Member Data Documentation

◆ buffer

◆ cursor

◆ data

◆ onReceivedFromPeerEvent

◆ size