util.hpp

Go to the documentation of this file.

#ifndef _dal_util_H_
#define _dal_util_H_
 
#include <exception>
 
#include "conffwk/Configuration.hpp"
// #include "conffwk/DalObject.hpp"
#include "nlohmann/json.hpp"
#include "logging/Logging.hpp" // NOTE: if ISSUES ARE DECLARED BEFORE include logging/Logging.hpp, TLOG_DEBUG<<issue wont work.
 
#include "confmodel/Application.hpp"
#include "confmodel/PhysicalHost.hpp"
#include "confmodel/Segment.hpp"
#include "confmodel/Service.hpp"
#include "confmodel/Session.hpp"
#include "confmodel/VirtualHost.hpp"
#include "confmodel/confmodelIssues.hpp"
 
namespace dunedaq {
 
namespace confmodel {
 
const dunedaq::confmodel::Session *
get_session(dunedaq::conffwk::Configuration &conf, const std::string &name,
            unsigned long rlevel = 10,
            const std::vector<std::string> *rclasses = nullptr);
 
template <typename T>
void add_json_value(conffwk::ConfigObject &obj, std::string &name,
                    bool multi_value, nlohmann::json &attributes) {
  if (!multi_value) {
    T value;
    obj.get(name, value);
    attributes[name] = value;
  } else {
    std::vector<T> value_vector;
    obj.get(name, value_vector);
    attributes[name] = nlohmann::json(value_vector);
  }
}
 
template <typename T>
const std::vector<std::string> construct_commandline_parameters_appfwk(
    const T *app, const conffwk::Configuration &confdb,
    const dunedaq::confmodel::Session *session) {
 
  const dunedaq::confmodel::Service *control_service = nullptr;
 
  for (auto const *as : app->get_exposes_service()) {
    if (as->UID().ends_with("_control")) {
      if (control_service)
        throw DuplicatedControlService(ERS_HERE, as->UID());
      control_service = as;
    }
  }
 
  if (control_service == nullptr)
    throw NoControlServiceDefined(ERS_HERE, app->UID());
 
  const std::string control_uri = control_service->get_protocol() + "://" +
                                  app->get_runs_on()->get_runs_on()->UID() +
                                  ":" +
                                  std::to_string(control_service->get_port());
 
  const std::string configuration_uri = confdb.get_impl_spec();
 
  return {
      "-s",
      session->UID(),
      "--name",
      app->UID(),
      "-c",
      control_uri,
      "--configurationService",
      configuration_uri,
  };
}
 
} // namespace confmodel
 
} // namespace dunedaq
 
#endif