#include <MqttMapper.h>

Collaboration diagram for mqtt::lib::MqttMapper:

Classes
struct	ScheduledPublish

Public Types
using	MappedPublishes = std::tuple<std::vector<iot::mqtt::packets::Publish>, std::vector<ScheduledPublish>>
using	ConnectParameter = std::tuple<bool, std::string, std::string, uint8_t, bool, std::string, std::string>

Public Member Functions
	MqttMapper ()
	MqttMapper (const MqttMapper &)=delete
MqttMapper &	operator= (const MqttMapper &)=delete
virtual	~MqttMapper ()
bool	setMapping (nlohmann::json mappingJson)
const nlohmann::json &	getMapping () const
std::string	getClientId () const
uint16_t	getKeepAlive () const
ConnectParameter	getConnectPayload () const
std::list< iot::mqtt::Topic >	extractSubscriptions () const
MappedPublishes	getMappings (const iot::mqtt::packets::Publish &publish)

Static Public Member Functions
static const std::string &	getSchema ()
static const nlohmann::json	validate (const nlohmann::json &json)
static const nlohmann::json	validate (const nlohmann::json &json, nlohmann::json_schema::basic_error_handler &err)

Private Member Functions
nlohmann::json	findMatchingTopicLevel (const nlohmann::json &topicLevel, const std::string &topic) const
void	getMappedTemplate (const nlohmann::json &templateMapping, nlohmann::json &json, MappedPublishes &mappedPublishes) const
void	getTemplateMappings (const nlohmann::json &templateMapping, nlohmann::json &json, const iot::mqtt::packets::Publish &publish, MappedPublishes &mappedPublishes) const

Static Private Member Functions
static void	extractSubscription (const nlohmann::json &topicLevelJson, const std::string &topic, std::list< iot::mqtt::Topic > &topicList)
static void	extractSubscriptions (const nlohmann::json &mappingJson, const std::string &topic, std::list< iot::mqtt::Topic > &topicList)
static void	getStaticMappings (const nlohmann::json &staticMapping, const iot::mqtt::packets::Publish &publish, MappedPublishes &mappedPublishes)
static void	getMappedMessage (const std::string &topic, const std::string &message, uint8_t qoS, bool retain, double delay, MappedPublishes &mappedPublishes)
static void	getMappedMessage (const nlohmann::json &staticMapping, const iot::mqtt::packets::Publish &publish, MappedPublishes &mappedPublishes)

Private Attributes
nlohmann::json	mappingJson
nlohmann::json	mappingJsonUnpatched
std::list< void * >	pluginHandles
inja::Environment *	injaEnvironment

Static Private Attributes
static const nlohmann::json_schema::json_validator	validator
static const std::string	mappingJsonSchemaString

Detailed Description

Definition at line 76 of file MqttMapper.h.

Member Typedef Documentation

◆ ConnectParameter

using mqtt::lib::MqttMapper::ConnectParameter = std::tuple<bool, std::string, std::string, uint8_t, bool, std::string, std::string>

Definition at line 84 of file MqttMapper.h.

◆ MappedPublishes

using mqtt::lib::MqttMapper::MappedPublishes = std::tuple<std::vector<iot::mqtt::packets::Publish>, std::vector<ScheduledPublish>>

Definition at line 83 of file MqttMapper.h.

Constructor & Destructor Documentation

◆ MqttMapper() [1/2]

mqtt::lib::MqttMapper::MqttMapper ( )

Definition at line 99 of file MqttMapper.cpp.

        : injaEnvironment(new inja::Environment) {
        setMapping({});
    }

References injaEnvironment, and setMapping().

Here is the call graph for this function:

◆ MqttMapper() [2/2]

mqtt::lib::MqttMapper::MqttMapper ( const MqttMapper & )

delete

◆ ~MqttMapper()

mqtt::lib::MqttMapper::~MqttMapper ( )

virtual

Definition at line 104 of file MqttMapper.cpp.

                            {
        delete injaEnvironment;
 
        for (void* pluginHandle : pluginHandles) {
            core::DynamicLoader::dlClose(pluginHandle);
        }
    }

References injaEnvironment.

Member Function Documentation

◆ extractSubscription()

void mqtt::lib::MqttMapper::extractSubscription	(	const nlohmann::json &	topicLevelJson,
		const std::string &	topic,
		std::list< iot::mqtt::Topic > &	topicList )

staticprivate

Definition at line 307 of file MqttMapper.cpp.

                                                                           {
        const std::string name = topicLevelJson["name"];
 
        if (topicLevelJson.contains("subscription")) {
            const uint8_t qoS = topicLevelJson["subscription"]["qos"];
 
            topicList.emplace_back(topic + ((topic.empty() || topic == "/") && !name.empty() ? "" : "/") + name, qoS);
        }
 
        if (topicLevelJson.contains("topic_level")) {
            extractSubscriptions(topicLevelJson, topic + ((topic.empty() || topic == "/") && !name.empty() ? "" : "/") + name, topicList);
        }
    }

Referenced by extractSubscriptions().

Here is the caller graph for this function:

◆ extractSubscriptions() [1/2]

std::list< iot::mqtt::Topic > mqtt::lib::MqttMapper::extractSubscriptions ( ) const

Definition at line 232 of file MqttMapper.cpp.

                                                                 {
        std::list<iot::mqtt::Topic> topicList;
 
        extractSubscriptions(mappingJson["mapping"], "", topicList);
 
        return topicList;
    }

Referenced by mqtt::mqttintegrator::lib::Mqtt::Mqtt(), and mqtt::mqttintegrator::lib::Mqtt::resubscribe().

Here is the caller graph for this function:

◆ extractSubscriptions() [2/2]

void mqtt::lib::MqttMapper::extractSubscriptions	(	const nlohmann::json &	mappingJson,
		const std::string &	topic,
		std::list< iot::mqtt::Topic > &	topicList )

staticprivate

Definition at line 324 of file MqttMapper.cpp.

                                                                                                                              {
        if (mappingJson.contains("topic_level")) {
            const nlohmann::json& topicLevels = mappingJson["topic_level"];
 
            if (topicLevels.is_object()) {
                extractSubscription(topicLevels, topic, topicList);
            } else {
                for (const nlohmann::json& topicLevel : topicLevels) {
                    extractSubscription(topicLevel, topic, topicList);
                }
            }
        }
    }

References extractSubscription().

Here is the call graph for this function:

◆ findMatchingTopicLevel()

nlohmann::json mqtt::lib::MqttMapper::findMatchingTopicLevel	(	const nlohmann::json &	topicLevel,
		const std::string &	topic ) const

private

Definition at line 338 of file MqttMapper.cpp.

                                                                                                                {
        nlohmann::json foundTopicLevel;
 
        if (topicLevel.is_object()) {
            const std::string::size_type slashPosition = topic.find('/');
            const std::string topicLevelName = topic.substr(0, slashPosition);
 
            if (topicLevel["name"] == topicLevelName || topicLevel["name"] == "+" || topicLevel["name"] == "#") {
                if (slashPosition == std::string::npos) {
                    foundTopicLevel = topicLevel;
                } else if (topicLevel.contains("topic_level")) {
                    foundTopicLevel = findMatchingTopicLevel(topicLevel["topic_level"], topic.substr(slashPosition + 1));
                }
            }
        } else if (topicLevel.is_array()) {
            for (const nlohmann::json& topicLevelEntry : topicLevel) {
                foundTopicLevel = findMatchingTopicLevel(topicLevelEntry, topic);
 
                if (!foundTopicLevel.empty()) {
                    break;
                }
            }
        }
 
        return foundTopicLevel;
    }

References findMatchingTopicLevel().

Referenced by findMatchingTopicLevel(), and getMappings().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ getClientId()

std::string mqtt::lib::MqttMapper::getClientId ( ) const

Definition at line 212 of file MqttMapper.cpp.

                                            {
        return mappingJson["connection"]["client_id"];
    }

Referenced by mqtt::mqttintegrator::lib::Mqtt::Mqtt().

Here is the caller graph for this function:

◆ getConnectPayload()

MqttMapper::ConnectParameter mqtt::lib::MqttMapper::getConnectPayload ( ) const

Definition at line 220 of file MqttMapper.cpp.

                                                                   {
        const nlohmann::json& connectionJson = mappingJson["connection"];
 
        return std::make_tuple(connectionJson["clean_session"],
                               connectionJson["will_topic"],
                               connectionJson["will_message"],
                               connectionJson["will_qos"],
                               connectionJson["will_retain"],
                               connectionJson["username"],
                               connectionJson["password"]);
    }

Referenced by mqtt::mqttintegrator::lib::Mqtt::onConnected().

Here is the caller graph for this function:

◆ getKeepAlive()

uint16_t mqtt::lib::MqttMapper::getKeepAlive ( ) const

Definition at line 216 of file MqttMapper.cpp.

                                            {
        return mappingJson["connection"]["keep_alive"];
    }

Referenced by mqtt::mqttintegrator::lib::Mqtt::Mqtt().

Here is the caller graph for this function:

◆ getMappedMessage() [1/2]

void mqtt::lib::MqttMapper::getMappedMessage	(	const nlohmann::json &	staticMapping,
		const iot::mqtt::packets::Publish &	publish,
		MappedPublishes &	mappedPublishes )

staticprivate

Definition at line 477 of file MqttMapper.cpp.

                                                                        {
        const nlohmann::json& messageMapping = staticMapping["message_mapping"];
 
        VLOG(1) << "  Message mapping: " << messageMapping.dump();
 
        if (messageMapping.is_object()) {
            if (messageMapping["message"] == publish.getMessage()) {
                getMappedMessage(staticMapping["mapped_topic"],
                                 messageMapping["mapped_message"],
                                 staticMapping["qos"],
                                 staticMapping["retain"],
                                 staticMapping["delay"],
                                 mappedPublishes);
            } else {
                VLOG(1) << "    no matching mapped message found";
            }
        } else {
            const nlohmann::json::const_iterator matchedMessageMappingIterator =
                std::find_if(messageMapping.begin(), messageMapping.end(), [&publish](const nlohmann::json& messageMappingCandidat) {
                    return messageMappingCandidat["message"] == publish.getMessage();
                });
 
            if (matchedMessageMappingIterator != messageMapping.end()) {
                getMappedMessage(staticMapping["mapped_topic"],
                                 (*matchedMessageMappingIterator)["mapped_message"],
                                 staticMapping["qos"],
                                 staticMapping["retain"],
                                 staticMapping["delay"],
                                 mappedPublishes);
            } else {
                VLOG(1) << "    no matching mapped message found";
            }
        }
    }

Referenced by getStaticMappings().

Here is the caller graph for this function:

◆ getMappedMessage() [2/2]

void mqtt::lib::MqttMapper::getMappedMessage	(	const std::string &	topic,
		const std::string &	message,
		uint8_t	qoS,
		bool	retain,
		double	delay,
		MappedPublishes &	mappedPublishes )

staticprivate

Definition at line 457 of file MqttMapper.cpp.

                                                                                                                                    {
        VLOG(1) << "  Mapped topic:";
        VLOG(1) << "    -> " << topic;
        VLOG(1) << "  Mapped message:";
        VLOG(1) << "    -> " << message;
        VLOG(1) << "  Send mapping:" << (delay > 0 ? " delayed" : "");
        VLOG(1) << "    Topic: " << topic;
        VLOG(1) << "    Message: " << message;
        VLOG(1) << "    QoS: " << static_cast<int>(qoS);
        VLOG(1) << "    retain: " << retain;
        VLOG(1) << "    Delay: " << delay;
 
        if (delay < 0.0) {
            std::get<0>(mappedPublishes).emplace_back(0, topic, message, qoS, false, retain);
        } else {
            std::get<1>(mappedPublishes).push_back({delay, iot::mqtt::packets::Publish(0, topic, message, qoS, false, retain)});
        }
    }

Referenced by getMappedTemplate().

Here is the caller graph for this function:

◆ getMappedTemplate()

void mqtt::lib::MqttMapper::getMappedTemplate	(	const nlohmann::json &	templateMapping,
		nlohmann::json &	json,
		MappedPublishes &	mappedPublishes ) const

private

Definition at line 366 of file MqttMapper.cpp.

                                                                                                                                 {
        const std::string& mappingTemplate = templateMapping["mapping_template"];
        const std::string& mappedTopic = templateMapping["mapped_topic"];
 
        try {
            // Render topic
            const std::string renderedTopic = injaEnvironment->render(mappedTopic, json);
            json["mapped_topic"] = renderedTopic;
 
            VLOG(1) << "  Mapped topic template: " << mappedTopic;
            VLOG(1) << "    -> " << renderedTopic;
 
            try {
                // Render message
                const std::string renderedMessage = injaEnvironment->render(mappingTemplate, json);
                VLOG(1) << "  Mapped message template: " << mappingTemplate;
                VLOG(1) << "    -> " << renderedMessage;
 
                const nlohmann::json& suppressions = templateMapping["suppressions"];
                const bool retain = templateMapping["retain"];
 
                if (suppressions.empty() || std::find(suppressions.begin(), suppressions.end(), renderedMessage) == suppressions.end() ||
                    (retain && renderedMessage.empty())) {
                    const uint8_t qoS = templateMapping["qos"];
                    const double delay = templateMapping["delay"];
 
                    VLOG(1) << "  Send mapping:" << (delay > 0 ? " delayed" : "");
                    VLOG(1) << "    Topic: " << renderedTopic;
                    VLOG(1) << "    Message: " << renderedMessage << "";
                    VLOG(1) << "    QoS: " << static_cast<int>(qoS);
                    VLOG(1) << "    retain: " << retain;
                    VLOG(1) << "    Delay: " << delay;
 
                    getMappedMessage(renderedTopic, renderedMessage, qoS, retain, delay, mappedPublishes);
                } else {
                    VLOG(1) << "    Rendered message: '" << renderedMessage << "' in suppression list:";
                    for (const nlohmann::json& item : suppressions) {
                        VLOG(1) << "         '" << item.get<std::string>() << "'";
                    }
                    VLOG(1) << "  Send mapping: suppressed";
                }
            } catch (const inja::InjaError& e) {
                VLOG(1) << "  Message template rendering failed: " << mappingTemplate << " : " << json.dump();
                VLOG(1) << "    What: " << e.what();
                VLOG(1) << "    INJA: " << e.type << ": " << e.message;
                VLOG(1) << "    INJA (line:column):" << e.location.line << ":" << e.location.column;
            }
        } catch (const inja::InjaError& e) {
            VLOG(1) << "  Topic template rendering failed: " << mappingTemplate << " : " << json.dump();
            VLOG(1) << "    What: " << e.what();
            VLOG(1) << "    INJA: " << e.type << ": " << e.message;
            VLOG(1) << "    INJA (line:column):" << e.location.line << ":" << e.location.column;
        }
    }

References inja::SourceLocation::column, getMappedMessage(), injaEnvironment, inja::SourceLocation::line, inja::InjaError::location, inja::InjaError::message, inja::Environment::render(), and inja::InjaError::type.

Referenced by getTemplateMappings().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ getMapping()

const nlohmann::json & mqtt::lib::MqttMapper::getMapping ( ) const

Definition at line 208 of file MqttMapper.cpp.

                                                     {
        return mappingJsonUnpatched;
    }

References mappingJsonUnpatched.

Referenced by mqtt::lib::ConfigApplication::getMapping(), and mqtt::lib::admin::makeMappingAdminRouter().

Here is the caller graph for this function:

◆ getMappings()

MqttMapper::MappedPublishes mqtt::lib::MqttMapper::getMappings ( const iot::mqtt::packets::Publish & publish )

Definition at line 240 of file MqttMapper.cpp.

                                                                                          {
        MappedPublishes mappedPublishes;
        if (mappingJson.contains("mapping") && !mappingJson["mapping"].empty()) {
            nlohmann::json matchingTopicLevel = findMatchingTopicLevel(mappingJson["mapping"]["topic_level"], publish.getTopic());
 
            if (!matchingTopicLevel.empty()) {
                const nlohmann::json& subscription = matchingTopicLevel["subscription"];
 
                if (subscription.contains("static")) {
                    VLOG(1) << "Topic mapping found for:";
                    VLOG(1) << "  Type: static";
                    VLOG(1) << "  Topic: " << publish.getTopic();
                    VLOG(1) << "  Message: " << publish.getMessage();
                    VLOG(1) << "  QoS: " << static_cast<uint16_t>(publish.getQoS());
                    VLOG(1) << "  Retain: " << publish.getRetain();
 
                    getStaticMappings(subscription["static"], publish, mappedPublishes);
                }
 
                if (subscription.contains("value")) {
                    VLOG(1) << "Topic mapping found for:";
                    VLOG(1) << "  Type: value";
                    VLOG(1) << "  Topic: " << publish.getTopic();
                    VLOG(1) << "  Message: " << publish.getMessage();
                    VLOG(1) << "  QoS: " << static_cast<uint16_t>(publish.getQoS());
                    VLOG(1) << "  Retain: " << publish.getRetain();
 
                    nlohmann::json json;
                    json["message"] = publish.getMessage();
 
                    getTemplateMappings(subscription["value"], json, publish, mappedPublishes);
                }
 
                if (subscription.contains("json")) {
                    VLOG(1) << "Topic mapping found for:";
                    VLOG(1) << "  Type: json";
                    VLOG(1) << "  Topic: " << publish.getTopic();
                    VLOG(1) << "  Message: " << publish.getMessage();
                    VLOG(1) << "  QoS: " << static_cast<uint16_t>(publish.getQoS());
                    VLOG(1) << "  Retain: " << publish.getRetain();
 
                    try {
                        nlohmann::json json;
                        json["message"] = nlohmann::json::parse(publish.getMessage());
 
                        getTemplateMappings(subscription["json"], json, publish, mappedPublishes);
                    } catch (const nlohmann::json::parse_error& e) {
                        VLOG(1) << "  Parsing message into json failed: " << publish.getMessage();
                        VLOG(1) << "     What: " << e.what() << '\n'
                                << "     Exception Id: " << e.id << '\n'
                                << "     Byte position of error: " << e.byte;
                    }
                }
            }
        }
 
        return mappedPublishes;
    }

References findMatchingTopicLevel(), getStaticMappings(), and getTemplateMappings().

Referenced by mqtt::mqttbroker::lib::Mqtt::onPublish(), and mqtt::mqttintegrator::lib::Mqtt::onPublish().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ getSchema()

const std::string & mqtt::lib::MqttMapper::getSchema ( )

static

Definition at line 112 of file MqttMapper.cpp.

                                           {
        return mappingJsonSchemaString;
    }

References mappingJsonSchemaString.

Referenced by mqtt::lib::admin::makeMappingAdminRouter().

Here is the caller graph for this function:

◆ getStaticMappings()

void mqtt::lib::MqttMapper::getStaticMappings	(	const nlohmann::json &	staticMapping,
		const iot::mqtt::packets::Publish &	publish,
		MappedPublishes &	mappedPublishes )

staticprivate

Definition at line 445 of file MqttMapper.cpp.

                                                                         {
        if (staticMapping.is_object()) {
            getMappedMessage(staticMapping, publish, mappedPublishes);
        } else if (staticMapping.is_array()) {
            for (const nlohmann::json& concreteStaticMapping : staticMapping) {
                getMappedMessage(concreteStaticMapping, publish, mappedPublishes);
            }
        }
    }

References getMappedMessage().

Referenced by getMappings().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ getTemplateMappings()

void mqtt::lib::MqttMapper::getTemplateMappings	(	const nlohmann::json &	templateMapping,
		nlohmann::json &	json,
		const iot::mqtt::packets::Publish &	publish,
		MappedPublishes &	mappedPublishes ) const

private

Definition at line 421 of file MqttMapper.cpp.

                                                                                 {
        json["topic"] = publish.getTopic();
        json["qos"] = publish.getQoS();
        json["retain"] = publish.getRetain();
        json["package_identifier"] = publish.getPacketIdentifier();
 
        try {
            VLOG(1) << "  Render data: " << json.dump();
 
            if (templateMapping.is_object()) {
                getMappedTemplate(templateMapping, json, mappedPublishes);
            } else {
                for (const nlohmann::json& concreteTemplateMapping : templateMapping) {
                    getMappedTemplate(concreteTemplateMapping, json, mappedPublishes);
                }
            }
        } catch (const nlohmann::json::exception& e) {
            VLOG(1) << "JSON Exception during Render data:\n" << e.what();
        }
    }

References getMappedTemplate().

Referenced by getMappings().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ operator=()

MqttMapper & mqtt::lib::MqttMapper::operator= ( const MqttMapper & )

delete

◆ setMapping()

bool mqtt::lib::MqttMapper::setMapping ( nlohmann::json mappingJson )

Definition at line 116 of file MqttMapper.cpp.

                                                        { // can throw
        delete injaEnvironment;
 
        for (void* handle : pluginHandles) {
            core::DynamicLoader::dlClose(handle);
        }
        pluginHandles.clear();
 
        injaEnvironment = new inja::Environment;
 
        nlohmann::json defaultPatch;
        try {
            defaultPatch = validator.validate(mappingJson);
        } catch (const std::exception& e) {
            throw std::runtime_error("Validating JSON failed: Mapping JSON = " + mappingJson.dump(4) + "\n" + e.what());
        }
 
        nlohmann::json oldMappingJson = this->mappingJson;
        try {
            this->mappingJson = mappingJson.patch(defaultPatch);
            if (mappingJson.empty()) {
                this->mappingJsonUnpatched = this->mappingJson;
            } else {
                this->mappingJsonUnpatched = mappingJson;
            }
        } catch (const std::exception& e) {
            throw std::runtime_error("Patching JSON with default patch failed: Default patch = " + defaultPatch.dump(4) + "\n" + e.what());
        }
 
        bool mustReconnect = this->mappingJson["connection"] != oldMappingJson["connection"];
 
        if (mappingJson["mapping"].contains("plugins")) {
            VLOG(1) << "Loading plugins ...";
            for (const nlohmann::json& pluginJson : mappingJson["mapping"]["plugins"]) {
                const std::string plugin = pluginJson;
 
                void* handle = core::DynamicLoader::dlOpen(plugin);
 
                if (handle != nullptr) {
                    pluginHandles.push_back(handle);
 
                    VLOG(1) << "  Loading plugin: " << plugin << " ...";
 
                    const std::vector<mqtt::lib::Function>* loadedFunctions =
                        static_cast<std::vector<mqtt::lib::Function>*>(core::DynamicLoader::dlSym(handle, "functions"));
                    if (loadedFunctions != nullptr) {
                        VLOG(1) << "  Registering inja 'none void callbacks'";
                        for (const mqtt::lib::Function& function : *loadedFunctions) {
                            VLOG(1) << "    " << function.name;
 
                            if (function.numArgs >= 0) {
                                injaEnvironment->add_callback(function.name, function.numArgs, function.function);
                            } else {
                                injaEnvironment->add_callback(function.name, function.function);
                            }
                        }
                        VLOG(1) << "  Registering inja 'none void callbacks done'";
                    } else {
                        VLOG(1) << "  No inja none 'void callbacks found' in plugin " << plugin;
                    }
 
                    const std::vector<mqtt::lib::VoidFunction>* loadedVoidFunctions =
                        static_cast<std::vector<mqtt::lib::VoidFunction>*>(core::DynamicLoader::dlSym(handle, "voidFunctions"));
                    if (loadedVoidFunctions != nullptr) {
                        VLOG(1) << "  Registering inja 'void callbacks'";
                        for (const mqtt::lib::VoidFunction& voidFunction : *loadedVoidFunctions) {
                            VLOG(1) << "    " << voidFunction.name;
 
                            if (voidFunction.numArgs >= 0) {
                                injaEnvironment->add_void_callback(voidFunction.name, voidFunction.numArgs, voidFunction.function);
                            } else {
                                injaEnvironment->add_void_callback(voidFunction.name, voidFunction.function);
                            }
                        }
                        VLOG(1) << "  Registering inja 'void callbacks' done";
                    } else {
                        VLOG(1) << "  No inja 'void callbacks' found in plugin " << plugin;
                    }
 
                    VLOG(1) << "  Loading plugin done: " << plugin;
                } else {
                    VLOG(1) << "  Error loading plugin: " << plugin;
                    throw std::runtime_error("Error loading plugin '" + plugin + "': " + core::DynamicLoader::dlError());
                }
            }
 
            VLOG(1) << "Loading plugins done";
        }
 
        return mustReconnect;
    }

References injaEnvironment, mappingJson, mappingJsonUnpatched, pluginHandles, nlohmann::json_schema::json_validator::validate(), and validator.

Referenced by mqtt::lib::admin::makeMappingAdminRouter(), MqttMapper(), and mqtt::lib::ConfigApplication::setMapping().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ validate() [1/2]

const nlohmann::json mqtt::lib::MqttMapper::validate ( const nlohmann::json & json )

static

Definition at line 299 of file MqttMapper.cpp.

                                                                    {
        return validator.validate(json);
    }

References nlohmann::json_schema::json_validator::validate(), and validator.

Referenced by mqtt::lib::JsonMappingReader::rollbackTo().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ validate() [2/2]

const nlohmann::json mqtt::lib::MqttMapper::validate	(	const nlohmann::json &	json,
		nlohmann::json_schema::basic_error_handler &	err )

static

Definition at line 303 of file MqttMapper.cpp.

                                                                                                                 {
        return validator.validate(json, err);
    }

References nlohmann::json_schema::json_validator::validate(), and validator.

Referenced by mqtt::lib::admin::makeMappingAdminRouter().

Here is the call graph for this function:

Here is the caller graph for this function:

Member Data Documentation

◆ injaEnvironment

inja::Environment* mqtt::lib::MqttMapper::injaEnvironment

private

Definition at line 134 of file MqttMapper.h.

Referenced by getMappedTemplate(), MqttMapper(), setMapping(), and ~MqttMapper().

◆ mappingJson

nlohmann::json mqtt::lib::MqttMapper::mappingJson

private

Definition at line 129 of file MqttMapper.h.

Referenced by setMapping().

◆ mappingJsonSchemaString

const std::string mqtt::lib::MqttMapper::mappingJsonSchemaString

staticprivate

Definition at line 138 of file MqttMapper.h.

Referenced by getSchema().

◆ mappingJsonUnpatched

nlohmann::json mqtt::lib::MqttMapper::mappingJsonUnpatched

private

Definition at line 130 of file MqttMapper.h.

Referenced by getMapping(), and setMapping().

◆ pluginHandles

std::list<void*> mqtt::lib::MqttMapper::pluginHandles

private

Definition at line 132 of file MqttMapper.h.

Referenced by setMapping().

◆ validator

const nlohmann::json_schema::json_validator mqtt::lib::MqttMapper::validator

staticprivate

Definition at line 136 of file MqttMapper.h.

Referenced by setMapping(), validate(), and validate().

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

lib/MqttMapper.h
lib/MqttMapper.cpp

MQTTSuite

Classes

Public Types

Public Member Functions

Static Public Member Functions

Private Member Functions

Static Private Member Functions

Private Attributes

Static Private Attributes

Detailed Description

Member Typedef Documentation

◆ ConnectParameter

◆ MappedPublishes

Constructor & Destructor Documentation

◆ MqttMapper() [1/2]

◆ MqttMapper() [2/2]

◆ ~MqttMapper()

Member Function Documentation

◆ extractSubscription()

◆ extractSubscriptions() [1/2]

◆ extractSubscriptions() [2/2]

◆ findMatchingTopicLevel()

◆ getClientId()

◆ getConnectPayload()

◆ getKeepAlive()

◆ getMappedMessage() [1/2]

◆ getMappedMessage() [2/2]

◆ getMappedTemplate()

◆ getMapping()

◆ getMappings()

◆ getSchema()

◆ getStaticMappings()

◆ getTemplateMappings()

◆ operator=()

◆ setMapping()

◆ validate() [1/2]

◆ validate() [2/2]

Member Data Documentation

◆ injaEnvironment

◆ mappingJson

◆ mappingJsonSchemaString

◆ mappingJsonUnpatched

◆ pluginHandles

◆ validator