dbInterface.hpp

Go to the documentation of this file.

#ifndef FCF_DEVMGR_COMMON_DB_INTERFACE_HPP_
#define FCF_DEVMGR_COMMON_DB_INTERFACE_HPP_

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

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

namespace fcf {
  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  // FCF_DEVMGR_COMMON_DB_INTERFACE_HPP_