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_TRKSIM_OLDBINTERFACE_HPP
#define HLCC_TRKSIM_OLDBINTERFACE_HPP
 
#include <string>
#include <vector>
#include <memory> // shared_ptr
#include <optional>
 
#include "Msif.hpp"
 
#include <hlcc/oldbmux/observablePublisher.hpp>
#include <boost/asio/thread_pool.hpp>
#include <taiclock/taiClock.hpp>
#include <ptk/posastro.hpp>
#include <rad/oldbInterface.hpp>
#include <rad/cii/oldbAdapter.hpp>
#include "Ccsinsif.hpp"
#include "Ccsinsdetif.hpp"
#include <hlcc/oldbmux/ciiOldbDataPointAsync.hpp>
 
#include "trksim/monitoring.hpp"
 
 
namespace hlcc::trksim {
 
/*
 * Monitor OLDB Attributes.
 */
const std::string KEY_MON_TARG_CIRS_RA  = "ms/lsv/trackctr/mon/ra"; // CIRS
const std::string KEY_MON_TARG_CIRS_DEC = "ms/lsv/trackctr/mon/dec";
const std::string KEY_MON_TARG_ALT      = "ms/lsv/trackest/mon/estimate/sv/track/target_alt";
const std::string KEY_MON_TARG_AZ       = "ms/lsv/trackest/mon/estimate/sv/track/target_az";
const std::string KEY_MON_CURR_ALT      = "ms/lsv/trackest/mon/estimate/sv/track/current_alt";
const std::string KEY_MON_CURR_AZ       = "ms/lsv/trackest/mon/estimate/sv/track/current_az";
const std::string KEY_MON_STATE_APP     = "mon/state"; // HLCC application style: combines application and estimation
const std::string KEY_MON_STATE_TRACK   = "ms/lsv/trackest/mon/estimate/sv/track/state"; // MS LSV style: Tracking state separate, from estimator
const std::string KEY_MON_TRS_HKS_DATA_OK = "mon/trs/hks_data_ok";
const std::string KEY_MON_TRS_HKS_DATA_DUT1 = "mon/trs/hks_dut1";
const std::string KEY_MON_TRS_HKS_DATA_XP = "mon/trs/hks_xp";
const std::string KEY_MON_TRS_HKS_DATA_YP = "mon/trs/hks_yp";
 
 
class Config;
 
struct OldbData{
      /* TODO: make the following fields private with getters. */
 
      
    std::shared_ptr<::ccscommonif::RaDec> target_ra_dec_cirs; // CIRS
    std::shared_ptr<::hlcc::oldbmux::ObservablePublisher<::ccscommonif::RaDec>> target_ra_dec_cirs_publisher;
 
    std::shared_ptr<::ccscommonif::AltAz> target_alt_az;
    std::shared_ptr<::hlcc::oldbmux::ObservablePublisher<::ccscommonif::AltAz>> target_alt_az_publisher;
 
    std::shared_ptr<::ccscommonif::AltAz> current_alt_az;
    std::shared_ptr<::hlcc::oldbmux::ObservablePublisher<::ccscommonif::AltAz>> current_alt_az_publisher;
 
//    std::shared_ptr<::ccsinsif::TrackingData> tracking_data;
//    std::shared_ptr<::hlcc::oldbmux::ObservablePublisher<::ccsinsif::TrackingData>> tracking_data_publisher;
//
//    std::shared_ptr<::ccsinsif::TrackingDataExtended> tracking_data_extended;
//    std::shared_ptr<::hlcc::oldbmux::ObservablePublisher<::ccsinsif::TrackingDataExtended>> tracking_data_extended_publisher;
 
    // Removed mudpi send of pk positions(ETCS-1027)
 
    std::shared_ptr<::stdif::Status> status_app;
    std::shared_ptr<::hlcc::oldbmux::ObservablePublisher<::stdif::Status>> status_app_publisher;
 
    // Port oldb->dds
    std::shared_ptr<::msif::TrackTarget> track_target;
    std::shared_ptr<::hlcc::oldbmux::ObservablePublisher<::msif::TrackTarget>> track_target_publisher;
 
    std::shared_ptr<::msif::TrackSv> track_sv;
    std::shared_ptr<::hlcc::oldbmux::ObservablePublisher<::msif::TrackSv>> track_sv_publisher;
 
    std::shared_ptr<::hlcc::oldbmux::CiiOldbDataPointAsync<double>> heartbeat_subscriber;
 
};

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

    virtual ~OldbInterface();

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

    void PublishTargets(ElapsedTimeStats& stats);

    void PublishCurrentPositions(ElapsedTimeStats& stats, const bool& radec_validity, taiclock::TaiClock::time_point timestamp);

    //void PublishCurrentTime(ElapsedTimeStats& stats);

    ptk::HorizonPositionEsoTimestamped GetCurrentObservedAltAz();

    void SetConfig(hlcc::trksim::Config& cfg);

    void SetControlState(const std::string& value,
                         const taiclock::TaiClock::time_point& timestamp,
                         ElapsedTimeStats& stats);

    void SetTrackingState(const std::string& value,
                         const taiclock::TaiClock::time_point& timestamp,
                         ElapsedTimeStats& stats);
 
    void SetConfig(const rad::Config& cfg);     // solves hidden virtual function
 
    void SetControlState(const std::string& value);     // solves hidden virtual function

    void SetTrsHksDataState(bool hks_data_ok);

    void WriteTrsHksData(ptk::Dut1 dut1, ptk::Arcsecs xp, ptk::Arcsecs yp);

    std::optional<ptk::Dut1> ReadTrsHksDut1();

    std::optional<ptk::Arcsecs> ReadTrsHksPolar(std::string oldb_key);
 
 
    void UpdateHeartbeat();
    OldbInterface(const OldbInterface&) = delete;       
    OldbInterface& operator=(const OldbInterface&) = delete;  
    OldbData& GetOldbData();
    
 private:
    std::tuple<std::optional<double>, std::optional<std::chrono::system_clock::time_point>> 
        ReadTrsHksParamInternal(std::string oldb_key);

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

    log4cplus::Logger m_logger_oldb_async;
 
    OldbData m_oldb_data;
};
 
}  // namespace hlcc::trksim
 
#endif  // HLCC_TRKSIM_OLDBINTERFACE_HPP