2 * ============LICENSE_START=======================================================
4 * ================================================================================
5 * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
6 * ================================================================================
7 * Licensed under the Apache License, Version 2.0 (the "License");
8 * you may not use this file except in compliance with the License.
9 * You may obtain a copy of the License at
11 * http://www.apache.org/licenses/LICENSE-2.0
13 * Unless required by applicable law or agreed to in writing, software
14 * distributed under the License is distributed on an "AS IS" BASIS,
15 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
16 * See the License for the specific language governing permissions and
17 * limitations under the License.
18 * ============LICENSE_END=========================================================
21 package org.openecomp.sdc.ci.tests.execute.service;
23 import static org.testng.AssertJUnit.assertTrue;
25 import java.io.IOException;
26 import java.util.ArrayList;
27 import java.util.HashMap;
28 import java.util.List;
31 import org.apache.http.HttpStatus;
32 import org.junit.Rule;
33 import org.junit.rules.TestName;
34 import org.openecomp.sdc.be.datatypes.enums.ComponentTypeEnum;
35 import org.openecomp.sdc.be.datatypes.enums.ResourceTypeEnum;
36 import org.openecomp.sdc.be.model.Resource;
37 import org.openecomp.sdc.be.model.User;
38 import org.openecomp.sdc.be.resources.data.auditing.AuditingActionEnum;
39 import org.openecomp.sdc.ci.tests.api.ComponentBaseTest;
40 import org.openecomp.sdc.ci.tests.api.Urls;
41 import org.openecomp.sdc.ci.tests.datatypes.ArtifactReqDetails;
42 import org.openecomp.sdc.ci.tests.datatypes.ComponentInstanceReqDetails;
43 import org.openecomp.sdc.ci.tests.datatypes.ResourceReqDetails;
44 import org.openecomp.sdc.ci.tests.datatypes.ServiceReqDetails;
45 import org.openecomp.sdc.ci.tests.datatypes.enums.ArtifactTypeEnum;
46 import org.openecomp.sdc.ci.tests.datatypes.enums.LifeCycleStatesEnum;
47 import org.openecomp.sdc.ci.tests.datatypes.enums.UserRoleEnum;
48 import org.openecomp.sdc.ci.tests.datatypes.http.HttpRequest;
49 import org.openecomp.sdc.ci.tests.datatypes.http.RestResponse;
50 import org.openecomp.sdc.ci.tests.utils.general.AtomicOperationUtils;
51 import org.openecomp.sdc.ci.tests.utils.general.ElementFactory;
52 import org.openecomp.sdc.ci.tests.utils.general.FileUtils;
53 import org.openecomp.sdc.ci.tests.utils.rest.ArtifactRestUtils;
54 import org.openecomp.sdc.ci.tests.utils.rest.ComponentInstanceRestUtils;
55 import org.openecomp.sdc.ci.tests.utils.rest.LifecycleRestUtils;
56 import org.openecomp.sdc.ci.tests.utils.rest.ResourceRestUtils;
57 import org.openecomp.sdc.ci.tests.utils.rest.ResponseParser;
58 import org.openecomp.sdc.ci.tests.utils.rest.ServiceRestUtils;
59 import org.openecomp.sdc.common.api.Constants;
60 import org.openecomp.sdc.common.datastructure.AuditingFieldsKeysEnum;
61 import org.openecomp.sdc.common.datastructure.Wrapper;
62 import org.testng.AssertJUnit;
63 import org.testng.annotations.BeforeMethod;
64 import org.testng.annotations.Test;
66 import com.google.gson.JsonArray;
67 import com.google.gson.JsonElement;
69 import fj.data.Either;
71 public class GetComponentAuditApiTest extends ComponentBaseTest {
73 public static final String SERVICES_API = "services";
74 public static final String RESOURCES_API = "resources";
76 protected User sdncAdminUser;
77 protected User sdncDesignerUser;
78 protected User sdncTesterUser;
81 public static TestName name = new TestName();
83 public GetComponentAuditApiTest() {
84 super(name, GetComponentAuditApiTest.class.getName());
87 // in case tests fail, run this method as test to create mapping in ES
88 public void updateElasticSearchMapping() throws IOException {
89 Either<String, Exception> fileContentUTF8 = FileUtils
90 .getFileContentUTF8("src\\test\\resources\\CI\\other\\mapping.json");
91 AssertJUnit.assertTrue(fileContentUTF8.isLeft());
93 final String ES_TEMPLATE_URL = "http://%s:%s/_template/audit_template";
94 String url = String.format(ES_TEMPLATE_URL, config.getEsHost(), config.getEsPort());
96 RestResponse sendHttpPost = new HttpRequest().sendHttpPost(url, fileContentUTF8.left().value(), null);
97 AssertJUnit.assertTrue(sendHttpPost.getErrorCode() == HttpStatus.SC_OK);
102 sdncAdminUser = ElementFactory.getDefaultUser(UserRoleEnum.ADMIN);
103 sdncDesignerUser = ElementFactory.getDefaultUser(UserRoleEnum.DESIGNER);
104 sdncTesterUser = ElementFactory.getDefaultUser(UserRoleEnum.TESTER);
110 public void testServiceAuditCertifiedVersion() throws Exception {
112 ServiceReqDetails serviceDetails = ElementFactory.getDefaultService();
113 Wrapper<String> versionZeroOneIDWrapper = new Wrapper<String>(),
114 versionZeroTwoIDWrapper = new Wrapper<String>();
116 createBasicServiceForAudit(versionZeroOneIDWrapper, versionZeroTwoIDWrapper, serviceDetails, true);
117 // First Certification
119 LifecycleRestUtils.certifyService(serviceDetails);
120 // LCSbaseTest.certifyService(serviceDetails);
121 AssertJUnit.assertTrue(serviceDetails.getVersion().equals("1.0"));
123 // Second Certification
124 increaseServiceVersion(serviceDetails, "1.1");
125 increaseServiceVersion(serviceDetails, "1.2");
126 increaseServiceVersion(serviceDetails, "1.3");
127 increaseServiceVersion(serviceDetails, "1.4");
128 LifecycleRestUtils.certifyService(serviceDetails);
129 AssertJUnit.assertTrue(serviceDetails.getVersion().equals("2.0"));
130 String certifiedId = serviceDetails.getUniqueId();
131 LifecycleRestUtils.changeServiceState(serviceDetails, sdncDesignerUser, LifeCycleStatesEnum.CHECKOUT);
132 LifecycleRestUtils.changeServiceState(serviceDetails, sdncDesignerUser, LifeCycleStatesEnum.CHECKIN);
134 JsonElement element = getAuditJson(SERVICES_API, certifiedId);
135 // audits kept: 5*check ins + 4*check outs + 2*artifact payload
136 // updates(tosca) + certification request + certification start +
137 // certification success
138 // + 3 A&AI(ArtifactDelete, ArtifactUpload, ArtifactUpdate)
139 List<String> actions = new ArrayList<>();
140 JsonArray jsonArray = element.getAsJsonArray();
141 for( int i =0 ; i < jsonArray.size(); i++){
142 actions.add(jsonArray.get(i).getAsJsonObject().get(AuditingFieldsKeysEnum.AUDIT_ACTION.getDisplayName()).getAsString());
144 long checkinCount = actions.stream().filter( e -> e.equals(AuditingActionEnum.CHECKIN_RESOURCE.getName())).count();
145 assertTrue(checkinCount == 5);
147 long checkOutCount = actions.stream().filter( e -> e.equals(AuditingActionEnum.CHECKOUT_RESOURCE.getName())).count();
148 assertTrue(checkOutCount == 4);
150 long certificationRequestCount = actions.stream().filter( e -> e.equals(AuditingActionEnum.CERTIFICATION_REQUEST_RESOURCE.getName())).count();
151 assertTrue(certificationRequestCount == 1);
153 long certificationStartCount = actions.stream().filter( e -> e.equals(AuditingActionEnum.START_CERTIFICATION_RESOURCE.getName())).count();
154 assertTrue(certificationStartCount == 1);
156 long certificationSuccessCount = actions.stream().filter( e -> e.equals(AuditingActionEnum.CERTIFICATION_SUCCESS_RESOURCE.getName())).count();
157 assertTrue(certificationSuccessCount == 1);
162 protected void certifyResource(ResourceReqDetails defaultResource) throws IOException {
163 RestResponse response = LifecycleRestUtils.changeResourceState(defaultResource, sdncDesignerUser,
164 LifeCycleStatesEnum.CERTIFICATIONREQUEST);
165 AssertJUnit.assertTrue(response.getErrorCode() == HttpStatus.SC_OK);
166 response = LifecycleRestUtils.changeResourceState(defaultResource, sdncTesterUser,
167 LifeCycleStatesEnum.STARTCERTIFICATION);
168 AssertJUnit.assertTrue(response.getErrorCode() == HttpStatus.SC_OK);
169 response = LifecycleRestUtils.changeResourceState(defaultResource, sdncTesterUser, LifeCycleStatesEnum.CERTIFY);
170 AssertJUnit.assertTrue(response.getErrorCode() == HttpStatus.SC_OK);
173 protected JsonElement getAuditJson(String componentType, String componentId) throws IOException {
174 Map<String, String> headers = new HashMap<String, String>() {
176 put(Constants.USER_ID_HEADER, UserRoleEnum.ADMIN.getUserId());
179 String url = String.format(Urls.GET_COMPONENT_AUDIT_RECORDS, config.getCatalogBeHost(),
180 config.getCatalogBePort(), componentType, componentId);
182 RestResponse httpSendGet = new HttpRequest().httpSendGet(url, headers);
183 AssertJUnit.assertTrue(httpSendGet.getErrorCode() == HttpStatus.SC_OK);
184 JsonElement element = ResponseParser.parseToObject(httpSendGet.getResponse(), JsonElement.class);
185 AssertJUnit.assertTrue(element.isJsonArray());
189 protected void createBasicServiceForAudit(Wrapper<String> versionZeroOneIDWrapper,
190 Wrapper<String> versionZeroTwoIDWrapper, ServiceReqDetails serviceDetails, Boolean withResInst)
193 User designerUser = sdncDesignerUser;
195 RestResponse response = ServiceRestUtils.createService(serviceDetails, designerUser);
196 AssertJUnit.assertTrue(response.getErrorCode() == HttpStatus.SC_CREATED);
197 versionZeroOneIDWrapper.setInnerElement(serviceDetails.getUniqueId());
200 Resource resourceObj = AtomicOperationUtils
201 .createResourceByType(ResourceTypeEnum.VFC, UserRoleEnum.DESIGNER, true).left().value();
202 AtomicOperationUtils.uploadArtifactByType(ArtifactTypeEnum.HEAT, resourceObj, UserRoleEnum.DESIGNER, true,
204 AtomicOperationUtils.changeComponentState(resourceObj, UserRoleEnum.DESIGNER, LifeCycleStatesEnum.CERTIFY,
206 ResourceReqDetails resource = new ResourceReqDetails(resourceObj);
207 ComponentInstanceReqDetails resourceInstanceReqDetails = ElementFactory.getDefaultComponentInstance();
208 resourceInstanceReqDetails.setComponentUid(resource.getUniqueId());
209 ComponentInstanceRestUtils.createComponentInstance(resourceInstanceReqDetails, sdncDesignerUser,
210 serviceDetails.getUniqueId(), ComponentTypeEnum.SERVICE);
212 // ServiceUtils.createCertResourceWithDeploymentArt(serviceDetails,
216 response = LifecycleRestUtils.changeServiceState(serviceDetails, designerUser, LifeCycleStatesEnum.CHECKIN);
217 AssertJUnit.assertTrue(response.getErrorCode() == HttpStatus.SC_OK);
218 AssertJUnit.assertTrue(serviceDetails.getVersion().equals("0.1"));
220 response = LifecycleRestUtils.changeServiceState(serviceDetails, designerUser, LifeCycleStatesEnum.CHECKOUT);
221 AssertJUnit.assertTrue(response.getErrorCode() == HttpStatus.SC_OK);
222 // ServiceUtils.addServiceDeploymentArtifact(serviceDetails.getUniqueId(),
224 versionZeroTwoIDWrapper.setInnerElement(serviceDetails.getUniqueId());
225 AssertJUnit.assertTrue(serviceDetails.getVersion().equals("0.2"));
226 response = LifecycleRestUtils.changeServiceState(serviceDetails, designerUser, LifeCycleStatesEnum.CHECKIN);
227 AssertJUnit.assertTrue(response.getErrorCode() == HttpStatus.SC_OK);
229 increaseServiceVersion(serviceDetails, "0.3");
231 increaseServiceVersion(serviceDetails, "0.4");
233 increaseServiceVersion(serviceDetails, "0.5");
237 protected void increaseServiceVersion(ServiceReqDetails serviceDetails, String excpectedVersion) throws Exception {
238 RestResponse response = LifecycleRestUtils.changeServiceState(serviceDetails, sdncDesignerUser,
239 LifeCycleStatesEnum.CHECKOUT);
240 AssertJUnit.assertTrue(response.getErrorCode() == HttpStatus.SC_OK);
241 AssertJUnit.assertTrue(serviceDetails.getVersion().equals(excpectedVersion));
242 response = LifecycleRestUtils.changeServiceState(serviceDetails, sdncDesignerUser, LifeCycleStatesEnum.CHECKIN);
243 AssertJUnit.assertTrue(response.getErrorCode() == HttpStatus.SC_OK);
246 protected void createBasicResourceForAudit(Wrapper<String> versionOnePointTwoIDWrapper,
247 ResourceReqDetails defaultResource) throws Exception {
249 RestResponse response = ResourceRestUtils.createResource(defaultResource, sdncDesignerUser);
250 AssertJUnit.assertTrue(response.getErrorCode() == HttpStatus.SC_CREATED);
252 // ArtifactDefinition artifactDef = new
253 // ArtifactUtils().constructDefaultArtifactInfo();
254 // response = resourceUtils.add_artifact(defaultResource,
255 // sdncDesignerUser, defaultResource.getVersion(), artifactDef);
256 // assertTrue(response.getErrorCode() == HttpStatus.SC_OK);
258 ArtifactReqDetails heatArtifactDetails = ElementFactory
259 .getDefaultDeploymentArtifactForType(ArtifactTypeEnum.HEAT.getType());
260 response = ArtifactRestUtils.addInformationalArtifactToResource(heatArtifactDetails, sdncDesignerUser,
261 defaultResource.getUniqueId());
262 AssertJUnit.assertTrue("add HEAT artifact to resource request returned status:" + response.getErrorCode(),
263 response.getErrorCode() == 200);
265 response = LifecycleRestUtils.changeResourceState(defaultResource, sdncDesignerUser,
266 LifeCycleStatesEnum.CHECKIN);
268 increaseResourceVersion(defaultResource, "0.2");
270 increaseResourceVersion(defaultResource, "0.3");
272 increaseResourceVersion(defaultResource, "0.4");
274 increaseResourceVersion(defaultResource, "0.5");
276 certifyResource(defaultResource);
277 AssertJUnit.assertTrue(response.getErrorCode() == HttpStatus.SC_OK);
278 AssertJUnit.assertTrue(defaultResource.getVersion().equals("1.0"));
280 increaseResourceVersion(defaultResource, "1.1");
282 increaseResourceVersion(defaultResource, "1.2");
283 versionOnePointTwoIDWrapper.setInnerElement(defaultResource.getUniqueId());
285 increaseResourceVersion(defaultResource, "1.3");
287 increaseResourceVersion(defaultResource, "1.4");
291 protected void increaseResourceVersion(ResourceReqDetails defaultResource, String expectedVersion)
293 RestResponse response = LifecycleRestUtils.changeResourceState(defaultResource, sdncDesignerUser,
294 LifeCycleStatesEnum.CHECKOUT);
295 AssertJUnit.assertTrue(response.getErrorCode() == HttpStatus.SC_OK);
296 AssertJUnit.assertTrue(defaultResource.getVersion().equals(expectedVersion));
297 response = LifecycleRestUtils.changeResourceState(defaultResource, sdncDesignerUser,
298 LifeCycleStatesEnum.CHECKIN);
299 AssertJUnit.assertTrue(response.getErrorCode() == HttpStatus.SC_OK);
303 public void testServiceAuditLastUncertifiedVersion() throws Exception {
305 ServiceReqDetails serviceDetails = ElementFactory.getDefaultService();
306 Wrapper<String> versionZeroOneIDWrapper = new Wrapper<String>(),
307 versionZeroTwoIDWrapper = new Wrapper<String>();
309 createBasicServiceForAudit(versionZeroOneIDWrapper, versionZeroTwoIDWrapper, serviceDetails, false);
311 JsonElement element = getAuditJson(SERVICES_API, versionZeroTwoIDWrapper.getInnerElement());
313 assertTrue(element.getAsJsonArray().size() == 3);
318 public void testServiceAuditFirstUncertifiedVersion() throws Exception {
320 ServiceReqDetails serviceDetails = ElementFactory.getDefaultService();
321 Wrapper<String> versionZeroOneIDWrapper = new Wrapper<String>(),
322 versionZeroTwoIDWrapper = new Wrapper<String>();
324 createBasicServiceForAudit(versionZeroOneIDWrapper, versionZeroTwoIDWrapper, serviceDetails, false);
326 JsonElement element = getAuditJson(SERVICES_API, versionZeroOneIDWrapper.getInnerElement());
328 assertTrue(element.getAsJsonArray().size() == 3);
333 public void testResourceAuditUncertifiedVersion() throws Exception {
335 ResourceReqDetails defaultResource = ElementFactory.getDefaultResource();
336 Wrapper<String> versionOnePointTwoIDWrapper = new Wrapper<String>();
338 createBasicResourceForAudit(versionOnePointTwoIDWrapper, defaultResource);
340 JsonElement element = getAuditJson(RESOURCES_API, versionOnePointTwoIDWrapper.getInnerElement());
342 assertTrue(element.getAsJsonArray().size() == 3);
347 public void testResourceAuditCertifiedVersion() throws Exception {
349 ResourceReqDetails defaultResource = ElementFactory.getDefaultResource();
350 Wrapper<String> versionOnePointTwoIDWrapper = new Wrapper<String>();
352 createBasicResourceForAudit(versionOnePointTwoIDWrapper, defaultResource);
354 certifyResource(defaultResource);
355 assertTrue(defaultResource.getVersion().equals("2.0"));
356 String certifiedId = defaultResource.getUniqueId();
358 increaseResourceVersion(defaultResource, "2.1");
360 increaseResourceVersion(defaultResource, "2.2");
362 JsonElement element = getAuditJson(RESOURCES_API, certifiedId);
364 assertTrue(element.getAsJsonArray().size() == 13);