#include <Mqtt.h>

Inheritance diagram for mqtt::mqttstore::lib::Mqtt:

Collaboration diagram for mqtt::mqttstore::lib::Mqtt:

Public Member Functions

Mqtt (const std::string &connectionName, const std::string &clientId, std::uint8_t qoSDefault, std::uint16_t keepAlive, bool cleanSession, const std::string &willTopic, const std::string &willMessage, std::uint8_t willQoS, bool willRetain, const std::string &username, const std::string &password, const std::list< std::string > &subTopics, MariaDbStorage::ConnectionConfig connectionConfig, const std::string &rawTable, bool autoCreateRawTable, StoragePlan storagePlan, const std::string &sessionStoreFileName="")

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

Private Member Functions
void	onConnected () final
bool	onSignal (int signum) final
void	onConnack (const iot::mqtt::packets::Connack &connack) final
void	onPublish (const iot::mqtt::packets::Publish &publish) final
void	onSuback (const iot::mqtt::packets::Suback &suback) final

Static Private Member Functions
static std::uint8_t	getQos (const std::string &qoSString)

Private Attributes
MariaDbStorage	storage
const std::uint8_t	qoSDefault
const bool	cleanSession
const std::string	willTopic
const std::string	willMessage
const std::uint8_t	willQoS
const bool	willRetain
const std::string	username
const std::string	password
const std::list< std::string >	subTopics

Detailed Description

Definition at line 33 of file Mqtt.h.

Member Typedef Documentation

◆ Super

using mqtt::mqttstore::lib::Mqtt::Super = iot::mqtt::client::Mqtt

private

Definition at line 54 of file Mqtt.h.

Constructor & Destructor Documentation

◆ Mqtt()

mqtt::mqttstore::lib::Mqtt::Mqtt	(	const std::string &	connectionName,
		const std::string &	clientId,
		std::uint8_t	qoSDefault,
		std::uint16_t	keepAlive,
		bool	cleanSession,
		const std::string &	willTopic,
		const std::string &	willMessage,
		std::uint8_t	willQoS,
		bool	willRetain,
		const std::string &	username,
		const std::string &	password,
		const std::list< std::string > &	subTopics,
		MariaDbStorage::ConnectionConfig	connectionConfig,
		const std::string &	rawTable,
		bool	autoCreateRawTable,
		StoragePlan	storagePlan,
		const std::string &	sessionStoreFileName = "" )

explicit

Definition at line 37 of file Mqtt.cpp.

        : iot::mqtt::client::Mqtt(connectionName, clientId, keepAlive, sessionStoreFileName)
        , storage(connectionName, connectionConfig, rawTable, autoCreateRawTable, std::move(storagePlan))
        , qoSDefault(qoSDefault)
        , cleanSession(cleanSession)
        , willTopic(willTopic)
        , willMessage(willMessage)
        , willQoS(willQoS)
        , willRetain(willRetain)
        , username(username)
        , password(password)
        , subTopics(subTopics) {
        VLOG(1) << "MQTTStore client id: " << clientId;
        VLOG(1) << "  Keep Alive: " << keepAlive;
        VLOG(1) << "  Clean Session: " << cleanSession;
        VLOG(1) << "  Will Topic: " << willTopic;
        VLOG(1) << "  Will QoS: " << static_cast<std::uint16_t>(willQoS);
        VLOG(1) << "  Will Retain: " << willRetain;
        VLOG(1) << "  Username configured: " << (!username.empty());
    }

References cleanSession, Mqtt(), password, qoSDefault, username, willMessage, willQoS, willRetain, and willTopic.

Referenced by Mqtt().

Here is the call graph for this function:

Here is the caller graph for this function:

Member Function Documentation

◆ getQos()

std::uint8_t mqtt::mqttstore::lib::Mqtt::getQos ( const std::string & qoSString )

staticnodiscardprivate

Definition at line 87 of file Mqtt.cpp.

                                                      {
        const unsigned long qoS = std::stoul(qoSString);
 
        if (qoS > 2) {
            throw std::out_of_range("qos " + qoSString + " not in range [0..2]");
        }
 
        return static_cast<std::uint8_t>(qoS);
    }

Referenced by onConnack().

Here is the caller graph for this function:

◆ onConnack()

void mqtt::mqttstore::lib::Mqtt::onConnack ( const iot::mqtt::packets::Connack & connack )

finalprivate

Definition at line 97 of file Mqtt.cpp.

                                                             {
        if (connack.getReturnCode() != 0) {
            VLOG(0) << connectionName << " MQTTStore: broker rejected connection with return code "
                    << static_cast<int>(connack.getReturnCode());
            sendDisconnect();
            return;
        }
 
        if (subTopics.empty()) {
            VLOG(0) << connectionName << " MQTTStore: no subscriptions configured";
            sendDisconnect();
            return;
        }
 
        try {
            std::list<iot::mqtt::Topic> topicList;
            std::transform(subTopics.begin(),
                           subTopics.end(),
                           std::back_inserter(topicList),
                           [qoSDefault = this->qoSDefault](const std::string& compositeTopic) {
                               const std::size_t pos = compositeTopic.rfind("##");
                               const std::string topic = compositeTopic.substr(0, pos);
                               std::uint8_t qoS = qoSDefault;
 
                               if (pos != std::string::npos) {
                                   qoS = getQos(compositeTopic.substr(pos + 2));
                               }
 
                               VLOG(0) << "MQTTStore subscribe: QoS " << static_cast<int>(qoS) << " | " << topic;
                               return iot::mqtt::Topic(topic, qoS);
                           });
 
            sendSubscribe(topicList);
        } catch (const std::logic_error& error) {
            VLOG(0) << connectionName << " MQTTStore subscription failed: " << error.what();
            sendDisconnect();
        }
    }

References getQos(), and qoSDefault.

Here is the call graph for this function:

◆ onConnected()

void mqtt::mqttstore::lib::Mqtt::onConnected ( )

finalprivate

Definition at line 74 of file Mqtt.cpp.

                           {
        VLOG(1) << "MQTTStore: initiating MQTT session";
        sendConnect(cleanSession, willTopic, willMessage, willQoS, willRetain, username, password);
    }

References cleanSession, password, username, willMessage, willQoS, willRetain, and willTopic.

◆ onPublish()

void mqtt::mqttstore::lib::Mqtt::onPublish ( const iot::mqtt::packets::Publish & publish )

finalprivate

Definition at line 136 of file Mqtt.cpp.

                                                             {
        VLOG(1) << connectionName << " MQTTStore received publish: topic='" << publish.getTopic()
                << "' qos=" << static_cast<std::uint16_t>(publish.getQoS()) << " retain=" << (publish.getRetain() != 0)
                << " dup=" << (publish.getDup() != 0);
 
        storage.store({.connectionName = connectionName,
                       .topic = publish.getTopic(),
                       .payload = publish.getMessage(),
                       .qoS = publish.getQoS(),
                       .retain = publish.getRetain() != 0,
                       .dup = publish.getDup() != 0,
                       .packetIdentifier = publish.getPacketIdentifier()});
    }

◆ onSignal()

bool mqtt::mqttstore::lib::Mqtt::onSignal ( int signum )

nodiscardfinalprivate

Definition at line 79 of file Mqtt.cpp.

                                  {
        VLOG(1) << "MQTTStore: exit due to '" << strsignal(signum) << "' (SIG" << utils::system::sigabbrev_np(signum) << " = " << signum
                << ")";
        sendDisconnect();
 
        return Super::onSignal(signum);
    }

◆ onSuback()

void mqtt::mqttstore::lib::Mqtt::onSuback ( const iot::mqtt::packets::Suback & suback )

finalprivate

Definition at line 150 of file Mqtt.cpp.

                                                          {
        VLOG(1) << "MQTTStore Suback";
 
        for (auto returnCode : suback.getReturnCodes()) {
            VLOG(0) << "  r: " << static_cast<int>(returnCode);
        }
    }

Member Data Documentation

◆ cleanSession

const bool mqtt::mqttstore::lib::Mqtt::cleanSession

private

Definition at line 67 of file Mqtt.h.

Referenced by Mqtt(), and onConnected().

◆ password

const std::string mqtt::mqttstore::lib::Mqtt::password

private

Definition at line 73 of file Mqtt.h.

Referenced by Mqtt(), and onConnected().

◆ qoSDefault

const std::uint8_t mqtt::mqttstore::lib::Mqtt::qoSDefault

private

Definition at line 66 of file Mqtt.h.

Referenced by Mqtt(), and onConnack().

◆ storage

MariaDbStorage mqtt::mqttstore::lib::Mqtt::storage

private

Definition at line 65 of file Mqtt.h.

◆ subTopics

const std::list<std::string> mqtt::mqttstore::lib::Mqtt::subTopics

private

Definition at line 74 of file Mqtt.h.

◆ username

const std::string mqtt::mqttstore::lib::Mqtt::username

private

Definition at line 72 of file Mqtt.h.

Referenced by Mqtt(), and onConnected().

◆ willMessage

const std::string mqtt::mqttstore::lib::Mqtt::willMessage

private

Definition at line 69 of file Mqtt.h.

Referenced by Mqtt(), and onConnected().

◆ willQoS

const std::uint8_t mqtt::mqttstore::lib::Mqtt::willQoS

private

Definition at line 70 of file Mqtt.h.

Referenced by Mqtt(), and onConnected().

◆ willRetain

const bool mqtt::mqttstore::lib::Mqtt::willRetain

private

Definition at line 71 of file Mqtt.h.

Referenced by Mqtt(), and onConnected().

◆ willTopic

const std::string mqtt::mqttstore::lib::Mqtt::willTopic

private

Definition at line 68 of file Mqtt.h.

Referenced by Mqtt(), and onConnected().

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

mqttstore/lib/Mqtt.h
mqttstore/lib/Mqtt.cpp

MQTTSuite

Public Member Functions

Private Types

Private Member Functions

Static Private Member Functions

Private Attributes

Detailed Description

Member Typedef Documentation

◆ Super

Constructor & Destructor Documentation

◆ Mqtt()

Member Function Documentation

◆ getQos()

◆ onConnack()

◆ onConnected()

◆ onPublish()

◆ onSignal()

◆ onSuback()

Member Data Documentation

◆ cleanSession

◆ password

◆ qoSDefault

◆ storage

◆ subTopics

◆ username

◆ willMessage

◆ willQoS

◆ willRetain

◆ willTopic