SignalDistributor.hpp

#pragma once
 
/*
  Copyright 2023, SINTEF Ocean
  This Source Code Form is subject to the terms of the Mozilla Public
  License, v. 2.0. If a copy of the MPL was not distributed with this
  file, You can obtain one at http://mozilla.org/MPL/2.0/.
*/
 
#include <cstdint>
#include <filesystem>
#include <queue>
#include <tuple>
#include <vector>
 
#include <xtypes/idl/idl.hpp>
 
#include "auxiliaries.hpp"
#include "model-descriptor.hpp"
 
namespace ddsfmu {
 
typedef std::tuple<std::uint32_t, std::string, std::string, config::ScalarVariableType> SignalInfo;
 
class SignalDistributor {
public:
 
  enum class Cardinality { INPUT, OUTPUT, PARAMETER };
 
  SignalDistributor(); 
  static config::ScalarVariableType
    resolve_type(const eprosima::xtypes::DynamicData::ReadableNode& node);
 
  void load_idls(const std::filesystem::path& resource_path);
 
  bool has_structure(const std::string& topic_type);
 
  void add(const std::string& topic_name, const std::string& topic_type, Cardinality cardinal);
 
  inline void queue_for_key_parameter(const std::string& topic_name, const std::string& topic_type){
    m_potential_keys.push(std::make_pair(topic_name, topic_type));
  }
 
  void process_key_queue();
 
  inline const std::vector<SignalInfo>& get_mapping() const {
    return m_signal_mapping;
  } 
  inline std::uint32_t outputs() const {
    return m_outputs;
  } 
private:
  std::queue<std::pair<std::string, std::string>> m_potential_keys;
  std::uint32_t m_real_idx, m_integer_idx, m_boolean_idx, m_string_idx, m_outputs;
  std::vector<SignalInfo> m_signal_mapping;
  eprosima::xtypes::idl::Context m_context;
};
 
}