iot::mqtt::server::broker::RetainTree::TopicLevel Class Reference

Collaboration diagram for iot::mqtt::server::broker::RetainTree::TopicLevel:

Public Member Functions
	TopicLevel (iot::mqtt::server::broker::Broker *broker)
void	retain (const Message &message, std::string topic)
bool	release (std::string topic)
void	appear (const std::string &clientId, std::string topic, uint8_t qoS)
TopicLevel &	fromJson (const nlohmann::json &json)
nlohmann::json	toJson () const
void	clear ()

Private Member Functions
void	appear (const std::string &clientId, uint8_t clientQoS)

Private Attributes
Message	message
std::map< std::string, TopicLevel >	subTopicLevels
iot::mqtt::server::broker::Broker *	broker = nullptr

Detailed Description

Definition at line 53 of file RetainTree.h.

Constructor & Destructor Documentation

TopicLevel()

iot::mqtt::server::broker::RetainTree::TopicLevel::TopicLevel ( iot::mqtt::server::broker::Broker * broker )

explicit

Definition at line 71 of file RetainTree.cpp.

        : broker(broker) {
    }

Referenced by clear().

Here is the caller graph for this function:

Member Function Documentation

appear() [1/2]

void iot::mqtt::server::broker::RetainTree::TopicLevel::appear	(	const std::string &	clientId,
		std::string	topic,
		uint8_t	qoS )

Definition at line 129 of file RetainTree.cpp.

                                                                                             {
        if (topic.empty()) {
            if (!message.getTopic().empty()) {
                LOG(INFO) << "MQTT Broker: Retained Topic found:";
                LOG(INFO) << "MQTT Broker:   Topic: " << message.getTopic();
                LOG(INFO) << "MQTT Broker:   Message:\n" << iot::mqtt::Mqtt::toHexString(message.getMessage());
                LOG(DEBUG) << "MQTT Broker:     QoS: " << static_cast<uint16_t>(message.getQoS());
                LOG(DEBUG) << "MQTT Broker:   Client:";
                LOG(DEBUG) << "MQTT Broker:     QoS: " << static_cast<uint16_t>(qoS);
 
                LOG(INFO) << "MQTT Broker: Distributing message ...";
                broker->sendPublish(clientId, message, std::min(message.getQoS(), qoS), true);
                LOG(INFO) << "MQTT Broker: ... distributing message completed";
            }
        } else {
            const std::string topicLevel = topic.substr(0, topic.find('/'));
 
            topic.erase(0, topicLevel.size() + 1);
 
            auto foundNode = subTopicLevels.find(topicLevel);
            if (foundNode != subTopicLevels.end()) {
                foundNode->second.appear(clientId, topic, qoS);
            } else if (topicLevel == "+") {
                for (auto& [notUsed, topicTree] : subTopicLevels) {
                    topicTree.appear(clientId, topic, qoS);
                }
            } else if (topicLevel == "#") {
                appear(clientId, qoS);
            }
        }
    }

appear() [2/2]

void iot::mqtt::server::broker::RetainTree::TopicLevel::appear ( const std::string & clientId, uint8_t clientQoS )

private

Definition at line 161 of file RetainTree.cpp.

                                                                                  {
        if (!message.getTopic().empty()) {
            LOG(INFO) << "MQTT Broker: Retained Topic found:";
            LOG(INFO) << "MQTT Broker:   Topic: " << message.getTopic();
            LOG(INFO) << "MQTT Broker:   Message:\n" << iot::mqtt::Mqtt::toHexString(message.getMessage());
            LOG(DEBUG) << "MQTT Broker:     QoS: " << static_cast<uint16_t>(message.getQoS());
            LOG(DEBUG) << "MQTT Broker:   Client:";
            LOG(DEBUG) << "MQTT Broker:     QoS: " << static_cast<uint16_t>(clientQoS);
 
            LOG(INFO) << "MQTT Broker: Distributing message ...";
            broker->sendPublish(clientId, message, std::min(message.getQoS(), clientQoS), true);
            LOG(INFO) << "MQTT Broker: ... distributing message completed";
        }
 
        for (auto& [topicLevel, topicTree] : subTopicLevels) {
            topicTree.appear(clientId, clientQoS);
        }
    }

clear()

void iot::mqtt::server::broker::RetainTree::TopicLevel::clear

(

)

Definition at line 194 of file RetainTree.cpp.

                                     {
        *this = TopicLevel(broker);
    }

References TopicLevel().

Here is the call graph for this function:

fromJson()

RetainTree::TopicLevel & iot::mqtt::server::broker::RetainTree::TopicLevel::fromJson

(

const nlohmann::json &

json

)

Definition at line 75 of file RetainTree.cpp.

                                                                                 {
        subTopicLevels.clear();
 
        message.fromJson(json.value("message", nlohmann::json()));
 
        if (json.contains("topic_level")) {
            for (const auto& topicLevelItem : json["topic_level"].items()) {
                subTopicLevels.emplace(topicLevelItem.key(), TopicLevel(broker).fromJson(topicLevelItem.value()));
            }
        }
 
        return *this;
    }

release()

bool iot::mqtt::server::broker::RetainTree::TopicLevel::release

(

std::string

topic

)

Definition at line 105 of file RetainTree.cpp.

                                                      {
        if (topic.empty()) {
            LOG(DEBUG) << "MQTT Broker: Release retained:";
            LOG(DEBUG) << "MQTT Broker:   Topic: " << message.getTopic();
 
            message = Message();
        } else {
            const std::string topicLevel = topic.substr(0, topic.find('/'));
 
            auto&& it = subTopicLevels.find(topicLevel);
            if (it != subTopicLevels.end()) {
                topic.erase(0, topicLevel.size() + 1);
 
                if (it->second.release(topic)) {
                    LOG(DEBUG) << "               Erase: " << topicLevel;
 
                    subTopicLevels.erase(it);
                }
            }
        }
 
        return subTopicLevels.empty() && message.getMessage().empty();
    }

retain()

void iot::mqtt::server::broker::RetainTree::TopicLevel::retain	(	const Message &	message,
		std::string	topic )

Definition at line 88 of file RetainTree.cpp.

                                                                             {
        if (topic.empty()) {
            LOG(DEBUG) << "MQTT Broker: Retain:";
            LOG(DEBUG) << "MQTT Broker:   Topic: " << message.getTopic();
            LOG(DEBUG) << "MQTT Broker:   Message:\n" << iot::mqtt::Mqtt::toHexString(message.getMessage());
            LOG(DEBUG) << "MQTT Broker:     QoS: " << static_cast<uint16_t>(message.getQoS());
 
            this->message = message;
        } else {
            const std::string topicLevel = topic.substr(0, topic.find('/'));
 
            topic.erase(0, topicLevel.size() + 1);
 
            subTopicLevels.insert({topicLevel, RetainTree::TopicLevel(broker)}).first->second.retain(message, topic);
        }
    }

References iot::mqtt::server::broker::Message::getQoS().

Here is the call graph for this function:

toJson()

nlohmann::json iot::mqtt::server::broker::RetainTree::TopicLevel::toJson

(

)

const

Definition at line 180 of file RetainTree.cpp.

                                                    {
        nlohmann::json json;
 
        if (!message.getMessage().empty()) {
            json["message"] = message.toJson();
        }
 
        for (const auto& [topicLevel, topicLevelValue] : subTopicLevels) {
            json["topic_level"][topicLevel] = topicLevelValue.toJson();
        }
 
        return json;
    }

Member Data Documentation

broker

iot::mqtt::server::broker::Broker* iot::mqtt::server::broker::RetainTree::TopicLevel::broker = nullptr

private

Definition at line 74 of file RetainTree.h.

message

Message iot::mqtt::server::broker::RetainTree::TopicLevel::message

private

Definition at line 70 of file RetainTree.h.

subTopicLevels

std::map<std::string, TopicLevel> iot::mqtt::server::broker::RetainTree::TopicLevel::subTopicLevels

private

Definition at line 72 of file RetainTree.h.

---

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

• iot/mqtt/server/broker/RetainTree.h
• iot/mqtt/server/broker/RetainTree.cpp