Method unregisterTopics

lib/TopicHandlerService/src/TopicHandlerService.cpp:221–271

}

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

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

        /* Handle each topic */
        if (0U < jsonTopics.size())
        {
            for (JsonVariantConst jsonTopic : jsonTopics)
            {
                String topicName;

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

                    if (true == jsonTopicName.is<String>())
                    {
                        topicName = jsonTopicName.as<const char*>();
                    }
                }
                /* Only topic name is available */
                else if (true == jsonTopic.is<String>())
                {
                    topicName = jsonTopic.as<const char*>();
                }
                else
                {
                    /* Skip */
                    ;
                }

                if (false == topicName.isEmpty())
                {
                    unregisterTopic(deviceId, entityId, topicName, purge);

                    removeFromTopicMetaDataList(deviceId, entityId, topicName);
                    removeFromPluginList(plugin, topicName);
                }
            }
        }
    }
}

void TopicHandlerService::registerTopic(const String& deviceId, const String& entityId, const String& topic, JsonObjectConst& jsonExtra, ITopicHandler::GetTopicFunc getTopicFunc, HasChangedFunc hasChangedFunc, ITopicHandler::SetTopicFunc setTopicFunc, ITopicHandler::UploadReqFunc uploadReqFunc)
{