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_PFSSIMHLCC_OLDBINTERFACE_HPP
#define HLCC_PFSSIMHLCC_OLDBINTERFACE_HPP
 
#include <string>
#include <vector>
#include <memory> // shared_ptr
 
#include <hlcc/oldbmux/observablePublisher.hpp>
#include <boost/asio/thread_pool.hpp>
#include <taiclock/taiClock.hpp>
#include <rad/oldbInterface.hpp>
#include <rad/cii/oldbAdapter.hpp>
#include "Ccsinsif.hpp"
#include "Ccsinsdetif.hpp"
#include "pfssimhlcc/pointingCorrection.hpp"
#include "pfssimhlcc/config.hpp"
#include "pfssimhlcc/monitoring.hpp"
#include <hlcc/oldbmux/ciiOldbDataPointAsync.hpp>
 
namespace hlcc::pfssimhlcc {
 
/*
 * Monitor OLDB Attributes.
 */
const std::string KEY_MON_GPA_PCORR_RA     = "mon/gpa/pcorrection_ra";
const std::string KEY_MON_GPA_PCORR_DEC    = "mon/gpa/pcorrection_dec";
const std::string KEY_MON_GPA_PCORR_VALID  = "mon/gpa/pcorrection_valid";
const std::string KEY_MON_GPA_PCORR_TSTAMP = "mon/gpa/timstamp";
const std::string KEY_MON_GPB_PCORR_RA     = "mon/gpb/pcorrection_ra";
const std::string KEY_MON_GPB_PCORR_DEC    = "mon/gpb/pcorrection_dec";
const std::string KEY_MON_GPB_PCORR_VALID  = "mon/gpb/pcorrection_valid";
const std::string KEY_MON_GPB_PCORR_TSTAMP = "mon/gpb/timstamp";
const std::string KEY_MON_GPC_PCORR_RA     = "mon/gpc/pcorrection_ra";
const std::string KEY_MON_GPC_PCORR_DEC    = "mon/gpc/pcorrection_dec";
const std::string KEY_MON_GPC_PCORR_VALID  = "mon/gpc/pcorrection_valid";
const std::string KEY_MON_GPC_PCORR_TSTAMP = "mon/gpc/timstamp";
const std::string HEARTBEAT("mon/heartbeat");
 
class OldbInterface : public rad::OldbInterface {
 public:
    OldbInterface(const std::string& prefix = "");
 
    virtual ~OldbInterface();
 
    void Init(::hlcc::pfssimhlcc::Config& config);
 
    void SetConfig(hlcc::pfssimhlcc::Config& cfg);
 
    void SetConfig(const rad::Config& cfg);     // solves hidden virtual function
 
    void StorePointingCorrections(const pfs::gpctr::PointingCorrection pcorr_a, // PointingCorrections are immutable: const is no pointless here
                                  const pfs::gpctr::PointingCorrection pcorr_b,
                                  const pfs::gpctr::PointingCorrection pcorr_c);
 
    void UpdateHeartbeat();
    OldbInterface(const OldbInterface&) = delete;       
    OldbInterface& operator=(const OldbInterface&) = delete;  
 
 private:
 
    std::shared_ptr<::hlcc::oldbmux::CiiOldbDataPointAsync<double>> heartbeat_subscriber;
 
    boost::asio::thread_pool m_async_exec {2};
 
    log4cplus::Logger m_logger_oldb_async;
 
};
 
}  // namespace hlcc::pfssimhlcc
 
#endif  // HLCC_PFSSIMHLCC_OLDBINTERFACE_HPP