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_ELTPK_OLDBINTERFACE_HPP
#define HLCC_TELIF_ELTPK_OLDBINTERFACE_HPP
 
#include <vector>
#include <optional>
#include <memory> // shared_ptr
 
#include <hlcc/oldbmux/ciiOldbDataPointAsync.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 <Eltpkif.hpp>
#include <Msif.hpp>
#include "eltpk/determPub.hpp"
#include "eltpk/monitoring.hpp"
#include <ccsinsdetifLlnetio.hpp>
 
 
namespace hlcc::eltpk {
 
/*
 * Monitor OLDB Attributes.
 */
const std::string KEY_MON_STATE = "mon/state";
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";
//const std::string KEY_MON_RA = "mon/ra";
//const std::string KEY_MON_DEC = "mon/dec";
 
/*
 * Telmon Oldb Attibutes - These attributes are provided by Eltpk but stored in the telmon
 * branch in Oldb.
 */
// Backward calculated CIRS position (Ra, Dec) from the current (alt, az) of the mount.
const std::string KEY_TELMON_MON_RADEC_BACKCALC_FROM_ALTAZ = "/elt/cs/hlcc/telmon/mon/radec_backcalc_from_altaz";
 
// Observed hour angle HOB, from the current (alt, az) of the mount.
const std::string KEY_TELMON_MON_OBSERVED_HOUR_ANGLE = "/elt/cs/hlcc/telmon/mon/observed_hour_angle";
 
class Config;
struct OldbData{
        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<::ccscommonif::RaDec> current_ra_dec_backcalc;
        std::shared_ptr<::hlcc::oldbmux::ObservablePublisher<::ccscommonif::RaDec>> current_ra_dec_backcalc_publisher;
        std::shared_ptr<::hlcc::oldbmux::CiiOldbDataPointAsync<std::vector<double>>> current_ra_dec_backcalc_dp_async; // exposed here to set quality also separately from publishing
 
        std::shared_ptr<::ccscommonif::RaDec> current_hour_angle; // we abuse RA for HA
        std::shared_ptr<::hlcc::oldbmux::ObservablePublisher<::ccscommonif::RaDec>> current_hour_angle_publisher;
 
        std::shared_ptr<::ccsinsif::CurrentTime> current_time;
        std::shared_ptr<::hlcc::oldbmux::ObservablePublisher<::ccsinsif::CurrentTime>> current_time_publisher;
 
        std::shared_ptr<::ccsinsif::TrackingData> tracking_data;
        std::shared_ptr<::hlcc::oldbmux::ObservablePublisher<::ccsinsif::TrackingData>> tracking_data_publisher;
        std::shared_ptr<::hlcc::oldbmux::CiiOldbDataPointAsync<std::vector<double>>> radec_gs_dp_async; // exposed here to set quality also separately from publishing
 
        std::shared_ptr<::ccsinsif::TrackingDataExtended> tracking_data_extended;
        std::shared_ptr<::hlcc::oldbmux::ObservablePublisher<::ccsinsif::TrackingDataExtended>> tracking_data_extended_publisher;
 
        std::shared_ptr<::ccsinsif::SiteInfo> site_info;
        std::shared_ptr<::hlcc::oldbmux::ObservablePublisher<::ccsinsif::SiteInfo>> site_info_publisher;
 
        std::shared_ptr<::stdif::Status> status_data;
        std::shared_ptr<::hlcc::oldbmux::ObservablePublisher<::stdif::Status>> status_data_publisher;
        std::shared_ptr<::hlcc::oldbmux::ObservablePublisher<::ccsinsif::PresetArgs>> preset_args_publisher;
        std::shared_ptr<::hlcc::oldbmux::CiiOldbDataPointAsync<std::vector<double>>> target_ra_dec_dp_async; // exposed here to set quality also separately from publishing
 
        std::unique_ptr<::elt::mal::ps::Subscriber<::msif::TrackTarget>> track_target_subscriber;
        std::shared_ptr<::msif::TrackTarget> track_target;
        std::unique_ptr<::elt::mal::ps::MrvSubscriber<::msif::TrackSv>> track_sv_subscriber;
        std::shared_ptr<::msif::TrackSv> track_sv;
 
        std::shared_ptr<::hlcc::oldbmux::CiiOldbDataPointAsync<double>> heartbeat_subscriber;
 
        std::shared_ptr<::hlcc::oldbmux::CiiOldbDataPointAsync<double>> time_lst_subscriber;
    };

struct AsmData {
    bool data_quality; /* false means the quality of the data in this struct is not reliable */
    double air_temperature;
    double air_temperature_average;
    double relative_humidity;
    double relative_humidity_average;
    double ambient_pressure;
    double ambient_pressure_average;
};

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

    virtual ~OldbInterface();

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

    void PublishTargets(ElapsedTimeStats& stats);

    void PublishCurrentPositions(ElapsedTimeStats& stats, const bool& radec_validity);

    void SetTargetRaDecValidity(const bool& ra_dec_validity);

    double GetTimeLst();

    void SetTimeLst(double lst);

    void PublishCurrentTime(ElapsedTimeStats& stats);

    void PublishSiteInfo(ElapsedTimeStats& stats);

    void PublishPresetArgs(const std::shared_ptr<::ccsinsif::PresetArgs>& preset_args);

    ptk::HorizonPositionEsoTimestamped GetCurrentObservedAltAz();
 
 
    /* TODO: make the following fields private with getters. */

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

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

    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 SetConfig(const rad::Config& cfg);     // solves hidden virtual function
 
    void SetControlState(const std::string& value);     // solves hidden virtual function
    OldbData& GetOldbData();
    OldbInterface(const OldbInterface&) = delete;       
    OldbInterface& operator=(const OldbInterface&) = delete;  
    std::shared_ptr<determ::LlnetioPub> GetLlnetioPub();
    std::shared_ptr<determ::MudpiPub> GetMudpiPub();
    void UpdateHeartbeat();
 
 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 {};

    std::shared_ptr<determ::LlnetioPub> m_llnetio_pub;
    
    double m_time_lst;

    std::shared_ptr<determ::MudpiPub> m_mudpi_pub {};
};
 
}  // namespace hlcc::eltpk
 
#endif  // HLCC_TELIF_ELTPK_OLDBINTERFACE_HPP