mqtt::lib::JsonMappingReader Class Reference

#include <JsonMappingReader.h>

Collaboration diagram for mqtt::lib::JsonMappingReader:

Public Member Functions
	JsonMappingReader ()=delete

Static Public Member Functions
static nlohmann::json &	readMappingFromFile (const std::string &mapFilePath)

Static Private Attributes
static nlohmann::json	mappingJsonSchema = nlohmann::json::parse(mappingJsonSchemaString)
static const std::string	mappingJsonSchemaString
static std::map< std::string, nlohmann::json >	mapFileJsons

Detailed Description

Definition at line 55 of file JsonMappingReader.h.

Constructor & Destructor Documentation

JsonMappingReader()

mqtt::lib::JsonMappingReader::JsonMappingReader ( )

delete

Member Function Documentation

readMappingFromFile()

nlohmann::json & mqtt::lib::JsonMappingReader::readMappingFromFile ( const std::string & mapFilePath )

static

Definition at line 63 of file JsonMappingReader.cpp.

                                                                                     {
        if (!mapFileJsons.contains(mapFilePath)) {
            if (!mapFilePath.empty()) {
                std::ifstream mapFile(mapFilePath);
 
                if (mapFile.is_open()) {
                    VLOG(1) << "MappingFilePath: " << mapFilePath;
 
                    try {
                        mapFile >> mapFileJsons[mapFilePath];
 
                        try {
                            const nlohmann::json_schema::json_validator validator(mappingJsonSchema);
 
                            try {
                                const nlohmann::json defaultPatch = validator.validate(mapFileJsons[mapFilePath]);
 
                                try {
                                    mapFileJsons[mapFilePath] = mapFileJsons[mapFilePath].patch(defaultPatch);
                                } catch (const std::exception& e) {
                                    VLOG(1) << e.what();
                                    VLOG(1) << "Patching JSON with default patch failed:\n" << defaultPatch.dump(4);
                                    mapFileJsons[mapFilePath].clear();
                                }
                            } catch (const std::exception& e) {
                                VLOG(1) << "  Validating JSON failed:\n" << mapFileJsons[mapFilePath].dump(4);
                                VLOG(1) << "    " << e.what();
                                mapFileJsons[mapFilePath].clear();
                            }
                        } catch (const std::exception& e) {
                            VLOG(1) << e.what();
                            VLOG(1) << "Setting root json mapping schema failed:\n" << mappingJsonSchema.dump(4);
                            mapFileJsons[mapFilePath].clear();
                        }
                    } catch (const std::exception& e) {
                        VLOG(1) << "JSON map file parsing failed: " << e.what() << " at " << mapFile.tellg();
                        mapFileJsons[mapFilePath].clear();
                    }
 
                    mapFile.close();
                } else {
                    VLOG(1) << "MappingFilePath: " << mapFilePath << " not found";
                }
            } else {
                VLOG(1) << "MappingFilePath empty";
            }
        }
 
        return mapFileJsons[mapFilePath];
    }

References nlohmann::json_schema::json_validator::json_validator(), mapFileJsons, and mappingJsonSchema.

Referenced by mqtt::mqttbroker::SocketContextFactory::create(), mqtt::mqttintegrator::SocketContextFactory::create(), and mqtt::mqttintegrator::websocket::SubProtocolFactory::create().

Here is the call graph for this function:

Here is the caller graph for this function:

Member Data Documentation

mapFileJsons

std::map< std::string, nlohmann::json > mqtt::lib::JsonMappingReader::mapFileJsons

staticprivate

Definition at line 65 of file JsonMappingReader.h.

Referenced by readMappingFromFile().

mappingJsonSchema

nlohmann::json mqtt::lib::JsonMappingReader::mappingJsonSchema = nlohmann::json::parse(mappingJsonSchemaString)

staticprivate

Definition at line 62 of file JsonMappingReader.h.

Referenced by readMappingFromFile().

mappingJsonSchemaString

const std::string mqtt::lib::JsonMappingReader::mappingJsonSchemaString

staticprivate

Definition at line 63 of file JsonMappingReader.h.

---

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

• lib/JsonMappingReader.h
• lib/JsonMappingReader.cpp