Added unescape_java_properties.

Author: razvan

rust/operator-binary/src/druid_controller.rs

@@ -489,18 +489,7 @@ fn build_rolegroup_config_map(
                 //                        transformed_config.iter(),
                 //                    )
                 //                    .context(PropertiesWriteSnafu)?;
-                let runtime_properties: String = transformed_config
-                    .iter()
-                    .map(|kv| {
-                        format!(
-                            "{}={}",
-                            kv.0,
-                            kv.1.clone().unwrap_or_else(|| "".to_string())
-                        )
-                    })
-                    .reduce(|content, line| format!("{content}\n{line}"))
-                    .unwrap_or_else(|| "".to_string());
-
+                let runtime_properties = unescape_java_properties(&transformed_config);
                 cm_conf_data.insert(RUNTIME_PROPS.to_string(), runtime_properties);
             }
             PropertyNameKind::File(file_name) if file_name == JVM_CONFIG => {
@@ -555,6 +544,20 @@ fn build_rolegroup_config_map(
         })
 }
 
+fn unescape_java_properties(props: &BTreeMap<String, Option<String>>) -> String {
+    props
+    .iter()
+    .map(|kv| {
+        format!(
+            "{}={}",
+            kv.0,
+            kv.1.clone().unwrap_or_else(|| "".to_string())
+        )
+    })
+    .reduce(|content, line| format!("{content}\n{line}"))
+    .unwrap_or_else(|| "".to_string())
+}
+
 /// The rolegroup [`Service`] is a headless service that allows direct access to the instances of a certain rolegroup
 ///
 /// This is mostly useful for internal communication between peers, or for clients that perform client-side load balancing.
@@ -940,4 +943,18 @@ mod test {
 
         Ok(())
     }
+
+
+    #[test]
+    fn test_unescape_java_properties() {
+        let expected = r#"druid.auth.authenticator.ldap.credentialsValidator.baseDn=ou=users,dc=example,dc=org
+druid.auth.authenticator.ldap.credentialsValidator.bindPassword=admin"#;
+
+        let props: BTreeMap<String, Option<String>> = vec![
+            ("druid.auth.authenticator.ldap.credentialsValidator.bindPassword".to_string(), Some("admin".to_string())),
+            ("druid.auth.authenticator.ldap.credentialsValidator.baseDn".to_string(), Some("ou=users,dc=example,dc=org".to_string())),
+        ].into_iter().collect();
+
+        assert_eq!(expected.to_string(), unescape_java_properties(&props));
+    }
 }