daqifMock.hpp

Go to the documentation of this file.

/**
 * @file
 * @ingroup daq_test
 * @copyright 2022 ESO - European Southern Observatory
 *
 * @brief Mockup of DpmDaqControlAsync
 */
// GCOVR_EXCL_START
#ifndef OCM_DAQ_TEST_MOCK_DAQIF_ASYNC_MOCK_HPP
#define OCM_DAQ_TEST_MOCK_DAQIF_ASYNC_MOCK_HPP
#include <Daqif.hpp>
#include <daq/config.hpp>
#include <gmock/gmock.h>
 
namespace daq {
 
struct DpmDaqControlAsyncMock : daqif::DpmDaqControlAsync {
    MOCK_METHOD(::elt::mal::future<std::shared_ptr<::daqif::DaqReply>>,
                QueueDaq,
                (const std::string& specification),
                (override));
    MOCK_METHOD(::elt::mal::future<std::shared_ptr<::daqif::DaqReply>>,
                AbortDaq,
                (const std::string& id),
                (override));
    MOCK_METHOD(
        ::elt::mal::future<std::shared_ptr<::daqif::DaqStatus>>,
        GetDaqStatus,
        (const std::string& id),
        (override));
    MOCK_METHOD(::elt::mal::future<std::vector<std::shared_ptr<::daqif::DaqStatus>>>,
                GetActiveDaqs,
                (),
                (override));
 
    // mal API stuff
    MOCK_METHOD(std::shared_ptr<::elt::mal::Mal>, getMal, (), (const, override));
    MOCK_METHOD(::elt::mal::future<void>, asyncConnect, (), (override));
    MOCK_METHOD(elt::mal::rr::ListenerRegistration,
                registerConnectionListener,
                (elt::mal::rr::ClientRrEntity::ConnectionListener),
                (override));
};
#if 0
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, int32_t());
    MOCK_METHOD1(setSizeRecorded, void(int32_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;
    }
};
#endif
}  // namespace daq
#endif  // #ifndef OCM_DAQ_TEST_MOCK_DAQIF_ASYNC_MOCK_HPP
// GCOVR_EXCL_STOP