Add security logging base class

include/fastdds/rtps/security/logging/Logging.h

@@ -18,9 +18,12 @@
 #ifndef _FASTDDS_RTPS_SECURITY_LOGGING_LOGGING_H_
 #define _FASTDDS_RTPS_SECURITY_LOGGING_LOGGING_H_
 
+#include <limits>
+
 #include "fastdds/rtps/security/logging/LogOptions.h"
 #include "fastdds/rtps/security/logging/BuiltinLoggingType.h"
 #include "fastdds/rtps/security/exceptions/SecurityException.h"
+#include "fastdds/rtps/common/Guid.h"
 
 namespace eprosima {
 namespace fastrtps {
@@ -105,6 +108,10 @@ class Logging
    */
   LoggerListener const* get_listener() const { return listener_; }
 
+  bool set_guid(const GUID_t& guid, SecurityException& exception);
+
+  bool set_domaine_id(const uint32_t id, SecurityException& exception);
+
 protected:
 
   /**
@@ -137,6 +144,10 @@ class Logging
   bool options_set_ = false;
 
   LogOptions log_options_;
+  GUID_t guid_;
+  std::string guid_str_;
+  uint32_t domain_id_ = std::numeric_limits<uint32_t>::max();
+  std::string domain_id_str_;
 
   // DomainParticipant::create_publisher(...)
   Publisher* publisher_;

src/cpp/rtps/security/SecurityManager.cpp

@@ -125,6 +125,8 @@ bool SecurityManager::init(
 
     SecurityException exception;
 
+    domain_id_ = participant_->getRTPSParticipantAttributes().builtin.domainId;
+
     const PropertyPolicy log_properties = PropertyPolicyHelper::get_properties_with_prefix(
           participant_->getRTPSParticipantAttributes().properties,
           "dds.sec.log.builtin.DDS_LogTopic.");
@@ -184,6 +186,12 @@ bool SecurityManager::init(
           logInfo(SECURITY, "Logging to file is not yet implemented.");
         }
 
+        if (!(logging_plugin_->set_guid(participant_->getGuid(), exception) &&
+              logging_plugin_->set_domaine_id(domain_id_, exception)))
+        {
+          return init_logging_fail();
+        }
+
         if (!( logging_plugin_->set_log_options(log_options, exception) &&
                logging_plugin_->enable_logging(exception) ))
         {
@@ -199,8 +207,6 @@ bool SecurityManager::init(
       }
     }
 
-    domain_id_ = participant_->getRTPSParticipantAttributes().builtin.domainId;
-
     authentication_plugin_ = factory_.create_authentication_plugin(participant_properties);
 
     if (authentication_plugin_ != nullptr)

src/cpp/rtps/security/logging/Logging.cpp

@@ -117,8 +117,8 @@ bool Logging::convert(const EventLogLevel event_log_level,
 
   builtin_msg.structured_data.emplace(
         "DDS",
-        NameValuePairSeq{NameValuePair{"guid", ""},
-                         NameValuePair{"domain_id", ""},
+        NameValuePairSeq{NameValuePair{"guid", guid_str_},
+                         NameValuePair{"domain_id", domain_id_str_},
                          NameValuePair{"plugin_class", plugin_class},
                          NameValuePair{"plugin_method", plugin_method}}
   );
@@ -133,6 +133,48 @@ void Logging::log_impl(const BuiltinLoggingType& /*message*/,
   exception = SecurityException("Logging not implemented.");
 }
 
+bool Logging::set_guid(const GUID_t& guid, SecurityException& exception)
+{
+  if (GUID_t::unknown() == guid)
+  {
+    exception = SecurityException("Invalid guid value.");
+    return false;
+  }
+  else if (GUID_t::unknown() != guid_)
+  {
+    exception = SecurityException("Guid already set.");
+    return false;
+  }
+
+  guid_ = guid;
+
+  std::stringstream ss;
+  ss << guid_;
+
+  guid_str_ = ss.str();
+
+  return true;
+}
+
+bool Logging::set_domaine_id(const uint32_t id, SecurityException& exception)
+{
+  if (std::numeric_limits<uint32_t>::max() == id)
+  {
+    exception = SecurityException("Invalid domaine id value.");
+    return false;
+  }
+  else if (std::numeric_limits<uint32_t>::max() == domain_id_)
+  {
+    exception = SecurityException("Domaine id already set (" + std::to_string(domain_id_) + ")");
+    return false;
+  }
+
+  domain_id_ = id;
+  domain_id_str_ = std::to_string(domain_id_);
+
+  return true;
+}
+
 } //namespace security
 } //namespace rtps
 } //namespace fastrtps