recifMock.hpp

Go to the documentation of this file.

/**
 * @file
 * @ingroup daq_test
 * @copyright 2022 ESO - European Southern Observatory
 *
 * @brief Mockup of metadaqif classes
 */
// GCOVR_EXCL_START
#ifndef OCM_DAQ_TEST_MOCK_RECIF_ASYNC_MOCK_HPP
#define OCM_DAQ_TEST_MOCK_RECIF_ASYNC_MOCK_HPP
#include <Recif.hpp>
#include <daq/config.hpp>
#include <gmock/gmock.h>
 
namespace daq {
 
struct RecCmdsAsyncMock : recif::RecCmdsAsync {
    MOCK_METHOD1(RecStart,
                 ::elt::mal::future<std::shared_ptr<::recif::RecStatus>>(
                     const std::shared_ptr<::recif::RecProperties>&));
    MOCK_METHOD0(RecContinue,
                 ::elt::mal::future<std::shared_ptr<::recif::RecStatus>>());
    MOCK_METHOD0(RecStop,
                 ::elt::mal::future<std::shared_ptr<::recif::RecStatus>>());
    MOCK_METHOD0(RecAbort, ::elt::mal::future<std::string>());
    MOCK_METHOD0(RecPause,
                 ::elt::mal::future<std::shared_ptr<::recif::RecStatus>>());
    MOCK_METHOD1(RecStatus,
                 ::elt::mal::future<std::shared_ptr<::recif::RecStatus>>(const std::string&));
    MOCK_METHOD1(RecWait,
                 ::elt::mal::future<std::shared_ptr<::recif::RecWaitStatus>>(
                     const std::shared_ptr<recif::RecWaitSpec>&));
 
    // mal API stuff
    MOCK_CONST_METHOD0(getMal, std::shared_ptr<::elt::mal::Mal>());
    MOCK_METHOD0(asyncConnect, ::elt::mal::future<void>());
    MOCK_METHOD1(
        registerConnectionListener,
        elt::mal::rr::ListenerRegistration(elt::mal::rr::ClientRrEntity::ConnectionListener));
};
 
struct RecStatusMock : recif::RecStatus {
public:
    MOCK_CONST_METHOD0(getId, std::string());
    MOCK_METHOD1(setId, void(const std::string&));
 
    MOCK_CONST_METHOD0(getDpFiles, std::vector<std::string>());
    MOCK_METHOD1(setDpFiles, void(const std::vector<std::string>&));
 
    MOCK_CONST_METHOD0(getEndTime, double());
    MOCK_METHOD1(setEndTime, void(double end_time));
 
    MOCK_CONST_METHOD0(getFilesGenerated, int32_t());
    MOCK_METHOD1(setFilesGenerated, void(int32_t files_generated));
 
    MOCK_CONST_METHOD0(getFramesProcessed, int32_t());
    MOCK_METHOD1(setFramesProcessed, void(int32_t frames_recorded));
 
    MOCK_CONST_METHOD0(getFramesRemaining, int32_t());
    MOCK_METHOD1(setFramesRemaining, void(int32_t frames_remaining));
 
    MOCK_CONST_METHOD0(getInfo, std::string());
    MOCK_METHOD1(setInfo, void(std::string const&));
 
    MOCK_CONST_METHOD0(getRemainingTime, double());
    MOCK_METHOD1(setRemainingTime, void(double remaining_time));
 
    MOCK_CONST_METHOD0(getSizeRecorded, int64_t());
    MOCK_METHOD1(setSizeRecorded, void(int64_t size_recorded));
 
    MOCK_CONST_METHOD0(getStartTime, double());
    MOCK_METHOD1(setStartTime, void(double start_time));
 
    MOCK_CONST_METHOD0(getStatus, ::recif::RecStatusNames());
    MOCK_METHOD1(setStatus, void(::recif::RecStatusNames status));
 
    MOCK_CONST_METHOD0(getTimeElapsed, double());
    MOCK_METHOD1(setTimeElapsed, void(double time_elapsed));
 
    // Mal stuff
    std::unique_ptr<recif::RecStatus> clone() const override {
        return {};
    }
    std::unique_ptr<recif::RecStatus> cloneKey() const override {
        return {};
    }
    bool hasKey() const override {
        return false;
    };
    bool keyEquals(const recif::RecStatus& other) const override {
        return false;
    }
};
 
}  // namespace daq
#endif  // #ifndef OCM_DAQ_TEST_MOCK_RECIF_ASYNC_MOCK_HPP
// GCOVR_EXCL_STOP