dbInterface.hpp

Go to the documentation of this file.

/**
 * @file
 * @ingroup server
 * @copyright ESO - European Southern Observatory
 * @author
 *
 * @brief DbInterface class header file.
 */
#ifndef SERVER_DB_INTERFACE_HPP_
#define SERVER_DB_INTERFACE_HPP_
 
#include <rad/oldbAsyncWriter.hpp>
 
#include <string>
 
namespace server {
 
const std::string KEY_CONTROL_STATE = "ctr.state";
#if 0
const std::string KEY_CONFIG_REQ_ENDPOINT = "cfg.req.endpoint";
const std::string KEY_CONFIG_PUB_ENDPOINT = "cfg.pub.endpoint";
const std::string KEY_CONFIG_DB_ENDPOINT = "cfg.db.endpoint";
const std::string KEY_CONFIG_DB_PREFIX = "cfg.db.prefix";
const std::string KEY_CONFIG_DB_TIMEOUT_SEC = "cfg.db.timeout_sec";
const std::string KEY_CONFIG_SM_SCXML = "cfg.sm.scxml";
const std::string KEY_CONFIG_FILENAME = "cfg.filename";
const std::string KEY_CONFIG_LOG_LEVEL = "cfg.log.level";
const std::string KEY_CONFIG_LOG_PROPERTIES = "cfg.log.properties";
const std::string KEY_CONFIG_INSTRUMENT_ID = "cfg.instrument_id";
const std::string KEY_CONFIG_DATAROOT = "cfg.dataroot";
const std::string KEY_CONFIG_WORKSPACE = "cfg.workspace";
 
const std::string KEY_CONFIG_STALE_DAQ_ACQUIRING = "cfg.daq.stale.acquiring_hours";
const std::string KEY_CONFIG_STALE_DAQ_MERGING = "cfg.daq.stale.merging_hours";
 
const std::string KEY_CONFIG_DPM_REQ_ENDPOINT = "cfg.dpm.req.endpoint";
const std::string KEY_CONFIG_DPM_PUB_ENDPOINT = "cfg.dpm.pub.endpoint";
const std::string KEY_CONFIG_DPM_TIMEOUT_SEC = "cfg.dpm.timeout_sec";
#endif
class Config;
 
 
/**
 * This class is the write-only interface to the CII OLDB.
 */
class DbInterface {
 public:
    /**
     * Constructor.
     *
     * @param[in] prefix String used as prefix when building the keys.
     * @param[in] runtime_db Reference to the in-memory DB adapter.
     */
    DbInterface(const std::string& prefix, rad::OldbAsyncWriter& runtime_db);
 
    /**
     * Destructor
     */
    virtual ~DbInterface();
 
    /**
     * @param[in] value State to be stored in the DB.
     */
    void SetControlState(const std::string& value);
 
    /**
     * Set the application configuration information in the DB.
     *
     * @param[in] reqEndpoint Request msg endpoint.
     * @param[in] dbIpAddr DB IP address.
     * @param[in] dbPort DB port.
     * @param[in] dbTimeout DB timeout.
     */
    void SetConfig(Config& cfg);
 
    /**
     * @param[in] key Key to be written in the DB.
     * @param[in] value Value, associated to the given key, to be written in the DB.
     */
    void Set(const std::string& key, const std::string& value);
 
    DbInterface(const DbInterface&) = delete;       //! Disable copy constructor
    DbInterface& operator=(const DbInterface&) = delete;  //! Disable assignment operator
 
 private:
    std::string m_prefix;
    rad::OldbAsyncWriter& m_runtime_db;
};
 
}  // namespace server
 
#endif  // SERVER_DB_INTERFACE_HPP_