#include <Mqtt.h>

Inheritance diagram for iot::mqtt::server::Mqtt:

Collaboration diagram for iot::mqtt::server::Mqtt:

Public Member Functions
	Mqtt (const std::string &connectionName, const std::shared_ptr< broker::Broker > &broker)

	~Mqtt () override

void	subscribe (const std::string &topic, uint8_t qoS) const

void	unsubscribe (const std::string &topic) const

void	sendConnack (uint8_t returnCode, uint8_t flags) const

void	sendSuback (uint16_t packetIdentifier, const std::list< uint8_t > &returnCodes) const

void	sendUnsuback (uint16_t packetIdentifier) const

void	sendPingresp () const

std::list< std::string >	getSubscriptions () const

std::string	getProtocol () const

uint8_t	getLevel () const

uint8_t	getConnectFlags () const

uint16_t	getKeepAlive () const

std::string	getClientId () const

std::string	getWillTopic () const

std::string	getWillMessage () const

std::string	getUsername () const

std::string	getPassword () const

bool	getUsernameFlag () const

bool	getPasswordFlag () const

bool	getWillRetain () const

uint8_t	getWillQoS () const

bool	getWillFlag () const

bool	getCleanSession () const

bool	getReflect () const

Public Member Functions inherited from iot::mqtt::Mqtt
	Mqtt (const std::string &connectionName)

	Mqtt (const std::string &connectionName, const std::string &clientId)

	Mqtt (Mqtt &&)=delete

	Mqtt (const Mqtt &)=delete

Mqtt &	operator= (Mqtt &&)=delete

Mqtt &	operator= (const Mqtt &)=delete

virtual void	onConnected ()

virtual void	onDisconnected ()

const std::string &	getConnectionName () const

const MqttContext *	getMqttContext () const

void	sendPublish (const std::string &topic, const std::string &message, uint8_t qoS, bool retain)

void	sendPuback (uint16_t packetIdentifier) const

void	sendPubrec (uint16_t packetIdentifier) const

void	sendPubrel (uint16_t packetIdentifier) const

void	sendPubcomp (uint16_t packetIdentifier) const

Protected Member Functions
bool	onSignal (int sig) override

Protected Member Functions inherited from iot::mqtt::Mqtt
void	initSession (Session *session, utils::Timeval keepAlive)

virtual void	onPublish (const iot::mqtt::packets::Publish &publish)

virtual void	onPuback (const iot::mqtt::packets::Puback &puback)

virtual void	onPubrec (const iot::mqtt::packets::Pubrec &pubrec)

virtual void	onPubrel (const iot::mqtt::packets::Pubrel &pubrel)

virtual void	onPubcomp (const iot::mqtt::packets::Pubcomp &pubcomp)

bool	_onPublish (const iot::mqtt::packets::Publish &publish)

void	_onPuback (const iot::mqtt::packets::Puback &puback)

void	_onPubrec (const iot::mqtt::packets::Pubrec &pubrec)

void	_onPubrel (const iot::mqtt::packets::Pubrel &pubrel)

void	_onPubcomp (const iot::mqtt::packets::Pubcomp &pubcomp)

uint16_t	getPacketIdentifier ()

void	send (const iot::mqtt::ControlPacket &controlPacket) const

void	printVP (const iot::mqtt::ControlPacket &packet) const

void	printFixedHeader (const iot::mqtt::FixedHeader &fixedHeader) const

Protected Attributes
std::string	protocol

uint8_t	level = 0

uint8_t	connectFlags = 0

uint16_t	keepAlive = 0

std::string	willTopic

std::string	willMessage

std::string	username

std::string	password

bool	usernameFlag = false

bool	passwordFlag = false

bool	willRetain = false

uint8_t	willQoS = 0

bool	willFlag = false

bool	cleanSession = false

bool	reflect = true

std::shared_ptr< iot::mqtt::server::broker::Broker >	broker

Protected Attributes inherited from iot::mqtt::Mqtt
std::string	connectionName

std::string	clientId

MqttContext *	mqttContext = nullptr

Private Types
using	Super = iot::mqtt::Mqtt

Private Member Functions
iot::mqtt::ControlPacketDeserializer *	createControlPacketDeserializer (iot::mqtt::FixedHeader &fixedHeader) final

void	deliverPacket (iot::mqtt::ControlPacketDeserializer *controlPacketDeserializer) override

bool	initSession (const utils::Timeval &keepAlive)

void	releaseSession ()

virtual void	onConnect (const iot::mqtt::packets::Connect &connect)

virtual void	onSubscribe (const iot::mqtt::packets::Subscribe &subscribe)

virtual void	onUnsubscribe (const iot::mqtt::packets::Unsubscribe &unsubscribe)

virtual void	onPingreq (const iot::mqtt::packets::Pingreq &pingreq)

virtual void	onDisconnect (const iot::mqtt::packets::Disconnect &disconnect)

void	_onConnect (const iot::mqtt::server::packets::Connect &connect)

void	_onPublish (const iot::mqtt::server::packets::Publish &publish)

void	_onSubscribe (const iot::mqtt::server::packets::Subscribe &subscribe)

void	_onUnsubscribe (const iot::mqtt::server::packets::Unsubscribe &unsubscribe)

void	_onPingreq (const iot::mqtt::server::packets::Pingreq &pingreq)

void	_onDisconnect (const iot::mqtt::server::packets::Disconnect &disconnect)

void	initSession (Session *session, utils::Timeval keepAlive)

Friends
class	iot::mqtt::server::packets::Connect

class	iot::mqtt::server::packets::Subscribe

class	iot::mqtt::server::packets::Unsubscribe

class	iot::mqtt::server::packets::Pingreq

class	iot::mqtt::server::packets::Disconnect

class	iot::mqtt::server::packets::Publish

class	iot::mqtt::server::packets::Pubcomp

class	iot::mqtt::server::packets::Pubrec

class	iot::mqtt::server::packets::Puback

class	iot::mqtt::server::packets::Pubrel

Additional Inherited Members
Static Public Member Functions inherited from iot::mqtt::Mqtt
static std::string	toHexString (const std::vector< char > &data)

static std::string	toHexString (const std::string &data)

Detailed Description

Definition at line 87 of file Mqtt.h.

Member Typedef Documentation

◆ Super

using iot::mqtt::server::Mqtt::Super = iot::mqtt::Mqtt

private

Definition at line 89 of file Mqtt.h.

Constructor & Destructor Documentation

◆ Mqtt()

iot::mqtt::server::Mqtt::Mqtt	(	const std::string &	connectionName,
		const std::shared_ptr< broker::Broker > &	broker
	)

explicit

Definition at line 73 of file Mqtt.cpp.

        : Super(connectionName)
        , broker(broker) {
    }

References iot::mqtt::Mqtt::Mqtt().

Here is the call graph for this function:

◆ ~Mqtt()

iot::mqtt::server::Mqtt::~Mqtt ( )

overridevirtual

Reimplemented from iot::mqtt::Mqtt.

Definition at line 78 of file Mqtt.cpp.

                {
        releaseSession();
 
        if (willFlag) {
            broker->publish(clientId, willTopic, willMessage, willQoS, willRetain);
        }
    }

References iot::mqtt::Mqtt::clientId, iot::mqtt::server::broker::Broker::publish(), releaseSession(), willFlag, willMessage, willQoS, willRetain, and willTopic.

Here is the call graph for this function:

Member Function Documentation

◆ _onConnect()

void iot::mqtt::server::Mqtt::_onConnect ( const iot::mqtt::server::packets::Connect & connect )

private

Definition at line 221 of file Mqtt.cpp.

                                                                    {
        LOG(INFO) << connectionName << " MQTT Broker:   Protocol: " << connect.getProtocol();
        LOG(INFO) << connectionName << " MQTT Broker:   Version: " << static_cast<uint16_t>(connect.getLevel());
        LOG(INFO) << connectionName << " MQTT Broker:   ConnectFlags: 0x" << std::hex << std::setfill('0') << std::setw(2)
                  << static_cast<uint16_t>(connect.getConnectFlags()) << std::dec << std::setw(0);
        LOG(INFO) << connectionName << " MQTT Broker:   KeepAlive: " << connect.getKeepAlive();
        LOG(INFO) << connectionName << " MQTT Broker:   ClientID: " << connect.getClientId();
        LOG(INFO) << connectionName << " MQTT Broker:   CleanSession: " << connect.getCleanSession();
 
        if (connect.getWillFlag()) {
            LOG(INFO) << connectionName << " MQTT Broker:   WillTopic: " << connect.getWillTopic();
            LOG(INFO) << connectionName << " MQTT Broker:   WillMessage: " << connect.getWillMessage();
            LOG(INFO) << connectionName << " MQTT Broker:   WillQoS: " << static_cast<uint16_t>(connect.getWillQoS());
            LOG(INFO) << connectionName << " MQTT Broker:   WillRetain: " << connect.getWillRetain();
        }
        if (connect.getUsernameFlag()) {
            LOG(INFO) << connectionName << " MQTT Broker:   Username: " << connect.getUsername();
        }
        if (connect.getPasswordFlag()) {
            LOG(INFO) << connectionName << " MQTT Broker:   Password: " << connect.getPassword();
        }
 
        if (connect.getProtocol() != "MQTT") {
            LOG(ERROR) << connectionName << " MQTT Broker:   Wrong Protocol: " << connect.getProtocol();
            mqttContext->end(true);
        } else if ((connect.getLevel()) != MQTT_VERSION_3_1_1) {
            LOG(ERROR) << connectionName << " MQTT Broker:   Wrong Protocol Level: " << MQTT_VERSION_3_1_1 << " != " << connect.getLevel();
            sendConnack(MQTT_CONNACK_UNACEPTABLEVERSION, MQTT_SESSION_NEW);
 
            mqttContext->end(true);
        } else if (connect.isFakedClientId() && !connect.getCleanSession()) {
            LOG(ERROR) << connectionName << " MQTT Broker:   Resume session but no ClientId present";
            sendConnack(MQTT_CONNACK_IDENTIFIERREJECTED, MQTT_SESSION_NEW);
 
            mqttContext->end(true);
        } else {
            // V-Header
            protocol = connect.getProtocol();
            level = connect.getLevel();
            reflect = connect.getReflect();
            connectFlags = connect.getConnectFlags();
            keepAlive = connect.getKeepAlive();
 
            // Payload
            clientId = connect.getClientId();
            willTopic = connect.getWillTopic();
            willMessage = connect.getWillMessage();
            username = connect.getUsername();
            password = connect.getPassword();
 
            // Derived from flags
            usernameFlag = connect.getUsernameFlag();
            passwordFlag = connect.getPasswordFlag();
            willRetain = connect.getWillRetain();
            willQoS = connect.getWillQoS();
            willFlag = connect.getWillFlag();
            cleanSession = connect.getCleanSession();
 
            if (initSession(keepAlive)) {
                onConnect(connect);
            } else {
                mqttContext->end(true);
            }
        }
    }

Referenced by iot::mqtt::server::packets::Connect::deliverPacket().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ _onDisconnect()

void iot::mqtt::server::Mqtt::_onDisconnect ( const iot::mqtt::server::packets::Disconnect & disconnect )

private

Definition at line 348 of file Mqtt.cpp.

                                                                             {
        willFlag = false;
 
        onDisconnect(disconnect);
 
        releaseSession();
    }

References onDisconnect(), releaseSession(), and willFlag.

Referenced by iot::mqtt::server::packets::Disconnect::deliverPacket().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ _onPingreq()

void iot::mqtt::server::Mqtt::_onPingreq ( const iot::mqtt::server::packets::Pingreq & pingreq )

private

Definition at line 342 of file Mqtt.cpp.

                                                                    {
        sendPingresp();
 
        onPingreq(pingreq);
    }

References onPingreq(), and sendPingresp().

Referenced by iot::mqtt::server::packets::Pingreq::deliverPacket().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ _onPublish()

void iot::mqtt::server::Mqtt::_onPublish ( const iot::mqtt::server::packets::Publish & publish )

private

Definition at line 287 of file Mqtt.cpp.

                                                                    {
        if (Super::_onPublish(publish)) {
            broker->publish(clientId, publish.getTopic(), publish.getMessage(), publish.getQoS(), publish.getRetain());
 
            onPublish(publish);
        }
    }

References iot::mqtt::Mqtt::_onPublish(), iot::mqtt::Mqtt::clientId, iot::mqtt::packets::Publish::getMessage(), iot::mqtt::packets::Publish::getQoS(), iot::mqtt::packets::Publish::getRetain(), iot::mqtt::packets::Publish::getTopic(), iot::mqtt::Mqtt::onPublish(), and iot::mqtt::server::broker::Broker::publish().

Referenced by iot::mqtt::server::packets::Publish::deliverPacket().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ _onSubscribe()

void iot::mqtt::server::Mqtt::_onSubscribe ( const iot::mqtt::server::packets::Subscribe & subscribe )

private

Definition at line 295 of file Mqtt.cpp.

                                                                          {
        if (subscribe.getPacketIdentifier() == 0) {
            LOG(ERROR) << connectionName << " MQTT Broker:   PackageIdentifier missing";
            mqttContext->end(true);
        } else {
            LOG(DEBUG) << connectionName << " MQTT Broker:   PacketIdentifier: 0x" << std::hex << std::setfill('0') << std::setw(4)
                       << subscribe.getPacketIdentifier();
 
            for (const iot::mqtt::Topic& topic : subscribe.getTopics()) {
                LOG(INFO) << connectionName << " MQTT Broker:   Topic filter: '" << topic.getName()
                          << "', QoS: " << static_cast<uint16_t>(topic.getQoS());
            }
 
            std::list<uint8_t> returnCodes;
            for (const iot::mqtt::Topic& topic : subscribe.getTopics()) {
                const uint8_t returnCode = broker->subscribe(clientId, topic.getName(), topic.getQoS());
                returnCodes.push_back(returnCode);
            }
 
            sendSuback(subscribe.getPacketIdentifier(), returnCodes);
 
            onSubscribe(subscribe);
        }
    }

References iot::mqtt::Mqtt::clientId, iot::mqtt::Mqtt::connectionName, iot::mqtt::MqttContext::end(), iot::mqtt::Topic::getName(), iot::mqtt::packets::Subscribe::getPacketIdentifier(), iot::mqtt::Topic::getQoS(), iot::mqtt::packets::Subscribe::getTopics(), iot::mqtt::Mqtt::mqttContext, onSubscribe(), sendSuback(), and iot::mqtt::server::broker::Broker::subscribe().

Referenced by iot::mqtt::server::packets::Subscribe::deliverPacket().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ _onUnsubscribe()

void iot::mqtt::server::Mqtt::_onUnsubscribe ( const iot::mqtt::server::packets::Unsubscribe & unsubscribe )

private

Definition at line 320 of file Mqtt.cpp.

                                                                                {
        if (unsubscribe.getPacketIdentifier() == 0) {
            LOG(ERROR) << connectionName << " MQTT Broker:   PackageIdentifier missing";
            mqttContext->end(true);
        } else {
            LOG(DEBUG) << connectionName << " MQTT Broker:   PacketIdentifier: 0x" << std::hex << std::setfill('0') << std::setw(4)
                       << unsubscribe.getPacketIdentifier();
 
            for (const std::string& topic : unsubscribe.getTopics()) {
                LOG(INFO) << connectionName << " MQTT Broker:   Topic: " << topic;
            }
 
            for (const std::string& topic : unsubscribe.getTopics()) {
                broker->unsubscribe(clientId, topic);
            }
 
            sendUnsuback(unsubscribe.getPacketIdentifier());
 
            onUnsubscribe(unsubscribe);
        }
    }

References iot::mqtt::Mqtt::clientId, iot::mqtt::Mqtt::connectionName, iot::mqtt::MqttContext::end(), iot::mqtt::packets::Unsubscribe::getPacketIdentifier(), iot::mqtt::packets::Unsubscribe::getTopics(), iot::mqtt::Mqtt::mqttContext, onUnsubscribe(), sendUnsuback(), and iot::mqtt::server::broker::Broker::unsubscribe().

Referenced by iot::mqtt::server::packets::Unsubscribe::deliverPacket().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ createControlPacketDeserializer()

iot::mqtt::ControlPacketDeserializer * iot::mqtt::server::Mqtt::createControlPacketDeserializer ( iot::mqtt::FixedHeader & fixedHeader )

finalprivatevirtual

Implements iot::mqtt::Mqtt.

Definition at line 99 of file Mqtt.cpp.

                                                                                                           {
        iot::mqtt::ControlPacketDeserializer* controlPacketDeserializer = nullptr;
 
        switch (fixedHeader.getType()) {
            case MQTT_CONNECT:
                controlPacketDeserializer =
                    new iot::mqtt::server::packets::Connect(fixedHeader.getRemainingLength(), fixedHeader.getFlags());
                break;
            case MQTT_PUBLISH:
                controlPacketDeserializer =
                    new iot::mqtt::server::packets::Publish(fixedHeader.getRemainingLength(), fixedHeader.getFlags());
                break;
            case MQTT_PUBACK:
                controlPacketDeserializer =
                    new iot::mqtt::server::packets::Puback(fixedHeader.getRemainingLength(), fixedHeader.getFlags());
                break;
            case MQTT_PUBREC:
                controlPacketDeserializer =
                    new iot::mqtt::server::packets::Pubrec(fixedHeader.getRemainingLength(), fixedHeader.getFlags());
                break;
            case MQTT_PUBREL:
                controlPacketDeserializer =
                    new iot::mqtt::server::packets::Pubrel(fixedHeader.getRemainingLength(), fixedHeader.getFlags());
                break;
            case MQTT_PUBCOMP:
                controlPacketDeserializer =
                    new iot::mqtt::server::packets::Pubcomp(fixedHeader.getRemainingLength(), fixedHeader.getFlags());
                break;
            case MQTT_SUBSCRIBE:
                controlPacketDeserializer =
                    new iot::mqtt::server::packets::Subscribe(fixedHeader.getRemainingLength(), fixedHeader.getFlags());
                break;
            case MQTT_UNSUBSCRIBE:
                controlPacketDeserializer =
                    new iot::mqtt::server::packets::Unsubscribe(fixedHeader.getRemainingLength(), fixedHeader.getFlags());
                break;
            case MQTT_PINGREQ:
                controlPacketDeserializer =
                    new iot::mqtt::server::packets::Pingreq(fixedHeader.getRemainingLength(), fixedHeader.getFlags());
                break;
            case MQTT_DISCONNECT:
                controlPacketDeserializer =
                    new iot::mqtt::server::packets::Disconnect(fixedHeader.getRemainingLength(), fixedHeader.getFlags());
                break;
            default:
                controlPacketDeserializer = nullptr;
                break;
        }
 
        return controlPacketDeserializer;
    }

Here is the call graph for this function:

◆ deliverPacket()

void iot::mqtt::server::Mqtt::deliverPacket ( iot::mqtt::ControlPacketDeserializer * controlPacketDeserializer )

overrideprivatevirtual

Implements iot::mqtt::Mqtt.

Definition at line 151 of file Mqtt.cpp.

                                                                                        {
        static_cast<iot::mqtt::server::ControlPacketDeserializer*>(controlPacketDeserializer)->deliverPacket(this); // NOLINT
    }

References iot::mqtt::server::ControlPacketDeserializer::deliverPacket().

Here is the call graph for this function:

◆ getCleanSession()

bool iot::mqtt::server::Mqtt::getCleanSession ( ) const

Definition at line 432 of file Mqtt.cpp.

                                     {
        return cleanSession;
    }

References cleanSession.

◆ getClientId()

std::string iot::mqtt::server::Mqtt::getClientId ( ) const

Definition at line 392 of file Mqtt.cpp.

                                      {
        return clientId;
    }

References iot::mqtt::Mqtt::clientId.

Referenced by iot::mqtt::server::broker::Session::sendPublish().

Here is the caller graph for this function:

◆ getConnectFlags()

uint8_t iot::mqtt::server::Mqtt::getConnectFlags ( ) const

Definition at line 384 of file Mqtt.cpp.

                                        {
        return connectFlags;
    }

References connectFlags.

◆ getKeepAlive()

uint16_t iot::mqtt::server::Mqtt::getKeepAlive ( ) const

Definition at line 388 of file Mqtt.cpp.

                                      {
        return keepAlive;
    }

References keepAlive.

◆ getLevel()

uint8_t iot::mqtt::server::Mqtt::getLevel ( ) const

Definition at line 380 of file Mqtt.cpp.

                                 {
        return level;
    }

References level.

◆ getPassword()

std::string iot::mqtt::server::Mqtt::getPassword ( ) const

Definition at line 408 of file Mqtt.cpp.

                                      {
        return password;
    }

References password.

◆ getPasswordFlag()

bool iot::mqtt::server::Mqtt::getPasswordFlag ( ) const

Definition at line 416 of file Mqtt.cpp.

                                     {
        return passwordFlag;
    }

References passwordFlag.

◆ getProtocol()

std::string iot::mqtt::server::Mqtt::getProtocol ( ) const

Definition at line 376 of file Mqtt.cpp.

                                      {
        return protocol;
    }

References protocol.

◆ getReflect()

bool iot::mqtt::server::Mqtt::getReflect ( ) const

Definition at line 436 of file Mqtt.cpp.

                                {
        return reflect;
    }

References reflect.

Referenced by iot::mqtt::server::broker::Session::sendPublish().

Here is the caller graph for this function:

◆ getSubscriptions()

std::list< std::string > iot::mqtt::server::Mqtt::getSubscriptions ( ) const

Definition at line 372 of file Mqtt.cpp.

                                                    {
        return broker->getSubscriptions(clientId);
    }

References iot::mqtt::Mqtt::clientId, and iot::mqtt::server::broker::Broker::getSubscriptions().

Here is the call graph for this function:

◆ getUsername()

std::string iot::mqtt::server::Mqtt::getUsername ( ) const

Definition at line 404 of file Mqtt.cpp.

                                      {
        return username;
    }

References username.

◆ getUsernameFlag()

bool iot::mqtt::server::Mqtt::getUsernameFlag ( ) const

Definition at line 412 of file Mqtt.cpp.

                                     {
        return usernameFlag;
    }

References usernameFlag.

◆ getWillFlag()

bool iot::mqtt::server::Mqtt::getWillFlag ( ) const

Definition at line 428 of file Mqtt.cpp.

                                 {
        return willFlag;
    }

References willFlag.

◆ getWillMessage()

std::string iot::mqtt::server::Mqtt::getWillMessage ( ) const

Definition at line 400 of file Mqtt.cpp.

                                         {
        return willMessage;
    }

References willMessage.

◆ getWillQoS()

uint8_t iot::mqtt::server::Mqtt::getWillQoS ( ) const

Definition at line 424 of file Mqtt.cpp.

                                   {
        return willQoS;
    }

References willQoS.

◆ getWillRetain()

bool iot::mqtt::server::Mqtt::getWillRetain ( ) const

Definition at line 420 of file Mqtt.cpp.

                                   {
        return willRetain;
    }

References willRetain.

◆ getWillTopic()

std::string iot::mqtt::server::Mqtt::getWillTopic ( ) const

Definition at line 396 of file Mqtt.cpp.

                                       {
        return willTopic;
    }

References willTopic.

◆ initSession() [1/2]

bool iot::mqtt::server::Mqtt::initSession ( const utils::Timeval & keepAlive )

private

Definition at line 155 of file Mqtt.cpp.

                                                        {
        bool success = true;
 
        if (broker->hasActiveSession(clientId)) {
            LOG(ERROR) << connectionName << " MQTT Broker: Existing session found for ClientId = " << clientId;
            LOG(ERROR) << connectionName << " MQTT Broker:   closing";
            sendConnack(MQTT_CONNACK_IDENTIFIERREJECTED, 0);
 
            willFlag = false;
            success = false;
        } else if (broker->hasRetainedSession(clientId)) {
            LOG(INFO) << connectionName << " MQTT Broker: Retained session found for ClientId = " << clientId;
            if (cleanSession) {
                LOG(DEBUG) << connectionName << "   New SessionId = " << this;
                sendConnack(MQTT_CONNACK_ACCEPT, MQTT_SESSION_NEW);
 
                broker->unsubscribe(clientId);
                initSession(broker->newSession(clientId, this), keepAlive);
            } else {
                LOG(DEBUG) << connectionName << "   Renew SessionId = " << this;
                sendConnack(MQTT_CONNACK_ACCEPT, MQTT_SESSION_PRESENT);
 
                initSession(broker->renewSession(clientId, this), keepAlive);
                broker->restartSession(clientId);
            }
        } else {
            LOG(INFO) << connectionName << " MQTT Broker: No session found for ClientId = " << clientId;
            LOG(INFO) << connectionName << " MQTT Broker:   new SessionId = " << this;
 
            sendConnack(MQTT_CONNACK_ACCEPT, MQTT_SESSION_NEW);
 
            initSession(broker->newSession(clientId, this), keepAlive);
        }
 
        return success;
    }

References cleanSession, iot::mqtt::Mqtt::clientId, iot::mqtt::Mqtt::connectionName, iot::mqtt::server::broker::Broker::hasActiveSession(), iot::mqtt::server::broker::Broker::hasRetainedSession(), iot::mqtt::Mqtt::initSession(), iot::mqtt::server::broker::Broker::newSession(), iot::mqtt::server::broker::Broker::renewSession(), iot::mqtt::server::broker::Broker::restartSession(), sendConnack(), iot::mqtt::server::broker::Broker::unsubscribe(), and willFlag.

Referenced by _onConnect().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ initSession() [2/2]

void iot::mqtt::Mqtt::initSession	(	Session *	session,
		utils::Timeval	keepAlive
	)

private

Definition at line 105 of file Mqtt.cpp.

                                                                   {
        this->session = session;
 
        for (const auto& [packetIdentifier, publish] : session->publishMap) {
            LOG(INFO) << connectionName << " MQTT: PUBLISH Resend";
 
            send(publish);
        }
 
        for (const uint16_t packetIdentifier : session->pubrelPacketIdentifierSet) {
            LOG(INFO) << connectionName << " MQTT: PUBREL Resend";
 
            send(iot::mqtt::packets::Pubrel(packetIdentifier));
        }
 
        if (keepAlive > 0) {
            keepAlive *= 1.5;
 
            LOG(INFO) << connectionName << " MQTT: Keep alive initialized with: " << keepAlive;
 
            keepAliveTimer = core::timer::Timer::singleshotTimer(
                [this, keepAlive]() {
                    LOG(ERROR) << connectionName << " MQTT: Keep-alive timer expired. Interval was: " << keepAlive;
                    mqttContext->close();
                },
                keepAlive);
        }
 
        mqttContext->getSocketConnection()->setTimeout(0);
    }

◆ onConnect()

void iot::mqtt::server::Mqtt::onConnect ( const iot::mqtt::packets::Connect & connect )

privatevirtual

Definition at line 206 of file Mqtt.cpp.

206 {

207 }

Referenced by _onConnect().

Here is the caller graph for this function:

◆ onDisconnect()

void iot::mqtt::server::Mqtt::onDisconnect ( const iot::mqtt::packets::Disconnect & disconnect )

privatevirtual

Definition at line 218 of file Mqtt.cpp.

218 {

219 }

Referenced by _onDisconnect().

Here is the caller graph for this function:

◆ onPingreq()

void iot::mqtt::server::Mqtt::onPingreq ( const iot::mqtt::packets::Pingreq & pingreq )

privatevirtual

Definition at line 215 of file Mqtt.cpp.

215 {

216 }

Referenced by _onPingreq().

Here is the caller graph for this function:

◆ onSignal()

bool iot::mqtt::server::Mqtt::onSignal ( int sig )

overrideprotectedvirtual

Implements iot::mqtt::Mqtt.

Definition at line 94 of file Mqtt.cpp.

                                                {
        willFlag = false;
        return true;
    }

References willFlag.

◆ onSubscribe()

void iot::mqtt::server::Mqtt::onSubscribe ( const iot::mqtt::packets::Subscribe & subscribe )

privatevirtual

Definition at line 209 of file Mqtt.cpp.

209 {

210 }

Referenced by _onSubscribe().

Here is the caller graph for this function:

◆ onUnsubscribe()

void iot::mqtt::server::Mqtt::onUnsubscribe ( const iot::mqtt::packets::Unsubscribe & unsubscribe )

privatevirtual

Definition at line 212 of file Mqtt.cpp.

212 {

213 }

Referenced by _onUnsubscribe().

Here is the caller graph for this function:

◆ releaseSession()

void iot::mqtt::server::Mqtt::releaseSession ( )

private

Definition at line 192 of file Mqtt.cpp.

                              {
        if (broker->isActiveSession(clientId, this)) {
            if (cleanSession) {
                LOG(DEBUG) << connectionName << " MQTT Broker: Delete session for ClientId = " << clientId;
                LOG(DEBUG) << connectionName << " MQTT Broker:   SessionId = " << this;
                broker->deleteSession(clientId);
            } else {
                LOG(DEBUG) << connectionName << " MQTT Broker: Retain session for ClientId = " << clientId;
                LOG(DEBUG) << connectionName << " MQTT Broker:   SessionId = " << this;
                broker->retainSession(clientId);
            }
        }
    }

References cleanSession, iot::mqtt::Mqtt::clientId, iot::mqtt::Mqtt::connectionName, iot::mqtt::server::broker::Broker::deleteSession(), iot::mqtt::server::broker::Broker::isActiveSession(), and iot::mqtt::server::broker::Broker::retainSession().

Referenced by _onDisconnect(), and ~Mqtt().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ sendConnack()

void iot::mqtt::server::Mqtt::sendConnack	(	uint8_t	returnCode,
		uint8_t	flags
	)		const

Definition at line 356 of file Mqtt.cpp.

                                                                  { // Server
        send(iot::mqtt::packets::Connack(returnCode, flags));
    }

References iot::mqtt::packets::Connack::Connack(), and iot::mqtt::Mqtt::send().

Referenced by _onConnect(), and initSession().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ sendPingresp()

void iot::mqtt::server::Mqtt::sendPingresp ( ) const

Definition at line 368 of file Mqtt.cpp.

                                  { // Server
        send(iot::mqtt::packets::Pingresp());
    }

References iot::mqtt::packets::Pingresp::Pingresp(), and iot::mqtt::Mqtt::send().

Referenced by _onPingreq().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ sendSuback()

void iot::mqtt::server::Mqtt::sendSuback	(	uint16_t	packetIdentifier,
		const std::list< uint8_t > &	returnCodes
	)		const

Definition at line 360 of file Mqtt.cpp.

                                                                                              { // Server
        send(iot::mqtt::packets::Suback(packetIdentifier, returnCodes));
    }

References iot::mqtt::Mqtt::send(), and iot::mqtt::packets::Suback::Suback().

Referenced by _onSubscribe().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ sendUnsuback()

void iot::mqtt::server::Mqtt::sendUnsuback ( uint16_t packetIdentifier ) const

Definition at line 364 of file Mqtt.cpp.

                                                           { // Server
        send(iot::mqtt::packets::Unsuback(packetIdentifier));
    }

References iot::mqtt::Mqtt::send(), and iot::mqtt::packets::Unsuback::Unsuback().

Referenced by _onUnsubscribe().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ subscribe()

void iot::mqtt::server::Mqtt::subscribe	(	const std::string &	topic,
		uint8_t	qoS
	)		const

Definition at line 86 of file Mqtt.cpp.

                                                                  {
        broker->subscribe(clientId, topic, qoS);
    }

References iot::mqtt::Mqtt::clientId, and iot::mqtt::server::broker::Broker::subscribe().

Here is the call graph for this function:

◆ unsubscribe()

void iot::mqtt::server::Mqtt::unsubscribe ( const std::string & topic ) const

Definition at line 90 of file Mqtt.cpp.

                                                       {
        broker->unsubscribe(clientId, topic);
    }

References iot::mqtt::Mqtt::clientId, and iot::mqtt::server::broker::Broker::unsubscribe().

Here is the call graph for this function:

Friends And Related Symbol Documentation

◆ iot::mqtt::server::packets::Connect

friend class iot::mqtt::server::packets::Connect

friend

Definition at line 170 of file Mqtt.h.

◆ iot::mqtt::server::packets::Disconnect

friend class iot::mqtt::server::packets::Disconnect

friend

Definition at line 174 of file Mqtt.h.

◆ iot::mqtt::server::packets::Pingreq

friend class iot::mqtt::server::packets::Pingreq

friend

Definition at line 173 of file Mqtt.h.

◆ iot::mqtt::server::packets::Puback

friend class iot::mqtt::server::packets::Puback

friend

Definition at line 178 of file Mqtt.h.

◆ iot::mqtt::server::packets::Pubcomp

friend class iot::mqtt::server::packets::Pubcomp

friend

Definition at line 176 of file Mqtt.h.

◆ iot::mqtt::server::packets::Publish

friend class iot::mqtt::server::packets::Publish

friend

Definition at line 175 of file Mqtt.h.

◆ iot::mqtt::server::packets::Pubrec

friend class iot::mqtt::server::packets::Pubrec

friend

Definition at line 177 of file Mqtt.h.

◆ iot::mqtt::server::packets::Pubrel

friend class iot::mqtt::server::packets::Pubrel

friend

Definition at line 179 of file Mqtt.h.

◆ iot::mqtt::server::packets::Subscribe

friend class iot::mqtt::server::packets::Subscribe

friend

Definition at line 171 of file Mqtt.h.

◆ iot::mqtt::server::packets::Unsubscribe

friend class iot::mqtt::server::packets::Unsubscribe

friend

Definition at line 172 of file Mqtt.h.

Member Data Documentation

◆ broker

std::shared_ptr<iot::mqtt::server::broker::Broker> iot::mqtt::server::Mqtt::broker

protected

Definition at line 168 of file Mqtt.h.

◆ cleanSession

bool iot::mqtt::server::Mqtt::cleanSession = false

protected

Definition at line 165 of file Mqtt.h.

Referenced by _onConnect(), getCleanSession(), initSession(), and releaseSession().

◆ connectFlags

uint8_t iot::mqtt::server::Mqtt::connectFlags = 0

protected

Definition at line 152 of file Mqtt.h.

Referenced by _onConnect(), and getConnectFlags().

◆ keepAlive

uint16_t iot::mqtt::server::Mqtt::keepAlive = 0

protected

Definition at line 153 of file Mqtt.h.

Referenced by _onConnect(), and getKeepAlive().

◆ level

uint8_t iot::mqtt::server::Mqtt::level = 0

protected

Definition at line 151 of file Mqtt.h.

Referenced by _onConnect(), and getLevel().

◆ password

std::string iot::mqtt::server::Mqtt::password

protected

Definition at line 158 of file Mqtt.h.

Referenced by _onConnect(), and getPassword().

◆ passwordFlag

bool iot::mqtt::server::Mqtt::passwordFlag = false

protected

Definition at line 161 of file Mqtt.h.

Referenced by _onConnect(), and getPasswordFlag().

◆ protocol

std::string iot::mqtt::server::Mqtt::protocol

protected

Definition at line 150 of file Mqtt.h.

Referenced by _onConnect(), and getProtocol().

◆ reflect

bool iot::mqtt::server::Mqtt::reflect = true

protected

Definition at line 166 of file Mqtt.h.

Referenced by _onConnect(), and getReflect().

◆ username

std::string iot::mqtt::server::Mqtt::username

protected

Definition at line 157 of file Mqtt.h.

Referenced by _onConnect(), and getUsername().

◆ usernameFlag

bool iot::mqtt::server::Mqtt::usernameFlag = false

protected

Definition at line 160 of file Mqtt.h.

Referenced by _onConnect(), and getUsernameFlag().

◆ willFlag

bool iot::mqtt::server::Mqtt::willFlag = false

protected

Definition at line 164 of file Mqtt.h.

Referenced by _onConnect(), _onDisconnect(), getWillFlag(), initSession(), onSignal(), and ~Mqtt().

◆ willMessage

std::string iot::mqtt::server::Mqtt::willMessage

protected

Definition at line 156 of file Mqtt.h.

Referenced by _onConnect(), getWillMessage(), and ~Mqtt().

◆ willQoS

uint8_t iot::mqtt::server::Mqtt::willQoS = 0

protected

Definition at line 163 of file Mqtt.h.

Referenced by _onConnect(), getWillQoS(), and ~Mqtt().

◆ willRetain

bool iot::mqtt::server::Mqtt::willRetain = false

protected

Definition at line 162 of file Mqtt.h.

Referenced by _onConnect(), getWillRetain(), and ~Mqtt().

◆ willTopic

std::string iot::mqtt::server::Mqtt::willTopic

protected

Definition at line 155 of file Mqtt.h.

Referenced by _onConnect(), getWillTopic(), and ~Mqtt().

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

iot/mqtt/server/Mqtt.h
iot/mqtt/server/Mqtt.cpp

Public Member Functions

Protected Member Functions

Protected Attributes

Private Types

Private Member Functions

Friends

Additional Inherited Members

Detailed Description

Member Typedef Documentation

◆ Super

Constructor & Destructor Documentation

◆ Mqtt()

◆ ~Mqtt()

Member Function Documentation

◆ _onConnect()

◆ _onDisconnect()

◆ _onPingreq()

◆ _onPublish()

◆ _onSubscribe()

◆ _onUnsubscribe()

◆ createControlPacketDeserializer()

◆ deliverPacket()

◆ getCleanSession()

◆ getClientId()

◆ getConnectFlags()

◆ getKeepAlive()

◆ getLevel()

◆ getPassword()

◆ getPasswordFlag()

◆ getProtocol()

◆ getReflect()

◆ getSubscriptions()

◆ getUsername()

◆ getUsernameFlag()

◆ getWillFlag()

◆ getWillMessage()

◆ getWillQoS()

◆ getWillRetain()

◆ getWillTopic()

◆ initSession() [1/2]

◆ initSession() [2/2]

◆ onConnect()

◆ onDisconnect()

◆ onPingreq()

◆ onSignal()

◆ onSubscribe()

◆ onUnsubscribe()

◆ releaseSession()

◆ sendConnack()

◆ sendPingresp()

◆ sendSuback()

◆ sendUnsuback()

◆ subscribe()

◆ unsubscribe()

Friends And Related Symbol Documentation

◆ iot::mqtt::server::packets::Connect

◆ iot::mqtt::server::packets::Disconnect

◆ iot::mqtt::server::packets::Pingreq

◆ iot::mqtt::server::packets::Puback

◆ iot::mqtt::server::packets::Pubcomp

◆ iot::mqtt::server::packets::Publish

◆ iot::mqtt::server::packets::Pubrec

◆ iot::mqtt::server::packets::Pubrel

◆ iot::mqtt::server::packets::Subscribe

◆ iot::mqtt::server::packets::Unsubscribe

Member Data Documentation

◆ broker

◆ cleanSession

◆ connectFlags

◆ keepAlive

◆ level

◆ password

◆ passwordFlag

◆ protocol

◆ reflect

◆ username

◆ usernameFlag

◆ willFlag

◆ willMessage

◆ willQoS