testAsyncOpBase.hpp

Go to the documentation of this file.

/**
 * @file
 * @ingroup daq_ocm_libdaq_test
 * @copyright 2022 ESO - European Southern Observatory
 *
 * @brief Contains declaration for async operations shared base class
 */
#ifndef OCM_DAQ_TEST_ASYNC_OP_BASE_HPP_
#define OCM_DAQ_TEST_ASYNC_OP_BASE_HPP_
#include <daq/config.hpp>
 
#include <gmock/gmock.h>
#include <gtest/gtest.h>
#include <log4cplus/logger.h>
#include <boost/asio/io_context.hpp>
 
#include <daq/status.hpp>
#include <daq/source.hpp>
#include <daq/pendingReplies.hpp>
#include <daq/op/asyncOpParams.hpp>
#include <rad/ioExecutor.hpp>
 
#include "mock/recifMock.hpp"
#include "mock/metadaqifMock.hpp"
#include "statusObserver.hpp"
 
MATCHER_P(RecPropertyIdEq, id, "") {
    *result_listener << "where the id is" << (arg->getId());
    return arg && arg->getId() == id;
}
 
/**
 * Base fixture for async operation tests.
 *
 * @ingroup daq_ocm_libdaq_test
 */
struct TestAsyncOpBase : ::testing::Test {
    std::shared_ptr<daq::RecCmdsAsyncMock> m_prim_rr_client;
    std::shared_ptr<daq::RecCmdsAsyncMock> m_prim_rr_client2;
    std::shared_ptr<daq::MetaDaqAsyncMock> m_meta_rr_client;
    std::shared_ptr<daq::MetaDaqAsyncMock> m_meta_rr_client2;
    
 
    boost::asio::io_context m_io_ctx;
    rad::IoExecutor m_executor;
    log4cplus::Logger m_logger;
    daq::fits::StandardKeywordFormatter m_std_formatter;
    std::string m_id;
    StatusObserverMock m_observer;
    std::shared_ptr<daq::ObservableStatus> m_status;
    std::shared_ptr<daq::ObservableEventLog> m_event_log;
    daq::op::AlertState m_alerts;
    std::shared_ptr<daq::PendingReplies> m_pending_replies;
    std::vector<daq::Source<daq::PrimSource>> m_prim_sources;
    std::vector<daq::Source<daq::MetaSource>> m_meta_sources;
   
    // Used in tests
    boost::promise<std::shared_ptr<recif::RecStatus>> m_recstatus_promise1;
    boost::promise<std::shared_ptr<recif::RecStatus>> m_recstatus_promise2;
    boost::promise<std::string> m_string_promise1;
    boost::promise<std::string> m_string_promise2;
 
    TestAsyncOpBase();
    void SetUp() override;
    void TearDown() override;
 
    template<class SourceType>
    std::vector<daq::Source<SourceType>>
    MakeSources(std::vector<SourceType> sources) {
        std::vector<daq::Source<SourceType>> dest;
        dest.reserve(sources.size());
        std::transform(std::make_move_iterator(sources.begin()), std::make_move_iterator(sources.end()),
                       std::back_inserter(dest), [](SourceType&& s) -> daq::Source<SourceType> {
                           return daq::Source<SourceType>{std::move(s)};
                       });
        return dest;
    }
 
    /**
     * Make async params using m_std_formatter if no fmt is not provided.
     */
    daq::op::AsyncOpParams MakeParams(daq::fits::KeywordFormatter const* fmt = nullptr);
};
 
#endif // #ifndef OCM_DAQ_TEST_ASYNC_OP_BASE_HPP_