mqtt::mqttcli::lib::Mqtt Class Reference

#include <Mqtt.h>

Inheritance diagram for mqtt::mqttcli::lib::Mqtt:

Collaboration diagram for mqtt::mqttcli::lib::Mqtt:

Public Member Functions

Mqtt (const std::string &connectionName, const std::string &clientId, uint8_t qoSDefault, uint16_t keepAlive, bool cleanSession, const std::string &willTopic, const std::string &willMessage, uint8_t willQoS, bool willRetain, const std::string &username, const std::string &password, const std::list< std::string > &subTopics, const std::string &pubTopic, const std::string &pubMessage, bool pubRetain=false, const std::string &sessionStoreFileName="")

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

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

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

Detailed Description

Definition at line 57 of file Mqtt.h.

Member Typedef Documentation

Super

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

private

Definition at line 77 of file Mqtt.h.

Constructor & Destructor Documentation

Mqtt()

mqtt::mqttcli::lib::Mqtt::Mqtt ( const std::string & connectionName, const std::string & clientId, uint8_t qoSDefault, uint16_t keepAlive, bool cleanSession, const std::string & willTopic, const std::string & willMessage, uint8_t willQoS, bool willRetain, const std::string & username, const std::string & password, const std::list< std::string > & subTopics, const std::string & pubTopic, const std::string & pubMessage, bool pubRetain = false, const std::string & sessionStoreFileName = "" )

explicit

Definition at line 220 of file Mqtt.cpp.

        : iot::mqtt::client::Mqtt(connectionName, clientId, keepAlive, sessionStoreFileName)
        , qoSDefault(qoSDefault)
        , cleanSession(cleanSession)
        , willTopic(willTopic)
        , willMessage(willMessage)
        , willQoS(willQoS)
        , willRetain(willRetain)
        , username(username)
        , password(password)
        , subTopics(subTopics)
        , pubTopic(pubTopic)
        , pubMessage(pubMessage)
        , pubRetain(pubRetain) {
        VLOG(1) << "Client Id: " << clientId;
        VLOG(1) << "  Keep Alive: " << keepAlive;
        VLOG(1) << "  Clean Session: " << cleanSession;
        VLOG(1) << "  Will Topic: " << willTopic;
        VLOG(1) << "  Will Message: " << willMessage;
        VLOG(1) << "  Will QoS: " << static_cast<uint16_t>(willQoS);
        VLOG(1) << "  Will Retain " << willRetain;
        VLOG(1) << "  Username: " << username;
        VLOG(1) << "  Password: " << password;
    }

References cleanSession, password, pubMessage, pubRetain, pubTopic, qoSDefault, subTopics, username, willMessage, willQoS, willRetain, and willTopic.

Referenced by mqtt::mqttcli::SocketContextFactory::create().

Here is the caller graph for this function:

Member Function Documentation

onConnack()

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

finalprivate

Definition at line 285 of file Mqtt.cpp.

                                                             {
        bool sendDisconnectFlag = true;
 
        if (connack.getReturnCode() == 0) {
            if (!subTopics.empty()) {
                VLOG(0) << "MQTT Subscribe";
 
                try {
                    std::list<iot::mqtt::Topic> topicList;
                    std::transform(subTopics.begin(),
                                   subTopics.end(),
                                   std::back_inserter(topicList),
                                   [qoSDefault = this->qoSDefault](const std::string& compositTopic) -> iot::mqtt::Topic {
                                       std::size_t pos = compositTopic.rfind("##");
 
                                       const std::string topic = compositTopic.substr(0, pos);
                                       uint8_t qoS = qoSDefault;
 
                                       if (pos != std::string::npos) {
                                           try {
                                               qoS = getQos(compositTopic.substr(pos + 2));
                                           } catch (const std::logic_error& error) {
                                               VLOG(0) << "[" << Color::Code::FG_RED << "Error" << Color::Code::FG_DEFAULT
                                                       << "] Malformed composit topic: " << compositTopic << "\n"
                                                       << error.what();
                                               throw;
                                           }
                                       }
                                       VLOG(0) << "  t: " << static_cast<int>(qoS) << " | " << topic;
                                       return iot::mqtt::Topic(topic, qoS);
                                   });
                    sendSubscribe(topicList);
 
                    sendDisconnectFlag = false;
                } catch (const std::logic_error&) {
                }
            }
 
            if (!pubTopic.empty()) {
                VLOG(0) << "MQTT Publish";
 
                std::size_t pos = pubTopic.rfind("##");
 
                const std::string topic = pubTopic.substr(0, pos);
 
                uint8_t qoS = qoSDefault;
 
                try {
                    if (pos != std::string::npos) {
                        try {
                            qoS = getQos(pubTopic.substr(pos + 2));
                        } catch (const std::logic_error& error) {
                            VLOG(0) << "[" << Color::Code::FG_RED << "Error" << Color::Code::FG_DEFAULT
                                    << "] Malformed composit topic: " << pubTopic << "\n"
                                    << error.what();
                            throw;
                        }
                    }
                    sendPublish(topic, pubMessage, qoS, pubRetain);
 
                    sendDisconnectFlag = qoS > 0 ? false : sendDisconnectFlag;
                } catch (const std::logic_error&) {
                }
            }
            if (sendDisconnectFlag) {
                sendDisconnect();
            }
        } else {
            sendDisconnect();
        }
    }

References mqtt::mqttcli::lib::getQos(), pubMessage, pubRetain, pubTopic, qoSDefault, and subTopics.

Here is the call graph for this function:

onConnected()

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

finalprivate

Definition at line 260 of file Mqtt.cpp.

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

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

onPuback()

void mqtt::mqttcli::lib::Mqtt::onPuback ( const iot::mqtt::packets::Puback & puback )

finalprivate

Definition at line 374 of file Mqtt.cpp.

                                                                           {
        if (subTopics.empty()) {
            sendDisconnect();
        }
    }

References subTopics.

onPubcomp()

void mqtt::mqttcli::lib::Mqtt::onPubcomp ( const iot::mqtt::packets::Pubcomp & pubcomp )

finalprivate

Definition at line 380 of file Mqtt.cpp.

                                                                              {
        if (subTopics.empty()) {
            sendDisconnect();
        }
    }

References subTopics.

onPublish()

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

finalprivate

Definition at line 365 of file Mqtt.cpp.

                                                             {
        std::string prefix = "MQTT Publish";
        std::string headLine = publish.getTopic() + " │ QoS: " + std::to_string(static_cast<uint16_t>(publish.getQoS())) +
                               " │ Retain: " + (publish.getRetain() != 0 ? "true" : "false") +
                               " │ Dup: " + (publish.getDup() != 0 ? "true" : "false");
 
        VLOG(0) << formatAsLogString(prefix, headLine, publish.getMessage());
    }

References formatAsLogString().

Here is the call graph for this function:

onSignal()

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

nodiscardfinalprivate

Definition at line 266 of file Mqtt.cpp.

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

onSuback()

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

finalprivate

Definition at line 357 of file Mqtt.cpp.

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

Member Data Documentation

cleanSession

const bool mqtt::mqttcli::lib::Mqtt::cleanSession

private

Definition at line 89 of file Mqtt.h.

Referenced by Mqtt(), and onConnected().

password

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

private

Definition at line 96 of file Mqtt.h.

Referenced by Mqtt(), and onConnected().

pubMessage

const std::string mqtt::mqttcli::lib::Mqtt::pubMessage

private

Definition at line 100 of file Mqtt.h.

Referenced by Mqtt(), and onConnack().

pubRetain

const bool mqtt::mqttcli::lib::Mqtt::pubRetain

private

Definition at line 101 of file Mqtt.h.

Referenced by Mqtt(), and onConnack().

pubTopic

const std::string mqtt::mqttcli::lib::Mqtt::pubTopic

private

Definition at line 99 of file Mqtt.h.

Referenced by Mqtt(), and onConnack().

qoSDefault

const uint8_t mqtt::mqttcli::lib::Mqtt::qoSDefault

private

Definition at line 88 of file Mqtt.h.

Referenced by Mqtt(), and onConnack().

subTopics

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

private

Definition at line 98 of file Mqtt.h.

Referenced by Mqtt(), onConnack(), onPuback(), and onPubcomp().

username

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

private

Definition at line 95 of file Mqtt.h.

Referenced by Mqtt(), and onConnected().

willMessage

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

private

Definition at line 92 of file Mqtt.h.

Referenced by Mqtt(), and onConnected().

willQoS

const uint8_t mqtt::mqttcli::lib::Mqtt::willQoS

private

Definition at line 93 of file Mqtt.h.

Referenced by Mqtt(), and onConnected().

willRetain

const bool mqtt::mqttcli::lib::Mqtt::willRetain

private

Definition at line 94 of file Mqtt.h.

Referenced by Mqtt(), and onConnected().

willTopic

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

private

Definition at line 91 of file Mqtt.h.

Referenced by Mqtt(), and onConnected().

---

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

• mqttcli/lib/Mqtt.h
• mqttcli/lib/Mqtt.cpp