Refs #21711: RTPSParticipant get_subscription/publication_info() implementation

Signed-off-by: Mario Dominguez <mariodominguez@eprosima.com>

Author: Mario-DL

src/cpp/rtps/participant/RTPSParticipant.cpp

@@ -202,17 +202,17 @@ std::vector<fastdds::rtps::TransportNetmaskFilterInfo> RTPSParticipant::get_netm
 }
 
 bool RTPSParticipant::get_publication_info(
-        fastdds::dds::builtin::PublicationBuiltinTopicData&,
-        const GUID_t&) const
+        fastdds::dds::builtin::PublicationBuiltinTopicData& data,
+        const GUID_t& writer_guid) const
 {
-    return false;
+    return mp_impl->get_publication_info(data, writer_guid);
 }
 
 bool RTPSParticipant::get_subscription_info(
-        fastdds::dds::builtin::SubscriptionBuiltinTopicData&,
-        const GUID_t&) const
+        fastdds::dds::builtin::SubscriptionBuiltinTopicData& data,
+        const GUID_t& reader_guid) const
 {
-    return false;
+    return mp_impl->get_subscription_info(data, reader_guid);
 }
 
 #if HAVE_SECURITY

src/cpp/rtps/participant/RTPSParticipantImpl.cpp

@@ -58,6 +58,7 @@
 #include <fastrtps/utils/Semaphore.h>
 #include <fastrtps/xmlparser/XMLProfileManager.h>
 
+#include <rtps/builtin/data/ProxyDataConverters.hpp>
 #include <rtps/builtin/discovery/participant/PDPClient.h>
 #include <rtps/builtin/discovery/participant/PDPServer.hpp>
 #include <rtps/history/BasicPayloadPool.hpp>
@@ -2939,6 +2940,40 @@ std::vector<fastdds::rtps::TransportNetmaskFilterInfo> RTPSParticipantImpl::get_
     return m_network_Factory.netmask_filter_info();
 }
 
+bool RTPSParticipantImpl::get_publication_info(
+        fastdds::dds::builtin::PublicationBuiltinTopicData& data,
+        const GUID_t& writer_guid) const
+{
+    bool ret = false;
+    WriterProxyData wproxy_data(m_att.allocation.locators.max_unicast_locators,
+            m_att.allocation.locators.max_multicast_locators);
+
+    if (mp_builtinProtocols->mp_PDP->lookupWriterProxyData(writer_guid, wproxy_data))
+    {
+        from_proxy_to_builtin(wproxy_data, data);
+        ret = true;
+    }
+
+    return ret;
+}
+
+bool RTPSParticipantImpl::get_subscription_info(
+        fastdds::dds::builtin::SubscriptionBuiltinTopicData& data,
+        const GUID_t& reader_guid) const
+{
+    bool ret = false;
+    ReaderProxyData rproxy_data(m_att.allocation.locators.max_unicast_locators,
+            m_att.allocation.locators.max_multicast_locators);
+
+    if (mp_builtinProtocols->mp_PDP->lookupReaderProxyData(reader_guid, rproxy_data))
+    {
+        from_proxy_to_builtin(rproxy_data, data);
+        ret = true;
+    }
+
+    return ret;
+}
+
 #ifdef FASTDDS_STATISTICS
 
 bool RTPSParticipantImpl::register_in_writer(

src/cpp/rtps/participant/RTPSParticipantImpl.h

@@ -91,6 +91,8 @@ namespace dds {
 namespace builtin {
 
 class TypeLookupManager;
+struct PublicationBuiltinTopicData;
+struct SubscriptionBuiltinTopicData;
 
 } // namespace builtin
 } // namespace dds
@@ -1128,6 +1130,30 @@ class RTPSParticipantImpl
      */
     std::vector<fastdds::rtps::TransportNetmaskFilterInfo> get_netmask_filter_info() const;
 
+    /**
+     * @brief Fills the provided PublicationBuiltinTopicData with the information of the
+     * writer identified by writer_guid.
+     *
+     * @param[out] data PublicationBuiltinTopicData to fill.
+     * @param[in] writer_guid GUID of the writer to get the information from.
+     * @return True if the writer was found and the data was filled.
+     */
+    bool get_publication_info(
+            fastdds::dds::builtin::PublicationBuiltinTopicData& data,
+            const GUID_t& writer_guid) const;
+
+    /**
+     * @brief Fills the provided SubscriptionBuiltinTopicData with the information of the
+     * reader identified by reader_guid.
+     *
+     * @param[out] data SubscriptionBuiltinTopicData to fill.
+     * @param[in] reader_guid GUID of the reader to get the information from.
+     * @return True if the reader was found and the data was filled.
+     */
+    bool get_subscription_info(
+            fastdds::dds::builtin::SubscriptionBuiltinTopicData& data,
+            const GUID_t& reader_guid) const;
+
     template <EndpointKind_t kind, octet no_key, octet with_key>
     static bool preprocess_endpoint_attributes(
             const EntityId_t& entity_id,