oldbInterface.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_OLDBINTERFACE_HPP
#define HLCC_TELIF_TELIF_OLDBINTERFACE_HPP
 
 
#include <string>
#include <vector>
#include <memory> // shared_ptr
#include <hlcc/oldbmux/observablePublisher.hpp>
#include <rad/oldbInterface.hpp>
#include <rad/cii/oldbAdapter.hpp>
#include <rad/exceptions.hpp>
#include "Ccsinsif.hpp"
#include "Ccsinsifextref.hpp"
#include "Ccsinsifstroke.hpp"
#include "Ccsinsifao.hpp"
#include "Stdif.hpp"
#include "Telifif.hpp"
#include "Trexif.hpp"
#include "telif/config.hpp"
#include <hlcc/oldbmux/ciiOldbDataPointAsync.hpp>
 
 
namespace hlcc::telif {
 
 
struct TrexData{
 
    std::shared_ptr<::elt::mal::ps::Subscriber<::trexif::TrexPerformanceTel>> trex_perf_subscriber;
    std::shared_ptr<::elt::mal::ps::Subscriber<::trexif::TrexStatusTel>> trex_status_subscriber;
};

class OldbInterface : public rad::OldbInterface {
 public:
    OldbInterface(const std::string& prefix="");

    virtual ~OldbInterface();
 

    void Init(::hlcc::telif::Config& config);

    void PublishObservingWavelength(double wavelength);

    void PublishSetVelocityOffset(const std::shared_ptr<::ccsinsif::VelocityOffset>& velocity_offset_args);

    bool GetReadyForHandover();

    bool GetTracking();

    bool GetTargetValidity();

    std::string GetEltpkState();

    std::string GetCommandSource();

    void PublishCommandSource(const std::string&);

    double GetSiteLatitude();

    double GetSiteLongitude();

    double GetSiteElevation();

    void PublishExtrefInsRef();

    void PublishStrokeRous(const std::shared_ptr<::ccsinsif::rous::Maneuver>&);

    void PublishAoMirrorHealth(const std::shared_ptr<::ccsinsif::ao::Health>&);

    void PublishCcsInfo();
 
    inline std::shared_ptr<::ccsinsif::insref::Offsets> GetInsrefOffset() { return insref_offsets; }
    inline std::shared_ptr<::ccsinsif::CcsInfo> GetCcsInfoEntity() { return ccs_info; }
 
    void SetConfig(const hlcc::telif::Config& cfg);

    std::string GetControlState();

    void SetControlState(const std::string& status) override; // , int64_t timestamp
    //    void SetRaDec(const double ra, const double dec);
    void SetConfig(const rad::Config& cfg);    // solves hidden virtual function

    void PublishPresetSequenceMode(const telifif::SequenceMode& sequence_mode);

    telifif::SequenceMode ReadPresetSequenceMode();

    void PublishPresetSequence(const std::string &sequence);

    std::string ReadPresetSequence();

    void PublishUpdateTargetSequenceMode(const telifif::SequenceMode& sequence_mode);

    telifif::SequenceMode ReadUpdateTargetSequenceMode();

    void PublishUpdateTargetSequence(const std::string &sequence);

    std::string ReadUpdateTargetSequence();    
    std::string ReadUpdateTargetSequenceStatus();
    
    void PublishUpdateTargetSequenceStatus(const std::string &sequence);

    void PublishOffsetSequenceMode(const telifif::SequenceMode& sequence_mode);

    telifif::SequenceMode ReadOffsetSequenceMode();

    void PublishOffsetSequence(const std::string &sequence);

    std::string ReadOffsetSequence();

    void PublishMessageOffsetSequence(uint16_t id, std::string message);

    std::vector<std::shared_ptr<telifif::SeqMessage>> ReadMessageOffsetSequence();

    std::string WriteGuideProbeToOldb(std::shared_ptr<pfsif::GuideStarArgs> gp_args);

    TrexData GetTrexData();

    std::vector<std::string> GetGsToGpMap();

    void SetGsToGpMap(const std::vector<std::string>& gs_gp_map);
    
    void UpdateHeartbeat();
    void PublishPerfEstimate(std::vector<double> perf_data);
 
    void SetOperatorAllowsHandover(bool operator_allows_handover);
    
    OldbInterface(const OldbInterface&) = delete;       
    OldbInterface& operator=(const OldbInterface&) = delete;  
 
 private:
    std::shared_ptr<::hlcc::oldbmux::ObservablePublisher<::ccsinsif::insref::Offsets>> insref_offsets_publisher;
    std::shared_ptr<::hlcc::oldbmux::ObservablePublisher<::ccsinsif::rous::Maneuver>> rous_maneuver_publisher;
    std::shared_ptr<::hlcc::oldbmux::ObservablePublisher<::ccsinsif::ao::Health>> ao_health_publisher;
    std::shared_ptr<::hlcc::oldbmux::ObservablePublisher<::ccsinsif::CcsInfo>> ccs_info_publisher;
 
    std::shared_ptr<::ccsinsif::insref::Offsets> insref_offsets;
    std::shared_ptr<::ccsinsif::CcsInfo> ccs_info;
 
    std::shared_ptr<::stdif::Status> status_data;
    std::shared_ptr<::hlcc::oldbmux::ObservablePublisher<::stdif::Status>> status_data_publisher;
    std::shared_ptr<::ccsinsif::CommandSource> cmd_source_data;
    std::shared_ptr<::hlcc::oldbmux::ObservablePublisher<::ccsinsif::CommandSource>> cmd_src_data_publisher;
 
    std::unique_ptr<::elt::mal::ps::Publisher<::telifif::SeqMessage>> offset_sequence_msg_publisher;
    std::unique_ptr<::elt::mal::ps::Subscriber<::telifif::SeqMessage>> offset_sequence_msg_subscriber;
 
    std::shared_ptr<::hlcc::oldbmux::CiiOldbDataPointAsync<std::vector<double>>> perf_estimate_subscriber;
 
    std::shared_ptr<::hlcc::oldbmux::CiiOldbDataPointAsync<double>> heartbeat_subscriber;
    std::shared_ptr<::hlcc::oldbmux::CiiOldbDataPointAsync<bool>> handover_subscriber;
 
    TrexData m_trex_data;
 
    std::mutex m_mutex;

    boost::asio::thread_pool m_async_exec {5};

    log4cplus::Logger m_logger_oldb_async;
};
 
}  // namespace hlcc::telif
 
#endif  // HLCC_TELIF_TELIF_OLDBINTERFACE_HPP