2 * ============LICENSE_START=======================================================
4 * ================================================================================
5 * Copyright © 2017-2018 AT&T Intellectual Property. All rights reserved.
6 * Copyright © 2017-2018 European Software Marketing Ltd.
7 * ================================================================================
8 * Licensed under the Apache License, Version 2.0 (the "License");
9 * you may not use this file except in compliance with the License.
10 * You may obtain a copy of the License at
12 * http://www.apache.org/licenses/LICENSE-2.0
14 * Unless required by applicable law or agreed to in writing, software
15 * distributed under the License is distributed on an "AS IS" BASIS,
16 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
17 * See the License for the specific language governing permissions and
18 * limitations under the License.
19 * ============LICENSE_END=========================================================
21 package org.onap.aai.modelloader.notification;
23 import static org.hamcrest.CoreMatchers.is;
24 import static org.hamcrest.MatcherAssert.assertThat;
25 import static org.mockito.ArgumentMatchers.any;
26 import static org.mockito.ArgumentMatchers.eq;
27 import static org.mockito.Mockito.when;
28 import static org.onap.aai.modelloader.fixture.NotificationDataFixtureBuilder.getNotificationDataWithCatalogFile;
29 import static org.onap.aai.modelloader.fixture.NotificationDataFixtureBuilder.getNotificationDataWithOneOfEach;
31 import java.io.IOException;
32 import java.util.ArrayList;
33 import java.util.List;
34 import java.util.Properties;
36 import org.junit.jupiter.api.AfterEach;
37 import org.junit.jupiter.api.BeforeEach;
38 import org.junit.jupiter.api.Test;
39 import org.mockito.Mock;
40 import org.mockito.Mockito;
41 import org.mockito.MockitoAnnotations;
42 import org.onap.aai.babel.service.data.BabelArtifact;
43 import org.onap.aai.modelloader.config.ModelLoaderConfig;
44 import org.onap.aai.modelloader.entity.Artifact;
45 import org.onap.aai.modelloader.entity.catalog.VnfCatalogArtifact;
46 import org.onap.aai.modelloader.entity.catalog.VnfCatalogArtifactHandler;
47 import org.onap.aai.modelloader.entity.model.BabelArtifactParsingException;
48 import org.onap.aai.modelloader.entity.model.ModelArtifactHandler;
49 import org.onap.aai.modelloader.extraction.InvalidArchiveException;
50 import org.onap.aai.modelloader.fixture.NotificationDataFixtureBuilder;
51 import org.onap.aai.modelloader.restclient.AaiRestClient;
52 import org.onap.aai.modelloader.service.ArtifactDeploymentManager;
53 import org.onap.aai.modelloader.util.ArtifactTestUtils;
54 import org.onap.sdc.api.notification.INotificationData;
55 import org.springframework.web.client.RestTemplate;
58 * Tests {@link ArtifactDeploymentManager}.
60 public class TestArtifactDeploymentManager {
62 private static final String CONFIG_FILE = "model-loader.properties";
63 private static final String SHOULD_HAVE_RETURNED_FALSE = "This should have returned false";
65 private Properties configProperties;
66 private ArtifactDeploymentManager manager;
68 @Mock private ModelArtifactHandler modelArtifactHandlerMock;
69 @Mock private VnfCatalogArtifactHandler vnfCatalogArtifactHandlerMock;
72 public void setup() throws IOException {
73 MockitoAnnotations.openMocks(this);
74 configProperties = new Properties();
75 configProperties.load(this.getClass().getClassLoader().getResourceAsStream(CONFIG_FILE));
77 ModelLoaderConfig modelLoaderConfig = new ModelLoaderConfig(configProperties, null);
78 AaiRestClient aaiRestClient = new AaiRestClient(modelLoaderConfig, new RestTemplate());
79 manager = new ArtifactDeploymentManager(modelArtifactHandlerMock, vnfCatalogArtifactHandlerMock, aaiRestClient);
83 public void tearDown() {
84 configProperties = null;
85 modelArtifactHandlerMock = null;
86 vnfCatalogArtifactHandlerMock = null;
91 public void deploy_csarDeploymentsFailed() throws IOException, BabelArtifactParsingException {
92 INotificationData data = NotificationDataFixtureBuilder.getNotificationDataWithToscaCsarFile();
93 byte[] xml = new ArtifactTestUtils().loadResource("convertedYmls/AAI-SCP-Test-VSP-resource-1.0.xml");
94 List<BabelArtifact> toscaArtifacts = setupTest(xml, data);
95 List<Artifact> modelArtifacts = new BabelArtifactConverter().convertToModel(toscaArtifacts);
97 when(modelArtifactHandlerMock.pushArtifacts(eq(modelArtifacts), eq(data.getDistributionID()), any(), any()))
100 assertThat(SHOULD_HAVE_RETURNED_FALSE, manager.deploy(data, modelArtifacts, new ArrayList<>()), is(false));
102 Mockito.verify(modelArtifactHandlerMock).pushArtifacts(eq(modelArtifacts), eq(data.getDistributionID()), any(),
104 Mockito.verify(vnfCatalogArtifactHandlerMock, Mockito.never()).pushArtifacts(eq(modelArtifacts),
105 eq(data.getDistributionID()), any(), any());
106 Mockito.verify(modelArtifactHandlerMock).rollback(eq(new ArrayList<Artifact>()), eq(data.getDistributionID()),
108 Mockito.verify(vnfCatalogArtifactHandlerMock, Mockito.never()).rollback(eq(new ArrayList<Artifact>()),
109 eq(data.getDistributionID()), any());
112 private List<BabelArtifact> setupTest(byte[] xml, INotificationData data) throws IOException {
113 List<BabelArtifact> toscaArtifacts = new ArrayList<>();
114 org.onap.sdc.api.notification.IArtifactInfo artifactInfo = data.getServiceArtifacts().get(0);
116 BabelArtifact xmlArtifact =
117 new BabelArtifact(artifactInfo.getArtifactName(), BabelArtifact.ArtifactType.MODEL, new String(xml));
118 toscaArtifacts.add(xmlArtifact);
120 return toscaArtifacts;
124 public void deploy_catalogDeploymentsFailed()
125 throws IOException, BabelArtifactParsingException, InvalidArchiveException {
126 INotificationData data = getNotificationDataWithCatalogFile();
128 List<org.onap.aai.modelloader.entity.Artifact> catalogFiles = new ArrayList<>();
129 catalogFiles.add(new VnfCatalogArtifact("Some catalog content"));
131 when(modelArtifactHandlerMock.pushArtifacts(any(), any(), any(), any())).thenReturn(true);
132 when(vnfCatalogArtifactHandlerMock.pushArtifacts(eq(catalogFiles), eq(data.getDistributionID()), any(), any()))
135 assertThat(SHOULD_HAVE_RETURNED_FALSE, manager.deploy(data, new ArrayList<>(), catalogFiles), is(false));
137 Mockito.verify(modelArtifactHandlerMock).pushArtifacts(eq(new ArrayList<Artifact>()),
138 eq(data.getDistributionID()), any(), any());
139 Mockito.verify(vnfCatalogArtifactHandlerMock).pushArtifacts(eq(catalogFiles), eq(data.getDistributionID()),
141 Mockito.verify(modelArtifactHandlerMock).rollback(eq(new ArrayList<Artifact>()), eq(data.getDistributionID()),
143 Mockito.verify(vnfCatalogArtifactHandlerMock).rollback(eq(new ArrayList<Artifact>()),
144 eq(data.getDistributionID()), any());
148 public void testNoArtifactsDeployed() throws IOException, BabelArtifactParsingException, InvalidArchiveException {
149 doFailedCombinedTests(false, false);
153 public void testModelsNotDeployed() throws IOException, BabelArtifactParsingException, InvalidArchiveException {
154 doFailedCombinedTests(false, true);
158 public void testCatalogsNotDeployed() throws IOException, BabelArtifactParsingException, InvalidArchiveException {
159 doFailedCombinedTests(true, false);
162 private void doFailedCombinedTests(boolean modelsDeployed, boolean catalogsDeployed)
163 throws IOException, BabelArtifactParsingException, InvalidArchiveException {
164 INotificationData data = getNotificationDataWithOneOfEach();
165 byte[] xml = new ArtifactTestUtils().loadResource("convertedYmls/AAI-SCP-Test-VSP-resource-1.0.xml");
166 List<BabelArtifact> toscaArtifacts = setupTest(xml, data);
167 List<Artifact> modelArtifacts = new BabelArtifactConverter().convertToModel(toscaArtifacts);
169 List<org.onap.aai.modelloader.entity.Artifact> catalogFiles = new ArrayList<>();
170 catalogFiles.add(new VnfCatalogArtifact("Some catalog content"));
172 when(vnfCatalogArtifactHandlerMock.pushArtifacts(eq(catalogFiles), eq(data.getDistributionID()), any(), any()))
173 .thenReturn(catalogsDeployed);
174 when(modelArtifactHandlerMock.pushArtifacts(eq(modelArtifacts), eq(data.getDistributionID()), any(), any()))
175 .thenReturn(modelsDeployed);
177 assertThat(SHOULD_HAVE_RETURNED_FALSE, manager.deploy(data, modelArtifacts, catalogFiles), is(false));
179 // Catalog artifacts are only pushed if models are successful.
180 Mockito.verify(modelArtifactHandlerMock).pushArtifacts(eq(modelArtifacts), eq(data.getDistributionID()), any(),
182 if (modelsDeployed) {
183 Mockito.verify(vnfCatalogArtifactHandlerMock).pushArtifacts(eq(catalogFiles), eq(data.getDistributionID()),
187 if (modelsDeployed && catalogsDeployed) {
188 Mockito.verify(modelArtifactHandlerMock, Mockito.never()).rollback(any(), any(), any());
189 Mockito.verify(vnfCatalogArtifactHandlerMock, Mockito.never()).rollback(any(), any(), any());
191 if (modelsDeployed) {
192 Mockito.verify(modelArtifactHandlerMock).rollback(eq(new ArrayList<Artifact>()),
193 eq(data.getDistributionID()), any());
194 Mockito.verify(vnfCatalogArtifactHandlerMock).rollback(eq(new ArrayList<Artifact>()),
195 eq(data.getDistributionID()), any());
197 Mockito.verify(modelArtifactHandlerMock).rollback(eq(new ArrayList<Artifact>()),
198 eq(data.getDistributionID()), any());
199 Mockito.verify(vnfCatalogArtifactHandlerMock, Mockito.never()).rollback(any(), any(), any());
205 * Deploy both models and VNF images.
207 * @throws IOException
208 * @throws BabelArtifactParsingException
209 * @throws InvalidArchiveException
212 public void testDeploySuccess() throws IOException, BabelArtifactParsingException, InvalidArchiveException {
213 INotificationData data = getNotificationDataWithOneOfEach();
214 byte[] xml = new ArtifactTestUtils().loadResource("convertedYmls/AAI-SCP-Test-VSP-resource-1.0.xml");
215 List<BabelArtifact> toscaArtifacts = setupTest(xml, data);
216 List<Artifact> modelArtifacts = new BabelArtifactConverter().convertToModel(toscaArtifacts);
218 List<org.onap.aai.modelloader.entity.Artifact> catalogFiles = new ArrayList<>();
219 catalogFiles.add(new VnfCatalogArtifact("Some catalog content"));
221 when(vnfCatalogArtifactHandlerMock.pushArtifacts(eq(catalogFiles), eq(data.getDistributionID()), any(), any()))
223 when(modelArtifactHandlerMock.pushArtifacts(eq(modelArtifacts), eq(data.getDistributionID()), any(), any()))
226 assertThat(manager.deploy(data, modelArtifacts, catalogFiles), is(true));
228 Mockito.verify(vnfCatalogArtifactHandlerMock).pushArtifacts(eq(catalogFiles), eq(data.getDistributionID()),
230 Mockito.verify(modelArtifactHandlerMock).pushArtifacts(eq(modelArtifacts), eq(data.getDistributionID()), any(),
232 Mockito.verify(modelArtifactHandlerMock, Mockito.never()).rollback(any(), any(), any());
233 Mockito.verify(vnfCatalogArtifactHandlerMock, Mockito.never()).rollback(any(), any(), any());