Utilize fog default dds profiles

Dockerfile

@@ -33,4 +33,4 @@ RUN ln -s /usr/local/lib/libmicroxrcedds_agent.so.2.2.0 /usr/local/lib/libmicrox
 ENV PATH="/usr/local/bin:$PATH" \
     LD_LIBRARY_PATH="/usr/local/lib:$LD_LIBRARY_PATH"
 
-COPY entrypoint.sh parse_agent_refs.py agent.refs.mustache agent.refs /
+COPY entrypoint.sh parse_agent_refs.py combine_default_profiles.py dds_security_part_mustache.xml agent.refs /

agent.refs

@@ -1,8 +1,8 @@
 <profiles>
-    <participant profile_name="default_xrce_participant">
+    <participant profile_name="participant_profile_fog_sw">
         <domainId>0</domainId>
         <rtps>
-            <name>default_xrce_participant</name>
+            <name>participant_profile_fog_sw</name>
         </rtps>
     </participant>
 </profiles>

combine_default_profiles.py

@@ -0,0 +1,59 @@
+#!/usr/bin/python3
+
+import sys, os
+import shutil
+
+agent_refs_path=""
+if len(sys.argv) > 1:
+  agent_refs_path=sys.argv[1]
+
+dds_security_part_file = os.path.join(agent_refs_path, "dds_security_part.xml")
+default_profiles_file = os.path.join(agent_refs_path, "default_profiles.xml")
+agent_refs_tmp_file = os.path.join(agent_refs_path, "agent.refs.tmp")
+agent_refs_file = os.path.join(agent_refs_path, "agent.refs")
+
+def cleanup_temporary_files():
+  # cleanup
+  if os.path.exists(agent_refs_tmp_file):
+    os.remove(agent_refs_tmp_file)
+  if os.path.exists(default_profiles_file):
+    os.remove(default_profiles_file)
+  if os.path.exists(dds_security_part_file):
+    os.remove(dds_security_part_file)
+
+
+if not os.path.exists(dds_security_part_file):
+  print("No ROS2 security additions found for default profiles")
+  cleanup_temporary_files()
+  sys.exit(0)
+
+sec_part_data = ""
+with open(dds_security_part_file, "r") as f:
+  sec_part_data = f.read()
+
+### Combine security part to original profiles data
+keep_config = True
+with open(default_profiles_file, "r") as in_f:
+  with open(agent_refs_tmp_file, "w") as out_f:
+    for line in in_f.readlines():
+      line_str = line.strip()
+      # Remove data_reader and data_writer configs
+      #  as they conflicts with xrce client side configs
+      if line_str.startswith("<data_writer") or line_str.startswith("<data_reader"):
+        keep_config = False
+
+      if keep_config:
+        out_f.write(line)
+        if line_str.startswith("<rtps>"):
+          out_f.write(sec_part_data)
+
+      if line_str.startswith("</data_writer") or line_str.startswith("</data_reader"):
+        keep_config = True
+
+# Replace original agent.refs with generated one
+if os.path.exists(agent_refs_tmp_file):
+  if os.path.exists(agent_refs_file):
+    os.remove(agent_refs_file)
+  shutil.copyfile(agent_refs_tmp_file, agent_refs_file)
+
+cleanup_temporary_files()

agent.refs.mustache → dds_security_part_mustache.xml

@@ -1,8 +1,3 @@
-<profiles>
-    <participant profile_name="default_xrce_participant">
-        <domainId>0</domainId>
-        <rtps>
-            <name>default_xrce_participant</name>
             <propertiesPolicy>
                 <properties>
                     <!-- Activate DDS:Auth:PKI-DH plugin -->
@@ -58,6 +53,3 @@
                     </property>
                 </properties>
             </propertiesPolicy>
-        </rtps>
-    </participant>
-</profiles>

entrypoint.sh

@@ -1,8 +1,16 @@
 #!/bin/bash -e
 
-unset FASTRTPS_DEFAULT_PROFILES_FILE
+
+if [ "$FASTRTPS_DEFAULT_PROFILES_FILE" != "" ]; then
+        cp $FASTRTPS_DEFAULT_PROFILES_FILE /default_profiles.xml
+else
+        cp agent.refs default_profiles.xml
+fi
 
 /parse_agent_refs.py
+/combine_default_profiles.py
+
+unset FASTRTPS_DEFAULT_PROFILES_FILE
 
 _term() {
         # FILL UP PROCESS SEARCH PATTERN HERE TO FIND PROPER PROCESS FOR SIGINT:

parse_agent_refs.py

@@ -36,14 +36,14 @@
 with open(key_path, "r") as f:
   key = f.read().rstrip()
 
-agent_refs_must_file = os.path.join(agent_refs_path, "agent.refs.mustache")
+agent_refs_must_file = os.path.join(agent_refs_path, "dds_security_part_mustache.xml")
 with open(agent_refs_must_file, "r") as f:
   tmpl = f.read()
 
 agent_refs_data = pystache.render(tmpl, {'enclave_path': enclave_path, 'key_p11': key })
 
 # Remove original agent.refs
-agent_refs_file = os.path.join(agent_refs_path, "agent.refs")
+agent_refs_file = os.path.join(agent_refs_path, "dds_security_part.xml")
 if os.path.exists(agent_refs_file):
   os.remove(agent_refs_file)