Method registerTopics

lib/TopicHandlerService/src/TopicHandlerService.cpp:121–219

}

void TopicHandlerService::registerTopics(const String& deviceId, const String& entityId, IPluginMaintenance* plugin)
{
    if ((false == deviceId.isEmpty()) &&
        (nullptr != plugin))
    {
        const size_t        JSON_DOC_SIZE = 1024U;
        DynamicJsonDocument topicsDoc(JSON_DOC_SIZE);
        JsonArray           jsonTopics = topicsDoc.createNestedArray("topics");

        /* Get topics from plugin. */
        plugin->getTopics(jsonTopics);

        if (true == topicsDoc.overflowed())
        {
            LOG_ERROR("JSON document size exceeded.");
        }
        /* Handle each topic */
        else if (0U < jsonTopics.size())
        {
            for (JsonVariantConst jsonTopic : jsonTopics)
            {
                String                       topicName;
                JsonObjectConst              jsonExtra;
                String                       extraFileName;
                String                       topicAccess   = DEFAULT_ACCESS;
                ITopicHandler::GetTopicFunc  getTopicFunc  = nullptr;
                ITopicHandler::SetTopicFunc  setTopicFunc  = nullptr;
                ITopicHandler::UploadReqFunc uploadReqFunc = nullptr;

                /* Topic specific parameter available? */
                if (true == jsonTopic.is<JsonObjectConst>())
                {
                    JsonVariantConst jsonTopicName   = jsonTopic["name"];
                    JsonVariantConst jsonTopicAccess = jsonTopic["access"];
                    JsonVariantConst jsonExtraVar    = jsonTopic["extra"];

                    if (true == jsonTopicName.is<String>())
                    {
                        topicName = jsonTopicName.as<const char*>();
                    }

                    if (true == jsonTopicAccess.is<String>())
                    {
                        topicAccess = jsonTopicAccess.as<const char*>();
                    }

                    if (true == jsonExtraVar.is<JsonObjectConst>())
                    {
                        jsonExtra = jsonExtraVar.as<JsonObjectConst>();
                    }
                    else if (true == jsonExtraVar.is<String>())
                    {
                        extraFileName = jsonExtraVar.as<const char*>();
                    }
                    else
                    {
                        /* Skip */
                        ;