telifCmdsImpl.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_TELIFCMDSIMPL_HPP
#define HLCC_TELIF_TELIF_TELIFCMDSIMPL_HPP
 
#include <rad/exceptions.hpp>
#include <rad/smAdapter.hpp>
 
#include "telif/telifCmds.rad.hpp"
#include "telif/logger.hpp"
 
namespace hlcc::telif {
 
 
class TelifCmdsImpl : public telifif::AsyncTelifCmds {
public:
    explicit TelifCmdsImpl(rad::SMAdapter& sm) : m_sm(sm) {
        RAD_TRACE(GetLogger());
    }
 
    virtual ~TelifCmdsImpl() {
        RAD_TRACE(GetLogger());
    }
 
    virtual elt::mal::future<std::string> MoveToNamedPos(const std::string& position_name) override {
 
        RAD_TRACE(GetLogger());
        LOG4CPLUS_INFO(GetLogger(), "Received MoveToNamedPos with: position_name  " << position_name);
        auto ev = std::make_shared<TelifCmds::MoveToNamedPos>(position_name);
        m_sm.RegisterDefaultRequestRejectHandler<TelifCmds::MoveToNamedPos>();
        m_sm.PostEvent(ev);
        RAD_TRACE(GetLogger());
 
        return ev->GetPayload().GetReplyFuture();
 
    }
 
    virtual elt::mal::future<std::string> MoveToAltAzPos(const std::shared_ptr<ccsinsif::AltAz>& axes_position) override {
 
        RAD_TRACE(GetLogger());
        LOG4CPLUS_INFO(GetLogger(), "Received MoveToAltAzPos with: Alt " << axes_position->getAlt()
                                    << ", Az  " << axes_position->getAz());
        auto ev = std::make_shared<TelifCmds::MoveToAltAzPos>(axes_position->clone());
        m_sm.RegisterDefaultRequestRejectHandler<TelifCmds::MoveToAltAzPos>();
        m_sm.PostEvent(ev);
 
        return ev->GetPayload().GetReplyFuture();
    }
 
    virtual elt::mal::future<std::string> StopTracking() override {
 
        RAD_TRACE(GetLogger());
        LOG4CPLUS_INFO(GetLogger(), "Received StopTracking");
        auto ev = std::make_shared<TelifCmds::StopTracking>();
        m_sm.RegisterDefaultRequestRejectHandler<TelifCmds::StopTracking>();
        m_sm.PostEvent(ev);
 
        return ev->GetPayload().GetReplyFuture();
    }
 
    virtual ::elt::mal::future<std::string> SetPresetSequenceMode(telifif::SequenceMode sequence_mode) override {
        RAD_TRACE(GetLogger());
        LOG4CPLUS_INFO(GetLogger(), "Received SetPresetSequenceMode with: sequence_mode " << sequence_mode);
        auto ev = std::make_shared<TelifCmds::SetPresetSequenceMode>(sequence_mode);
        m_sm.RegisterDefaultRequestRejectHandler<TelifCmds::SetPresetSequenceMode>();
        m_sm.PostEvent(ev);
        return ev->GetPayload().GetReplyFuture();
    }
 
    virtual ::elt::mal::future<std::string> SetPresetSequence(const std::string& sequence) override {
        RAD_TRACE(GetLogger());
        LOG4CPLUS_INFO(GetLogger(), "Received SetPresetSequence with: sequence " << sequence);
        auto ev = std::make_shared<TelifCmds::SetPresetSequence>(sequence);
        m_sm.RegisterDefaultRequestRejectHandler<TelifCmds::SetPresetSequence>();
        m_sm.PostEvent(ev);
        return ev->GetPayload().GetReplyFuture();
    }
 
    virtual ::elt::mal::future<std::string> SetOffsetSequenceMode(telifif::SequenceMode sequence_mode) override {
        RAD_TRACE(GetLogger());
        LOG4CPLUS_INFO(GetLogger(), "Received SetOffsetSequenceMode with: sequence_mode " << sequence_mode);
        auto ev = std::make_shared<TelifCmds::SetOffsetSequenceMode>(sequence_mode);
        m_sm.RegisterDefaultRequestRejectHandler<TelifCmds::SetOffsetSequenceMode>();
        m_sm.PostEvent(ev);
        return ev->GetPayload().GetReplyFuture();
    }
 
    virtual ::elt::mal::future<std::string> SetOffsetSequence(const std::string& sequence) override {
        RAD_TRACE(GetLogger());
        LOG4CPLUS_INFO(GetLogger(), "Received SetOffsetSequence with: sequence " << sequence);
        auto ev = std::make_shared<TelifCmds::SetOffsetSequence>(sequence);
        m_sm.RegisterDefaultRequestRejectHandler<TelifCmds::SetOffsetSequence>();
        m_sm.PostEvent(ev);
        return ev->GetPayload().GetReplyFuture();
    }
 
    virtual ::elt::mal::future<std::string> SetGuideProbe(const std::shared_ptr<pfsif::GuideStarArgs>& guide_star_args) override {
        RAD_TRACE(GetLogger());
        LOG4CPLUS_INFO(GetLogger(), "Received SetGuideProbe with: id  " << guide_star_args->getId() << ", Ra  "
                                    << guide_star_args->getRa() << ", Dec " << guide_star_args->getDec() << ", Epoch  "
                                    << guide_star_args->getEpoch() << ", Band  " << guide_star_args->getBand() << ", Rshift  "
                                    << guide_star_args->getRshift() <<  ", Radvel  " << guide_star_args->getRadvel()
                                    << ", Magnitude  " << guide_star_args->getMagnitude() << ", Parallax  "
                                    << guide_star_args->getParallax() << ", Proper_motion_ra " << guide_star_args->getProper_motion_ra()
                                    << ", Proper_motion_dec  " << guide_star_args->getProper_motion_dec());
        auto ev = std::make_shared<TelifCmds::SetGuideProbe>(guide_star_args->clone());
 
        m_sm.RegisterDefaultRequestRejectHandler<TelifCmds::SetGuideProbe>();
 
        m_sm.PostEvent(ev);
 
        return ev->GetPayload().GetReplyFuture();
    }
 
    virtual ::elt::mal::future<std::string> SetGpHierarchy(const std::shared_ptr<pfsif::GpHierarchyArgs>& gp_hierarchy_args) override {
        RAD_TRACE(GetLogger());
        LOG4CPLUS_INFO(GetLogger(), "Received SetGpHierarchy with: A  " << gp_hierarchy_args->getA() << ", B  "
                                    << gp_hierarchy_args->getB() << ", C  " << gp_hierarchy_args->getC());
        auto ev = std::make_shared<TelifCmds::SetGpHierarchy>(gp_hierarchy_args->clone());
 
        m_sm.RegisterDefaultRequestRejectHandler<TelifCmds::SetGpHierarchy>();
 
        m_sm.PostEvent(ev);
 
        return ev->GetPayload().GetReplyFuture();
    }
 
    virtual ::elt::mal::future<std::string> StopGuideProbe(const pfsif::GuideProbeId guide_probe_id) override {
        RAD_TRACE(GetLogger());
        LOG4CPLUS_INFO(GetLogger(), "Received StopGuideProbe with: id  " << guide_probe_id );
        auto ev = std::make_shared<TelifCmds::StopGuideProbe>(guide_probe_id);
 
        m_sm.RegisterDefaultRequestRejectHandler<TelifCmds::StopGuideProbe>();
 
        m_sm.PostEvent(ev);
 
        return ev->GetPayload().GetReplyFuture();
    }
 
private:
    rad::SMAdapter& m_sm;
 
    static std::string ContinuationCheckRejection(elt::mal::future<std::string> future, std::string method_name) {
        std::string reply = future.get(); // the future is (normally) already fulfilled when called from a then-continuation.
        if (reply.find("Request rejected in state") != std::string::npos) { // TODO C++20 use std::string::starts_with.
            LOG4CPLUS_INFO(GetLogger(), method_name << " command rejected by eltpk: " << reply);
        }
        return reply;
    };
};
 
}  // namespace hlcc::telif
 
#endif  // HLCC_TELIF_TELIF_TELIFCMDSIMPL_HPP