diff options
Diffstat (limited to 'src/test')
37 files changed, 1025 insertions, 476 deletions
diff --git a/src/test/java/org/onap/aai/modelloader/service/TestModelLoaderApplication.java b/src/test/java/org/onap/aai/modelloader/TestModelLoaderApplication.java index 0f3ed45..c54f43e 100644 --- a/src/test/java/org/onap/aai/modelloader/service/TestModelLoaderApplication.java +++ b/src/test/java/org/onap/aai/modelloader/TestModelLoaderApplication.java @@ -1,5 +1,5 @@ /** - * ============LICENSE_START======================================================= + * ============LICENSE_START======================================================= * org.onap.aai * ================================================================================ * Copyright © 2017-2018 AT&T Intellectual Property. All rights reserved. @@ -18,12 +18,13 @@ * limitations under the License. * ============LICENSE_END========================================================= */ -package org.onap.aai.modelloader.service; +package org.onap.aai.modelloader; import org.junit.Test; +import org.onap.aai.modelloader.ModelLoaderApplication; /** - * Tests for ModelLoaderApplication class + * Tests for ModelLoaderApplication class. * */ public class TestModelLoaderApplication { @@ -34,7 +35,7 @@ public class TestModelLoaderApplication { @Test public void testServiceStarts() { - // The SDC Distribution Client is expected to fail to initialise. + // The SDC Distribution Client is disabled. ModelLoaderApplication.main(new String[0]); } diff --git a/src/test/java/org/onap/aai/modelloader/config/ModelLoaderConfigTest.java b/src/test/java/org/onap/aai/modelloader/config/TestModelLoaderConfig.java index e8060e2..bfd793a 100644 --- a/src/test/java/org/onap/aai/modelloader/config/ModelLoaderConfigTest.java +++ b/src/test/java/org/onap/aai/modelloader/config/TestModelLoaderConfig.java @@ -1,5 +1,5 @@ /** - * ============LICENSE_START======================================================= + * ============LICENSE_START======================================================= * org.onap.aai * ================================================================================ * Copyright © 2017-2018 AT&T Intellectual Property. All rights reserved. @@ -34,10 +34,10 @@ import org.onap.aai.modelloader.restclient.AaiRestClient; import org.onap.sdc.utils.ArtifactTypeEnum; /** - * Tests for ModelLoaderConfig class + * Tests for ModelLoaderConfig class. * */ -public class ModelLoaderConfigTest { +public class TestModelLoaderConfig { @Test public void testYangModelArtifactType() { @@ -89,7 +89,7 @@ public class ModelLoaderConfigTest { } @Test - public void testDecryptAAIAuthenticationPassword() { + public void testDecryptAaiAuthenticationPassword() { String password = "myvoiceismypassword"; ModelLoaderConfig config = createObfuscatedTestConfig(ModelLoaderConfig.PROP_AAI_AUTHENTICATION_PASSWORD, password); @@ -97,7 +97,7 @@ public class ModelLoaderConfigTest { } @Test - public void testDecryptAAIKeystorePassword() { + public void testDecryptAaiKeystorePassword() { String password = "myvoiceismypassword"; ModelLoaderConfig config = createObfuscatedTestConfig(ModelLoaderConfig.PROP_AAI_KEYSTORE_PASSWORD, password); assertEquals(password, config.getAaiKeyStorePassword()); @@ -148,8 +148,7 @@ public class ModelLoaderConfigTest { } @Test - public void testNoAAIAuth() throws IOException { - + public void testMissingAuthenticationProperties() throws IOException { Properties props = new Properties(); props.load(new FileInputStream("src/test/resources/model-loader-empty-auth-password.properties")); @@ -180,8 +179,10 @@ public class ModelLoaderConfigTest { /** - * @param propertyName - * @param propertyValue + * Create a Model Loader Configuration object from the supplied Property. + * + * @param propertyName property key + * @param propertyValue value of the property * @return a new ModelLoaderConfig object containing a single obfuscated property value */ private ModelLoaderConfig createObfuscatedTestConfig(String propertyName, String propertyValue) { diff --git a/src/test/java/org/onap/aai/modelloader/entity/catalog/VnfCatalogArtifactHandlerTest.java b/src/test/java/org/onap/aai/modelloader/entity/catalog/TestVnfCatalogArtifactHandler.java index b6d4564..b54bb20 100644 --- a/src/test/java/org/onap/aai/modelloader/entity/catalog/VnfCatalogArtifactHandlerTest.java +++ b/src/test/java/org/onap/aai/modelloader/entity/catalog/TestVnfCatalogArtifactHandler.java @@ -1,5 +1,5 @@ /** - * ============LICENSE_START======================================================= + * ============LICENSE_START======================================================= * org.onap.aai * ================================================================================ * Copyright © 2017-2018 AT&T Intellectual Property. All rights reserved. @@ -20,12 +20,15 @@ */ package org.onap.aai.modelloader.entity.catalog; -import static org.junit.Assert.assertTrue; +import static org.hamcrest.CoreMatchers.containsString; +import static org.hamcrest.CoreMatchers.is; +import static org.junit.Assert.assertThat; import static org.junit.Assert.fail; import static org.mockito.Mockito.mock; import static org.mockito.Mockito.when; import java.io.IOException; +import java.io.UnsupportedEncodingException; import java.nio.file.Files; import java.nio.file.Paths; import java.util.ArrayList; @@ -41,24 +44,19 @@ import org.onap.aai.modelloader.entity.Artifact; import org.onap.aai.modelloader.restclient.AaiRestClient; import org.onap.aai.restclient.client.OperationResult; -public class VnfCatalogArtifactHandlerTest { +public class TestVnfCatalogArtifactHandler { protected static String CONFIG_FILE = "model-loader.properties"; - @Test - public void testWithMocks() throws Exception { - - Properties configProperties = new Properties(); - try { - configProperties.load(this.getClass().getClassLoader().getResourceAsStream(CONFIG_FILE)); - } catch (IOException e) { - fail(); - } - ModelLoaderConfig config = new ModelLoaderConfig(configProperties, null); - config.setModelVersion("11"); - - AaiRestClient mockRestClient = mock(AaiRestClient.class); + private AaiRestClient mockRestClient = mock(AaiRestClient.class); + /** + * Update A&AI with 4 images, 2 of which already exist. + * + * @throws Exception + */ + @Test + public void testUpdateVnfImages() throws Exception { // GET operation OperationResult mockGetResp = mock(OperationResult.class); @@ -69,32 +67,64 @@ public class VnfCatalogArtifactHandlerTest { .thenReturn(Response.Status.NOT_FOUND.getStatusCode()) .thenReturn(Response.Status.OK.getStatusCode()); // @formatter:on + when(mockRestClient.getResource(Mockito.anyString(), Mockito.anyString(), Mockito.any(MediaType.class))) .thenReturn(mockGetResp); + mockPutOperations(); - // PUT operation - OperationResult mockPutResp = mock(OperationResult.class); + // Example VNF Catalog XML + VnfCatalogArtifactHandler handler = new VnfCatalogArtifactHandler(createConfig()); + assertThat(handler.pushArtifacts(createVnfCatalogArtifact(), "test", new ArrayList<Artifact>(), mockRestClient), + is(true)); - when(mockPutResp.getResultCode()).thenReturn(Response.Status.CREATED.getStatusCode()); - when(mockRestClient.putResource(Mockito.anyString(), Mockito.anyString(), Mockito.anyString(), - Mockito.any(MediaType.class))).thenReturn(mockPutResp); + assertPutOperationsSucceeded(); + } + + private ModelLoaderConfig createConfig() { + Properties configProperties = new Properties(); + try { + configProperties.load(this.getClass().getClassLoader().getResourceAsStream(CONFIG_FILE)); + } catch (IOException e) { + fail(); + } + ModelLoaderConfig config = new ModelLoaderConfig(configProperties, null); + return config; + } - // Example VNF Catalog with - VnfCatalogArtifactHandler vnfCAH = new VnfCatalogArtifactHandler(config); + /** + * Example VNF Catalog based on JSON data (returned by Babel) + * + * @return test Artifacts + * @throws IOException + * @throws UnsupportedEncodingException + */ + private List<Artifact> createVnfCatalogArtifact() throws IOException, UnsupportedEncodingException { String examplePath = "src/test/resources/imagedataexample.json"; byte[] encoded = Files.readAllBytes(Paths.get(examplePath)); List<Artifact> artifacts = new ArrayList<Artifact>(); artifacts.add(new VnfCatalogArtifact(new String(encoded, "utf-8"))); + return artifacts; + } - assertTrue(vnfCAH.pushArtifacts(artifacts, "test", new ArrayList<Artifact>(), mockRestClient)); + /** + * Always return CREATED (success) for a PUT operation. + */ + private void mockPutOperations() { + OperationResult mockPutResp = mock(OperationResult.class); + when(mockPutResp.getResultCode()).thenReturn(Response.Status.CREATED.getStatusCode()); + when(mockRestClient.putResource(Mockito.anyString(), Mockito.anyString(), Mockito.anyString(), + Mockito.any(MediaType.class))).thenReturn(mockPutResp); + } + private void assertPutOperationsSucceeded() { // Only two of the VNF images should be pushed ArgumentCaptor<String> argument = ArgumentCaptor.forClass(String.class); - AaiRestClient r = Mockito.verify(mockRestClient, Mockito.times(2)); - r.putResource(Mockito.anyString(), argument.capture(), Mockito.anyString(), Mockito.any(MediaType.class)); - assertTrue(argument.getAllValues().get(0).contains("3.16.9")); - assertTrue(argument.getAllValues().get(0).contains("VM00")); - assertTrue(argument.getAllValues().get(1).contains("3.16.1")); - assertTrue(argument.getAllValues().get(1).contains("VM01")); + AaiRestClient mockedClient = Mockito.verify(mockRestClient, Mockito.times(2)); + mockedClient.putResource(Mockito.anyString(), argument.capture(), Mockito.anyString(), + Mockito.any(MediaType.class)); + assertThat(argument.getAllValues().get(0), containsString("3.16.9")); + assertThat(argument.getAllValues().get(0), containsString("VM00")); + assertThat(argument.getAllValues().get(1), containsString("3.16.1")); + assertThat(argument.getAllValues().get(1), containsString("VM01")); } } diff --git a/src/test/java/org/onap/aai/modelloader/entity/catalog/TestVnfImageException.java b/src/test/java/org/onap/aai/modelloader/entity/catalog/TestVnfImageException.java index a41ddf9..c8b14f7 100644 --- a/src/test/java/org/onap/aai/modelloader/entity/catalog/TestVnfImageException.java +++ b/src/test/java/org/onap/aai/modelloader/entity/catalog/TestVnfImageException.java @@ -1,5 +1,5 @@ /** - * ============LICENSE_START======================================================= + * ============LICENSE_START======================================================= * org.onap.aai * ================================================================================ * Copyright © 2017-2018 AT&T Intellectual Property. All rights reserved. @@ -27,7 +27,7 @@ import static org.junit.Assert.assertThat; import org.junit.Test; /** - * Tests for NotificationDataImpl class + * Tests for NotificationDataImpl class. * */ public class TestVnfImageException { @@ -41,8 +41,7 @@ public class TestVnfImageException { assertThat(exception.getImageId(), is(equalTo("id2"))); assertThat(exception.getResultCode().get(), is(equalTo(1))); - Exception e = new Exception("message"); - exception = new VnfImageException(e); + exception = new VnfImageException(new Exception("message")); assertThat(exception.getImageId(), is(equalTo("message"))); } diff --git a/src/test/java/org/onap/aai/modelloader/entity/model/ModelArtifactParserTest.java b/src/test/java/org/onap/aai/modelloader/entity/model/ModelArtifactParserTest.java deleted file mode 100644 index 84a4313..0000000 --- a/src/test/java/org/onap/aai/modelloader/entity/model/ModelArtifactParserTest.java +++ /dev/null @@ -1,122 +0,0 @@ -/** - * ============LICENSE_START======================================================= - * org.onap.aai - * ================================================================================ - * Copyright © 2017-2018 AT&T Intellectual Property. All rights reserved. - * Copyright © 2017-2018 European Software Marketing Ltd. - * ================================================================================ - * 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.aai.modelloader.entity.model; - -import static org.junit.Assert.assertTrue; - -import java.nio.file.Files; -import java.nio.file.Paths; -import java.util.List; -import org.junit.Test; -import org.onap.aai.modelloader.entity.Artifact; - -public class ModelArtifactParserTest { - - @Test - public void testParseModelFileNoDeps() throws Exception { - final String MODEL_FILE = "src/test/resources/models/l3-network-widget.xml"; - - try { - String fileString = new String(Files.readAllBytes(Paths.get(MODEL_FILE))); - - ModelArtifactParser parser = new ModelArtifactParser(); - List<Artifact> modelList = parser.parse(fileString, "test-artifact"); - - assertTrue(modelList.size() == 1); - - ModelArtifact model = (ModelArtifact) modelList.get(0); - System.out.println(model.toString()); - - assertTrue(model.getModelInvariantId().equalsIgnoreCase("3d560d81-57d0-438b-a2a1-5334dba0651a")); - assertTrue(model.getModelNamespace().equalsIgnoreCase("http://org.openecomp.aai.inventory/v9")); - assertTrue(model.getModelNamespaceVersion().equalsIgnoreCase("v9")); - assertTrue(model.getType().toString().equalsIgnoreCase("MODEL")); - System.out.println(model.getDependentModelIds().size()); - assertTrue(model.getDependentModelIds().size() == 0); - } catch (Exception e) { - e.printStackTrace(); - assertTrue(false); - } - } - - @Test - public void testParseModelFileDeps() throws Exception { - final String MODEL_FILE = "src/test/resources/models/AAI-stellService-service-1.xml"; - - try { - String fileString = new String(Files.readAllBytes(Paths.get(MODEL_FILE))); - - ModelArtifactParser parser = new ModelArtifactParser(); - List<Artifact> modelList = parser.parse(fileString, "test-artifact"); - - assertTrue(modelList.size() == 1); - - ModelArtifact model = (ModelArtifact) modelList.get(0); - System.out.println(model.toString()); - - assertTrue(model.getModelInvariantId().equalsIgnoreCase("fedf9da3-6a74-4813-8fa2-221a98b0e7ad")); - assertTrue(model.getModelVerId().equalsIgnoreCase("e0373537-7f66-4094-9939-e2f5de6ff5f6")); - assertTrue(model.getType().toString().equalsIgnoreCase("MODEL")); - assertTrue(model.getDependentModelIds().size() == 3); - assertTrue(model.getDependentModelIds() - .contains("5c12984d-db0f-4300-a0e0-9791775cc40f|88bdbadf-db8a-490f-881e-c8effcbc3f66")); - assertTrue(model.getDependentModelIds() - .contains("959b7c09-9f34-4e5f-8b63-505381db176e|374d0899-bbc2-4403-9320-fe9bebef75c6")); - } catch (Exception e) { - e.printStackTrace(); - assertTrue(false); - } - } - - @Test - public void testParseModelFileInvalidArtifact() throws Exception { - final String MODEL_FILE = "src/test/resources/models/invalid-model.xml"; - - try { - String fileString = new String(Files.readAllBytes(Paths.get(MODEL_FILE))); - - ModelArtifactParser parser = new ModelArtifactParser(); - List<Artifact> modelList = parser.parse(fileString, "test-artifact"); - - assertTrue(modelList == null || modelList.isEmpty()); - } catch (Exception e) { - e.printStackTrace(); - assertTrue(false); - } - } - - @Test - public void testParseModelFileIncompleteArtifact() throws Exception { - final String MODEL_FILE = "src/test/resources/models/incomplete-model.xml"; - - try { - String fileString = new String(Files.readAllBytes(Paths.get(MODEL_FILE))); - - ModelArtifactParser parser = new ModelArtifactParser(); - List<Artifact> modelList = parser.parse(fileString, "test-artifact"); - - assertTrue(modelList == null || modelList.isEmpty()); - } catch (Exception e) { - e.printStackTrace(); - assertTrue(false); - } - } -} diff --git a/src/test/java/org/onap/aai/modelloader/entity/model/ModelSorterTest.java b/src/test/java/org/onap/aai/modelloader/entity/model/ModelSorterTest.java index d1d54b7..8f4bf8d 100644 --- a/src/test/java/org/onap/aai/modelloader/entity/model/ModelSorterTest.java +++ b/src/test/java/org/onap/aai/modelloader/entity/model/ModelSorterTest.java @@ -1,5 +1,5 @@ /** - * ============LICENSE_START======================================================= + * ============LICENSE_START======================================================= * org.onap.aai * ================================================================================ * Copyright © 2017-2018 AT&T Intellectual Property. All rights reserved. @@ -24,6 +24,7 @@ import static org.hamcrest.CoreMatchers.equalTo; import static org.hamcrest.CoreMatchers.is; import static org.hamcrest.CoreMatchers.not; import static org.hamcrest.CoreMatchers.nullValue; +import static org.hamcrest.Matchers.isEmptyString; import static org.junit.Assert.assertThat; import java.util.ArrayList; @@ -40,17 +41,18 @@ public class ModelSorterTest { ModelArtifact model = buildTestModel(); ModelSorter.Node nodeA = new ModelSorter.Node(model); ModelSorter.Node nodeB = new ModelSorter.Node(model); - ModelSorter.Node nodeC = new ModelSorter.Node(model); ModelSorter.Edge edgeA = new ModelSorter.Edge(nodeA, nodeB); - ModelSorter.Edge edgeB = new ModelSorter.Edge(nodeA, nodeB); - ModelSorter.Edge edgeC = new ModelSorter.Edge(nodeB, nodeA); - ModelSorter.Edge edgeD = new ModelSorter.Edge(nodeA, nodeC); assertThat(edgeA, is(equalTo(edgeA))); assertThat(edgeA, is(not(equalTo(null)))); assertThat(edgeA, is(not(equalTo(model)))); + ModelSorter.Edge edgeB = new ModelSorter.Edge(nodeA, nodeB); + ModelSorter.Edge edgeC = new ModelSorter.Edge(nodeB, nodeA); + + ModelSorter.Node nodeC = new ModelSorter.Node(model); + ModelSorter.Edge edgeD = new ModelSorter.Edge(nodeA, nodeC); assertThat(edgeA, is(equalTo(edgeB))); assertThat(edgeA, is(not(equalTo(edgeC)))); assertThat(edgeA, is(not(equalTo(edgeD)))); @@ -60,18 +62,32 @@ public class ModelSorterTest { public void nodeEquality() throws BabelArtifactParsingException { ModelArtifact model = buildTestModel(); ModelSorter.Node nodeA = new ModelSorter.Node(model); - ModelSorter.Node nodeB = new ModelSorter.Node(model); assertThat(nodeA, is(equalTo(nodeA))); assertThat(nodeA, is(not(equalTo(null)))); assertThat(nodeA, is(not(equalTo(model)))); + ModelSorter.Node nodeB = new ModelSorter.Node(model); assertThat(nodeA, is(equalTo(nodeB))); assertThat(nodeA.toString(), is(equalTo(nodeB.toString()))); assertThat(nodeA, is(not(equalTo(new ModelSorter.Node(new ModelArtifact()))))); } @Test + public void testToString() throws BabelArtifactParsingException { + ModelArtifact model = buildTestModel(); + + ModelSorter.Node nodeA = new ModelSorter.Node(model); + assertThat(nodeA.toString(), not(isEmptyString())); + + ModelSorter.Node nodeB = new ModelSorter.Node(model); + nodeA.addEdge(nodeB); + assertThat(nodeA.toString(), not(isEmptyString())); + assertThat(nodeB.toString(), not(isEmptyString())); + + } + + @Test public void noModels() throws BabelArtifactParsingException { assertThat(new ModelSorter().sort(null), is(nullValue())); assertThat(new ModelSorter().sort(Collections.emptyList()).size(), is(0)); @@ -84,20 +100,32 @@ public class ModelSorterTest { @Test public void multipleModels() throws BabelArtifactParsingException { - Artifact a = buildTestModel("aaaa", "mvaaaa", "cccc|mvcccc"); - Artifact b = buildTestModel("bbbb", "mvbbbb", "aaaa|mvaaaa"); - Artifact c = buildTestModel("cccc", "mvcccc"); - List<Artifact> expected = Arrays.asList(c, a, b); - assertThat(new ModelSorter().sort(Arrays.asList(a, b, c)), is(expected)); + Artifact artA = buildTestModel("aaaa", "mvaaaa", "cccc|mvcccc"); + Artifact artB = buildTestModel("bbbb", "mvbbbb", "aaaa|mvaaaa"); + Artifact artC = buildTestModel("cccc", "mvcccc"); + List<Artifact> expected = Arrays.asList(artC, artA, artB); + assertThat(new ModelSorter().sort(Arrays.asList(artA, artB, artC)), is(expected)); + } + + + @Test + public void multipleModelsWithMultipleIncomingEdges() throws BabelArtifactParsingException { + ModelArtifact artA = buildTestModel("aaaa", "mvaaaa", "cccc|mvcccc"); + Artifact artB = buildTestModel("bbbb", "mvbbbb", "aaaa|mvaaaa"); + Artifact artC = buildTestModel("cccc", "mvcccc"); + Artifact artD = buildTestModel("dddd", "mvdddd", "cccc|mvcccc"); + artA.addDependentModelId("dddd|mvdddd"); + List<Artifact> expected = Arrays.asList(artC, artD, artA, artB); + assertThat(new ModelSorter().sort(Arrays.asList(artA, artB, artC, artD)), is(expected)); } @Test public void multipleModelsAndNamedQueries() throws BabelArtifactParsingException { - Artifact a = buildTestModel("aaaa", "1111", "cccc|2222"); + Artifact artifact = buildTestModel("aaaa", "1111", "cccc|2222"); Artifact nq1 = buildTestNamedQuery("nq1", "aaaa|1111"); Artifact nq2 = buildTestNamedQuery("nqw", "existing-model"); - List<Artifact> expected = Arrays.asList(a, nq2, nq1); - assertThat(new ModelSorter().sort(Arrays.asList(nq1, nq2, a)), is(expected)); + List<Artifact> expected = Arrays.asList(artifact, nq2, nq1); + assertThat(new ModelSorter().sort(Arrays.asList(nq1, nq2, artifact)), is(expected)); } @Test(expected = BabelArtifactParsingException.class) diff --git a/src/test/java/org/onap/aai/modelloader/entity/model/TestModelArtifactHandler.java b/src/test/java/org/onap/aai/modelloader/entity/model/TestModelArtifactHandler.java index 82990de..2a951a8 100644 --- a/src/test/java/org/onap/aai/modelloader/entity/model/TestModelArtifactHandler.java +++ b/src/test/java/org/onap/aai/modelloader/entity/model/TestModelArtifactHandler.java @@ -1,5 +1,5 @@ /** - * ============LICENSE_START======================================================= + * ============LICENSE_START======================================================= * org.onap.aai * ================================================================================ * Copyright © 2017-2018 AT&T Intellectual Property. All rights reserved. diff --git a/src/test/java/org/onap/aai/modelloader/entity/model/TestModelArtifactParser.java b/src/test/java/org/onap/aai/modelloader/entity/model/TestModelArtifactParser.java new file mode 100644 index 0000000..aef0acc --- /dev/null +++ b/src/test/java/org/onap/aai/modelloader/entity/model/TestModelArtifactParser.java @@ -0,0 +1,102 @@ +/** + * ============LICENSE_START======================================================= + * org.onap.aai + * ================================================================================ + * Copyright © 2017-2018 AT&T Intellectual Property. All rights reserved. + * Copyright © 2017-2018 European Software Marketing Ltd. + * ================================================================================ + * 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.aai.modelloader.entity.model; + +import static org.hamcrest.CoreMatchers.is; +import static org.hamcrest.CoreMatchers.not; +import static org.hamcrest.CoreMatchers.nullValue; +import static org.hamcrest.text.IsEqualIgnoringCase.equalToIgnoringCase; +import static org.junit.Assert.assertThat; + +import java.nio.file.Files; +import java.nio.file.Paths; +import java.util.List; +import org.junit.Test; +import org.onap.aai.modelloader.entity.Artifact; +import org.springframework.util.CollectionUtils; + +public class TestModelArtifactParser { + + private static final String MODEL_FILE = "src/test/resources/models/l3-network-widget.xml"; + private static final String MODEL_FILE_SERVICE = "src/test/resources/models/AAI-stellService-service-1.xml"; + private static final String MODEL_FILE_INCOMPLETE = "src/test/resources/models/incomplete-model.xml"; + private static final String MODEL_FILE_INVALID = "src/test/resources/models/invalid-model.xml"; + + @Test + public void testParseModelFileNoDeps() throws Exception { + String fileString = new String(Files.readAllBytes(Paths.get(MODEL_FILE))); + + ModelArtifactParser parser = new ModelArtifactParser(); + List<Artifact> modelList = parser.parse(fileString, "test-artifact"); + + assertThat(modelList.size(), is(1)); + + ModelArtifact model = (ModelArtifact) modelList.get(0); + assertThat(model.toString(), is(not(nullValue()))); + + assertThat(model.getModelInvariantId(), equalToIgnoringCase("3d560d81-57d0-438b-a2a1-5334dba0651a")); + assertThat(model.getModelNamespace(), equalToIgnoringCase("http://org.openecomp.aai.inventory/v9")); + assertThat(model.getModelNamespaceVersion(), equalToIgnoringCase("v9")); + assertThat(model.getType().toString(), equalToIgnoringCase("MODEL")); + assertThat(model.getDependentModelIds().size(), is(0)); + } + + @Test + public void testParseModelFileDeps() throws Exception { + String fileString = new String(Files.readAllBytes(Paths.get(MODEL_FILE_SERVICE))); + + ModelArtifactParser parser = new ModelArtifactParser(); + List<Artifact> modelList = parser.parse(fileString, "test-artifact"); + + assertThat(modelList.size(), is(1)); + + ModelArtifact model = (ModelArtifact) modelList.get(0); + assertThat(model.toString(), is(not(nullValue()))); + assertThat(model.getModelInvariantId(), equalToIgnoringCase("fedf9da3-6a74-4813-8fa2-221a98b0e7ad")); + assertThat(model.getModelVerId(), equalToIgnoringCase("e0373537-7f66-4094-9939-e2f5de6ff5f6")); + assertThat(model.getType().toString(), equalToIgnoringCase("MODEL")); + assertThat(model.getDependentModelIds().size(), is(3)); + assertThat(model.getDependentModelIds() + .contains("5c12984d-db0f-4300-a0e0-9791775cc40f|88bdbadf-db8a-490f-881e-c8effcbc3f66"), is(true)); + assertThat(model.getDependentModelIds() + .contains("959b7c09-9f34-4e5f-8b63-505381db176e|374d0899-bbc2-4403-9320-fe9bebef75c6"), is(true)); + } + + @Test + public void testParseModelFileInvalidArtifact() throws Exception { + String fileString = new String(Files.readAllBytes(Paths.get(MODEL_FILE_INVALID))); + + ModelArtifactParser parser = new ModelArtifactParser(); + List<Artifact> modelList = parser.parse(fileString, "test-artifact"); + + assertThat(CollectionUtils.isEmpty(modelList), is(true)); + } + + @Test + public void testParseModelFileIncompleteArtifact() throws Exception { + String fileString = new String(Files.readAllBytes(Paths.get(MODEL_FILE_INCOMPLETE))); + + ModelArtifactParser parser = new ModelArtifactParser(); + List<Artifact> modelList = parser.parse(fileString, "test-artifact"); + + assertThat(CollectionUtils.isEmpty(modelList), is(true)); + } +} diff --git a/src/test/java/org/onap/aai/modelloader/entity/model/NamedQueryArtifactParserTest.java b/src/test/java/org/onap/aai/modelloader/entity/model/TestNamedQueryArtifactParser.java index fa2d2d7..f676f8e 100644 --- a/src/test/java/org/onap/aai/modelloader/entity/model/NamedQueryArtifactParserTest.java +++ b/src/test/java/org/onap/aai/modelloader/entity/model/TestNamedQueryArtifactParser.java @@ -1,5 +1,5 @@ /** - * ============LICENSE_START======================================================= + * ============LICENSE_START======================================================= * org.onap.aai * ================================================================================ * Copyright © 2017-2018 AT&T Intellectual Property. All rights reserved. @@ -20,6 +20,9 @@ */ package org.onap.aai.modelloader.entity.model; +import static org.hamcrest.CoreMatchers.not; +import static org.hamcrest.Matchers.isEmptyString; +import static org.junit.Assert.assertThat; import static org.junit.Assert.assertTrue; import java.nio.file.Files; @@ -28,12 +31,12 @@ import java.util.List; import org.junit.Test; import org.onap.aai.modelloader.entity.Artifact; -public class NamedQueryArtifactParserTest { +public class TestNamedQueryArtifactParser { + + private static final String MODEL_FILE = "src/test/resources/models/named-query-wan-connector.xml"; @Test public void testParseNamedQuery() throws Exception { - final String MODEL_FILE = "src/test/resources/models/named-query-wan-connector.xml"; - try { String fileString = new String(Files.readAllBytes(Paths.get(MODEL_FILE))); @@ -43,8 +46,8 @@ public class NamedQueryArtifactParserTest { assertTrue(modelList.size() == 1); NamedQueryArtifact model = (NamedQueryArtifact) modelList.get(0); - System.out.println(model.toString()); + assertThat(model.toString(), not(isEmptyString())); assertTrue(model.getNamedQueryUuid().equalsIgnoreCase("94cac189-8d88-4d63-a194-f44214e080ff")); assertTrue(model.getType().toString().equalsIgnoreCase("NAMED_QUERY")); assertTrue(model.getDependentModelIds().size() == 4); diff --git a/src/test/java/org/onap/aai/modelloader/extraction/ArtifactInfoExtractorTest.java b/src/test/java/org/onap/aai/modelloader/extraction/TestArtifactInfoExtractor.java index 8ae2c7e..3957c7c 100644 --- a/src/test/java/org/onap/aai/modelloader/extraction/ArtifactInfoExtractorTest.java +++ b/src/test/java/org/onap/aai/modelloader/extraction/TestArtifactInfoExtractor.java @@ -1,5 +1,5 @@ /** - * ============LICENSE_START======================================================= + * ============LICENSE_START======================================================= * org.onap.aai * ================================================================================ * Copyright © 2017-2018 AT&T Intellectual Property. All rights reserved. @@ -33,14 +33,14 @@ import org.junit.After; import org.junit.Before; import org.junit.Test; import org.onap.aai.modelloader.fixture.ArtifactInfoBuilder; -import org.onap.aai.modelloader.fixture.TestNotificationDataImpl; +import org.onap.aai.modelloader.fixture.MockNotificationDataImpl; import org.onap.sdc.api.notification.IArtifactInfo; import org.onap.sdc.api.notification.INotificationData; /** - * Tests {@link ArtifactInfoExtractor} + * Tests {@link ArtifactInfoExtractor}. */ -public class ArtifactInfoExtractorTest { +public class TestArtifactInfoExtractor { private ArtifactInfoExtractor extractor; @@ -65,7 +65,7 @@ public class ArtifactInfoExtractorTest { @Test public void extract_dataHasNullArtifacts() { - doEmptyArtifactsTest(new TestNotificationDataImpl()); + doEmptyArtifactsTest(new MockNotificationDataImpl()); } @Test diff --git a/src/test/java/org/onap/aai/modelloader/fixture/ArtifactInfoBuilder.java b/src/test/java/org/onap/aai/modelloader/fixture/ArtifactInfoBuilder.java index aa475f3..a22e46f 100644 --- a/src/test/java/org/onap/aai/modelloader/fixture/ArtifactInfoBuilder.java +++ b/src/test/java/org/onap/aai/modelloader/fixture/ArtifactInfoBuilder.java @@ -1,5 +1,5 @@ /** - * ============LICENSE_START======================================================= + * ============LICENSE_START======================================================= * org.onap.aai * ================================================================================ * Copyright © 2017-2018 AT&T Intellectual Property. All rights reserved. @@ -42,12 +42,12 @@ public class ArtifactInfoBuilder { */ public static IArtifactInfo build(final String type, final String name, final String description, final String version) { - IArtifactInfo artifact = new ArtifactInfoImpl(); + ArtifactInfoImpl artifact = new ArtifactInfoImpl(); - ((ArtifactInfoImpl) artifact).setArtifactType(type); - ((ArtifactInfoImpl) artifact).setArtifactName(name); - ((ArtifactInfoImpl) artifact).setArtifactDescription(description); - ((ArtifactInfoImpl) artifact).setArtifactVersion(version); + artifact.setArtifactType(type); + artifact.setArtifactName(name); + artifact.setArtifactDescription(description); + artifact.setArtifactVersion(version); return artifact; } @@ -63,7 +63,7 @@ public class ArtifactInfoBuilder { * <p/> * * @param artifactInfoBits a two dimensional array of data used to build the artifacts - * @return List<IArtifactInfo> a list of artifacts built from the given array of info + * @return List<IArtifactInfo> a list of artifacts built from the given array of info */ static List<IArtifactInfo> buildArtifacts(final String[][] artifactInfoBits) { List<IArtifactInfo> artifacts = new ArrayList<>(); diff --git a/src/test/java/org/onap/aai/modelloader/fixture/TestNotificationDataImpl.java b/src/test/java/org/onap/aai/modelloader/fixture/MockNotificationDataImpl.java index a7defdf..7851690 100644 --- a/src/test/java/org/onap/aai/modelloader/fixture/TestNotificationDataImpl.java +++ b/src/test/java/org/onap/aai/modelloader/fixture/MockNotificationDataImpl.java @@ -1,5 +1,5 @@ /** - * ============LICENSE_START======================================================= + * ============LICENSE_START======================================================= * org.onap.aai * ================================================================================ * Copyright © 2017-2018 AT&T Intellectual Property. All rights reserved. @@ -28,15 +28,15 @@ import org.onap.sdc.api.notification.IResourceInstance; /** * This class is an implementation of INotificationData for test purposes. */ -public class TestNotificationDataImpl implements INotificationData { +public class MockNotificationDataImpl implements INotificationData { - private String distributionID; + private String distributionId; private List<IResourceInstance> resources; private List<IArtifactInfo> serviceArtifacts; @Override public String getDistributionID() { - return distributionID; + return distributionId; } @Override @@ -70,7 +70,7 @@ public class TestNotificationDataImpl implements INotificationData { } @Override - public IArtifactInfo getArtifactMetadataByUUID(String s) { + public IArtifactInfo getArtifactMetadataByUUID(String uuid) { return null; } @@ -87,8 +87,8 @@ public class TestNotificationDataImpl implements INotificationData { this.serviceArtifacts = serviceArtifacts; } - public void setDistributionID(String distributionID) { - this.distributionID = distributionID; + public void setDistributionId(String distributionId) { + this.distributionId = distributionId; } @Override diff --git a/src/test/java/org/onap/aai/modelloader/fixture/NotificationDataFixtureBuilder.java b/src/test/java/org/onap/aai/modelloader/fixture/NotificationDataFixtureBuilder.java index 44f59a3..133a7af 100644 --- a/src/test/java/org/onap/aai/modelloader/fixture/NotificationDataFixtureBuilder.java +++ b/src/test/java/org/onap/aai/modelloader/fixture/NotificationDataFixtureBuilder.java @@ -1,5 +1,5 @@ /** - * ============LICENSE_START======================================================= + * ============LICENSE_START======================================================= * org.onap.aai * ================================================================================ * Copyright © 2017-2018 AT&T Intellectual Property. All rights reserved. @@ -32,17 +32,19 @@ import org.onap.sdc.api.notification.IResourceInstance; public class NotificationDataFixtureBuilder { private static final String DESCRIPTION_OF_RESOURCE = "description of resource"; - private static final INotificationData EMPTY_NOTIFICATION_DATA = new TestNotificationDataImpl(); + private static final MockNotificationDataImpl EMPTY_NOTIFICATION_DATA = new MockNotificationDataImpl(); private static final String MODEL_QUERY_SPEC = "MODEL_QUERY_SPEC"; - private static final INotificationData NOTIFICATION_DATA_WITH_CATALOG_FILE = new TestNotificationDataImpl(); - private static final INotificationData NOTIFICATION_DATA_WITH_MODEL_QUERY_SPEC = new TestNotificationDataImpl(); - private static final INotificationData NOTIFICATION_DATA_WITH_INVALID_TYPE = new TestNotificationDataImpl(); - private static final INotificationData NOTIFICATION_DATA_WITH_ONE_OF_EACH = new TestNotificationDataImpl(); - private static final INotificationData NOTIFICATION_DATA_WITH_ONE_RESOURCE = new TestNotificationDataImpl(); - private static final INotificationData NOTIFICATION_DATA_WITH_ONE_SERVICE = new TestNotificationDataImpl(); - private static final INotificationData NOTIFICATION_DATA_WITH_ONE_SERVICE_AND_RESOURCES = - new TestNotificationDataImpl(); - private static final INotificationData NOTIFICATION_DATA_WITH_TOSCA_CSAR_FILE = new TestNotificationDataImpl(); + private static final MockNotificationDataImpl NOTIFICATION_DATA_WITH_CATALOG_FILE = new MockNotificationDataImpl(); + private static final MockNotificationDataImpl NOTIFICATION_DATA_WITH_MODEL_QUERY_SPEC = + new MockNotificationDataImpl(); + private static final MockNotificationDataImpl NOTIFICATION_DATA_WITH_INVALID_TYPE = new MockNotificationDataImpl(); + private static final MockNotificationDataImpl NOTIFICATION_DATA_WITH_ONE_OF_EACH = new MockNotificationDataImpl(); + private static final MockNotificationDataImpl NOTIFICATION_DATA_WITH_ONE_RESOURCE = new MockNotificationDataImpl(); + private static final MockNotificationDataImpl NOTIFICATION_DATA_WITH_ONE_SERVICE = new MockNotificationDataImpl(); + private static final MockNotificationDataImpl NOTIFICATION_DATA_WITH_ONE_SERVICE_AND_RESOURCES = + new MockNotificationDataImpl(); + private static final MockNotificationDataImpl NOTIFICATION_DATA_WITH_TOSCA_CSAR_FILE = + new MockNotificationDataImpl(); private static final String RESOURCE = "resource"; private static final String TOSCA_CSAR = "TOSCA_CSAR"; private static final String INVALID_TYPE = "INVALID_TYPE"; @@ -61,8 +63,8 @@ public class NotificationDataFixtureBuilder { } private static void buildEmptyNotificationData() { - ((TestNotificationDataImpl) EMPTY_NOTIFICATION_DATA).setResources(new ArrayList<>()); - ((TestNotificationDataImpl) EMPTY_NOTIFICATION_DATA).setServiceArtifacts(new ArrayList<>()); + EMPTY_NOTIFICATION_DATA.setResources(new ArrayList<>()); + EMPTY_NOTIFICATION_DATA.setServiceArtifacts(new ArrayList<>()); } private static void buildWithCatalogFile() { @@ -74,7 +76,7 @@ public class NotificationDataFixtureBuilder { List<IArtifactInfo> artifacts = ArtifactInfoBuilder.buildArtifacts(new String[][] {{"R", RESOURCE, DESCRIPTION_OF_RESOURCE, VERSION}}); resources.add(ResourceInstanceBuilder.build(artifacts)); - ((TestNotificationDataImpl) NOTIFICATION_DATA_WITH_ONE_RESOURCE).setResources(resources); + NOTIFICATION_DATA_WITH_ONE_RESOURCE.setResources(resources); } private static void buildWithModelQuerySpec() { @@ -96,18 +98,18 @@ public class NotificationDataFixtureBuilder { artifacts = ArtifactInfoBuilder .buildArtifacts(new String[][] {{MODEL_QUERY_SPEC, "resource2", "description of resource2", VERSION}}); resources.add(ResourceInstanceBuilder.build(artifacts)); - ((TestNotificationDataImpl) NOTIFICATION_DATA_WITH_ONE_OF_EACH).setResources(resources); + NOTIFICATION_DATA_WITH_ONE_OF_EACH.setResources(resources); } private static void buildWithOneService() { buildService("S", NOTIFICATION_DATA_WITH_ONE_SERVICE); } - private static void buildService(String type, INotificationData data) { + private static void buildService(String type, MockNotificationDataImpl data) { List<IArtifactInfo> artifacts = new ArrayList<>(); artifacts.add(ArtifactInfoBuilder.build(type, "service", "description of service", "s1.0")); - ((TestNotificationDataImpl) data).setDistributionID("ID"); - ((TestNotificationDataImpl) data).setServiceArtifacts(artifacts); + data.setDistributionId("ID"); + data.setServiceArtifacts(artifacts); } private static void buildWithOneServiceAndResources() { @@ -117,7 +119,7 @@ public class NotificationDataFixtureBuilder { List<IArtifactInfo> artifacts = ArtifactInfoBuilder .buildArtifacts(new String[][] {{TOSCA_CSAR, RESOURCE, "description of resource", VERSION}}); resources.add(ResourceInstanceBuilder.build(artifacts)); - ((TestNotificationDataImpl) NOTIFICATION_DATA_WITH_ONE_SERVICE_AND_RESOURCES).setResources(resources); + NOTIFICATION_DATA_WITH_ONE_SERVICE_AND_RESOURCES.setResources(resources); } private static void buildWithToscaCsarFile() { diff --git a/src/test/java/org/onap/aai/modelloader/fixture/ResourceInstanceBuilder.java b/src/test/java/org/onap/aai/modelloader/fixture/ResourceInstanceBuilder.java index 01e00f8..b88614b 100644 --- a/src/test/java/org/onap/aai/modelloader/fixture/ResourceInstanceBuilder.java +++ b/src/test/java/org/onap/aai/modelloader/fixture/ResourceInstanceBuilder.java @@ -1,5 +1,5 @@ /** - * ============LICENSE_START======================================================= + * ============LICENSE_START======================================================= * org.onap.aai * ================================================================================ * Copyright © 2017-2018 AT&T Intellectual Property. All rights reserved. @@ -36,10 +36,8 @@ class ResourceInstanceBuilder { * @return IResourceInstance implementation of IResourceInstance for test purposes */ static IResourceInstance build(final List<IArtifactInfo> artifacts) { - IResourceInstance instance = new TestResourceInstanceImpl(); - - ((TestResourceInstanceImpl) instance).setArtifacts(artifacts); - + TestResourceInstanceImpl instance = new TestResourceInstanceImpl(); + instance.setArtifacts(artifacts); return instance; } } diff --git a/src/test/java/org/onap/aai/modelloader/fixture/TestResourceInstanceImpl.java b/src/test/java/org/onap/aai/modelloader/fixture/TestResourceInstanceImpl.java index 7eaebb5..0f2751b 100644 --- a/src/test/java/org/onap/aai/modelloader/fixture/TestResourceInstanceImpl.java +++ b/src/test/java/org/onap/aai/modelloader/fixture/TestResourceInstanceImpl.java @@ -1,5 +1,5 @@ /** - * ============LICENSE_START======================================================= + * ============LICENSE_START======================================================= * org.onap.aai * ================================================================================ * Copyright © 2017-2018 AT&T Intellectual Property. All rights reserved. diff --git a/src/test/java/org/onap/aai/modelloader/notification/ArtifactDeploymentManagerTest.java b/src/test/java/org/onap/aai/modelloader/notification/TestArtifactDeploymentManager.java index 9d6f3c4..d8cb19a 100644 --- a/src/test/java/org/onap/aai/modelloader/notification/ArtifactDeploymentManagerTest.java +++ b/src/test/java/org/onap/aai/modelloader/notification/TestArtifactDeploymentManager.java @@ -1,5 +1,5 @@ /** - * ============LICENSE_START======================================================= + * ============LICENSE_START======================================================= * org.onap.aai * ================================================================================ * Copyright © 2017-2018 AT&T Intellectual Property. All rights reserved. @@ -20,7 +20,8 @@ */ package org.onap.aai.modelloader.notification; -import static org.junit.Assert.assertFalse; +import static org.hamcrest.CoreMatchers.is; +import static org.junit.Assert.assertThat; import static org.mockito.Matchers.any; import static org.mockito.Matchers.eq; import static org.mockito.Mockito.mock; @@ -45,14 +46,15 @@ import org.onap.aai.modelloader.entity.catalog.VnfCatalogArtifactHandler; import org.onap.aai.modelloader.entity.model.BabelArtifactParsingException; import org.onap.aai.modelloader.entity.model.ModelArtifactHandler; import org.onap.aai.modelloader.extraction.InvalidArchiveException; +import org.onap.aai.modelloader.fixture.NotificationDataFixtureBuilder; +import org.onap.aai.modelloader.service.ArtifactDeploymentManager; import org.onap.aai.modelloader.util.ArtifactTestUtils; -import org.onap.sdc.api.IDistributionClient; import org.onap.sdc.api.notification.INotificationData; /** - * Tests {@link ArtifactDeploymentManager } + * Tests {@link ArtifactDeploymentManager}. */ -public class ArtifactDeploymentManagerTest { +public class TestArtifactDeploymentManager { private static final String CONFIG_FILE = "model-loader.properties"; private static final String SHOULD_HAVE_RETURNED_FALSE = "This should have returned false"; @@ -60,39 +62,53 @@ public class ArtifactDeploymentManagerTest { private Properties configProperties; private ArtifactDeploymentManager manager; - private IDistributionClient mockDistributionClient; private ModelArtifactHandler mockModelArtifactHandler; - private NotificationPublisher mockNotificationPublisher; private VnfCatalogArtifactHandler mockVnfCatalogArtifactHandler; @Before public void setup() throws IOException { configProperties = new Properties(); configProperties.load(this.getClass().getClassLoader().getResourceAsStream(CONFIG_FILE)); - ModelLoaderConfig config = new ModelLoaderConfig(configProperties, null); - mockDistributionClient = mock(IDistributionClient.class); mockModelArtifactHandler = mock(ModelArtifactHandler.class); - mockNotificationPublisher = mock(NotificationPublisher.class); mockVnfCatalogArtifactHandler = mock(VnfCatalogArtifactHandler.class); - manager = new ArtifactDeploymentManager(mockDistributionClient, config); + manager = new ArtifactDeploymentManager(new ModelLoaderConfig(configProperties, null)); Whitebox.setInternalState(manager, "modelArtifactHandler", mockModelArtifactHandler); - Whitebox.setInternalState(manager, "notificationPublisher", mockNotificationPublisher); Whitebox.setInternalState(manager, "vnfCatalogArtifactHandler", mockVnfCatalogArtifactHandler); } @After public void tearDown() { configProperties = null; - mockDistributionClient = null; mockModelArtifactHandler = null; - mockNotificationPublisher = null; mockVnfCatalogArtifactHandler = null; manager = null; } + @Test + public void deploy_csarDeploymentsFailed() throws IOException, BabelArtifactParsingException { + INotificationData data = NotificationDataFixtureBuilder.getNotificationDataWithToscaCsarFile(); + byte[] xml = new ArtifactTestUtils().loadResource("convertedYmls/AAI-SCP-Test-VSP-resource-1.0.xml"); + List<BabelArtifact> toscaArtifacts = setupTest(xml, data); + List<Artifact> modelArtifacts = new BabelArtifactConverter().convertToModel(toscaArtifacts); + + when(mockModelArtifactHandler.pushArtifacts(eq(modelArtifacts), eq(data.getDistributionID()), any(), any())) + .thenReturn(false); + + assertThat(SHOULD_HAVE_RETURNED_FALSE, manager.deploy(data, modelArtifacts, new ArrayList<>()), is(false)); + + Mockito.verify(mockModelArtifactHandler).pushArtifacts(eq(modelArtifacts), eq(data.getDistributionID()), any(), + any()); + Mockito.verify(mockVnfCatalogArtifactHandler, Mockito.never()).pushArtifacts(eq(modelArtifacts), + eq(data.getDistributionID()), any(), any()); + Mockito.verify(mockModelArtifactHandler).rollback(eq(new ArrayList<Artifact>()), eq(data.getDistributionID()), + any()); + Mockito.verify(mockVnfCatalogArtifactHandler, Mockito.never()).rollback(eq(new ArrayList<Artifact>()), + eq(data.getDistributionID()), any()); + } + private List<BabelArtifact> setupTest(byte[] xml, INotificationData data) throws IOException { List<BabelArtifact> toscaArtifacts = new ArrayList<>(); org.onap.sdc.api.notification.IArtifactInfo artifactInfo = data.getServiceArtifacts().get(0); @@ -115,11 +131,8 @@ public class ArtifactDeploymentManagerTest { when(mockModelArtifactHandler.pushArtifacts(any(), any(), any(), any())).thenReturn(true); when(mockVnfCatalogArtifactHandler.pushArtifacts(eq(catalogFiles), eq(data.getDistributionID()), any(), any())) .thenReturn(false); - Mockito.doNothing().when(mockNotificationPublisher).publishDeployFailure(mockDistributionClient, data, - data.getServiceArtifacts().get(0)); - assertFalse(SHOULD_HAVE_RETURNED_FALSE, - manager.deploy(data, data.getServiceArtifacts(), new ArrayList<>(), catalogFiles)); + assertThat(SHOULD_HAVE_RETURNED_FALSE, manager.deploy(data, new ArrayList<>(), catalogFiles), is(false)); Mockito.verify(mockModelArtifactHandler).pushArtifacts(eq(new ArrayList<Artifact>()), eq(data.getDistributionID()), any(), any()); @@ -129,15 +142,27 @@ public class ArtifactDeploymentManagerTest { any()); Mockito.verify(mockVnfCatalogArtifactHandler).rollback(eq(new ArrayList<Artifact>()), eq(data.getDistributionID()), any()); - Mockito.verify(mockNotificationPublisher).publishDeployFailure(mockDistributionClient, data, - data.getServiceArtifacts().get(0)); } - private void doFailedCombinedTests(boolean modelsOK, boolean catalogsOK) + @Test + public void testNoArtifactsDeployed() throws IOException, BabelArtifactParsingException, InvalidArchiveException { + doFailedCombinedTests(false, false); + } + + @Test + public void testModelsNotDeployed() throws IOException, BabelArtifactParsingException, InvalidArchiveException { + doFailedCombinedTests(false, true); + } + + @Test + public void testCatalogsNotDeployed() throws IOException, BabelArtifactParsingException, InvalidArchiveException { + doFailedCombinedTests(true, false); + } + + private void doFailedCombinedTests(boolean modelsDeployed, boolean catalogsDeployed) throws IOException, BabelArtifactParsingException, InvalidArchiveException { INotificationData data = getNotificationDataWithOneOfEach(); - ArtifactTestUtils artifactTestUtils = new ArtifactTestUtils(); - byte[] xml = artifactTestUtils.loadResource("convertedYmls/AAI-SCP-Test-VSP-resource-1.0.xml"); + byte[] xml = new ArtifactTestUtils().loadResource("convertedYmls/AAI-SCP-Test-VSP-resource-1.0.xml"); List<BabelArtifact> toscaArtifacts = setupTest(xml, data); List<Artifact> modelArtifacts = new BabelArtifactConverter().convertToModel(toscaArtifacts); @@ -145,35 +170,25 @@ public class ArtifactDeploymentManagerTest { catalogFiles.add(new VnfCatalogArtifact("Some catalog content")); when(mockVnfCatalogArtifactHandler.pushArtifacts(eq(catalogFiles), eq(data.getDistributionID()), any(), any())) - .thenReturn(catalogsOK); + .thenReturn(catalogsDeployed); when(mockModelArtifactHandler.pushArtifacts(eq(modelArtifacts), eq(data.getDistributionID()), any(), any())) - .thenReturn(modelsOK); + .thenReturn(modelsDeployed); - Mockito.doNothing().when(mockNotificationPublisher).publishDeploySuccess(mockDistributionClient, data, - data.getServiceArtifacts().get(0)); - Mockito.doNothing().when(mockNotificationPublisher).publishDeployFailure(mockDistributionClient, data, - data.getServiceArtifacts().get(0)); - - assertFalse(SHOULD_HAVE_RETURNED_FALSE, - manager.deploy(data, data.getServiceArtifacts(), modelArtifacts, catalogFiles)); + assertThat(SHOULD_HAVE_RETURNED_FALSE, manager.deploy(data, modelArtifacts, catalogFiles), is(false)); // Catalog artifacts are only pushed if models are successful. Mockito.verify(mockModelArtifactHandler).pushArtifacts(eq(modelArtifacts), eq(data.getDistributionID()), any(), any()); - if (modelsOK) { + if (modelsDeployed) { Mockito.verify(mockVnfCatalogArtifactHandler).pushArtifacts(eq(catalogFiles), eq(data.getDistributionID()), any(), any()); } - if (modelsOK && catalogsOK) { - Mockito.verify(mockNotificationPublisher).publishDeploySuccess(mockDistributionClient, data, - data.getServiceArtifacts().get(0)); + if (modelsDeployed && catalogsDeployed) { Mockito.verify(mockModelArtifactHandler, Mockito.never()).rollback(any(), any(), any()); Mockito.verify(mockVnfCatalogArtifactHandler, Mockito.never()).rollback(any(), any(), any()); } else { - Mockito.verify(mockNotificationPublisher).publishDeployFailure(mockDistributionClient, data, - data.getServiceArtifacts().get(0)); - if (modelsOK) { + if (modelsDeployed) { Mockito.verify(mockModelArtifactHandler).rollback(eq(new ArrayList<Artifact>()), eq(data.getDistributionID()), any()); Mockito.verify(mockVnfCatalogArtifactHandler).rollback(eq(new ArrayList<Artifact>()), @@ -186,4 +201,35 @@ public class ArtifactDeploymentManagerTest { } } + /** + * Deploy both models and VNF images. + * + * @throws IOException + * @throws BabelArtifactParsingException + * @throws InvalidArchiveException + */ + @Test + public void testDeploySuccess() throws IOException, BabelArtifactParsingException, InvalidArchiveException { + INotificationData data = getNotificationDataWithOneOfEach(); + byte[] xml = new ArtifactTestUtils().loadResource("convertedYmls/AAI-SCP-Test-VSP-resource-1.0.xml"); + List<BabelArtifact> toscaArtifacts = setupTest(xml, data); + List<Artifact> modelArtifacts = new BabelArtifactConverter().convertToModel(toscaArtifacts); + + List<org.onap.aai.modelloader.entity.Artifact> catalogFiles = new ArrayList<>(); + catalogFiles.add(new VnfCatalogArtifact("Some catalog content")); + + when(mockVnfCatalogArtifactHandler.pushArtifacts(eq(catalogFiles), eq(data.getDistributionID()), any(), any())) + .thenReturn(true); + when(mockModelArtifactHandler.pushArtifacts(eq(modelArtifacts), eq(data.getDistributionID()), any(), any())) + .thenReturn(true); + + assertThat(manager.deploy(data, modelArtifacts, catalogFiles), is(true)); + + Mockito.verify(mockVnfCatalogArtifactHandler).pushArtifacts(eq(catalogFiles), eq(data.getDistributionID()), + any(), any()); + Mockito.verify(mockModelArtifactHandler).pushArtifacts(eq(modelArtifacts), eq(data.getDistributionID()), any(), + any()); + Mockito.verify(mockModelArtifactHandler, Mockito.never()).rollback(any(), any(), any()); + Mockito.verify(mockVnfCatalogArtifactHandler, Mockito.never()).rollback(any(), any(), any()); + } } diff --git a/src/test/java/org/onap/aai/modelloader/notification/ArtifactDownloadManagerTest.java b/src/test/java/org/onap/aai/modelloader/notification/TestArtifactDownloadManager.java index 2c02487..030a0ff 100644 --- a/src/test/java/org/onap/aai/modelloader/notification/ArtifactDownloadManagerTest.java +++ b/src/test/java/org/onap/aai/modelloader/notification/TestArtifactDownloadManager.java @@ -1,5 +1,5 @@ /** - * ============LICENSE_START======================================================= + * ============LICENSE_START======================================================= * org.onap.aai * ================================================================================ * Copyright © 2017-2018 AT&T Intellectual Property. All rights reserved. @@ -20,8 +20,10 @@ */ package org.onap.aai.modelloader.notification; -import static org.junit.Assert.assertFalse; -import static org.junit.Assert.assertTrue; +import static org.hamcrest.CoreMatchers.is; +import static org.hamcrest.CoreMatchers.not; +import static org.hamcrest.collection.IsEmptyCollection.empty; +import static org.junit.Assert.assertThat; import static org.mockito.Mockito.doNothing; import static org.mockito.Mockito.mock; import static org.mockito.Mockito.when; @@ -32,14 +34,10 @@ import static org.onap.aai.modelloader.fixture.NotificationDataFixtureBuilder.ge import static org.onap.aai.modelloader.fixture.NotificationDataFixtureBuilder.getNotificationDataWithToscaCsarFile; import java.io.IOException; -import java.security.KeyManagementException; -import java.security.KeyStoreException; -import java.security.NoSuchAlgorithmException; -import java.security.UnrecoverableKeyException; -import java.security.cert.CertificateException; import java.util.ArrayList; import java.util.List; import java.util.Properties; +import org.hamcrest.collection.IsEmptyCollection; import org.junit.After; import org.junit.Before; import org.junit.Test; @@ -48,10 +46,12 @@ import org.mockito.Mockito; import org.mockito.internal.util.reflection.Whitebox; import org.onap.aai.babel.service.data.BabelArtifact; import org.onap.aai.modelloader.config.ModelLoaderConfig; +import org.onap.aai.modelloader.entity.Artifact; import org.onap.aai.modelloader.entity.model.BabelArtifactParsingException; import org.onap.aai.modelloader.restclient.BabelServiceClient; -import org.onap.aai.modelloader.restclient.BabelServiceClient.BabelServiceException; -import org.onap.aai.modelloader.restclient.BabelServiceClientFactory; +import org.onap.aai.modelloader.restclient.BabelServiceClientException; +import org.onap.aai.modelloader.service.BabelServiceClientFactory; +import org.onap.aai.modelloader.service.HttpsBabelServiceClientFactory; import org.onap.aai.modelloader.util.ArtifactTestUtils; import org.onap.sdc.api.IDistributionClient; import org.onap.sdc.api.notification.IArtifactInfo; @@ -61,13 +61,9 @@ import org.onap.sdc.impl.DistributionClientDownloadResultImpl; import org.onap.sdc.utils.DistributionActionResultEnum; /** - * Tests {@link ArtifactDownloadManager} + * Tests {@link ArtifactDownloadManager}. */ -public class ArtifactDownloadManagerTest { - - private static final String FALSE_SHOULD_HAVE_BEEN_RETURNED = "A value of 'false' should have been returned"; - private static final String OOPS = "oops"; - private static final String TRUE_SHOULD_HAVE_BEEN_RETURNED = "A value of 'true' should have been returned"; +public class TestArtifactDownloadManager { private ArtifactDownloadManager downloadManager; private BabelServiceClient mockBabelClient; @@ -82,7 +78,7 @@ public class ArtifactDownloadManagerTest { mockDistributionClient = mock(IDistributionClient.class); mockNotificationPublisher = mock(NotificationPublisher.class); mockBabelArtifactConverter = mock(BabelArtifactConverter.class); - mockClientFactory = mock(BabelServiceClientFactory.class); + mockClientFactory = mock(HttpsBabelServiceClientFactory.class); when(mockClientFactory.create(Mockito.any())).thenReturn(mockBabelClient); Properties configProperties = new Properties(); @@ -101,61 +97,50 @@ public class ArtifactDownloadManagerTest { mockNotificationPublisher = null; } + /** + * Test downloading zero artifacts from SDC. + */ @Test - public void downloadArtifacts_emptyListSupplied() { - List<org.onap.aai.modelloader.entity.Artifact> modelFiles = new ArrayList<>(); - List<org.onap.aai.modelloader.entity.Artifact> catalogFiles = new ArrayList<>(); - - assertTrue(TRUE_SHOULD_HAVE_BEEN_RETURNED, downloadManager - .downloadArtifacts(getNotificationDataWithOneService(), new ArrayList<>(), modelFiles, catalogFiles)); - + public void testDownloadWithZeroArtifacts() { + List<Artifact> modelFiles = new ArrayList<>(); + List<Artifact> catalogFiles = new ArrayList<>(); + assertThat(downloadManager.downloadArtifacts(getNotificationDataWithOneService(), new ArrayList<>(), modelFiles, + catalogFiles), is(true)); + assertThat(modelFiles, is(empty())); + assertThat(catalogFiles, is(empty())); Mockito.verifyZeroInteractions(mockBabelClient, mockDistributionClient, mockNotificationPublisher, mockBabelArtifactConverter); } @Test - public void downloadArtifacts_artifactDownloadFails() { + public void testArtifactDownloadFails() { INotificationData data = getNotificationDataWithOneService(); IArtifactInfo artifact = data.getServiceArtifacts().get(0); - when(mockDistributionClient.download(artifact)) - .thenReturn(createDistributionClientDownloadResult(DistributionActionResultEnum.FAIL, OOPS, null)); + String errorMessage = "error msg"; + when(mockDistributionClient.download(artifact)).thenReturn( + createDistributionClientDownloadResult(DistributionActionResultEnum.FAIL, errorMessage, null)); doNothing().when(mockNotificationPublisher).publishDownloadFailure(mockDistributionClient, data, artifact, - OOPS); + errorMessage); - assertFalse(FALSE_SHOULD_HAVE_BEEN_RETURNED, - downloadManager.downloadArtifacts(data, data.getServiceArtifacts(), null, null)); + assertThat(downloadManager.downloadArtifacts(data, data.getServiceArtifacts(), null, null), is(false)); Mockito.verify(mockDistributionClient).download(artifact); - Mockito.verify(mockNotificationPublisher).publishDownloadFailure(mockDistributionClient, data, artifact, OOPS); + Mockito.verify(mockNotificationPublisher).publishDownloadFailure(mockDistributionClient, data, artifact, + errorMessage); Mockito.verifyZeroInteractions(mockBabelClient, mockBabelArtifactConverter); } - private IDistributionClientDownloadResult createDistributionClientDownloadResult( - DistributionActionResultEnum status, String message, byte[] payload) { - IDistributionClientDownloadResult downloadResult = new DistributionClientDownloadResultImpl(status, message); - - ((DistributionClientDownloadResultImpl) downloadResult).setArtifactPayload(payload); - - return downloadResult; - } - @Test - public void downloadArtifacts_noSuchAlgorithmExceptionFromCreatingBabelClient() throws Exception { - doCreateBabelClientFailureTest(NoSuchAlgorithmException.class); - } - - @SuppressWarnings("unchecked") - private void doCreateBabelClientFailureTest(Class<? extends Throwable> exception) throws Exception { - when(mockClientFactory.create(Mockito.any())).thenThrow(exception); + public void testErrorCreatingBabelClient() throws Exception { + when(mockClientFactory.create(Mockito.any())).thenThrow(new BabelServiceClientException(new Exception())); INotificationData data = getNotificationDataWithToscaCsarFile(); IArtifactInfo artifactInfo = data.getServiceArtifacts().get(0); setupValidDownloadCsarMocks(data, artifactInfo, new ArtifactTestUtils()); doNothing().when(mockNotificationPublisher).publishDeployFailure(mockDistributionClient, data, artifactInfo); - assertFalse(FALSE_SHOULD_HAVE_BEEN_RETURNED, - downloadManager.downloadArtifacts(data, data.getServiceArtifacts(), null, null)); + assertThat(downloadManager.downloadArtifacts(data, data.getServiceArtifacts(), null, null), is(false)); Mockito.verify(mockDistributionClient).download(artifactInfo); Mockito.verify(mockNotificationPublisher).publishDownloadSuccess(mockDistributionClient, data, artifactInfo); @@ -165,49 +150,17 @@ public class ArtifactDownloadManagerTest { } @Test - public void downloadArtifacts_keyStoreExceptionFromCreatingBabelClient() throws Exception { - doCreateBabelClientFailureTest(KeyStoreException.class); - } - - @Test - public void downloadArtifacts_certificateExceptionFromCreatingBabelClient() throws Exception { - doCreateBabelClientFailureTest(CertificateException.class); - } - - @Test - public void downloadArtifacts_iOExceptionFromCreatingBabelClient() throws Exception { - doCreateBabelClientFailureTest(IOException.class); - } - - @Test - public void downloadArtifacts_unrecoverableKeyExceptionFromCreatingBabelClient() throws Exception { - doCreateBabelClientFailureTest(UnrecoverableKeyException.class); - } - - @Test - public void downloadArtifacts_keyManagementExceptionFromCreatingBabelClient() throws Exception { - doCreateBabelClientFailureTest(KeyManagementException.class); - } - - /** - * Test disabled as exception handling needs to be reworked - * - * @throws IOException - */ - @SuppressWarnings("unchecked") - @Test - public void downloadArtifacts_invalidToscaCsarFile() throws IOException, BabelServiceException { + public void downloadArtifacts_invalidToscaCsarFile() throws IOException, BabelServiceClientException { INotificationData data = getNotificationDataWithToscaCsarFile(); IArtifactInfo artifact = data.getServiceArtifacts().get(0); when(mockDistributionClient.download(artifact)).thenReturn(createDistributionClientDownloadResult( DistributionActionResultEnum.SUCCESS, null, "This is not a valid Tosca CSAR File".getBytes())); doNothing().when(mockNotificationPublisher).publishDownloadSuccess(mockDistributionClient, data, artifact); when(mockBabelClient.postArtifact(Matchers.any(), Matchers.anyString(), Matchers.anyString(), - Matchers.anyString())).thenThrow(BabelServiceException.class); + Matchers.anyString())).thenThrow(new BabelServiceClientException("")); doNothing().when(mockNotificationPublisher).publishDeployFailure(mockDistributionClient, data, artifact); - assertFalse(FALSE_SHOULD_HAVE_BEEN_RETURNED, - downloadManager.downloadArtifacts(data, data.getServiceArtifacts(), null, null)); + assertThat(downloadManager.downloadArtifacts(data, data.getServiceArtifacts(), null, null), is(false)); Mockito.verify(mockDistributionClient).download(artifact); Mockito.verify(mockNotificationPublisher).publishDownloadSuccess(mockDistributionClient, data, artifact); @@ -230,8 +183,8 @@ public class ArtifactDownloadManagerTest { DistributionActionResultEnum.SUCCESS, null, "This is not a valid Model Query Spec".getBytes())); doNothing().when(mockNotificationPublisher).publishDownloadSuccess(mockDistributionClient, data, artifact); - assertFalse(FALSE_SHOULD_HAVE_BEEN_RETURNED, - downloadManager.downloadArtifacts(data, data.getServiceArtifacts(), modelArtifacts, null)); + assertThat(downloadManager.downloadArtifacts(data, data.getServiceArtifacts(), modelArtifacts, null), + is(false)); Mockito.verify(mockDistributionClient).download(artifact); Mockito.verify(mockNotificationPublisher).publishDownloadSuccess(mockDistributionClient, data, artifact); @@ -242,7 +195,7 @@ public class ArtifactDownloadManagerTest { @Test public void downloadArtifacts_validToscaCsarFile() - throws IOException, BabelServiceException, BabelArtifactParsingException { + throws IOException, BabelServiceClientException, BabelArtifactParsingException { INotificationData data = getNotificationDataWithToscaCsarFile(); IArtifactInfo artifactInfo = data.getServiceArtifacts().get(0); @@ -250,10 +203,9 @@ public class ArtifactDownloadManagerTest { List<org.onap.aai.modelloader.entity.Artifact> modelArtifacts = new ArrayList<>(); List<org.onap.aai.modelloader.entity.Artifact> catalogFiles = new ArrayList<>(); - assertTrue(TRUE_SHOULD_HAVE_BEEN_RETURNED, - downloadManager.downloadArtifacts(data, data.getServiceArtifacts(), modelArtifacts, catalogFiles)); - - assertTrue("There should not have been any catalog files", catalogFiles.size() == 0); + assertThat(downloadManager.downloadArtifacts(data, data.getServiceArtifacts(), modelArtifacts, catalogFiles), + is(true)); + assertThat(catalogFiles.size(), is(0)); Mockito.verify(mockDistributionClient).download(artifactInfo); Mockito.verify(mockNotificationPublisher).publishDownloadSuccess(mockDistributionClient, data, artifactInfo); @@ -264,7 +216,7 @@ public class ArtifactDownloadManagerTest { } private void setupValidDownloadCsarMocks(INotificationData data, IArtifactInfo artifactInfo, - ArtifactTestUtils artifactTestUtils) throws IOException, BabelServiceException { + ArtifactTestUtils artifactTestUtils) throws IOException, BabelServiceClientException { when(mockDistributionClient.download(artifactInfo)) .thenReturn(createDistributionClientDownloadResult(DistributionActionResultEnum.SUCCESS, null, artifactTestUtils.loadResource("compressedArtifacts/service-VscpaasTest-csar.csar"))); @@ -280,20 +232,19 @@ public class ArtifactDownloadManagerTest { } @Test - public void downloadArtifacts_validModelQuerySpec() - throws IOException, BabelServiceException, BabelArtifactParsingException { - ArtifactTestUtils artifactTestUtils = new ArtifactTestUtils(); + public void downloadArtifactsWithValidModelQuerySpec() + throws IOException, BabelServiceClientException, BabelArtifactParsingException { INotificationData data = getNotificationDataWithModelQuerySpec(); IArtifactInfo artifact = data.getServiceArtifacts().get(0); - setupValidModelQuerySpecMocks(artifactTestUtils, data, artifact); + setupValidModelQuerySpecMocks(new ArtifactTestUtils(), data, artifact); List<org.onap.aai.modelloader.entity.Artifact> modelFiles = new ArrayList<>(); List<org.onap.aai.modelloader.entity.Artifact> catalogFiles = new ArrayList<>(); - assertTrue(TRUE_SHOULD_HAVE_BEEN_RETURNED, - downloadManager.downloadArtifacts(data, data.getServiceArtifacts(), modelFiles, catalogFiles)); + assertThat(downloadManager.downloadArtifacts(data, data.getServiceArtifacts(), modelFiles, catalogFiles), + is(true)); - assertTrue("There should have been some model artifacts", !modelFiles.isEmpty()); - assertTrue("There should not have been any catalog artifacts", catalogFiles.isEmpty()); + assertThat(modelFiles, is(not(IsEmptyCollection.empty()))); + assertThat(catalogFiles, is(empty())); Mockito.verify(mockDistributionClient).download(artifact); Mockito.verify(mockNotificationPublisher).publishDownloadSuccess(mockDistributionClient, data, artifact); @@ -311,7 +262,7 @@ public class ArtifactDownloadManagerTest { @Test public void downloadArtifacts_validCsarAndModelFiles() - throws IOException, BabelServiceException, BabelArtifactParsingException { + throws IOException, BabelServiceClientException, BabelArtifactParsingException { ArtifactTestUtils artifactTestUtils = new ArtifactTestUtils(); INotificationData data = getNotificationDataWithOneOfEach(); List<IArtifactInfo> artifacts = new ArrayList<>(); @@ -327,8 +278,7 @@ public class ArtifactDownloadManagerTest { List<org.onap.aai.modelloader.entity.Artifact> modelFiles = new ArrayList<>(); List<org.onap.aai.modelloader.entity.Artifact> catalogFiles = new ArrayList<>(); - assertTrue(TRUE_SHOULD_HAVE_BEEN_RETURNED, - downloadManager.downloadArtifacts(data, artifacts, modelFiles, catalogFiles)); + assertThat(downloadManager.downloadArtifacts(data, artifacts, modelFiles, catalogFiles), is(true)); Mockito.verify(mockDistributionClient).download(serviceArtifact); Mockito.verify(mockNotificationPublisher).publishDownloadSuccess(mockDistributionClient, data, serviceArtifact); @@ -360,12 +310,12 @@ public class ArtifactDownloadManagerTest { when(mockBabelClient.postArtifact(Matchers.any(), Matchers.anyString(), Matchers.anyString(), Matchers.anyString())).thenReturn(createBabelArtifacts()); - List<org.onap.aai.modelloader.entity.Artifact> modelArtifacts = new ArrayList<>(); - List<org.onap.aai.modelloader.entity.Artifact> catalogFiles = new ArrayList<>(); - assertFalse(FALSE_SHOULD_HAVE_BEEN_RETURNED, - downloadManager.downloadArtifacts(data, data.getServiceArtifacts(), modelArtifacts, catalogFiles)); - - assertTrue("There should not have been any catalog files", catalogFiles.size() == 0); + List<Artifact> modelArtifacts = new ArrayList<>(); + List<Artifact> catalogFiles = new ArrayList<>(); + assertThat(downloadManager.downloadArtifacts(data, data.getServiceArtifacts(), modelArtifacts, catalogFiles), + is(false)); + assertThat(modelArtifacts, is(empty())); + assertThat(catalogFiles, is(empty())); Mockito.verify(mockDistributionClient).download(artifactInfo); Mockito.verify(mockNotificationPublisher).publishDeployFailure(mockDistributionClient, data, artifactInfo); @@ -375,24 +325,27 @@ public class ArtifactDownloadManagerTest { } @Test - public void downloadArtifacts_invalidType() - throws IOException, BabelServiceException, BabelArtifactParsingException { + public void downloadArtifactsWithInvalidType() + throws IOException, BabelServiceClientException, BabelArtifactParsingException { INotificationData data = getNotificationDataWithInvalidType(); IArtifactInfo artifact = data.getServiceArtifacts().get(0); - List<org.onap.aai.modelloader.entity.Artifact> catalogArtifacts = new ArrayList<>(); - when(mockDistributionClient.download(artifact)).thenReturn(createDistributionClientDownloadResult( DistributionActionResultEnum.SUCCESS, null, "This content does not matter.".getBytes())); doNothing().when(mockNotificationPublisher).publishDownloadSuccess(mockDistributionClient, data, artifact); - assertFalse(FALSE_SHOULD_HAVE_BEEN_RETURNED, - downloadManager.downloadArtifacts(data, data.getServiceArtifacts(), null, catalogArtifacts)); - + assertThat(downloadManager.downloadArtifacts(data, data.getServiceArtifacts(), null, new ArrayList<>()), + is(false)); Mockito.verify(mockDistributionClient).download(artifact); Mockito.verify(mockNotificationPublisher).publishDownloadSuccess(mockDistributionClient, data, artifact); Mockito.verify(mockNotificationPublisher).publishDeployFailure(mockDistributionClient, data, artifact); - Mockito.verifyZeroInteractions(mockBabelClient, mockBabelArtifactConverter); } + + private IDistributionClientDownloadResult createDistributionClientDownloadResult( + DistributionActionResultEnum status, String message, byte[] payload) { + DistributionClientDownloadResultImpl downloadResult = new DistributionClientDownloadResultImpl(status, message); + downloadResult.setArtifactPayload(payload); + return downloadResult; + } } diff --git a/src/test/java/org/onap/aai/modelloader/notification/BabelArtifactConverterTest.java b/src/test/java/org/onap/aai/modelloader/notification/TestBabelArtifactConverter.java index e9e6059..718c415 100644 --- a/src/test/java/org/onap/aai/modelloader/notification/BabelArtifactConverterTest.java +++ b/src/test/java/org/onap/aai/modelloader/notification/TestBabelArtifactConverter.java @@ -1,5 +1,5 @@ /** - * ============LICENSE_START======================================================= + * ============LICENSE_START======================================================= * org.onap.aai * ================================================================================ * Copyright © 2017-2018 AT&T Intellectual Property. All rights reserved. @@ -20,6 +20,7 @@ */ package org.onap.aai.modelloader.notification; +import static org.junit.Assert.assertEquals; import static org.junit.Assert.assertTrue; import static org.junit.Assert.fail; @@ -28,15 +29,18 @@ import java.util.ArrayList; import java.util.List; import org.junit.Test; import org.onap.aai.babel.service.data.BabelArtifact; +import org.onap.aai.modelloader.entity.Artifact; +import org.onap.aai.modelloader.entity.ArtifactType; import org.onap.aai.modelloader.entity.model.BabelArtifactParsingException; import org.onap.aai.modelloader.fixture.NotificationDataFixtureBuilder; +import org.onap.aai.modelloader.util.ArtifactTestUtils; import org.onap.sdc.api.notification.IArtifactInfo; import org.onap.sdc.api.notification.INotificationData; /** - * Tests {@link BabelArtifactConverter} + * Tests {@link BabelArtifactConverter}. */ -public class BabelArtifactConverterTest { +public class TestBabelArtifactConverter { @Test(expected = NullPointerException.class) public void convert_nullToscaFiles() throws BabelArtifactParsingException { @@ -45,20 +49,20 @@ public class BabelArtifactConverterTest { } @Test - public void convert_emptyToscaFiles() throws BabelArtifactParsingException { + public void testEmptyToscaFiles() throws BabelArtifactParsingException { assertTrue("Nothing should have been returned", new BabelArtifactConverter().convertToModel(new ArrayList<>()).isEmpty()); } @Test(expected = BabelArtifactParsingException.class) - public void convert_problemWithConvertedXML() throws IOException, BabelArtifactParsingException { - byte[] problemXML = + public void testInvalidXml() throws IOException, BabelArtifactParsingException { + byte[] problemXml = "<model xmlns=\"http://org.openecomp.aai.inventory/v10\"><rubbish>This is some xml that should cause the model artifact parser to throw an erorr</rubbish></model>" .getBytes(); INotificationData data = NotificationDataFixtureBuilder.getNotificationDataWithToscaCsarFile(); - List<BabelArtifact> toscaArtifacts = setupTest(problemXML, data); + List<BabelArtifact> toscaArtifacts = setupTest(problemXml, data); new BabelArtifactConverter().convertToModel(toscaArtifacts); fail("An instance of ModelArtifactParsingException should have been thrown"); @@ -74,4 +78,18 @@ public class BabelArtifactConverterTest { return toscaArtifacts; } + + @Test + public void convert_singleResourceFile() throws BabelArtifactParsingException, IOException { + INotificationData data = NotificationDataFixtureBuilder.getNotificationDataWithToscaCsarFile(); + + byte[] xml = new ArtifactTestUtils().loadResource("convertedYmls/AAI-SCP-Test-VSP-resource-1.0.xml"); + List<BabelArtifact> toscaArtifacts = setupTest(xml, data); + + List<Artifact> modelArtifacts = new BabelArtifactConverter().convertToModel(toscaArtifacts); + + assertTrue("There should have been 1 artifact", modelArtifacts.size() == 1); + assertEquals(new String(xml), modelArtifacts.get(0).getPayload()); + assertEquals(ArtifactType.MODEL, modelArtifacts.get(0).getType()); + } } diff --git a/src/test/java/org/onap/aai/modelloader/notification/EventCallbackTest.java b/src/test/java/org/onap/aai/modelloader/notification/TestEventCallback.java index 57a4c09..1215a7b 100644 --- a/src/test/java/org/onap/aai/modelloader/notification/EventCallbackTest.java +++ b/src/test/java/org/onap/aai/modelloader/notification/TestEventCallback.java @@ -1,5 +1,5 @@ /** - * ============LICENSE_START======================================================= + * ============LICENSE_START======================================================= * org.onap.aai * ================================================================================ * Copyright © 2017-2018 AT&T Intellectual Property. All rights reserved. @@ -36,13 +36,14 @@ import org.mockito.internal.util.reflection.Whitebox; import org.onap.aai.modelloader.config.ModelLoaderConfig; import org.onap.aai.modelloader.entity.model.BabelArtifactParsingException; import org.onap.aai.modelloader.fixture.NotificationDataFixtureBuilder; +import org.onap.aai.modelloader.service.ArtifactDeploymentManager; import org.onap.sdc.api.IDistributionClient; import org.onap.sdc.api.notification.INotificationData; /** - * Tests {@link EventCallback} + * Tests {@link EventCallback}. */ -public class EventCallbackTest { +public class TestEventCallback { private static final String CONFIG_FILE = "model-loader.properties"; @@ -53,6 +54,7 @@ public class EventCallbackTest { private ArtifactDeploymentManager mockArtifactDeploymentManager; private ArtifactDownloadManager mockArtifactDownloadManager; private IDistributionClient mockDistributionClient; + private NotificationPublisher mockNotificationPublisher; @Before public void setup() throws IOException { @@ -63,11 +65,13 @@ public class EventCallbackTest { mockArtifactDeploymentManager = mock(ArtifactDeploymentManager.class); mockArtifactDownloadManager = mock(ArtifactDownloadManager.class); mockDistributionClient = mock(IDistributionClient.class); + mockNotificationPublisher = mock(NotificationPublisher.class); eventCallback = new EventCallback(mockDistributionClient, config); Whitebox.setInternalState(eventCallback, "artifactDeploymentManager", mockArtifactDeploymentManager); Whitebox.setInternalState(eventCallback, "artifactDownloadManager", mockArtifactDownloadManager); + Whitebox.setInternalState(eventCallback, "notificationPublisher", mockNotificationPublisher); } @After @@ -103,14 +107,13 @@ public class EventCallbackTest { when(mockArtifactDownloadManager.downloadArtifacts(any(INotificationData.class), any(List.class), any(List.class), any(List.class))).thenReturn(true); - when(mockArtifactDeploymentManager.deploy(any(INotificationData.class), any(List.class), any(List.class), - any(List.class))).thenReturn(true); + when(mockArtifactDeploymentManager.deploy(any(INotificationData.class), any(List.class), any(List.class))) + .thenReturn(true); eventCallback.activateCallback(data); verify(mockArtifactDownloadManager).downloadArtifacts(any(INotificationData.class), any(List.class), any(List.class), any(List.class)); - verify(mockArtifactDeploymentManager).deploy(any(INotificationData.class), any(List.class), any(List.class), - any(List.class)); + verify(mockArtifactDeploymentManager).deploy(any(INotificationData.class), any(List.class), any(List.class)); } } diff --git a/src/test/java/org/onap/aai/modelloader/service/TestNotificationDataImpl.java b/src/test/java/org/onap/aai/modelloader/notification/TestNotificationDataImpl.java index 395b1f3..c045910 100644 --- a/src/test/java/org/onap/aai/modelloader/service/TestNotificationDataImpl.java +++ b/src/test/java/org/onap/aai/modelloader/notification/TestNotificationDataImpl.java @@ -1,5 +1,5 @@ /** - * ============LICENSE_START======================================================= + * ============LICENSE_START======================================================= * org.onap.aai * ================================================================================ * Copyright © 2017-2018 AT&T Intellectual Property. All rights reserved. @@ -18,7 +18,7 @@ * limitations under the License. * ============LICENSE_END========================================================= */ -package org.onap.aai.modelloader.service; +package org.onap.aai.modelloader.notification; import static org.hamcrest.CoreMatchers.equalTo; import static org.hamcrest.CoreMatchers.is; @@ -37,7 +37,6 @@ public class TestNotificationDataImpl { public void testGettersAndSetters() { NotificationDataImpl data = new NotificationDataImpl(); String distributionId = "testid"; - String context = "testcontext"; data.setDistributionID(distributionId); assertThat(data.getDistributionID(), is(equalTo(distributionId))); @@ -53,6 +52,7 @@ public class TestNotificationDataImpl { assertThat(data.getServiceArtifacts().size(), is(0)); // Unsupported method! + String context = "testcontext"; data.setWorkloadContext(context); assertThat(data.getWorkloadContext(), is(equalTo(null))); } diff --git a/src/test/java/org/onap/aai/modelloader/notification/TestNotificationPublisher.java b/src/test/java/org/onap/aai/modelloader/notification/TestNotificationPublisher.java index bc91b2f..4939fd6 100644 --- a/src/test/java/org/onap/aai/modelloader/notification/TestNotificationPublisher.java +++ b/src/test/java/org/onap/aai/modelloader/notification/TestNotificationPublisher.java @@ -1,5 +1,5 @@ /** - * ============LICENSE_START======================================================= + * ============LICENSE_START======================================================= * org.onap.aai * ================================================================================ * Copyright © 2017-2018 AT&T Intellectual Property. All rights reserved. diff --git a/src/test/java/org/onap/aai/modelloader/restclient/MockBabelServiceClient.java b/src/test/java/org/onap/aai/modelloader/restclient/MockBabelServiceClient.java new file mode 100644 index 0000000..604aca7 --- /dev/null +++ b/src/test/java/org/onap/aai/modelloader/restclient/MockBabelServiceClient.java @@ -0,0 +1,41 @@ +/** + * ============LICENSE_START======================================================= + * org.onap.aai + * ================================================================================ + * Copyright © 2017-2018 AT&T Intellectual Property. All rights reserved. + * Copyright © 2017-2018 European Software Marketing Ltd. + * ================================================================================ + * 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.aai.modelloader.restclient; + +import java.util.Collections; +import java.util.List; +import org.onap.aai.babel.service.data.BabelArtifact; +import org.onap.aai.modelloader.config.ModelLoaderConfig; + +/** + * Mocked Client for interfacing with Babel. + * + */ +public class MockBabelServiceClient implements BabelServiceClient { + + public MockBabelServiceClient(ModelLoaderConfig config) throws BabelServiceClientException {} + + @Override + public List<BabelArtifact> postArtifact(byte[] artifactPayload, String artifactName, String artifactVersion, + String transactionId) throws BabelServiceClientException { + return Collections.emptyList(); + } +} diff --git a/src/test/java/org/onap/aai/modelloader/restclient/TestAaiRestClient.java b/src/test/java/org/onap/aai/modelloader/restclient/TestAaiRestClient.java new file mode 100644 index 0000000..8b1b22c --- /dev/null +++ b/src/test/java/org/onap/aai/modelloader/restclient/TestAaiRestClient.java @@ -0,0 +1,144 @@ +/** + * ============LICENSE_START======================================================= + * org.onap.aai + * ================================================================================ + * Copyright © 2017-2018 AT&T Intellectual Property. All rights reserved. + * Copyright © 2017-2018 European Software Marketing Ltd. + * ================================================================================ + * 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.aai.modelloader.restclient; + +import static org.junit.Assert.assertTrue; + +import java.io.File; +import java.io.IOException; +import java.nio.file.Files; +import java.nio.file.Paths; +import java.util.Properties; +import java.util.stream.IntStream; +import java.util.stream.Stream; +import javax.ws.rs.core.MediaType; +import javax.ws.rs.core.Response; +import javax.xml.parsers.DocumentBuilderFactory; +import org.onap.aai.modelloader.config.ModelLoaderConfig; +import org.onap.aai.modelloader.entity.ArtifactType; +import org.onap.aai.modelloader.entity.model.ModelArtifact; +import org.onap.aai.modelloader.entity.model.ModelArtifactParser; +import org.onap.aai.restclient.client.OperationResult; +import org.w3c.dom.Document; +import org.w3c.dom.Node; +import org.w3c.dom.NodeList; + +public class TestAaiRestClient { + + private static final String MODEL_FILE = "src/test/resources/models/l3-network-widget.xml"; + + // This test requires a running A&AI system. To test locally, annotate with org.junit.Test + public void testRestClient() throws Exception { + Properties props = new Properties(); + props.setProperty("ml.distribution.ARTIFACT_TYPES", "MODEL_INVENTORY_PROFILE,MODEL_QUERY_SPEC,VNF_CATALOG"); + props.setProperty("ml.aai.BASE_URL", "https://localhost:8443"); + props.setProperty("ml.aai.MODEL_URL", "/aai/v9/service-design-and-creation/models/model/"); + props.setProperty("ml.aai.KEYSTORE_FILE", "aai-client-cert.p12"); + props.setProperty("ml.aai.KEYSTORE_PASSWORD", "OBF:1i9a1u2a1unz1lr61wn51wn11lss1unz1u301i6o"); + + ModelLoaderConfig config = new ModelLoaderConfig(props, "."); + + File xmlFile = new File(MODEL_FILE); + DocumentBuilderFactory dbFactory = DocumentBuilderFactory.newInstance(); + dbFactory.setFeature("http://apache.org/xml/features/disallow-doctype-decl", true); + Document doc = dbFactory.newDocumentBuilder().parse(xmlFile); + + NodeList nodesList = doc.getDocumentElement().getChildNodes(); + + // Get the model IDs + + // @formatter:off + String modelInvariantId = + getNodesStream(nodesList) + .filter(childNode -> childNode.getNodeName().equals(ModelArtifactParser.MODEL_INVARIANT_ID)) + .findFirst() + .map(Node::getTextContent) + .orElse(null); + + String modelId = getNodesStream(nodesList) + .flatMap(n -> getNodesStream(n.getChildNodes())) + .filter(childNode -> childNode.getNodeName().equals(ModelArtifactParser.MODEL_VER)) + .findFirst() + .map(n -> n.getChildNodes().item(1).getTextContent()) + .orElse(null); + // @formatter:on + + try { + // Build the model artifact + ModelArtifact model = new ModelArtifact(); + model.setModelInvariantId(modelInvariantId); + model.setModelVerId(modelId); + model.setPayload(readFile(MODEL_FILE)); + model.setModelNamespace("http://org.openecomp.aai.inventory/v9"); + + AaiRestClient aaiClient = new AaiRestClient(config); + + // GET model + OperationResult opResult = + aaiClient.getResource(getUrl(model, config), "example-trans-id-0", MediaType.APPLICATION_XML_TYPE); + assertTrue(opResult.getResultCode() == Response.Status.NOT_FOUND.getStatusCode()); + + // PUT the model + opResult = aaiClient.putResource(getUrl(model, config), model.getPayload(), "example-trans-id-1", + MediaType.APPLICATION_XML_TYPE); + assertTrue(opResult.getResultCode() == Response.Status.CREATED.getStatusCode()); + + // DELETE the model + opResult = aaiClient.getAndDeleteResource(getUrl(model, config), "example-trans-id-3"); + assertTrue(opResult.getResultCode() == Response.Status.NO_CONTENT.getStatusCode()); + } catch (Exception e) { + e.printStackTrace(); + } + } + + private Stream<Node> getNodesStream(NodeList nodeList) { + return IntStream.range(0, nodeList.getLength()).mapToObj(nodeList::item); + } + + static String readFile(String path) throws IOException { + byte[] encoded = Files.readAllBytes(Paths.get(path)); + return new String(encoded); + } + + private String getUrl(ModelArtifact model, ModelLoaderConfig config) { + String subUrl; + if (model.getType().equals(ArtifactType.MODEL)) { + subUrl = config.getAaiModelUrl(model.getModelNamespaceVersion()).trim(); + } else { + subUrl = config.getAaiNamedQueryUrl(model.getModelNamespaceVersion()).trim(); + } + + String baseUrl = config.getAaiBaseUrl().trim(); + if (!baseUrl.endsWith("/") && !subUrl.startsWith("/")) { + baseUrl = baseUrl + "/"; + } + + if (baseUrl.endsWith("/") && subUrl.startsWith("/")) { + baseUrl = baseUrl.substring(0, baseUrl.length() - 1); + } + + if (!subUrl.endsWith("/")) { + subUrl = subUrl + "/"; + } + + return baseUrl + subUrl + model.getModelInvariantId(); + } +} diff --git a/src/test/java/org/onap/aai/modelloader/restclient/TestAaiServiceClient.java b/src/test/java/org/onap/aai/modelloader/restclient/TestAaiServiceClient.java index 96620ee..ac2d7e4 100644 --- a/src/test/java/org/onap/aai/modelloader/restclient/TestAaiServiceClient.java +++ b/src/test/java/org/onap/aai/modelloader/restclient/TestAaiServiceClient.java @@ -1,5 +1,5 @@ /** - * ============LICENSE_START======================================================= + * ============LICENSE_START======================================================= * org.onap.aai * ================================================================================ * Copyright © 2017-2018 AT&T Intellectual Property. All rights reserved. @@ -39,7 +39,7 @@ import org.junit.Test; import org.onap.aai.modelloader.config.ModelLoaderConfig; /** - * Local testing of the Babel service + * Local testing of the A&AI Service client. * */ public class TestAaiServiceClient { @@ -55,6 +55,8 @@ public class TestAaiServiceClient { Properties props = new Properties(); props.put("ml.aai.KEYSTORE_PASSWORD", "2244"); + props.put("ml.aai.KEYSTORE_FILE", "src/test/resources/auth/aai-client-cert.p12"); + props.put("ml.aai.KEYSTORE_PASSWORD", "OBF:1i9a1u2a1unz1lr61wn51wn11lss1unz1u301i6o"); ModelLoaderConfig config = new ModelLoaderConfig(props, "."); aaiClient = new AaiRestClient(config); } @@ -73,7 +75,7 @@ public class TestAaiServiceClient { @Test public void testOperations() { - String url = "http://localhost"; + String url = "http://localhost:8080"; String transId = ""; MediaType mediaType = MediaType.APPLICATION_JSON_TYPE; aaiClient.getResource(url, "", mediaType); diff --git a/src/test/java/org/onap/aai/modelloader/restclient/TestBabelServiceClient.java b/src/test/java/org/onap/aai/modelloader/restclient/TestBabelServiceClient.java index b42fee4..4f99bfc 100644 --- a/src/test/java/org/onap/aai/modelloader/restclient/TestBabelServiceClient.java +++ b/src/test/java/org/onap/aai/modelloader/restclient/TestBabelServiceClient.java @@ -1,5 +1,5 @@ /** - * ============LICENSE_START======================================================= + * ============LICENSE_START======================================================= * org.onap.aai * ================================================================================ * Copyright © 2017-2018 AT&T Intellectual Property. All rights reserved. @@ -31,11 +31,6 @@ import java.io.IOException; import java.net.URISyntaxException; import java.nio.file.Files; import java.nio.file.Paths; -import java.security.KeyManagementException; -import java.security.KeyStoreException; -import java.security.NoSuchAlgorithmException; -import java.security.UnrecoverableKeyException; -import java.security.cert.CertificateException; import java.util.ArrayList; import java.util.List; import java.util.Properties; @@ -51,10 +46,10 @@ import org.junit.Before; import org.junit.Test; import org.onap.aai.babel.service.data.BabelArtifact; import org.onap.aai.modelloader.config.ModelLoaderConfig; -import org.onap.aai.modelloader.restclient.BabelServiceClient.BabelServiceException; +import org.onap.aai.modelloader.service.HttpsBabelServiceClientFactory; /** - * Local testing of the Babel service + * Local testing of the Babel service client. * */ public class TestBabelServiceClient { @@ -62,16 +57,14 @@ public class TestBabelServiceClient { private Server server; private String responseBody; - { + @Before + public void startJetty() throws Exception { List<BabelArtifact> response = new ArrayList<>(); response.add(new BabelArtifact("", null, "")); response.add(new BabelArtifact("", null, "")); response.add(new BabelArtifact("", null, "")); responseBody = new Gson().toJson(response); - } - @Before - public void startJetty() throws Exception { server = new Server(8080); server.setHandler(getMockHandler()); server.start(); @@ -83,14 +76,17 @@ public class TestBabelServiceClient { } @Test - public void testRestClient() throws UnrecoverableKeyException, KeyManagementException, NoSuchAlgorithmException, - KeyStoreException, CertificateException, IOException, BabelServiceException, URISyntaxException { + public void testRestClient() throws BabelServiceClientException, IOException, URISyntaxException { Properties configProperties = new Properties(); configProperties.put("ml.babel.KEYSTORE_PASSWORD", "OBF:1vn21ugu1saj1v9i1v941sar1ugw1vo0"); + configProperties.put("ml.babel.KEYSTORE_FILE", "src/test/resources/auth/aai-client-dummy.p12"); + configProperties.put("ml.babel.TRUSTSTORE_PASSWORD", "OBF:1vn21ugu1saj1v9i1v941sar1ugw1vo0"); + // In a real deployment this would be a different file (to the client keystore) + configProperties.put("ml.babel.TRUSTSTORE_FILE", "src/test/resources/auth/aai-client-dummy.p12"); configProperties.put("ml.babel.BASE_URL", "http://localhost:8080/"); configProperties.put("ml.babel.GENERATE_ARTIFACTS_URL", "generate"); BabelServiceClient client = - new BabelServiceClientFactory().create(new ModelLoaderConfig(configProperties, ".")); + new HttpsBabelServiceClientFactory().create(new ModelLoaderConfig(configProperties, ".")); List<BabelArtifact> result = client.postArtifact(readBytesFromFile("compressedArtifacts/service-VscpaasTest-csar.csar"), "service-Vscpass-Test", "1.0", "Test-Transaction-ID-BabelClient"); @@ -120,4 +116,3 @@ public class TestBabelServiceClient { return handler; } } - diff --git a/src/test/java/org/onap/aai/modelloader/service/MockBabelServiceClientFactory.java b/src/test/java/org/onap/aai/modelloader/service/MockBabelServiceClientFactory.java new file mode 100644 index 0000000..fa369ce --- /dev/null +++ b/src/test/java/org/onap/aai/modelloader/service/MockBabelServiceClientFactory.java @@ -0,0 +1,37 @@ +/** + * ============LICENSE_START======================================================= + * org.onap.aai + * ================================================================================ + * Copyright © 2017-2018 AT&T Intellectual Property. All rights reserved. + * Copyright © 2017-2018 European Software Marketing Ltd. + * ================================================================================ + * 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.aai.modelloader.service; + +import org.onap.aai.modelloader.config.ModelLoaderConfig; +import org.onap.aai.modelloader.restclient.BabelServiceClient; +import org.onap.aai.modelloader.restclient.BabelServiceClientException; +import org.onap.aai.modelloader.restclient.MockBabelServiceClient; +import org.springframework.stereotype.Service; + +@Service +public class MockBabelServiceClientFactory implements BabelServiceClientFactory { + + @Override + public BabelServiceClient create(ModelLoaderConfig config) throws BabelServiceClientException { + return new MockBabelServiceClient(config); + } + +} diff --git a/src/test/java/org/onap/aai/modelloader/service/TestArtifactInfoImpl.java b/src/test/java/org/onap/aai/modelloader/service/TestArtifactInfoImpl.java index 366d5a5..ec55f15 100644 --- a/src/test/java/org/onap/aai/modelloader/service/TestArtifactInfoImpl.java +++ b/src/test/java/org/onap/aai/modelloader/service/TestArtifactInfoImpl.java @@ -1,5 +1,5 @@ /** - * ============LICENSE_START======================================================= + * ============LICENSE_START======================================================= * org.onap.aai * ================================================================================ * Copyright © 2017-2018 AT&T Intellectual Property. All rights reserved. @@ -39,19 +39,19 @@ public class TestArtifactInfoImpl { public void testGettersAndSetters() { ArtifactInfoImpl info = new ArtifactInfoImpl(); String artifactName = "testname"; - String artifactType = "test-type"; - String artifactVersion = "v1"; - String artifactDescription = "test description"; info.setArtifactName(artifactName); assertThat(info.getArtifactName(), is(equalTo(artifactName))); + String artifactType = "test-type"; info.setArtifactType(artifactType); assertThat(info.getArtifactType(), is(equalTo(artifactType))); + String artifactVersion = "v1"; info.setArtifactVersion(artifactVersion); assertThat(info.getArtifactVersion(), is(equalTo(artifactVersion))); + String artifactDescription = "test description"; info.setArtifactDescription(artifactDescription); assertThat(info.getArtifactDescription(), is(equalTo(artifactDescription))); diff --git a/src/test/java/org/onap/aai/modelloader/service/TestModelLoaderService.java b/src/test/java/org/onap/aai/modelloader/service/TestModelLoaderService.java new file mode 100644 index 0000000..8e07650 --- /dev/null +++ b/src/test/java/org/onap/aai/modelloader/service/TestModelLoaderService.java @@ -0,0 +1,86 @@ +/** + * ============LICENSE_START======================================================= + * org.onap.aai + * ================================================================================ + * Copyright © 2017-2018 AT&T Intellectual Property. All rights reserved. + * Copyright © 2017-2018 European Software Marketing Ltd. + * ================================================================================ + * 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.aai.modelloader.service; + +import static org.hamcrest.CoreMatchers.is; +import static org.junit.Assert.assertThat; + +import java.io.IOException; +import java.util.Base64; +import javax.ws.rs.core.Response; +import org.junit.After; +import org.junit.Test; +import org.junit.runner.RunWith; +import org.onap.aai.modelloader.util.ArtifactTestUtils; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.boot.test.context.SpringBootTest; +import org.springframework.test.context.TestPropertySource; +import org.springframework.test.context.junit4.SpringRunner; + +/** + * Tests for the ModelLoaderService class. + * + */ +@RunWith(SpringRunner.class) +@SpringBootTest(classes = {ModelLoaderService.class, MockBabelServiceClientFactory.class}) +@TestPropertySource(properties = {"CONFIG_HOME=src/test/resources",}) +public class TestModelLoaderService { + + @Autowired + private ModelLoaderService service; + + @After + public void shutdown() { + service.preShutdownOperations(); + } + + @Test + public void testMissingConfig() { + new ModelLoaderService().start(); + } + + @Test + public void testLoadModel() { + Response response = service.loadModel(""); + assertThat(response.getStatus(), is(Response.Status.OK.getStatusCode())); + } + + @Test + public void testSaveModel() { + Response response = service.saveModel("", ""); + assertThat(response.getStatus(), is(Response.Status.OK.getStatusCode())); + } + + @Test + public void testIngestModel() throws IOException { + byte[] csarPayload = new ArtifactTestUtils().loadResource("compressedArtifacts/service-VscpaasTest-csar.csar"); + Response response = service.ingestModel("model-name", "", Base64.getEncoder().encodeToString(csarPayload)); + assertThat(response.getStatus(), is(Response.Status.OK.getStatusCode())); + } + + @Test + public void testIngestModelMissingName() throws IOException { + byte[] csarPayload = new ArtifactTestUtils().loadResource("compressedArtifacts/service-VscpaasTest-csar.csar"); + Response response = service.ingestModel("", "", Base64.getEncoder().encodeToString(csarPayload)); + assertThat(response.getStatus(), is(Response.Status.OK.getStatusCode())); + } + +} diff --git a/src/test/java/org/onap/aai/modelloader/service/TestModelLoaderServiceWithSdc.java b/src/test/java/org/onap/aai/modelloader/service/TestModelLoaderServiceWithSdc.java new file mode 100644 index 0000000..ff0614b --- /dev/null +++ b/src/test/java/org/onap/aai/modelloader/service/TestModelLoaderServiceWithSdc.java @@ -0,0 +1,63 @@ +/** + * ============LICENSE_START======================================================= + * org.onap.aai + * ================================================================================ + * Copyright © 2017-2018 AT&T Intellectual Property. All rights reserved. + * Copyright © 2017-2018 European Software Marketing Ltd. + * ================================================================================ + * 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.aai.modelloader.service; + +import static org.hamcrest.CoreMatchers.is; +import static org.junit.Assert.assertThat; + +import java.io.IOException; +import java.util.Base64; +import javax.ws.rs.core.Response; +import org.junit.After; +import org.junit.Test; +import org.junit.runner.RunWith; +import org.onap.aai.modelloader.util.ArtifactTestUtils; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.boot.test.context.SpringBootTest; +import org.springframework.test.context.TestPropertySource; +import org.springframework.test.context.junit4.SpringRunner; + +/** + * Tests for the ModelLoaderService class. + * + */ +@RunWith(SpringRunner.class) +@SpringBootTest(classes = {ModelLoaderService.class, HttpsBabelServiceClientFactory.class}) +@TestPropertySource(properties = {"CONFIG_HOME=src/test/resources/sdc_test",}) +public class TestModelLoaderServiceWithSdc { + + @Autowired + private ModelLoaderService service; + + @After + public void shutdown() { + service.preShutdownOperations(); + } + + @Test + public void testIngestModel() throws IOException { + byte[] csarPayload = new ArtifactTestUtils().loadResource("compressedArtifacts/service-VscpaasTest-csar.csar"); + Response response = service.ingestModel("model-name", "", Base64.getEncoder().encodeToString(csarPayload)); + assertThat(response.getStatus(), is(Response.Status.INTERNAL_SERVER_ERROR.getStatusCode())); + } + + +} diff --git a/src/test/java/org/onap/aai/modelloader/util/ArtifactTestUtils.java b/src/test/java/org/onap/aai/modelloader/util/ArtifactTestUtils.java index 9b6ea06..752f389 100644 --- a/src/test/java/org/onap/aai/modelloader/util/ArtifactTestUtils.java +++ b/src/test/java/org/onap/aai/modelloader/util/ArtifactTestUtils.java @@ -1,5 +1,5 @@ /** - * ============LICENSE_START======================================================= + * ============LICENSE_START======================================================= * org.onap.aai * ================================================================================ * Copyright © 2017-2018 AT&T Intellectual Property. All rights reserved. @@ -21,14 +21,34 @@ package org.onap.aai.modelloader.util; import java.io.IOException; +import java.net.URL; import org.apache.commons.io.IOUtils; +import org.onap.aai.babel.service.data.BabelArtifact; /** * This class provides some utilities to assist with running tests. */ public class ArtifactTestUtils { + public static BabelArtifact loadModelArtifact(String resource) throws IOException { + return new BabelArtifact("ModelArtifact", BabelArtifact.ArtifactType.MODEL, + ArtifactTestUtils.loadResourceAsString(resource)); + } public byte[] loadResource(String resourceName) throws IOException { - return IOUtils.toByteArray(ArtifactTestUtils.class.getClassLoader().getResource(resourceName)); + URL resource = getResource(resourceName); + if (resource != null) { + return IOUtils.toByteArray(resource); + } else { + throw new IOException("Cannot locate resource: " + resourceName); + } + } + + public static String loadResourceAsString(String resourceName) throws IOException { + return IOUtils.toString(getResource(resourceName)); } + + private static URL getResource(String resourceName) { + return ArtifactTestUtils.class.getClassLoader().getResource(resourceName); + } + } diff --git a/src/test/java/org/onap/aai/modelloader/util/JsonXmlConverterTest.java b/src/test/java/org/onap/aai/modelloader/util/TestJsonXmlConverter.java index 2271c57..4b7db56 100644 --- a/src/test/java/org/onap/aai/modelloader/util/JsonXmlConverterTest.java +++ b/src/test/java/org/onap/aai/modelloader/util/TestJsonXmlConverter.java @@ -1,5 +1,5 @@ /** - * ============LICENSE_START======================================================= + * ============LICENSE_START======================================================= * org.onap.aai * ================================================================================ * Copyright © 2017-2018 AT&T Intellectual Property. All rights reserved. @@ -20,8 +20,8 @@ */ package org.onap.aai.modelloader.util; -import static org.junit.Assert.assertFalse; -import static org.junit.Assert.assertTrue; +import static org.hamcrest.CoreMatchers.is; +import static org.junit.Assert.assertThat; import java.io.ByteArrayInputStream; import java.nio.file.Files; @@ -33,25 +33,30 @@ import org.w3c.dom.Document; import org.w3c.dom.Node; import org.w3c.dom.NodeList; -public class JsonXmlConverterTest { +public class TestJsonXmlConverter { - @Test - public void testConversion() throws Exception { - final String XML_MODEL_FILE = "src/test/resources/models/l3-network-widget.xml"; - final String JSON_MODEL_FILE = "src/test/resources/models/l3-network-widget.json"; + private static final String XML_MODEL_FILE = "src/test/resources/models/l3-network-widget.xml"; + private static final String JSON_MODEL_FILE = "src/test/resources/models/l3-network-widget.json"; - try { - byte[] encoded = Files.readAllBytes(Paths.get(XML_MODEL_FILE)); - String originalXML = new String(encoded); + @Test + public void testJsonIsValid() { + assertThat(JsonXmlConverter.isValidJson("{}"), is(true)); + assertThat(JsonXmlConverter.isValidJson("[]"), is(true)); - assertFalse(JsonXmlConverter.isValidJson(originalXML)); + assertThat(JsonXmlConverter.isValidJson("{"), is(false)); + assertThat(JsonXmlConverter.isValidJson("["), is(false)); + } + @Test + public void testConversion() throws Exception { + byte[] encoded = Files.readAllBytes(Paths.get(XML_MODEL_FILE)); + assertThat(JsonXmlConverter.isValidJson(new String(encoded)), is(false)); encoded = Files.readAllBytes(Paths.get(JSON_MODEL_FILE)); - String originalJSON = new String(encoded); + String originalJson = new String(encoded); - assertTrue(JsonXmlConverter.isValidJson(originalJSON)); + assertThat(JsonXmlConverter.isValidJson(originalJson), is(true)); - String xmlFromJson = JsonXmlConverter.convertJsonToXml(originalJSON); + String xmlFromJson = JsonXmlConverter.convertJsonToXml(originalJson); // Spot check one of the attributes DocumentBuilderFactory factory = DocumentBuilderFactory.newInstance(); @@ -69,10 +74,9 @@ public class JsonXmlConverterTest { } } - assertTrue(modelVid.equals("3d560d81-57d0-438b-a2a1-5334dba0651a")); - } catch (Exception e) { - e.printStackTrace(); - assertTrue(false); - } + assertThat(modelVid.equals("3d560d81-57d0-438b-a2a1-5334dba0651a"), is(true)); + + // Convert the XML form back into JSON + JsonXmlConverter.convertXmlToJson(xmlFromJson); } } diff --git a/src/test/resources/auth/aai-client-dummy.p12 b/src/test/resources/auth/aai-client-dummy.p12 Binary files differnew file mode 100644 index 0000000..ce363f5 --- /dev/null +++ b/src/test/resources/auth/aai-client-dummy.p12 diff --git a/src/test/resources/convertedYmls/AAI-SCP-Test-VSP-resource-1.0.xml b/src/test/resources/convertedYmls/AAI-SCP-Test-VSP-resource-1.0.xml new file mode 100644 index 0000000..bc723c1 --- /dev/null +++ b/src/test/resources/convertedYmls/AAI-SCP-Test-VSP-resource-1.0.xml @@ -0,0 +1,51 @@ +<model xmlns="http://org.openecomp.aai.inventory/v10"> + <model-invariant-id>b2b88a73-5c55-4984-99dd-a35c55935d14</model-invariant-id> + <model-type>resource</model-type> + <model-vers> + <model-ver> + <model-version-id>2e42bac2-318a-410c-b8ff-3b3a31351be7</model-version-id> + <model-name>SCP-Test-VSP</model-name> + <model-version>1.0</model-version> + <model-description>SCP Test VSP</model-description> + <model-elements> + <model-element> + <new-data-del-flag>T</new-data-del-flag> + <cardinality>unbounded</cardinality> + <model-elements> + <model-element> + <new-data-del-flag>T</new-data-del-flag> + <cardinality>unbounded</cardinality> + <model-elements/> + <relationship-list> + <relationship> + <related-to>model-ver</related-to> + <relationship-data> + <relationship-key>model-ver.model-version-id</relationship-key> + <relationship-value>06258c44-ab48-4b4b-a5db-16892f7d1e76</relationship-value> + </relationship-data> + <relationship-data> + <relationship-key>model.model-invariant-id</relationship-key> + <relationship-value>6f288081-b321-47c9-b038-6de70079a3bf</relationship-value> + </relationship-data> + </relationship> + </relationship-list> + </model-element> + </model-elements> + <relationship-list> + <relationship> + <related-to>model-ver</related-to> + <relationship-data> + <relationship-key>model-ver.model-version-id</relationship-key> + <relationship-value>93a6166f-b3d5-4f06-b4ba-aed48d009ad9</relationship-value> + </relationship-data> + <relationship-data> + <relationship-key>model.model-invariant-id</relationship-key> + <relationship-value>acc6edd8-a8d4-4b93-afaa-0994068be14c</relationship-value> + </relationship-data> + </relationship> + </relationship-list> + </model-element> + </model-elements> + </model-ver> + </model-vers> +</model>
\ No newline at end of file diff --git a/src/test/resources/model-loader-empty-auth-password.properties b/src/test/resources/model-loader-empty-auth-password.properties index 91fd527..fabd855 100644 --- a/src/test/resources/model-loader-empty-auth-password.properties +++ b/src/test/resources/model-loader-empty-auth-password.properties @@ -1,22 +1,27 @@ # Model Loader Distribution Client Configuration ml.distribution.ACTIVE_SERVER_TLS_AUTH=false -ml.distribution.ASDC_ADDRESS= +ml.distribution.ASDC_ADDRESS=localhost:8443 +ml.distribution.MSG_BUS_ADDRESSES=localhost ml.distribution.CONSUMER_GROUP=aai-ml-group-test ml.distribution.CONSUMER_ID=aai-ml-id-test -ml.distribution.ENVIRONMENT_NAME= +ml.distribution.ENVIRONMENT_NAME=env ml.distribution.KEYSTORE_PASSWORD= -ml.distribution.KEYSTORE_FILE=asdc-client.jks -ml.distribution.PASSWORD= +ml.distribution.KEYSTORE_FILE= +ml.distribution.PASSWORD=Aa123456 ml.distribution.POLLING_INTERVAL=30 ml.distribution.POLLING_TIMEOUT=20 ml.distribution.USER=ci -ml.distribution.ARTIFACT_TYPES=MODEL_INVENTORY_PROFILE,MODEL_QUERY_SPEC,VNF_CATALOG +ml.distribution.ARTIFACT_TYPES=MODEL_QUERY_SPEC,TOSCA_CSAR -# Model Loader AAI REST Client Configuration -ml.aai.BASE_URL= -ml.aai.MODEL_URL=/aai/v8/service-design-and-creation/models/model/ -ml.aai.NAMED_QUERY_URL=/aai/v8/service-design-and-creation/named-queries/named-query/ -ml.aai.VNF_IMAGE_URL=/aai/v8/service-design-and-creation/vnf-images +# Disable ASDC polling & enable REST interface +ml.distribution.ASDC_CONNECTION_DISABLE=true +ml.debug.INGEST_SIMULATOR=enabled + +# Model Loader Client Configuration for the A&AI REST interface +ml.aai.BASE_URL=https://localhost:8443 +ml.aai.MODEL_URL=/aai/v*/service-design-and-creation/models/model/ +ml.aai.NAMED_QUERY_URL=/aai/v*/service-design-and-creation/named-queries/named-query/ +ml.aai.VNF_IMAGE_URL=/aai/v*/service-design-and-creation/vnf-images ml.aai.KEYSTORE_FILE=aai-client-cert.p12 ml.aai.KEYSTORE_PASSWORD= ml.aai.AUTH_USER=ModelLoader diff --git a/src/test/resources/model-loader-no-auth-password.properties b/src/test/resources/model-loader-no-auth-password.properties index 2f36934..96b24c8 100644 --- a/src/test/resources/model-loader-no-auth-password.properties +++ b/src/test/resources/model-loader-no-auth-password.properties @@ -1,21 +1,26 @@ # Model Loader Distribution Client Configuration ml.distribution.ACTIVE_SERVER_TLS_AUTH=false -ml.distribution.ASDC_ADDRESS= +ml.distribution.ASDC_ADDRESS=localhost:8443 +ml.distribution.MSG_BUS_ADDRESSES=localhost ml.distribution.CONSUMER_GROUP=aai-ml-group-test ml.distribution.CONSUMER_ID=aai-ml-id-test -ml.distribution.ENVIRONMENT_NAME= +ml.distribution.ENVIRONMENT_NAME=env ml.distribution.KEYSTORE_PASSWORD= -ml.distribution.KEYSTORE_FILE=asdc-client.jks -ml.distribution.PASSWORD= +ml.distribution.KEYSTORE_FILE= +ml.distribution.PASSWORD=Aa123456 ml.distribution.POLLING_INTERVAL=30 ml.distribution.POLLING_TIMEOUT=20 ml.distribution.USER=ci -ml.distribution.ARTIFACT_TYPES=MODEL_INVENTORY_PROFILE,MODEL_QUERY_SPEC,VNF_CATALOG +ml.distribution.ARTIFACT_TYPES=MODEL_QUERY_SPEC,TOSCA_CSAR -# Model Loader AAI REST Client Configuration -ml.aai.BASE_URL= -ml.aai.MODEL_URL=/aai/v8/service-design-and-creation/models/model/ -ml.aai.NAMED_QUERY_URL=/aai/v8/service-design-and-creation/named-queries/named-query/ -ml.aai.VNF_IMAGE_URL=/aai/v8/service-design-and-creation/vnf-images +# Disable ASDC polling & enable REST interface +ml.distribution.ASDC_CONNECTION_DISABLE=true +ml.debug.INGEST_SIMULATOR=enabled + +# Model Loader Client Configuration for the A&AI REST interface +ml.aai.BASE_URL=https://localhost:8443 +ml.aai.MODEL_URL=/aai/v*/service-design-and-creation/models/model/ +ml.aai.NAMED_QUERY_URL=/aai/v*/service-design-and-creation/named-queries/named-query/ +ml.aai.VNF_IMAGE_URL=/aai/v*/service-design-and-creation/vnf-images ml.aai.KEYSTORE_FILE=aai-client-cert.p12 ml.aai.KEYSTORE_PASSWORD= diff --git a/src/test/resources/model-loader.properties b/src/test/resources/model-loader.properties index 9f3226a..3ba1519 100644 --- a/src/test/resources/model-loader.properties +++ b/src/test/resources/model-loader.properties @@ -1,20 +1,24 @@ # Model Loader Distribution Client Configuration ml.distribution.ACTIVE_SERVER_TLS_AUTH=false -ml.distribution.ASDC_ADDRESS=localhost +ml.distribution.ASDC_ADDRESS=localhost:8443 ml.distribution.MSG_BUS_ADDRESSES=localhost ml.distribution.CONSUMER_GROUP=aai-ml-group-test ml.distribution.CONSUMER_ID=aai-ml-id-test ml.distribution.ENVIRONMENT_NAME=env ml.distribution.KEYSTORE_PASSWORD= -ml.distribution.KEYSTORE_FILE=asdc-client.jks +ml.distribution.KEYSTORE_FILE= ml.distribution.PASSWORD=Aa123456 ml.distribution.POLLING_INTERVAL=30 ml.distribution.POLLING_TIMEOUT=20 ml.distribution.USER=ci -ml.distribution.ARTIFACT_TYPES=MODEL_INVENTORY_PROFILE,MODEL_QUERY_SPEC,VNF_CATALOG +ml.distribution.ARTIFACT_TYPES=MODEL_QUERY_SPEC,TOSCA_CSAR + +# Disable ASDC polling & enable REST interface +ml.distribution.ASDC_CONNECTION_DISABLE=true +ml.debug.INGEST_SIMULATOR=enabled # Model Loader Client Configuration for the A&AI REST interface -ml.aai.BASE_URL= +ml.aai.BASE_URL=https://localhost:8443 ml.aai.MODEL_URL=/aai/v*/service-design-and-creation/models/model/ ml.aai.NAMED_QUERY_URL=/aai/v*/service-design-and-creation/named-queries/named-query/ ml.aai.VNF_IMAGE_URL=/aai/v*/service-design-and-creation/vnf-images diff --git a/src/test/resources/sdc_test/model-loader.properties b/src/test/resources/sdc_test/model-loader.properties new file mode 100644 index 0000000..ee5c0ed --- /dev/null +++ b/src/test/resources/sdc_test/model-loader.properties @@ -0,0 +1,30 @@ +# Model Loader Distribution Client Configuration +ml.distribution.ACTIVE_SERVER_TLS_AUTH=false +ml.distribution.ASDC_ADDRESS=localhost:8443 +ml.distribution.MSG_BUS_ADDRESSES=localhost +ml.distribution.CONSUMER_GROUP=aai-ml-group-test +ml.distribution.CONSUMER_ID=aai-ml-id-test +ml.distribution.ENVIRONMENT_NAME=env +ml.distribution.KEYSTORE_PASSWORD= +ml.distribution.KEYSTORE_FILE= +ml.distribution.PASSWORD=Aa123456 +ml.distribution.POLLING_INTERVAL=30 +ml.distribution.POLLING_TIMEOUT=20 +ml.distribution.USER=ci +ml.distribution.ARTIFACT_TYPES=MODEL_QUERY_SPEC,TOSCA_CSAR + +# Model Loader Client Configuration for the A&AI REST interface +ml.aai.BASE_URL=https://localhost:8443 +ml.aai.MODEL_URL=/aai/v*/service-design-and-creation/models/model/ +ml.aai.NAMED_QUERY_URL=/aai/v*/service-design-and-creation/named-queries/named-query/ +ml.aai.VNF_IMAGE_URL=/aai/v*/service-design-and-creation/vnf-images +ml.aai.KEYSTORE_FILE=aai-client-cert.p12 +ml.aai.KEYSTORE_PASSWORD= +ml.aai.AUTH_USER=ModelLoader +ml.aai.AUTH_PASSWORD= + +# Model Loader Client Configuration for the Babel Service +ml.babel.BASE_URL= +ml.babel.GENERATE_ARTIFACTS_URL= +ml.babel.KEYSTORE_FILE= +ml.babel.KEYSTORE_PASSWORD= |