testAsyncOpBase.cpp

Go to the documentation of this file.

/**
 * @file
 * @ingroup daq_ocm_libdaq_test
 * @copyright 2022 ESO - European Southern Observatory
 *
 * @brief Definition of TestAsyncOpBase
 */
#include "testAsyncOpBase.hpp"
 
using namespace daq;
using namespace ::testing;
 
TestAsyncOpBase::TestAsyncOpBase()
    : m_io_ctx()
    , m_executor(m_io_ctx)
    , m_logger(log4cplus::Logger::getInstance("test"))
    , m_id("id")
    , m_status(std::make_shared<ObservableStatus>(m_id, m_id))
    , m_event_log(std::make_shared<ObservableEventLog>())
    , m_pending_replies(PendingReplies::Create()) {
}
 
void TestAsyncOpBase::SetUp() {
    m_prim_rr_client = std::make_shared<RecCmdsAsyncMock>();
    m_prim_rr_client2 = std::make_shared<NiceMock<RecCmdsAsyncMock>>();
    m_meta_rr_client = std::make_shared<MetaDaqAsyncMock>();
    m_meta_rr_client2 = std::make_shared<NiceMock<MetaDaqAsyncMock>>();
 
    // Connect listener
    m_status->ConnectObserver(std::reference_wrapper(m_observer));
 
    PrimSource p1("prim-source-1", m_prim_rr_client);
    PrimSource p2("prim-source-2", m_prim_rr_client2);
 
    m_prim_sources = MakeSources<PrimSource>({p1, p2});
 
    MetaSource s1("meta-source-1", m_meta_rr_client);
    MetaSource s2("meta-source-2", m_meta_rr_client2);
 
    m_meta_sources = MakeSources<MetaSource>({s1, s2});
}
 
void TestAsyncOpBase::TearDown() {
    m_meta_rr_client.reset();
    m_meta_rr_client2.reset();
    m_prim_rr_client.reset();
    m_prim_rr_client2.reset();
}
 
op::AsyncOpParams TestAsyncOpBase::MakeParams(daq::fits::KeywordFormatter const* ptr) {
    return op::AsyncOpParams(
        *m_status.get(),
        *m_event_log.get(),
        m_alerts,
        m_executor,
        m_logger,
        m_id,
        *m_pending_replies.get(),
        m_prim_sources,
        m_meta_sources,
        ptr != nullptr ? *ptr : static_cast<daq::fits::KeywordFormatter const&>(m_std_formatter));
}