CustomKeyFilterFactory.hpp

#pragma once
 
/*
  Copyright 2023, SINTEF Ocean
  This Source Code Form is subject to the terms of the Mozilla Public
  License, v. 2.0. If a copy of the MPL was not distributed with this
  file, You can obtain one at http://mozilla.org/MPL/2.0/.
*/
 
#include <string>
 
#include <fastdds/dds/topic/IContentFilter.hpp>
#include <fastdds/dds/topic/IContentFilterFactory.hpp>
#include <fastdds/dds/topic/TopicDataType.hpp>
 
#include "Converter.hpp"
#include "CustomKeyFilter.hpp"
 
namespace ddsfmu {
namespace detail {
 
class CustomKeyFilterFactory : public eprosima::fastdds::dds::IContentFilterFactory {
public:
  eprosima::fastrtps::types::ReturnCode_t create_content_filter(
    const char* filter_class_name, // Custom filter class name is 'CUSTOM_KEY_FILTER'.
    const char* type_name,         // Type name of dynamic type
    const eprosima::fastdds::dds::TopicDataType* data_type, // This is a DynamicPubSubType*
    const char* /*filter_expression*/, // This Custom Filter doesn't implement a filter expression.
    const ParameterSeq& filter_parameters, // The GUID and key parameters
    eprosima::fastdds::dds::IContentFilter*& filter_instance) override {
    // Check the ContentFilteredTopic should be created by this factory.
    if (std::string(filter_class_name) != "CUSTOM_KEY_FILTER") {
      return ReturnCode_t::RETCODE_BAD_PARAMETER;
    }
 
    if (filter_parameters.length() < 1) { return ReturnCode_t::RETCODE_BAD_PARAMETER; }
 
    if (filter_instance == nullptr) {
      try {
        filter_instance = new CustomKeyFilter(data_type, type_name, filter_parameters);
      } catch (const std::runtime_error& err) {
        std::cerr << err.what() << std::endl;
        return ReturnCode_t::RETCODE_BAD_PARAMETER;
      }
    }
 
    if (std::string(filter_parameters[0]) != "|GUID UNKNOWN|") {
      try {
        CustomKeyFilter* instance = dynamic_cast<CustomKeyFilter*>(filter_instance);
 
        // Only adds a reader once. Once added, changing filter_parameters has not effect
        if (!instance->has_reader_GUID(filter_parameters[0])) {
          instance->add_type(data_type, type_name, filter_parameters);
        }
      } catch (const std::runtime_error& err) {
        std::cerr << err.what() << std::endl;
        return ReturnCode_t::RETCODE_BAD_PARAMETER;
      }
    }
 
    //if (filter_instance != nullptr) { delete (dynamic_cast<CustomKeyFilter*>(filter_instance)); }
    return ReturnCode_t::RETCODE_OK;
  }
 
  eprosima::fastrtps::types::ReturnCode_t delete_content_filter(
    const char* filter_class_name,
    eprosima::fastdds::dds::IContentFilter* filter_instance) override {
    if (std::string(filter_class_name) != "CUSTOM_KEY_FILTER" || !filter_instance) {
      return ReturnCode_t::RETCODE_BAD_PARAMETER;
    }
 
    delete (dynamic_cast<CustomKeyFilter*>(filter_instance));
    return ReturnCode_t::RETCODE_OK;
  }
};
 
}
}