trackCmdsImpl.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_TRKSIM_TRACK_CMDS_IMPL_HPP
#define HLCC_TRKSIM_TRACK_CMDS_IMPL_HPP
 
#include <trksim/trackCtrEvents.rad.hpp>
 
#include <trksim/logger.hpp>
 
#include <rad/exceptions.hpp>
#include <rad/smAdapter.hpp>
 
namespace hlcc {
namespace trksim {
 
class TrackCmdsImpl : public::msif::AsyncTrackCmds {
public:
    explicit TrackCmdsImpl(rad::SMAdapter& sm) : m_sm(sm) {
        RAD_TRACE(GetLogger());
 
        m_sm.RegisterDefaultRequestRejectHandler<TrackCtrEvents::Preset>();
        m_sm.RegisterDefaultRequestRejectHandler<TrackCtrEvents::UpdateTarget>();
        m_sm.RegisterDefaultRequestRejectHandler<TrackCtrEvents::SkyOffset>();
        m_sm.RegisterDefaultRequestRejectHandler<TrackCtrEvents::VelocityOffset>();
        m_sm.RegisterDefaultRequestRejectHandler<TrackCtrEvents::SetTargetAltAz>();
        m_sm.RegisterDefaultRequestRejectHandler<TrackCtrEvents::SetPointingPosition>();
        m_sm.RegisterDefaultRequestRejectHandler<TrackCtrEvents::SetPointingOffset>();
        m_sm.RegisterDefaultRequestRejectHandler<TrackCtrEvents::SetObservingWavelength>();
        m_sm.RegisterDefaultRequestRejectHandler<TrackCtrEvents::Stop>();
        //m_sm.RegisterDefaultRequestRejectHandler<TrackCtrEvents::SetPointingModel>();
    }
 
    virtual ~TrackCmdsImpl() {
        RAD_TRACE(GetLogger());
    }
 
    elt::mal::future<std::string> Preset(const std::shared_ptr<::ccscommonif::TargetData>& args) override {
        RAD_TRACE(GetLogger());
        LOG4CPLUS_INFO(GetLogger(), "Received Preset with: Ra  " << args->getRa() << ", Dec "
                                    << args->getDec() << ", Epoch  " << args->getEpoch()
                                    << ", Rshift" << args->getRshift() <<  ", Radvel  " << args->getRadvel()
                                    << ", Parallax  " << args->getParallax()
                                    << ", Proper_motion_ra " << args->getProper_motion_ra()
                                    << ", Proper_motion_dec  " << args->getProper_motion_dec()
                                    << ", Velocity_offset_ra " << args->getVelocity_offset_ra()
                                    << ", Velocity_offset_dec " << args->getVelocity_offset_dec()
                                    << ", Wavelength " << args->getWavelength()
                                    << ", Time_ephem_utc " << args->getTime_ephem_utc());
        auto ev = std::make_shared<TrackCtrEvents::Preset>(args->clone());
        m_sm.PostEvent(ev);
 
        return ev->GetPayload().GetReplyFuture();
    }
 
    elt::mal::future<std::string> UpdateTarget(const std::shared_ptr<::ccscommonif::TargetData>& args) override {
        RAD_TRACE(GetLogger());
 
        LOG4CPLUS_INFO(GetLogger(), "Received UpdateTarget with: Ra  " << args->getRa() << ", Dec "
                                    << args->getDec() << ", Epoch  " << args->getEpoch()
                                    << ", Rshift" << args->getRshift() <<  ", Radvel  " << args->getRadvel()
                                    << ", Parallax  " << args->getParallax()
                                    << ", Proper_motion_ra " << args->getProper_motion_ra()
                                    << ", Proper_motion_dec  " << args->getProper_motion_dec()
                                    << ", Velocity_offset_ra " << args->getVelocity_offset_ra()
                                    << ", Velocity_offset_dec " << args->getVelocity_offset_dec()
                                    << ", Wavelength " << args->getWavelength()
                                    << ", Time_ephem_utc " << args->getTime_ephem_utc());
 
        auto ev = std::make_shared<TrackCtrEvents::UpdateTarget>(args->clone());
        m_sm.PostEvent(ev);
 
        return ev->GetPayload().GetReplyFuture();
    }
 
    elt::mal::future<std::string> SkyOffset(const std::shared_ptr<::ccscommonif::RaDec>& args) override {
        RAD_TRACE(GetLogger());
        LOG4CPLUS_INFO(GetLogger(), "Received SkyOffset with: Ra  " <<  args->getRa()
                                    << ", Dec  " << args->getDec());
        auto ev = std::make_shared<TrackCtrEvents::SkyOffset>(args->clone());
        m_sm.PostEvent(ev);
 
        return ev->GetPayload().GetReplyFuture();
    }
 
    elt::mal::future<std::string> VelocityOffset(const std::shared_ptr<::ccscommonif::RaDec>& args) override {
        RAD_TRACE(GetLogger());
        LOG4CPLUS_INFO(GetLogger(), "Received VelocityOffset with: Ra  " <<  args->getRa()
                                    << ", Dec  " << args->getDec());
        auto ev = std::make_shared<TrackCtrEvents::VelocityOffset>(args->clone());
        m_sm.PostEvent(ev);
 
        return ev->GetPayload().GetReplyFuture();
    }
 
    elt::mal::future<std::string> SetTargetAltAz(const std::shared_ptr<::ccscommonif::AltAz>& args) override {
 
        RAD_TRACE(GetLogger());
        LOG4CPLUS_INFO(GetLogger(), "Received SetTargetAltAz with: Alt  " <<  args->getAlt()
                                    << ", Az  " << args->getAz());
        auto ev = std::make_shared<TrackCtrEvents::SetTargetAltAz>(args->clone());
        m_sm.PostEvent(ev);
 
        return ev->GetPayload().GetReplyFuture();
    }
 
    elt::mal::future<std::string> SetPointingPosition(const std::shared_ptr<::msif::XY>& args) override {
 
        RAD_TRACE(GetLogger());
        LOG4CPLUS_INFO(GetLogger(), "Received SetTargetAltAz with: X  " <<  args->getX()
                                    << ", Y  " << args->getY());
        auto ev = std::make_shared<TrackCtrEvents::SetPointingPosition>(args->clone());
        m_sm.PostEvent(ev);
 
        return ev->GetPayload().GetReplyFuture();
    }
 
    elt::mal::future<std::string> SetPointingOffset(const std::shared_ptr<::msif::DeltaRaDec>& args) override {
 
        RAD_TRACE(GetLogger());
        LOG4CPLUS_INFO(GetLogger(), "Received SetPointingOffset with: DeltaRa  " <<  args->getDelta_ra()
                                    << ", DeltaDec  " << args->getDelta_dec());
 
        auto ev = std::make_shared<TrackCtrEvents::SetPointingOffset>(args->clone());
        m_sm.PostEvent(ev);
 
        return ev->GetPayload().GetReplyFuture();
    }
    
    [[deprecated("SetObservingWavelength is Deprecated - Use UpdateTarget")]]
    elt::mal::future<std::string> SetObservingWavelength(double wavelenght) override {
        RAD_TRACE(GetLogger());
        LOG4CPLUS_INFO(GetLogger(), "Received SetObservingWavelength with: Wavelenght  " <<  wavelenght);
 
        auto ev = std::make_shared<TrackCtrEvents::SetObservingWavelength>(wavelenght);
        m_sm.PostEvent(ev);
 
        return ev->GetPayload().GetReplyFuture();
    }
 
    elt::mal::future<std::string> Stop() override {
        RAD_TRACE(GetLogger());
        LOG4CPLUS_INFO(GetLogger(), "Received Stop");
               auto ev = std::make_shared<TrackCtrEvents::Stop>();
        m_sm.PostEvent(ev);
 
        return ev->GetPayload().GetReplyFuture();
    }
 
    /*
    // This is probably better handels as a configuration command/(parameters)
    elt::mal::future<std::string> SetPointingModel(const std::string& args) override {
 
        RAD_TRACE(GetLogger());
 
        auto ev = std::make_shared<TrackCtrEvents::SetPointingModel>(args);
        m_sm.PostEvent(ev);
 
        return ev->GetPayload().GetReplyFuture();
    }
    */
 
private:
    rad::SMAdapter& m_sm;
};
 
}  // namespace trksim
}  // namespace hlcc
 
#endif  // HLCC_TRKSIM_TRACK_CMDS_IMPL_HPP