dbInterface.cpp

Go to the documentation of this file.

/**
 * @file
 * @ingroup server
 * @copyright ESO - European Southern Observatory
 * @author
 *
 * @brief DbInterface class source file.
 */
 
#include "dbInterface.hpp"
#include "config.hpp"
#include "logger.hpp"
 
#include <rad/assert.hpp>
#include <rad/exceptions.hpp>
#include <rad/oldbInterface.hpp>  // KEY_MON_STATE
 
namespace server {
 
DbInterface::DbInterface(const std::string& prefix, rad::OldbAsyncWriter& writer)
    : m_prefix(prefix), m_runtime_db(writer) {
    RAD_TRACE(GetLogger());
    if (prefix.empty()) {
        throw std::invalid_argument("OLDB prefix is invalid (empty)");
    }
    if (prefix.back() != '/') {
        m_prefix.push_back('/');
    }
}
 
DbInterface::~DbInterface() {
    RAD_TRACE(GetLogger());
}
 
void DbInterface::SetControlState(const std::string& value) {
    RAD_TRACE(GetLogger());
    m_runtime_db.Set(m_prefix + rad::KEY_MON_STATE, value);
}
 
void DbInterface::SetConfig(Config& cfg) {
    RAD_TRACE(GetLogger());
    cfg.GetMgr().Visit([&](daq::config::Manager::CiiValue const& param) {
        m_runtime_db.Set(m_prefix + param.metadata.canonical_name, param.value);
    });
}
 
void DbInterface::Set(const std::string& key, const std::string& value) {
    RAD_TRACE(GetLogger());
    m_runtime_db.Set(m_prefix + key, value);
}
 
}  // namespace server