seqServerFacade.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_SEQSERVERFACADE_HPP
#define HLCC_TELIF_TELIF_SEQSERVERFACADE_HPP
 
#include <string>
#include <vector>
#include <atomic>
#include <thread>
#include "Telifif.hpp"
 
namespace hlcc::telif {
struct ObParams{
    std::string ob_name;
    std::string ob_args; // as json
};
 
class SeqServerFacade {
 
 public:

    SeqServerFacade(std::string ip, std::string port, std::string script);

    virtual ~SeqServerFacade();

    bool IsConnected();

    void SetObVariable(std::string var_name, std::string var_value);

    void SkipUserActions();

    void SkipDefaultActions();

    void RunScript();

    void RunScriptInteractive();

    static std::string GetSeqServerIpPort();

    static std::pair<bool, std::string> RunSeqScript(telifif::SequenceMode seq_mode, std::string script_name, std::optional<ObParams> ob = std::nullopt);
    static std::string GetHostIp();
 
    SeqServerFacade(const SeqServerFacade&) = delete;             
    SeqServerFacade& operator=(const SeqServerFacade&) = delete;  
 
 private:

    void LoadObScript();

    std::string GetParameterIndex(std::string param_name);

    std::vector<std::string> GetUserActionSteps();

    std::vector<std::string> GetDefaultActionSteps();

    bool Connect();

    void SendCommand(std::string command);

    void Disconnect();

    std::string m_seq_ip;       // Sequencer server ip address
    std::string m_seq_port;     // Sequencer server port
    std::string m_seq_script;   // Sequencer script to be loaded
    int m_conn_status;          // Status of connection to seq server (0 = success, -1 = errors.)
    int m_client_fd;            // Client file descriptor
    std::atomic_bool m_socket_reader_loop; // While is true we will keep reading from the socket
    std::thread m_socket_reader_thread; // Thread to handle the reading from the socket
};
 
}  // namespace hlcc::telif
 
#endif  // HLCC_TELIF_TELIF_SEQSERVERFACADE_HPP