1 files changed, 78 insertions, 0 deletions
diff --git a/datafile-app-server/src/test/java/org/onap/dcaegen2/collectors/datafile/configuration/CloudConfigParserTest.java b/datafile-app-server/src/test/java/org/onap/dcaegen2/collectors/datafile/configuration/CloudConfigParserTest.java
new file mode 100644
index 00000000..e7ef7d79
--- /dev/null
+++ b/datafile-app-server/src/test/java/org/onap/dcaegen2/collectors/datafile/configuration/CloudConfigParserTest.java
@@ -0,0 +1,78 @@
+/*-
+ * ============LICENSE_START======================================================================
+ * Copyright (C) 2022 Nokia. All rights reserved.
+ * ===============================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except
+ * in compliance with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software distributed under the License
+ * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
+ * or implied. See the License for the specific language governing permissions and limitations under
+ * the License.
+ * ============LICENSE_END========================================================================
+ */
+
+package org.onap.dcaegen2.collectors.datafile.configuration;
+
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertThrows;
+import static org.junit.jupiter.api.Assertions.assertTrue;
+
+import com.google.gson.JsonObject;
+import com.google.gson.JsonParser;
+import java.io.IOException;
+import java.nio.file.Files;
+import java.nio.file.Path;
+import org.junit.jupiter.api.Test;
+import org.onap.dcaegen2.collectors.datafile.exceptions.DatafileTaskException;
+
+class CloudConfigParserTest {
+
+    public static final String CONFIG_TLS_JSON = "src/test/resources/datafile_test_config_tls.json";
+    public static final String CONFIG_NO_TLS_JSON = "src/test/resources/datafile_test_config_no_tls.json";
+    public static final String INCORRECT_CERT_CONFIG_JSON = "src/test/resources/datafile_test_config_incorrect_cert_config.json";
+    public static final String EXPECTED_EXCEPTION_MESSAGE = "Wrong configuration. External certificate enabled but configs are missing: Could not find member: dmaap.certificateConfig.keyCert";
+
+    @Test
+    public void shouldCorrectReadCertificateConfigWithTLS () throws IOException, DatafileTaskException {
+
+        CloudConfigParser parser = getCloudConfigParser(CONFIG_TLS_JSON);
+        CertificateConfig certificateConfig = parser.getCertificateConfig();
+
+        assertEquals(true, certificateConfig.enableCertAuth());
+        assertEquals("/src/test/resources/dfc.jks", certificateConfig.keyCert());
+        assertEquals("/src/test/resources/dfc.jks.pass", certificateConfig.keyPasswordPath());
+        assertEquals("/src/test/resources/cert.jks", certificateConfig.trustedCa());
+        assertEquals("/src/test/resources/cert.jks.pass", certificateConfig.trustedCaPasswordPath());
+        assertEquals(true, certificateConfig.httpsHostnameVerify());
+    }
+
+    @Test
+    public void shouldCorrectReadCertificateConfigWithoutTLS () throws IOException, DatafileTaskException {
+        CloudConfigParser parser = getCloudConfigParser(CONFIG_NO_TLS_JSON);
+        CertificateConfig certificateConfig = parser.getCertificateConfig();
+
+        assertEquals(false, certificateConfig.enableCertAuth());
+        assertEquals("", certificateConfig.keyCert());
+        assertEquals("", certificateConfig.keyPasswordPath());
+        assertEquals("", certificateConfig.trustedCa());
+        assertEquals("", certificateConfig.trustedCaPasswordPath());
+    }
+
+    @Test
+    public void shouldThrowExceptionWhenCertAuthIsEnabledButPathsPropertyIsMissing () throws IOException {
+        CloudConfigParser parser = getCloudConfigParser(INCORRECT_CERT_CONFIG_JSON);
+
+        DatafileTaskException exception = assertThrows(DatafileTaskException.class, parser::getCertificateConfig);
+        assertTrue(exception.getMessage().contains(EXPECTED_EXCEPTION_MESSAGE));
+    }
+
+    private CloudConfigParser getCloudConfigParser(String configPath) throws IOException {
+        String jsonStr = Files.readString(Path.of(configPath));
+        JsonObject jsonObject = JsonParser.parseString(jsonStr).getAsJsonObject();
+
+        return new CloudConfigParser(jsonObject,null);
+    }
+}