summaryrefslogtreecommitdiffstats
path: root/mod/bpgenerator/src/test/java
diff options
context:
space:
mode:
Diffstat (limited to 'mod/bpgenerator/src/test/java')
-rw-r--r--mod/bpgenerator/src/test/java/org/onap/blueprintgenerator/core/BlueprintGeneratorTest.java286
-rw-r--r--mod/bpgenerator/src/test/java/org/onap/blueprintgenerator/core/TlsInfoTest.java163
-rw-r--r--mod/bpgenerator/src/test/java/org/onap/blueprintgenerator/models/blueprint/AppconfigTest.java62
-rw-r--r--mod/bpgenerator/src/test/java/org/onap/blueprintgenerator/models/blueprint/ImportsTest.java52
-rw-r--r--mod/bpgenerator/src/test/java/org/onap/blueprintgenerator/models/blueprint/ResourceConfigTest.java38
-rw-r--r--mod/bpgenerator/src/test/java/org/onap/blueprintgenerator/models/blueprint/tls/ExternalCertificateParametersFactoryTest.java62
-rw-r--r--mod/bpgenerator/src/test/java/org/onap/blueprintgenerator/models/dmaapbp/DmaapBlueprintTest.java245
-rw-r--r--mod/bpgenerator/src/test/java/org/onap/blueprintgenerator/models/dmaapbp/DmaapNodeTest.java224
8 files changed, 0 insertions, 1132 deletions
diff --git a/mod/bpgenerator/src/test/java/org/onap/blueprintgenerator/core/BlueprintGeneratorTest.java b/mod/bpgenerator/src/test/java/org/onap/blueprintgenerator/core/BlueprintGeneratorTest.java
deleted file mode 100644
index b978701..0000000
--- a/mod/bpgenerator/src/test/java/org/onap/blueprintgenerator/core/BlueprintGeneratorTest.java
+++ /dev/null
@@ -1,286 +0,0 @@
-/*============LICENSE_START=======================================================
- org.onap.dcae
- ================================================================================
- Copyright (c) 2019 AT&T Intellectual Property. All rights reserved.
- Copyright (c) 2020 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.blueprintgenerator.core;
-
-import static org.junit.Assert.assertArrayEquals;
-import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.assertFalse;
-import static org.junit.Assert.assertNotNull;
-import static org.mockito.ArgumentMatchers.any;
-import static org.mockito.Mockito.times;
-import static org.mockito.Mockito.verify;
-
-import java.io.PrintStream;
-import java.util.ArrayList;
-import java.util.LinkedHashMap;
-import java.util.TreeMap;
-import org.junit.Test;
-import org.mockito.ArgumentCaptor;
-import org.mockito.Mockito;
-import org.onap.blueprintgenerator.models.blueprint.Blueprint;
-import org.onap.blueprintgenerator.models.blueprint.GetInput;
-import org.onap.blueprintgenerator.models.componentspec.ComponentSpec;
-import org.onap.blueprintgenerator.models.dmaapbp.DmaapNode;
-import org.onap.blueprintgenerator.models.onapbp.OnapNode;
-import org.onap.blueprintgenerator.models.policymodel.PolicyModel;
-import picocli.CommandLine;
-
-// TODO: Auto-generated Javadoc
-
-/**
- * The Class BlueprintGeneratorTest.
- */
-public class BlueprintGeneratorTest {
-
- /**
- * Component spec test.
- *
- */
- @Test
- public void componentSpecTest() {
- ComponentSpec spec = new ComponentSpec();
- TestComponentSpec test = new TestComponentSpec();
- spec.createComponentSpecFromString(test.getComponentSpecAsString());
- ComponentSpec expectedSpec = test.getComponentSpec();
-
- assertEquals(expectedSpec.getSelf(), spec.getSelf());
- assertEquals(expectedSpec.getServices(), spec.getServices());
- assertEquals(expectedSpec.getStreams(), spec.getStreams());
- assertArrayEquals(expectedSpec.getParameters(), spec.getParameters());
- assertEquals(expectedSpec.getAuxilary(), spec.getAuxilary());
- assertArrayEquals(expectedSpec.getArtifacts(), spec.getArtifacts());
- }
-
- /**
- * Tosca definition test.
- */
- @Test
- public void toscaDefinitionTest() {
- ComponentSpec cs = new ComponentSpec();
- TestComponentSpec test = new TestComponentSpec();
- cs.createComponentSpecFromString(test.getComponentSpecAsString());
- Blueprint bp = new Blueprint();
- bp = bp.createBlueprint(cs, "", 'o', "", "");
-
- assertEquals("cloudify_dsl_1_3", bp.getTosca_definitions_version());
- }
-
- /**
- * Imports test.
- */
- @Test
- public void importsTest() {
- ComponentSpec cs = new ComponentSpec();
- TestComponentSpec test = new TestComponentSpec();
- cs.createComponentSpecFromString(test.getComponentSpecAsString());
-
- Blueprint bp = new Blueprint();
- bp = bp.createBlueprint(cs, "", 'o', "", "");
-
- ArrayList<String> imps = new ArrayList<>();
- imps.add("https://www.getcloudify.org/spec/cloudify/4.5.5/types.yaml");
- imps.add("plugin:k8splugin?version=3.4.2");
- imps.add("plugin:dcaepolicyplugin?version=2.4.0");
- assertEquals(imps, bp.getImports());
- }
-
- @Test
- public void inputTest() {
- ComponentSpec cs = new ComponentSpec();
- cs.createComponentSpecFromFile("TestCases/testComponentSpec.json");
-
- Blueprint bp = new Blueprint();
- bp = bp.createBlueprint(cs, "", 'o', "", "");
-
- TreeMap<String, LinkedHashMap<String, Object>> inputs = new TreeMap<>();
-
- //mr inputs
- LinkedHashMap<String, Object> stringType = new LinkedHashMap<>();
- stringType.put("type", "string");
-
- //necessary inputs
- LinkedHashMap<String, Object> tag = new LinkedHashMap<>();
- tag.put("type", "string");
- String tester = "test.tester";
- tag.put("default", '"' + tester + '"');
- inputs.put("tag_version", tag);
-
- inputs.put("log_directory", stringType);
-
- LinkedHashMap<String, Object> cert = new LinkedHashMap<>();
- cert.put("type", "string");
- cert.put("default", "");
- inputs.put("cert_directory", cert);
-
- LinkedHashMap<String, Object> env = new LinkedHashMap<>();
- env.put("default", "{}");
- inputs.put("envs", env);
-
- LinkedHashMap<String, Object> port = new LinkedHashMap<>();
- port.put("type", "string");
- port.put("description", "Kubernetes node port on which collector is exposed");
- port.put("default", "99");
- inputs.put("external_port", port);
-
- LinkedHashMap<String, Object> rep = new LinkedHashMap<>();
- rep.put("type", "integer");
- rep.put("description", "number of instances");
- rep.put("default", 1);
- inputs.put("replicas", rep);
-
- LinkedHashMap<String, Object> aaf = new LinkedHashMap<>();
- aaf.put("type", "boolean");
- aaf.put("default", false);
- inputs.put("use_tls", aaf);
-
- //parmaeter input
- LinkedHashMap<String, Object> test = new LinkedHashMap<>();
- test.put("type", "string");
- String testParam = "test-param-1";
- test.put("default", '"' + testParam + '"');
- inputs.put("testParam1", test);
-
- //mr/dr inputs
- inputs.put("TEST-PUB-DR_feed0_client_role", stringType);
- inputs.put("TEST-PUB-DR_feed0_password", stringType);
- inputs.put("TEST-PUB-DR_feed0_username", stringType);
- inputs.put("TEST-PUB-MR_topic1_aaf_password", stringType);
- inputs.put("TEST-PUB-MR_topic1_aaf_username", stringType);
- inputs.put("TEST-PUB-MR_topic1_client_role", stringType);
- inputs.put("TEST-SUB-DR_feed1_client_role", stringType);
- inputs.put("TEST-SUB-DR_feed1_password", stringType);
- inputs.put("TEST-SUB-DR_feed1_username", stringType);
- inputs.put("TEST-SUB-MR_topic0_client_role", stringType);
- inputs.put("TEST-SUB-MR_topic2_aaf_password", stringType);
- inputs.put("TEST-SUB-MR_topic2_aaf_username", stringType);
- inputs.put("namespace", stringType);
- inputs.put("idn_fqdn", cert);
- inputs.put("feed0_name", stringType);
- inputs.put("feed1_name", stringType);
- inputs.put("topic0_name", stringType);
- inputs.put("topic1_name", stringType);
-
- LinkedHashMap<String, Object> cpu = new LinkedHashMap<>();
- cpu.put("type", "string");
- cpu.put("default", "250m");
- inputs.put("test.component.spec_cpu_limit", cpu);
- inputs.put("test.component.spec_cpu_request", cpu);
-
- LinkedHashMap<String, Object> mem = new LinkedHashMap<>();
- mem.put("type", "string");
- mem.put("default", "128Mi");
- inputs.put("test.component.spec_memory_limit", mem);
- inputs.put("test.component.spec_memory_request", mem);
- }
-
- @Test
- public void interfaceTest() {
- ComponentSpec cs = new ComponentSpec();
- cs.createComponentSpecFromFile("TestCases/testComponentSpec.json");
-
- Blueprint bp = new Blueprint();
- bp = bp.createBlueprint(cs, "", 'o', "", "");
-
- OnapNode node = (OnapNode) bp.getNode_templates().get("test.component.spec");
-
- OnapNode testNode = new OnapNode();
-
- //set the type
- testNode.setType("dcae.nodes.ContainerizedServiceComponent");
-
- ArrayList<String> ports = new ArrayList<>();
- ports.add("concat: [\"80:\", {get_input: external_port }]");
- ports.add("concat: [\"99:\", {get_input: external_port }]");
- }
-
- @Test
- public void parametersTest() {
- ComponentSpec cs = new ComponentSpec();
- cs.createComponentSpecFromFile("TestCases/testComponentSpec.json");
-
- Blueprint bp = new Blueprint();
- bp = bp.createBlueprint(cs, "", 'o', "", "");
-
- OnapNode node = (OnapNode) bp.getNode_templates().get("test.component.spec");
-
- GetInput par = (GetInput) node.getProperties().getApplication_config().getParams().get("testParam1");
- assertEquals("testParam1", par.getBpInputName());
- }
-
- @Test
- public void streamPublishesTest() {
- ComponentSpec cs = new ComponentSpec();
- cs.createComponentSpecFromFile("TestCases/testComponentSpec.json");
-
- Blueprint bp = new Blueprint();
- bp = bp.createBlueprint(cs, "", 'o', "", "");
-
- OnapNode node = (OnapNode) bp.getNode_templates().get("test.component.spec");
-
- assertFalse(node.getProperties().getApplication_config().getStreams_publishes().isEmpty());
- }
-
- @Test
- public void dmaapPluginTest() {
- ComponentSpec cs = new ComponentSpec();
- cs.createComponentSpecFromFile("TestCases/testComponentSpec.json");
-
- Blueprint bp = new Blueprint();
- bp = bp.createBlueprint(cs, "", 'd', "", "");
-
- DmaapNode dmaap = (DmaapNode) bp.getNode_templates().get("test.component.spec");
-
- //check if the stream publishes and subscribes are not null to see if the dmaap plugin was invoked properly
- assertNotNull(dmaap.getProperties().getStreams_publishes());
- assertNotNull(dmaap.getProperties().getStreams_subscribes());
- }
-
- @Test
- public void testPrintInstructionsBlueprintCommand() {
- BlueprintCommand objUnderTest = new BlueprintCommand();
- CommandLine cli = new CommandLine(objUnderTest);
- PrintStream mockStdOutWriter = Mockito.mock(PrintStream.class);
- ArgumentCaptor<String> captor = ArgumentCaptor.forClass(String.class);
- cli.usage(mockStdOutWriter);
- verify(mockStdOutWriter, times(1)).print(any(Object.class));
-
- }
-
- @Test
- public void testPrintInstructionsPolicyCommand() {
- PolicyCommand objUnderTest = new PolicyCommand();
- CommandLine cli = new CommandLine(objUnderTest);
- PrintStream mockStdOutWriter = Mockito.mock(PrintStream.class);
- ArgumentCaptor<String> captor = ArgumentCaptor.forClass(String.class);
- cli.usage(mockStdOutWriter);
- verify(mockStdOutWriter, times(1)).print(any(Object.class));
- }
-
- @Test
- public void testPolicyModels() {
- ComponentSpec cs = new ComponentSpec();
- cs.createComponentSpecFromFile("TestCases/testComponentSpec.json");
-
- PolicyModel p = new PolicyModel();
- p.createPolicyModels(cs, "TestModels");
- }
-}
diff --git a/mod/bpgenerator/src/test/java/org/onap/blueprintgenerator/core/TlsInfoTest.java b/mod/bpgenerator/src/test/java/org/onap/blueprintgenerator/core/TlsInfoTest.java
deleted file mode 100644
index 8adf03d..0000000
--- a/mod/bpgenerator/src/test/java/org/onap/blueprintgenerator/core/TlsInfoTest.java
+++ /dev/null
@@ -1,163 +0,0 @@
-/*============LICENSE_START=======================================================
- org.onap.dcae
- ================================================================================
- Copyright (c) 2020 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.blueprintgenerator.core;
-
-import org.junit.Test;
-import org.junit.runner.RunWith;
-import org.junit.runners.Parameterized;
-import org.onap.blueprintgenerator.models.blueprint.Blueprint;
-import org.onap.blueprintgenerator.models.blueprint.Node;
-import org.onap.blueprintgenerator.models.blueprint.tls.TlsInfo;
-import org.onap.blueprintgenerator.models.blueprint.tls.impl.ExternalCertificateParameters;
-import org.onap.blueprintgenerator.models.blueprint.tls.impl.ExternalTlsInfo;
-import org.onap.blueprintgenerator.models.componentspec.ComponentSpec;
-
-import java.util.Arrays;
-import java.util.LinkedHashMap;
-import java.util.List;
-
-import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.assertFalse;
-import static org.junit.Assert.assertNotNull;
-import static org.junit.Assert.assertNull;
-
-@RunWith(Parameterized.class)
-public class TlsInfoTest {
-
- @Parameterized.Parameter
- public char bpType;
-
- @Parameterized.Parameters(name = "Blueprint type: {0}")
- public static List<Character> data() {
- return Arrays.asList('o', 'd');
- }
-
- @Test
- public void useTlsTrueAndUseExternalTlsTrueTest(){
- Blueprint bp = createBlueprintFromFile("TestCases/TlsInfo/testComponentSpec_withTlsTrueAndExternalTlsTrue.json");
-
- assertBlueprintContainsExternalTlsInfoWithUseFlagDefault(bp, true);
- assertBlueprintContainsTlsInfoWithUseFlagDefault(bp, true);
- }
-
- @Test
- public void useTlsFalseAndUseExternalTlsFalseTest(){
- Blueprint bp = createBlueprintFromFile("TestCases/TlsInfo/testComponentSpec_withTlsFalseAndExternalTlsFalse.json");
-
- assertBlueprintContainsExternalTlsInfoWithUseFlagDefault(bp, false);
- assertBlueprintContainsTlsInfoWithUseFlagDefault(bp, false);
- }
-
- @Test
- public void useTlsTrueAndNoExternalTlsFlagTest(){
- Blueprint bp = createBlueprintFromFile("TestCases/TlsInfo/testComponentSpec_withTlsTrueAndNoExternalTls.json");
-
- assertBlueprintContainsTlsInfoWithUseFlagDefault(bp, true);
- assertBlueprintHasNoExternalTlsInfo(bp);
- }
-
- @Test
- public void noTlsInfo(){
- Blueprint bp = createBlueprintFromFile("TestCases/TlsInfo/testComponentSpec_withoutTlsInfo.json");
-
- assertBlueprintHasNoTlsInfo(bp);
- assertBlueprintHasNoExternalTlsInfo(bp);
- }
-
- private void assertBlueprintContainsExternalTlsInfoWithUseFlagDefault(Blueprint bp, boolean useFlagDefault) {
- //should create proper inputs
- assertContainsInputWithDefault(bp, "external_cert_use_external_tls", useFlagDefault);
- assertContainsInputWithDefault(bp, "external_cert_ca_name", "\"RA\"");
- assertContainsInputWithDefault(bp, "external_cert_cert_type", "\"P12\"");
- assertContainsInputWithDefault(bp, "external_cert_common_name", "\"sample.onap.org\"");
- assertContainsInputWithDefault(bp, "external_cert_sans",
- "\"sample.onap.org:component.sample.onap.org\"");
-
- Node node = bp.getNode_templates().get("test.component.spec");
-
- //should create proper externalTlsInfo object in node properties
- ExternalTlsInfo externalTlsInfo = node.getProperties().getExternal_cert();
- assertNotNull(externalTlsInfo);
-
- assertEquals("external_cert_ca_name", externalTlsInfo.getCaName().getBpInputName());
- assertEquals("external_cert_cert_type", externalTlsInfo.getCertType().getBpInputName());
- assertEquals("external_cert_use_external_tls", externalTlsInfo.getUseExternalTls().getBpInputName());
- assertEquals("/opt/app/dcae-certificate/", externalTlsInfo.getExternalCertDirectory());
-
- ExternalCertificateParameters extCertParams = externalTlsInfo.getExternalCertificateParameters();
- assertNotNull(extCertParams);
-
- assertEquals("external_cert_common_name", extCertParams.getCommonName().getBpInputName());
- assertEquals("external_cert_sans", extCertParams.getSans().getBpInputName());
- }
-
- private void assertBlueprintContainsTlsInfoWithUseFlagDefault(Blueprint bp, boolean useFlagDefault) {
- //shold create proper inputs
- assertContainsInputWithDefault(bp, "use_tls", useFlagDefault);
-
- Node node = bp.getNode_templates().get("test.component.spec");
-
- //should create proper tlsInfo object in node properties
- TlsInfo tlsInfo = node.getProperties().getTls_info();
- assertEquals("use_tls", tlsInfo.getUseTls().getBpInputName());
- assertEquals("/opt/app/dcae-certificate/", tlsInfo.getCertDirectory());
-
- }
-
- private void assertBlueprintHasNoExternalTlsInfo(Blueprint bp) {
- //should not create inputs for external tls
- assertFalse(bp.getInputs().containsKey("external_cert_use_external_tls"));
- assertFalse(bp.getInputs().containsKey("external_cert_common_name"));
- assertFalse(bp.getInputs().containsKey("external_cert_ca_name"));
- assertFalse(bp.getInputs().containsKey("external_cert_sans"));
-
- Node node = bp.getNode_templates().get("test.component.spec");
-
- //should not create externalTlsInfo object in node properties
- ExternalTlsInfo externalTlsInfo = node.getProperties().getExternal_cert();
- assertNull(externalTlsInfo);
- }
-
-
- private void assertBlueprintHasNoTlsInfo(Blueprint bp) {
- //should not create inputs for tls
- assertFalse(bp.getInputs().containsKey("use_tls"));
-
- Node node = bp.getNode_templates().get("test.component.spec");
-
- //should not create tlsInfo object in node properties
- assertNull(node.getProperties().getTls_info());
- }
-
- private void assertContainsInputWithDefault(Blueprint bp, String inputName, Object defaultValue) {
- LinkedHashMap<String, Object> input = bp.getInputs().get(inputName);
- assertNotNull(input);
- assertEquals(defaultValue, input.get("default"));
- }
-
- private Blueprint createBlueprintFromFile(String path) {
- ComponentSpec cs = new ComponentSpec();
- cs.createComponentSpecFromFile(path);
-
- Blueprint bp = new Blueprint();
- bp = bp.createBlueprint(cs, "", this.bpType, "", "");
- return bp;
- }
-}
diff --git a/mod/bpgenerator/src/test/java/org/onap/blueprintgenerator/models/blueprint/AppconfigTest.java b/mod/bpgenerator/src/test/java/org/onap/blueprintgenerator/models/blueprint/AppconfigTest.java
deleted file mode 100644
index 173d230..0000000
--- a/mod/bpgenerator/src/test/java/org/onap/blueprintgenerator/models/blueprint/AppconfigTest.java
+++ /dev/null
@@ -1,62 +0,0 @@
-/*============LICENSE_START=======================================================
- org.onap.dcae
- ================================================================================
- Copyright (c) 2020 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.blueprintgenerator.models.blueprint;
-
-import static org.junit.Assert.assertEquals;
-
-import java.io.BufferedReader;
-import java.io.File;
-import java.io.FileInputStream;
-import java.io.FileNotFoundException;
-import java.io.InputStream;
-import java.io.InputStreamReader;
-import java.nio.charset.StandardCharsets;
-import java.util.LinkedHashMap;
-import java.util.TreeMap;
-import java.util.stream.Collectors;
-import org.junit.Test;
-import org.onap.blueprintgenerator.models.componentspec.ComponentSpec;
-
-public class AppconfigTest {
-
- @Test
- public void createAppconfigShouldReturnExpectedResult() throws FileNotFoundException {
- TreeMap<String, LinkedHashMap<String, Object>> inputs = new TreeMap<String, LinkedHashMap<String, Object>>();
- ComponentSpec cs = new ComponentSpec();
- cs.createComponentSpecFromFile("TestCases/testComponentSpec.json");
-
- TreeMap<String, LinkedHashMap<String, Object>> result = new Appconfig().createAppconfig(inputs, cs, "", false);
-
- assertEquals(getExpectedStringFromFile(), result.toString());
- }
-
- private String getExpectedStringFromFile() throws FileNotFoundException {
- File file = new File("TestCases/expects/createAppConfigResult.txt");
- InputStream inputStream = new FileInputStream(file);
- return readFromInputStream(inputStream);
- }
-
- private String readFromInputStream(InputStream inputStream) {
- return new BufferedReader(
- new InputStreamReader(inputStream, StandardCharsets.UTF_8))
- .lines()
- .collect(Collectors.joining(""));
- }
-}
diff --git a/mod/bpgenerator/src/test/java/org/onap/blueprintgenerator/models/blueprint/ImportsTest.java b/mod/bpgenerator/src/test/java/org/onap/blueprintgenerator/models/blueprint/ImportsTest.java
deleted file mode 100644
index 1ce296a..0000000
--- a/mod/bpgenerator/src/test/java/org/onap/blueprintgenerator/models/blueprint/ImportsTest.java
+++ /dev/null
@@ -1,52 +0,0 @@
-/*============LICENSE_START=======================================================
- org.onap.dcae
- ================================================================================
- Copyright (c) 2020 Nokia Intellectual Property. 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.blueprintgenerator.models.blueprint;
-
-import static org.junit.Assert.assertEquals;
-
-import java.util.ArrayList;
-import java.util.Arrays;
-import java.util.List;
-import org.junit.Test;
-
-public class ImportsTest {
-
- private final List<String> expectedImports = Arrays.asList(
- "https://www.getcloudify.org/spec/cloudify/4.5.5/types.yaml",
- "plugin:k8splugin?version=3.4.1",
- "plugin:pgaas?version=1.3.0",
- "plugin:clamppolicyplugin?version=1.1.0",
- "plugin:dmaap?version=1.5.0"
- );
-
- @Test
- public void shouldReadImportsFromFile() {
- ArrayList<String> importsFromFile = Imports.createImportsFromFile("TestCases/imports/imports.yaml");
- assertEquals(expectedImports, importsFromFile);
- }
-
- @Test
- public void shouldRemoveBlankImportsFromFile() {
- ArrayList<String> importsFromFile =
- Imports.createImportsFromFile("TestCases/imports/importsWithBlanks.yaml");
- assertEquals(expectedImports, importsFromFile);
- }
-
-}
diff --git a/mod/bpgenerator/src/test/java/org/onap/blueprintgenerator/models/blueprint/ResourceConfigTest.java b/mod/bpgenerator/src/test/java/org/onap/blueprintgenerator/models/blueprint/ResourceConfigTest.java
deleted file mode 100644
index cf12da1..0000000
--- a/mod/bpgenerator/src/test/java/org/onap/blueprintgenerator/models/blueprint/ResourceConfigTest.java
+++ /dev/null
@@ -1,38 +0,0 @@
-/*============LICENSE_START=======================================================
- org.onap.dcae
- ================================================================================
- Copyright (c) 2020 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.blueprintgenerator.models.blueprint;
-
-import static org.junit.Assert.assertEquals;
-
-import java.util.LinkedHashMap;
-import java.util.TreeMap;
-import org.junit.Test;
-
-public class ResourceConfigTest {
-
- @Test
- public void createResourceConfig() {
- TreeMap<String, LinkedHashMap<String, Object>> result = new ResourceConfig()
- .createResourceConfig(new TreeMap<>(), "demo");
-
- String expectedResult = "{demo_cpu_limit={type=string, default=250m}, demo_cpu_request={type=string, default=250m}, demo_memory_limit={type=string, default=128Mi}, demo_memory_request={type=string, default=128Mi}}";
- assertEquals(expectedResult, result.toString());
- }
-}
diff --git a/mod/bpgenerator/src/test/java/org/onap/blueprintgenerator/models/blueprint/tls/ExternalCertificateParametersFactoryTest.java b/mod/bpgenerator/src/test/java/org/onap/blueprintgenerator/models/blueprint/tls/ExternalCertificateParametersFactoryTest.java
deleted file mode 100644
index 1cdb58b..0000000
--- a/mod/bpgenerator/src/test/java/org/onap/blueprintgenerator/models/blueprint/tls/ExternalCertificateParametersFactoryTest.java
+++ /dev/null
@@ -1,62 +0,0 @@
-/*============LICENSE_START=======================================================
- org.onap.dcae
- ================================================================================
- Copyright (c) 2020 Nokia Intellectual Property. 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.blueprintgenerator.models.blueprint.tls;
-
-import org.junit.Test;
-import org.onap.blueprintgenerator.models.blueprint.tls.impl.ExternalCertificateParameters;
-
-import java.util.LinkedHashMap;
-import java.util.Map;
-
-import static org.junit.Assert.assertEquals;
-import static org.onap.blueprintgenerator.models.blueprint.tls.TlsConstants.COMMON_NAME_FIELD;
-import static org.onap.blueprintgenerator.models.blueprint.tls.TlsConstants.DEFAULT_COMMON_NAME;
-import static org.onap.blueprintgenerator.models.blueprint.tls.TlsConstants.DEFAULT_SANS;
-import static org.onap.blueprintgenerator.models.blueprint.tls.TlsConstants.INPUT_PREFIX;
-import static org.onap.blueprintgenerator.models.blueprint.tls.TlsConstants.SANS_FIELD;
-
-public class ExternalCertificateParametersFactoryTest {
-
- private static final String PREFIXED_COMMON_NAME_FIELD = INPUT_PREFIX + COMMON_NAME_FIELD;
- private static final String PREFIXED_SANS_FIELD = INPUT_PREFIX + SANS_FIELD;
- private static final String DEFAULT = "default";
-
- @Test
- public void shouldCreateExternalCertificatePropertiesObject() {
- // given
- ExternalCertificateParametersFactory cut = new ExternalCertificateParametersFactory();
- // when
- ExternalCertificateParameters result = cut.create();
- // then
- assertEquals(result.getCommonName().getBpInputName(), PREFIXED_COMMON_NAME_FIELD);
- assertEquals(result.getSans().getBpInputName(), PREFIXED_SANS_FIELD);
- }
-
- @Test
- public void shouldCreateCorrectInputListWithDefaultValuesTakenFromComponentSpec() {
- // given
- ExternalCertificateParametersFactory cut = new ExternalCertificateParametersFactory();
- // when
- Map<String, LinkedHashMap<String, Object>> result = cut.createInputList();
- // then
- assertEquals(DEFAULT_COMMON_NAME, result.get(PREFIXED_COMMON_NAME_FIELD).get(DEFAULT));
- assertEquals(DEFAULT_SANS, result.get(PREFIXED_SANS_FIELD).get(DEFAULT));
- }
-}
diff --git a/mod/bpgenerator/src/test/java/org/onap/blueprintgenerator/models/dmaapbp/DmaapBlueprintTest.java b/mod/bpgenerator/src/test/java/org/onap/blueprintgenerator/models/dmaapbp/DmaapBlueprintTest.java
deleted file mode 100644
index 9e31002..0000000
--- a/mod/bpgenerator/src/test/java/org/onap/blueprintgenerator/models/dmaapbp/DmaapBlueprintTest.java
+++ /dev/null
@@ -1,245 +0,0 @@
-/*============LICENSE_START=======================================================
- org.onap.dcae
- ================================================================================
- Copyright (c) 2020 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.blueprintgenerator.models.dmaapbp;
-
-import static org.junit.Assert.assertNotNull;
-import static org.junit.Assert.assertTrue;
-import static org.mockito.Mockito.mock;
-import static org.mockito.Mockito.when;
-
-
-import java.util.ArrayList;
-import java.util.List;
-import org.junit.Test;
-import org.onap.blueprintgenerator.models.blueprint.Blueprint;
-import org.onap.blueprintgenerator.models.componentspec.Artifacts;
-import org.onap.blueprintgenerator.models.componentspec.Auxilary;
-import org.onap.blueprintgenerator.models.componentspec.ComponentSpec;
-import org.onap.blueprintgenerator.models.componentspec.Parameters;
-import org.onap.blueprintgenerator.models.componentspec.Publishes;
-import org.onap.blueprintgenerator.models.componentspec.Self;
-import org.onap.blueprintgenerator.models.componentspec.Streams;
-import org.onap.blueprintgenerator.models.componentspec.Subscribes;
-
-public class DmaapBlueprintTest {
-
- private static final String MOCKED_NAME = "sample.name";
- private static final String MESSAGE_ROUTER_TYPE_1 = "message_router";
- private static final String MESSAGE_ROUTER_TYPE_2 = "message router";
- private static final String DATA_ROUTER_TYPE_1 = "data_router";
- private static final String DATA_ROUTER_TYPE_2 = "data router";
- private static final String CONFIG_KEY_1 = "Configkey1";
- private static final String CONFIG_KEY_2 = "Configkey2";
-
- private static final String TOPIC_NODE_1 = CONFIG_KEY_1 + "_topic";
- private static final String TOPIC_NODE_2 = CONFIG_KEY_2 + "_topic";
- private static final String FEED_NODE_1 = CONFIG_KEY_1 + "_feed";
- private static final String FEED_NODE_2 = CONFIG_KEY_2 + "_feed";
-
- private static final String SAMPLE_FORMAT = "Format";
- private static final String SAMPLE_VERSION = "1.0.0";
- private static final String SAMPLE_ROUTE = "SampleRoute";
- private static final String SAMPLE_DESCRIPTION = "sample description";
- private static final String SAMPLE_PORTS = "8080:8080";
- private static final String SAMPLE_ARTIFACT_TYPE = "test";
- private static final String SAMPLE_ARTIFACT_URI = "test_uri";
-
- @Test
- public void dmaapBlueprintShouldHaveNodeTemplateWithDmaapNode() {
-
- //given
- ComponentSpec componentSpec = getMockedComponentSpec();
- DmaapBlueprint dmaapBlueprint = new DmaapBlueprint();
-
- //when
- Blueprint resultBlueprint = dmaapBlueprint.createDmaapBlueprint(componentSpec, "", "");
-
- //then
- assertTrue(resultBlueprint.getNode_templates().get(MOCKED_NAME) instanceof DmaapNode);
- }
-
- @Test
- public void nodeTemplateHasTopicNodeWhenAddMessageRouterAsPublishes() {
- //given
- ComponentSpec componentSpec = getMockedComponentSpec();
- Streams streams = new Streams();
- streams.setPublishes(getMessageRouterPublishes());
- streams.setSubscribes(new Subscribes[0]);
-
- when(componentSpec.getStreams()).thenReturn(streams);
- DmaapBlueprint dmaapBlueprint = new DmaapBlueprint();
-
- //when
- Blueprint resultBlueprint = dmaapBlueprint.createDmaapBlueprint(componentSpec, "", "");
-
- //then
- assertNotNull(resultBlueprint.getNode_templates().get(TOPIC_NODE_1));
- assertNotNull(resultBlueprint.getNode_templates().get(TOPIC_NODE_2));
-
- }
-
- @Test
- public void nodeTemplateHasTopicNodeWhenAddMessageRouterAsSubscribes() {
- //given
- ComponentSpec componentSpec = getMockedComponentSpec();
- Streams streams = new Streams();
- streams.setPublishes(new Publishes[0]);
- streams.setSubscribes(getMessageRouterSubscribes());
-
- when(componentSpec.getStreams()).thenReturn(streams);
- DmaapBlueprint dmaapBlueprint = new DmaapBlueprint();
-
- //when
- Blueprint resultBlueprint = dmaapBlueprint.createDmaapBlueprint(componentSpec, "", "");
-
- //then
- assertNotNull(resultBlueprint.getNode_templates().get(TOPIC_NODE_1));
- assertNotNull(resultBlueprint.getNode_templates().get(TOPIC_NODE_2));
-
- }
-
- @Test
- public void nodeTemplateHasFeedNodeWhenAddDataRouterAsPublishes() {
- //given
- ComponentSpec componentSpec = getMockedComponentSpec();
- Streams streams = new Streams();
- streams.setPublishes(getDataRouterPublishes());
- streams.setSubscribes(new Subscribes[0]);
-
- when(componentSpec.getStreams()).thenReturn(streams);
- DmaapBlueprint dmaapBlueprint = new DmaapBlueprint();
-
- //when
- Blueprint resultBlueprint = dmaapBlueprint.createDmaapBlueprint(componentSpec, "", "");
-
- //then
- assertNotNull(resultBlueprint.getNode_templates().get(FEED_NODE_1));
- assertNotNull(resultBlueprint.getNode_templates().get(FEED_NODE_2));
-
- }
-
- @Test
- public void nodeTemplateHasFeedNodeWhenAddDataRouterAsSubscribes() {
- //given
- ComponentSpec componentSpec = getMockedComponentSpec();
- Streams streams = new Streams();
- streams.setPublishes(new Publishes[0]);
- streams.setSubscribes(getDataRouterSubscribes());
-
- when(componentSpec.getStreams()).thenReturn(streams);
- DmaapBlueprint dmaapBlueprint = new DmaapBlueprint();
-
- //when
- Blueprint resultBlueprint = dmaapBlueprint.createDmaapBlueprint(componentSpec, "", "");
-
- //then
- assertNotNull(resultBlueprint.getNode_templates().get(FEED_NODE_1));
- assertNotNull(resultBlueprint.getNode_templates().get(FEED_NODE_2));
-
- }
-
- private Publishes[] getMessageRouterPublishes() {
- List<Publishes> publishesList = new ArrayList<>();
-
- publishesList.add(createSamplePublishes(MESSAGE_ROUTER_TYPE_1, CONFIG_KEY_1));
- publishesList.add(createSamplePublishes(MESSAGE_ROUTER_TYPE_2, CONFIG_KEY_2));
- return publishesList.toArray(new Publishes[0]);
- }
-
- private Subscribes[] getMessageRouterSubscribes() {
- List<Subscribes> subscribesList = new ArrayList<>();
-
- subscribesList.add(createSampleSubscribes(MESSAGE_ROUTER_TYPE_1, CONFIG_KEY_1));
- subscribesList.add(createSampleSubscribes(MESSAGE_ROUTER_TYPE_2, CONFIG_KEY_2));
- return subscribesList.toArray(new Subscribes[0]);
- }
-
- private Publishes[] getDataRouterPublishes() {
- List<Publishes> publishesList = new ArrayList<>();
-
- publishesList.add(createSamplePublishes(DATA_ROUTER_TYPE_1, CONFIG_KEY_1));
- publishesList.add(createSamplePublishes(DATA_ROUTER_TYPE_2, CONFIG_KEY_2));
- return publishesList.toArray(new Publishes[0]);
- }
-
- private Subscribes[] getDataRouterSubscribes() {
- List<Subscribes> subscribesList = new ArrayList<>();
-
- subscribesList.add(createSampleSubscribes(DATA_ROUTER_TYPE_1, CONFIG_KEY_1));
- subscribesList.add(createSampleSubscribes(DATA_ROUTER_TYPE_2, CONFIG_KEY_2));
- return subscribesList.toArray(new Subscribes[0]);
- }
-
- private Publishes createSamplePublishes(String type, String key) {
- Publishes publishes = new Publishes();
-
- publishes.setType(type);
- publishes.setConfig_key(key);
- publishes.setFormat(SAMPLE_FORMAT);
- publishes.setVersion(SAMPLE_VERSION);
- publishes.setRoute(SAMPLE_ROUTE);
-
- return publishes;
- }
-
- private Subscribes createSampleSubscribes(String type, String key) {
- Subscribes subscribes = new Subscribes();
-
- subscribes.setType(type);
- subscribes.setConfig_key(key);
- subscribes.setFormat(SAMPLE_FORMAT);
- subscribes.setVersion(SAMPLE_FORMAT);
- subscribes.setRoute(SAMPLE_ROUTE);
-
- return subscribes;
- }
-
- private ComponentSpec getMockedComponentSpec() {
- Self self = mock(Self.class);
- when(self.getDescription()).thenReturn(SAMPLE_DESCRIPTION);
- when(self.getName()).thenReturn(MOCKED_NAME);
-
- Auxilary auxilary = mock(Auxilary.class);
- ArrayList<Object> ports = new ArrayList<>();
- ports.add(SAMPLE_PORTS);
- when(auxilary.getPorts()).thenReturn(ports);
-
- Streams streams = mock(Streams.class);
- when(streams.getPublishes()).thenReturn(new Publishes[0]);
- when(streams.getSubscribes()).thenReturn(new Subscribes[0]);
-
- Artifacts artifact = new Artifacts();
- artifact.setType(SAMPLE_ARTIFACT_TYPE);
- artifact.setUri(SAMPLE_ARTIFACT_URI);
-
- Artifacts[] arrayArtifacts = new Artifacts[10];
- arrayArtifacts[0] = artifact;
-
- ComponentSpec componentSpec = mock(ComponentSpec.class);
- when(componentSpec.getSelf()).thenReturn(self);
- when(componentSpec.getAuxilary()).thenReturn(auxilary);
- when(componentSpec.getStreams()).thenReturn(streams);
- when(componentSpec.getArtifacts()).thenReturn(arrayArtifacts);
- when(componentSpec.getParameters()).thenReturn(new Parameters[0]);
- when(componentSpec.getSelfName()).thenReturn(MOCKED_NAME);
- return componentSpec;
- }
-}
diff --git a/mod/bpgenerator/src/test/java/org/onap/blueprintgenerator/models/dmaapbp/DmaapNodeTest.java b/mod/bpgenerator/src/test/java/org/onap/blueprintgenerator/models/dmaapbp/DmaapNodeTest.java
deleted file mode 100644
index 83419e5..0000000
--- a/mod/bpgenerator/src/test/java/org/onap/blueprintgenerator/models/dmaapbp/DmaapNodeTest.java
+++ /dev/null
@@ -1,224 +0,0 @@
-/*============LICENSE_START=======================================================
- org.onap.dcae
- ================================================================================
- Copyright (c) 2020 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.blueprintgenerator.models.dmaapbp;
-
-import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.assertNotNull;
-import static org.junit.Assert.assertNull;
-import static org.junit.Assert.assertTrue;
-import static org.mockito.Mockito.spy;
-import static org.mockito.Mockito.when;
-import static org.onap.blueprintgenerator.models.blueprint.BpConstants.CONTENERIZED_SERVICE_COMPONENT_USING_DMAAP;
-import static org.onap.blueprintgenerator.models.blueprint.BpConstants.FEED;
-import static org.onap.blueprintgenerator.models.blueprint.BpConstants.SUBSCRIBE_TO_EVENTS;
-import static org.onap.blueprintgenerator.models.blueprint.BpConstants.SUBSCRIBE_TO_FILES;
-import static org.onap.blueprintgenerator.models.blueprint.BpConstants.TOPIC;
-
-import java.util.Map;
-import java.util.TreeMap;
-import org.junit.Test;
-import org.onap.blueprintgenerator.core.TestComponentSpec;
-import org.onap.blueprintgenerator.models.componentspec.Auxilary;
-import org.onap.blueprintgenerator.models.componentspec.ComponentSpec;
-import org.onap.blueprintgenerator.models.componentspec.Publishes;
-import org.onap.blueprintgenerator.models.componentspec.Streams;
-import org.onap.blueprintgenerator.models.componentspec.Subscribes;
-
-public class DmaapNodeTest {
-
- private static final String DATA_ROUTER_TYPE = "data_router";
- private static final String MESSAGE_ROUTER_TYPE = "message_router";
-
- private static final String CONFIG_KEY = "Configkey";
-
- private static final String SAMPLE_FORMAT = "Format";
- private static final String SAMPLE_VERSION = "1.0.0";
- private static final String SAMPLE_ROUTE = "SampleRoute";
- private static final String TYPE = "type";
- private static final String TARGET = "target";
-
-
- @Test
- public void dmaapNodeShouldHaveExpectedNodeType() {
-
- ComponentSpec mockedComponentSpec = getSpiedComponentSpecWithoutRelationships();
-
- DmaapNode dmaapNode = new DmaapNode();
- dmaapNode.createDmaapNode(mockedComponentSpec, new TreeMap<>(), "");
-
- assertEquals(CONTENERIZED_SERVICE_COMPONENT_USING_DMAAP, dmaapNode.getType());
- }
-
- @Test
- public void createdDmaapNodeShouldHaveRelationshipWithTypeAndTargetForMessageRouterPublishes() {
- ComponentSpec componentSpec = getSpiedComponentSpecWithoutRelationships();
-
- Streams streams = new Streams();
- streams.setSubscribes(new Subscribes[0]);
- streams.setPublishes(createSamplePublishes(MESSAGE_ROUTER_TYPE));
-
- when(componentSpec.getStreams()).thenReturn(streams);
- DmaapNode dmaapNode = new DmaapNode();
- dmaapNode.createDmaapNode(componentSpec, new TreeMap<>(), "");
-
- Map<String, String> relationship = dmaapNode.getRelationships().get(0);
-
- assertNotNull(relationship.get(TYPE));
- assertNotNull(relationship.get(TARGET));
- }
-
- @Test
- public void createdDmaapNodeShouldHaveRelationshipWithTypeAndTargetForDataRouterPublishes() {
- ComponentSpec componentSpec = getSpiedComponentSpecWithoutRelationships();
-
- Streams streams = new Streams();
- streams.setSubscribes(new Subscribes[0]);
- streams.setPublishes(createSamplePublishes(DATA_ROUTER_TYPE));
-
- when(componentSpec.getStreams()).thenReturn(streams);
- DmaapNode dmaapNode = new DmaapNode();
- dmaapNode.createDmaapNode(componentSpec, new TreeMap<>(), "");
-
- Map<String, String> relationship = dmaapNode.getRelationships().get(0);
-
- assertNotNull(relationship.get(TYPE));
- assertNotNull(relationship.get(TARGET));
- }
-
- @Test
- public void createdDmaapNodeShouldHaveRelationshipWithTypeAndTargetForMessageRouterSubscribes() {
- ComponentSpec componentSpec = getSpiedComponentSpecWithoutRelationships();
-
- Streams streams = new Streams();
- streams.setSubscribes(createSampleSubscribes(MESSAGE_ROUTER_TYPE));
- streams.setPublishes(new Publishes[0]);
-
- when(componentSpec.getStreams()).thenReturn(streams);
- DmaapNode dmaapNode = new DmaapNode();
- dmaapNode.createDmaapNode(componentSpec, new TreeMap<>(), "");
-
- Map<String, String> relationship = dmaapNode.getRelationships().get(0);
-
- assertEquals(SUBSCRIBE_TO_EVENTS, relationship.get(TYPE));
- assertNotNull(relationship.get(TARGET));
- }
-
- @Test
- public void createdDmaapNodeShouldHaveRelationshipWithTypeAndTargetForDataRouterSubscribes() {
- ComponentSpec componentSpec = getSpiedComponentSpecWithoutRelationships();
-
- Streams streams = new Streams();
- streams.setSubscribes(createSampleSubscribes(DATA_ROUTER_TYPE));
- streams.setPublishes(new Publishes[0]);
-
- when(componentSpec.getStreams()).thenReturn(streams);
- DmaapNode dmaapNode = new DmaapNode();
- dmaapNode.createDmaapNode(componentSpec, new TreeMap<>(), "");
-
- Map<String, String> relationship = dmaapNode.getRelationships().get(0);
-
- assertEquals(SUBSCRIBE_TO_FILES, relationship.get(TYPE));
- assertNotNull(relationship.get(TARGET));
- }
-
- @Test
- public void createFeedNodeShouldSetFeedNodeType() {
- ComponentSpec componentSpec = getSpiedComponentSpecWithoutRelationships();
-
- DmaapNode dmaapNode = new DmaapNode();
- dmaapNode.createFeedNode(componentSpec, new TreeMap<>(), "");
-
- assertEquals(FEED, dmaapNode.getType());
- }
-
- @Test
- public void feedNodePropertiesShouldHaveUseExistingField() {
- ComponentSpec componentSpec = getSpiedComponentSpecWithoutRelationships();
-
- DmaapNode dmaapNode = new DmaapNode();
- dmaapNode.createFeedNode(componentSpec, new TreeMap<>() ,"");
-
- assertTrue(dmaapNode.getProperties().getUseExisting());
- }
-
- @Test
- public void createTopicNodeShouldSetTopicNodeType() {
-
- ComponentSpec componentSpec = getSpiedComponentSpecWithoutRelationships();
-
- DmaapNode dmaapNode = new DmaapNode();
- dmaapNode.createTopicNode(componentSpec, new TreeMap<>(), "");
-
- assertEquals(TOPIC, dmaapNode.getType());
- }
-
- @Test
- public void topicNodePropertiesShouldNotHaveUseExistingField() {
- ComponentSpec componentSpec = getSpiedComponentSpecWithoutRelationships();
-
- DmaapNode dmaapNode = new DmaapNode();
- dmaapNode.createTopicNode(componentSpec, new TreeMap<>() ,"");
-
- assertNull(dmaapNode.getProperties().getUseExisting());
- }
-
- private Publishes[] createSamplePublishes(String type) {
- Publishes publishes = new Publishes();
-
- publishes.setType(type);
- publishes.setConfig_key(CONFIG_KEY);
- publishes.setFormat(SAMPLE_FORMAT);
- publishes.setVersion(SAMPLE_VERSION);
- publishes.setRoute(SAMPLE_ROUTE);
-
- return new Publishes[]{publishes};
- }
-
- private Subscribes[] createSampleSubscribes(String type) {
- Subscribes subscribes = new Subscribes();
-
- subscribes.setType(type);
- subscribes.setConfig_key(CONFIG_KEY);
- subscribes.setFormat(SAMPLE_FORMAT);
- subscribes.setVersion(SAMPLE_VERSION);
- subscribes.setRoute(SAMPLE_ROUTE);
-
- return new Subscribes[]{subscribes};
- }
-
- private ComponentSpec getSpiedComponentSpecWithoutRelationships() {
- ComponentSpec baseComponentSpec = new ComponentSpec();
- baseComponentSpec.createComponentSpecFromString(new TestComponentSpec().getComponentSpecAsString());
- ComponentSpec componentSpec = spy(baseComponentSpec);
-
- Streams streams = new Streams();
- streams.setSubscribes(new Subscribes[0]);
- streams.setPublishes(new Publishes[0]);
- when(componentSpec.getStreams()).thenReturn(streams);
-
- Auxilary auxilary = spy(baseComponentSpec.getAuxilary());
- when(auxilary.getDatabases()).thenReturn(null);
-
- when(componentSpec.getAuxilary()).thenReturn(auxilary);
- when(componentSpec.getPolicyInfo()).thenReturn(null);
-
- return componentSpec;
- }
-}