rwdacc.cpp

Go to the documentation of this file.

// DUNE DAQ modification notice:
// This file has been modified from the original ATLAS dbe source for the DUNE DAQ project.
// Fork baseline commit: dbe-02-12-17 (2022-05-12).
// Renamed since fork: no.
 
/************************************************************
 * rwdacc.cpp
 *
 *  Created on: Feb 4, 2016
 *      Author: Leonidas Georgopoulos
 ************************************************************/
#include "dbe/Conversion.hpp"
#include "dbe/Exceptions.hpp"
#include "dbe/config_api_set.hpp"
#include "dbe/config_direct_access.hpp"
#include "dbe/confobject_desc.hpp"
#include "dbe/dbaccessor.hpp"
#include "dbe/messenger.hpp"
 
#include "conffwk/ConfigObject.hpp"
#include "conffwk/Configuration.hpp"
#include "conffwk/Errors.hpp"
#include "conffwk/Schema.hpp"
#include "ers/LocalContext.hpp"
#include "logging/Logging.hpp"
 
#include <QString>
#include <QStringList>
 
#include <functional>
#include <map>
#include <stdexcept>
#include <string>
#include <vector>
 
using namespace dunedaq::conffwk;
 
namespace dbe {
 
namespace config {
 
namespace api {
//------------------------------------------------------------------------------------------
ConfigObject
rwdacc::create_object(std::string const& fn, std::string const& cn, std::string const& uid)
{
  if (info::onclass::definition(cn, false).p_abstract) {
    ERROR("Create Object: Was not possible to create object ",
          "Abstract classes cannot hold objects",
          uid,
          "for abstract class",
          cn);
 
    throw daq::dbe::ObjectChangeWasNotSuccessful(ERS_HERE);
  }
 
  // An empty object, if its creation does not succeed this object will be returned
  ConfigObject newobj;
 
  try {
    dbaccessor::dbptr()->create(fn, cn, uid, newobj);
  } catch (dunedaq::conffwk::Exception const& ex) {
    FAIL("Object creation failed", dbe::config::errors::parse(ex), "\n\nObject UID:", uid);
 
    throw daq::dbe::ObjectChangeWasNotSuccessful(ERS_HERE);
  }
 
  return newobj;
}
//------------------------------------------------------------------------------------------
 
//------------------------------------------------------------------------------------------
template<typename RESTYPE, typename KEYTYPE = std::string>
using mapreader = std::function<RESTYPE(KEYTYPE const&)>;
//------------------------------------------------------------------------------------------
 
//------------------------------------------------------------------------------------------
tref
rwdacc::set_object(tref newobj,
                   dbe::t_config_object_preimage::type_attrmap const& attributes,
                   dbe::t_config_object_preimage::type_relmap const& relations)
{
  auto relreader = [&relations](std::string const& name) { return relations.at(name); };
 
  auto attreader = [&attributes](std::string const& name) { return attributes.at(name); };
 
  if (not newobj.is_null()) {
    dunedaq::conffwk::class_t ClassInfo = dbe::config::api::info::onclass::definition(newobj.class_name(), false);
    std::vector<dunedaq::conffwk::attribute_t> AttList = ClassInfo.p_attributes;
    std::vector<dunedaq::conffwk::relationship_t> RelList = ClassInfo.p_relationships;
 
    for (dunedaq::conffwk::attribute_t const& att : AttList) {
      try {
        if (att.p_is_multi_value) {
          switch (att.p_type) {
            case dunedaq::conffwk::bool_type: {
              auto data = dbe::convert::to<std::vector<bool>>(dbe::convert::to<QStringList>(attreader(att.p_name)),
                                                              att.p_int_format);
              set::noactions::attribute(newobj, att, data, true);
            } break;
            case dunedaq::conffwk::enum_type: {
              auto data =
                dbe::convert::to<std::vector<std::string>>(dbe::convert::to<QStringList>(attreader(att.p_name)));
              set::noactions::anenum(newobj, att, data, true);
            } break;
            case dunedaq::conffwk::date_type: {
              auto data =
                dbe::convert::to<std::vector<std::string>>(dbe::convert::to<QStringList>(attreader(att.p_name)));
              set::noactions::adate(newobj, att, data, true);
            } break;
            case dunedaq::conffwk::time_type: {
              auto data =
                dbe::convert::to<std::vector<std::string>>(dbe::convert::to<QStringList>(attreader(att.p_name)));
              set::noactions::atime(newobj, att, data, true);
            } break;
            case dunedaq::conffwk::string_type: {
              auto data =
                dbe::convert::to<std::vector<std::string>>(dbe::convert::to<QStringList>(attreader(att.p_name)));
              set::noactions::attribute(newobj, att, data, true);
            } break;
            case dunedaq::conffwk::class_type: {
              auto data =
                dbe::convert::to<std::vector<std::string>>(dbe::convert::to<QStringList>(attreader(att.p_name)));
              set::noactions::aclass(newobj, att, data, true);
            } break;
            case dunedaq::conffwk::float_type: {
              auto data = dbe::convert::to<std::vector<float>>(dbe::convert::to<QStringList>(attreader(att.p_name)),
                                                               att.p_int_format);
              set::noactions::attribute(newobj, att, data, true);
            } break;
            case dunedaq::conffwk::double_type: {
              auto data = dbe::convert::to<std::vector<double>>(dbe::convert::to<QStringList>(attreader(att.p_name)),
                                                                att.p_int_format);
              set::noactions::attribute(newobj, att, data, true);
            } break;
            case dunedaq::conffwk::s8_type: {
              auto data = dbe::convert::to<std::vector<int8_t>>(dbe::convert::to<QStringList>(attreader(att.p_name)),
                                                                att.p_int_format);
              set::noactions::attribute(newobj, att, data, true);
            } break;
            case dunedaq::conffwk::s16_type: {
              auto data = dbe::convert::to<std::vector<int16_t>>(dbe::convert::to<QStringList>(attreader(att.p_name)),
                                                                 att.p_int_format);
              set::noactions::attribute(newobj, att, data, true);
            } break;
            case dunedaq::conffwk::s32_type: {
              auto data = dbe::convert::to<std::vector<int32_t>>(dbe::convert::to<QStringList>(attreader(att.p_name)),
                                                                 att.p_int_format);
              set::noactions::attribute(newobj, att, data, true);
            } break;
            case dunedaq::conffwk::s64_type: {
              auto data = dbe::convert::to<std::vector<int64_t>>(dbe::convert::to<QStringList>(attreader(att.p_name)),
                                                                 att.p_int_format);
              set::noactions::attribute(newobj, att, data, true);
            } break;
            case dunedaq::conffwk::u8_type: {
              auto data = dbe::convert::to<std::vector<u_int8_t>>(dbe::convert::to<QStringList>(attreader(att.p_name)),
                                                                  att.p_int_format);
              set::noactions::attribute(newobj, att, data, true);
            } break;
            case dunedaq::conffwk::u16_type: {
              auto data = dbe::convert::to<std::vector<u_int16_t>>(dbe::convert::to<QStringList>(attreader(att.p_name)),
                                                                   att.p_int_format);
              set::noactions::attribute(newobj, att, data, true);
            } break;
            case dunedaq::conffwk::u32_type: {
              auto data = dbe::convert::to<std::vector<u_int32_t>>(dbe::convert::to<QStringList>(attreader(att.p_name)),
                                                                   att.p_int_format);
              set::noactions::attribute(newobj, att, data, true);
            } break;
            case dunedaq::conffwk::u64_type: {
              auto data = dbe::convert::to<std::vector<u_int64_t>>(dbe::convert::to<QStringList>(attreader(att.p_name)),
                                                                   att.p_int_format);
              set::noactions::attribute(newobj, att, data, true);
            } break;
            default:
              break;
          }
        } else {
          switch (att.p_type) {
            case dunedaq::conffwk::bool_type: {
              auto data =
                dbe::convert::to<bool>(dbe::convert::to<QStringList>(attreader(att.p_name)), att.p_int_format);
              set::noactions::attribute(newobj, att, data, true);
            } break;
            case dunedaq::conffwk::enum_type: {
              auto data = dbe::convert::to<std::string>(dbe::convert::to<QStringList>(attreader(att.p_name)));
              set::noactions::anenum(newobj, att, data, true);
            } break;
            case dunedaq::conffwk::date_type: {
              auto data = dbe::convert::to<std::string>(dbe::convert::to<QStringList>(attreader(att.p_name)));
              set::noactions::adate(newobj, att, data, true);
            } break;
            case dunedaq::conffwk::time_type: {
              auto data = dbe::convert::to<std::string>(dbe::convert::to<QStringList>(attreader(att.p_name)));
              set::noactions::atime(newobj, att, data, true);
            } break;
            case dunedaq::conffwk::string_type: {
              auto data = dbe::convert::to<std::string>(dbe::convert::to<QStringList>(attreader(att.p_name)));
              set::noactions::attribute(newobj, att, data, true);
            } break;
            case dunedaq::conffwk::class_type: {
              auto data = dbe::convert::to<std::string>(dbe::convert::to<QStringList>(attreader(att.p_name)));
              set::noactions::aclass(newobj, att, data, true);
            } break;
            case dunedaq::conffwk::float_type: {
              auto data =
                dbe::convert::to<float>(dbe::convert::to<QStringList>(attreader(att.p_name)), att.p_int_format);
              set::noactions::attribute(newobj, att, data, true);
            } break;
            case dunedaq::conffwk::double_type: {
              auto data =
                dbe::convert::to<double>(dbe::convert::to<QStringList>(attreader(att.p_name)), att.p_int_format);
              set::noactions::attribute(newobj, att, data, true);
            } break;
            case dunedaq::conffwk::s8_type: {
              auto data =
                dbe::convert::to<int8_t>(dbe::convert::to<QStringList>(attreader(att.p_name)), att.p_int_format);
              set::noactions::attribute(newobj, att, data, true);
            } break;
            case dunedaq::conffwk::s16_type: {
              auto data =
                dbe::convert::to<int16_t>(dbe::convert::to<QStringList>(attreader(att.p_name)), att.p_int_format);
              set::noactions::attribute(newobj, att, data, true);
            } break;
            case dunedaq::conffwk::s32_type: {
              auto data =
                dbe::convert::to<int32_t>(dbe::convert::to<QStringList>(attreader(att.p_name)), att.p_int_format);
              set::noactions::attribute(newobj, att, data, true);
            } break;
            case dunedaq::conffwk::s64_type: {
              auto data =
                dbe::convert::to<int64_t>(dbe::convert::to<QStringList>(attreader(att.p_name)), att.p_int_format);
              set::noactions::attribute(newobj, att, data, true);
            } break;
            case dunedaq::conffwk::u8_type: {
              auto data =
                dbe::convert::to<u_int8_t>(dbe::convert::to<QStringList>(attreader(att.p_name)), att.p_int_format);
              set::noactions::attribute(newobj, att, data, true);
            } break;
            case dunedaq::conffwk::u16_type: {
              auto data =
                dbe::convert::to<u_int16_t>(dbe::convert::to<QStringList>(attreader(att.p_name)), att.p_int_format);
              set::noactions::attribute(newobj, att, data, true);
            } break;
            case dunedaq::conffwk::u32_type: {
              auto data =
                dbe::convert::to<u_int32_t>(dbe::convert::to<QStringList>(attreader(att.p_name)), att.p_int_format);
              set::noactions::attribute(newobj, att, data, true);
            } break;
            case dunedaq::conffwk::u64_type: {
              auto data =
                dbe::convert::to<u_int64_t>(dbe::convert::to<QStringList>(attreader(att.p_name)), att.p_int_format);
              set::noactions::attribute(newobj, att, data, true);
            } break;
            default:
              break;
          }
        }
      } catch (std::out_of_range const& e) {
        // nothing to do just ignore this , it might be the case that the attribute was not defined
      }
    }
 
    for (dunedaq::conffwk::relationship_t const& rel : RelList) {
      try {
        auto data = relreader(rel.p_name);
        set::noactions::relation(newobj, rel, data);
      } catch (std::out_of_range const& e) {
        // nothing to do just ignore this , it might be the case that the relation was not defined
      }
    }
  }
 
  return newobj;
}
//------------------------------------------------------------------------------------------
 
//------------------------------------------------------------------------------------------
void
rwdacc::destroy_object(ConfigObject& todelete)
{
  try {
    dbaccessor::dbptr()->destroy_obj(todelete);
  } catch (dunedaq::conffwk::Exception const& ex) {
    WARN("Object deletion did not succeed for object", errors::parse(ex).c_str(), todelete.UID().c_str());
 
    throw daq::dbe::ObjectChangeWasNotSuccessful(ERS_HERE);
  }
}
//------------------------------------------------------------------------------------------
 
//------------------------------------------------------------------------------------------
ConfigObject
rwdacc::get_object(std::string const& classname, std::string const& objectname)
{
  if (dbaccessor::is_loaded()) {
    try {
      ConfigObject object;
      dbaccessor::dbptr()->get(classname, objectname, object);
      return object;
    } catch (dunedaq::conffwk::NotFound const& e) {
      TLOG_DEBUG(3) << "Object not found";
    } catch (dunedaq::conffwk::Generic const& e) {
      ERROR("Generic exception caught", dbe::config::errors::parse(e).c_str());
      TLOG_DEBUG(3) << "Generic Exception Caught";
    } catch (...) {
      ERROR("Unknown exception caught", "");
      TLOG_DEBUG(3) << "Unknown exception caught!";
    }
  }
  return {};
}
//------------------------------------------------------------------------------------------
 
//------------------------------------------------------------------------------------------
std::vector<ConfigObject>
rwdacc::query_class(std::string const& classname, std::string const& query)
{
  std::vector<ConfigObject> objects;
  if (dbaccessor::is_loaded()) {
    try {
      dbaccessor::dbptr()->get(classname, objects, query);
    } catch (dunedaq::conffwk::NotFound const& e) {
      TLOG_DEBUG(3) << "Object not found";
    } catch (dunedaq::conffwk::Generic const& e) {
      ERROR("Generic exception caught", dbe::config::errors::parse(e).c_str());
      TLOG_DEBUG(3) << "Generic Exception Caught";
    } catch (...) {
      ERROR("Unknown exception caught", "");
      TLOG_DEBUG(3) << "Unknown exception caught!";
    }
  }
  return objects;
}
//------------------------------------------------------------------------------------------
 
//------------------------------------------------------------------------------------------
void
rwdacc::rename_object(ConfigObject& object, std::string const& newname)
{
  object.rename(newname);
}
//------------------------------------------------------------------------------------------
 
} // namespace api
 
} // namespace config
 
} // namespace dbe