dbInterface.hpp

Go to the documentation of this file.

#ifndef DEVMGR_COMMON_DB_INTERFACE_HPP_
#define DEVMGR_COMMON_DB_INTERFACE_HPP_

// System headers
#include <string>
#include <mutex>

// Local headers
#include <rad/DbAdapter.hpp>


namespace devmgr {
namespace common {

    const std::string KEY_CONTROL_STATE         = "state";
    const std::string KEY_CONTROL_SUBSTATE      = "substate";
    const std::string KEY_CONTROL_STATUS        = "status";

    const std::string KEY_CONTROL_STATE_STR     = "state_str";
    const std::string KEY_CONTROL_SUBSTATE_STR  = "substate_str";

    const std::string KEY_CONFIG_REQ_ENDPOINT   = "req_endpoint";
    const std::string KEY_CONFIG_PUB_ENDPOINT   = "pub_endpoint";
    const std::string KEY_CONFIG_SUB_ENDPOINT   = "sub_endpoint";
    const std::string KEY_CONFIG_EXT_PUB_ENDPOINT = "ext_pub_endpoint";
    const std::string KEY_CONFIG_EXT_SUB_ENDPOINT = "ext_sub_endpoint";
    const std::string KEY_CONFIG_DB_ENDPOINT    = "db_endpoint";
    const std::string KEY_CONFIG_DB_TIMEOUT     = "db_timeout";
    const std::string KEY_CONFIG_SM_SCXML       = "scxml";
    const std::string KEY_CONFIG_FILENAME       = "filename";
    const std::string KEY_CONFIG_LOG_LEVEL      = "loglevel";

    const std::string KEY_CONFIG_SERVER_ID      = "server_id";
    const std::string KEY_CONFIG_SERVER         = "server";
    const std::string KEY_CONFIG_DEVICES        = "devices";
    const std::string KEY_CONFIG_DEVFILE        = "cfgfile";
    const std::string KEY_CONFIG_CMDTOUT        = "cmdtout";
    const std::string KEY_CONFIG_TYPE           = "type";
    const std::string KEY_CONFIG_DICTIONARIES   = "dictionaries";
    const std::string KEY_CONFIG_PREFIX         = "fits_prefix";


class DbInterface {
    public:
      DbInterface(const std::string& prefix, rad::DbAdapter& runtime_db);

      virtual ~DbInterface();

      std::string GetControlState();

      std::string GetControlSubstate();

      std::string GetControlStatus();

      std::string Get(const std::string& key);

      void SetControlState(const std::string& value);

      void SetControlSubstate(const std::string& value);

      void SetControlStatus(const std::string& value);

      void SetControl(const std::string& state,
                      const std::string& substate);

      void SetControl(const short state,
                      const short substate);

      void SetConfig(const std::string& req_endpoint,
                     const std::string& db_endpoint,
                     const timeval& db_timeout,
                     const std::string& scxml_filename,
                     const std::string& config_filename,
                     const std::string& log_level);

      void Set(const std::string& key, const std::string& value);

      void MultiSet(std::vector<std::string>& kvs);

      DbInterface(const DbInterface&) = delete;       
      DbInterface& operator=(const DbInterface&) = delete;  

    private:
      std::string               m_prefix;     
      rad::DbAdapter&           m_runtime_db; 
      std::timed_mutex          m_mutex;      
    };

  } // namespace common
}  // namespace devmgr

#endif  // DEVMGR_COMMON_DB_INTERFACE_HPP_