dataContext.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_TELIF_DATACONTEXT_HPP
#define HLCC_TELIF_TELIF_DATACONTEXT_HPP
 
#include <ptk/posastro.hpp>
#include <rad/smAdapter.hpp>
#include <rad/dataContext.hpp>
 
#include "Ccsinsifextref.hpp"
#include "Ccsinsifstroke.hpp"
#include "Ccsinsifao.hpp"
#include <Ccsinsif.hpp>
 
#include "ambientdataclient/ambientData.hpp"
 
#include <Eltpkif.hpp>
#include "Telifif.hpp"
 
#include "telif/config.hpp"
#include "telif/oldbInterface.hpp"
#include "telif/dataAcquisition.hpp"
#include "telif/rousData.hpp"
#include "telif/offsetHandler.hpp"
 
 
namespace hlcc::telif {

class DataContext : public rad::DataContext {
 public:
    DataContext();

    virtual ~DataContext();

    void ReloadConfig() override;

    Config& GetConfig() override;

    void UpdateDb() override;

    OldbInterface& GetOldbInterface() override;
 
    //void GetTargetRaDec(double& ra, double& dec);
    //void SetTargetRaDec(const double ra, const double dec);

    ptk::PositionOnEarth GetSitePosition();

    hlcc::ambientdataclient::AmbientData& GetAmbientData();

    bool ConnectEltpk();

    void SetObservingWavelength(double wavelength);

    void SetVelocityOffset(const std::shared_ptr<::ccsinsif::VelocityOffset>& velocity_offset_args);
 
    /* Set ref_aberration and publish entity */
    void SetRefrenceAberration(const elt::mal::shared_vector<const double>& ref_aberration);
 
    /* Set ref_focus and publish entity */
    void SetRefrenceFocus(const double& ref_focus);
 
    /*
     * Publishes the instrument reference offsets to PubSub and Oldb
     */
    void PublishExtrefInsRef();

    void SetStrokeRous(const std::shared_ptr<::ccsinsif::rous::Maneuver>& x);

    void SetAoMirrorHealth(const std::shared_ptr<::ccsinsif::ao::Health>& x);

    bool GetReadyForHandover();

    bool GetTracking();

    std::string GetTelifState();

    std::string GetEltpkState();

    std::string GetCommandSource();

    void SetCommandSource(const std::string&);

    void PublishCommandSource();

    DataAcquisitionList& GetDataAcquisitionList();

    RousData& GetRousData();

    void ReadyForHandoverEstimation(rad::SMAdapter& sm_adapter, bool force_update = false);

    void TrackingEstimation(rad::SMAdapter& sm_adapter, bool force_update = false);

    std::shared_ptr<elt::mal::Mal> GetEntityFactory();

    std::shared_ptr<elt::mal::Mal> GetEntityFactoryDeterm();

    std::shared_ptr<elt::mal::Mal> GetReplyFactory();
    
    void SetUpdateTargetSequenceMode(const telifif::SequenceMode& seq_mode);

    telifif::SequenceMode GetUpdateTargetSequenceMode();

    void SetUpdateTargetSequence(const std::string &sequence);

    std::string GetUpdateTargetSequence();

    void SetPresetSequenceMode(const telifif::SequenceMode& seq_mode);

    telifif::SequenceMode GetPresetSequenceMode();

    void SetPresetSequence(const std::string &sequence);

    std::string GetPresetSequence();

    OffsetHandler& GetOffsetHandler();

    void AddOffsetHandlerArgs(std::shared_ptr<::ccsinsif::OffsetSkyArgs> offset_sky_args);

    std::vector<std::shared_ptr<::ccsinsif::OffsetSkyArgs>> GetOffsetHandlerArgs();

    void GetAndPublishTrexPerfData();
 
    // 2025-07: ETCS-1916 ops-logs for received commands and state-changes
    void RecordOpsLog (const std::string &name, const std::string &value);
 
    DataContext(const DataContext&) = delete;       
    DataContext& operator=(const DataContext&) = delete;  
 
 private:
    Config                m_config;
    OldbInterface         m_oldb_interface;
//    double                  m_ra;
//    double                  m_dec;
 
    mutable std::mutex m_mutex;

    hlcc::ambientdataclient::AmbientData m_ambient_data;
 
    elt::mal::future<void> eltpk_connection_future; // Futute for the pksim connection
 
    // Data Acquisitons
    DataAcquisitionList    m_daq_list;
 
    // Mal entity references
    std::shared_ptr<elt::mal::Mal> m_entity_factory; // Mal used for pub-sub
    std::shared_ptr<elt::mal::Mal> m_reply_factory;  // Mal used for req-rep
    std::shared_ptr<elt::mal::Mal> m_entity_factory_determ;  // Mal used for determ-pub-sub
    std::shared_ptr<::trexif::TrexStatusTel> trex_status;
    std::shared_ptr<::trexif::TrexPerformanceTel> trex_perf;
    // Rous operation data
    RousData               m_rous_data;
 
    // Command source
    std::string m_command_source;
 
    // Ready for handover estimation
    bool m_previous_ready_for_handover;
    
    bool m_previous_tracking;
    // SkyOffset handler
    OffsetHandler m_offset_handler;
    // Vestor of OffsetSkyArgs
    std::vector<std::shared_ptr<::ccsinsif::OffsetSkyArgs>> m_offset_handler_args;
};
 
}  // namespace hlcc::telif
 
#endif  // HLCC_TELIF_TELIF_DATACONTEXT_HPP