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>
 
namespace hlcc::telif {
 
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 bool RunSystemCommand(
        const std::string& cmd, const std::vector<std::string>& args, std::string& cmd_output
    );
 
    static std::string GetHostIp();
 
    SeqServerFacade(const SeqServerFacade&) = delete;             
    SeqServerFacade& operator=(const SeqServerFacade&) = delete;  
 
 private:
 
    void Initialize();
 
    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