mockAsyncProcess.hpp

Go to the documentation of this file.

/**
 * @file
 * @ingroup daq_common_libdpm
 * @copyright (c) Copyright ESO 2022
 * All Rights Reserved
 * ESO (eso.org) is an Intergovernmental Organisation, and therefore special legal conditions apply.
 *
 * @brief Mocks for daq::RsyncAsyncProcessIf
 */
#ifndef DAQ_DPM_MOCK_MOCKASYNCPROCESS_HPP
#define DAQ_DPM_MOCK_MOCKASYNCPROCESS_HPP
 
#include <gmock/gmock.h>
 
#include <daq/process/rsyncAsyncProcess.hpp>
 
namespace daq {
/**
 * Combined fake/mock
 */
struct MockAsyncProcess : virtual AsyncProcessIf {
    virtual boost::future<int> Initiate() override {
        return promise.get_future();
    }
    MOCK_METHOD(std::optional<pid_t>, GetPid, (), (const, noexcept, override));
      
    MOCK_METHOD(std::error_code, Abort, (), (noexcept, override));
    MOCK_METHOD(std::error_code, Signal, (int), (override, noexcept));
    MOCK_METHOD(std::vector<std::string> const&, GetArguments, (), (const, override, noexcept));
    MOCK_METHOD(bool, IsRunning, (), (const, noexcept, override));
 
    using AsyncProcessIf::SigOutStream;
    boost::signals2::connection ConnectStdout(SigOutStream::slot_type const& slot) override {
        return stdout.connect(slot);
    }
    boost::signals2::connection ConnectStderr(SigOutStream::slot_type const& slot) override {
        return stderr.connect(slot);
    }
 
    SigOutStream stdout;
    SigOutStream stderr;
    boost::promise<int> promise;
};
 
struct MockRsyncAsyncProcess : virtual RsyncAsyncProcessIf, MockAsyncProcess {
    using RsyncAsyncProcessIf::SigProgress;
    boost::signals2::connection ConnectProgress(SigProgress::slot_type const& slot) override {
        return progress.connect(slot);
    }
    SigProgress progress;
};
} // namespace daq
#endif // #ifndef DAQ_DPM_MOCK_MOCKASYNCPROCESS_HPP