determPub.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_DETERMPUB_HPP
#define HLCC_TELIF_ELTPK_DETERMPUB_HPP
#include <memory>
#include <ccsinsdetifLlnetio.hpp>
#include "Ccsinsif.hpp"
#include "Ccsinsdetif.hpp"
#include "string"
#include <mal/utility/Uri.hpp>
#include <mal/utility/LoadMal.hpp>
#include "eltpk/config.hpp"
#include <hlcc/oldbmux/observablePublisher.hpp>
 
namespace hlcc::eltpk::determ{
 
 
class LlnetioPub{
    public:
        LlnetioPub(uint32_t udp_port = 10001, std::string src_ip = "127.0.0.1", std::string dst_ip = "239.128.7.1");

        std::error_code Publish();

        std::shared_ptr<::ccsinsdetifllnetio::PointingKernelPositions> GetPkPos();
 
    private:
        std::shared_ptr<ccsinsdetifllnetio::LlnetioConfig> m_llnetio;
        std::shared_ptr<::ccsinsdetifllnetio::PointingKernelPositions> m_pk_positions_llnetio;
        // llnetio configurations (udp, mudpi, rtms)
        std::unique_ptr<llnetio::UdpTxSocket> m_udp ;
        std::unique_ptr<llnetio::mudpi::Sender> m_mudpi_snd ;
        std::unique_ptr<llnetio::rtms::Sender> m_snd;
        // END
};
 
 
class MudpiPub{
    public:
        MudpiPub(::hlcc::eltpk::Config& config, std::vector<std::shared_ptr<elt::mal::ps::qos::QoS>> qos);

        ::hlcc::oldbmux::PublishingTimeElapsed Publish();

        std::shared_ptr<ccsinsif::PointingKernelPositions> GetPkPos();
 
    private:
        // Mal mudpi pkp publisher
        std::shared_ptr<::hlcc::oldbmux::ObservablePublisher<::ccsinsif::PointingKernelPositions>> m_pk_positions_publisher;
        // Mal mudpi pkp data
        std::shared_ptr<ccsinsif::PointingKernelPositions> m_pk_positions;
    };
}
#endif