metadaqCmdsImpl.hpp

Go to the documentation of this file.

// SPDX-FileCopyrightText: 2020-2025 European Southern Observatory (ESO)
//
// SPDX-License-Identifier: LGPL-3.0-only
 
#ifndef HLCC_TELIF_TELIF_METADAQCMDSIMPL_HPP
#define HLCC_TELIF_TELIF_METADAQCMDSIMPL_HPP
 
#include "Metadaqif.hpp"
#include <rad/exceptions.hpp>
#include <rad/smAdapter.hpp>
 
#include "telif/metadaqCmds.rad.hpp"
#include "telif/logger.hpp"
 
 
namespace hlcc::telif {
 
class MetadaqCmdsImpl : public metadaqif::AsyncMetaDaq {
public:
    explicit MetadaqCmdsImpl(rad::SMAdapter& sm) : m_sm(sm) {
        RAD_TRACE(GetLogger());
    }
 
    virtual ~MetadaqCmdsImpl() {
        RAD_TRACE(GetLogger());
    }
 
    virtual elt::mal::future<std::shared_ptr<::metadaqif::DaqReply>> StartDaq(const std::string& id) override {
        RAD_TRACE(GetLogger());
        LOG4CPLUS_INFO(GetLogger(), "Received StartDaq with: Id  " << id);
 
        auto ev = std::make_shared<MetadaqCmds::StartDaq>(id);
 
        m_sm.RegisterRejectHandler(MetadaqCmds::StartDaq::ID, [](const rad::AnyEvent& event, std::string const& state) {
            RAD_TRACE(GetLogger());
            auto req = rad::GetPayloadNothrow<MetadaqCmds::StartDaq>(event);
            if (req == nullptr) {
                LOG4CPLUS_ERROR(GetLogger(), event.GetId() << " has no associated request!");
                return;
            }
            /* Get the 'id' from payload*/
            const std::string received_id = req->GetRequestPayload();
            metadaqif::DaqException rply_exception(received_id, "Request rejected in state " + state);
            req->SetException(rply_exception);
        });
 
        m_sm.PostEvent(ev);
 
        return ev->GetPayload().GetReplyFuture();
    }
 
    virtual elt::mal::future<std::shared_ptr<::metadaqif::DaqStopReply>> StopDaq(const std::string& id) override {
        RAD_TRACE(GetLogger());
        LOG4CPLUS_INFO(GetLogger(), "Received StopDaq with: Id  " << id);
 
        auto ev = std::make_shared<MetadaqCmds::StopDaq>(id);
 
        m_sm.RegisterRejectHandler(MetadaqCmds::StopDaq::ID, [](const rad::AnyEvent& event, std::string const& state) {
            RAD_TRACE(GetLogger());
            auto req = rad::GetPayloadNothrow<MetadaqCmds::StopDaq>(event);
            if (req == nullptr) {
                LOG4CPLUS_ERROR(GetLogger(), event.GetId() << " has no associated request!");
                return;
            }
            /* Get the 'id' from payload*/
            const std::string received_id = req->GetRequestPayload();
            metadaqif::DaqException rply_exception(received_id, "Request rejected in state " + state);
            req->SetException(rply_exception);
        });
 
        m_sm.PostEvent(ev);
 
        return ev->GetPayload().GetReplyFuture();
    }
 
    virtual elt::mal::future<std::shared_ptr<::metadaqif::DaqReply>> AbortDaq(const std::string& id) override {
        RAD_TRACE(GetLogger());
        LOG4CPLUS_INFO(GetLogger(), "Received AbortDaq with: Id  " << id);
 
        auto ev = std::make_shared<MetadaqCmds::AbortDaq>(id);
 
        m_sm.RegisterRejectHandler(MetadaqCmds::AbortDaq::ID, [](const rad::AnyEvent& event, std::string const& state) {
            RAD_TRACE(GetLogger());
            auto req = rad::GetPayloadNothrow<MetadaqCmds::AbortDaq>(event);
            if (req == nullptr) {
                LOG4CPLUS_ERROR(GetLogger(), event.GetId() << " has no associated request!");
                return;
            }
            /* Get the 'id' from payload*/
            const std::string received_id = req->GetRequestPayload();
            metadaqif::DaqException rply_exception(received_id, "Request rejected in state " + state);
            req->SetException(rply_exception);
        });
 
        m_sm.PostEvent(ev);
 
        return ev->GetPayload().GetReplyFuture();
    }
 
    virtual elt::mal::future<std::shared_ptr<::metadaqif::DaqStatus>> GetDaqStatus(const std::string& id) override {
        RAD_TRACE(GetLogger());
        LOG4CPLUS_INFO(GetLogger(), "Received GetDaqStatus with: Id  " << id);
 
        auto ev = std::make_shared<MetadaqCmds::GetDaqStatus>(id);
 
        m_sm.RegisterRejectHandler(MetadaqCmds::GetDaqStatus::ID, [](const rad::AnyEvent& event, std::string const& state) {
            RAD_TRACE(GetLogger());
            auto req = rad::GetPayloadNothrow<MetadaqCmds::GetDaqStatus>(event);
            if (req == nullptr) {
                LOG4CPLUS_ERROR(GetLogger(), event.GetId() << " has no associated request!");
                return;
            }
            /* Get the 'id' from payload*/
            const std::string received_id = req->GetRequestPayload();
            metadaqif::DaqException rply_exception(received_id, "Request rejected in state " + state);
            req->SetException(rply_exception);
        });
 
        m_sm.PostEvent(ev);
 
        return ev->GetPayload().GetReplyFuture();
    }
 
private:
    rad::SMAdapter& m_sm;
};
 
}  // namespace hlcc::telif
 
#endif  // HLCC_TELIF_TELIF_METADAQCMDSIMPL_HPP