Test for Demo Data Trigger Plugin

Description

This examples test the Demo Data Trigger Plugin

Location

./src/examples/src/adtf/filters/standard_filters/data_triggered_filter/test/

Build Environment

To see how to set up the build environment have a look at ADTF CMake Environment

this implementation shows:

• how to use our ADTF Testing SDK
• how to test a Filter
• how to set up a test system with adtf::system::testing::giant::cTestSystem
• how to create sample data with adtf::filter::testing::giant::cTestWriter
• how to access sample data from output pins using adtf::filter::testing::giant::cOutputRecorder

Implementation

 
#include "../demo_data_trigger_function.h"
 
#include <adtftesting/adtf_testing.h>
#include <adtfsystemsdk/testing/test_system.h>
#include <adtffiltersdk/adtf_filtersdk.h>
 
struct cMyTestSystem: adtf::system::testing::cTestSystem
{
    cMyTestSystem()
    {
        LoadPlugin("demo_data_triggered_filter.adtfplugin");
    }
};
 
adtf::ucom::object_ptr<adtf::streaming::IFilter> create_filter(cSimpleDataCalculator::tOperator eOperator)
{
    adtf::ucom::object_ptr<adtf::streaming::IFilter> pFilter;
    REQUIRE_OK(_runtime->CreateInstance("demo_data_trigger.filter.adtf.cid", pFilter));
 
    auto pConfiguration = adtf::ucom::ucom_cast<adtf::base::IConfiguration*>(pFilter.Get());
    adtf::base::set_property_by_path<uint32_t>(*pConfiguration, "calculator_function/operator", eOperator);
 
    return pFilter;
}
 
void test_calculation(cSimpleDataCalculator::tOperator eOperator, float fExpectedResult)
{
    auto pFilter = create_filter(eOperator);
 
    adtf::filter::testing::cTestWriter oWriter1(pFilter, "in1", adtf::streaming::stream_type_plain<float>());
    adtf::filter::testing::cTestWriter oWriter2(pFilter, "in2", adtf::streaming::stream_type_plain<float>());
    adtf::filter::testing::cOutputRecorder oOutput(pFilter, "out");
 
    REQUIRE_OK(pFilter->SetState(adtf::streaming::IFilter::tFilterState::State_Running));
 
    oWriter1.Write<float>(4.0, true);
    oWriter2.Write<float>(2.0, true);
 
    auto oOutputSamples = oOutput.GetCurrentOutput().GetSamples();
 
    REQUIRE(oOutputSamples.size() == 1);
    REQUIRE(adtf::streaming::sample_data<float>(oOutputSamples.back()) == Approx(fExpectedResult));
}
 
TEST_CASE_METHOD(cMyTestSystem, "Test Addition")
{
    test_calculation(cSimpleDataCalculator::tOperator::ePLUS, 6.0);
}
 
TEST_CASE_METHOD(cMyTestSystem, "Test Substraction")
{
    test_calculation(cSimpleDataCalculator::tOperator::eMINUS, 2.0);
}
 
TEST_CASE_METHOD(cMyTestSystem, "Test Multiplication")
{
    test_calculation(cSimpleDataCalculator::tOperator::eMULTI, 8.0);
}
 
TEST_CASE_METHOD(cMyTestSystem, "Test Division")
{
    test_calculation(cSimpleDataCalculator::tOperator::eDIVIDE, 2.0);
}
 
TEST_CASE_METHOD(cMyTestSystem, "Test Invalid Operator")
{
    auto pFilter = create_filter(static_cast<cSimpleDataCalculator::tOperator>(cSimpleDataCalculator::tOperator::eDIVIDE + 1));
 
    REQUIRE(ERR_INVALID_ARG == pFilter->SetState(adtf::streaming::IFilter::tFilterState::State_Running));
}