iot::mqtt::server::broker::SubscribtionTree Class Reference

#include <SubscribtionTree.h>

Collaboration diagram for iot::mqtt::server::broker::SubscribtionTree:

Classes
class	TopicLevel

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

Private Attributes
TopicLevel	head

Detailed Description

Definition at line 39 of file SubscribtionTree.h.

Constructor & Destructor Documentation

SubscribtionTree()

iot::mqtt::server::broker::SubscribtionTree::SubscribtionTree ( iot::mqtt::server::broker::Broker * broker )

explicit

Definition at line 40 of file SubscribtionTree.cpp.

        : head(broker, "") {
    }

Member Function Documentation

appear()

void iot::mqtt::server::broker::SubscribtionTree::appear

(

const std::string &

clientId

)

Definition at line 44 of file SubscribtionTree.cpp.

                                                           {
        head.appear(clientId, "");
    }

clear()

void iot::mqtt::server::broker::SubscribtionTree::clear

(

)

Definition at line 267 of file SubscribtionTree.cpp.

                                 {
        head.clear();
    }

fromJson()

void iot::mqtt::server::broker::SubscribtionTree::fromJson

(

const nlohmann::json &

json

)

Definition at line 261 of file SubscribtionTree.cpp.

                                                            {
        if (!json.empty()) {
            head.fromJson(json);
        }
    }

publish()

void iot::mqtt::server::broker::SubscribtionTree::publish

(

Message &&

message

)

Definition at line 63 of file SubscribtionTree.cpp.

                                                    {
        auto hashCount = std::ranges::count(message.getTopic(), '#');
        if (!message.getTopic().empty() && (hashCount == 0 || (hashCount == 1 && message.getTopic().ends_with('#')))) {
            head.publish(message, message.getTopic());
        } else {
            LOG(ERROR) << "MQTT Broker: Publish: Wrong '#' placement: " << message.getTopic();
        }
    }

subscribe()

bool iot::mqtt::server::broker::SubscribtionTree::subscribe	(	const std::string &	topic,
		const std::string &	clientId,
		uint8_t	qoS )

Definition at line 48 of file SubscribtionTree.cpp.

                                                                                                   {
        bool success = false;
 
        auto hashCount = std::ranges::count(topic, '#');
        if (!topic.empty() && (hashCount == 0 || (hashCount == 1 && topic.ends_with('#')))) {
            head.subscribe(clientId, qoS, topic);
 
            success = true;
        } else {
            LOG(ERROR) << "MQTT Broker: Subscribe: Wrong '#' placement: " << topic;
        }
 
        return success;
    }

toJson()

nlohmann::json iot::mqtt::server::broker::SubscribtionTree::toJson

(

)

const

Definition at line 271 of file SubscribtionTree.cpp.

                                                {
        return head.toJson();
    }

unsubscribe() [1/2]

void iot::mqtt::server::broker::SubscribtionTree::unsubscribe

(

const std::string &

clientId

)

Definition at line 81 of file SubscribtionTree.cpp.

                                                                {
        head.unsubscribe(clientId);
    }

unsubscribe() [2/2]

void iot::mqtt::server::broker::SubscribtionTree::unsubscribe	(	const std::string &	topic,
		const std::string &	clientId )

Definition at line 72 of file SubscribtionTree.cpp.

                                                                                        {
        auto hashCount = std::ranges::count(topic, '#');
        if (!topic.empty() && (hashCount == 0 || (hashCount == 1 && topic.ends_with('#')))) {
            head.unsubscribe(clientId, topic);
        } else {
            LOG(ERROR) << "MQTT Broker: Unsubscribe: Wrong '#' placement: " << topic;
        }
    }

Member Data Documentation

head

TopicLevel iot::mqtt::server::broker::SubscribtionTree::head

private

Definition at line 85 of file SubscribtionTree.h.

---

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

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