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 "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"; // currently still apparent position rather than 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
 
 
class Config;
 
struct OldbData{
      /* TODO: make the following fields private with getters. */
 
    std::shared_ptr<::ccsinsif::RaDec> target_ra_dec_cirs; // currently still apparent position, will later become CIRS
    std::shared_ptr<::hlcc::oldbmux::ObservablePublisher<::ccsinsif::RaDec>> target_ra_dec_cirs_publisher;
 
    std::shared_ptr<::ccsinsif::AltAz> target_alt_az;
    std::shared_ptr<::hlcc::oldbmux::ObservablePublisher<::ccsinsif::AltAz>> target_alt_az_publisher;
 
    std::shared_ptr<::ccsinsif::AltAz> current_alt_az;
    std::shared_ptr<::hlcc::oldbmux::ObservablePublisher<::ccsinsif::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;
 
};
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::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
    AsmData ReadAsm();
    void UpdateHeartbeat();
    OldbInterface(const OldbInterface&) = delete;       
    OldbInterface& operator=(const OldbInterface&) = delete;  
    OldbData& GetOldbData();
 private:
 
    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