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_TELMON_OLDBINTERFACE_HPP
#define HLCC_TELIF_TELMON_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 "Stdif.hpp"
#include "Ccsinsif.hpp"
#include "Ccsinsdetif.hpp"
#include "Ccsinsifextref.hpp"
#include "Ccsinsifstroke.hpp"
#include "Ccsinsifao.hpp"
#include <hlcc/oldbmux/ciiOldbDataPointAsync.hpp>
 
#include "telmon/config.hpp"
 
namespace hlcc::telmon {

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

    virtual ~OldbInterface();

    void Init(Config& config);
 
    void SetConfig(const hlcc::telmon::Config& cfg);
 
    void SetControlState(const std::string& status) override;

    std::string GetControlState();
    void SetConfig(const rad::Config& cfg);     // solves hidden virtual function
    void UpdateHeartbeat();
    OldbInterface(const OldbInterface&) = delete;       
    OldbInterface& operator=(const OldbInterface&) = delete;  
 
 private:
    std::shared_ptr<::stdif::Status> status_data;
    std::shared_ptr<::hlcc::oldbmux::ObservablePublisher<::stdif::Status>> status_data_publisher;
    std::shared_ptr<::hlcc::oldbmux::CiiOldbDataPointAsync<double>> heartbeat_subscriber;

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

    log4cplus::Logger m_logger_oldb_async;
 
};
 
}  // namespace hlcc::eltpk
 
#endif  // HLCC_TELIF_TELMON_OLDBINTERFACE_HPP