iot::mqtt::Session Class Reference

#include <Session.h>

Inheritance diagram for iot::mqtt::Session:

Collaboration diagram for iot::mqtt::Session:

Public Member Functions
	Session ()=default
	Session (const nlohmann::json &json)
virtual	~Session ()=default
	Session (const Session &)=default
Session &	operator= (const Session &)=default
bool	isCleanSession () const
virtual nlohmann::json	toJson () const
void	fromJson (const nlohmann::json &json)
void	clear ()

Private Attributes
std::map< uint16_t, iot::mqtt::packets::Publish >	publishMap
std::set< uint16_t >	pubrelPacketIdentifierSet
std::set< uint16_t >	publishPacketIdentifierSet

Friends
class	iot::mqtt::Mqtt

Detailed Description

Definition at line 62 of file Session.h.

Constructor & Destructor Documentation

Session() [1/3]

iot::mqtt::Session::Session ( )

default

Session() [2/3]

iot::mqtt::Session::Session ( const nlohmann::json &  json )

explicit

Definition at line 55 of file Session.cpp.

                                             {
        fromJson(json);
    }

References fromJson().

Here is the call graph for this function:

~Session()

virtual iot::mqtt::Session::~Session ( )

virtualdefault

Session() [3/3]

iot::mqtt::Session::Session ( const Session &  )

default

Member Function Documentation

clear()

void iot::mqtt::Session::clear

(

)

Definition at line 111 of file Session.cpp.

                        {
        publishMap.clear();
        pubrelPacketIdentifierSet.clear();
        publishPacketIdentifierSet.clear();
    }

References publishMap, publishPacketIdentifierSet, and pubrelPacketIdentifierSet.

Referenced by iot::mqtt::client::Mqtt::Mqtt().

Here is the caller graph for this function:

fromJson()

void iot::mqtt::Session::fromJson

(

const nlohmann::json &

json

)

Definition at line 89 of file Session.cpp.

                                                   {
        if (json.contains("pubrel_packetidentifier_set")) {
            pubrelPacketIdentifierSet = static_cast<std::set<uint16_t>>(json["pubrel_packetidentifier_set"]);
        }
        if (json.contains("publish_packetidentifier_set")) {
            publishPacketIdentifierSet = static_cast<std::set<uint16_t>>(json["publish_packetidentifier_set"]);
        }
        if (json.contains("publish_map")) {
            for (const auto& publishJson : json["publish_map"]) {
                if (publishJson.contains("packet_identifier")) {
                    publishMap.emplace(publishJson["packet_identifier"],
                                       iot::mqtt::packets::Publish(publishJson["packet_identifier"],
                                                                   publishJson["topic"],
                                                                   publishJson["message"],
                                                                   publishJson["qos"],
                                                                   publishJson["dup"],
                                                                   publishJson["retain"]));
                }
            }
        }
    }

References iot::mqtt::packets::Publish::Publish(), publishMap, publishPacketIdentifierSet, and pubrelPacketIdentifierSet.

Referenced by iot::mqtt::server::broker::Session::fromJson(), iot::mqtt::client::Mqtt::Mqtt(), and Session().

Here is the call graph for this function:

Here is the caller graph for this function:

isCleanSession()

bool iot::mqtt::Session::isCleanSession

(

)

const

operator=()

Session & iot::mqtt::Session::operator= ( const Session &  )

default

toJson()

nlohmann::json iot::mqtt::Session::toJson ( ) const

virtual

Reimplemented in iot::mqtt::server::broker::Session.

Definition at line 59 of file Session.cpp.

                                       {
        nlohmann::json json;
 
        std::vector<nlohmann::json> publishJsonVector;
        for (const auto& [packetIdentifier, publish] : publishMap) {
            nlohmann::json publishJson;
 
            publishJson["packet_identifier"] = packetIdentifier;
            publishJson["topic"] = publish.getTopic();
            publishJson["message"] = publish.getMessage();
            publishJson["dup"] = publish.getDup();
            publishJson["qos"] = publish.getQoS();
            publishJson["retain"] = publish.getRetain();
 
            publishJsonVector.emplace_back(publishJson);
        }
 
        if (!publishJsonVector.empty()) {
            json["publish_map"] = publishJsonVector;
        }
        if (!pubrelPacketIdentifierSet.empty()) {
            json["pubrel_packetidentifier_set"] = pubrelPacketIdentifierSet;
        }
        if (!publishPacketIdentifierSet.empty()) {
            json["publish_packetidentifier_set"] = publishPacketIdentifierSet;
        }
 
        return json;
    }

References iot::mqtt::packets::Publish::getDup(), iot::mqtt::packets::Publish::getMessage(), iot::mqtt::packets::Publish::getQoS(), iot::mqtt::packets::Publish::getRetain(), iot::mqtt::packets::Publish::getTopic(), publishMap, publishPacketIdentifierSet, and pubrelPacketIdentifierSet.

Referenced by iot::mqtt::server::broker::Session::toJson(), and iot::mqtt::client::Mqtt::~Mqtt().

Here is the call graph for this function:

Here is the caller graph for this function:

Friends And Related Symbol Documentation

iot::mqtt::Mqtt

friend class iot::mqtt::Mqtt

friend

Definition at line 87 of file Session.h.

Member Data Documentation

publishMap

std::map<uint16_t, iot::mqtt::packets::Publish> iot::mqtt::Session::publishMap

private

Definition at line 81 of file Session.h.

Referenced by iot::mqtt::Mqtt::_onPubcomp(), iot::mqtt::Mqtt::_onPubrec(), clear(), fromJson(), iot::mqtt::Mqtt::initSession(), iot::mqtt::Mqtt::sendPublish(), and toJson().

publishPacketIdentifierSet

std::set<uint16_t> iot::mqtt::Session::publishPacketIdentifierSet

private

Definition at line 85 of file Session.h.

Referenced by iot::mqtt::Mqtt::_onPublish(), iot::mqtt::Mqtt::_onPubrel(), clear(), fromJson(), and toJson().

pubrelPacketIdentifierSet

std::set<uint16_t> iot::mqtt::Session::pubrelPacketIdentifierSet

private

Definition at line 82 of file Session.h.

Referenced by iot::mqtt::Mqtt::_onPubcomp(), iot::mqtt::Mqtt::_onPubrec(), clear(), fromJson(), iot::mqtt::Mqtt::initSession(), and toJson().

---

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

• iot/mqtt/Session.h
• iot/mqtt/Session.cpp